Function runMcpHttpBridge

apps/cli/src/main.ts:1336–1416

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

 * when stdin closes or the daemon connection drops; close is best-effort.
 */
const runMcpHttpBridge = async (input: {
  readonly manifest: ExecutorLocalServerManifest;
  readonly elicitationMode: "browser" | "model";
}): Promise<void> => {
  const stdio = new StdioServerTransport();
  const authorization = getExecutorServerAuthorizationHeader(input.manifest.connection);
  const http = new StreamableHTTPClientTransport(
    mcpUrlForActiveLocalServer(input.manifest.connection, input.elicitationMode),
    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}`);
  };

  const forwardMessage =
    (send: (message: JSONRPCMessage) => Promise<void>, context: string) =>
    (message: JSONRPCMessage) => {
      void send(message).then(undefined, (cause: unknown) => {
        reportError(context, cause);
        shutdown();
      });