add support for live stream jobs

Alex Schworer · Alex Schworer · commit 7907cfd2c6c0 · 2013-05-18T18:28:46.000-07:00
diff --git a/zencoder/core.py b/zencoder/core.py
@@ -297,17 +297,16 @@ def __init__(self, *args, **kwargs):
         kwargs['resource_name'] = 'jobs'
         super(Job, self).__init__(*args, **kwargs)
 
-    def create(self, input, outputs=None, options=None):
+    def create(self, input=None, live_stream=False, outputs=None, options=None):
         """
-        Creates a job
+        Creates a transcoding job.
 
         @param input: the input url as string
+        @param live_stream: starts an RTMP Live Stream
         @param outputs: a list of output dictionaries
         @param options: a dictionary of job options
         """
-        as_test = int(self.test)
-
-        data = {"input": input, "test": as_test}
+        data = {"input": input, "test": self.test}
         if outputs:
             data['outputs'] = outputs
 
@@ -364,6 +363,10 @@ def delete(self, job_id):
         """
         return self.cancel(job_id)
 
+    def finish(self, job_id):
+        """ Finishes the live stream for `job_id`. """
+        return self.put(self.base_url + '/%s/finish' % str(job_id))
+
 class Report(HTTPBackend):
     def __init__(self, *args, **kwargs):
         """
@@ -404,3 +407,4 @@ def minutes(self, start_date=None, end_date=None, grouping=None):
 
         url = self.base_url + '/minutes'
         return self.get(url, data=data)
+
