fix(coding-agent): remove sleep's abort listener once the timer fires (stack 1/3)

packages/coding-agent/src/utils/sleep.ts

@@ -1,5 +1,6 @@
 /**
  * Sleep helper that respects abort signal.
+ * The abort listener is removed once the timer fires, so a long-lived signal does not collect one per call.
  */
 export function sleep(ms: number, signal?: AbortSignal): Promise<void> {
 	return new Promise((resolve, reject) => {
@@ -8,11 +9,15 @@ export function sleep(ms: number, signal?: AbortSignal): Promise<void> {
 			return;
 		}
 
-		const timeout = setTimeout(resolve, ms);
-
-		signal?.addEventListener("abort", () => {
+		const onAbort = () => {
 			clearTimeout(timeout);
 			reject(new Error("Aborted"));
-		});
+		};
+		const timeout = setTimeout(() => {
+			signal?.removeEventListener("abort", onAbort);
+			resolve();
+		}, ms);
+
+		signal?.addEventListener("abort", onAbort, { once: true });
 	});
 }

packages/coding-agent/test/sleep.test.ts

@@ -0,0 +1,28 @@
+import { describe, expect, it, vi } from "vitest";
+import { sleep } from "../src/utils/sleep.ts";
+
+describe("sleep", () => {
+	it("resolves after the delay", async () => {
+		await expect(sleep(1)).resolves.toBeUndefined();
+	});
+
+	it("rejects at once when the signal is already aborted", async () => {
+		const controller = new AbortController();
+		controller.abort();
+		await expect(sleep(1000, controller.signal)).rejects.toThrow("Aborted");
+	});
+
+	it("rejects when aborted mid-wait", async () => {
+		const controller = new AbortController();
+		const waiting = sleep(1000, controller.signal);
+		controller.abort();
+		await expect(waiting).rejects.toThrow("Aborted");
+	});
+
+	it("removes its abort listener once the timer fires", async () => {
+		const controller = new AbortController();
+		const remove = vi.spyOn(controller.signal, "removeEventListener");
+		await sleep(1, controller.signal);
+		expect(remove).toHaveBeenCalledWith("abort", expect.any(Function));
+	});
+});