const spawnMock = vi.hoisted(() => vi.fn());

const killProcessTreeMock = vi.hoisted(() => vi.fn());

const signalProcessTreeMock = vi.hoisted(() => vi.fn());

vi.mock("node:child_process", async () => ({

...(await vi.importActual<typeof import("node:child_process")>("node:child_process")),

vi.mock("../process/kill-tree.js", () => ({

killProcessTree: killProcessTreeMock,

signalProcessTree: signalProcessTreeMock,

}));

class MockChildProcess extends EventEmitter {

vi.useRealTimers();

spawnMock.mockReset();

killProcessTreeMock.mockReset();

signalProcessTreeMock.mockReset();

});

it("starts stdio MCP servers in a disposable process group on POSIX", async () => {

await closing;

});

it("force-SIGKILLs synchronously when killProcessTree's grace expires (#86412)", async () => {

vi.useFakeTimers();

const child = new MockChildProcess();

spawnMock.mockReturnValue(child);

const transport = new OpenClawStdioClientTransport({ command: "npx" });

const started = transport.start();

child.emit("spawn");

await started;

const closing = transport.close();

await vi.advanceTimersByTimeAsync(2000);

expect(killProcessTreeMock).toHaveBeenCalledWith(4321);

expect(signalProcessTreeMock).not.toHaveBeenCalled();

// killProcessTree's SIGKILL is .unref()'d (#86412); close() force-SIGKILLs synchronously instead.

await vi.advanceTimersByTimeAsync(2000);

expect(signalProcessTreeMock).toHaveBeenCalledWith(4321, "SIGKILL");

child.exitCode = 0;

child.emit("close", 0);

await closing;

});

it("does not kill the process tree when graceful stdio close exits", async () => {

vi.useFakeTimers();

const child = new MockChildProcess();