Function runTests

test/compression.ts:78–275

()

// Import after mock server is ready
async function runTests() {
  const { startProxy } = await import("../src/proxy.js");

  console.log("\n═══ Compression & Size Validation Tests ═══\n");

  let passed = 0;
  let failed = 0;

  function assert(condition: boolean, msg: string) {
    if (condition) {
      console.log(`  ✓ ${msg}`);
      passed++;
    } else {
      console.error(`  ✗ FAIL: ${msg}`);
      failed++;
    }
  }

  // Start mock BlockRun API
  const mockApi = await startMockServer();
  console.log(`Mock API started on port ${mockApi.port}`);

  // Generate an ephemeral test wallet key
  const testWalletKey = generatePrivateKey();

  // Start ClawRouter proxy pointing to mock API
  const proxy = await startProxy({
    wallet: testWalletKey,
    apiBase: `http://127.0.0.1:${mockApi.port}`,
    port: 0,
    skipBalanceCheck: true,
    autoCompressRequests: true, // Enable compression
    compressionThresholdKB: 50, // Lower threshold for testing
    onReady: (port) => console.log(`ClawRouter proxy started on port ${port}`),
  });

  // Test 1: Small request - no compression needed
  {
    console.log("\n--- Test 1: Small request (no compression) ---");
    modelCalls.length = 0;
    paymentAttempts.length = 0;
    requestBodies.length = 0;

    const res = await fetch(`${proxy.baseUrl}/v1/chat/completions`, {
      method: "POST",
      headers: { "Content-Type": "application/json" },
      body: JSON.stringify({
        model: "auto",
        messages: [{ role: "user", content: "Hello" }],
        max_tokens: 50,
      }),
    });

    assert(res.ok, `Small request succeeds: ${res.status}`);
    assert(modelCalls.length === 1, `One model called: ${modelCalls.join(", ")}`);
  }

  // Test 2: Large request - compression attempted