fix: text extraction bypass, stderr diagnostics, OpenAI ensureBlock removal

server.js

@@ -1,11 +1,11 @@
-"use strict";
+"use strict";
 
 const https = require("https");
 const http = require("http");
 const crypto = require("crypto");
 
 // ============================================================
-// 1. 配置
+// 1. 閰嶇疆
 // ============================================================
 const CONFIG = require("./config.json");
 const BASE_HOST = "ima.qq.com";
@@ -32,8 +32,7 @@ function maskKey(k) {
 }
 
 // ============================================================
-// 2. HTTP 客户端
-// ============================================================
+// 2. HTTP 瀹㈡埛绔?// ============================================================
 const IMA_HEADERS = {
   "from_browser_ima": "1",
   get "x-ima-cookie"() { return COOKIE; },
@@ -42,8 +41,7 @@ const IMA_HEADERS = {
   origin: BASE_URL,
   "User-Agent": "okhttp/4.12.0",
   "Content-Type": "application/json; charset=utf-8",
-  "Accept-Encoding": "gzip",  // ⭐ 修复: 与真实 App 请求头一致
-};
+  "Accept-Encoding": "gzip",  // 猸?淇: 涓庣湡瀹?App 璇锋眰澶翠竴鑷?};
 
 function imaPost(path, body, extraH = {}, timeout = 30000) {
   return new Promise((resolve, reject) => {
@@ -53,8 +51,7 @@ function imaPost(path, body, extraH = {}, timeout = 30000) {
       headers: { ...IMA_HEADERS, ...extraH, "Content-Length": Buffer.byteLength(payload) },
       timeout,
     }, (res) => {
-      // ⭐ 修复: 处理 gzip 压缩响应（与 Accept-Encoding: gzip 配套）
-      const zlib = require("zlib");
+      // 猸?淇: 澶勭悊 gzip 鍘嬬缉鍝嶅簲锛堜笌 Accept-Encoding: gzip 閰嶅锛?      const zlib = require("zlib");
       const encoding = res.headers["content-encoding"] || "";
       let stream = res;
       if (encoding === "gzip") stream = res.pipe(zlib.createGunzip());
@@ -184,7 +181,7 @@ function _recurseObj(obj, keySet, depth) {
 const _TEXT_KEYS = new Set(["Text", "text", "Content", "content", "Delta", "delta", "Msg", "msg", "Message", "reply", "Reply", "answer", "Answer"]);
 const _THINK_KEYS = new Set(["think", "Think", "thinking", "Thinking", "reasoning",
   "reasoning_content", "Reasoning", "thought", "Thought",
-  "思维", "思考", "推理",
+  "鎬濈淮", "鎬濊€?, "鎺ㄧ悊",
   "reasoningText", "thinkContent", "think_text"]);
 
 function extractEventText(d) {
@@ -212,7 +209,13 @@ function eventTexts(evt) {
   if (d == null) return { text: "", think: "" };
   // THINKING events: IMA uses "Message" key for streaming thinking content
   if (evt.event === "THINKING" && typeof d.Message === "string") return { text: "", think: d.Message };
-  return { text: extractEventText(d), think: extractThinkText(d) };
+  const text = extractEventText(d);
+  const think = extractThinkText(d);
+  // Diaagnostic: log when non-THINKING event has empty text (forced flush to stderr)
+  if (!text && !think && evt.data && evt.event !== "THINKING") {
+    process.stderr.write("[EVT-MISS] event=" + (evt.event || "(none)") + " raw=" + evt.data.slice(0, 300) + "\n");
+  }
+  return { text, think };
 }
 
 function eventText(evt) {
@@ -231,9 +234,8 @@ function eventText(evt) {
 async function imaInitSession(question) {
   const { data } = await imaPost("/cgi-bin/session_logic/init_session", {
     env_info: { interact_type: 2, robot_type: 10000 },
-    name: (question || "新对话").slice(0, 50),
-    msgs_limit: 20,  // IMA 上限为 20（超过会报 code=51）
-  });
+    name: (question || "鏂板璇?).slice(0, 50),
+    msgs_limit: 20,  // IMA 涓婇檺涓?20锛堣秴杩囦細鎶?code=51锛?  });
   if (data.code === 0) return data.session_id;
   throw new Error(`InitSession failed: code=${data.code} msg=${data.msg}`);
 }
@@ -263,7 +265,7 @@ async function collectResponseText(events) {
 }
 
 // ============================================================
-// 4. 会话缓存
+// 4. 浼氳瘽缂撳瓨
 // ============================================================
 const sessions = new Map();
 const SESSION_TTL = 30 * 60 * 1000;
@@ -285,22 +287,20 @@ async function ensureSession(convId, question, forceNew = false) {
   return id;
 }
 
-// ⭐ 修复: IMA 会话达到 msgs_limit 后自动重建，避免"突然结束"
+// 猸?淇: IMA 浼氳瘽杈惧埌 msgs_limit 鍚庤嚜鍔ㄩ噸寤猴紝閬垮厤"绐佺劧缁撴潫"
 async function imaQaStreamWithRetry(convId, question, modelType, modelId) {
   let sessionId = await ensureSession(convId, question);
   const events = await imaQaStream(sessionId, question, modelType, modelId);
-  // 收集并检测是否触发会话限制错误（INNER_EXCEPTION 含 session limit）
-  return (async function*() {
+  // 鏀堕泦骞舵娴嬫槸鍚﹁Е鍙戜細璇濋檺鍒堕敊璇紙INNER_EXCEPTION 鍚?session limit锛?  return (async function*() {
     let hitLimit = false;
     for await (const evt of events) {
       if (evt.event === "INNER_EXCEPTION" || evt.event === "ERROR" || evt.event === "FAILED") {
-        // IMA 会话满了通常返回 INNER_EXCEPTION，此时重建 session 重试一次
-        try {
+        // IMA 浼氳瘽婊′簡閫氬父杩斿洖 INNER_EXCEPTION锛屾鏃堕噸寤?session 閲嶈瘯涓€娆?        try {
           const newId = await ensureSession(convId, question, true);
           const retryEvents = await imaQaStream(newId, question, modelType, modelId);
           for await (const e2 of retryEvents) yield e2;
         } catch (_) {
-          yield evt; // 重试也失败，把原始事件透传出去
+          yield evt; // 閲嶈瘯涔熷け璐ワ紝鎶婂師濮嬩簨浠堕€忎紶鍑哄幓
         }
         return;
       }
@@ -310,7 +310,7 @@ async function imaQaStreamWithRetry(convId, question, modelType, modelId) {
 }
 
 // ============================================================
-// 5. 模型
+// 5. 妯″瀷
 // ============================================================
 const MODELS = CONFIG.models;
 const DEFAULT_MODEL = CONFIG.default_model;
@@ -326,7 +326,7 @@ function resolveModel(requested) {
 }
 
 // ============================================================
-// 6. 认证 & 工具
+// 6. 璁よ瘉 & 宸ュ叿
 // ============================================================
 function checkAuth(req) {
   const bearer = (req.headers["authorization"] || "").replace(/^Bearer\s+/i, "");
@@ -356,7 +356,7 @@ function extractContent(msg) {
     return msg.content.map(c => {
       if (c.type === "text") return c.text;
       if (c.type === "tool_result") {
-        // Anthropic tool_result content 可能是 string 或 content_block[]
+        // Anthropic tool_result content 鍙兘鏄?string 鎴?content_block[]
         const tc = typeof c.content === "string" ? c.content
           : Array.isArray(c.content) ? c.content.map(cc => cc.text || "").join("") : "";
         return `Tool result:\n${tc}`;
@@ -368,7 +368,7 @@ function extractContent(msg) {
 }
 
 // ============================================================
-// 7. Function Calling — Prompt 注入引擎
+// 7. Function Calling 鈥?Prompt 娉ㄥ叆寮曟搸
 // ============================================================
 
 function escapeRawCtrlInStrings(s) {
@@ -388,17 +388,17 @@ function escapeRawCtrlInStrings(s) {
   return out;
 }
 
-// 修复 LLM 常见的 JSON 错误 (未转义引号、尾逗号、缺括号、字符串内裸换行)
+// 淇 LLM 甯歌鐨?JSON 閿欒 (鏈浆涔夊紩鍙枫€佸熬閫楀彿銆佺己鎷彿銆佸瓧绗︿覆鍐呰８鎹㈣)
 function tryRepairJson(raw) {
   try { return JSON.parse(raw); } catch (e) { /* continue */ }
   let fixed = raw;
-  // 0. 转义字符串内的裸控制符 (写文件时 content 含真实换行 → 否则 JSON.parse 失败)
+  // 0. 杞箟瀛楃涓插唴鐨勮８鎺у埗绗?(鍐欐枃浠舵椂 content 鍚湡瀹炴崲琛?鈫?鍚﹀垯 JSON.parse 澶辫触)
   fixed = escapeRawCtrlInStrings(fixed);
   try { return JSON.parse(fixed); } catch (e) { /* continue */ }
-  // 1. 去尾逗号
+  // 1. 鍘诲熬閫楀彿
   fixed = fixed.replace(/,(\s*[}\]])/g, '$1');
   try { return JSON.parse(fixed); } catch (e) { /* continue */ }
-  // 2. 补缺失的闭合括号
+  // 2. 琛ョ己澶辩殑闂悎鎷彿
   let depth = 0;
   for (const c of fixed) {
     if (c === '{' || c === '[') depth++;
@@ -410,7 +410,7 @@ function tryRepairJson(raw) {
     fixed += closer.repeat(Math.min(depth, 5));
     try { return JSON.parse(fixed); } catch (e) { /* continue */ }
   }
-  // 3. 提取 name + arguments (即使 JSON 破损也能尽可能恢复)
+  // 3. 鎻愬彇 name + arguments (鍗充娇 JSON 鐮存崯涔熻兘灏藉彲鑳芥仮澶?
   const nameMatch = fixed.match(/"name"\s*:\s*"([^"]+)"/);
   if (nameMatch) {
     const argsStart = fixed.indexOf('{', fixed.indexOf('"arguments"'));
@@ -427,23 +427,21 @@ function tryRepairJson(raw) {
   return null;
 }
 
-// 压缩 JSON Schema: 去掉 $schema/$defs/$ref 等元数据，单行紧凑输出
-function compactSchema(schema) {
+// 鍘嬬缉 JSON Schema: 鍘绘帀 $schema/$defs/$ref 绛夊厓鏁版嵁锛屽崟琛岀揣鍑戣緭鍑?function compactSchema(schema) {
   if (!schema || typeof schema !== "object") return "{}";
-  // 深拷贝后递归清理
+  // 娣辨嫹璐濆悗閫掑綊娓呯悊
   function clean(obj) {
     if (Array.isArray(obj)) return obj.map(clean);
     if (obj && typeof obj === "object") {
       const out = {};
       for (const [k, v] of Object.entries(obj)) {
-        if (k.startsWith("$")) continue;  // 去掉 $schema, $defs, $ref, $dynamicAnchor 等
-        out[k] = clean(v);
+        if (k.startsWith("$")) continue;  // 鍘绘帀 $schema, $defs, $ref, $dynamicAnchor 绛?        out[k] = clean(v);
       }
       return out;
     }
     return obj;
   }
-  return JSON.stringify(clean(schema));  // 单行，无缩进
+  return JSON.stringify(clean(schema));  // 鍗曡锛屾棤缂╄繘
 }
 
 function buildToolsPrompt(tools) {
@@ -461,12 +459,12 @@ function buildToolsPrompt(tools) {
     })
     .join("\n");
 
-  return `## ⚠️ CRITICAL — YOU MUST USE FUNCTION CALLING
+  return `## 鈿狅笍 CRITICAL 鈥?YOU MUST USE FUNCTION CALLING
 
 You have access to these functions. When the user asks you to do something
 that a function can handle, you MUST call the function. NEVER say "I cannot"
 or "I don't have the ability". NEVER tell the user to save a file, run a
-command, or do any step themselves — DO IT by calling the function (e.g. use
+command, or do any step themselves 鈥?DO IT by calling the function (e.g. use
 Write to create files, Bash to run commands). ALWAYS use a function instead.
 
 ${funcDefs}
@@ -483,16 +481,13 @@ Rules:
 - arguments MUST be a valid JSON object matching the function's parameters
 - For file content, put the FULL content in the string value (newlines allowed)
 - Do NOT add any text before or after the <function_call> block
-- NEVER output file content or code for the user to copy — write it via Write`;
+- NEVER output file content or code for the user to copy 鈥?write it via Write`;
 }
 
-// ⭐ 工具结果回传轮专用 — "继续行动"版工具提示。
-// 修复历史: ① 旧的强制版 ("YOU MUST call / 不要输出任何文本") 让模型回传轮要么再发多余
-// 调用要么沉默; ② 过软版 ("有足够信息就用纯文本作答") 又走向另一极端 —— 模型把"让我先读
-// 取文件"这种【意图叙述】当成回答然后停手, 多步任务半途而废。
-// 本版核心原则: 叙述意图 ≠ 完成任务。只要还有未完成的步骤, 必须【在本轮就发出函数调用】,
-// 不能只说"我接下来要做 X"。只有当任务真正全部完成时, 才用纯文本给出最终答复。
-function buildToolsPromptSoft(tools) {
+// 猸?宸ュ叿缁撴灉鍥炰紶杞笓鐢?鈥?"缁х画琛屽姩"鐗堝伐鍏锋彁绀恒€?// 淇鍘嗗彶: 鈶?鏃х殑寮哄埗鐗?("YOU MUST call / 涓嶈杈撳嚭浠讳綍鏂囨湰") 璁╂ā鍨嬪洖浼犺疆瑕佷箞鍐嶅彂澶氫綑
+// 璋冪敤瑕佷箞娌夐粯; 鈶?杩囪蒋鐗?("鏈夎冻澶熶俊鎭氨鐢ㄧ函鏂囨湰浣滅瓟") 鍙堣蛋鍚戝彟涓€鏋佺 鈥斺€?妯″瀷鎶?璁╂垜鍏堣
+// 鍙栨枃浠?杩欑銆愭剰鍥惧彊杩般€戝綋鎴愬洖绛旂劧鍚庡仠鎵? 澶氭浠诲姟鍗婇€旇€屽簾銆?// 鏈増鏍稿績鍘熷垯: 鍙欒堪鎰忓浘 鈮?瀹屾垚浠诲姟銆傚彧瑕佽繕鏈夋湭瀹屾垚鐨勬楠? 蹇呴』銆愬湪鏈疆灏卞彂鍑哄嚱鏁拌皟鐢ㄣ€?
+// 涓嶈兘鍙"鎴戞帴涓嬫潵瑕佸仛 X"銆傚彧鏈夊綋浠诲姟鐪熸鍏ㄩ儴瀹屾垚鏃? 鎵嶇敤绾枃鏈粰鍑烘渶缁堢瓟澶嶃€?function buildToolsPromptSoft(tools) {
   if (!tools || tools.length === 0) return "";
 
   const funcDefs = tools
@@ -510,14 +505,14 @@ function buildToolsPromptSoft(tools) {
 
 ${funcDefs}
 
-## CRITICAL — keep going until the task is fully done
+## CRITICAL 鈥?keep going until the task is fully done
 
 The user's request may need MULTIPLE steps. After each function result, decide:
-the task is NOT finished yet → call the next function NOW; the task IS fully
-finished → give the final answer in plain text.
+the task is NOT finished yet 鈫?call the next function NOW; the task IS fully
+finished 鈫?give the final answer in plain text.
 
 NEVER reply with only your intention (e.g. "Let me read the file", "I'll now
-start the server", "下一步我将…"). Stating intent is NOT an action and NOT an
+start the server", "涓嬩竴姝ユ垜灏嗏€?). Stating intent is NOT an action and NOT an
 answer. If you intend to do something, you MUST emit the function call for it
 in THIS SAME reply.
 
@@ -530,19 +525,16 @@ Only when every step is done, reply to the user in plain text WITHOUT any
 <function_call> block.`;
 }
 
-// ⭐ StreamFilter: 实时过滤流式输出中的 <function_call> 块
-// 防止 Claude Code 客户端因看到 XML 标记而截停
-class StreamFilter {
+// 猸?StreamFilter: 瀹炴椂杩囨护娴佸紡杈撳嚭涓殑 <function_call> 鍧?// 闃叉 Claude Code 瀹㈡埛绔洜鐪嬪埌 XML 鏍囪鑰屾埅鍋?class StreamFilter {
   constructor() {
-    this._buf = '';           // 未决缓冲区
-    this._emitted = '';       // 已输出的纯净文本
-    this._funcBlocks = [];    // 捕获的 function_call JSON
-    this._inFunc = false;     // 是否在 <function_call> 内部
+    this._buf = '';           // 鏈喅缂撳啿鍖?    this._emitted = '';       // 宸茶緭鍑虹殑绾噣鏂囨湰
+    this._funcBlocks = [];    // 鎹曡幏鐨?function_call JSON
+    this._inFunc = false;     // 鏄惁鍦?<function_call> 鍐呴儴
     this._tagLen = 16;        // '<function_call>'.length
-    this._leftover = '';      // ⭐ parseCalls 无法解析的残留文本 (供流式层兜底输出)
+    this._leftover = '';      // 猸?parseCalls 鏃犳硶瑙ｆ瀽鐨勬畫鐣欐枃鏈?(渚涙祦寮忓眰鍏滃簳杈撳嚭)
   }
 
-  // 喂入新文本块，返回应发送给客户端的纯净文本 (可能为空)
+  // 鍠傚叆鏂版枃鏈潡锛岃繑鍥炲簲鍙戦€佺粰瀹㈡埛绔殑绾噣鏂囨湰 (鍙兘涓虹┖)
   feed(chunk) {
     this._buf += chunk;
     const out = [];
@@ -553,22 +545,18 @@ class StreamFilter {
       if (!this._inFunc) {
         const idx = this._buf.indexOf(startTag);
         if (idx === -1) {
-          // 没有发现开始标签 — 但先检查尾部是否部分匹配
-          const partialLen = this._partialMatch(startTag);
+          // 娌℃湁鍙戠幇寮€濮嬫爣绛?鈥?浣嗗厛妫€鏌ュ熬閮ㄦ槸鍚﹂儴鍒嗗尮閰?          const partialLen = this._partialMatch(startTag);
           if (partialLen > 0) {
-            // 保留可能的部分标签在缓冲区
-            const safe = this._buf.slice(0, -partialLen);
+            // 淇濈暀鍙兘鐨勯儴鍒嗘爣绛惧湪缂撳啿鍖?            const safe = this._buf.slice(0, -partialLen);
             if (safe) out.push(safe);
             this._buf = this._buf.slice(-partialLen);
             break;
           }
-          // 完全安全，全部输出
-          out.push(this._buf);
+          // 瀹屽叏瀹夊叏锛屽叏閮ㄨ緭鍑?          out.push(this._buf);
           this._buf = '';
           break;
         }
-        // 发现开始标签 — 输出标签之前的文本
-        if (idx > 0) out.push(this._buf.slice(0, idx));
+        // 鍙戠幇寮€濮嬫爣绛?鈥?杈撳嚭鏍囩涔嬪墠鐨勬枃鏈?        if (idx > 0) out.push(this._buf.slice(0, idx));
         this._buf = this._buf.slice(idx + startTag.length);
         this._inFunc = true;
       }
@@ -576,15 +564,15 @@ class StreamFilter {
       if (this._inFunc) {
         const idx = this._buf.indexOf(endTag);
         if (idx === -1) {
-          // 还没找到结束标签 — 全部抑制
+          // 杩樻病鎵惧埌缁撴潫鏍囩 鈥?鍏ㄩ儴鎶戝埗
           break;
         }
-        // 找到结束标签 — 捕获函数调用 JSON
+        // 鎵惧埌缁撴潫鏍囩 鈥?鎹曡幏鍑芥暟璋冪敤 JSON
         const json = this._buf.slice(0, idx).trim();
         if (json) this._funcBlocks.push(json);
         this._buf = this._buf.slice(idx + endTag.length);
         this._inFunc = false;
-        // 继续循环，可能后面还有文本或更多 function_call
+        // 缁х画寰幆锛屽彲鑳藉悗闈㈣繕鏈夋枃鏈垨鏇村 function_call
       }
     }
 
@@ -593,7 +581,7 @@ class StreamFilter {
     return text;
   }
 
-  // 检查缓冲区末尾是否部分匹配 tag
+  // 妫€鏌ョ紦鍐插尯鏈熬鏄惁閮ㄥ垎鍖归厤 tag
   _partialMatch(tag) {
     for (let i = tag.length - 1; i > 0; i--) {
       if (this._buf.endsWith(tag.slice(0, i))) return i;
@@ -601,13 +589,11 @@ class StreamFilter {
     return 0;
   }
 
-  // 流结束时调用 — 返回可能残留的缓冲区内容 (不含 function_call 部分)
+  // 娴佺粨鏉熸椂璋冪敤 鈥?杩斿洖鍙兘娈嬬暀鐨勭紦鍐插尯鍐呭 (涓嶅惈 function_call 閮ㄥ垎)
   flush() {
     if (this._inFunc) {
-      // ⭐ 修复: 流在 </function_call> 到达前就结束了 (IMA 截断 / 模型漏写闭合标签)。
-      // 旧逻辑直接丢弃缓冲区, 导致"调用命令后无任何回复" — 这里改为把残留 JSON
-      // 当作一个 function block 捕获, 交给 parseCalls() 去尽力修复。
-      const pending = this._buf.trim();
+      // 猸?淇: 娴佸湪 </function_call> 鍒拌揪鍓嶅氨缁撴潫浜?(IMA 鎴柇 / 妯″瀷婕忓啓闂悎鏍囩)銆?      // 鏃ч€昏緫鐩存帴涓㈠純缂撳啿鍖? 瀵艰嚧"璋冪敤鍛戒护鍚庢棤浠讳綍鍥炲" 鈥?杩欓噷鏀逛负鎶婃畫鐣?JSON
+      // 褰撲綔涓€涓?function block 鎹曡幏, 浜ょ粰 parseCalls() 鍘诲敖鍔涗慨澶嶃€?      const pending = this._buf.trim();
       if (pending) this._funcBlocks.push(pending);
       this._buf = '';
       this._inFunc = false;
@@ -622,8 +608,7 @@ class StreamFilter {
     return '';
   }
 
-  // 解析已捕获的所有 function_call 块
-  parseCalls() {
+  // 瑙ｆ瀽宸叉崟鑾风殑鎵€鏈?function_call 鍧?  parseCalls() {
     const calls = [];
     for (const raw of this._funcBlocks) {
       const parsed = tryRepairJson(raw);
@@ -637,8 +622,7 @@ class StreamFilter {
           },
         });
       } else if (raw.length > 0) {
-        // ⭐ JSON 修复失败 — 累积到 _leftover, 由流式层兜底输出, 避免对话静默中断。
-        // (非流式走 cleanText/_emitted; 流式层需读取 leftover 单独 emit)
+        // 猸?JSON 淇澶辫触 鈥?绱Н鍒?_leftover, 鐢辨祦寮忓眰鍏滃簳杈撳嚭, 閬垮厤瀵硅瘽闈欓粯涓柇銆?        // (闈炴祦寮忚蛋 cleanText/_emitted; 娴佸紡灞傞渶璇诲彇 leftover 鍗曠嫭 emit)
         const note = '\n[Function call (malformed)]:\n' + raw + '\n';
         this._emitted += note;
         this._leftover += note;
@@ -655,14 +639,14 @@ class StreamFilter {
 function parseFunctionCalls(text) {
   if (!text) return { found: false, text: "" };
 
-  // 也匹配 ```json {...} ``` 格式 (模型可能输出 JSON 代码块)
+  // 涔熷尮閰?```json {...} ``` 鏍煎紡 (妯″瀷鍙兘杈撳嚭 JSON 浠ｇ爜鍧?
   const jsonBlockRegex = /```(?:json)?\s*\n?\s*(\{(?:[^{}]|\{(?:[^{}]|\{[^{}]*\})*\})*\})\s*\n?\s*```/g;
 
   const regex = /<function_call>\s*\n?\s*(\{[\s\S]*?\})\s*\n?\s*<\/function_call>/g;
   const calls = [];
   let cleanText = text;
 
-  // 尝试两种格式: <function_call> 和 ```json name/arguments
+  // 灏濊瘯涓ょ鏍煎紡: <function_call> 鍜?```json name/arguments
   const patterns = [
     regex,
     /```(?:json)?\s*\n?\s*\{[^{}]*"name"\s*:\s*"[^"]+"[^{}]*"arguments"\s*:\s*\{[\s\S]*?\}\s*\}\s*\n?\s*```/g,
@@ -691,7 +675,7 @@ function parseFunctionCalls(text) {
     return { found: true, calls, text: cleanText };
   }
 
-  // 调试: 检查模型是否输出了近似的 function call 格式
+  // 璋冭瘯: 妫€鏌ユā鍨嬫槸鍚﹁緭鍑轰簡杩戜技鐨?function call 鏍煎紡
   if (text.includes('function') || text.includes('tool') || text.includes('bash') || text.includes('read_file')) {
   }
   return { found: false, text };
@@ -708,12 +692,12 @@ async function openaiChat(req, res, body) {
   const tools = body.tools || null;
   const toolChoice = body.tool_choice || null;
 
-  // --- 构建 question ---
+  // --- 鏋勫缓 question ---
   const hasToolResults = messages.some(m => m.role === "tool");
   const hasToolCalls = messages.some(m => m.role === "assistant" && m.tool_calls);
   let question;
 
-  // 确定工具集 (两个分支共用)
+  // 纭畾宸ュ叿闆?(涓や釜鍒嗘敮鍏辩敤)
   let effectiveTools = tools;
   if ((!effectiveTools || effectiveTools.length === 0) && toolChoice !== "none") {
     effectiveTools = [
@@ -724,17 +708,16 @@ async function openaiChat(req, res, body) {
       {type: "function", function: {name: "Grep", description: "Search file contents", parameters: {type: "object", properties: {pattern: {type: "string"}, path: {type: "string"}}, required: ["pattern"]}}},
     ];
   }
-  // ⭐ 标题生成请求不需要 tools
+  // 猸?鏍囬鐢熸垚璇锋眰涓嶉渶瑕?tools
   const _sysParts = messages.filter(m => m.role === "system").map(m => extractContent(m));
   const _sysPrompt = _sysParts.length > 0 ? _sysParts.join("\n") : "";
   const isTitleGenOAI = _sysPrompt.includes('Generate a concise, sentence-case title');
 
-  // ⭐ 限制工具数量，防止 prompt 超出限制
+  // 猸?闄愬埗宸ュ叿鏁伴噺锛岄槻姝?prompt 瓒呭嚭闄愬埗
   const MAX_TOOLS_OAI = 8;
   const ESSENTIAL_OAI = new Set(['Bash', 'Read', 'Write', 'Glob', 'Grep']);
   if (isTitleGenOAI) {
-    effectiveTools = [];  // 标题生成不需要工具
-  } else if (effectiveTools && effectiveTools.length > MAX_TOOLS_OAI) {
+    effectiveTools = [];  // 鏍囬鐢熸垚涓嶉渶瑕佸伐鍏?  } else if (effectiveTools && effectiveTools.length > MAX_TOOLS_OAI) {
     const essential = effectiveTools.filter(t => ESSENTIAL_OAI.has(t.function?.name));
     const others = effectiveTools.filter(t => !ESSENTIAL_OAI.has(t.function?.name));
     const available = MAX_TOOLS_OAI - essential.length;
@@ -747,13 +730,12 @@ async function openaiChat(req, res, body) {
 
   if (hasToolResults && hasToolCalls) {
     toolResultPathOAI = true;
-    // 工具结果回传轮 — 单段系统通知格式
+    // 宸ュ叿缁撴灉鍥炰紶杞?鈥?鍗曟绯荤粺閫氱煡鏍煎紡
     const lastUserOAI = messages.filter(m => m.role === "user").pop();
     const lastUserTextOAI = extractContent(lastUserOAI || {});
-    const cjkOAI = /[一-鿿㐀-䶿]/.test(lastUserTextOAI);
+    const cjkOAI = /[涓€-榭裤悁-涠縘/.test(lastUserTextOAI);
 
-    // 收集函数调用和结果
-    const calledOAI = [], resultsOAI = [];
+    // 鏀堕泦鍑芥暟璋冪敤鍜岀粨鏋?    const calledOAI = [], resultsOAI = [];
     for (const m of messages) {
       if (m.role === "assistant" && m.tool_calls) {
         for (const tc of m.tool_calls) calledOAI.push(tc.function.name + "(" + tc.function.arguments + ")");
@@ -762,7 +744,7 @@ async function openaiChat(req, res, body) {
         resultsOAI.push(extractContent(m).slice(0, 3000));
       }
     }
-    // 找到用户原始提问
+    // 鎵惧埌鐢ㄦ埛鍘熷鎻愰棶
     const userQsOAI = [];
     for (const m of messages) {
       if (m.role !== "user") continue;
@@ -773,27 +755,25 @@ async function openaiChat(req, res, body) {
     const origQ = userQsOAI.length > 0 ? userQsOAI[userQsOAI.length - 1] : (lastUserTextOAI || "");
 
     if (cjkOAI) {
-      question = "⚠️ 系统通知：你刚才调用了以下函数，返回结果如下：\n\n";
+      question = "鈿狅笍 绯荤粺閫氱煡锛氫綘鍒氭墠璋冪敤浜嗕互涓嬪嚱鏁帮紝杩斿洖缁撴灉濡備笅锛歕n\n";
       for (let i = 0; i < calledOAI.length; i++) {
-        question += "函数调用: " + calledOAI[i] + "\n返回结果:\n\"\"\"\n" + (resultsOAI[i] || "") + "\n\"\"\"\n\n";
+        question += "鍑芥暟璋冪敤: " + calledOAI[i] + "\n杩斿洖缁撴灉:\n\"\"\"\n" + (resultsOAI[i] || "") + "\n\"\"\"\n\n";
       }
-      question += "用户原始提问: \"" + origQ + "\"\n\n请用简体中文直接回答用户的问题。说出答案即可。不要说\"你分享了\"或\"看起来像是\"。上面用 \"\"\" 包裹的��容是你自己调用函数得到的返回结果。";
+      question += "鐢ㄦ埛鍘熷鎻愰棶: \"" + origQ + "\"\n\n璇风敤绠€浣撲腑鏂囩洿鎺ュ洖绛旂敤鎴风殑闂銆傝鍑虹瓟妗堝嵆鍙€備笉瑕佽\"浣犲垎浜簡\"鎴朶"鐪嬭捣鏉ュ儚鏄痋"銆備笂闈㈢敤 \"\"\" 鍖呰９鐨勫唴瀹规槸浣犺嚜宸辫皟鐢ㄥ嚱鏁板緱鍒扮殑杩斿洖缁撴灉銆?;
     } else {
-      question = "⚠️ SYSTEM: You just called these functions and received these outputs:\n\n";
+      question = "鈿狅笍 SYSTEM: You just called these functions and received these outputs:\n\n";
       for (let i = 0; i < calledOAI.length; i++) {
         question += "Function: " + calledOAI[i] + "\nOutput:\n\"\"\"\n" + (resultsOAI[i] || "") + "\n\"\"\"\n\n";
       }
       question += "User's original question: \"" + origQ + "\"\n\nAnswer DIRECTLY based on the outputs. Do NOT say \"you shared\" or \"it looks like\". The \"\"\" content is YOUR function output, NOT user input.";
     }
 
-    // 工具结果回传轮: 不携带完整 sysPrompt, 仅 5 个核心工具
-    // ⭐ 用软版提示 — 允许模型直接用文字作答, 避免被强制再发 function_call 而沉默
-    const minimalOAI = buildToolsPromptSoft(
+    // 宸ュ叿缁撴灉鍥炰紶杞? 涓嶆惡甯﹀畬鏁?sysPrompt, 浠?5 涓牳蹇冨伐鍏?    // 猸?鐢ㄨ蒋鐗堟彁绀?鈥?鍏佽妯″瀷鐩存帴鐢ㄦ枃瀛椾綔绛? 閬垮厤琚己鍒跺啀鍙?function_call 鑰屾矇榛?    const minimalOAI = buildToolsPromptSoft(
       (effectiveTools || []).filter(t => ESSENTIAL_OAI.has(t.function?.name)).slice(0, 5)
     );
     question = minimalOAI + "\n\n---\n" + question;
   } else {
-    // 普通问答 / 首轮 tool calling
+    // 鏅€氶棶绛?/ 棣栬疆 tool calling
     let sysPrompt = "";
     const sysParts = messages.filter(m => m.role === "system").map(m => extractContent(m));
     if (sysParts.length > 0) sysPrompt = sysParts.join("\n");
@@ -804,7 +784,7 @@ async function openaiChat(req, res, body) {
       return json(res, 400, { error: { message: "No user message", type: "invalid_request_error" } });
     }
 
-    // ⭐ 跳过系统注入消息 (<session>, <system-reminder>)
+    // 猸?璺宠繃绯荤粺娉ㄥ叆娑堟伅 (<session>, <system-reminder>)
     const realUserMsgs = userMsgs.filter(m => {
       const c = extractContent(m);
       return !c.startsWith('<session') && !c.startsWith('<system-reminder') && c.length > 10;
@@ -813,11 +793,10 @@ async function openaiChat(req, res, body) {
       ? extractContent(realUserMsgs[realUserMsgs.length - 1])
       : extractContent(userMsgs[userMsgs.length - 1]);
 
-    // ⭐ 语言检测
-    const hasCJKOAI = /[一-鿿㐀-䶿]/.test(lastUserMsg);
-    const langHintOAI = hasCJKOAI ? "\n## Language\nRespond in the same language as the user's message. The user is writing in Chinese — respond in Chinese (简体中文).\n" : "";
+    // 猸?璇█妫€娴?    const hasCJKOAI = /[涓€-榭裤悁-涠縘/.test(lastUserMsg);
+    const langHintOAI = hasCJKOAI ? "\n## Language\nRespond in the same language as the user's message. The user is writing in Chinese 鈥?respond in Chinese (绠€浣撲腑鏂?.\n" : "";
 
-    // IMA question 字段限制 10240 字符
+    // IMA question 瀛楁闄愬埗 10240 瀛楃
     const MAX_QUESTION = 10000;
 
     if (nonSys.length > 1 && realUserMsgs.length >= 1) {
@@ -826,8 +805,7 @@ async function openaiChat(req, res, body) {
         return c.length > 10 && !c.startsWith('<session') && !c.startsWith('<system-reminder');
       });
       if (realMsgs.length > 1) {
-        // ⭐ 修复: 扩展到 20 条，按字符数动态裁剪
-        const MAX_HISTORY_CHARS = 6000;
+        // 猸?淇: 鎵╁睍鍒?20 鏉★紝鎸夊瓧绗︽暟鍔ㄦ€佽鍓?        const MAX_HISTORY_CHARS = 6000;
         const recentMsgs = realMsgs
           .filter(m => m.role === "user" || m.role === "assistant")
           .slice(-20);
@@ -846,13 +824,13 @@ async function openaiChat(req, res, body) {
         question = `${sysPrompt ? "(Background)\n" + sysPrompt + "\n\n" : ""}${toolsPrompt}\n\n---\nUser message (respond to this):\n${lastUserMsg}`;
       }
     } else {
-      // ⭐ 智能压缩 system prompt (保留 toolsPrompt 完整)
+      // 猸?鏅鸿兘鍘嬬缉 system prompt (淇濈暀 toolsPrompt 瀹屾暣)
       let context = sysPrompt;
       const overhead = toolsPrompt.length + lastUserMsg.length + 200;
       const remaining = MAX_QUESTION - overhead;
 
       if (context && context.length > remaining && remaining > 0) {
-        // ⭐ 修复: 保留头尾，中间裁剪（保留核心规则 + 最新文件信息）
+        // 猸?淇: 淇濈暀澶村熬锛屼腑闂磋鍓紙淇濈暀鏍稿績瑙勫垯 + 鏈€鏂版枃浠朵俊鎭級
         const layoutMatch = context.match(/<project_layout>([\s\S]*?)<\/project_layout>/);
         const layoutSummary = layoutMatch
           ? layoutMatch[1].trim().split("\n").slice(0, 30).join("\n")
@@ -869,11 +847,11 @@ async function openaiChat(req, res, body) {
       question = `${context ? "(Background)\n" + context + "\n\n" : ""}${toolsPrompt}\n\n---\nUser message (respond to this):\n${lastUserMsg}`;
     }
 
-    // ⭐ 注入语言提示 & 截断 (工具结果回传轮跳过)
+    // 猸?娉ㄥ叆璇█鎻愮ず & 鎴柇 (宸ュ叿缁撴灉鍥炰紶杞烦杩?
     if (!toolResultPathOAI) {
       question += langHintOAI;
 
-      // 最终截断 — 始终保留 toolsPrompt，否则模型看不到 function 定义
+      // 鏈€缁堟埅鏂?鈥?濮嬬粓淇濈暀 toolsPrompt锛屽惁鍒欐ā鍨嬬湅涓嶅埌 function 瀹氫箟
       if (question.length > MAX_QUESTION) {
         const minTemplate = "\n\n---\nUser message (respond to this):\n";
         const compact = toolsPrompt + minTemplate + lastUserMsg + langHintOAI;
@@ -892,8 +870,8 @@ async function openaiChat(req, res, body) {
   }
 
 
-  // 会话 — 复用 IMA session 保持对话记忆
-  // ⭐ 修复: 用系统 prompt 作为稳定锚点（同 Anthropic 路径保持一致）
+  // 浼氳瘽 鈥?澶嶇敤 IMA session 淇濇寔瀵硅瘽璁板繂
+  // 猸?淇: 鐢ㄧ郴缁?prompt 浣滀负绋冲畾閿氱偣锛堝悓 Anthropic 璺緞淇濇寔涓€鑷达級
   let oaiConvId = req.headers["x-conversation-id"] || req.headers["x-session-id"] || "";
   if (!oaiConvId && messages.length > 0) {
     const sysMsg = messages.find(m => m.role === "system");
@@ -909,7 +887,7 @@ async function openaiChat(req, res, body) {
     return json(res, 502, { error: { message: "Session init failed: " + e.message, type: "api_error" } });
   }
 
-  // --- 非流式 ---
+  // --- 闈炴祦寮?---
   if (!stream) {
     try {
       const events = await imaQaStreamWithRetry(oaiConvId, question, model.type, model.id);
@@ -926,8 +904,7 @@ async function openaiChat(req, res, body) {
         };
         choice.finish_reason = "tool_calls";
       } else {
-        // ⭐ 兜底: 空文本时给出占位, 避免客户端收到完全空的回复
-        choice.message = { role: "assistant", content: text || "(本轮没有生成内容，请重试或换一种问法。)" };
+        // 猸?鍏滃簳: 绌烘枃鏈椂缁欏嚭鍗犱綅, 閬垮厤瀹㈡埛绔敹鍒板畬鍏ㄧ┖鐨勫洖澶?        choice.message = { role: "assistant", content: text || "(鏈疆娌℃湁鐢熸垚鍐呭锛岃閲嶈瘯鎴栨崲涓€绉嶉棶娉曘€?" };
       }
 
       return json(res, 200, {
@@ -943,7 +920,7 @@ async function openaiChat(req, res, body) {
     }
   }
 
-  // --- 流式 ---
+  // --- 娴佸紡 ---
   cors(res);
   res.writeHead(200, {
     "Content-Type": "text/event-stream",
@@ -955,7 +932,7 @@ async function openaiChat(req, res, body) {
   const chatId = "chatcmpl-" + crypto.randomUUID().slice(0, 8);
   const created = Math.floor(Date.now() / 1000);
   let resClosed = false;
-  let sentText = false;   // ⭐ 是否已向客户端发送过任何文本/工具内容 (兜底判断)
+  let sentText = false;   // 猸?鏄惁宸插悜瀹㈡埛绔彂閫佽繃浠讳綍鏂囨湰/宸ュ叿鍐呭 (鍏滃簳鍒ゆ柇)
   res.on('close', () => { resClosed = true; });
 
   function emit(delta, finishReason, toolCalls) {
@@ -1000,26 +977,22 @@ async function openaiChat(req, res, body) {
         }
       }
       if (et.text) {
-        ensureBlock("text");
         const clean = filter.feed(et.text);
         if (clean) emit(clean, null, null);
       }
     }
     if (DEBUG_SSE && !sawEvent) console.error("[SSE-EMPTY] openai stream: no data events");
 
-    // 冲刷残留缓冲
-    ensureBlock("text");
+    // 鍐插埛娈嬬暀缂撳啿
     const flushed = filter.flush();
     if (flushed && !resClosed) emit(flushed, null, null);
 
-    // 检测并发送函数调用
-    if (!resClosed) {
+    // 妫€娴嬪苟鍙戦€佸嚱鏁拌皟鐢?    if (!resClosed) {
       const calls = filter.parseCalls();
-      // ⭐ 无法解析的 function_call 残留 — 作为文本输出, 避免静默丢失
+      // 猸?鏃犳硶瑙ｆ瀽鐨?function_call 娈嬬暀 鈥?浣滀负鏂囨湰杈撳嚭, 閬垮厤闈欓粯涓㈠け
       if (filter.leftover) emit(filter.leftover, null, null);
       if (calls.length > 0) {
-        // ⭐ OpenAI streaming tool_calls: 逐个发送
-        for (let i = 0; i < calls.length; i++) {
+        // 猸?OpenAI streaming tool_calls: 閫愪釜鍙戦€?        for (let i = 0; i < calls.length; i++) {
           const tc = calls[i];
           if (resClosed) break;
           try {
@@ -1037,15 +1010,14 @@ async function openaiChat(req, res, body) {
           }) + "\n\n");
         }
       } else {
-        // ⭐ 兜底: 流正常结束但既无文本也无工具调用 (模型只回了被过滤的内容 /
-        // 空响应 / 异常中断)。绝不让客户端收到完全空的回复 — 这是"无回复就结束"的根因。
-        if (!sentText && !resClosed) {
+        // 猸?鍏滃簳: 娴佹甯哥粨鏉熶絾鏃㈡棤鏂囨湰涔熸棤宸ュ叿璋冪敤 (妯″瀷鍙洖浜嗚杩囨护鐨勫唴瀹?/
+        // 绌哄搷搴?/ 寮傚父涓��)銆傜粷涓嶈瀹㈡埛绔敹鍒板畬鍏ㄧ┖鐨勫洖澶?鈥?杩欐槸"鏃犲洖澶嶅氨缁撴潫"鐨勬牴鍥犮€?        if (!sentText && !resClosed) {
           const fb = done
-            ? "(本轮没有生成内容，请重试或换一种问法。)"
-            : "(响应在完成前被中断，请重试。)";
+            ? "(鏈疆娌℃湁鐢熸垚鍐呭锛岃閲嶈瘯鎴栨崲涓€绉嶉棶娉曘€?"
+            : "(鍝嶅簲鍦ㄥ畬鎴愬墠琚腑鏂紝璇烽噸璇曘€?";
           emit(fb, null, null);
         }
-        // done 为 true 表示正常完成
+        // done 涓?true 琛ㄧず姝ｅ父瀹屾垚
         res.write("data: " + JSON.stringify({
           id: chatId, object: "chat.completion.chunk", created, model: modelKey,
           choices: [{ index: 0, delta: {}, finish_reason: done ? "stop" : "length" }],
@@ -1081,8 +1053,8 @@ async function anthropicMessages(req, res, body) {
   else if (Array.isArray(body.system))
     sysPrompt = body.system.filter(s => s.type === "text").map(s => s.text).join("\n");
 
-  // tools → prompt injection
-  // 如果 Claude Code 没发送 tools，注入默认工具集
+  // tools 鈫?prompt injection
+  // 濡傛灉 Claude Code 娌″彂閫?tools锛屾敞鍏ラ粯璁ゅ伐鍏烽泦
   let tools = body.tools;
   if (!tools || tools.length === 0) {
     tools = [
@@ -1094,24 +1066,22 @@ async function anthropicMessages(req, res, body) {
     ];
   }
 
-  // ⭐ 标题生成请求不需要 tools (Claude Code 首轮请求)
+  // 猸?鏍囬鐢熸垚璇锋眰涓嶉渶瑕?tools (Claude Code 棣栬疆璇锋眰)
   const isTitleGen = sysPrompt.includes('Generate a concise, sentence-case title');
 
-  // ⭐ 限制工具数量，防止 prompt 超出 IMA 10240 字符限制
+  // 猸?闄愬埗宸ュ叿鏁伴噺锛岄槻姝?prompt 瓒呭嚭 IMA 10240 瀛楃闄愬埗
   const MAX_TOOLS = 8;
   const ESSENTIAL_TOOLS = new Set(['Bash', 'Read', 'Write', 'Glob', 'Grep']);
   let displayTools = tools;
   if (isTitleGen) {
-    displayTools = [];  // 标题生成不需要工具
-  } else if (displayTools.length > MAX_TOOLS) {
-    // 优先保留核心工具，再按原顺序补充其他工具
+    displayTools = [];  // 鏍囬鐢熸垚涓嶉渶瑕佸伐鍏?  } else if (displayTools.length > MAX_TOOLS) {
+    // 浼樺厛淇濈暀鏍稿績宸ュ叿锛屽啀鎸夊師椤哄簭琛ュ厖鍏朵粬宸ュ叿
     const essential = displayTools.filter(t => ESSENTIAL_TOOLS.has(t.name));
     const others = displayTools.filter(t => !ESSENTIAL_TOOLS.has(t.name));
     const available = MAX_TOOLS - essential.length;
     displayTools = [...essential, ...others.slice(0, Math.max(0, available))];
   }
-  // —— 过滤消息 ——
-  // ⭐ 检测 Anthropic 格式的 tool_use / tool_result (多轮回传)
+  // 鈥斺€?杩囨护娑堟伅 鈥斺€?  // 猸?妫€娴?Anthropic 鏍煎紡鐨?tool_use / tool_result (澶氳疆鍥炰紶)
   function msgHasType(msg, type) {
     if (Array.isArray(msg.content)) return msg.content.some(c => c.type === type);
     return false;
@@ -1119,18 +1089,16 @@ async function anthropicMessages(req, res, body) {
   const hasToolUses = messages.some(m => m.role === "assistant" && msgHasType(m, "tool_use"));
   const hasToolResults = messages.some(m => m.role === "user" && msgHasType(m, "tool_result"));
 
-  // ⭐ 清理用户消息中的系统注入元数据
-  function stripMetadata(text) {
+  // 猸?娓呯悊鐢ㄦ埛娑堟伅涓殑绯荤粺娉ㄥ叆鍏冩暟鎹?  function stripMetadata(text) {
     return text
-      // 删除元数据块 (含内容一起删)
+      // 鍒犻櫎鍏冩暟鎹潡 (鍚唴瀹逛竴璧峰垹)
       .replace(/<system-reminder>[\s\S]*?<\/system-reminder>/g, '')
       .replace(/<local-command-caveat>[\s\S]*?<\/local-command-caveat>/g, '')
       .replace(/<local-command-stdout>[\s\S]*?<\/local-command-stdout>/g, '')
-      // 删除单行命令元数据
-      .replace(/<command-name>[^<]*<\/command-name>/g, '')
+      // 鍒犻櫎鍗曡鍛戒护鍏冩暟鎹?      .replace(/<command-name>[^<]*<\/command-name>/g, '')
       .replace(/<command-message>[^<]*<\/command-message>/g, '')
       .replace(/<command-args>[^<]*<\/command-args>/g, '')
-      // ⭐ <session> 只删标签、保留内容 (用户消息在 session 内)
+      // 猸?<session> 鍙垹鏍囩銆佷繚鐣欏唴瀹?(鐢ㄦ埛娑堟伅鍦?session 鍐?
       .replace(/<\/?session>/g, '')
       .trim();
   }
@@ -1140,7 +1108,7 @@ async function anthropicMessages(req, res, body) {
   if (userMsgs.length === 0)
     return json(res, 400, { type: "error", error: { type: "invalid_request_error", message: "No user message" } });
 
-  // ⭐ 提取最后一条用户消息的实质内容
+  // 猸?鎻愬彇鏈€鍚庝竴鏉＄敤鎴锋秷鎭殑瀹炶川鍐呭
   const realUserMsgs = userMsgs.filter(m => {
     const c = stripMetadata(extractContent(m));
     return c.length > 5;
@@ -1152,25 +1120,25 @@ async function anthropicMessages(req, res, body) {
   if (!lastUserMsg) {
   }
 
-  // ⭐ 语言检测: 用户用中文则要求中文回复
-  const hasCJK = /[一-鿿㐀-䶿]/.test(lastUserMsg);
-  const langHint = hasCJK ? "\n## Language\nRespond in the same language as the user's message. The user is writing in Chinese — respond in Chinese (简体中文).\n" : "";
+  // 猸?璇█妫€娴? 鐢ㄦ埛鐢ㄤ腑鏂囧垯瑕佹眰涓枃鍥炲
+  const hasCJK = /[涓€-榭裤悁-涠縘/.test(lastUserMsg);
+  const langHint = hasCJK ? "\n## Language\nRespond in the same language as the user's message. The user is writing in Chinese 鈥?respond in Chinese (绠€浣撲腑鏂?.\n" : "";
 
-  // 工具通过 toolsPrompt 单独注入 (见下方 question 构建)
+  // 宸ュ叿閫氳繃 toolsPrompt 鍗曠嫭娉ㄥ叆 (瑙佷笅鏂?question 鏋勫缓)
   const toolsPrompt = (displayTools && displayTools.length > 0) ? buildToolsPrompt(
     displayTools.map(t => ({ type: "function", function: { name: t.name, description: t.description, parameters: t.input_schema || {} } }))
   ) : "";
 
   let question;
-  let toolResultPath = false;  // 工具结果回传轮标记 (跳过 langHint 和截断)
+  let toolResultPath = false;  // 宸ュ叿缁撴灉鍥炰紶杞爣璁?(璺宠繃 langHint 鍜屾埅鏂?
   const MAX_QUESTION = 10000;
 
   if (hasToolResults && hasToolUses) {
-    toolResultPath = true;  // 标记: 后续跳过 langHint 注入和通用截断
-    // ⭐ 工具结果回传轮 — 单段系统通知格式，让模型把结果当作系统提供的信息
+    toolResultPath = true;  // 鏍囪: 鍚庣画璺宠繃 langHint 娉ㄥ叆鍜岄€氱敤鎴柇
+    // 猸?宸ュ叿缁撴灉鍥炰紶杞?鈥?鍗曟绯荤粺閫氱煡鏍煎紡锛岃妯″瀷鎶婄粨鏋滃綋浣滅郴缁熸彁渚涚殑淇℃伅
     const isCJK = hasCJK;
 
-    // 收集工具调用名+结果
+    // 鏀堕泦宸ュ叿璋冪敤鍚?缁撴灉
     const calledFuncs = [];
     const results = [];
     for (const m of messages) {
@@ -1190,7 +1158,7 @@ async function anthropicMessages(req, res, body) {
       }
     }
 
-    // 找到用户的原始提问 (第一条非 tool_result 的用户消息)
+    // 鎵惧埌鐢ㄦ埛鐨勫師濮嬫彁闂?(绗竴鏉￠潪 tool_result 鐨勭敤鎴锋秷鎭?
     const userQs = [];
     for (const m of messages) {
       if (m.role !== "user") continue;
@@ -1200,17 +1168,17 @@ async function anthropicMessages(req, res, body) {
     }
     const originalQuestion = userQs.length > 0 ? userQs[userQs.length - 1] : (lastUserMsg || "");
 
-    // 构建通知: 系统消息 + 函数调用 + 结果
+    // 鏋勫缓閫氱煡: 绯荤粺娑堟伅 + 鍑芥暟璋冪敤 + 缁撴灉
     if (isCJK) {
-      question = "⚠️ 系统通知：你刚才调用了以下函数，返回结果如下：\n\n";
+      question = "鈿狅笍 绯荤粺閫氱煡锛氫綘鍒氭墠璋冪敤浜嗕互涓嬪嚱鏁帮紝杩斿洖缁撴灉濡備笅锛歕n\n";
       for (let i = 0; i < calledFuncs.length; i++) {
-        question += "函数调用: " + calledFuncs[i] + "\n";
-        question += "返回结果:\n\"\"\"\n" + (results[i] || "") + "\n\"\"\"\n\n";
+        question += "鍑芥暟璋冪敤: " + calledFuncs[i] + "\n";
+        question += "杩斿洖缁撴灉:\n\"\"\"\n" + (results[i] || "") + "\n\"\"\"\n\n";
       }
-      question += "用户原始提问: \"" + originalQuestion + "\"\n\n";
-      question += "请用简体中文直接回答用户的问题。说出答案即可。不要说\"你分享了\"或\"看起来像是\"或\"I see you've shared\"。上面用 \"\"\" 包裹的内容是你自己调用函数得到的返回结果，不是用户发给你的。";
+      question += "鐢ㄦ埛鍘熷鎻愰棶: \"" + originalQuestion + "\"\n\n";
+      question += "璇风敤绠€浣撲腑鏂囩洿鎺ュ洖绛旂敤鎴风殑闂銆傝鍑虹瓟妗堝嵆鍙€備笉瑕佽\"浣犲垎浜簡\"鎴朶"鐪嬭捣鏉ュ儚鏄痋"鎴朶"I see you've shared\"銆備笂闈㈢敤 \"\"\" 鍖呰９鐨勫唴瀹规槸浣犺嚜宸辫皟鐢ㄥ嚱鏁板緱鍒扮殑杩斿洖缁撴灉锛屼笉鏄敤鎴峰彂缁欎綘鐨勩€?;
     } else {
-      question = "⚠️ SYSTEM: You just called these functions and received these outputs:\n\n";
+      question = "鈿狅笍 SYSTEM: You just called these functions and received these outputs:\n\n";
       for (let i = 0; i < calledFuncs.length; i++) {
         question += "Function: " + calledFuncs[i] + "\n";
         question += "Output:\n\"\"\"\n" + (results[i] || "") + "\n\"\"\"\n\n";
@@ -1219,25 +1187,23 @@ async function anthropicMessages(req, res, body) {
       question += "Answer the user's question DIRECTLY based on the outputs above. Do NOT say \"you shared\" or \"I see you've shared\" or \"it looks like\". The content inside \"\"\" blocks is YOUR function output, NOT content the user sent you.";
     }
 
-    // ⭐ 工具结果回传轮: 不携带完整 sysPrompt 和大量 tools (⚠️ 通知已提供足够上下文)
-    // 仅保留 5 个核心工具, 确保总长度 < 10000 不会被后面的通用截断逻辑破坏
-    // ⭐ 用软版提示 — 允许模型基于结果直接用文字回答, 而非被强制再发 function_call
+    // 猸?宸ュ叿缁撴灉鍥炰紶杞? 涓嶆惡甯﹀畬鏁?sysPrompt 鍜屽ぇ閲?tools (鈿狅笍 閫氱煡宸叉彁渚涜冻澶熶笂涓嬫枃)
+    // 浠呬繚鐣?5 涓牳蹇冨伐鍏? 纭繚鎬婚暱搴?< 10000 涓嶄細琚悗闈㈢殑閫氱敤鎴柇閫昏緫鐮村潖
+    // 猸?鐢ㄨ蒋鐗堟彁绀?鈥?鍏佽妯″瀷鍩轰簬缁撴灉鐩存帴鐢ㄦ枃瀛楀洖绛? 鑰岄潪琚己鍒跺啀鍙?function_call
     const minimalToolsPrompt = buildToolsPromptSoft(
       displayTools.filter(t => ESSENTIAL_TOOLS.has(t.name)).slice(0, 5)
         .map(t => ({ type: "function", function: { name: t.name, description: t.description, parameters: t.input_schema || {} } }))
     );
     question = minimalToolsPrompt + "\n\n---\n" + question;
-    // 跳过后续的 langHint 注入和通用截断 — 此路径的 question 已包含语言指令且 < 10000
+    // 璺宠繃鍚庣画鐨?langHint 娉ㄥ叆鍜岄€氱敤鎴柇 鈥?姝よ矾寰勭殑 question 宸插寘鍚瑷€鎸囦护涓?< 10000
   } else if (nonSys.length > 1 && realUserMsgs.length >= 1) {
-    // 取真正的用户消息（过滤掉系统注入的元数据）
-    const realMsgs = nonSys
+    // 鍙栫湡姝ｇ殑鐢ㄦ埛娑堟伅锛堣繃婊ゆ帀绯荤粺娉ㄥ叆鐨勫厓鏁版嵁锛?    const realMsgs = nonSys
       .filter(m => {
         const c = stripMetadata(extractContent(m));
         return c.length > 5;
       });
     if (realMsgs.length > 1) {
-      // ⭐ 修复: 从 6 条扩展到 20 条，并按总字符限制动态裁剪（保留最新的消息）
-      const MAX_HISTORY_CHARS = 6000; // 留出空间给 sysPrompt + toolsPrompt
+      // 猸?淇: 浠?6 鏉℃墿灞曞埌 20 鏉★紝骞舵寜鎬诲瓧绗﹂檺鍒跺姩鎬佽鍓紙淇濈暀鏈€鏂扮殑娑堟伅锛?      const MAX_HISTORY_CHARS = 6000; // 鐣欏嚭绌洪棿缁?sysPrompt + toolsPrompt
       const recentMsgs = realMsgs.slice(-20);
       let historyParts = [];
       let historyLen = 0;
@@ -1251,16 +1217,14 @@ async function anthropicMessages(req, res, body) {
       question = historyParts.join("\n");
       question = (sysPrompt ? sysPrompt + "\n\n" : "") + (toolsPrompt ? toolsPrompt + "\n\n---\n" : "") + question;
     } else {
-      // 只有一条真正消息，走单轮路径
-      question = (sysPrompt ? "(Background)\n" + sysPrompt + "\n\n" : "") + toolsPrompt + "\n\n---\nUser message (respond to this):\n" + lastUserMsg;
+      // 鍙湁涓€鏉＄湡姝ｆ秷鎭紝璧板崟杞矾寰?      question = (sysPrompt ? "(Background)\n" + sysPrompt + "\n\n" : "") + toolsPrompt + "\n\n---\nUser message (respond to this):\n" + lastUserMsg;
     }
   } else {
     let context = sysPrompt;
     const overhead = toolsPrompt.length + lastUserMsg.length + 200;
     const remaining = MAX_QUESTION - overhead;
     if (context && context.length > remaining && remaining > 0) {
-      // ⭐ 修复: 保留头部（核心规则）+ 尾部（最新文件列表），中间裁剪
-      // 而非旧逻辑的"只保留前500字+目录"，那样会丢失大量重要指令
+      // 猸?淇: 淇濈暀澶撮儴锛堟牳蹇冭鍒欙級+ 灏鹃儴锛堟渶鏂版枃浠跺垪琛級锛屼腑闂磋鍓?      // 鑰岄潪鏃ч€昏緫鐨?鍙繚鐣欏墠500瀛?鐩綍"锛岄偅鏍蜂細涓㈠け澶ч噺閲嶈鎸囦护
       const layoutMatch = context.match(/<project_layout>([\s\S]*?)<\/project_layout>/);
       const layoutSummary = layoutMatch ? layoutMatch[1].trim().split("\n").slice(0, 30).join("\n") : "";
       const headLen = Math.min(800, Math.floor(remaining * 0.6));
@@ -1274,7 +1238,7 @@ async function anthropicMessages(req, res, body) {
     question = (context ? "(Background)\n" + context + "\n\n" : "") + toolsPrompt + "\n\n---\nUser message (respond to this):\n" + lastUserMsg;
   }
 
-  // ⭐ 注入语言提示 & 截断 (工具结果回传轮跳过 — 已自带语言指令且 < 10000)
+  // 猸?娉ㄥ叆璇█鎻愮ず & 鎴柇 (宸ュ叿缁撴灉鍥炰紶杞烦杩?鈥?宸茶嚜甯﹁瑷€鎸囦护涓?< 10000)
   if (!toolResultPath) {
     question += langHint;
 
@@ -1291,18 +1255,16 @@ async function anthropicMessages(req, res, body) {
   }
 
 
-  // 会话 — ⭐ 关键: 必须复用 IMA session 才能保持对话记忆
+  // 浼氳瘽 鈥?猸?鍏抽敭: 蹇呴』澶嶇敤 IMA session 鎵嶈兘淇濇寔瀵硅瘽璁板繂
   const convId = req.headers["x-conversation-id"] || req.headers["x-session-id"] || "";
-  // ⭐ 修复: 用系统 prompt + 第一条用户消息的 hash 作为稳定会话锚点
-  // Claude Code 不发 x-conversation-id, 但同一对话的 system prompt 内容固定
+  // 猸?淇: 鐢ㄧ郴缁?prompt + 绗竴鏉＄敤鎴锋秷鎭殑 hash 浣滀负绋冲畾浼氳瘽閿氱偣
+  // Claude Code 涓嶅彂 x-conversation-id, 浣嗗悓涓€瀵硅瘽鐨?system prompt 鍐呭鍥哄畾
   let effectiveConvId = convId;
   if (!effectiveConvId && messages.length > 0) {
-    // 优先用 system prompt (Claude Code 在 system 里放项目路径等固定信息)
+    // 浼樺厛鐢?system prompt (Claude Code 鍦?system 閲屾斁椤圭洰璺緞绛夊浐瀹氫俊鎭?
     const sysMsg = messages.find(m => m.role === "system");
     const anchor = sysMsg
-      ? extractContent(sysMsg).slice(0, 200)           // system prompt 前200字，通常含项目路径
-      : extractContent(messages[0]).slice(0, 200);      // fallback: 第一条消息
-    effectiveConvId = "conv-" + crypto.createHash("md5").update(anchor).digest("hex").slice(0, 12);
+      ? extractContent(sysMsg).slice(0, 200)           // system prompt 鍓?00瀛楋紝閫氬父鍚」鐩矾寰?      : extractContent(messages[0]).slice(0, 200);      // fallback: 绗竴鏉℃秷鎭?    effectiveConvId = "conv-" + crypto.createHash("md5").update(anchor).digest("hex").slice(0, 12);
   }
   let sessionId;
   const isNewSession = !getCachedSession(effectiveConvId);
@@ -1312,7 +1274,7 @@ async function anthropicMessages(req, res, body) {
     return json(res, 502, { type: "error", error: { type: "api_error", message: "Session init failed: " + e.message } });
   }
 
-  // --- 非流式 ---
+  // --- 闈炴祦寮?---
   if (!stream) {
     try {
       const events = await imaQaStreamWithRetry(effectiveConvId, question, model.type, model.id);
@@ -1340,8 +1302,8 @@ async function anthropicMessages(req, res, body) {
       return json(res, 200, {
         id: "msg_" + crypto.randomUUID().slice(0, 8),
         type: "message", role: "assistant", model: modelKey,
-        // ⭐ 兜底: 空文本时给出占位, 避免客户端收到空 content
-        content: [{ type: "text", text: text || "(本轮没有生成内容，请重试或换一种问法。)" }],
+        // 猸?鍏滃簳: 绌烘枃鏈椂缁欏嚭鍗犱綅, 閬垮厤瀹㈡埛绔敹鍒扮┖ content
+        content: [{ type: "text", text: text || "(鏈疆娌℃湁鐢熸垚鍐呭锛岃閲嶈瘯鎴栨崲涓€绉嶉棶娉曘€?" }],
         stop_reason: "end_turn", stop_sequence: null,
         usage: { input_tokens: 0, output_tokens: 0 },
       });
@@ -1351,7 +1313,7 @@ async function anthropicMessages(req, res, body) {
     }
   }
 
-  // --- 流式 ---
+  // --- 娴佸紡 ---
   cors(res);
   res.writeHead(200, {
     "Content-Type": "text/event-stream",
@@ -1400,10 +1362,9 @@ async function anthropicMessages(req, res, body) {
 
   let stopReason = "end_turn";
   let done = false;
-  let sentText = false;   // ⭐ 是否已发送过任何文本 delta (兜底判断)
+  let sentText = false;   // 猸?鏄惁宸插彂閫佽繃浠讳綍鏂囨湰 delta (鍏滃簳鍒ゆ柇)
   const filter = new StreamFilter();
-  let calls = [];  // 在 try 外声明，供后续 tool_use 发送使用
-  try {
+  let calls = [];  // 鍦?try 澶栧０鏄庯紝渚涘悗缁?tool_use 鍙戦€佷娇鐢?  try {
     const events = await imaQaStreamWithRetry(effectiveConvId, question, model.type, model.id);
 
     for await (const evt of events) {
@@ -1413,6 +1374,12 @@ async function anthropicMessages(req, res, body) {
         break;
       }
       const et = eventTexts(evt);
+      // Diagnostic: log what each event produces
+      if (et.think || et.text) {
+        process.stderr.write("[SSE-EVT] event=" + (evt.event || "(none)") + " think=" + (et.think ? et.think.length + "c" : "none") + " text=" + (et.text ? et.text.length + "c" : "none") + "\n");
+      } else if (evt.data) {
+        process.stderr.write("[SSE-EVT] event=" + (evt.event || "(none)") + " UNMATCHED: " + evt.data.slice(0, 300) + "\n");
+      }
       // Emit thinking content as separate content block
       if (et.think) {
         if (DEBUG_SSE) console.log("[SSE-THINK]  " + JSON.stringify(et.think).slice(0, 200));
@@ -1426,42 +1393,49 @@ async function anthropicMessages(req, res, body) {
       }
       if (et.text) {
         ensureBlock("text");
-        const clean = filter.feed(et.text);
-        if (clean) { em("content_block_delta", { type: "content_block_delta", index: blockIdx, delta: { type: "text_delta", text: clean } }); sentText = true; }
+        // Bypass filter for text that clearly has no function_call
+        let clean;
+        if (et.text.indexOf('<') === -1) {
+          clean = et.text;
+        } else {
+          clean = filter.feed(et.text);
+        }
+        if (clean) {
+          em("content_block_delta", { type: "content_block_delta", index: blockIdx, delta: { type: "text_delta", text: clean } });
+          sentText = true;
+        } else {
+          process.stderr.write("[SSE-FILTER] feed returned empty, buf=" + filter._buf.length + "c inFunc=" + filter._inFunc + " et.text=" + et.text.slice(0, 80) + "\n");
+        }
       }
     }
 
-    // 冲刷残留缓冲
-    ensureBlock("text");
+    // 鍐插埛娈嬬暀缂撳啿
     const flushed = filter.flush();
     if (flushed && !resClosed) { em("content_block_delta", { type: "content_block_delta", index: blockIdx, delta: { type: "text_delta", text: flushed } }); sentText = true; }
 
     calls = filter.parseCalls();
-    // ⭐ 无法解析的 function_call 残留 — 作为文本输出, 避免静默丢失
+    // 猸?鏃犳硶瑙ｆ瀽鐨?function_call 娈嬬暀 鈥?浣滀负鏂囨湰杈撳嚭, 閬垮厤闈欓粯涓㈠け
     if (filter.leftover && !resClosed) { em("content_block_delta", { type: "content_block_delta", index: blockIdx, delta: { type: "text_delta", text: filter.leftover } }); sentText = true; }
 
-    // ⭐ 兜底: 流结束但既无文本也无工具调用 — 绝不让客户端收到完全空的回复。
-    // 这是 Claude Code "执行命令后无任何回复就结束" 的最终防线。
-    if (!sentText && calls.length === 0 && !resClosed) {
+    // 猸?鍏滃簳: 娴佺粨鏉熶絾鏃㈡棤鏂囨湰涔熸棤宸ュ叿璋冪敤 鈥?缁濅笉璁╁鎴风鏀跺埌瀹屽叏绌虹殑鍥炲銆?    // 杩欐槸 Claude Code "鎵ц鍛戒护鍚庢棤浠讳綍鍥炲灏辩粨鏉? 鐨勬渶缁堥槻绾裤€?    if (!sentText && calls.length === 0 && !resClosed) {
       const fb = done
-        ? "(本轮没有生成内容，请重试或换一种问法。)"
-        : "(响应在完成前被中断，请重试。)";
+        ? "(鏈疆娌℃湁鐢熸垚鍐呭锛岃閲嶈瘯鎴栨崲涓€绉嶉棶娉曘€?"
+        : "(鍝嶅簲鍦ㄥ畬鎴愬墠琚腑鏂紝璇烽噸璇曘€?";
       ensureBlock("text");
       em("content_block_delta", { type: "content_block_delta", index: blockIdx, delta: { type: "text_delta", text: fb } });
       sentText = true;
     }
   } catch (e) {
     console.error(`[ANTHROPIC-STREAM-ERR] ${e.message}`);
-    // ⭐ 异常路径同样兜底, 保证至少有一段文本
-    if (!sentText && !resClosed) {
-      try { em("content_block_delta", { type: "content_block_delta", index: blockIdx, delta: { type: "text_delta", text: "(响应处理出错，请重试。)" } }); sentText = true; } catch {}
+    // 猸?寮傚父璺緞鍚屾牱鍏滃簳, 淇濊瘉鑷冲皯鏈変竴娈垫枃鏈?    if (!sentText && !resClosed) {
+      try { em("content_block_delta", { type: "content_block_delta", index: blockIdx, delta: { type: "text_delta", text: "(鍝嶅簲澶勭悊鍑洪敊锛岃閲嶈瘯銆?" } }); sentText = true; } catch {}
     }
   }
 
-  // 结束文本块 (仅在未截停时)
+  // 缁撴潫鏂囨湰鍧?(浠呭湪鏈埅鍋滄椂)
   if (!resClosed) closeBlock();
 
-  // ⭐ 发送函数调用 — 使用上面已解析的 calls (避免重复解析)
+  // 猸?鍙戦€佸嚱鏁拌皟鐢?鈥?浣跨敤涓婇潰宸茶В鏋愮殑 calls (閬垮厤閲嶅瑙ｆ瀽)
   if (!resClosed && calls.length > 0) {
     stopReason = "tool_use";
     for (let i = 0; i < calls.length; i++) {
@@ -1482,7 +1456,7 @@ async function anthropicMessages(req, res, body) {
 }
 
 // ============================================================
-// 10. 路由
+// 10. 璺敱
 // ============================================================
 async function router(req, res) {
   cors(res);
@@ -1523,8 +1497,7 @@ async function router(req, res) {
       });
       body = raw ? JSON.parse(raw) : {};
 
-      // body 已解析
-    } catch (e) {
+      // body 宸茶В鏋?    } catch (e) {
       return json(res, 400, { error: { type: "invalid_request_error", message: "Invalid JSON body" } });
     }
   }
@@ -1579,17 +1552,18 @@ async function router(req, res) {
 }
 
 // ============================================================
-// 11. 启动
+// 11. 鍚姩
 // ============================================================
  const PORT = process.env.PORT || CONFIG.server?.port || 8080;
 const HOST = CONFIG.server?.host || "0.0.0.0";
 
 http.createServer(router).listen(PORT, HOST, () => {
   console.log(`\n${'='.repeat(50)}`);
-  console.log(`[STARTUP] 服务启动于 http://${HOST}:${PORT}`);
+  console.log(`[STARTUP] 鏈嶅姟鍚姩浜?http://${HOST}:${PORT}`);
   console.log(`[STARTUP] API keys count: ${API_KEYS.size} (source: ${(process.env.IMA_API_KEYS || "") ? "env IMA_API_KEYS" : "config.json"})`);
   for (const k of API_KEYS) {
     console.log(`[STARTUP]   key: ${maskKey(k)} (len=${k.length})`);
   }
   setInterval(refreshCookie, 60 * 1000);
 });
+