Merge branch 'ls-dev' into 'master'

JerryliDe · JerryliDe · commit 23bafa331520 · 2026-06-04T12:59:11.000+08:00
fix(core): pair synthetic ids for parallel same-name tool calls in sanitize to fix Gemini 400

See merge request ai_native/DeepVCode/DeepVcodeClient!478
diff --git a/packages/core/src/core/geminiChat.ts b/packages/core/src/core/geminiChat.ts
@@ -437,6 +437,94 @@ export class GeminiChat {
    * 函数体保持不变；如需更新清洗规则，只在这里修改即可。
    */
   static sanitizeRequestContents(requestContents: Content[]): Content[] {
+    // 🆕 [并行同名工具调用兜底] —— 在任何 dedup 之前给「同名 ≥2 且都无 id」的 fc/fr 配合成 id
+    //
+    // 触发场景（用户实拍 400，状态栏全程 [Gemini] gemini-3.5-flash，没切模型）：
+    //   Gemini 原生上游报：
+    //     "Please ensure that the number of function response parts
+    //      is equal to the number of function call parts of the function call turn."
+    //
+    // 根因：Gemini 协议下 functionCall / functionResponse 的 `id` 字段不强制必填。
+    //   当 Gemini 在一个 turn 里**并行调用 N 次同名工具**（比如同时 read_file
+    //   多个文件、并行 replace 多处），写回的 N 个 fr 全是同 name 无 id。
+    //   而下面去重阶段使用的 key = `id || name:${name}` 会让这 N 个 fr 全部 collide
+    //   到同一个桶，只保留 1 个 → API 收到 N 个 fc 但只有 1 个 fr → 数量不等 → 400。
+    //
+    //   `unmatchedCalls` 那一步用的 isToolMatch 在双方都无 id 时回退到「只看 name」，
+    //   N 个 fc 都"匹配"到唯一 1 个 fr，也不会触发 cancel 补全。
+    //
+    // 修复策略：进入任何 dedup 之前，专门针对「同名 ≥2 个无 id functionCall」这个
+    //   触发条件启动「合成 id 配对」—— 给这 N 个 fc 各自分配确定性合成 id，按
+    //   出现顺序入 FIFO 队列；下游 N 个无 id 同名 fr 按 FIFO 顺序 dequeue 同一个
+    //   合成 id 回填给自己。这样后续所有 dedup/匹配逻辑就能按 id 区分桶。
+    //
+    // 关键约束（保护现有行为，零回归）：
+    //   - 仅当**同名无 id fc 出现 ≥2 次**才启动 —— 这是 bug 的唯一触发条件。
+    //     单个无 id fc 的场景（Claude 跨模型迁移）继续走原 name 模糊匹配路径。
+    //   - 任一侧已经带 id 的 fc/fr 完全不动。
+    //   - 合成 id 用稳定 counter，不依赖 Date.now()/Math.random() —— 幂等性保留。
+    //   - 没匹配上的多余无 id fr 会自然落入下面"移除孤立 functionResponse"分支。
+    //   - 与 4343cb67 在 AnthropicConverter 内的合成 id 配对独立互不干扰。
+    {
+      // 第 0 步：扫描所有 functionCall，统计每个 name 下「无 id」实例的数量
+      const noIdCallsByName = new Map<string, number>();
+      for (const content of requestContents) {
+        if (content.role !== MESSAGE_ROLES.MODEL || !content.parts) continue;
+        for (const part of content.parts) {
+          const fc = (part as any)?.functionCall;
+          if (!fc || typeof fc !== 'object') continue;
+          if (typeof fc.id === 'string' && fc.id.length > 0) continue;
+          const name = typeof fc.name === 'string' ? fc.name : 'unknown';
+          noIdCallsByName.set(name, (noIdCallsByName.get(name) ?? 0) + 1);
+        }
+      }
+
+      // 仅对「同名 ≥2 个无 id fc」的 name 启动 FIFO 合成 id 配对
+      const namesNeedingSynth = new Set<string>();
+      for (const [name, count] of noIdCallsByName) {
+        if (count >= 2) namesNeedingSynth.add(name);
+      }
+
+      if (namesNeedingSynth.size > 0) {
+        let synthCounter = 0;
+        const queueByName = new Map<string, string[]>();
+        const mintId = (name: string) => `gem_synth_${name}_${++synthCounter}`;
+
+        // 第 1 遍：给目标 name 的所有无 id functionCall 分配合成 id 并入队
+        for (const content of requestContents) {
+          if (content.role !== MESSAGE_ROLES.MODEL || !content.parts) continue;
+          for (const part of content.parts) {
+            const fc = (part as any)?.functionCall;
+            if (!fc || typeof fc !== 'object') continue;
+            if (typeof fc.id === 'string' && fc.id.length > 0) continue;
+            const name = typeof fc.name === 'string' ? fc.name : 'unknown';
+            if (!namesNeedingSynth.has(name)) continue;
+            const synth = mintId(name);
+            fc.id = synth;
+            if (!queueByName.has(name)) queueByName.set(name, []);
+            queueByName.get(name)!.push(synth);
+          }
+        }
+
+        // 第 2 遍：目标 name 的无 id functionResponse 按 FIFO 配对回填合成 id
+        for (const content of requestContents) {
+          if (content.role !== MESSAGE_ROLES.USER || !content.parts) continue;
+          for (const part of content.parts) {
+            const fr = (part as any)?.functionResponse;
+            if (!fr || typeof fr !== 'object') continue;
+            if (typeof fr.id === 'string' && fr.id.length > 0) continue;
+            const name = typeof fr.name === 'string' ? fr.name : 'unknown';
+            if (!namesNeedingSynth.has(name)) continue;
+            const queue = queueByName.get(name);
+            if (queue && queue.length > 0) {
+              fr.id = queue.shift()!;
+            }
+            // 若队列耗尽：fr 找不到对应 fc，留给下面「移除孤立 functionResponse」处理
+          }
+        }
+      }
+    }
+
     const fixedContents: Content[] = [];
 
     // 🔍 辅助函数：判断 functionCall 和 functionResponse 是否匹配
diff --git a/packages/core/src/core/sanitizeRequestContents.test.ts b/packages/core/src/core/sanitizeRequestContents.test.ts
@@ -664,3 +664,213 @@ describe('GeminiChat.sanitizeRequestContents > 协议不变量', () => {
     assertContractInvariants(GeminiChat.sanitizeRequestContents(input));
   });
 });
