Code formatting

Author: psevestre

saas-modules/temporal/src/main/java/com/baeldung/temporal/workflows/hello/HelloWorkflow.java

@@ -5,8 +5,6 @@
 
 @WorkflowInterface
 public interface HelloWorkflow {
-
     @WorkflowMethod
     String hello(String person);
-
 }

saas-modules/temporal/src/main/java/com/baeldung/temporal/workflows/hello/HelloWorkflowApplication.java

@@ -12,20 +12,18 @@ public class HelloWorkflowApplication {
     private static final String QUEUE_NAME = "say-hello-queue";
     private static final Logger log = LoggerFactory.getLogger(HelloWorkflowApplication.class);
 
-
     public static void main(String[] args) {
 
         log.info("Creating worker...");
-        WorkflowServiceStubs service = WorkflowServiceStubs.newLocalServiceStubs();
-        WorkflowClient client = WorkflowClient.newInstance(service);
+        var service = WorkflowServiceStubs.newLocalServiceStubs();
+        var client = WorkflowClient.newInstance(service);
         var factory = WorkerFactory.newInstance(client);
-        Worker worker = factory.newWorker(QUEUE_NAME);
+        var worker = factory.newWorker(QUEUE_NAME);
 
         log.info("Registering workflows and activities...");
         HelloWorkflowRegistrar.newInstance().register(worker);
 
         log.info("Starting worker...");
         factory.start();
-
     }
 }

saas-modules/temporal/src/main/java/com/baeldung/temporal/workflows/hello/HelloWorkflowImpl.java

@@ -15,10 +15,8 @@ public class HelloWorkflowImpl implements HelloWorkflow {
         .build()
     );
 
-
     @Override
     public String hello(String person) {
         return activity.sayHello(person);
     }
-
 }

saas-modules/temporal/src/test/java/com/baeldung/temporal/HelloWorkerUnitTest.java

@@ -4,14 +4,18 @@
 import com.baeldung.temporal.workflows.hello.HelloWorkflowRegistrar;
 import io.temporal.client.WorkflowClient;
 import io.temporal.client.WorkflowOptions;
+import io.temporal.serviceclient.WorkflowServiceStubs;
+import io.temporal.serviceclient.WorkflowServiceStubsOptions;
 import io.temporal.testing.TestWorkflowEnvironment;
 import io.temporal.worker.Worker;
+import io.temporal.workflow.Workflow;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.util.Optional;
 import java.util.UUID;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
@@ -34,6 +38,17 @@ public void startWorker() {
         worker = testEnv.newWorker(QUEUE_NAME);
         HelloWorkflowRegistrar.newInstance().register(worker);
         client = testEnv.getWorkflowClient();
+
+//        var serviceStubs = WorkflowServiceStubs.newServiceStubs(WorkflowServiceStubsOptions
+//          .newBuilder()
+//            .setTarget("localhost:7233")
+//            .setEnableKeepAlive(true)
+//            .setEnableHttps(false)
+//          .build());
+//
+//        client = WorkflowClient.newInstance(serviceStubs);
+
+        testEnv.start();
     }
 
     @AfterEach
@@ -42,10 +57,7 @@ public void stopWorker() {
     }
 
     @Test
-    void givenPerson_whenSayHello_thenSuccess() throws Exception {
-
-        // We must register all activities/worklows before starting the test environment
-        testEnv.start();
+    void givenPerson_whenSayHelloAsync_thenSuccess() throws Exception {
 
         // Create workflow stub wich allow us to create workflow instances
         var wfid = UUID.randomUUID().toString();
@@ -59,12 +71,33 @@ void givenPerson_whenSayHello_thenSuccess() throws Exception {
 
         // Invoke workflow asynchronously.
         var execution = WorkflowClient.start(workflow::hello,"Baeldung");
+        var workflowStub = client.newUntypedWorkflowStub(execution.getWorkflowId());
+
+        // Retrieve a CompletableFuture we can use to wait for the result.
+        var future = workflowStub.getResultAsync(String.class);
+        log.info("Waiting for workflow to complete...");
+        var result = future.get();
+        log.info("Workflow completed with result: {}", result);
+        assertEquals("Hello, Baeldung", result);
+    }
+
+    @Test
+    void givenPerson_whenSayHelloSync_thenSuccess() throws Exception {
 
-        // Create a blocking workflow using tbe execution's workflow id
-        var syncWorkflow = client.newWorkflowStub(HelloWorkflow.class,execution.getWorkflowId());
+        // Create workflow stub wich allow us to create workflow instances
+        var wfid = UUID.randomUUID().toString();
+        var workflow = client.newWorkflowStub(
+          HelloWorkflow.class,
+          WorkflowOptions.newBuilder()
+            .setTaskQueue(QUEUE_NAME)
+            .setWorkflowId(wfid)
+            .build()
+        );
 
+        // Invoke workflow synchronously.
+        var result = workflow.hello("Baeldung");
 
         // The sync workflow stub will block until it completes. Notice that the call argumento here is ignored!
-        assertEquals("Hello, Baeldung", syncWorkflow.hello("ignored"));
+        assertEquals("Hello, Baeldung", result);
     }
 }