{
  "mcpServers": {
    "RapidMCP": {
      "url": "https://rapid-mcp.com/mcp/<serverId>/stream",
      "headers": {
        "Authorization": "Bearer XXXXX"
      }
    }
  }
}

import { assistant, hostedMcpTool } from "@openai/agents";

const rapidMcpTool = hostedMcpTool({
  serverLabel: "RapidMCP",
  serverUrl: "https://rapid-mcp.com/mcp/<serverId>/stream",
  headers: {
    // Becomes available as {{authorization}} or {{x-tenant-id}} in Rapid MCP templates
    Authorization: `Bearer ${process.env.RAPID_MCP_API_KEY!}`,
    "x-tenant-id": "acme-corp",
  },
  body: {
    // Becomes available as {{subdomain}} and {{environment}} in Rapid MCP templates
    subdomain: "acme",        // e.g. used in a tool as https://{{subdomain}}.example.com
    environment: "staging",   // e.g. used as a query param or header
  },
});

const agent = assistant({
  model: "gpt-4.1-mini",
  tools: {
    rapidMcp: rapidMcpTool,
  },
});

const result = await agent.run(
  "Use the RapidMCP tools to fetch staging data for the 'acme' tenant.",
);
console.log(result.output_text);

import { Agent, MCPServerStreamableHttp, Runner } from "@openai/agents";
import type { MCPToolMetaContext } from "@openai/agents";

const mcpHeaders = { Authorization: `Bearer TOKEN_GOES_HERE` };
const mcpUrl = "https://rapid-mcp.com/mcp/<serverId>/stream";

const mcpServer = new MCPServerStreamableHttp({
  url: mcpUrl,
  name: "Rapid MCP Server",
  requestInit: Object.keys(mcpHeaders).length ? { headers: mcpHeaders } : undefined,
  toolMetaResolver: (ctx: MCPToolMetaContext) => {
    const contextData = ctx.runContext.context as { orgId?: string } | undefined;
    return {
      orgId: contextData?.orgId,
      data: "yes",
    };
  },
});

await mcpServer.connect();

const agent = new Agent({
  name: "Rapid MCP Agent",
  mcpServers: [mcpServer],
});

const runner = new Runner();
const result = await runner.run(agent, "Run a tool call", {
  context: { orgId: "org_123" },
});

console.log(result.finalOutput);