- Release/CI/E2E: bound RPC RTT gateway readiness probes so a half-open local HTTP response cannot stall cleanup past the readiness deadline.

- Release/CI/E2E: stop RPC RTT gateway process groups so pnpm wrapper children cannot survive measurement cleanup.

- Release/CI/E2E: fail the kitchen-sink RPC walk when command RSS sampling captures no process samples.

- Release/CI/E2E: force-stop memory/fd repro gateway children that survive listener cleanup.

- Scripts/UI: stop descendant processes from wrapped non-interactive commands when `run-with-env` receives shutdown signals.

- Release/CI/E2E: write multi-node update Docker artifacts to unique per-run directories by default so parallel runs cannot overwrite evidence.

- Release/CI/E2E: write package Telegram Docker artifacts to unique per-run directories by default so parallel live/RTT runs cannot overwrite evidence.

export async function stopGatewayWithRuntime({

child,

childExitPollIntervalMs = 100,

childExitPolls = 50,

port,

findGatewayPidFn,

killProcess,

listenerSettleDelayMs = 500,

}) {

if (!hasChildExited(child)) {

child.kill("SIGINT");

for (let i = 0; i < 50; i += 1) {

if (hasChildExited(child)) {

break;

}

await sleep(100);

}

signalChild(child, "SIGINT");

await waitForChildExit(child, { intervalMs: childExitPollIntervalMs, polls: childExitPolls });

}

const listenerPid = findGatewayPidFn(port);

if (listenerPid) {

} catch {}

}

}

if (!hasChildExited(child)) {

signalChild(child, "SIGKILL");

await waitForChildExit(child, { intervalMs: childExitPollIntervalMs, polls: childExitPolls });

}

}

export { readBoundedResponseText };

function signalChild(child, signal) {

try {

child.kill(signal);

} catch {}

}

async function waitForChildExit(child, { intervalMs, polls }) {

for (let i = 0; i < polls; i += 1) {

if (hasChildExited(child)) {

return true;

}

await sleep(intervalMs);

}

return hasChildExited(child);

}

function parseJsonValue(text) {

try {

return JSON.parse(text);

expect(killProcess).not.toHaveBeenCalled();

});

it("force-kills a gateway child that survives listener cleanup", async () => {

const child = {

exitCode: null,

kill: vi.fn(),

signalCode: null,

};

const findGatewayPidFn = vi.fn().mockReturnValueOnce(1234).mockReturnValue(null);

const killProcess = vi.fn();

await expect(

stopGatewayWithRuntime({

child,

childExitPolls: 0,

findGatewayPidFn,

killProcess,

listenerSettleDelayMs: 0,

port: 9,

}),

).resolves.toBeUndefined();

expect(child.kill).toHaveBeenNthCalledWith(1, "SIGINT");

expect(killProcess).toHaveBeenCalledWith(1234, "SIGTERM");

expect(child.kill).toHaveBeenNthCalledWith(2, "SIGKILL");

});

it("bounds gateway readiness output while keeping newest logs", () => {

const first = updateGatewayReadyOutputState({ tail: "abc", readySeen: false }, "def", 8);

expect(first).toEqual({ tail: "abcdef", readySeen: false });