describe("crestodian probes", () => {

afterEach(() => {

vi.restoreAllMocks();

vi.unstubAllGlobals();

});

it("bounds noisy local command probe output", async () => {

expect(timeoutSpy).toHaveBeenCalledWith(expect.any(Function), MAX_TIMER_TIMEOUT_MS);

});

it("cancels gateway health response bodies", async () => {

const cancel = vi.fn(async () => undefined);

vi.stubGlobal(

"fetch",

vi.fn(

async () =>

({

ok: false,

statusText: "Service Unavailable",

body: { cancel },

}) as unknown as Response,

),

);

await expect(probeGatewayUrl("ws://127.0.0.1:1234")).resolves.toEqual({

reachable: false,

url: "ws://127.0.0.1:1234",

error: "Service Unavailable",

});

expect(cancel).toHaveBeenCalledTimes(1);

});

});

const timeoutMs = resolveTimerTimeoutMs(opts.timeoutMs, 900);

const controller = new AbortController();

const timeout = setTimeout(() => controller.abort(), timeoutMs);

let response: Response | undefined;

try {

const response = await fetch(healthUrl, {

response = await fetch(healthUrl, {

method: "GET",

signal: controller.signal,

});

};

} finally {

clearTimeout(timeout);

await response?.body?.cancel().catch(() => undefined);

}

}