"ok",

);

});

it("keeps oversized wait helper intervals within the timeout", async () => {

const transport = createQaChannelTransport(createQaBusState());

await expect(

transport.capabilities.waitForCondition(async () => undefined, 5, Number.MAX_SAFE_INTEGER),

).rejects.toThrow("timed out after 5ms");

});

});

import { setTimeout as sleep } from "node:timers/promises";

import type { OpenClawConfig } from "openclaw/plugin-sdk/config-contracts";

import { resolveTimerTimeoutMs } from "openclaw/plugin-sdk/number-runtime";

import type { QaProviderMode } from "./model-selection.js";

import { extractQaFailureReplyText } from "./reply-failure.js";

import type {

timeoutMs = 15_000,

intervalMs = 100,

): Promise<T> {

const pollIntervalMs = resolveTimerTimeoutMs(intervalMs, 100, 0);

const startedAt = Date.now();

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

const value = await check();

if (value !== null && value !== undefined) {

return value;

}

await sleep(intervalMs);

const remainingMs = timeoutMs - (Date.now() - startedAt);

if (remainingMs <= 0) {

break;

}

await sleep(Math.min(pollIntervalMs, remainingMs));

}

throw new Error(`timed out after ${timeoutMs}ms`);

}