Method startSingleServerImpl

src/node/services/mcpServerManager.ts:1633–2021

(
    name: string,
    info: MCPServerInfo,
    runtime: Runtime,
    _projectPath: string,
    workspacePath: string,
    projectSecrets: Record<string, string> | undefined,
    onActivity: () => void,
    signal: AbortSignal,
    onAbortCleanup?: (cleanupPromise: Promise<void>) => void
  )

  }

  private async startSingleServerImpl(
    name: string,
    info: MCPServerInfo,
    runtime: Runtime,
    _projectPath: string,
    workspacePath: string,
    projectSecrets: Record<string, string> | undefined,
    onActivity: () => void,
    signal: AbortSignal,
    onAbortCleanup?: (cleanupPromise: Promise<void>) => void
  ): Promise<MCPServerInstance | null> {
    if (signal.aborted) {
      return null;
    }

    if (info.transport === "stdio") {
      log.debug("[MCP] Spawning stdio server", { name });
      const execStream = await runtime.exec(info.command, {
        cwd: workspacePath,
        timeout: 60 * 60 * 24, // 24 hours — process lifetime, not startup
        abortSignal: signal,
      });

      const cleanupSpawnedExecStream = async () => {
        try {
          await execStream.stdin.close();
        } catch (error) {
          log.debug("[MCP] Error closing stdin during startup abort cleanup", { name, error });
        }

        try {
          await execStream.stdout.cancel();
        } catch (error) {
          log.debug("[MCP] Error canceling stdout during startup abort cleanup", { name, error });
        }

        try {
          await execStream.stderr.cancel();
        } catch (error) {
          log.debug("[MCP] Error canceling stderr during startup abort cleanup", { name, error });
        }
      };

      if (signal.aborted) {
        // runtime.exec() can return after abort when the process was already spawned.
        // Explicitly close/cancel stdio so the spawned process is not left running.
        await cleanupSpawnedExecStream();
        return null;
      }

      const transport = new MCPStdioTransport(execStream);

      const instanceRef: { current: MCPServerInstance | null } = { current: null };
      let transportClosed = false;
      const markClosed = () => {
        if (transportClosed) {
          return;
        }