fix: Claude CLI 错误反馈到前端 + 致命错误自动中断

- ClaudeCliProtocol: stderr 检测 rate_limit/429/401 等致命错误时自动 reject sendPrompt Promise - agent-chat.js: 监听 stderr/disconnected 事件并通过 SSE 推送到前端 - AgentChat.vue: error 事件停止 thinking 状态 + ACP 日志面板显示错误

fix: Claude CLI 错误反馈到前端 + 致命错误自动中断
- ClaudeCliProtocol: stderr 检测 rate_limit/429/401 等致命错误时自动 reject sendPrompt Promise - agent-chat.js: 监听 stderr/disconnected 事件并通过 SSE 推送到前端 - AgentChat.vue: error 事件停止 thinking 状态 + ACP 日志面板显示错误
yibo
1 parent 4a688046
Showing 5 changed files with 49 additions and 2 deletions
data/goals/_index.json
data/system/agents/master/memory/short-term/session-1774547297290.md
packages/acp-core/protocol/ClaudeCliProtocol.js
server/routes/agent-chat.js
web/src/views/AgentChat.vue
+[]
 \ No newline at end of file
+# Session 摘要
+
+- **时间**: 2026-03-26 17:48:17
+- **对话ID**: conv-mn7rjae6
+- **状态**: completed
+- **工具调用**: 0 次
+- **耗时**: 3分钟
+
+## 任务
+我需要创建一个名为 ABC 的 AI 互动剧公司。这家公司的核心业务逻辑和组织架构诉求如下：
+
+一、
+
+## 结果
+API Error: 429 {"type":"error","error":{"type":"rate_limit_error","message":"usage limit exceeded (2056)"},"request_id":"0614a461f8ade83e80e74a117efb3ac7"}
@@ -96,12 +96,21 @@ class ClaudeCliProtocol extends EventEmitter {
             }
         });
  
-        // stderr 转发
+        // stderr 转发 + 致命错误检测
         this._child.stderr.on('data', (data) => {
             const msg = data.toString().trim();
             if (msg) {
                 console.log('[ClaudeCliProtocol] stderr:', msg.substring(0, 300));
                 this.emit('stderr', msg);
+
+                // 检测致命错误：如果 sendPrompt 正在等待，主动 reject 防止 Promise 永远挂起
+                if (this._promptReject && /rate.?limit|usage.?limit|429|401|403|authentication|api.?key|quota|billing/i.test(msg)) {
+                    const err = new Error(`Claude CLI 致命错误: ${msg.substring(0, 500)}`);
+                    this._promptReject(err);
+                    this._promptResolve = null;
+                    this._promptReject = null;
+                    console.error('[ClaudeCliProtocol] 致命错误已触发 Promise reject');
+                }
             }
         });
  
@@ -1734,12 +1734,31 @@ router.post(&#39;/:agentId/chat&#39;, async (req, res) =&gt; {
       entry.protocol.on('session_update', onUpdate);
       entry.protocol.on('acp_event', onAcpEvent);
  
+      // 监听 stderr / error / disconnect — 将 Claude CLI 错误实时推送到前端
+      const onStderr = (msg) => {
+        console.warn(`[AgentChat] stderr from ${agentId}:`, msg.substring(0, 300));
+        sendSSE('acp_raw', { method: 'claude/stderr', params: { message: msg }, ts: Date.now() });
+        // 如果包含严重错误关键词，额外发一条 error 事件
+        if (/error|rate.?limit|429|403|timeout|ECONNREFUSED|failed/i.test(msg)) {
+          sendSSE('error', { message: `⚠️ Claude CLI: ${msg.substring(0, 500)}` });
+        }
+      };
+      const onDisconnected = ({ code, signal }) => {
+        if (code !== 0) {
+          sendSSE('error', { message: `Claude CLI 异常退出 (code=${code}, signal=${signal})` });
+        }
+      };
+      entry.protocol.on('stderr', onStderr);
+      entry.protocol.on('disconnected', onDisconnected);
+
       // 发送 prompt 并等待完成
       await entry.protocol.sendPrompt(prompt);
  
       // 清理监听
       entry.protocol.off('session_update', onUpdate);
       entry.protocol.off('acp_event', onAcpEvent);
+      entry.protocol.off('stderr', onStderr);
+      entry.protocol.off('disconnected', onDisconnected);
  
       // 持久化当前轮次的回复
       if (fullOutput) {
@@ -564,7 +564,10 @@ function handleEvent(type, data) {
       else if (data.event === 'start') subAgents.value[data.callId].status = 'running'
       scrollToBottom(); break
     case 'error':
-      messages.value.push({ role: 'assistant', content: `❌ ${data.message}`, timestamp: new Date().toISOString() }); break
+      messages.value.push({ role: 'assistant', content: `❌ ${data.message}`, timestamp: new Date().toISOString() })
+      acpLog.value.push({ type: 'error', icon: '🚨', text: data.message, ts: Date.now() })
+      thinkingText.value = ''; thinkingContent.value = ''
+      scrollToBottom(); scrollAcpLog(); break
   }
 }