fix(agent-chat): 自唤醒回调抽成 selfChat，端口取实际监听端口、测试环境短路

主体由另一个会话完成（其会话已关闭，由我接手核对并提交），我补了两处修复与一条守卫。 ## 它修的是什么六处「服务端自己给某个 agent 发一条 chat」各自写死 `hostname:'localhost', port: systemConfig.port`（3010）。单测把路由挂到 `app.listen(0)` 的临时端口上，回调却照样打进**线上 3010** —— 每跑一次汇报用例就给真 CEO 发一条 chat、起一个常驻 claude CLI 子进程、留一个 callback-T-* 会话目录。症状完全静默：测试全绿，只有进程数和内存在涨。（这条是被我在批 5 新加的 task-dispatch-store 用例触发出来的：那之前没有任何测试会走到汇报回调。）抽成 selfChat：端口从 req.socket 取（收到这条请求的那个监听端口，天然就是「我自己」），测试环境整体短路。 ## 我接手时发现并修掉的两处 `task/transition` 的两个调用点删掉了 `const chatReq` / `const postData` 的声明，**却留下了 `chatReq.write(postData); chatReq.end();` 两行**。 `node --check` 照样通过 —— 那是运行时 ReferenceError 不是语法错；而它在 `setImmediate` 里抛就是未捕获异常，**直接杀进程**。真起服务打了一遍 POST /api/agent/ceo/task/transition：200，服务仍在。修之前这条路必炸。 ## 守卫：server/tests/unit/self-chat-callbacks.test.js 1. chatReq / postData 只许出现在 selfChat 函数体内 —— 「删了声明留下调用」这类改造残留，语法检查和单测都抓不到，只有真跑到那条路径才炸； 2. 不许再有第二处自己拼 http.request 打 systemConfig.port（分叉的开始）； 3. 测试环境必须短路。第一版守卫把 selfChat 上方那段**注释**里引用的写法当成漏改报了红 —— 那是文档不是代码，已跳过注释行。全量：135 文件 / 1272 测试全绿。 Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>

