Add live_stream kwarg to Job.create

Author: Alex Schworer

test/fixtures/job_create_live.json

@@ -0,0 +1,12 @@
+{
+  "stream_url": "rtmp://foo:1935/live",
+  "stream_name": "bar",
+  "outputs": [
+    {
+      "label": null,
+      "url": "https://zencoder-temp-storage-us-east-1.s3.amazonaws.com",
+      "id": 97931084
+    }
+  ],
+  "id": 47010105
+}

test/test_jobs.py

@@ -19,6 +19,16 @@ def test_job_create(self, post):
         self.assertTrue(resp.body['id'] > 0)
         self.assertEquals(len(resp.body['outputs']), 1)
 
+    @patch("requests.Session.post")
+    def test_job_create_list(self, post):
+        post.return_value = load_response(201, 'fixtures/job_create_live.json')
+
+        resp = self.zen.job.create(live_stream=True)
+
+        self.assertEquals(resp.code, 201)
+        self.assertTrue(resp.body['id'] > 0)
+        self.assertEquals(len(resp.body['outputs']), 1)
+
     @patch("requests.Session.get")
     def test_job_details(self, get):
         get.return_value = load_response(200, 'fixtures/job_details.json')

zencoder/core.py

@@ -242,7 +242,7 @@ def create(self, input=None, live_stream=False, outputs=None, options=None):
         Creates a transcoding job.
 
         @param input: the input url as string
-        @param live_stream: starts an RTMP Live Stream
+        @param live_stream: starts a Live Stream job (input must be None)
         @param outputs: a list of output dictionaries
         @param options: a dictionary of job options
         """
@@ -253,6 +253,9 @@ def create(self, input=None, live_stream=False, outputs=None, options=None):
         if options:
             data.update(options)
 
+        if live_stream:
+            data['live_stream'] = live_stream
+
         return self.post(self.base_url, body=json.dumps(data))
 
     def list(self, page=1, per_page=50):