Mastra SDK

npm install @mastra/mcp@latest

import { MCPClient } from "@mastra/mcp";

const mcpClient = new MCPClient({
  servers: {
    observee: {
      url: new URL("https://mcp.observee.ai/mcp?client_id={your_client_id}"), // Replace with your client ID
      requestInit: {
        headers: {
          Authorization: "Bearer {observee_api_key}", // Replace with your API key
        },
      },
    },
  },
});

import { Agent } from "@mastra/core/agent";

// Fetch all available tools from Observee
const tools = await mcpClient.getTools();

// Create your agent with the static toolset
const agent = new Agent({
  tools,
  // ...other agent config
});

// Use the agent to handle user prompts
const response = await agent.generate("Summarize the latest sales data");
console.log(response);

import { Agent } from "@mastra/core/agent";

async function handleUserRequest(userPrompt: string, userApiKey: string) {
  // Create a client for the specific user's request
  const userMcpClient = new MCPClient({
    servers: {
      observee: {
        url: new URL("https://mcp.observee.ai/mcp?client_id={your_client_id}"),
        requestInit: {
          headers: {
            Authorization: `Bearer ${userApiKey}`,
          },
        },
      },
    },
  });

  // Fetch toolsets dynamically
  const toolsets = await userMcpClient.getToolsets();

  const agent = new Agent({ /* ... */ });
  const response = await agent.stream(userPrompt, { toolsets });

  await userMcpClient.disconnect();
  return response;
}