Merge pull request #14 from aleksey-korolev/master

Add field pass_through to ZencoderJob

Author: drallgood

src/main/java/de/bitzeche/video/transcoding/zencoder/job/ZencoderJob.java

@@ -49,6 +49,14 @@ public class ZencoderJob {
 
     private List<ZencoderNotification> notifications = new ArrayList<ZencoderNotification>();
 
+    /**
+     * According to <a href="zencoder API documentation">https://app.zencoder.com/docs/api/encoding</a> pass_through is
+     * "Optional information to store alongside this job".<br/>
+     * When pass_through field is provided during job submission it becomes available in job notification
+     * callback from the service.
+     */
+    private String passThrough;
+
 
     public ZencoderJob(String inputPath) {
 		this.inputPath = inputPath;
@@ -92,6 +100,12 @@ public Document createXML() throws ParserConfigurationException {
 		download_connections.setTextContent("" + this.downloadConnections);
 		root.appendChild(download_connections);
 
+		if (getPassThrough() != null) {
+            Node passThroughNode = document.createElement("pass_through");
+            passThroughNode.setTextContent(this.getPassThrough());
+            root.appendChild(passThroughNode);
+        }
+
 		Node test = document.createElement("test");
 		test.setTextContent((this.isTest ? "1" : "0"));
 		root.appendChild(test);
@@ -163,7 +177,11 @@ public int getDownloadConnections() {
 		return downloadConnections;
 	}
 
-	public boolean isTest() {
+    public String getPassThrough() {
+        return passThrough;
+    }
+
+    public boolean isTest() {
 		return isTest;
 	}
 
@@ -198,4 +216,8 @@ public void addNotification(ZencoderNotification item) {
     public void deleteNotification(ZencoderNotification item) {
         this.notifications.remove(item);
     }
+
+    public void setPassThrough(String passThrough) {
+        this.passThrough = passThrough;
+    }
 }

src/test/java/de/bitzeche/video/transcoding/zencoder/test/ZencoderJobTest.java

@@ -45,9 +45,18 @@ public void testWithOptions() throws ParserConfigurationException {
 		job.setTest(true);
 		job.setPrivate(true);
 		job.setZencoderRegion(ZencoderRegion.ASIA);
-		
+		job.setPassThrough("user_id:100");
+
 		String doc = StringUtil.stripSpacesAndLineBreaksFrom(job.toString());
-		String expected = ("<?xmlversion=\"1.0\"encoding=\"UTF-8\"?><api-request><input>http://testpath/</input><region>asia</region><download_connections>10</download_connections><test>1</test><private>1</private></api-request>");
+		String expected = ("<?xmlversion=\"1.0\"encoding=\"UTF-8\"?>" +
+                "<api-request>" +
+                "<input>http://testpath/</input>" +
+                "<region>asia</region>" +
+                "<download_connections>10</download_connections>" +
+                "<pass_through>user_id:100</pass_through>" +
+                "<test>1</test>" +
+                "<private>1</private>" +
+                "</api-request>");
 		Assert.assertEquals(doc, expected);
 	}