+
+// ─────────────────────────────────────────────────────────────────────
+// 9. 并行同名工具调用兜底（用户实拍 400 回归）
+//
+//   状态栏 [Gemini] gemini-3.5-flash 全程未切模型，
+//   错误是 Gemini 原生上游 400：
+//     "Please ensure that the number of function response parts is equal
+//      to the number of function call parts of the function call turn."
+//
+//   触发条件：单个 model turn 里**并行调用 N 次同名工具**（如同时
+//   read_file 多个文件、replace 多处），按 Gemini 原生协议 functionCall /
+//   functionResponse 的 id 都允许缺省，于是 N 个 fr 都同名无 id，去重阶段
+//   误判为「重复响应」只保留 1 个 → 400。
+//
+//   修复行为：sanitize 在最开头做 FIFO 合成 id 配对，仅当**同名 ≥2 个无 id
+//   fc** 触发；任一侧已带 id / 单条无 id 都不动（保护现有 Claude 跨模型场景）。
+// ─────────────────────────────────────────────────────────────────────
+describe('GeminiChat.sanitizeRequestContents > 并行同名工具调用兜底', () => {
+  it('单 turn 内并行调用 2 次同名工具（双方都无 id）：两组 fc/fr 全部保留', () => {
+    const input: Content[] = [
+      { role: MESSAGE_ROLES.USER, parts: [{ text: '同时读两个文件' } as any] },
+      {
+        role: MESSAGE_ROLES.MODEL,
+        parts: [
+          { functionCall: { name: 'read_file', args: { absolute_path: '/a.css' } } as any },
+          { functionCall: { name: 'read_file', args: { absolute_path: '/b.css' } } as any },
+        ],
+      },
+      {
+        role: MESSAGE_ROLES.USER,
+        parts: [
+          { functionResponse: { name: 'read_file', response: { output: 'AAA' } } as any },
+          { functionResponse: { name: 'read_file', response: { output: 'BBB' } } as any },
+        ],
+      },
+    ];
+
+    const result = GeminiChat.sanitizeRequestContents(input);
+
+    // 关键不变量：fc 的数量必须 === fr 的数量（这正是 Gemini 400 的判定式）
+    const fcCount = result.flatMap(c => c.parts || []).filter((p: any) => p.functionCall).length;
+    const frCount = result.flatMap(c => c.parts || []).filter((p: any) => p.functionResponse).length;
+    expect(fcCount).toBe(2);
+    expect(frCount).toBe(2);
+
+    // 两组 fr 的内容必须都被保留（按出现顺序 FIFO 配对到 fc）
+    const frs = result.flatMap(c => c.parts || []).filter((p: any) => p.functionResponse);
+    const outputs = frs.map((p: any) => p.functionResponse.response.output).sort();
+    expect(outputs).toEqual(['AAA', 'BBB']);
+  });
+
+  it('并行 N 次同名工具（N=5，双方都无 id）：全部 5 组 fc/fr 都保留，数量严格相等', () => {
+    const input: Content[] = [
+      {
+        role: MESSAGE_ROLES.MODEL,
+        parts: Array.from({ length: 5 }, (_, i) => ({
+          functionCall: { name: 'replace', args: { idx: i } } as any,
+        })),
+      },
+      {
+        role: MESSAGE_ROLES.USER,
+        parts: Array.from({ length: 5 }, (_, i) => ({
+          functionResponse: { name: 'replace', response: { idx: i } } as any,
+        })),
+      },
+    ];
+
+    const result = GeminiChat.sanitizeRequestContents(input);
+    const fcCount = result.flatMap(c => c.parts || []).filter((p: any) => p.functionCall).length;
+    const frCount = result.flatMap(c => c.parts || []).filter((p: any) => p.functionResponse).length;
+    expect(fcCount).toBe(5);
+    expect(frCount).toBe(5);
+  });
+
+  it('并行调用混合多个名字（read_file × 2 + glob × 2）：各自按 name 独立 FIFO，互不串扰', () => {
+    const input: Content[] = [
+      {
+        role: MESSAGE_ROLES.MODEL,
+        parts: [
+          { functionCall: { name: 'read_file', args: { p: 'a' } } as any },
+          { functionCall: { name: 'glob', args: { p: '**/*' } } as any },
+          { functionCall: { name: 'read_file', args: { p: 'b' } } as any },
+          { functionCall: { name: 'glob', args: { p: '*.ts' } } as any },
+        ],
+      },
+      {
+        role: MESSAGE_ROLES.USER,
+        parts: [
+          { functionResponse: { name: 'read_file', response: { from: 'a' } } as any },
+          { functionResponse: { name: 'glob', response: { from: '**/*' } } as any },
+          { functionResponse: { name: 'read_file', response: { from: 'b' } } as any },
+          { functionResponse: { name: 'glob', response: { from: '*.ts' } } as any },
+        ],
+      },
+    ];
+
+    const result = GeminiChat.sanitizeRequestContents(input);
+    const frs = result
+      .flatMap(c => c.parts || [])
+      .filter((p: any) => p.functionResponse)
+      .map((p: any) => `${p.functionResponse.name}:${p.functionResponse.response.from}`)
+      .sort();
+    expect(frs).toEqual(['glob:**/*', 'glob:*.ts', 'read_file:a', 'read_file:b']);
+  });
+
+  it('并行调用但 fr 比 fc 少（fc=3 fr=2）：少出来的那个 fc 应触发 cancel 补全', () => {
+    const input: Content[] = [
+      {
+        role: MESSAGE_ROLES.MODEL,
+        parts: [
+          { functionCall: { name: 'read_file', args: { p: 'a' } } as any },
+          { functionCall: { name: 'read_file', args: { p: 'b' } } as any },
+          { functionCall: { name: 'read_file', args: { p: 'c' } } as any },
+        ],
+      },
+      {
+        role: MESSAGE_ROLES.USER,
+        parts: [
+          { functionResponse: { name: 'read_file', response: { from: 'a' } } as any },
+          { functionResponse: { name: 'read_file', response: { from: 'b' } } as any },
+        ],
+      },
+    ];
+
+    const result = GeminiChat.sanitizeRequestContents(input);
+    const fcCount = result.flatMap(c => c.parts || []).filter((p: any) => p.functionCall).length;
+    const frCount = result.flatMap(c => c.parts || []).filter((p: any) => p.functionResponse).length;
+    // 数量必须严格相等（Gemini 400 的判定式）
+    expect(fcCount).toBe(frCount);
+    expect(fcCount).toBe(3);
+
+    // 必有恰好 1 个 cancel 占位（补给那个少出来的 fc），另外 2 个是真实 fr
+    const frs = result.flatMap(c => c.parts || []).filter((p: any) => p.functionResponse);
+    const cancels = frs.filter((p: any) => p.functionResponse.response?.result === 'user cancel');
+    expect(cancels.length).toBe(1);
+  });
+
+  it('单条无 id fc + 单条无 id fr：不触发合成 id 路径，按原 name 模糊匹配（行为零变化）', () => {
+    // 这条防御了 Claude 跨模型迁移场景（commit e5f01a81）
+    const input: Content[] = [
+      {
+        role: MESSAGE_ROLES.MODEL,
+        parts: [{ functionCall: { name: 'glob', args: { pattern: '**/*' } } as any }],
+      },
+      {
+        role: MESSAGE_ROLES.USER,
+        parts: [{ functionResponse: { name: 'glob', response: { ok: true } } as any }],
+      },
+    ];
+
+    const result = GeminiChat.sanitizeRequestContents(input);
+    const fc = result.flatMap(c => c.parts || []).find((p: any) => p.functionCall);
+    const fr = result.flatMap(c => c.parts || []).find((p: any) => p.functionResponse);
+    // 单条无 id 不应该被加合成 id —— 维持原始无 id 状态（兼容现有 Claude 测试期望）
+    expect((fc as any).functionCall.id).toBeUndefined();
+    expect((fr as any).functionResponse.id).toBeUndefined();
+  });
+
+  it('并行同名 fc 已经带 id：完全不走合成 id 路径，原 id 保留', () => {
+    const input: Content[] = [
+      {
+        role: MESSAGE_ROLES.MODEL,
+        parts: [
+          { functionCall: { name: 'read_file', id: 'real-1', args: {} } as any },
+          { functionCall: { name: 'read_file', id: 'real-2', args: {} } as any },
+        ],
+      },
+      {
+        role: MESSAGE_ROLES.USER,
+        parts: [
+          { functionResponse: { name: 'read_file', id: 'real-1', response: {} } as any },
+          { functionResponse: { name: 'read_file', id: 'real-2', response: {} } as any },
+        ],
+      },
+    ];
+
+    const result = GeminiChat.sanitizeRequestContents(input);
+    const fcs = result.flatMap(c => c.parts || []).filter((p: any) => p.functionCall);
+    expect((fcs[0] as any).functionCall.id).toBe('real-1');
+    expect((fcs[1] as any).functionCall.id).toBe('real-2');
+  });
+
+  it('幂等性：并行同名场景下，连续清洗两次结果完全一致', () => {
+    const dirty: Content[] = [
+      {
+        role: MESSAGE_ROLES.MODEL,
+        parts: [
+          { functionCall: { name: 'read_file', args: { p: 'a' } } as any },
+          { functionCall: { name: 'read_file', args: { p: 'b' } } as any },
+        ],
+      },
+      {
+        role: MESSAGE_ROLES.USER,
+        parts: [
+          { functionResponse: { name: 'read_file', response: { from: 'a' } } as any },
+          { functionResponse: { name: 'read_file', response: { from: 'b' } } as any },
+        ],
+      },
+    ];
+
+    // 注意：sanitize 会 mutate 原对象，所以两次必须用各自的深拷贝
+    const once = GeminiChat.sanitizeRequestContents(JSON.parse(JSON.stringify(dirty)));
+    const twice = GeminiChat.sanitizeRequestContents(JSON.parse(JSON.stringify(dirty)));
+    expect(twice).toEqual(once);
+
+    // 把第一次的产出再次清洗，结果也应稳定
+    const onceAgain = GeminiChat.sanitizeRequestContents(JSON.parse(JSON.stringify(once)));
+    expect(onceAgain).toEqual(once);
+  });
+});