fix(agent-chat): 自唤醒回调抽成 selfChat，端口取实际监听端口、测试环境短路
主体由另一个会话完成（其会话已关闭，由我接手核对并提交），我补了两处修复与一条守卫。 ## 它修的是什么六处「服务端自己给某个 agent 发一条 chat」各自写死 `hostname:'localhost', port: systemConfig.port`（3010）。单测把路由挂到 `app.listen(0)` 的临时端口上，回调却照样打进**线上 3010** —— 每跑一次汇报用例就给真 CEO 发一条 chat、起一个常驻 claude CLI 子进程、留一个 callback-T-* 会话目录。症状完全静默：测试全绿，只有进程数和内存在涨。（这条是被我在批 5 新加的 task-dispatch-store 用例触发出来的：那之前没有任何测试会走到汇报回调。）抽成 selfChat：端口从 req.socket 取（收到这条请求的那个监听端口，天然就是「我自己」），测试环境整体短路。 ## 我接手时发现并修掉的两处 `task/transition` 的两个调用点删掉了 `const chatReq` / `const postData` 的声明，**却留下了 `chatReq.write(postData); chatReq.end();` 两行**。 `node --check` 照样通过 —— 那是运行时 ReferenceError 不是语法错；而它在 `setImmediate` 里抛就是未捕获异常，**直接杀进程**。真起服务打了一遍 POST /api/agent/ceo/task/transition：200，服务仍在。修之前这条路必炸。 ## 守卫：server/tests/unit/self-chat-callbacks.test.js 1. chatReq / postData 只许出现在 selfChat 函数体内 —— 「删了声明留下调用」这类改造残留，语法检查和单测都抓不到，只有真跑到那条路径才炸； 2. 不许再有第二处自己拼 http.request 打 systemConfig.port（分叉的开始）； 3. 测试环境必须短路。第一版守卫把 selfChat 上方那段**注释**里引用的写法当成漏改报了红 —— 那是文档不是代码，已跳过注释行。全量：135 文件 / 1272 测试全绿。 Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
yibo · 宜博
1 parent 8f4c1b63
Showing 2 changed files with 105 additions and 98 deletions
server/routes/agent-chat.js
server/tests/unit/self-chat-callbacks.test.js
@@ -31,6 +31,38 @@ const { companyWorkspaceDir } = require(&#39;../src/core/prompt-builder&#39;);
 const systemConfig = require('../config');
 const router = express.Router();
+// 笏笏 閾ｪ蜚､驢貞屓隹ｼ夂ｫｯ蜿｣蜿門ｮ樣刔逶大成遶ｯ蜿｣梧ｵ玖ｯ慕識蠅紛菴鍋洒霍ｯ 笏笏笏笏笏笏笏笏笏笏笏笏笏笏笏笏笏笏笏笏
+//
+// 譖ｾ扈剰ｿ吝螟推閾ｪ蜀呎ｭｻ `hostname:'localhost', port: systemConfig.port`3010峨
+// 蜊墓ｵ区滑霍ｯ逕ｱ謖ょ芦 `app.listen(0)` 逧ｸｴ譌ｶ遶ｯ蜿｣荳奇ｼ悟屓隹唆辣ｧ譬ｷ謇楢ｿ**郤ｿ荳 3010**
+// 豈剰ｷ台ｸ谺｡ task-dispatch-store 逧ｱ冠逕ｨ萓具ｼ悟ｰｱ扈咏悄 CEO 蜿台ｸ譚｡ chat縲∬ｵｷ荳荳ｪ蟶ｸ鬩ｻ
+// claude CLI 蟄占ｿ帷ｨ九∝惠 system/agents/ceo/_global/ 荳狗蕗荳荳ｪ callback-T-* 逶ｮ蠖輔
+// 逞憾譏ｯ髱咎ｻ倡噪域ｵ玖ｯ募扈ｿ会ｼ悟宵譛芽ｿ帷ｨ区焚蜥悟蟄伜惠豸ｨ 窶披 蜷 docs/done/claude-cli-session-leak.md縲
+// 遶ｯ蜿｣莉 req.socket 蜿厄ｼ域噺蛻ｰ霑呎擅隸ｷ豎ら噪驍｣荳ｪ逶大成遶ｯ蜿｣悟､ｩ辟ｶ蟆ｱ譏ｯ"謌題蟾ｱ"峨
+const isTestEnv = () => !!process.env.VITEST || process.env.NODE_ENV === 'test';
+
+function selfChat(req, agentId, message, conversationId, label = 'SelfChat') {
+  if (isTestEnv()) {
+    console.log(`[${label}] 竢ｭ 豬玖ｯ慕識蠅ｼ瑚ｷｳ霑ｯｹ ${agentId} 逧蜚､驢 (conv: ${conversationId})`);
+    return;
+  }
+  const http = require('http');
+  const postData = JSON.stringify({ message, conversationId });
+  const chatReq = http.request({
+    hostname: req?.socket?.localAddress || '127.0.0.1',
+    port: req?.socket?.localPort || systemConfig.port,
+    path: `/api/agent/${agentId}/chat`,
+    method: 'POST',
+    headers: { 'Content-Type': 'application/json', 'Content-Length': Buffer.byteLength(postData) },
+  }, (chatRes) => {
+    chatRes.on('data', () => {});
+    chatRes.on('end', () => console.log(`[${label}] 笨 蟾ｲ蜚､驢 ${agentId} (conv: ${conversationId})`));
+  });
+  chatReq.on('error', (err) => console.error(`[${label}] 笶 蝗櫁ｰ､ｱ雍･: ${err.message}`));
+  chatReq.write(postData);
+  chatReq.end();
+}
+
 // 笏笏 荳荳ｪ蟇ｻ蝮蜷搾ｼ御ｸ臥ｧ崎ｯｭ荵会ｼ28 蜿ｷ隶ｾ隶｡ ﾂｧ4.1俄楳笏笏笏笏笏笏笏笏笏笏笏笏笏笏笏笏笏笏笏笏笏笏笏笏笏笏笏笏笏
 //
 // 謾ｹ騾蜑崎ｿ咎蜿ｪ譛我ｸ荳ｪ getAgentDir()瑚ｿ泌屓蛟ｼ蜷梧慮陲ｫ蠖捺縲靴LI 逧 cwd縲阪梧悽菴灘宵隸ｻ譬ｹ縲
@@ -1899,26 +1931,7 @@ router.post(&#39;/task/dispatch&#39;, async (req, res) =&gt; {
           const taskMessage = `[TASK from ${from}]\n莉ｻ蜉｡郛門捷: ${taskId}\n莨伜郤ｧ: ${priority}${goalInfo}\n\n${task}\n\n隸ｷ遶句叉謇ｧ陦梧ｭ､莉ｻ蜉｡縲よ鴬陦悟ｮ梧蜷趣ｼ悟ｦよ棡菴逧 agent.md 隗ｮ壻ｺ錘扈ｭ豁･鬪､瑚ｯｷ蝨ｨ蜷御ｸ霓ｮ蟇ｹ隸昜ｸｭ扈ｧ扈ｭ謇ｧ陦鯉ｼ御ｸ崎ｦ∝●荳区擂遲牙ｾｸ顔ｺｧ蛯ｬ菫ｼ—n蜈ｨ驛ｨ螳梧蜷惹ｽｿ逕ｨ莉･荳句多莉､豎冠:\nnode bin/lemon.js task report --taskId ${taskId} --from ${to} --to ${from} --status done --summary "(菴逧ｮ梧鞫倩ｦ)"`;
           // 蜀Κ隗ｦ蜿題♀螟ｩ (騾夊ｿ HTTP 閾ｪ隹畑)
-          const http = require('http');
-          const postData = JSON.stringify({ message: taskMessage, conversationId: executionConvId });
-          const options = {
-            hostname: 'localhost', port: systemConfig.port,
-            path: `/api/agent/${to}/chat`,
-            method: 'POST',
-            headers: { 'Content-Type': 'application/json', 'Content-Length': Buffer.byteLength(postData) },
-          };
-          const chatReq = http.request(options, (chatRes) => {
-            let body = '';
-            chatRes.on('data', (chunk) => body += chunk);
-            chatRes.on('end', () => {
-              console.log(`[TaskDispatch] 笨 ${to} 蠑よｭ･謇ｧ陦悟ｷｲ蜷ｯ蜉ｨ (conv: ${executionConvId})`);
-            });
-          });
-          chatReq.on('error', (err) => {
-            console.error(`[TaskDispatch] 笶 蠑よｭ･謇ｧ陦悟､ｱ雍･: ${err.message}`);
-          });
-          chatReq.write(postData);
-          chatReq.end();
+          selfChat(req, to, taskMessage, executionConvId, 'TaskDispatch');
         } catch (err) {
           console.error(`[TaskDispatch] 笶 蠑よｭ･隗ｦ蜿鷹漠隸ｯ: ${err.message}`);
         }
@@ -2077,26 +2090,7 @@ router.post(&#39;/task/report&#39;, (req, res) =&gt; {
           const statusText = status === 'done' ? '笨 蟾ｲ螳梧' : '笶 螟ｱ雍･';
           const callbackMessage = `[TASK_CALLBACK]\n莉ｻ蜉｡郛門捷: ${taskId}\n謇ｧ陦瑚: ${from}\n迥ｶ諤: ${statusText}\n鞫倩ｦ: ${summary || '(譌鞫倩ｦ)'}\n莠ｧ蜃ｺ譁ｻｶ: ${outputs.length > 0 ? outputs.join(', ') : '(譌)'}\n${taskMeta ? `蜴溷ｧ倶ｻｻ蜉｡: ${taskMeta.task}` : ''}\n\n**蜴ｻ驥肴署驢**壼惠 dispatch 莉ｻ菴墓眠莉ｻ蜉｡蜑搾ｼ瑚ｯｷ蜉｡蠢譽譟･逶ｮ譬 Agent 逧 todo.md 蜥悟螻莉ｻ蜉｡迥ｶ諤√ょｦよ棡蜷御ｸ逶ｮ譬ｷｲ譛臥嶌莨ｼ莉ｻ蜉｡蝨ｨ霑幄｡御ｸｭ檎峩謗･霍ｳ霑叉蜿ｯ檎ｻ晏ｯｹ遖∵ｭ｢驥榊､榊蜿代n\n隸ｷ譽譟･荳願ｿｰ莉ｻ蜉｡逧鴬陦檎ｻ捺棡檎┯蜷取ｹ謐ｮ菴逧 plan.md 扈ｧ扈ｭ謇ｧ陦御ｸ倶ｸ豁･隶｡蛻偵Ａ;
-          const http = require('http');
-          const postData = JSON.stringify({ message: callbackMessage, conversationId: callbackConvId });
-          const options = {
-            hostname: 'localhost', port: systemConfig.port,
-            path: `/api/agent/${to}/chat`,
-            method: 'POST',
-            headers: { 'Content-Type': 'application/json', 'Content-Length': Buffer.byteLength(postData) },
-          };
-          const chatReq = http.request(options, (chatRes) => {
-            let body = '';
-            chatRes.on('data', (chunk) => body += chunk);
-            chatRes.on('end', () => {
-              console.log(`[TaskCallback] 笨 蟾ｲ蝗櫁ｰ ${to}: ${taskId} ${statusText} (conv: ${callbackConvId})`);
-            });
-          });
-          chatReq.on('error', (err) => {
-            console.error(`[TaskCallback] 笶 蝗櫁ｰ､ｱ雍･: ${err.message}`);
-          });
-          chatReq.write(postData);
-          chatReq.end();
+          selfChat(req, to, callbackMessage, callbackConvId, 'TaskCallback');
           // 譖ｴ譁ｰ task 蜈焚謐ｮ
           if (taskMeta) {
@@ -2160,18 +2154,7 @@ router.post(&#39;/:agentId/task/transition&#39;, (req, res) =&gt; {
            // 騾夂衍 Master 螳｡謇ｹ
            setImmediate(() => {
                const masterMsg = `[笞 莠句燕螳｡謇ｹ隸ｷ豎\n菴逧ｸ句ｱ ${agentId} 蟾ｲ扈丞ｮ梧莠 P0 郤ｧ莉ｻ蜉｡ ${taskId} 逧ｧ髦ｶ谿ｵ縲n邇ｰ蝨ｨ螳ｭ｣蜃､刈霓ｽ螟ｧ螽∝鴨謇ｧ陦梧揀髯 (Execute) 關ｽ蝨ｰ譁ｹ譯医n\n隸ｷ菴髦ｯｻ蜈ｶ莠ｧ逕溽噪 ${artifact || '_plan.md'}悟ｹｶ蝨ｨ遑ｮ隶､譌隸ｯ蜷朱夊ｿ欠莉､謇句勘謾ｾ陦悟ｮＡ;
-               const http = require('http');
-               const postData = JSON.stringify({ message: masterMsg, conversationId: `approval-${taskId}` });
-               const options = {
-                   hostname: 'localhost', port: systemConfig.port,
-                   path: `/api/agent/master/chat`,
-                   method: 'POST',
-                   headers: { 'Content-Type': 'application/json', 'Content-Length': Buffer.byteLength(postData) },
-               };
-               const chatReq = http.request(options, () => {});
-               chatReq.on('error', () => {});
-               chatReq.write(postData);
-               chatReq.end();
+               selfChat(req, 'master', masterMsg, `approval-${taskId}`, 'TaskTransition');
            });
            // 謗先妙蠖灘燕霑帷ｨ倶ｽｿ蜈ｶ莨醍悛檎ｭ牙ｾ譁ｰ蜚､驢
@@ -2270,18 +2253,7 @@ ${artifactContent ? `霑呎弍荳贋ｸ髦ｶ谿ｵ菴謌紋ｽ逧燕鄂ｮ闃らせ逡吩ｸ狗噪莠､莉倡
       // 4. 蜿鷹∝筈驢呈欠莉､隶ｩ莉也ｫ句綾蝓ｺ莠取眠閼大ｭ占｡悟勘
       setImmediate(() => {
-        const http = require('http');
-        const postData = JSON.stringify({ message: "隸ｷ遑ｮ隶､菴蟾ｲ謾ｶ蛻ｰ邉ｻ扈溽噪譁ｰ髦ｶ谿ｵ謖りｽｽ謖ｻ､悟ｹｶ遶句叉謇ｧ陦御ｽ蠖灘燕髦ｶ谿ｵ譛ｬ蛻噪莉ｻ蜉｡", conversationId: activeConvId });
-        const options = {
-          hostname: 'localhost', port: systemConfig.port,
-          path: `/api/agent/${agentId}/chat`,
-          method: 'POST',
-          headers: { 'Content-Type': 'application/json', 'Content-Length': Buffer.byteLength(postData) },
-        };
-        const chatReq = http.request(options, () => {});
-        chatReq.on('error', () => {});
-        chatReq.write(postData);
-        chatReq.end();
+        selfChat(req, agentId, '隸ｷ遑ｮ隶､菴蟾ｲ謾ｶ蛻ｰ邉ｻ扈溽噪譁ｰ髦ｶ谿ｵ謖りｽｽ謖ｻ､悟ｹｶ遶句叉謇ｧ陦御ｽ蠖灘燕髦ｶ谿ｵ譛ｬ蛻噪莉ｻ蜉｡', activeConvId, 'TaskTransition');
       });
     }
@@ -2335,26 +2307,7 @@ router.post(&#39;/task/reject&#39;, (req, res) =&gt; {
           `node bin/lemon.js task report --taskId redo-${runId}-${stepIndex} --from ${agentId} --to ${reviewedBy} --status done --summary "(謾ｹ霑帛錘逧ｮ梧鞫倩ｦ)"`,
         ].join('\n');
-        const http = require('http');
-        const postData = JSON.stringify({ message: rejectMessage, conversationId: `redo-${runId}-step-${stepIndex}` });
-        const options = {
-          hostname: 'localhost', port: systemConfig.port,
-          path: `/api/agent/${agentId}/chat`,
-          method: 'POST',
-          headers: { 'Content-Type': 'application/json', 'Content-Length': Buffer.byteLength(postData) },
-        };
-        const chatReq = http.request(options, (chatRes) => {
-          let body = '';
-          chatRes.on('data', (chunk) => body += chunk);
-          chatRes.on('end', () => {
-            console.log(`[TaskReject] 売 ${agentId} 驥榊★莉ｻ蜉｡蟾ｲ隗ｦ蜿疏);
-          });
-        });
-        chatReq.on('error', (err) => {
-          console.error(`[TaskReject] 笶 驥榊★隗ｦ蜿大､ｱ雍･: ${err.message}`);
-        });
-        chatReq.write(postData);
-        chatReq.end();
+        selfChat(req, agentId, rejectMessage, `redo-${runId}-step-${stepIndex}`, 'TaskReject');
       });
     }
