it("waits for event-loop readiness before starting CLI pairing requests", async () => {

setLocalLoopbackGatewayConfig();

let resolveReady!: (result: {

ready: boolean;

elapsedMs: number;

maxDriftMs: number;

checks: number;

aborted: boolean;

}) => void;

let resolveReady:

| ((result: {

ready: boolean;

elapsedMs: number;

maxDriftMs: number;

checks: number;

aborted: boolean;

}) => void)

| undefined;

eventLoopReadyState.promise = new Promise((resolve) => {

resolveReady = resolve;

});

expect(lastClientOptions?.clientName).toBe(GATEWAY_CLIENT_NAMES.CLI);

expect(startCalls).toBe(0);

if (!resolveReady) {

throw new Error("Expected gateway event-loop readiness resolver to be initialized");

}

resolveReady({ ready: true, elapsedMs: 0, maxDriftMs: 0, checks: 2, aborted: false });

await promise;

it("waits for gateway client teardown before resolving", async () => {

setLocalLoopbackGatewayConfig();

let releaseStop!: () => void;

let releaseStop: (() => void) | undefined;

let stopStarted = false;

let stopFinished = false;

let callResolved = false;

});

expect(callResolved).toBe(false);

if (!releaseStop) {

throw new Error("Expected gateway stop release callback to be initialized");

}

releaseStop();

await promise;

setLocalLoopbackGatewayConfig();

vi.useFakeTimers();

let releaseStop!: () => void;

let releaseStop: (() => void) | undefined;

let stopStarted = false;

__testing.setDepsForTests({

await vi.advanceTimersByTimeAsync(5);

if (!releaseStop) {

throw new Error("Expected gateway stop release callback to be initialized");

}

releaseStop();

await expect(promise).resolves.toEqual({ ok: true });