Duplicate Assistant Messages with agent.network() + Memory

{
  "id": "9c51494e-8dc2-4f5c-8dbd-a2cf8d58beb7",
  "role": "assistant",
  "content": "{\"parts\":[{\"type\":\"text\",\"text\":\"Sure! Let me get that information for you.\"}]}"
}

{
  "id": "c1f6795d-8240-4c21-be30-48d523c46ad3",
  "role": "assistant",
  "content": "{\"parts\":[{\"type\":\"text\",\"text\":\"{\\\"isNetwork\\\":true,\\\"selectionReason\\\":\\\"The user is asking for poll information, which aligns with the voting_agent's capabilities...\\\",\\\"primitiveType\\\":\\\"agent\\\",\\\"primitiveId\\\":\\\"general_agent\\\",\\\"input\\\":\\\"...\\\",\\\"finalResult\\\":{...}}\"}]}"
}

import { Agent } from "@mastra/core";
import { Memory } from "@mastra/memory";
import { sharedStorage, sharedVector } from "../shared";
import gmailAgent from "./gmail-agent";
import webAgent from "./web-agent";
// ... other agents

export const orchestratorAgent = new Agent({
  name: "automation-orchestrator",
  instructions: "You are an intelligent automation orchestrator...",
  model: openrouter("openai/gpt-4o-mini"),

  agents: {
    gmail_agent: gmailAgent,
    web_agent: webAgent,
    // ... other agents
  },

  memory: new Memory({
    storage: sharedStorage,
    vector: sharedVector,
    embedder: openai.embedding('text-embedding-3-small'),
    options: {
      lastMessages: 20,
      semanticRecall: {
        topK: 5,
        messageRange: 2,
        scope: 'resource',
      },
      workingMemory: {
        enabled: true,
        scope: 'resource',
      },
    },
  }),
});

// Using agent.network() with memory
const networkStream = await orchestrator.network(content, {
  memory: {
    thread: chatId,
    resource: userId,
  },
  runtimeContext: networkRuntimeContext,
});

// Transform to AI SDK format for streaming
const { toAISdkFormat } = await import("@mastra/ai-sdk");
return createUIMessageStreamResponse({
  stream: toAISdkFormat(networkStream, { from: "network" }),
});