Method handle

packages/e2e-tests/src/mock-provider/server.ts:152–475

(req: Request)

    }

    private async handle(req: Request): Promise<Response> {
        const url = new URL(req.url);
        const method = req.method;

        // Accept both /messages and /v1/messages (depending on how baseURL is configured).
        const isMessages = url.pathname === "/messages" || url.pathname === "/v1/messages";

        if (method === "POST" && isMessages) {
            let body: Record<string, unknown> = {};
            try {
                body = (await req.json()) as Record<string, unknown>;
            } catch {
                body = {};
            }

            const headers: Record<string, string> = {};
            req.headers.forEach((value, key) => {
                headers[key] = value;
            });

            this.captured.push({
                receivedAt: Date.now(),
                method,
                path: url.pathname,
                headers,
                body,
            });

            // Matcher routing: first-match-wins. Matchers can return tailored
            // responses based on request body (e.g. slow down historian calls).
            let matcherResponse: MockResponse | null = null;
            for (const matcher of this.matchers) {
                const resp = matcher(body, headers);
                if (resp !== null) {
                    matcherResponse = resp;
                    break;
                }
            }
            const scripted = matcherResponse ?? this.responses.shift() ?? this.defaultResponse;
            if (!scripted) {
                return new Response(
                    JSON.stringify({
                        type: "error",
                        error: { type: "mock_error", message: "No scripted response available" },
                    }),
                    {
                        status: 500,
                        headers: { "content-type": "application/json" },
                    },
                );
            }

            if (scripted.delayMs && scripted.delayMs > 0) {
                await Bun.sleep(scripted.delayMs);
            }

            // Error response: emit an Anthropic-shaped error body with the
            // requested HTTP status. This bypasses the SSE/streaming path