import { EventEmitter } from "node:events";

import { afterEach, beforeEach, describe, expect, it, vi } from "vitest";

import { MAX_TIMER_TIMEOUT_MS } from "../../shared/number-coercion.js";

class FakeSocket extends EventEmitter {

public readonly writes: string[] = [];

await rejected;

expect(proxySocket.destroyed).toBe(true);

});

it("caps oversized CONNECT timeouts before arming the watchdog", async () => {

vi.useFakeTimers();

const proxySocket = new FakeSocket();

setNextNetSocket(proxySocket);

const { openHttpConnectTunnel } = await import("./http-connect-tunnel.js");

const tunnel = openHttpConnectTunnel({

proxyUrl: new URL("http://proxy.example:8080"),

targetHost: "api.push.apple.com",

targetPort: 443,

timeoutMs: Number.MAX_SAFE_INTEGER,

});

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`,

);

expect(proxySocket.destroyed).toBe(true);

});

});