Function modernHandlerFor

apps/local/src/mcp.ts:185–236

(resource: McpResource)

  };

  const modernHandlerFor = (resource: McpResource): McpHttpHandler => {
    const key = mcpResourceKey(resource);
    const cached = modernHandlers.get(key);
    if (cached) return cached;

    const handler = createMcpHandler(
      (context) => {
        const request = context.requestInfo;
        if (!request) {
          // oxlint-disable-next-line executor/no-effect-escape-hatch -- boundary: the third-party McpServerFactory Promise contract has no typed failure channel; missing documented request context is an SDK defect
          return Effect.runPromise(Effect.die("Modern MCP request context has no request"));
        }
        const parsedBody = modernRequestBodies.get(request);
        return Effect.runPromise(
          Effect.gen(function* () {
            const resourceConfig = yield* Effect.promise(() => configForResource(resource));
            const clientCapabilities = yield* clientCapabilitiesFromRequest(request);
            const requestStateBinding = yield* Effect.promise(() =>
              mcpRequestStateBindingFromBody({
                body: parsedBody,
                principal: "local",
                resource,
              }),
            );
            const server = yield* buildMcpServer({
              ...resourceConfig.config,
              artifactsEnabled: readArtifactsEnabled(request),
              appsEnabled: appsEnabledForClientCapabilities(clientCapabilities),
              requestStateSigningKey: signingKey(),
              requestStatePrincipal: "local",
              ...(requestStateBinding === null ? {} : { requestStateBinding }),
            });
            if (resourceConfig.close) {
              const closeServer = server.close.bind(server);
              const closeConfig = resourceConfig.close;
              let closed = false;
              server.close = async () => {
                if (closed) return;
                closed = true;
                await ignoreClose(closeServer);
                await ignoreClose(closeConfig);
              };
            }
            return server;
          }),
        );
      },
      { legacy: "reject" },
    );
    modernHandlers.set(key, handler);
    return handler;
  };

  return {
    handleRequest: async (request) => {