Function runMcpHttpBridge

apps/cli/src/main.ts:1392–1479

(input: {
  readonly manifest: ExecutorLocalServerManifest;
  readonly elicitationMode: "browser" | "model";
  readonly artifacts: boolean;
  readonly searchTools: boolean;
})

 * when stdin closes or the daemon connection drops; close is best-effort.
 */
const runMcpHttpBridge = async (input: {
  readonly manifest: ExecutorLocalServerManifest;
  readonly elicitationMode: "browser" | "model";
  readonly artifacts: boolean;
  readonly searchTools: boolean;
}): Promise<void> => {
  const stdio = new StdioServerTransport();
  const authorization = getExecutorServerAuthorizationHeader(input.manifest.connection);
  const http = new StreamableHTTPClientTransport(
    mcpUrlForActiveLocalServer({
      connection: input.manifest.connection,
      elicitationMode: input.elicitationMode,
      artifacts: input.artifacts,
      searchTools: input.searchTools,
    }),
    authorization ? { requestInit: { headers: { Authorization: authorization } } } : undefined,
  );

  let finished = false;
  let closing = false;
  let closePromise: Promise<void> | null = null;
  let resolveExit: () => void = () => {};
  const waitForExit = new Promise<void>((resolve) => {
    resolveExit = resolve;
  });

  const finish = () => {
    if (finished) return;
    finished = true;
    process.off("SIGINT", shutdown);
    process.off("SIGTERM", shutdown);
    process.stdin.off("end", shutdown);
    process.stdin.off("close", shutdown);
    resolveExit();
  };

  const closeBoth = (): Promise<void> => {
    if (!closePromise) {
      closing = true;
      closePromise = Promise.allSettled([stdio.close(), http.close()]).then(() => undefined);
    }
    return closePromise;
  };

  function shutdown() {
    finish();
    void closeBoth();
  }

  const isAbortDuringClose = (error: Error): boolean =>
    error.name === "AbortError" || error.message.toLowerCase().includes("aborted");

  const reportError = (context: string, cause: unknown) => {
    const error = toError(cause);
    if (closing && isAbortDuringClose(error)) return;
    console.error(`Executor MCP bridge ${context}: ${error.message}`);
  };