import assert from "node:assert/strict";import { test } from "node:test";import { handle, type Env } from "../src/worker.ts";import { fakeCtx, fakeKv } from "./fakes.ts";const env: Env = { USAGE: fakeKv() };const ctx = fakeCtx();function rpc(method: string, params?: unknown, id = 1): Request {  return new Request("http://localhost/mcp", {    method: "POST",    headers: { "content-type": "application/json", accept: "application/json, text/event-stream", "mcp-protocol-version": "2025-06-18" },    body: JSON.stringify({ jsonrpc: "2.0", id, method, ...(params ? { params } : {}) }),  });}test("POST /mcp answers initialize as JSON", async () => {  const res = await handle(rpc("initialize", { protocolVersion: "2025-06-18", capabilities: {}, clientInfo: { name: "test", version: "0" } }), env, ctx);  assert.equal(res.status, 200);  assert.match(res.headers.get("content-type") ?? "", /application\/json/);  assert.equal(res.headers.get("mcp-session-id"), null);  const body = (await res.json()) as { result: { serverInfo: { name: string } } };  assert.equal(body.result.serverInfo.name, "mcp-tools");});test("each request gets its own server, so tools/call needs no session", async () => {  const res = await handle(rpc("tools/call", { name: "convert_units", arguments: { value: 1, from: "ft", to: "in" } }), env, ctx);  const body = (await res.json()) as { result: { structuredContent: { result: number } } };  assert.equal(body.result.structuredContent.result, 12);});test("GET and DELETE on /mcp are refused with 405", async () => {  for (const method of ["GET", "DELETE"]) {    const res = await handle(new Request("http://localhost/mcp", { method }), env, ctx);    assert.equal(res.status, 405);    assert.equal(res.headers.get("allow"), "POST, OPTIONS");  }});test("CORS preflights succeed and responses carry the CORS headers", async () => {  const pre = await handle(new Request("http://localhost/mcp", { method: "OPTIONS" }), env, ctx);  assert.equal(pre.status, 204);  assert.equal(pre.headers.get("access-control-allow-origin"), "*");  assert.match(pre.headers.get("access-control-allow-headers") ?? "", /mcp-protocol-version/);  const res = await handle(rpc("tools/list"), env, ctx);  assert.equal(res.headers.get("access-control-allow-origin"), "*");});test("tool calls are counted after the response, and /stats reports them", async () => {  const env: Env = { USAGE: fakeKv() };  const ctx = fakeCtx();  await handle(rpc("tools/call", { name: "text_stats", arguments: { text: "Hello there." } }), env, ctx);  await handle(rpc("tools/call", { name: "time_in_zone", arguments: { zone: "Atlantis/Capital" } }), env, ctx);  await handle(rpc("tools/list"), env, ctx);  await ctx.settle();  const res = await handle(new Request("http://localhost/stats?days=1"), env, ctx);  assert.equal(res.status, 200);  const { days } = (await res.json()) as { days: { tools: Record<string, unknown> }[] };  assert.deepEqual(days[0].tools, { text_stats: { calls: 1, errors: 0 }, time_in_zone: { calls: 1, errors: 1 } });});test("a failing usage write does not fail the tool call", async () => {  const broken = fakeKv();  broken.put = async () => {    throw new Error("KV is down");  };  const ctx = fakeCtx();  const res = await handle(rpc("tools/call", { name: "convert_units", arguments: { value: 1, from: "m", to: "cm" } }), { USAGE: broken }, ctx);  const body = (await res.json()) as { result: { isError?: boolean } };  assert.equal(body.result.isError, undefined);  const logged = console.error;  console.error = () => {};  try {    await ctx.settle();  } finally {    console.error = logged;  }});test("/stats checks its days parameter", async () => {  for (const days of ["0", "32", "two"]) {    const res = await handle(new Request(`http://localhost/stats?days=${days}`), env, ctx);    assert.equal(res.status, 400);  }});test("other paths are 404", async () => {  const res = await handle(new Request("http://localhost/nope"), env, ctx);  assert.equal(res.status, 404);});