fix: 拦截格式错乱的纯文本 API Error 日志

修复 Claude CLI 遇到严重 API 错误 (如 Http 429) 时，输出的不是合法 JSON，而是像 'MiniMax 检查失败: HTTP 429: {...}' 这样的纯文本行。旧版本在 JSON.parse 失败后直接忽略。新版本增加 fallback，匹配非 JSON 行中的错误关键字并强制中断死等和前端展示。

fix: 拦截格式错乱的纯文本 API Error 日志
修复 Claude CLI 遇到严重 API 错误 (如 Http 429) 时，输出的不是合法 JSON，而是像 'MiniMax 检查失败: HTTP 429: {...}' 这样的纯文本行。旧版本在 JSON.parse 失败后直接忽略。新版本增加 fallback，匹配非 JSON 行中的错误关键字并强制中断死等和前端展示。
yibo
1 parent 103b8cdd
Showing 2 changed files with 15 additions and 2 deletions
packages/acp-core/protocol/ClaudeCliProtocol.js
server/routes/agent-chat.js
@@ -96,7 +96,20 @@ class ClaudeCliProtocol extends EventEmitter {
                     const event = JSON.parse(line);
                     this._handleStreamEvent(event);
                 } catch (e) {
-                    // 非 JSON 行，忽略
+                    // 非 JSON 行：拦截纯文本的崩溃日志或 API 拒绝日志
+                    const msg = line.trim();
+                    if (msg) {
+                        console.log(`[ClaudeCliProtocol] 📝 非JSON文本:`, msg.substring(0, 300));
+                        // 触发类似 stderr 的检测逻辑
+                        if (this._promptReject && /error|rate.?limit|429|401|403|authentication|api.?key|quota|billing|失败/i.test(msg)) {
+                            const err = new Error(`API 请求失败 (Raw): ${msg.substring(0, 500)}`);
+                            console.error(`[ClaudeCliProtocol] 拦截到底层纯文本错误:`, err.message);
+                            if (this._idleTimer) { clearTimeout(this._idleTimer); this._idleTimer = null; }
+                            this._promptReject(err);
+                            this._promptResolve = null;
+                            this._promptReject = null;
+                        }
+                    }
                 }
             }
         });
@@ -1753,7 +1753,7 @@ router.post(&#39;/:agentId/chat&#39;, async (req, res) =&gt; {
       entry.protocol.on('disconnected', onDisconnected);
       // 发出状态以便前端展示不卡壳
-      sendSSE('agent_output', { agent: agentId, message: `_[系统正在通过 \`${fullSystemConfig.model}\` 请求响应...]_\\n\\n` });
+      sendSSE('agent_output', { agent: agentId, message: `_[请求已发送，等待底层大模型响应...]_\\n\\n` });
       // 发送 prompt 并等待完成
       await entry.protocol.sendPrompt(prompt);