test(infra): stabilize CONNECT timeout cap test

steipete · steipete · commit 30c18e8e323c · 2026-05-29T23:39:50.000+01:00
diff --git a/src/infra/net/http-connect-tunnel.test.ts b/src/infra/net/http-connect-tunnel.test.ts
@@ -353,6 +353,7 @@ describe("openHttpConnectTunnel", () => {
 
   it("caps oversized CONNECT timeouts before arming the watchdog", async () => {
     vi.useFakeTimers();
+    const setTimeoutSpy = vi.spyOn(globalThis, "setTimeout");
     const proxySocket = new FakeSocket();
     setNextNetSocket(proxySocket);
     const { openHttpConnectTunnel } = await import("./http-connect-tunnel.js");
@@ -363,14 +364,16 @@ describe("openHttpConnectTunnel", () => {
       targetPort: 443,
       timeoutMs: Number.MAX_SAFE_INTEGER,
     });
+    const rejected = expect(tunnel).rejects.toThrow(
+      `Proxy CONNECT failed via http://proxy.example:8080: Proxy CONNECT timed out after ${MAX_TIMER_TIMEOUT_MS}ms`,
+    );
+    expect(setTimeoutSpy).toHaveBeenCalledWith(expect.any(Function), MAX_TIMER_TIMEOUT_MS);
 
     await vi.advanceTimersByTimeAsync(1);
     expect(proxySocket.destroyed).toBe(false);
 
-    await vi.advanceTimersByTimeAsync(MAX_TIMER_TIMEOUT_MS - 1);
-    await expect(tunnel).rejects.toThrow(
-      `Proxy CONNECT failed via http://proxy.example:8080: Proxy CONNECT timed out after ${MAX_TIMER_TIMEOUT_MS}ms`,
-    );
+    await vi.advanceTimersToNextTimerAsync();
+    await rejected;
     expect(proxySocket.destroyed).toBe(true);
   });
 });
