Function runLiveSuite

test/test-e2e.ts:816–1016

(startProxy: StartProxy)

}

async function runLiveSuite(startProxy: StartProxy): Promise<boolean> {
  if (!RUN_PAID_TESTS || !LIVE_WALLET_KEY) {
    console.log("\n=== Live paid e2e ===\n");
    skipTest("Live upstream smoke tests", "set funded BLOCKRUN_WALLET_KEY to enable");
    return true;
  }

  console.log("\n=== Live paid e2e ===\n");
  console.log(`Mode: LIVE, wallet=${privateKeyToAccount(LIVE_WALLET_KEY).address}`);

  let proxy: ProxyHandle | undefined;
  let allPassed = true;

  try {
    proxy = await startProxy({
      wallet: LIVE_WALLET_KEY,
      port: 0,
      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)}, cost=$${d.costEstimate.toFixed(4)}, saved=${(d.savings * 100).toFixed(0)}%)`,
        ),
      onPayment: (info) =>
        console.log(`  [payment] ${info.model} ${info.amount} on ${info.network}`),
    });

    allPassed =
      (await runTest("Live balance check", async () => {
        if (!proxy!.balanceMonitor) throw new Error("Balance monitor not available");
        const balance = await proxy!.balanceMonitor.checkBalance();
        if (!balance || typeof balance.balanceUSD !== "string") {
          throw new Error("Balance check returned invalid response");
        }
        if (balance.isEmpty) throw new Error("Wallet is empty - please fund it");
        return `(balance=${balance.balanceUSD})`;
      })) && allPassed;

    allPassed =
      (await runTest("Live non-streaming request (deepseek/deepseek-chat)", 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,
          },
          60_000,
        );
        const content = await expectChatContent(res);
        if (!content.includes("4")) throw new Error(`Expected "4" in response, got: ${content}`);
        return `(response="${content.trim()}")`;
      })) && allPassed;

    allPassed =