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 {

asDateTimestampMs,

parseStrictFiniteNumber,

resolveExpiresAtMsFromDurationMs,

} 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 resolveGroupMetadataExpiresAt(nowRaw = Date.now()): number | undefined {

const now = asDateTimestampMs(nowRaw);

return now === undefined

? undefined

: resolveExpiresAtMsFromDurationMs(GROUP_META_TTL_MS, { nowMs: now });

}

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

if (value == null) {

return undefined;

jid: string,

entry: T,

): void {

if (asDateTimestampMs(entry.expires) === undefined) {

cache.delete(jid);

return;

}

if (cache.has(jid)) {

cache.delete(jid);

}

if (!entry) {

return null;

}

if (entry.expires <= Date.now()) {

const now = asDateTimestampMs(Date.now());

const expires = asDateTimestampMs(entry.expires);

if (now === undefined || expires === undefined || expires <= now) {

cache.delete(jid);

return null;

}

subject: meta.subject,

participants,

mentionParticipants,

expires: Date.now() + GROUP_META_TTL_MS,

expires: resolveGroupMetadataExpiresAt() ?? 0,

};

};

const summarizeGroupMetaForReconnectCache = (

meta: GroupMetadata,

): WhatsAppGroupMetadataCacheEntry => ({

subject: meta.subject,

expires: Date.now() + GROUP_META_TTL_MS,

expires: resolveGroupMetadataExpiresAt() ?? Number.NaN,

});

const getGroupMeta = async (jid: string) => {

options.verbose,

`Failed to fetch group metadata for ${jid}: ${String(err)}`,

);

return { expires: Date.now() + GROUP_META_TTL_MS };

return { expires: resolveGroupMetadataExpiresAt() ?? 0 };

}

};

await listener.close();

});

it("does not keep reconnect group metadata when the expiry would exceed a valid Date", async () => {

const groupMetadataCache: NonNullable<InboxMonitorOptions["groupMetadataCache"]> = new Map();

const dateNow = vi.spyOn(Date, "now").mockReturnValue(8_640_000_000_000_000);

try {

const sock = getSock();

sock.groupFetchAllParticipating.mockResolvedValueOnce({

"123@g.us": {

id: "123@g.us",

subject: "Boundary Group",

owner: undefined,

participants: [],

},

});

const { listener } = await startInboxMonitor(vi.fn(async () => {}) as InboxOnMessage, {

groupMetadataCache,

});

await vi.waitFor(() => {

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

});

expect(groupMetadataCache.has("123@g.us")).toBe(false);

await listener.close();

} finally {

dateNow.mockRestore();

}

});

it("does not block inbound listeners while group hydration is pending", async () => {

let resolveHydration!: () => void;

const sock = getSock();