Function handleMcp

packages/core/test-servers/src/worker.ts:338–353

(request: Request)

const mcpTransports = new Map<string, WebStandardStreamableHTTPServerTransport>();

const handleMcp = async (request: Request) => {
  if (!isAuthorized(request)) return unauthorized(request);
  const sessionId = request.headers.get("mcp-session-id") ?? undefined;
  const existing = sessionId ? mcpTransports.get(sessionId) : undefined;
  if (sessionId && !existing) return text("Session not found", { status: 404 });
  if (existing) return existing.handleRequest(request);

  const transport = new WebStandardStreamableHTTPServerTransport({
    sessionIdGenerator: () => crypto.randomUUID(),
    onsessioninitialized: (sid) => {
      mcpTransports.set(sid, transport);
    },
  });
  await createMcpServer().connect(transport);
  return transport.handleRequest(request);
};

const handleRequest = async (request: Request): Promise<Response> => {
  const url = new URL(request.url);