Function connectMcpServer

src/mcp/client.ts:72–102

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

 *  `authIntercept` lets the caller surface the OAuth URL in the TUI and
 *  provide the auth code (from the callback or a manual paste). */
export async function connectMcpServer(name: string, config: McpServerConfig, authIntercept?: AuthIntercept): Promise<McpConnection> {
	const { transport, authenticate } = buildTransport(name, config, authIntercept)
	const client = new Client(CLIENT_INFO, { capabilities: {} })

	// For OAuth servers, run the auth flow (browser redirect or M2M) before
	// connecting. This may open a browser and block until the user authorizes.
	if (authenticate) {
		await withTimeout(authenticate(), CONNECT_TIMEOUT_MS, `MCP server "${name}" auth timed out`)
	}

	// Wrap connect in a timeout so a hung server doesn't block startup.
	await withTimeout(client.connect(transport), CONNECT_TIMEOUT_MS, `MCP server "${name}" timed out`)

	const tools = await listServerTools(name, client)
	return {
		client,
		tools,
		close: async () => {
			try {
				await transport.close()
			} catch {
				// best-effort
			}
			try {
				await client.close()
			} catch {
				// best-effort
			}
		},
	}
}

/** Enumerate tools from a connected client, namespaced as mcp__<server>__<tool>. */
export async function listServerTools(server: string, client: Client): Promise<McpTool[]> {