fix(imessage): normalize leading echo-cache corruption bytes

openclaw-clownfish[bot] · openclaw-clownfish[bot] · commit 80b1dd16bf00 · 2026-04-29T00:34:09.000Z
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -13,6 +13,7 @@ Docs: https://docs.openclaw.ai
 
 ### Fixes
 
+- Channels/iMessage: strip only leading imsg replacement/control-byte corruption when matching sent-message echo-cache text, preserving line breaks and interior bytes in a narrow ProjectClownfish repair of #62191. Fixes #41330; refs #59973. Thanks @maguilar631697.
 - Telegram/exec approvals: stop treating general Telegram chat allowlists and `defaultTo` routes as native exec approvers; Telegram now uses explicit `execApprovals.approvers` or owner identity from `commands.ownerAllowFrom`, matching the first-pairing owner bootstrap path. Thanks @pashpashpash.
 - Chat commands: route sensitive group `/diagnostics` and `/export-trajectory` approvals and results to a private owner route, preferring same-surface DMs before falling back to the first configured owner route, so Discord group invocations can land in Telegram when that is the primary owner interface. Thanks @pashpashpash.
 - Plugin SDK/Discord: restore a deprecated `openclaw/plugin-sdk/discord` compatibility facade and the legacy compat group-policy warning export for the published `@openclaw/discord@2026.3.13` package, covering its config, account, directory, status, and thread-binding imports while keeping new plugins on generic SDK subpaths. Fixes #73685; supersedes #73703. Thanks @rderickson9 and @SymbolStar.
diff --git a/extensions/imessage/src/monitor/echo-cache.ts b/extensions/imessage/src/monitor/echo-cache.ts
@@ -23,11 +23,38 @@ export type SentMessageCache = {
 const SENT_MESSAGE_TEXT_TTL_MS = 4_000;
 const SENT_MESSAGE_ID_TTL_MS = 60_000;
 
+function isLeadingImsgEchoCorruptionChar(char: string): boolean {
+  if (char === "\uFFFD") {
+    return true;
+  }
+  const code = char.codePointAt(0);
+  if (code === undefined) {
+    return false;
+  }
+  return (
+    (code >= 0x00 && code <= 0x08) ||
+    (code >= 0x0b && code <= 0x0c) ||
+    (code >= 0x0e && code <= 0x1f) ||
+    (code >= 0x7f && code <= 0x9f)
+  );
+}
+
+function stripLeadingImsgEchoCorruption(text: string): string {
+  let start = 0;
+  for (const char of text) {
+    if (!isLeadingImsgEchoCorruptionChar(char)) {
+      break;
+    }
+    start += char.length;
+  }
+  return start === 0 ? text : text.slice(start);
+}
+
 function normalizeEchoTextKey(text: string | undefined): string | null {
   if (!text) {
     return null;
   }
-  const normalized = text.replace(/\r\n?/g, "\n").trim();
+  const normalized = stripLeadingImsgEchoCorruption(text.replace(/\r\n?/g, "\n").trim()).trim();
   return normalized ? normalized : null;
 }
 
diff --git a/extensions/imessage/src/monitor/monitor-provider.echo-cache.test.ts b/extensions/imessage/src/monitor/monitor-provider.echo-cache.test.ts
@@ -17,6 +17,29 @@ describe("iMessage sent-message echo cache", () => {
     expect(cache.has("acct:imessage:+1666", { text: "Reasoning:\n_step_" })).toBe(false);
   });
 
+  it("matches text with leading imsg replacement and control-byte corruption", () => {
+    vi.useFakeTimers();
+    vi.setSystemTime(new Date("2026-02-25T00:00:00Z"));
+    const cache = createSentMessageCache();
+
+    cache.remember("acct:imessage:+1555", { text: "Delivered reply" });
+
+    expect(cache.has("acct:imessage:+1555", { text: "\uFFFD\u0001Delivered reply" })).toBe(true);
+    expect(cache.has("acct:imessage:+1555", { text: "\u0002Delivered reply" })).toBe(true);
+  });
+
+  it("does not collapse interior replacement bytes, control bytes, tabs, or line breaks", () => {
+    vi.useFakeTimers();
+    vi.setSystemTime(new Date("2026-02-25T00:00:00Z"));
+    const cache = createSentMessageCache();
+    const text = "alpha\n\tbeta\u0001gamma\uFFFDdelta";
+
+    cache.remember("acct:imessage:+1555", { text });
+
+    expect(cache.has("acct:imessage:+1555", { text })).toBe(true);
+    expect(cache.has("acct:imessage:+1555", { text: "alpha betagammadelta" })).toBe(false);
+  });
+
   it("matches by outbound message id and ignores placeholder ids", () => {
     vi.useFakeTimers();
     vi.setSystemTime(new Date("2026-02-25T00:00:00Z"));
