Upgrade lc4j-agentic to 1.8.0-beta15 (#953)

Signed-off-by: Ricardo Zanini <ricardozanini@gmail.com>

Author: ricardozanini

experimental/fluent/agentic-langchain4j/src/main/java/io/serverlessworkflow/fluent/agentic/langchain4j/AbstractAgentService.java

@@ -66,7 +66,7 @@ public S beforeCall(Consumer<AgenticScope> beforeCall) {
   }
 
   @SuppressWarnings("unchecked")
-  public S outputName(String outputName) {
+  public S outputKey(String outputName) {
     Function<DefaultAgenticScope, Object> outputFunction = cog -> cog.readState(outputName);
     this.workflowBuilder.outputAs(outputFunction, DefaultAgenticScope.class);
     this.workflowBuilder.document(

experimental/fluent/agentic-langchain4j/src/main/java/io/serverlessworkflow/fluent/agentic/langchain4j/WorkflowInvocationHandler.java

@@ -65,7 +65,7 @@ private static void writeAgenticScopeState(
     }
   }
 
-  private String outputName() {
+  private String outputKey() {
     Object outputName =
         this.workflow
             .getDocument()
@@ -81,12 +81,12 @@ private String outputName() {
   @Override
   public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
     AgenticScopeRegistry registry = registry();
-    // outputName
+    // outputKey
     if (method.getDeclaringClass() == AgentSpecification.class) {
       return switch (method.getName()) {
         case "name" -> this.workflow.getDocument().getName();
         case "description" -> this.workflow.getDocument().getSummary();
-        case "outputName" -> outputName();
+        case "outputKey" -> outputKey();
         default ->
             throw new UnsupportedOperationException(
                 "Unknown method on AgentInstance class : " + method.getName());
@@ -135,7 +135,7 @@ private Object executeWorkflow(AgenticScope agenticScope, Method method, Object[
                   () ->
                       new IllegalArgumentException(
                           "Workflow hasn't returned a AgenticScope object."));
-      Object result = output.readState(outputName());
+      Object result = output.readState(outputKey());
 
       return method.getReturnType().equals(ResultWithAgenticScope.class)
           ? new ResultWithAgenticScope<>(output, result)

experimental/fluent/agentic-langchain4j/src/test/java/io/serverlessworkflow/fluent/agentic/langchain4j/SequentialAgentServiceImplTest.java

@@ -64,7 +64,7 @@ void shouldSetOutputName_inDocumentMetadata() {
     String outputName = "myOutputName";
     SequentialAgentServiceImpl<DummyAgent> service =
         (SequentialAgentServiceImpl<DummyAgent>)
-            SequentialAgentServiceImpl.builder(DummyAgent.class).outputName(outputName);
+            SequentialAgentServiceImpl.builder(DummyAgent.class).outputKey(outputName);
 
     // when
     Workflow wf = service.getDefinition();

experimental/fluent/agentic-langchain4j/src/test/java/io/serverlessworkflow/fluent/agentic/langchain4j/WorkflowAgentsIT.java

@@ -40,28 +40,28 @@ void sequential_agents_tests() {
         spy(
             AgenticServices.agentBuilder(CreativeWriter.class)
                 .chatModel(BASE_MODEL)
-                .outputName("story")
+                .outputKey("story")
                 .build());
 
     AudienceEditor audienceEditor =
         spy(
             AgenticServices.agentBuilder(AudienceEditor.class)
                 .chatModel(BASE_MODEL)
-                .outputName("story")
+                .outputKey("story")
                 .build());
 
     StyleEditor styleEditor =
         spy(
             AgenticServices.agentBuilder(StyleEditor.class)
                 .chatModel(BASE_MODEL)
-                .outputName("story")
+                .outputKey("story")
                 .build());
 
     UntypedAgent novelCreator =
         builder
             .sequenceBuilder()
             .subAgents(creativeWriter, audienceEditor, styleEditor)
-            .outputName("story")
+            .outputKey("story")
             .build();
 
     Map<String, Object> input =

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

@@ -44,7 +44,7 @@ public void verifyAgentCall() {
     Agents.MovieExpert movieExpert =
         spy(
             AgenticServices.agentBuilder(Agents.MovieExpert.class)
-                .outputName("movies")
+                .outputKey("movies")
                 .chatModel(BASE_MODEL)
                 .build());
 

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

@@ -191,7 +191,6 @@ public void errorHandling() {
     assertThat(result).containsKey("story");
   }
 
-  @SuppressWarnings("unchecked")
   @Test
   @DisplayName("Conditional agents via choice(...)")
   public void conditionalWorkflow() {

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

@@ -29,15 +29,15 @@ private AgentsUtils() {}
   public static Agents.MovieExpert newMovieExpert() {
     return spy(
         AgenticServices.agentBuilder(Agents.MovieExpert.class)
-            .outputName("movies")
+            .outputKey("movies")
             .chatModel(BASE_MODEL)
             .build());
   }
 
   public static Agents.MovieExpert newMovieExpert2() {
     return spy(
         AgenticServices.agentBuilder(Agents.MovieExpert.class)
-            .outputName("movies")
+            .outputKey("movies")
             .name("findMovie2")
             .chatModel(BASE_MODEL)
             .build());
@@ -46,39 +46,39 @@ public static Agents.MovieExpert newMovieExpert2() {
   public static Agents.CreativeWriter newCreativeWriter() {
     return spy(
         AgenticServices.agentBuilder(Agents.CreativeWriter.class)
-            .outputName("story")
+            .outputKey("story")
             .chatModel(BASE_MODEL)
             .build());
   }
 
   public static Agents.AudienceEditor newAudienceEditor() {
     return spy(
         AgenticServices.agentBuilder(Agents.AudienceEditor.class)
-            .outputName("story")
+            .outputKey("story")
             .chatModel(BASE_MODEL)
             .build());
   }
 
   public static Agents.StyleEditor newStyleEditor() {
     return spy(
         AgenticServices.agentBuilder(Agents.StyleEditor.class)
-            .outputName("story")
+            .outputKey("story")
             .chatModel(BASE_MODEL)
             .build());
   }
 
   public static Agents.SummaryStory newSummaryStory() {
     return spy(
         AgenticServices.agentBuilder(Agents.SummaryStory.class)
-            .outputName("story")
+            .outputKey("story")
             .chatModel(BASE_MODEL)
             .build());
   }
 
   public static Agents.StyleScorer newStyleScorer() {
     return spy(
         AgenticServices.agentBuilder(Agents.StyleScorer.class)
-            .outputName("score")
+            .outputKey("score")
             .chatModel(BASE_MODEL)
             .build());
   }
@@ -87,47 +87,47 @@ public static Agents.FoodExpert newFoodExpert() {
     return spy(
         AgenticServices.agentBuilder(Agents.FoodExpert.class)
             .chatModel(BASE_MODEL)
-            .outputName("meals")
+            .outputKey("meals")
             .build());
   }
 
   public static Agents.AstrologyAgent newAstrologyAgent() {
     return spy(
         AgenticServices.agentBuilder(Agents.AstrologyAgent.class)
             .chatModel(BASE_MODEL)
-            .outputName("horoscope")
+            .outputKey("horoscope")
             .build());
   }
 
   public static Agents.CategoryRouter newCategoryRouter() {
     return spy(
         AgenticServices.agentBuilder(Agents.CategoryRouter.class)
             .chatModel(BASE_MODEL)
-            .outputName("category")
+            .outputKey("category")
             .build());
   }
 
   public static Agents.MedicalExpert newMedicalExpert() {
     return spy(
         AgenticServices.agentBuilder(Agents.MedicalExpert.class)
             .chatModel(BASE_MODEL)
-            .outputName("response")
+            .outputKey("response")
             .build());
   }
 
   public static Agents.TechnicalExpert newTechnicalExpert() {
     return spy(
         AgenticServices.agentBuilder(Agents.TechnicalExpert.class)
             .chatModel(BASE_MODEL)
-            .outputName("response")
+            .outputKey("response")
             .build());
   }
 
   public static Agents.LegalExpert newLegalExpert() {
     return spy(
         AgenticServices.agentBuilder(Agents.LegalExpert.class)
             .chatModel(BASE_MODEL)
-            .outputName("response")
+            .outputKey("response")
             .build());
   }
 

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

@@ -52,7 +52,7 @@ void chat_bot() {
             AgenticServices.agentBuilder(Agents.ChatBot.class)
                 .chatModel(Models.BASE_MODEL)
                 .chatMemoryProvider(memoryId -> MessageWindowChatMemory.withMaxMessages(10))
-                .outputName("conversation")
+                .outputKey("conversation")
                 .build());
     BlockingQueue<CloudEvent> replyEvents = new LinkedBlockingQueue<>();
     BlockingQueue<CloudEvent> finishedEvents = new LinkedBlockingQueue<>();

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

@@ -51,7 +51,7 @@ void email_drafter_agent() {
     Agents.EmailDrafter emailDrafter =
         AgenticServices.agentBuilder(Agents.EmailDrafter.class)
             .chatModel(Models.BASE_MODEL)
-            .outputName("email_draft")
+            .outputKey("email_draft")
             .build();
 
     BlockingQueue<CloudEvent> finishedEvents = new LinkedBlockingQueue<>();

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

@@ -57,7 +57,7 @@ void mixed_workflow() {
             AgenticServices.agentBuilder(Agents.ChatBot.class)
                 .chatModel(Models.BASE_MODEL)
                 .chatMemoryProvider(memoryId -> MessageWindowChatMemory.withMaxMessages(10))
-                .outputName("userInput")
+                .outputKey("userInput")
                 .build());
 
     final Workflow mixedWorkflow =