chore: Test anonymous class activities

Signed-off-by: Javier Aliaga <[email protected]>

Author: javier-aliaga

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

@@ -161,11 +161,13 @@ public void testNamedActivitiesWorkflows() throws Exception {
 
     TestWorkflowPayload workflowOutput = deserialize(workflowStatus.getSerializedOutput());
 
-    assertEquals(3, workflowOutput.getPayloads().size());
+    assertEquals(5, workflowOutput.getPayloads().size());
     assertEquals("First Activity", workflowOutput.getPayloads().get(0));
     assertEquals("First Activity", workflowOutput.getPayloads().get(1));
     assertEquals("Second Activity", workflowOutput.getPayloads().get(2));
-    
+    assertEquals("Anonymous Activity", workflowOutput.getPayloads().get(3));
+    assertEquals("Anonymous Activity 2", workflowOutput.getPayloads().get(4));
+
     assertEquals(instanceId, workflowOutput.getWorkflowId());
   }
 

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

@@ -35,10 +35,16 @@ public WorkflowStub create() {
 
       var payloadAfterB = ctx.callActivity("b", payloadAfterA, TestWorkflowPayload.class).await();
 
-      var payloadAfteC = ctx.callActivity("c", payloadAfterB, TestWorkflowPayload.class)
+      var payloadAfterC = ctx.callActivity("c", payloadAfterB, TestWorkflowPayload.class)
           .await();
 
-      ctx.complete(payloadAfteC);
+      var payloadAfterD = ctx.callActivity("d", payloadAfterC, TestWorkflowPayload.class)
+          .await();
+
+      var payloadAfterE = ctx.callActivity("e", payloadAfterD, TestWorkflowPayload.class)
+          .await();
+          
+      ctx.complete(payloadAfterE);
     };
   }
 

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

@@ -15,8 +15,10 @@
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 import io.dapr.config.Properties;
+import io.dapr.workflows.WorkflowActivityContext;
 import io.dapr.workflows.client.DaprWorkflowClient;
 import io.dapr.workflows.runtime.WorkflowRuntimeBuilder;
+import io.dapr.workflows.WorkflowActivity;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -63,6 +65,23 @@ public WorkflowRuntimeBuilder workflowRuntimeBuilder(
     builder.registerActivity("a",FirstActivity.class);
     builder.registerActivity("b",FirstActivity.class);
     builder.registerActivity("c", new SecondActivity());
+    builder.registerActivity("d", new WorkflowActivity() {
+      @Override
+      public Object run(WorkflowActivityContext ctx) {
+        TestWorkflowPayload workflowPayload = ctx.getInput(TestWorkflowPayload.class);
+        workflowPayload.getPayloads().add("Anonymous Activity");
+        return workflowPayload;
+      }
+    });
+    builder.registerActivity("e", new WorkflowActivity() {
+      @Override
+      public Object run(WorkflowActivityContext ctx) {
+        TestWorkflowPayload workflowPayload = ctx.getInput(TestWorkflowPayload.class);
+        workflowPayload.getPayloads().add("Anonymous Activity 2");
+        return workflowPayload;
+      }
+    });
+
 
 
     return builder;