Function createExecutorMcpServer

packages/hosts/mcp/src/tool-server.ts:1522–2921

(
  config: ExecutorMcpServerConfig<E>,
)

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

export const createExecutorMcpServer = <E extends Cause.YieldableError>(
  config: ExecutorMcpServerConfig<E>,
): Effect.Effect<McpServer, McpPassthroughUnavailableError> =>
  Effect.gen(function* () {
    const engine = "engine" in config ? config.engine : createExecutionEngine(config);
    const description =
      config.description ??
      (yield* engine.getDescription.pipe(Effect.withSpan("mcp.host.get_description")));
    // The same live integration inventory the description carries, re-used by
    // the `skills` tool so the `execute` guide lists what is connected too.
    const executeInventory = extractInventory(description);
    // Artifacts are on unless this connection opted out (`?artifacts=false`).
    // One flag decides the whole surface: the tools, the shell resource, and
    // the skills catalog below.
    const artifactsEnabled = config.artifactsEnabled ?? true;
    const skillCatalog: readonly Skill[] =
      config.mode === "passthrough"
        ? [
            SEARCH_INVOKE_SKILL,
            ...skillCatalogFor({
              artifacts: artifactsEnabled && config.loadAppShellHtml !== undefined,
              discovery: "search-invoke",
            }),
          ]
        : skillCatalogFor({ artifacts: artifactsEnabled });
    // Per-integration search tools are off unless this connection opted in
    // (`?search_tools=true`).
    const searchToolsEnabled = config.searchToolsEnabled ?? false;
    // Passthrough (`?mode=passthrough`) replaces the codemode surface
    // wholesale. The flag is read once here and every codemode-only
    // registration below is gated on it, so the two surfaces cannot leak into
    // each other.
    const mode: McpToolMode = config.mode ?? "codemode";
    const passthrough = mode === "passthrough";
    if (passthrough && (!config.tools || !config.connections || !config.integrations)) {
      return yield* new McpPassthroughUnavailableError({
        reason:
          "passthrough mode requires tool list/schema, connection list, and integration list APIs",
      });
    }

    // Captured at construction time. SDK callbacks fire later (often
    // deferred past the outer Effect's await), so we use the runtime to
    // re-enter Effect-land at each callback edge.
    const context = yield* Effect.context<never>();
    const debugEnabled = config.debug ?? readDebugDefault();
    const debugLog = (event: string, data: Record<string, unknown>) => {
      if (!debugEnabled) return;
      // oxlint-disable-next-line executor/no-try-catch-or-throw -- boundary: debug logging must tolerate non-serializable SDK capability snapshots
      try {
        console.error(`[executor:mcp] ${event} ${JSON.stringify(data)}`);
      } catch {
        console.error(`[executor:mcp] ${event}`, data);
      }
    };
    const elicitationMode =
      config.elicitationMode ??
      ({