add tests

Signed-off-by: Matheus Cruz <[email protected]>

Author: mcruzdev

sdk-tests/src/test/java/io/dapr/it/testcontainers/workflows/DaprWorkflowsIT.java

@@ -20,6 +20,7 @@
 import io.dapr.testcontainers.DaprContainer;
 import io.dapr.testcontainers.DaprLogLevel;
 import io.dapr.workflows.client.DaprWorkflowClient;
+import io.dapr.workflows.client.WorkflowInstanceStatus;
 import io.dapr.workflows.client.WorkflowRuntimeStatus;
 import io.dapr.workflows.client.WorkflowState;
 import io.dapr.workflows.runtime.WorkflowRuntime;
@@ -120,6 +121,27 @@ public void testWorkflows() throws Exception {
     assertEquals(instanceId, workflowOutput.getWorkflowId());
   }
 
+  @Test
+  public void testWorkflowsOldApi() throws Exception {
+    TestWorkflowPayload payload = new TestWorkflowPayload(new ArrayList<>());
+    String instanceId = workflowClient.scheduleNewWorkflow(TestWorkflow.class, payload);
+
+    workflowClient.waitForWorkflowStart(instanceId, Duration.ofSeconds(10), false);
+    workflowClient.raiseEvent(instanceId, "MoveForward", payload);
+
+    Duration timeout = Duration.ofSeconds(10);
+    WorkflowInstanceStatus workflowStatus = workflowClient.waitForInstanceCompletion(instanceId, timeout, true);
+
+    assertNotNull(workflowStatus);
+
+    TestWorkflowPayload workflowOutput = deserialize(workflowStatus.getSerializedOutput());
+
+    assertEquals(2, workflowOutput.getPayloads().size());
+    assertEquals("First Activity", workflowOutput.getPayloads().get(0));
+    assertEquals("Second Activity", workflowOutput.getPayloads().get(1));
+    assertEquals(instanceId, workflowOutput.getWorkflowId());
+  }
+
   @Test
   public void testSuspendAndResumeWorkflows() throws Exception {
     TestWorkflowPayload payload = new TestWorkflowPayload(new ArrayList<>());

sdk-tests/src/test/java/io/dapr/it/testcontainers/workflows/multiapp/WorkflowsMultiAppCallActivityIT.java

@@ -22,7 +22,7 @@
 import io.dapr.workflows.client.WorkflowInstanceStatus;
 import io.dapr.workflows.client.WorkflowRuntimeStatus;
 import io.dapr.config.Properties;
-import net.bytebuddy.utility.dispatcher.JavaDispatcher;
+import io.dapr.workflows.client.WorkflowState;
 import org.junit.jupiter.api.Tag;
 import org.junit.jupiter.api.Test;
 import org.testcontainers.containers.Network;
@@ -177,7 +177,46 @@ public void testMultiAppWorkflow() throws Exception {
       assertNotNull(instanceId, "Workflow instance ID should not be null");
       workflowClient.waitForWorkflowStart(instanceId, Duration.ofSeconds(30), false);
 
-      WorkflowInstanceStatus workflowStatus = workflowClient.waitForWorkflowCompletion(instanceId, null, true);
+      WorkflowState workflowStatus = workflowClient.waitForWorkflowCompletion(instanceId, null, true);
+      assertNotNull(workflowStatus, "Workflow status should not be null");
+      assertEquals(WorkflowRuntimeStatus.COMPLETED, workflowStatus.getRuntimeStatus(),
+          "Workflow should complete successfully");
+      String workflowOutput = workflowStatus.readOutputAs(String.class);
+      assertEquals(expectedOutput, workflowOutput, "Workflow output should match expected result");
+    } finally {
+      workflowClient.close();
+    }
+  }
+
+  /**
+   * It duplicates the {@link #testMultiAppWorkflow()} due to deprecated APIs.
+   * It must be deleted after {@link WorkflowInstanceStatus} be removed.
+   */
+  @Test
+  @Deprecated(forRemoval = true)
+  public void testMultiAppWorkflowOldApi() throws Exception {
+    // TestContainers wait strategies ensure all containers are ready before this test runs
+
+    String input = "Hello World";
+    String expectedOutput = "HELLO WORLD [TRANSFORMED BY APP2] [FINALIZED BY APP3]";
+
+    // Create workflow client connected to the main workflow orchestrator
+    // Use the same endpoint configuration that the workers use
+    // The workers use host.testcontainers.internal:50001
+    Map<String, String> propertyOverrides = Map.of(
+        "dapr.grpc.endpoint", MAIN_WORKFLOW_SIDECAR.getGrpcEndpoint(),
+        "dapr.http.endpoint", MAIN_WORKFLOW_SIDECAR.getHttpEndpoint()
+    );
+
+    Properties clientProperties = new Properties(propertyOverrides);
+    DaprWorkflowClient workflowClient = new DaprWorkflowClient(clientProperties);
+
+    try {
+      String instanceId = workflowClient.scheduleNewWorkflow(MultiAppWorkflow.class, input);
+      assertNotNull(instanceId, "Workflow instance ID should not be null");
+      workflowClient.waitForWorkflowStart(instanceId, Duration.ofSeconds(30), false);
+
+      WorkflowInstanceStatus workflowStatus = workflowClient.waitForInstanceCompletion(instanceId, null, true);
       assertNotNull(workflowStatus, "Workflow status should not be null");
       assertEquals(WorkflowRuntimeStatus.COMPLETED, workflowStatus.getRuntimeStatus(),
           "Workflow should complete successfully");