🐛 处理 PR #1355 Copilot review 建议及 llm_client 同类问题

- background_session_manager.ts: target 添加 ToolCall | undefined 类型，避免 strict 模式下隐式 any
- ChatArea.tsx: 主消息分支 tool_call_delta 同步改为 id/index/running 三级匹配
- openai.test.ts: 重写 "{}" 用例的断言与名称，明确 start 事件 args 为空、首 chunk args 作为 delta
- anthropic.ts: content_block_stop 清理对应 index，message_stop 清空 toolUseByIndex，顺带去掉 diff-annotation 注释
- llm_client.ts: 移除单指针 currentToolCall 模型，改为 push-then-match 三级匹配，修复执行路径在并发 tool_call 下的参数串扰

Author: CodFrm

src/app/service/agent/core/providers/anthropic.ts

@@ -248,11 +248,11 @@ export function parseAnthropicStream(
             } else if (delta?.type === "thinking_delta") {
               onEvent({ type: "thinking_delta", delta: delta.thinking });
             } else if (delta?.type === "input_json_delta") {
-              const tu = toolUseByIndex.get(json.index); // ← 新增
+              const tu = toolUseByIndex.get(json.index);
               onEvent({
                 type: "tool_call_delta",
-                id: tu?.id || "", // ← 不再固定 ""
-                index: json.index, // ← 新增
+                id: tu?.id || "",
+                index: json.index,
                 delta: delta.partial_json,
               });
             } else if (delta?.type === "image_delta" && imageBlockData) {
@@ -279,6 +279,10 @@ export function parseAnthropicStream(
               });
               imageBlockData = null;
             }
+            // tool_use block 结束后清理 index→id 映射，避免长会话下 map 持续增长
+            if (typeof json.index === "number") {
+              toolUseByIndex.delete(json.index);
+            }
             break;
           }
           case "message_delta": {
@@ -298,6 +302,7 @@ export function parseAnthropicStream(
             break;
           }
           case "message_stop": {
+            toolUseByIndex.clear();
             onEvent({ type: "done" });
             return true;
           }

src/app/service/agent/core/providers/openai.test.ts

@@ -552,7 +552,7 @@ describe("parseOpenAIStream", () => {
     }
   });
 
