Implement SSE

build.gradle

@@ -29,6 +29,8 @@ dependencies {
     implementation 'org.json:json:20231013'
     implementation 'commons-codec:commons-codec:1.15'
     implementation 'io.socket:socket.io-client:2.1.0'
+    implementation 'com.launchdarkly:okhttp-eventsource:4.1.1'
+
 
     testImplementation 'org.mock-server:mockserver-junit-jupiter-no-dependencies:5.15.0'
     testImplementation 'org.mockito:mockito-core:4.8.0'

examples/src/main/java/com/transloadit/examples/ImageResizer.java

@@ -22,7 +22,7 @@ public final class ImageResizer {
      * @param args
      */
     public static void main(String[] args) {
-        Transloadit transloadit = new Transloadit("TRANSLOADIT_KEY", "TRANSLOADIT_SECRET");
+        Transloadit transloadit = new Transloadit(System.getenv("TRANSLOADIT_KEY"), System.getenv("TRANSLOADIT_SECRET"));
 
         Map<String, Object> stepOptions = new HashMap<>();
         stepOptions.put("width", 75);
@@ -37,56 +37,65 @@ public static void main(String[] args) {
         assembly.setAssemblyListener(new AssemblyListener() {
             @Override
             public void onAssemblyFinished(AssemblyResponse response) {
-                JSONArray result = response.getStepResult("resize");
-                System.out.println("Resize result:");
-                for (int i = 0; i < result.length(); i++) {
-                    JSONObject item = result.getJSONObject(i);
-                    System.out.println(String.format("%s.%s: %s",
-                            item.getString("basename"), item.getString("ext"), item.getString("ssl_url")));
-                }
+                System.out.println("Assembly finished");
+                System.out.println("Result: " + response.getSslUrl());
             }
 
             @Override
             public void onError(Exception error) {
+                System.out.println("Error");
                 error.printStackTrace();
             }
 
             @Override
             public void onMetadataExtracted() {
-                System.out.println("Metadata Extracted");
+                System.out.println("Metadata extracted");
             }
 
             @Override
             public void onAssemblyUploadFinished() {
-                System.out.println("Assembly Upload complete, Executing ...");
-
+                System.out.println("Assembly Upload complete. Executing ...");
             }
 
             @Override
-            public void onFileUploadFinished(String fileName, JSONObject uploadInformation) {
+            public void onFileUploadFinished(JSONObject uploadInformation) {
+                String fileName = uploadInformation.getString("name");
                 System.out.println("File uploaded: " + fileName);
             }
 
             @Override
             public void onFileUploadPaused(String name) {
-
+                System.out.println("File upload paused: " + name);
             }
 
             @Override
             public void onFileUploadResumed(String name) {
+                System.out.println("File upload resumed: " + name);
 
             }
 
             @Override
             public void onFileUploadProgress(long uploadedBytes, long totalBytes) {
+                System.out.println("Uploaded " + uploadedBytes + "/" + totalBytes + " Bytes");
 
             }
 
             @Override
-            public void onAssemblyResultFinished(String stepName, JSONObject result) {
-
+            public void onAssemblyProgress(JSONObject progressPerOriginalFile) {
+                double combinedProgress = progressPerOriginalFile.getDouble("bytes_processed")
+                        / progressPerOriginalFile.getDouble("bytes_expected");
+                System.out.println("Assembly Execution Progress: " + combinedProgress);
             }
 
+            @Override
+            public void onAssemblyResultFinished(JSONArray result) {
+                String stepName = result.getString(0);
+                JSONObject resultData = result.getJSONObject(1);
+                System.out.println("\n ---- Step Result for Step: ---- ");
+                System.out.println("StepName: " + stepName + "\nFile: " + resultData.get("basename") + "."
+                        + resultData.get("ext"));
+                System.out.println("Download link: " + resultData.getString("ssl_url") + "\n");
+            }
         });
 
         try {

examples/src/main/java/com/transloadit/examples/KotlinExample.kt

@@ -20,7 +20,7 @@ class KotlinExample {
         @JvmStatic
         fun main(args: Array<String>) {
             // Setup the TransloaditClient and a new Assembly
-            val transloadit = Transloadit("TRANSLOADIT_KEY", "TRANSLOADIT_SECRET")
+            val transloadit = Transloadit(System.getenv("TRANSLOADIT_KEY"), System.getenv("TRANSLOADIT_SECRET"))
 
             val assembly: Assembly = transloadit.newAssembly()
             val kotlinExample = KotlinExample()
@@ -36,7 +36,8 @@ class KotlinExample {
                     JSONObject()
                     .put("text","Kotlin Example")
                     .put("color","#e61010")
-                    .put("font","Helvetica")
+                    .put("font","Ubuntu-Mono-Bold")
+                    // .put("font","Helvetica") You can put Helvetica here in order to test the error handling
                     .put("size", 15)
             )
 
@@ -47,7 +48,8 @@ class KotlinExample {
             // Add Assembly Listener to receive notifications.
             assembly.assemblyListener = object : AssemblyListener {
                 override fun onAssemblyFinished(response: AssemblyResponse?) {
-                    println("Download Results")
+                    println("--- Assembly finished ---")
+                    println("You can download the following result files:")
                     if (response != null) {
                        val resultJson: JSONArray = response.getStepResult("convert_and_text");
                         for ( i in 0 until resultJson.length()){
@@ -73,27 +75,31 @@ class KotlinExample {
                     println("Assembly uploaded, executing ...")
                 }
 
-                override fun onFileUploadFinished(fileName: String?, uploadInformation: JSONObject?) {
-                    println("File " + fileName + "has been uploaded successfully")
+                override fun onFileUploadFinished(uploadInformation: JSONObject?) {
+                    val fileName = uploadInformation!!.getString("name")
+                    println("File $fileName has been uploaded successfully")
                 }
 
                 override fun onFileUploadPaused(name: String?) {
-                    println("Upload" + name + "has been paused")
+                    println("Upload$name has been paused")
                 }
 
                 override fun onFileUploadResumed(name: String?) {
-                    println("Upload" + name + "has been resumed")
+                    println("Upload$name has been resumed")
                 }
 
                 override fun onFileUploadProgress(uploadedBytes: Long, totalBytes: Long) {
                     println("Uploaded $uploadedBytes from $totalBytes bytes")
                 }
 
-                override fun onAssemblyResultFinished(stepName: String?, result: JSONObject?) {
-                    println("Step Result available: ")
-                    println(
-                        """StepName: $stepName File: ${result!!.getString("basename")}.${result.getString("ext")}
-                    """.trimIndent())
+                override fun onAssemblyProgress(progress: JSONObject?) {
+                    println("Assembly Progress: $progress")
+                }
+
+
+                override fun onAssemblyResultFinished(result: JSONArray) {
+                    val stepName = result.getString(0)
+                    println("Step - $stepName - has a result")
                 }
             }
 

examples/src/main/java/com/transloadit/examples/MultiStepProcessing.java

@@ -28,7 +28,7 @@ public final class MultiStepProcessing {
      */
     public static void main(String[] args) throws FileNotFoundException {
         // New Transloadit Instance
-        Transloadit transloadit = new Transloadit("TRANSLOADIT_KEY", "TRANSLOADIT_SECRET");
+        Transloadit transloadit = new Transloadit(System.getenv("TRANSLOADIT_KEY"), System.getenv("TRANSLOADIT_SECRET"));
         Assembly assembly = transloadit.newAssembly();
 
         // Add Files and define Field name
@@ -87,14 +87,6 @@ public static void main(String[] args) throws FileNotFoundException {
             public void onAssemblyFinished(AssemblyResponse response) {
                 System.out.println("Assembly finished");
             }
-            public void printStatus(JSONArray status) {
-                for (int i = 0; i < status.length(); i++) {
-                    JSONObject obj = status.getJSONObject(i);
-                    System.out.printf(
-                            "Resulting file: %s %s, Download at:\n %s%n",
-                            obj.getString("basename"), obj.getString("ext"), obj.getString("ssl_url"));
-                }
-            }
 
             @Override
             public void onError(Exception error) {
@@ -113,7 +105,8 @@ public void onAssemblyUploadFinished() {
             }
 
             @Override
-            public void onFileUploadFinished(String fileName, JSONObject uploadInformation) {
+            public void onFileUploadFinished(JSONObject uploadInformation) {
+                String fileName = uploadInformation.getString("name");
                 System.out.println("File uploaded: " + fileName);
             }
 
@@ -135,11 +128,20 @@ public void onFileUploadProgress(long uploadedBytes, long totalBytes) {
             }
 
             @Override
-            public void onAssemblyResultFinished(String stepName, JSONObject result) {
+            public void onAssemblyProgress(JSONObject progressPerOriginalFile) {
+                double combinedProgress = progressPerOriginalFile.getDouble("bytes_processed")
+                        / progressPerOriginalFile.getDouble("bytes_expected");
+                System.out.println("Assembly Execution Progress: " + combinedProgress);
+            }
+
+            @Override
+            public void onAssemblyResultFinished(JSONArray result) {
+                String stepName = result.getString(0);
+                JSONObject resultData = result.getJSONObject(1);
                 System.out.println("\n ---- Step Result for Step: ---- ");
-                System.out.println("StepName: " + stepName + "\nFile: " + result.get("basename") + "."
-                        + result.get("ext"));
-                System.out.println("Download link: " + result.getString("ssl_url") + "\n");
+                System.out.println("StepName: " + stepName + "\nFile: " + resultData.get("basename") + "."
+                        + resultData.get("ext"));
+                System.out.println("Download link: " + resultData.getString("ssl_url") + "\n");
             }
         });
         try {
@@ -154,7 +156,6 @@ public void onAssemblyResultFinished(String stepName, JSONObject result) {
             Thread.sleep(3000);
             assembly.resumeUploads();
 
-            System.out.println("Assembly ID: " + assembly.getClientSideGeneratedAssemblyID());
          } catch (LocalOperationException | RequestException | InterruptedException e) {
             e.printStackTrace();
         }

examples/src/main/java/com/transloadit/examples/OverrideTemplate.java

@@ -35,7 +35,7 @@ public final class OverrideTemplate {
      * @param args
      */
     public static void main(String[] args) {
-        Transloadit transloadit = new Transloadit("TRANSLOADIT_KEY", "TRANSLOADIT_SECRET");
+        Transloadit transloadit = new Transloadit(System.getenv("TRANSLOADIT_KEY"), System.getenv("TRANSLOADIT_SECRET"));
 
         Map<String, Object> stepOptions = new HashMap<>();
         stepOptions.put("url", "https://transloadit.com/");
@@ -49,56 +49,66 @@ public static void main(String[] args) {
         assembly.setAssemblyListener(new AssemblyListener() {
             @Override
             public void onAssemblyFinished(AssemblyResponse response) {
-                JSONArray result = response.getStepResult("screenshot");
-                System.out.println("Resize result:");
-                for (int i = 0; i < result.length(); i++) {
-                    JSONObject item = result.getJSONObject(i);
-                    System.out.println(String.format("%s.%s: %s",
-                            item.getString("basename"), item.getString("ext"), item.getString("ssl_url")));
-                }
+                System.out.println("Assembly finished");
+                System.out.println("Result: " + response.json().getJSONObject("results")
+                        .getJSONArray("screenshot").getJSONObject(0).getString("ssl_url"));
             }
 
             @Override
             public void onError(Exception error) {
+                System.out.println("Error");
                 error.printStackTrace();
             }
 
             @Override
             public void onMetadataExtracted() {
-                System.out.println("Metadata Extracted");
+                System.out.println("Metadata extracted");
             }
 
             @Override
             public void onAssemblyUploadFinished() {
-                System.out.println("Assembly Upload complete, Executing ...");
-
+                System.out.println("Assembly Upload complete. Executing ...");
             }
 
             @Override
-            public void onFileUploadFinished(String fileName, JSONObject uploadInformation) {
+            public void onFileUploadFinished(JSONObject uploadInformation) {
+                String fileName = uploadInformation.getString("name");
                 System.out.println("File uploaded: " + fileName);
             }
 
             @Override
             public void onFileUploadPaused(String name) {
-
+                System.out.println("File upload paused: " + name);
             }
 
             @Override
             public void onFileUploadResumed(String name) {
+                System.out.println("File upload resumed: " + name);
 
             }
 
             @Override
             public void onFileUploadProgress(long uploadedBytes, long totalBytes) {
+                System.out.println("Uploaded " + uploadedBytes + "/" + totalBytes + " Bytes");
 
             }
 
             @Override
-            public void onAssemblyResultFinished(String stepName, JSONObject result) {
-
+            public void onAssemblyProgress(JSONObject progressPerOriginalFile) {
+                double combinedProgress = progressPerOriginalFile.getDouble("bytes_processed")
+                        / progressPerOriginalFile.getDouble("bytes_expected");
+                System.out.println("Assembly Execution Progress: " + combinedProgress);
             }
 
+            @Override
+            public void onAssemblyResultFinished(JSONArray result) {
+                String stepName = result.getString(0);
+                JSONObject resultData = result.getJSONObject(1);
+                System.out.println("\n ---- Step Result for Step: ---- ");
+                System.out.println("StepName: " + stepName + "\nFile: " + resultData.get("basename") + "."
+                        + resultData.get("ext"));
+                System.out.println("Download link: " + resultData.getString("ssl_url") + "\n");
+            }
         });
 
         try {

examples/src/main/java/com/transloadit/examples/TemplateExample.java

@@ -18,7 +18,7 @@ public final class TemplateExample {
      * @param args
      */
     public static void main(String[] args) {
-        Transloadit transloadit = new Transloadit("TRANSLOADIT_KEY", "TRANSLOADIT_SECRET");
+        Transloadit transloadit = new Transloadit(System.getenv("TRANSLOADIT_KEY"), System.getenv("TRANSLOADIT_SECRET"));
 
         Assembly assembly = transloadit.newAssembly();
         // set template id
@@ -34,9 +34,16 @@ public static void main(String[] args) {
             System.out.println("waiting for assembly to finish ...");
             while (!response.isFinished()) {
                 response = transloadit.getAssemblyByUrl(response.getSslUrl());
+
+                // wait for 500ms before checking again in order to avoid hitting the rate limit
+                try {
+                    Thread.sleep(500);
+                } catch (InterruptedException e) {
+                    throw new RuntimeException(e);
+                }
             }
 
-            String resultUrl = response.getStepResult("resize").getJSONObject(0).getString("ssl_url");
+            String resultUrl = response.getSslUrl();
             System.out.println("Here's your assembly result: " + resultUrl);
 
         } catch (RequestException | LocalOperationException e) {

examples/src/main/java/com/transloadit/examples/Watermarker.java

@@ -21,7 +21,7 @@ public final class Watermarker {
      * @param args
      */
     public static void main(String[] args) {
-        Transloadit transloadit = new Transloadit("TRANSLOADIT_KEY", "TRANSLOADIT_SECRET");
+        Transloadit transloadit = new Transloadit(System.getenv("TRANSLOADIT_KEY"), System.getenv("TRANSLOADIT_SECRET"));
 
         Map<String, Object> stepOptions = new HashMap<>();
         stepOptions.put("use", ":original");
@@ -43,6 +43,13 @@ public static void main(String[] args) {
             System.out.println("waiting for assembly to finish ...");
             while (!response.isFinished()) {
                 response = transloadit.getAssemblyByUrl(response.getSslUrl());
+
+                // wait for 500ms before checking again in order to avoid hitting the rate limit
+                try {
+                    Thread.sleep(500);
+                } catch (InterruptedException e) {
+                    throw new RuntimeException(e);
+                }
             }
 
             String resultUrl = response.getStepResult("encode").getJSONObject(0).getString("ssl_url");

examples/src/main/java/com/transloadit/examples/async/AsyncExample.java

@@ -16,7 +16,7 @@ public final class AsyncExample {
      * @param args
      */
     public static void main(String[] args) {
-        Transloadit transloadit = new Transloadit("TRANSLOADIT_KEY", "TRANSLOADIT_SECRET");
+        Transloadit transloadit = new Transloadit(System.getenv("TRANSLOADIT_KEY"), System.getenv("TRANSLOADIT_SECRET"));
 
         Map<String, Object> stepOptions = new HashMap<String, Object>();
         stepOptions.put("width", 75);

examples/src/main/java/com/transloadit/examples/async/AsyncPausePlayExample.java

@@ -16,7 +16,7 @@ public final class AsyncPausePlayExample {
      * @param args
      */
     public static void main(String[] args) {
-        Transloadit transloadit = new Transloadit("TRANSLOADIT_KEY", "TRANSLOADIT_SECRET");
+        Transloadit transloadit = new Transloadit(System.getenv("TRANSLOADIT_KEY"), System.getenv("TRANSLOADIT_SECRET"));
 
         Map<String, Object> stepOptions = new HashMap<String, Object>();
         stepOptions.put("width", 75);