Function testClientTimeout

test/resilience-errors.ts:199–248

(ctx: TestContext)

// ═══════════════════════════════════════════════════════════════════════════

async function testClientTimeout(ctx: TestContext): Promise<void> {
  console.log("\n═══ Test 3: Client Timeout ═══\n");

  // Create a slow mock server
  const slowServer = createServer((req, res) => {
    // Never respond - let client timeout
    req.on("data", () => {});
    req.on("end", () => {
      // Don't send response - let it hang
    });
  });

  await new Promise<void>((resolve) => {
    slowServer.listen(0, "127.0.0.1", () => resolve());
  });

  const slowPort = (slowServer.address() as { port: number }).port;

  const slowProxy = await startProxy({
    wallet: TEST_WALLET,
    apiBase: `http://127.0.0.1:${slowPort}`,
    skipBalanceCheck: true,
    requestTimeoutMs: 1000, // 1s timeout
  });

  try {
    // Client with 500ms timeout (will timeout before proxy's 1s)
    await fetch(`${slowProxy.baseUrl}/v1/chat/completions`, {
      method: "POST",
      headers: { "Content-Type": "application/json" },
      body: JSON.stringify({
        model: "deepseek/deepseek-chat",
        messages: [{ role: "user", content: "test" }],
      }),
      signal: AbortSignal.timeout(500),
    }).catch(() => {}); // Expected timeout

    // Wait for cleanup
    await sleep(100);

    // Verify proxy recovered
    const health = await fetch(`${slowProxy.baseUrl}/health`);
    assert(health.ok, "Proxy survived client timeout");
  } catch (err) {
    assert(false, `Timeout test failed: ${err instanceof Error ? err.message : String(err)}`);
  } finally {
    await slowProxy.close();
    await new Promise<void>((resolve) => slowServer.close(() => resolve()));
  }
}

// ═══════════════════════════════════════════════════════════════════════════
// Test 4: Malformed HTTP (clientError Handler)