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);
@@ -82,6 +82,11 @@ public void onFileUploadProgress(long uploadedBytes, long totalBytes) {
 
             }
 
+            @Override
+            public void onAssemblyProgress(double combinedProgress, JSONObject progressPerOriginalFile) {
+                System.out.printf("Assembly Execution Progress: %f", combinedProgress);
+            }
+
             @Override
             public void onAssemblyResultFinished(String stepName, JSONObject result) {
 

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)
             )
 
@@ -89,6 +90,11 @@ class KotlinExample {
                     println("Uploaded $uploadedBytes from $totalBytes bytes")
                 }
 
+                override fun onAssemblyProgress(combinedProgress: Double, progressPerOriginalFile: JSONObject?) {
+                    println("Assembly Progress: $combinedProgress")
+                    println("Progress per file: ${progressPerOriginalFile.toString()}")
+                }
+
                 override fun onAssemblyResultFinished(stepName: String?, result: JSONObject?) {
                     println("Step Result available: ")
                     println(

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
@@ -134,6 +134,11 @@ public void onFileUploadProgress(long uploadedBytes, long totalBytes) {
 
             }
 
+            @Override
+            public void onAssemblyProgress(double combinedProgress, JSONObject progressPerOriginalFile) {
+                System.out.println("Assembly Execution Progress: " + combinedProgress);
+            }
+
             @Override
             public void onAssemblyResultFinished(String stepName, JSONObject result) {
                 System.out.println("\n ---- Step Result for Step: ---- ");
@@ -154,7 +159,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/");
@@ -94,6 +94,11 @@ public void onFileUploadProgress(long uploadedBytes, long totalBytes) {
 
             }
 
+            @Override
+            public void onAssemblyProgress(double combinedProgress, JSONObject progressPerOriginalFile) {
+
+            }
+
             @Override
             public void onAssemblyResultFinished(String stepName, JSONObject result) {
 

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

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");

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);

settings.gradle

@@ -1,5 +1,5 @@
 // Uncomment following line if you want to use the local java-sdk
 // for the example instead of pulling the JARs from JCenter.
 // This is useful for debugging and testing new features.
-//include ':examples'
+// include ':examples'
 rootProject.name = 'transloadit'