fix: clear cross-run messaging-tool sent-text state after every compaction

jet · jet · commit a071872c35ac · 2026-05-18T02:07:31.000+08:00
When a run completes and the session compacts, the arrays tracking
texts sent via messaging tools (message(action=send), sessions_send,
etc.) were only cleared on compaction retries (willRetry=true).
On normal compaction (willRetry=false), stale entries survived into
the next run, where isMessagingToolDuplicateNormalized() could
false-positive on the new run's final reply text — silently dropping
legitimate block replies.

Clear messagingToolSentTexts, messagingToolSentTextsNormalized,
messagingToolSentTargets, and messagingToolSentMediaUrls
unconditionally at every compaction_end so the next run always
starts with a clean slate.

Co-Authored-By: Cha &lt;cha@jetd.one&gt; via OpenClaw
diff --git a/src/agents/pi-embedded-subscribe.handlers.compaction.test.ts b/src/agents/pi-embedded-subscribe.handlers.compaction.test.ts
@@ -36,6 +36,10 @@ function createCompactionContext(params: {
     state: {
       compactionInFlight: true,
       pendingCompactionRetry: 0,
+      messagingToolSentTexts: [],
+      messagingToolSentTextsNormalized: [],
+      messagingToolSentTargets: [],
+      messagingToolSentMediaUrls: [],
     } as never,
     log: {
       debug: vi.fn(),
diff --git a/src/agents/pi-embedded-subscribe.handlers.compaction.ts b/src/agents/pi-embedded-subscribe.handlers.compaction.ts
@@ -81,6 +81,16 @@ export function handleCompactionEnd(ctx: EmbeddedPiSubscribeContext, evt: Compac
   const reason = normalizeCompactionReason(evt.reason);
   const kind = compactionLogKind(reason);
   ctx.state.compactionInFlight = false;
+  // After every compaction (retry or not), discard messaging-tool sent-text
+  // tracking from the completed run.  Without this, stale entries survive
+  // into the next run and cause `isMessagingToolDuplicateNormalized` to
+  // false-positive on block-reply dedup — silently dropping legitimate
+  // final replies when a previous run called `message(action=send)` or
+  // `sessions_send` and the new text shares a normalized substring.
+  ctx.state.messagingToolSentTexts.length = 0;
+  ctx.state.messagingToolSentTextsNormalized.length = 0;
+  ctx.state.messagingToolSentTargets.length = 0;
+  ctx.state.messagingToolSentMediaUrls.length = 0;
   const willRetry = Boolean(evt.willRetry);
   // Increment counter whenever compaction actually produced a result,
   // regardless of willRetry.  Overflow-triggered compaction sets willRetry=true
