Function buildTransport

src/mcp/client.ts:16–56

Build the SDK transport for a server config. For http/sse servers with an * `oauth` block, returns an auth-aware transport whose `authenticate()` runs * the OAuth flow (browser redirect or M2M) before `start()`.

(name: string, config: McpServerConfig, intercept?: AuthIntercept)

 *  `oauth` block, returns an auth-aware transport whose `authenticate()` runs
 *  the OAuth flow (browser redirect or M2M) before `start()`. */
function buildTransport(name: string, config: McpServerConfig, intercept?: AuthIntercept): {
	transport: AnyTransport
	authenticate?: () => Promise<void>
} {
	if (config.type === "sse") {
		if (hasOAuth(config)) {
			const auth = createAuthTransport(name, new URL(config.url), "sse", config.oauth!, {
				headers: config.headers ?? {},
			}, intercept)
			return { transport: auth.transport, authenticate: auth.authenticate }
		}
		return {
			transport: new SSEClientTransport(new URL(config.url), {
				requestInit: { headers: config.headers ?? {} },
			}),
		}
	}
	if (config.type === "http") {
		if (hasOAuth(config)) {
			const auth = createAuthTransport(name, new URL(config.url), "http", config.oauth!, {
				headers: config.headers ?? {},
			}, intercept)
			return { transport: auth.transport, authenticate: auth.authenticate }
		}
		return {
			transport: new StreamableHTTPClientTransport(new URL(config.url), {
				requestInit: { headers: config.headers ?? {} },
			}),
		}
	}
	// stdio (default)
	return {
		transport: new StdioClientTransport({
			command: config.command,
			args: config.args ?? [],
			env: config.env,
			cwd: config.cwd,
			stderr: "pipe",
		}),
	}
}

/** A live connection to a single MCP server. */
export interface McpConnection {