Function testMemoryPressure

test/resilience-errors.ts:285–313

(ctx: TestContext)

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

async function testMemoryPressure(ctx: TestContext): Promise<void> {
  console.log("\n═══ Test 5: Memory Pressure (Concurrent Large Requests) ═══\n");

  try {
    // Send 20 concurrent requests with 100KB payloads
    const promises = Array.from({ length: 20 }).map(() =>
      fetch(`${ctx.proxy.baseUrl}/v1/chat/completions`, {
        method: "POST",
        headers: { "Content-Type": "application/json" },
        body: JSON.stringify({
          model: "deepseek/deepseek-chat",
          messages: [{ role: "user", content: "x".repeat(100_000) }], // 100KB
        }),
        signal: AbortSignal.timeout(5000),
      }).catch(() => null),
    );

    await Promise.all(promises);
    await sleep(100);

    const health = await fetch(`${ctx.proxy.baseUrl}/health`);
    assert(health.ok, "Proxy survived memory pressure (20x 100KB concurrent requests)");
  } catch (err) {
    assert(
      false,
      `Memory pressure test failed: ${err instanceof Error ? err.message : String(err)}`,
    );
  }
}

// ═══════════════════════════════════════════════════════════════════════════
// Main Test Runner