let5see/clawdbot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

test: avoid global SIGTERM emit in child-process-bridge

Browse Source
This commit is contained in:
Peter Steinberger
2026-01-17 19:20:40 +00:00
parent b0f44acf9e
commit 2d4de656d2
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/process/child-process-bridge.test.ts
View File

@@ -79,6 +79,7 @@ describe("attachChildProcessBridge", () => {
it("forwards SIGTERM to the wrapped child", async () => { it("forwards SIGTERM to the wrapped child", async () => {
const childPath = path.resolve(process.cwd(), "test/fixtures/child-process-bridge/child.js"); const childPath = path.resolve(process.cwd(), "test/fixtures/child-process-bridge/child.js");
const beforeSigterm = new Set(process.listeners("SIGTERM"));
const child = spawn(process.execPath, [childPath], { const child = spawn(process.execPath, [childPath], {
stdio: ["ignore", "pipe", "inherit"], stdio: ["ignore", "pipe", "inherit"],
env: process.env, env: process.env,
@@ -86,6 +87,8 @@ describe("attachChildProcessBridge", () => {
const { detach } = attachChildProcessBridge(child); const { detach } = attachChildProcessBridge(child);
detachments.push(detach); detachments.push(detach);
children.push(child); children.push(child);
const afterSigterm = process.listeners("SIGTERM");
const addedSigterm = afterSigterm.find((listener) => !beforeSigterm.has(listener));
if (!child.stdout) throw new Error("expected stdout"); if (!child.stdout) throw new Error("expected stdout");
const portLine = await waitForLine(child.stdout); const portLine = await waitForLine(child.stdout);
@@ -95,7 +98,8 @@ describe("attachChildProcessBridge", () => {
expect(await canConnect(port)).toBe(true); expect(await canConnect(port)).toBe(true);
// Simulate systemd sending SIGTERM to the parent process. // Simulate systemd sending SIGTERM to the parent process.
process.emit("SIGTERM"); if (!addedSigterm) throw new Error("expected SIGTERM listener");
addedSigterm();
await new Promise<void>((resolve, reject) => { await new Promise<void>((resolve, reject) => {
const timeout = setTimeout(() => reject(new Error("timeout waiting for child exit")), 10_000); const timeout = setTimeout(() => reject(new Error("timeout waiting for child exit")), 10_000);