).rejects.toThrow("qa gateway child did not reach restart boundary");

});

it("keeps oversized restart-boundary poll intervals within the timeout", async () => {

await expect(

testing.waitForQaGatewayRestartBoundary({

logs: () => "signal SIGUSR1 received\n",

offset: 0,

pollMs: Number.MAX_SAFE_INTEGER,

timeoutMs: 5,

}),

).rejects.toThrow("qa gateway child did not reach restart boundary");

});

it("stages a live Anthropic setup-token profile for isolated QA workers", async () => {

const stateDir = await mkdtemp(path.join(os.tmpdir(), "qa-setup-token-state-"));

cleanups.push(async () => {

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

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

import { formatErrorMessage } from "openclaw/plugin-sdk/error-runtime";

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

import type { ModelProviderConfig } from "openclaw/plugin-sdk/provider-model-shared";

import { fetchWithSsrFGuard } from "openclaw/plugin-sdk/ssrf-runtime";

import {

timeoutMs?: number;

}) {

const timeoutMs = params.timeoutMs ?? QA_GATEWAY_CHILD_RESTART_BOUNDARY_TIMEOUT_MS;

const pollMs = params.pollMs ?? 100;

const pollMs = resolveTimerTimeoutMs(params.pollMs ?? 100, 100, 0);

const startedAt = Date.now();

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

if (params.logs().slice(params.offset).includes("restart mode:")) {

return;

}

await sleep(pollMs);

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

if (remainingMs <= 0) {

break;

}

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

}

throw new Error(`qa gateway child did not reach restart boundary within ${timeoutMs}ms`);

}