Formatted convo

Author: caelinsutch

apps/execution-worker/src/durable-objects/execution-agent.ts

@@ -191,6 +191,7 @@ ${input.taskDescription}`,
           .withTags({
             agentId: input.agentId,
             conversationId: input.conversationId,
+            result: result.text,
           })
           .info("ExecutionAgent: Pinging interaction worker with completion");
 

apps/interaction-worker/src/services/process-message/process-agent-completion.ts

@@ -30,6 +30,8 @@ export const processAgentCompletion = async (
     success,
   });
 
+  completionLogger.info(input)
+
   try {
     // Get the execution agent
     const executionAgent = await db.query.agents.findFirst({
@@ -157,7 +159,7 @@ export const processAgentCompletion = async (
 
     // Format conversation with the new agent message
     const formattedConversation = formatAgentConversation({
-      conversationHistory: conversationHistory.map((msg: any) => ({
+      conversationHistory: conversationHistory.map((msg) => ({
         message: msg,
         parts: msg.parts,
       })),
@@ -171,21 +173,24 @@ export const processAgentCompletion = async (
       isGroup: conversation.isGroup,
     });
 
+    logger.info("Formatted conversation", {
+      formattedConversation,
+    });
+
     // Generate response from interaction agent
-    const { messagesToUser, hasUserMessages, usage } = await generateResponse(
+    const { messagesToUser, hasUserMessages, } = await generateResponse(
       formattedConversation,
       {
         conversation,
-        conversationHistory: conversationHistory.map((msg: any) => ({
+        conversationHistory: conversationHistory.map((msg) => ({
           message: msg,
           parts: msg.parts,
         })),
         participants: [],
         env,
         db,
         interactionAgentId: interactionAgent.id,
-        currentMessage: newMessage as any,
-        currentParts: [],
+        currentMessage: newMessage,
       },
     );
 

apps/interaction-worker/src/services/process-message/types.ts

@@ -4,7 +4,6 @@ import type { Database } from "../../db/client";
 
 export type ProcessMessageOptions = {
   currentMessage: Message;
-  currentParts: Part[];
   conversation: Conversation;
   conversationHistory: { message: Message; parts: Part[] }[];
   participants: User[];