Function runServerTest

src/node/services/mcpServerManager.ts:418–550

* Run a test connection to an MCP server. * Connects, fetches tools, then closes.

(
  server:
    | { transport: "stdio"; command: string }
    | {
        transport: "http" | "sse" | "auto";
        url: string;
        headers?: ResolvedHeaders;
        authProvider?: OAuthClientProvider;
      },
  projectPath: string,
  logContext: string
)

 * Connects, fetches tools, then closes.
 */
async function runServerTest(
  server:
    | { transport: "stdio"; command: string }
    | {
        transport: "http" | "sse" | "auto";
        url: string;
        headers?: ResolvedHeaders;
        authProvider?: OAuthClientProvider;
      },
  projectPath: string,
  logContext: string
): Promise<MCPTestResult> {
  const timeoutPromise = new Promise<MCPTestResult>((resolve) =>
    setTimeout(() => resolve({ success: false, error: "Connection timed out" }), TEST_TIMEOUT_MS)
  );

  const testPromise = (async (): Promise<MCPTestResult> => {
    let stdioTransport: MCPStdioTransport | null = null;
    let client: Awaited<ReturnType<typeof createMCPClient>> | null = null;
    let getCapturedWwwAuthenticateHeader: (() => string | null) | null = null;

    try {
      if (server.transport === "stdio") {
        const runtime = createRuntime({ type: "local", srcBaseDir: projectPath });
        log.debug(`[MCP] Testing ${logContext}`, { transport: "stdio" });

        const execStream = await runtime.exec(server.command, {
          cwd: projectPath,
          timeout: TEST_TIMEOUT_MS / 1000,
        });

        stdioTransport = new MCPStdioTransport(execStream);
        await stdioTransport.start();
        client = await createMCPClient({ transport: stdioTransport });
      } else {
        log.debug(`[MCP] Testing ${logContext}`, { transport: server.transport });

        const challengeCapture = createWwwAuthenticateCaptureFetch();
        getCapturedWwwAuthenticateHeader = challengeCapture.getCapturedHeader;

        const transportBase = {
          url: server.url,
          headers: server.headers,
          fetch: challengeCapture.fetch,
          ...(server.authProvider ? { authProvider: server.authProvider } : {}),
        };

        const tryHttp = async () =>
          createMCPClient({
            transport: {
              type: "http",
              ...transportBase,
            },
          });

        const trySse = async () =>
          createMCPClient({
            transport: {