better combined processsing

Signed-off-by: Dmitrii Tikhomirov <[email protected]>

Author: treblereel

experimental/agentic/src/main/java/io/serverlessworkflow/impl/expressions/agentic/AgenticModelFactory.java

@@ -24,6 +24,7 @@
 import io.serverlessworkflow.impl.expressions.agentic.langchain4j.AgenticScopeRegistryAssessor;
 import java.time.OffsetDateTime;
 import java.util.Map;
+import java.util.stream.Collectors;
 
 class AgenticModelFactory implements WorkflowModelFactory {
 
@@ -60,7 +61,11 @@ public WorkflowModel fromAny(WorkflowModel prev, Object obj) {
 
   @Override
   public WorkflowModel combine(Map<String, WorkflowModel> workflowVariables) {
-    return newAgenticModel(workflowVariables);
+    Map<String, Object> combinedState =
+        workflowVariables.entrySet().stream()
+            .map(e -> Map.entry(e.getKey(), e.getValue().asJavaObject()))
+            .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
+    return newAgenticModel(combinedState);
   }
 
   @Override

experimental/fluent/agentic/src/test/java/io/serverlessworkflow/fluent/agentic/WorkflowTests.java

@@ -175,17 +175,12 @@ public void testParallel() throws ExecutionException, InterruptedException {
     topic.put("style", "sci-fi");
 
     try (WorkflowApplication app = WorkflowApplication.builder().build()) {
-      AgenticScope result =
-          app.workflowDefinition(workflow)
-              .instance(topic)
-              .start()
-              .get()
-              .as(AgenticScope.class)
-              .orElseThrow();
+      Map<String, Object> result =
+          app.workflowDefinition(workflow).instance(topic).start().get().asMap().orElseThrow();
 
-      assertEquals("Fake conflict response", result.readState("setting"));
-      assertEquals("Fake hero response", result.readState("hero"));
-      assertEquals("Fake setting response", result.readState("conflict"));
+      assertEquals("Fake conflict response", result.get("setting").toString());
+      assertEquals("Fake hero response", result.get("hero").toString());
+      assertEquals("Fake setting response", result.get("conflict").toString());
     }
   }
 
@@ -224,16 +219,11 @@ public void testSeqAndThenParallel() throws ExecutionException, InterruptedExcep
     topic.put("fact", "alien");
 
     try (WorkflowApplication app = WorkflowApplication.builder().build()) {
-      AgenticScope result =
-          app.workflowDefinition(workflow)
-              .instance(topic)
-              .start()
-              .get()
-              .as(AgenticScope.class)
-              .orElseThrow();
+      Map<String, Object> result =
+          app.workflowDefinition(workflow).instance(topic).start().get().asMap().orElseThrow();
 
-      assertEquals(cultureTraits, result.readState("culture"));
-      assertEquals(technologyTraits, result.readState("technology"));
+      assertEquals(cultureTraits, result.get("culture"));
+      assertEquals(technologyTraits, result.get("technology"));
     }
   }