Chained method calls should accumulate state rather than overwrite previous values

Signed-off-by: Dmitrii Tikhomirov <chani.liet@gmail.com>

Author: treblereel

experimental/fluent/agentic/src/main/java/io/serverlessworkflow/fluent/agentic/AgentWorkflowBuilder.java

@@ -16,8 +16,12 @@
 package io.serverlessworkflow.fluent.agentic;
 
 import dev.langchain4j.agentic.scope.AgenticScope;
+import io.serverlessworkflow.api.types.TaskItem;
 import io.serverlessworkflow.fluent.func.spi.FuncTransformations;
 import io.serverlessworkflow.fluent.spec.BaseWorkflowBuilder;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
 import java.util.UUID;
 import java.util.function.Predicate;
 
@@ -49,7 +53,7 @@ public AgentWorkflowBuilder agent(Object agent) {
   public AgentWorkflowBuilder agent(String name, Object agent) {
     final AgentDoTaskBuilder doTaskBuilder = this.newDo();
     doTaskBuilder.agent(name, agent);
-    this.workflow.setDo(doTaskBuilder.build().getDo());
+    setDo(doTaskBuilder);
     return this;
   }
 
@@ -60,7 +64,7 @@ public AgentWorkflowBuilder sequence(Object... agents) {
   public AgentWorkflowBuilder sequence(String name, Object... agents) {
     final AgentDoTaskBuilder doTaskBuilder = this.newDo();
     doTaskBuilder.sequence(name, agents);
-    this.workflow.setDo(doTaskBuilder.build().getDo());
+    setDo(doTaskBuilder);
     return this;
   }
 
@@ -71,7 +75,7 @@ public AgentWorkflowBuilder parallel(Object... agents) {
   public AgentWorkflowBuilder parallel(String name, Object... agents) {
     final AgentDoTaskBuilder doTaskBuilder = this.newDo();
     doTaskBuilder.parallel(name, agents);
-    this.workflow.setDo(doTaskBuilder.build().getDo());
+    setDo(doTaskBuilder);
     return this;
   }
 
@@ -83,7 +87,7 @@ public AgentWorkflowBuilder loop(
       String name, Predicate<AgenticScope> exitCondition, Object... agents) {
     final AgentDoTaskBuilder doTaskBuilder = this.newDo();
     doTaskBuilder.loop(name, loop -> loop.subAgents(agents).exitCondition(exitCondition));
-    this.workflow.setDo(doTaskBuilder.build().getDo());
+    setDo(doTaskBuilder);
     return this;
   }
 
@@ -96,4 +100,14 @@ protected AgentDoTaskBuilder newDo() {
   protected AgentWorkflowBuilder self() {
     return this;
   }
+
+  private void setDo(AgentDoTaskBuilder doTaskBuilder) {
+    if (workflow.getDo() != null) {
+      List<TaskItem> existing = new ArrayList<>(workflow.getDo());
+      existing.addAll(doTaskBuilder.build().getDo());
+      this.workflow.setDo(Collections.unmodifiableList(existing));
+    } else {
+      this.workflow.setDo(doTaskBuilder.build().getDo());
+    }
+  }
 }

fluent/spec/src/main/java/io/serverlessworkflow/fluent/spec/BaseWorkflowBuilder.java

@@ -19,8 +19,12 @@
 import io.serverlessworkflow.api.types.Export;
 import io.serverlessworkflow.api.types.Input;
 import io.serverlessworkflow.api.types.Output;
+import io.serverlessworkflow.api.types.TaskItem;
 import io.serverlessworkflow.api.types.Workflow;
 import io.serverlessworkflow.fluent.spec.spi.TransformationHandlers;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
 import java.util.UUID;
 import java.util.function.Consumer;
 
@@ -90,7 +94,9 @@ public SELF tasks(Consumer<DBuilder> doTaskConsumer) {
     if (this.workflow.getDo() == null) {
       this.workflow.setDo(doTaskBuilder.build().getDo());
     } else {
-      this.workflow.getDo().addAll(doTaskBuilder.build().getDo());
+      List<TaskItem> existingTasks = new ArrayList<>(this.workflow.getDo());
+      existingTasks.addAll(doTaskBuilder.build().getDo());
+      this.workflow.setDo(Collections.unmodifiableList(existingTasks));
     }
     return self();
   }