import {

asDateTimestampMs,

resolveExpiresAtMsFromDurationMs,

} from "openclaw/plugin-sdk/number-runtime";

import type { ClawdbotConfig, RuntimeEnv } from "../runtime-api.js";

import { resolveFeishuRuntimeAccount } from "./accounts.js";

import { handleFeishuMessage, type FeishuMessageEvent } from "./bot.js";

export function resetProcessedFeishuCardActionTokensForTests(): void {

processedCardActionTokens.clear();

resolvedChatTypeCache.clear();

}

function pruneProcessedCardActionTokens(now: number): void {

const CHAT_TYPE_CACHE_MAX_SIZE = 5_000;

function pruneChatTypeCache(now: number): void {

const validNow = asDateTimestampMs(now);

if (validNow === undefined) {

resolvedChatTypeCache.clear();

return;

}

for (const [key, entry] of resolvedChatTypeCache.entries()) {

if (entry.expiresAt <= now) {

const expiresAt = asDateTimestampMs(entry.expiresAt);

if (expiresAt === undefined || expiresAt <= validNow) {

resolvedChatTypeCache.delete(key);

}

}

return v.replace(/[\r\n]/g, " ").slice(0, 500);

}

function cacheResolvedCardActionChatType(

cacheKey: string,

value: "p2p" | "group",

now: number,

): void {

const expiresAt = resolveExpiresAtMsFromDurationMs(CHAT_TYPE_CACHE_TTL_MS, { nowMs: now });

resolvedChatTypeCache.delete(cacheKey);

if (expiresAt !== undefined) {

resolvedChatTypeCache.set(cacheKey, { value, expiresAt });

}

}

async function resolveCardActionChatType(params: {

event: FeishuCardActionEvent;

account: ReturnType<typeof resolveFeishuRuntimeAccount>;

const now = Date.now();

pruneChatTypeCache(now);

const cached = resolvedChatTypeCache.get(cacheKey);

if (cached) {

const cachedExpiresAt = cached ? asDateTimestampMs(cached.expiresAt) : undefined;

if (cached && cachedExpiresAt !== undefined) {

return cached.value;

}

if (cached) {

resolvedChatTypeCache.delete(cacheKey);

}

try {

const response = (await createFeishuClient(params.account).im.chat.get({

normalizeResolvedCardActionChatType(response.data?.chat_mode) ??

normalizeResolvedCardActionChatType(response.data?.chat_type);

if (resolvedChatType) {

resolvedChatTypeCache.set(cacheKey, {

value: resolvedChatType,

expiresAt: now + CHAT_TYPE_CACHE_TTL_MS,

});

cacheResolvedCardActionChatType(cacheKey, resolvedChatType, now);

return resolvedChatType;

}

params.log(