-  it("首 chunk 同时带 name 和 arguments='{}' 时不应污染后续 args", async () => {
+  it("首 chunk 同时带 name 和 arguments 时：start 事件 args 为空，首 chunk args 作为 delta 发出", async () => {
     const reader = createMockReader([
       // gateway / 某些 model 会先发一个 arguments="{}" 占位再送真正 JSON
       'data: {"choices":[{"delta":{"tool_calls":[{"index":0,"id":"call_x","function":{"name":"agent","arguments":"{}"}}]}}]}\n\n',
@@ -565,18 +565,16 @@ describe("parseOpenAIStream", () => {
 
     expect(events[0].type).toBe("tool_call_start");
     if (events[0].type === "tool_call_start") {
-      // 关键断言：start 事件里的 args 必须为空，不能是 "{}"
+      // 关键断言：start 事件里的 args 必须为空，不能是 "{}"（避免前缀污染）
       expect(events[0].toolCall.arguments).toBe("");
       expect(events[0].toolCall.name).toBe("agent");
     }
-    // 三段 delta：首 chunk 的 "{}" + 两次真实 JSON
+    // 首 chunk 的 "{}" 作为第一段 delta 原样透传（模型问题：整体非合法 JSON，但解析器不吞字符）
     const deltas = events.filter((e) => e.type === "tool_call_delta");
     expect(deltas).toHaveLength(3);
-    const joined = deltas.map((e) => (e.type === "tool_call_delta" ? e.delta : "")).join("");
-    // 拼接后应等同 LLM 真正要发的（就算首 chunk 有 "{}"，也应被后续覆盖式语义接受）
-    // 注意：如果模型真的先发 "{}" 再发别的 JSON，整体不是合法 JSON —— 这是模型问题，
-    // 但至少我们不在 start 事件里把 "{}" 当成 args 的 prefix。
-    expect(joined.startsWith("{}")).toBe(true); // 原样透传
+    expect(deltas[0].type === "tool_call_delta" && deltas[0].delta).toBe("{}");
+    expect(deltas[1].type === "tool_call_delta" && deltas[1].delta).toBe('{"description":"r"');
+    expect(deltas[2].type === "tool_call_delta" && deltas[2].delta).toBe(',"prompt":"do"}');
   });
 
   it("并发多个 tool_call（不同 index）arguments 不应互相串扰", async () => {

src/app/service/agent/service_worker/background_session_manager.ts

@@ -62,12 +62,12 @@ export class BackgroundSessionManager {
         // 并发 tool call 时（OpenAI 用 index 区分、Anthropic 的多个 tool_use block）length-1 会把 delta 写错工具。
         if (rc.streamingState.toolCalls.length === 0) break;
 
-        let target;
-        // 1a. 按 id 配對
+        let target: ToolCall | undefined = undefined;
+        // 1a. 按 id 匹配
         if (event.id) {
           target = rc.streamingState.toolCalls.find((t) => t.id === event.id);
         }
-        // 1b. 按 index 配對（OpenAI 後續 chunk 無 id 只有 index）
+        // 1b. 按 index 匹配（OpenAI 后续 chunk 无 id 只有 index）
         if (!target && event.index !== undefined) {
           target = rc.streamingState.toolCalls[event.index];
         }

src/app/service/agent/service_worker/llm_client.ts

@@ -128,7 +128,6 @@ export class LLMClient {
     let content = "";
     let thinking = "";
     const toolCalls: ToolCall[] = [];
-    let currentToolCall: ToolCall | null = null;
     let usage:
       | { inputTokens: number; outputTokens: number; cacheCreationInputTokens?: number; cacheReadInputTokens?: number }
       | undefined;
@@ -157,23 +156,34 @@ export class LLMClient {
             thinking += event.delta;
             break;
           case "tool_call_start":
-            // 如果已有一个正在收集的 tool call，先保存它（多个 tool_use 并行返回时）
-            if (currentToolCall) {
-              toolCalls.push(currentToolCall);
-            }
-            currentToolCall = { ...event.toolCall, arguments: event.toolCall.arguments || "" };
+            // 并发 tool_call 时 parser 会交错发 delta，这里立即 push 到数组，
+            // 由 tool_call_delta 通过 id/index 定位目标 tool，避免串扰。
+            toolCalls.push({ ...event.toolCall, arguments: event.toolCall.arguments || "", status: "running" });
             break;
-          case "tool_call_delta":
-            if (currentToolCall) {
-              currentToolCall.arguments += event.delta;
+          case "tool_call_delta": {
+            if (!toolCalls.length) break;
+            let target: ToolCall | undefined = undefined;
+            // 1a. 按 id 匹配
+            if (event.id) {
+              target = toolCalls.find((t) => t.id === event.id);
+            }
+            // 1b. 按 index 匹配（OpenAI 后续 chunk 无 id 只有 index）
+            if (!target && event.index !== undefined) {
+              target = toolCalls[event.index];
             }
+            // 2. fallback：最新一个状态为 running 的 tool call
+            if (!target) {
+              for (let i = toolCalls.length - 1; i >= 0; i--) {
+                if (toolCalls[i].status === "running") {
+                  target = toolCalls[i];
+                  break;
+                }
+              }
+            }
+            if (target) target.arguments += event.delta;
             break;
+          }
           case "done": {
-            // 保存当前的 tool call
-            if (currentToolCall) {
-              toolCalls.push(currentToolCall);
-              currentToolCall = null;
-            }
             if (event.usage) {
               usage = event.usage;
             }

src/pages/options/routes/AgentChat/ChatArea.tsx

@@ -281,12 +281,21 @@ export default function ChatArea({
           if (!msg.toolCalls) msg.toolCalls = [];
           msg.toolCalls.push({ ...event.toolCall, status: "running" });
           break;
-        case "tool_call_delta":
-          if (msg.toolCalls?.length) {
-            const lastTc = msg.toolCalls[msg.toolCalls.length - 1];
-            lastTc.arguments += event.delta;
+        case "tool_call_delta": {
+          if (!msg.toolCalls?.length) break;
+          let t = event.id ? msg.toolCalls.find((x) => x.id === event.id) : undefined;
+          if (!t && event.index !== undefined) t = msg.toolCalls[event.index];
+          if (!t) {
+            for (let i = msg.toolCalls.length - 1; i >= 0; i--) {
+              if (msg.toolCalls[i].status === "running") {
+                t = msg.toolCalls[i];
+                break;
+              }
+            }
           }
+          if (t) t.arguments += event.delta;
           break;
+        }
         case "tool_call_complete": {
           const tc = msg.toolCalls?.find((t) => t.id === event.id);
           if (tc) {