throw exitedBeforeReadyError();

}

while (Date.now() - started < timeoutMs) {

const remainingMs = Math.max(1, timeoutMs - (Date.now() - started));

if (hasChildExited(child)) {

throw exitedBeforeReadyError();

}

try {

const readyz = await fetchJson(`http://127.0.0.1:${port}/readyz`, {

attempts: 1,

fetchImpl: options.fetchImpl,

timeoutMs: Math.min(FETCH_TIMEOUT_MS, remainingMs),

});

if (readyz.ok) {

return;

if (logReportedReady()) {

lastError = `${lastError}; gateway log reported ready before HTTP readiness`;

}

await delay(pollDelayMs);

const nextDelayMs = Math.min(pollDelayMs, Math.max(1, timeoutMs - (Date.now() - started)));

await delay(nextDelayMs);

}

if (hasChildExited(child)) {

throw new Error(`gateway exited before ready\n${tailFile(logPath)}`);

rmSync(root, { recursive: true, force: true });

}

});

it("keeps stalled readiness probes inside the caller deadline", async () => {

const root = mkdtempSync(path.join(tmpdir(), "openclaw-kitchen-rpc-stalled-ready-"));

try {

const logPath = path.join(root, "gateway.log");

writeFileSync(logPath, "booting\n");

let calls = 0;

const startedAt = Date.now();

await expect(

waitForGatewayReady({ exitCode: null, signalCode: null }, 9, logPath, {

fetchImpl: () => {

calls += 1;

return new Promise(() => {});

},

pollDelayMs: 1,

timeoutMs: 25,

}),

).rejects.toThrow("gateway did not become ready");

expect(calls).toBe(1);

expect(Date.now() - startedAt).toBeLessThan(500);

} finally {

rmSync(root, { recursive: true, force: true });

}

});

});

describe("kitchen-sink RPC gateway readiness logs", () => {