TEMP: UNDO ME: Debug

Author: maxkorp

typescript-sdk/integrations/mastra/example/src/mastra/index.ts

@@ -17,6 +17,6 @@ export const mastra = new Mastra({
   }),
   logger: new PinoLogger({
     name: "Mastra",
-    level: "info",
+    level: "debug",
   }),
 });

typescript-sdk/integrations/mastra/src/mastra.ts

@@ -18,6 +18,7 @@ import { Agent as LocalMastraAgent } from "@mastra/core/agent";
 import { RuntimeContext } from "@mastra/core/runtime-context";
 import { randomUUID } from "crypto";
 import { Observable } from "rxjs";
+import util from "util";
 import { MastraClient } from "@mastra/client-js";
 type RemoteMastraAgent = ReturnType<MastraClient["getAgent"]>;
 import {
@@ -70,6 +71,8 @@ export class MastraAgent extends AbstractAgent {
           runId: input.runId,
         };
 
+        console.log("runStartedEvent", runStartedEvent);
+
         subscriber.next(runStartedEvent);
 
         // Handle local agent memory management (from Mastra implementation)
@@ -118,6 +121,7 @@ export class MastraAgent extends AbstractAgent {
                 messageId,
                 delta: text,
               };
+              console.log("textMessageChunkEvent", util.inspect(event, { depth: null }));
               subscriber.next(event);
             },
             onToolCallPart: (streamPart) => {
@@ -127,19 +131,22 @@ export class MastraAgent extends AbstractAgent {
                 toolCallId: streamPart.toolCallId,
                 toolCallName: streamPart.toolName,
               };
+              console.log("toolCallStartEvent", util.inspect(startEvent, { depth: null }));
               subscriber.next(startEvent);
 
               const argsEvent: ToolCallArgsEvent = {
                 type: EventType.TOOL_CALL_ARGS,
                 toolCallId: streamPart.toolCallId,
                 delta: JSON.stringify(streamPart.args),
               };
+              console.log("toolCallArgsEvent", util.inspect(argsEvent, { depth: null }));
               subscriber.next(argsEvent);
 
               const endEvent: ToolCallEndEvent = {
                 type: EventType.TOOL_CALL_END,
                 toolCallId: streamPart.toolCallId,
               };
+              console.log("toolCallEndEvent", util.inspect(endEvent, { depth: null }));
               subscriber.next(endEvent);
             },
             onToolResultPart(streamPart) {
@@ -151,6 +158,11 @@ export class MastraAgent extends AbstractAgent {
                 role: "tool",
               };
 
+              console.log(
+                "toolCallResultEvent",
+                util.inspect(toolCallResultEvent, { depth: null }),
+              );
+
               subscriber.next(toolCallResultEvent);
             },
             onFinishMessagePart: async () => {
@@ -162,6 +174,7 @@ export class MastraAgent extends AbstractAgent {
               subscriber.error(error);
             },
             onRunFinished: async () => {
+              console.log("onRunFinished");
               if (this.isLocalMastraAgent(this.agent)) {
                 try {
                   const memory = await this.agent.getMemory();
@@ -248,9 +261,11 @@ export class MastraAgent extends AbstractAgent {
       },
       {} as Record<string, any>,
     );
+    console.log("clientTools", util.inspect(clientTools, { depth: null }));
     const resourceId = this.resourceId ?? threadId;
     const convertedMessages = convertAGUIMessagesToMastra(messages);
     const runtimeContext = this.runtimeContext;
+    console.log("runtimeContext", runtimeContext);
 
     if (this.isLocalMastraAgent(this.agent)) {
       // Local agent - use the agent's stream method directly
@@ -286,13 +301,15 @@ export class MastraAgent extends AbstractAgent {
             }
           } else {
             // If it's already a readable stream, process it directly
-            await processDataStream({
+            const postProcessedResponse = await processDataStream({
               stream: response as any,
               onTextPart,
               onToolCallPart,
               onToolResultPart,
               onFinishMessagePart,
             });
+            console.log("data stream processed");
+            console.log("postProcessedResponse", util.inspect(postProcessedResponse, { depth: null }));
             await onRunFinished?.();
           }
         } else {
@@ -312,14 +329,22 @@ export class MastraAgent extends AbstractAgent {
           clientTools,
         });
 
+        console.log("response", util.inspect(response, { depth: null }));
+
         // Remote agents should have a processDataStream method
         if (response && typeof response.processDataStream === "function") {
-          await response.processDataStream({
+          console.log("processing data stream");
+          const postProcessedResponse = await response.processDataStream({
             onTextPart,
             onToolCallPart,
             onToolResultPart,
             onFinishMessagePart,
           });
+
+          console.log("data stream processed");
+
+          console.log("postProcessedResponse", util.inspect(postProcessedResponse, { depth: null }));
+
           await onRunFinished?.();
         } else {
           throw new Error("Invalid response from remote agent");

typescript-sdk/package.json

@@ -25,5 +25,12 @@
   "engines": {
     "node": ">=18"
   },
-  "version": "0.0.1"
+  "version": "0.0.1",
+  "dependencies": {
+    "@copilotkit/react-core": "link:../../../../Library/pnpm/global/5/node_modules/@copilotkit/react-core",
+    "@copilotkit/react-ui": "link:../../../../Library/pnpm/global/5/node_modules/@copilotkit/react-ui",
+    "@copilotkit/runtime": "link:../../../../Library/pnpm/global/5/node_modules/@copilotkit/runtime",
+    "@copilotkit/runtime-client-gql": "link:../../../../Library/pnpm/global/5/node_modules/@copilotkit/runtime-client-gql",
+    "@copilotkit/shared": "link:../../../../Library/pnpm/global/5/node_modules/@copilotkit/shared"
+  }
 }