import { formatLocationText } from "openclaw/plugin-sdk/channel-inbound";

import { createInboundDebouncer } from "openclaw/plugin-sdk/channel-inbound-debounce";

import { getChildLogger } from "openclaw/plugin-sdk/logging-core";

import { parseStrictFiniteNumber } from "openclaw/plugin-sdk/number-runtime";

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

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

import { uniqueStrings } from "openclaw/plugin-sdk/string-coerce-runtime";

mentionParticipants?: WhatsAppOutboundMentionParticipant[];

};

function parseWhatsAppTimestampSeconds(value: unknown): number | undefined {

if (value == null) {

return undefined;

}

if (typeof value === "string") {

return parseStrictFiniteNumber(value);

}

const parsed = Number(value);

return Number.isFinite(parsed) ? parsed : undefined;

}

function rememberGroupMetadataCacheEntry<T extends WhatsAppGroupMetadataCacheEntry>(

cache: Map<string, T>,

jid: string,

groupSubject = meta.subject;

groupParticipants = meta.participants;

}

const messageTimestampMs = msg.messageTimestamp

? Number(msg.messageTimestamp) * 1000

: undefined;

const messageTimestampSeconds = parseWhatsAppTimestampSeconds(msg.messageTimestamp);

const messageTimestampMs =

messageTimestampSeconds !== undefined ? messageTimestampSeconds * 1000 : undefined;

const accessCfg = options.loadConfig?.() ?? options.cfg;

const access = await checkInboundAccessControl({

return false;

}

const APPEND_RECENT_GRACE_MS = 60_000;

const msgTsRaw = msg.messageTimestamp;

const msgTsNum = msgTsRaw != null ? Number(msgTsRaw) : Number.NaN;

const msgTsMs = Number.isFinite(msgTsNum) ? msgTsNum * 1000 : 0;

const msgTsSeconds = parseWhatsAppTimestampSeconds(msg.messageTimestamp);

const msgTsMs = msgTsSeconds !== undefined ? msgTsSeconds * 1000 : 0;

return msgTsMs < connectedAtMs - APPEND_RECENT_GRACE_MS;

};

await listener.close();

});

it("still sends pairing replies when live DMs have null timestamps", async () => {

mockLoadConfig.mockReturnValue({});

upsertPairingRequestMock.mockResolvedValueOnce({ code: "PAIRCODE", created: true });

const { onMessage, listener, sock } = await openInboxMonitor();

const upsertBlocked = buildNotifyMessageUpsert({

id: "no-config-null-ts",

remoteJid: "999@s.whatsapp.net",

text: "ping",

timestamp: null as never,

});

sock.ev.emit("messages.upsert", upsertBlocked);

await vi.waitFor(

() => {

expect(sock.sendMessage).toHaveBeenCalledTimes(1);

},

{ timeout: 5_000, interval: 5 },

);

expect(onMessage).not.toHaveBeenCalled();

expectPairingPromptSent(sock, "999@s.whatsapp.net", "+999");

await listener.close();

});

it("skips pairing replies for outbound DMs in same-phone mode", async () => {

await expectOutboundDmSkipsPairing({

selfChatMode: true,

await listener.close();

});

it("skips append messages with non-decimal string timestamps", async () => {

const onMessage = vi.fn(async () => {});

const { listener, sock } = await startInboxMonitor(onMessage);

const recentTs = Math.floor(Date.now() / 1000) - 5;

sock.ev.emit("messages.upsert", {

type: "append",

messages: [

{

key: { id: "hex-1", fromMe: false, remoteJid: "120363@g.us" },

message: { conversation: "hex timestamp" },

messageTimestamp: `0x${recentTs.toString(16)}`,

pushName: "HexTs",

},

],

});

await settleInboundWork();

expect(onMessage).not.toHaveBeenCalled();

await listener.close();

});

it("handles Long-like protobuf timestamps correctly", async () => {

const onMessage = vi.fn(async () => {});

const { listener, sock } = await startInboxMonitor(onMessage);