Function runStdioMcpSession

apps/cli/src/main.ts:1441–1477

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

};

const runStdioMcpSession = (input: { readonly elicitationMode: "browser" | "model" }) =>
  Effect.gen(function* () {
    // `executor mcp` never owns the local database. If a local server is already
    // running, bridge this stdio client to it; otherwise ensure a durable
    // background daemon is up and bridge to that. ensureDaemon is the race-safe
    // election: concurrent cold starts elect one owner and the losers wait for
    // its manifest (waitForDaemonStartupTarget) rather than failing. Bridging
    // means many MCP clients, the web UI, and the desktop app share one owner,
    // and that owner's lifetime is never tied to a transient MCP client.
    const active = yield* readActiveLocalServerManifest();
    if (active) {
      yield* Effect.promise(() =>
        runMcpHttpBridge({ manifest: active, elicitationMode: input.elicitationMode }),
      );
      return;
    }

    // No reachable owner yet: ensure one. If we lose the election (another
    // process became owner first), ensureDaemon may fail, but the winner's
    // manifest is then reachable, so re-read it and bridge to that instead.
    const elected = yield* ensureDaemon(DEFAULT_BASE_URL).pipe(
      Effect.flatMap(() => readActiveLocalServerManifest()),
      Effect.catch((error) =>
        readActiveLocalServerManifest().pipe(
          Effect.flatMap((manifest) => (manifest ? Effect.succeed(manifest) : Effect.fail(error))),
        ),
      ),
    );
    if (!elected) {
      return yield* Effect.fail(
        new Error("The local Executor daemon started but did not advertise a reachable manifest."),
      );
    }
    yield* Effect.promise(() =>
      runMcpHttpBridge({ manifest: elected, elicitationMode: input.elicitationMode }),
    );
  });

const scope = Options.string("scope").pipe(
  Options.optional,