fix(agents): preserve source reply idempotency

giodl73-repo · giodl73-repo · commit 742faf1dd124 · 2026-05-22T21:01:53.000-07:00
diff --git a/src/agents/pi-embedded-subscribe.handlers.tools.test.ts b/src/agents/pi-embedded-subscribe.handlers.tools.test.ts
@@ -1429,6 +1429,7 @@ describe("messaging tool media URL tracking", () => {
           status: "ok",
           deliveryStatus: "sent",
           sourceReplySink: "internal-ui",
+          idempotencyKey: "stable-source-reply",
           sourceReply: {
             text: "visible in tui",
             mediaUrls: ["file:///tmp/reply.png"],
@@ -1444,6 +1445,7 @@ describe("messaging tool media URL tracking", () => {
         text: "visible in tui",
         mediaUrls: ["file:///tmp/reply.png"],
         channelData: { source: "tui" },
+        idempotencyKey: "stable-source-reply",
       },
     ]);
   });
diff --git a/src/agents/pi-embedded-subscribe.handlers.tools.ts b/src/agents/pi-embedded-subscribe.handlers.tools.ts
@@ -500,6 +500,11 @@ function extractMessagingToolSourceReplyPayload(
   if (channelData) {
     payload.channelData = channelData;
   }
+  const idempotencyKey =
+    readStringField(sourceReply, "idempotencyKey") ?? readStringField(details, "idempotencyKey");
+  if (idempotencyKey) {
+    payload.idempotencyKey = idempotencyKey;
+  }
   return Object.keys(payload).length > 0 ? payload : undefined;
 }
 

Original file line number	Diff line number	Diff line change
`@@ -500,6 +500,11 @@ function extractMessagingToolSourceReplyPayload(`
`500`	`500`	`if (channelData) {`
`501`	`501`	`payload.channelData = channelData;`
`502`	`502`	`}`
	`503`	`+ const idempotencyKey =`
	`504`	`+ readStringField(sourceReply, "idempotencyKey") ?? readStringField(details, "idempotencyKey");`
	`505`	`+ if (idempotencyKey) {`
	`506`	`+ payload.idempotencyKey = idempotencyKey;`
	`507`	`+ }`
`503`	`508`	`return Object.keys(payload).length > 0 ? payload : undefined;`
`504`	`509`	`}`
`505`	`510`