Function runMcpStdioServer

apps/local/src/mcp.ts:381–418

(config: ExecutorMcpToolConfig)

// ---------------------------------------------------------------------------

export const runMcpStdioServer = async (config: ExecutorMcpToolConfig): Promise<void> => {
  startIntegrationsRefresh();

  const requestStateSigningKey = crypto.getRandomValues(new Uint8Array(32));
  const stdio = serveStdio(() =>
    Effect.runPromise(
      buildMcpServer({
        ...config,
        appsEnabled: config.restoredAppsEnabled ?? false,
        requestStateSigningKey,
        requestStatePrincipal: "local",
        sessionful: true,
      }),
    ),
  );

  const waitForExit = () =>
    new Promise<void>((resolve) => {
      const finish = () => {
        process.off("SIGINT", finish);
        process.off("SIGTERM", finish);
        process.stdin.off("end", finish);
        process.stdin.off("close", finish);
        resolve();
      };
      process.once("SIGINT", finish);
      process.once("SIGTERM", finish);
      process.stdin.once("end", finish);
      process.stdin.once("close", finish);
    });

  // oxlint-disable-next-line executor/no-try-catch-or-throw -- boundary: stdio server lifetime uses Promise-based SDK/process APIs and always closes resources
  try {
    await waitForExit();
  } finally {
    await ignoreClose(() => stdio.close());
  }
};