test(server): cover whole replayed ACP thoughts as reasoning

A replayed agent_thought (not only agent_thought_chunk) is now covered by
the snapshot test. The reasoning id set is copied only when a new thought
starts, and the import event id reuses the turn item id.

Co-authored-by: Alan Justino da Silva <155623+alanjds@users.noreply.github.com>
Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>

Author: 3 people

apps/server/src/orchestration-v2/Adapters/AcpAdapterV2.test.ts

@@ -2627,13 +2627,24 @@ describe("AcpAdapterV2", () => {
           content: { type: "text", text: "weighing it" },
         },
       });
+      yield* sessionUpdateHandler!({
+        sessionId: "mock-session-1",
+        update: {
+          sessionUpdate: "agent_thought",
+          messageId: "whole-thought",
+          content: [{ type: "text", text: "settled on it" }],
+        },
+      });
 
       const snapshot = yield* runtime.readThreadSnapshot({ providerThread });
       assert.deepEqual(
         snapshot.messages.map((message) => message.text),
-        ["before plan", "after plan", "weighing it"],
+        ["before plan", "after plan", "weighing it", "settled on it"],
+      );
+      assert.deepEqual(
+        snapshot.reasoningMessageIds,
+        snapshot.messages.slice(2).map((message) => message.id),
       );
-      assert.deepEqual(snapshot.reasoningMessageIds, [snapshot.messages[2]!.id]);
     }).pipe(Effect.provide(layerTest), Effect.scoped),
   );
 

apps/server/src/project/AgentSessionImporter.ts

@@ -140,7 +140,7 @@ function messageEvents(input: {
     updatedAt: at,
   };
   const turnItemEvent = (payload: OrchestrationV2TurnItem): OrchestrationV2DomainEvent => ({
-    id: EventId.make(`${IMPORT_EVENT_PREFIX}:turn-item:${input.threadId}:${suffix}`),
+    id: EventId.make(turnItemId),
     type: "turn-item.updated",
     threadId: input.threadId,
     occurredAt: at,

packages/provider-acp/src/server/adapter.ts

@@ -4554,7 +4554,7 @@ export const makeAcpAdapterV2 = Effect.fn("makeAcpAdapterV2")(function* (
                 order: current.order.includes(key) ? current.order : [...current.order, key],
                 messages,
                 reasoningIds:
-                  role === "thought"
+                  role === "thought" && !current.reasoningIds.has(messageId)
                     ? new Set(current.reasoningIds).add(messageId)
                     : current.reasoningIds,
                 loadingRole: role,