truncated?: boolean;

};

type OpenClawTestChildProcess = Pick<ChildProcessWithoutNullStreams, "kill" | "pid">;

function createBoundedStringLog(): string[] {

const log = [] as BoundedStringLog;

log.byteLength = 0;

cwd,

env: { ...process.env, VITEST: "1" },

stdio: ["ignore", "pipe", "pipe"],

detached: shouldUseOpenClawTestProcessGroup(),

});

child.stdout?.setEncoding("utf8");

child.stderr?.setEncoding("utf8");

]);

if (completed === null) {

child.kill("SIGKILL");

signalOpenClawTestProcess(child, "SIGKILL");

throw new Error(`timeout preparing gateway entrypoint\n${formatLogs(stdout, stderr)}`);

}

if (completed.code !== 0) {

cwd,

env,

stdio: ["ignore", "pipe", "pipe"],

detached: shouldUseOpenClawTestProcessGroup(),

},

);

}

if (!hasChildExited(child) && !child.killed) {

try {

child.kill("SIGTERM");

signalOpenClawTestProcess(child, "SIGTERM");

} catch {

// ignore

}

);

if (!exited && !hasChildExited(child) && !child.killed) {

try {

child.kill("SIGKILL");

signalOpenClawTestProcess(child, "SIGKILL");

} catch {

// ignore

}

cwd: params.cwd,

env: params.env,

stdio: ["ignore", "pipe", "pipe"],

detached: shouldUseOpenClawTestProcessGroup(),

});

child.stdout?.setEncoding("utf8");

child.stderr?.setEncoding("utf8");

sleep(params.timeoutMs).then(() => null),

]);

if (completed === null) {

child.kill("SIGKILL");

signalOpenClawTestProcess(child, "SIGKILL");

await waitForGatewayExit(child, GATEWAY_STOP_TIMEOUT_MS);

throw new Error(

`command timed out after ${params.timeoutMs}ms: ${params.args.join(" ")}\n${formatLogs(stdout, stderr)}`,

};

}

function shouldUseOpenClawTestProcessGroup(): boolean {

return process.platform !== "win32";

}

function signalOpenClawTestProcess(

child: OpenClawTestChildProcess,

signal: NodeJS.Signals,

killProcess: (pid: number, signal: NodeJS.Signals) => boolean = process.kill,

): void {

if (shouldUseOpenClawTestProcessGroup() && typeof child.pid === "number") {

try {

killProcess(-child.pid, signal);

return;

} catch {

// Fall back to the direct child if the process group already exited.

}

}

child.kill(signal);

}

export const testing = {

appendLogChunk,

createBoundedStringLog,

formatLogs,

hasChildExited,

signalOpenClawTestProcess,

waitForPortOpen,

};