Function runLocalSuite

test/test-e2e.ts:430–814

(startProxy: StartProxy)

}

async function runLocalSuite(startProxy: StartProxy): Promise<boolean> {
  console.log("\n=== Local deterministic e2e (mock upstream) ===\n");

  const mock = await startMockUpstream();
  let proxy: ProxyHandle | undefined;
  let allPassed = true;

  try {
    proxy = await startProxy({
      wallet: LOCAL_WALLET_KEY,
      apiBase: mock.url,
      port: 0,
      skipBalanceCheck: true,
      requestTimeoutMs: REQUEST_TIMEOUT_MS,
      onReady: (port) => console.log(`Proxy ready on port ${port}`),
      onError: (err) => console.error(`Proxy error: ${err.message}`),
      onRouted: (d) =>
        console.log(
          `  [routed] ${d.model} (${d.tier}, ${d.method}, confidence=${d.confidence.toFixed(2)})`,
        ),
    });

    allPassed =
      (await runTest("Health check", async () => {
        const res = await fetchWithTimeout(`${proxy!.baseUrl}/health`);
        const payload = await readResponseBody(res);
        if (res.status !== 200) throw new Error(`Expected 200, got ${res.status}`);
        const body = asRecord(payload.json);
        if (body.status !== "ok") throw new Error(`Expected status ok, got ${body.status}`);
        if (!body.wallet) throw new Error("Missing wallet in health response");
        return `(wallet=${String(body.wallet)})`;
      })) && allPassed;

    allPassed =
      (await runTest("Non-streaming request through proxy", async () => {
        const res = await postJson(proxy!, "/v1/chat/completions", {
          model: "deepseek/deepseek-chat",
          messages: [{ role: "user", content: "What is 2+2? Reply with just the number." }],
          max_tokens: 10,
          stream: false,
        });
        const content = await expectChatContent(res);
        if (!content.includes("4")) throw new Error(`Expected "4" in response, got: ${content}`);
        return `(response="${content.trim()}")`;
      })) && allPassed;

    allPassed =
      (await runTest("Streaming request through proxy", async () => {
        const res = await postJson(proxy!, "/v1/chat/completions", {
          model: "google/gemini-2.5-flash",
          messages: [{ role: "user", content: "Say hello in one word." }],
          max_tokens: 10,
          stream: true,
        });
        if (res.status !== 200) throw new Error(`Expected 200, got ${res.status}`);
        const ct = res.headers.get("content-type");
        if (!ct?.includes("text/event-stream")) {
          throw new Error(`Expected text/event-stream, got ${ct}`);