diff options
| author | Jack Wotherspoon <[email protected]> | 2025-07-11 15:59:42 -0400 |
|---|---|---|
| committer | GitHub <[email protected]> | 2025-07-11 19:59:42 +0000 |
| commit | 2826c7a1c60bc09d256d7a7c11bdd98f65316cb7 (patch) | |
| tree | cb9e58b8d412df05108f8423b0614394598c7d54 /packages/core/src/tools/mcp-client.ts | |
| parent | 8f12e8a114546326ee5b39d6aae859da6d906d0b (diff) | |
feat: add headers support to SSE transport MCP servers (#3902)
Diffstat (limited to 'packages/core/src/tools/mcp-client.ts')
| -rw-r--r-- | packages/core/src/tools/mcp-client.ts | 16 |
1 files changed, 14 insertions, 2 deletions
diff --git a/packages/core/src/tools/mcp-client.ts b/packages/core/src/tools/mcp-client.ts index 89e97963..e4a87b68 100644 --- a/packages/core/src/tools/mcp-client.ts +++ b/packages/core/src/tools/mcp-client.ts @@ -6,7 +6,10 @@ import { Client } from '@modelcontextprotocol/sdk/client/index.js'; import { StdioClientTransport } from '@modelcontextprotocol/sdk/client/stdio.js'; -import { SSEClientTransport } from '@modelcontextprotocol/sdk/client/sse.js'; +import { + SSEClientTransport, + SSEClientTransportOptions, +} from '@modelcontextprotocol/sdk/client/sse.js'; import { StreamableHTTPClientTransport, StreamableHTTPClientTransportOptions, @@ -190,7 +193,16 @@ async function connectAndDiscover( transportOptions, ); } else if (mcpServerConfig.url) { - transport = new SSEClientTransport(new URL(mcpServerConfig.url)); + const transportOptions: SSEClientTransportOptions = {}; + if (mcpServerConfig.headers) { + transportOptions.requestInit = { + headers: mcpServerConfig.headers, + }; + } + transport = new SSEClientTransport( + new URL(mcpServerConfig.url), + transportOptions, + ); } else if (mcpServerConfig.command) { transport = new StdioClientTransport({ command: mcpServerConfig.command, |