@@ -2421,20 +2374,7 @@ router.post(&#39;/human-request&#39;, (req, res) =&gt; {
         `隸ｷ謨ｦ菫ｺｺ邀ｻ Master 謠蝉ｾ幄ｯ･ Key梧閠ｽ隸ｼｰ譏ｯ蜷ｦ蜿ｯ莉･菴ｿ逕ｨ螟畑譁ｹ譯医Ａ
       ].join('\n');
-      const http = require('http');
-      const postData = JSON.stringify({ message: masterMsg, conversationId: `human-req-${Date.now().toString(36)}` });
-      const options = {
-        hostname: 'localhost', port: systemConfig.port,
-        path: `/api/agent/master/chat`,
-        method: 'POST',
-        headers: { 'Content-Type': 'application/json', 'Content-Length': Buffer.byteLength(postData) },
-      };
-      const chatReq = http.request(options, (chatRes) => {
-        chatRes.on('data', () => {});
-      });
-      chatReq.on('error', () => {});
-      chatReq.write(postData);
-      chatReq.end();
+      selfChat(req, 'master', masterMsg, `human-req-${Date.now().toString(36)}`, 'HumanRequest');
     });
     res.json({ success: true, message: `蟾ｲ蟆ｯｷ豎ゆｸ頑冠扈 Master 蟷ｶ隶ｰ蠖戊 Human To-Do List` });
+/**
+ * 自唤醒回调（`selfChat`）的两条不变式。
+ *
+ * 背景：`/task/dispatch`、`/task/report`、`task/transition` 等六处都要「服务端自己给某个
+ * agent 发一条 chat」。它们原来各自写死 `hostname:'localhost', port: systemConfig.port`
+ * （3010）—— 单测把路由挂到 `app.listen(0)` 的临时端口上，回调却照样打进**线上 3010**：
+ * 每跑一次汇报用例就给真 CEO 发一条 chat、起一个常驻 claude CLI 子进程、留一个
+ * `callback-T-*` 会话目录。症状完全静默（测试全绿），只有进程数和内存在涨。
+ *
+ * 抽成 `selfChat` 之后要盯两件事：
+ *   1. **不许再有第二处自己拼 http.request 打 systemConfig.port** —— 那就是分叉的开始；
+ *   2. **不许留下 `chatReq.write(postData)` 这类孤儿调用** —— 改造时删了声明却留下调用，
+ *      `node --check` 一样通过（是运行时 ReferenceError 不是语法错），而它在
+ *      `setImmediate` 里抛就是未捕获异常、直接杀进程。实测这次改造就留下了两处。
+ */
+import { describe, it, expect } from 'vitest';
+import fs from 'fs';
+import path from 'path';
+
+const FILE = path.resolve(__dirname, '../../routes/agent-chat.js');
+const src = fs.readFileSync(FILE, 'utf-8');
+const lines = src.split('\n');
+
+describe('自唤醒回调', () => {
+  it('样本非空 —— 路径写错时不许退化成永远通过', () => {
+    expect(src.length).toBeGreaterThan(1000);
+    expect(src).toContain('function selfChat(');
+  });
+
+  it('chatReq / postData 只出现在 selfChat 内部，没有孤儿调用', () => {
+    // selfChat 的函数体范围
+    const start = lines.findIndex((l) => l.includes('function selfChat('));
+    expect(start).toBeGreaterThan(-1);
+    let end = start;
+    for (let i = start + 1; i < lines.length; i++) {
+      if (lines[i] === '}') { end = i; break; }
+    }
+    const offenders = [];
+    lines.forEach((l, i) => {
+      if (i >= start && i <= end) return;                       // 函数体内是正当用法
+      if (/\bchatReq\b|\bpostData\b/.test(l)) offenders.push(`${i + 1}: ${l.trim()}`);
+    });
+    expect(offenders).toEqual([]);
+  });
+
+  it('没有第二处自己拼 http.request 打 systemConfig.port', () => {
+    const start = lines.findIndex((l) => l.includes('function selfChat('));
+    let end = start;
+    for (let i = start + 1; i < lines.length; i++) {
+      if (lines[i] === '}') { end = i; break; }
+    }
+    const offenders = [];
+    lines.forEach((l, i) => {
+      if (i >= start && i <= end) return;
+      // 「自己拼端口去打自己」的形状：port: systemConfig.port
+      // 跳过注释行 —— selfChat 上方那段说明**引用**了这个写法来解释它为什么被换掉，
+      // 那是文档不是代码。第一版没跳，把注释当成漏改报了红。
+      if (/^\s*(\/\/|\*|\/\*)/.test(l)) return;
+      if (/port:\s*systemConfig\.port/.test(l)) offenders.push(`${i + 1}: ${l.trim()}`);
+    });
+    expect(offenders).toEqual([]);
+  });
+
+  it('测试环境必须短路 —— 否则单测会打进线上端口', () => {
+    expect(src).toMatch(/process\.env\.VITEST|NODE_ENV === 'test'/);
+  });
+});