// Measures gateway RPC round-trip time by launching an isolated local gateway

// and writing qa-lab-compatible summary artifacts.

import { spawn } from "node:child_process";

import { randomUUID } from "node:crypto";

import { existsSync } from "node:fs";

const DEFAULT_METHODS = ["health", "config.get"];

const DEFAULT_ITERATIONS = 10;

/** Maximum time to wait for a spawned gateway to become reachable. */

export const READY_TIMEOUT_MS = 120_000;

/** Per-probe timeout used while polling gateway readiness endpoints. */

export const READY_PROBE_TIMEOUT_MS = 1_000;

const PARENT_TERMINATION_SIGNALS = ["SIGHUP", "SIGINT", "SIGTERM"];

const IS_DIRECT_RUN =

return String(error);

}

/**

* Polls readiness endpoints while also failing fast if the child exits.

*/

export async function waitForGatewayReady({

child,

fetchImpl = fetch,

return [path.join(repoRoot, "openclaw.mjs")];

}

/**

* Signals the gateway process group on POSIX so spawned children are cleaned up.

*/

export function signalGatewayProcess(child, signal, killProcess = defaultKillProcess) {

if (process.platform !== "win32" && typeof child.pid === "number") {

try {

}

}

/**

* Checks process-group liveness without treating an already-exited child as an error.

*/

export function isGatewayProcessAlive(child, killProcess = defaultKillProcess) {

if (process.platform !== "win32" && typeof child.pid === "number") {

try {

}

}

/**

* Installs parent-process cleanup handlers for a spawned gateway.

*/

export function installGatewayParentCleanup(

child,

{ killProcess = defaultKillProcess, processLike = process } = {},

return !isGatewayProcessAlive(child, killProcess);

}

/**

* Stops the gateway with SIGTERM first and SIGKILL after the grace window.

*/

export async function stopGateway(child, options = {}) {

if (!isGatewayProcessAlive(child, options.killProcess)) {

return;

}

}

/**

* Starts an isolated loopback gateway with temp HOME/state directories.

*/

export async function startGateway({

configPath,

env = process.env,

return child;

}

/**

* Removes the temporary root used by the RPC RTT probe.

*/

export async function cleanupTempRoot(tempRoot, { rmImpl = fs.rm } = {}) {

try {

await rmImpl(tempRoot, { force: true, recursive: true });