fix: update code examples in statusline documentation and improve module provider abort handling

Author: qorzj

docs/statusline.md

@@ -6,7 +6,7 @@ Deep Code CLI 支持通过插件向终端底部状态栏注入自定义信息（
 
 在 `~/.deepcode/settings.json`(或项目级 `.deepcode/settings.json`)中添加 `statusline` 字段:
 
-```jsonc
+```json
 {
   "statusline": {
     "enabled": true,
@@ -100,7 +100,7 @@ export default function tokensProvider({ projectRoot, session }) {
 
 ## 安全限制
 
-- **module provider 路径必须位于项目根目录或用户家目录之下**,绝对路径在这两个范围之外会被拒绝加载(防止从任意位置执行代码)。
+- **module provider 路径必须位于项目根目录或用户home目录之下**,绝对路径在这两个范围之外会被拒绝加载(防止从任意位置执行代码)。
 - 单个 segment 文本被自动:
   - 取第一个非空行
   - 去除 ANSI 转义序列

docs/statusline_en.md

@@ -6,7 +6,7 @@ Deep Code CLI lets you inject custom information into the status line at the bot
 
 Add a `statusline` field to `~/.deepcode/settings.json` (or the project-level `.deepcode/settings.json`):
 
-```jsonc
+```json
 {
   "statusline": {
     "enabled": true,

packages/cli/src/tests/statusline.test.ts

@@ -171,6 +171,42 @@ test("loadModuleProvider succeeds for a well-formed module", async () => {
   }
 });
 
+test("loadModuleProvider removes abort listener after successful fetch", async () => {
+  const dir = fs.mkdtempSync(path.join(os.tmpdir(), "deepcode-statusline-"));
+  const modPath = path.join(dir, "cleanup.mjs");
+  fs.writeFileSync(modPath, "export default () => 'ok';", "utf8");
+  try {
+    const provider = await loadModuleProvider(modPath, undefined, "cleanup", 10_000);
+    assert.ok(provider);
+
+    const ac = new AbortController();
+    const signal = ac.signal;
+    const originalAdd = signal.addEventListener;
+    const originalRemove = signal.removeEventListener;
+    let abortListenerAdds = 0;
+    let abortListenerRemoves = 0;
+    signal.addEventListener = function (this: AbortSignal, ...args: Parameters<AbortSignal["addEventListener"]>) {
+      if (args[0] === "abort") {
+        abortListenerAdds += 1;
+      }
+      return originalAdd.apply(this, args);
+    } as AbortSignal["addEventListener"];
+    signal.removeEventListener = function (this: AbortSignal, ...args: Parameters<AbortSignal["removeEventListener"]>) {
+      if (args[0] === "abort") {
+        abortListenerRemoves += 1;
+      }
+      return originalRemove.apply(this, args);
+    } as AbortSignal["removeEventListener"];
+
+    const result = await provider!.fetch({ projectRoot: dir, signal });
+    assert.equal(result, "ok");
+    assert.equal(abortListenerAdds, 1);
+    assert.equal(abortListenerRemoves, 1);
+  } finally {
+    fs.rmSync(dir, { recursive: true, force: true });
+  }
+});
+
 test("resolveSettingsSources lets project-level providers override user-level by id", () => {
   const resolved = resolveSettingsSources(
     {

packages/cli/src/ui/statusline/module-provider.ts

@@ -63,26 +63,33 @@ export async function loadModuleProvider(
         if (ctx.signal.aborted) {
           return "";
         }
-        const result = await Promise.race([
-          Promise.resolve().then(() =>
-            providerFn({
-              projectRoot: ctx.projectRoot,
-              session: ctx.getSessionInfo ? ctx.getSessionInfo() : null,
-            })
-          ),
-          new Promise<string>((_, reject) => {
-            const timer = setTimeout(() => reject(new Error("timeout")), timeout);
-            ctx.signal.addEventListener(
-              "abort",
-              () => {
-                clearTimeout(timer);
-                reject(new Error("aborted"));
-              },
-              { once: true }
-            );
-          }),
-        ]);
-        return typeof result === "string" ? result : "";
+        let timer: ReturnType<typeof setTimeout> | null = null;
+        let onAbort: (() => void) | null = null;
+        const timeoutPromise = new Promise<never>((_, reject) => {
+          timer = setTimeout(() => reject(new Error("timeout")), timeout);
+          onAbort = () => reject(new Error("aborted"));
+          ctx.signal.addEventListener("abort", onAbort, { once: true });
+        });
+
+        try {
+          const result = await Promise.race([
+            Promise.resolve().then(() =>
+              providerFn({
+                projectRoot: ctx.projectRoot,
+                session: ctx.getSessionInfo ? ctx.getSessionInfo() : null,
+              })
+            ),
+            timeoutPromise,
+          ]);
+          return typeof result === "string" ? result : "";
+        } finally {
+          if (timer) {
+            clearTimeout(timer);
+          }
+          if (onAbort) {
+            ctx.signal.removeEventListener("abort", onAbort);
+          }
+        }
       },
     };
   } catch {