return port;

}

async function withTimeout<T>(promise: Promise<T>, timeoutMs: number, message: string): Promise<T> {

let timer: NodeJS.Timeout | undefined;

try {

return await Promise.race([

promise,

new Promise<never>((_resolve, reject) => {

timer = setTimeout(() => reject(new Error(message)), timeoutMs);

}),

]);

} finally {

if (timer) {

clearTimeout(timer);

}

}

}

async function createFakeGateway(port = 0): Promise<FakeGateway> {

const server = new WebSocketServer({ host: "127.0.0.1", port });

servers.push(server);

return seen;

})();

const timeoutPromise = new Promise<never>((_resolve, reject) => {

setTimeout(() => reject(new Error("timed out waiting for SDK run events")), 2_000);

});

const [seen, result] = await Promise.all([

Promise.race([seenPromise, timeoutPromise]),

withTimeout(seenPromise, 2_000, "timed out waiting for SDK run events"),

run.wait({ timeoutMs: 2_000 }),

]);

}

return { seen, sessionKeys };

})();

const eventsTimeout = new Promise<never>((_resolve, reject) => {

setTimeout(() => reject(new Error("timed out waiting for real Gateway SDK events")), 2_000);

});

emitAgentEvent({

runId,

data: { phase: "end", endedAt: 222 },

});

const { seen, sessionKeys } = await Promise.race([eventsPromise, eventsTimeout]);

const { seen, sessionKeys } = await withTimeout(

eventsPromise,

2_000,

"timed out waiting for real Gateway SDK events",

);

expect(seen).toEqual(["run.started", "assistant.delta", "run.completed"]);

expect(sessionKeys).toEqual([

"agent:main:dashboard:sdk-real-gateway",

})();

const result = await run.wait({ timeoutMs: 180_000 });

const events = await Promise.race([

const events = await withTimeout(

eventsPromise,

new Promise<never>((_resolve, reject) => {

setTimeout(() => reject(new Error("timed out waiting for live SDK run events")), 5_000);

}),

]);

5_000,

"timed out waiting for live SDK run events",

);

expect(result.status).toBe("completed");

expect(events.terminal).toBe("run.completed");