Function build

packages/core/api/src/server/mcp-build.ts:59–106

(
    principal: Principal,
    options: McpSessionBuildOptions | McpModernServerBuildOptions,
  )

  function build(principal: Principal, options: McpSessionBuildOptions): McpSessionBuildEffect;
  function build(principal: Principal, options: McpModernServerBuildOptions): McpModernBuildEffect;
  function build(
    principal: Principal,
    options: McpSessionBuildOptions | McpModernServerBuildOptions,
  ): Effect.Effect<
    Effect.Success<McpSessionBuildEffect> | Effect.Success<McpModernBuildEffect>,
    Effect.Error<McpSessionBuildEffect> | Effect.Error<McpModernBuildEffect>
  > {
    const { resource, ...serverOptions } = options;
    return Effect.gen(function* () {
      const { engine, executor } = yield* makeExecutionStack(
        principal.accountId,
        principal.organizationId,
        principal.organizationName,
        { mcpResource: resource },
      ).pipe(Effect.withSpan("mcp.execution_stack.build"));
      // Read inside the provided boundary: `webBaseUrl` is a host seam, and
      // hosts that cannot know their public URL at boot leave it unset.
      const hostConfig = yield* HostConfig;
      return { engine, executor, webBaseUrl: hostConfig.webBaseUrl };
    }).pipe(
      principal.organizationSlug !== undefined
        ? Effect.provideService(RequestOrgSlug, { slug: principal.organizationSlug })
        : (effect) => effect,
      Effect.provide(executionStack),
      Effect.mapError((cause) => new McpEngineBuildError({ cause })),
      Effect.flatMap(({ engine, executor, webBaseUrl }) =>
        buildMcpServer({
          engine,
          artifacts: executor.artifacts,
          connections: executor.connections,
          ...(hostOptions?.loadAppShellHtml
            ? { loadAppShellHtml: hostOptions.loadAppShellHtml }
            : {}),
          ...(hostOptions?.smokeRenderArtifact
            ? { smokeRenderArtifact: hostOptions.smokeRenderArtifact }
            : {}),
          ...(hostOptions?.onArtifactUsage ? { onArtifactUsage: hostOptions.onArtifactUsage } : {}),
          ...(webBaseUrl
            ? { artifactUrl: artifactUrlFor(webBaseUrl, principal.organizationSlug) }
            : {}),
          ...serverOptions,
        }).pipe(
          Effect.withSpan("mcp.server.create"),
          Effect.map((mcpServer) => ("sessionful" in options ? { mcpServer, engine } : mcpServer)),
        ),
      ),
    );
  }

  return build;
};