fix(studio): keep ADK stream chunks that share event ids

frontend/src/blocks.ts

@@ -1132,16 +1132,20 @@ export function createAssistantEventProjector(
           ignored: true,
         };
       }
-      if (ev.id && seenEventIds.has(ev.id)) {
+      // ADK streams content chunks under the id of their consolidated event, so
+      // only complete events and content-free partials (e.g. A2A status) dedupe.
+      const streamedChunk = ev.partial === true && Boolean(ev.content?.parts?.length);
+      const dedupeId = streamedChunk ? undefined : ev.id;
+      if (dedupeId && seenEventIds.has(dedupeId)) {
         return {
           turn: { role: "assistant", blocks: [] },
           completed: false,
           ignored: true,
         };
       }
-      if (ev.id) {
-        seenEventIds.add(ev.id);
-        eventIdOrder.push(ev.id);
+      if (dedupeId) {
+        seenEventIds.add(dedupeId);
+        eventIdOrder.push(dedupeId);
         if (eventIdOrder.length > MAX_SEEN_EVENT_IDS) {
           seenEventIds.delete(eventIdOrder.shift()!);
         }

frontend/tests/parallelStreamAggregation.test.mjs

@@ -537,3 +537,32 @@ test("closes the live sandbox task from its finalAlreadyEmitted wrapper response
   assert.equal(transportFinished.meta.localId, turns[0].meta.localId);
   assert.equal(transportFinished.meta.streaming, false);
 });
+
+test("keeps ADK streaming chunks that share the final event id", () => {
+  // ADK 2 gives every partial chunk of one model response the same id as its
+  // consolidated final event; only a replayed final event is a duplicate.
+  const projector = createAssistantEventProjector("adk-shared-id");
+  let turns = [];
+  for (const text of ["用户", "问", "你好"]) {
+    const result = projector.project(event("agent", text, { id: "shared-1" }));
+    assert.notEqual(result.ignored, true);
+    turns = upsertProjectedAssistantTurn(turns, result.turn);
+  }
+  assert.equal(blockText(turns[0], "text"), "用户问你好");
+
+  const final = projector.project(event("agent", "完整答案", {
+    partial: false,
+    id: "shared-1",
+  }));
+  assert.notEqual(final.ignored, true);
+  turns = upsertProjectedAssistantTurn(turns, final.turn);
+  assert.equal(turns.length, 1);
+  assert.equal(blockText(turns[0], "text"), "完整答案");
+  assert.equal(turns[0].meta.streaming, false);
+
+  const replayed = projector.project(event("agent", "完整答案", {
+    partial: false,
+    id: "shared-1",
+  }));
+  assert.equal(replayed.ignored, true);
+});

veadk/webui/assets/chunks/channel-XWr5Vfax.js → veadk/webui/assets/chunks/channel-Dnp9flxZ.js

@@ -1 +1 @@
-import{U as a,C as n}from"../visualizations/mermaid/mermaid.core-CVx1WIOc.js";const t=(r,o)=>a.lang.round(n.parse(r)[o]);export{t as c};
+import{U as a,C as n}from"../visualizations/mermaid/mermaid.core-DxEtHRGv.js";const t=(r,o)=>a.lang.round(n.parse(r)[o]);export{t as c};