// Imessage plugin module implements echo cache behavior.

import { stripLeadingEchoTextCorruptionMarkers } from "./echo-text-corruption.js";

import { hasPersistedIMessageEcho } from "./persisted-echo-cache.js";

type SentMessageLookup = {

const SENT_MESSAGE_TEXT_TTL_MS = 4_000;

const SENT_MESSAGE_ID_TTL_MS = 60_000;

function isLeadingEchoTextCorruptionMarker(code: number): boolean {

return (

code === 0x0000 || code === 0xfeff || code === 0xfffd || code === 0xfffe || code === 0xffff

);

}

function stripLeadingEchoTextCorruptionMarkers(text: string): string {

let offset = 0;

while (offset < text.length && isLeadingEchoTextCorruptionMarker(text.charCodeAt(offset))) {

offset += 1;

}

return offset === 0 ? text : text.slice(offset);

}

function normalizeEchoTextKey(text: string | undefined): string | null {

if (!text) {

return null;

// Imessage plugin shared helper: strip leading attributedBody corruption markers from echo text.

// The in-memory (echo-cache) and persisted (persisted-echo-cache) echo-dedupe paths must normalize

// identically, so a reflected own-message echo whose attributedBody decoded with a leading

// NUL/replacement marker still matches the clean stored send. Kept here (a leaf module with no

// imports) so the persisted path can reuse it without an echo-cache <-> persisted-echo-cache cycle.

function isLeadingEchoTextCorruptionMarker(code: number): boolean {

return (

code === 0x0000 || code === 0xfeff || code === 0xfffd || code === 0xfffe || code === 0xffff

);

}

export function stripLeadingEchoTextCorruptionMarkers(text: string): string {

let offset = 0;

while (offset < text.length && isLeadingEchoTextCorruptionMarker(text.charCodeAt(offset))) {

offset += 1;

}

return offset === 0 ? text : text.slice(offset);

}

expect(cache.has("acct:imessage:+1555", { text: "Delayed\u0000echo reply" })).toBe(false);

});

it("matches a delayed reflected echo with leading corruption markers via the persisted cache", () => {

// The persisted 12h cache is the only matcher once the 4s in-memory text TTL expires, so it

// must strip leading attributedBody corruption markers exactly like the in-memory key (#93511).

const scope = "acct:imessage:+1555";

const markers = String.fromCharCode(0x0000, 0xfffd, 0xfffe, 0xffff, 0xfeff);

rememberPersistedIMessageEcho({ scope, text: "Delayed echo reply" });

expect(hasPersistedIMessageEcho({ scope, text: "Delayed echo reply" })).toBe(true);

expect(hasPersistedIMessageEcho({ scope, text: `${markers}Delayed echo reply` })).toBe(true);

// Leading-only: a mid-string marker stays distinct.

expect(

hasPersistedIMessageEcho({ scope, text: `Delayed${String.fromCharCode(0x0000)}echo reply` }),

).toBe(false);

});

it("matches by outbound message id and ignores placeholder ids", () => {

vi.useFakeTimers();

vi.setSystemTime(new Date("2026-02-25T00:00:00Z"));

import type { PluginStateSyncKeyedStore } from "openclaw/plugin-sdk/plugin-state-runtime";

import { logVerbose } from "openclaw/plugin-sdk/runtime-env";

import { getIMessageRuntime } from "../runtime.js";

import { stripLeadingEchoTextCorruptionMarkers } from "./echo-text-corruption.js";

type PersistedEchoEntry = {

scope: string;

type PersistedEchoStore = PluginStateSyncKeyedStore<PersistedEchoEntry>;

function normalizeText(text: string | undefined): string | undefined {

const normalized = text?.replace(/\r\n?/g, "\n").trim();

if (!text) {

return undefined;

}

// Match the in-memory echo-cache key so a reflected echo with a leading attributedBody

// corruption marker still matches the clean stored send (the persisted sibling of #93511).

const normalized = stripLeadingEchoTextCorruptionMarkers(

text.replace(/\r\n?/g, "\n").trim(),

).trim();

return normalized || undefined;

}