53 lines
1.5 KiB
TypeScript
53 lines
1.5 KiB
TypeScript
export type ProviderId = "discord" | "telegram" | "whatsapp";
|
|
export type ProviderDirection = "inbound" | "outbound";
|
|
|
|
type ActivityEntry = {
|
|
inboundAt: number | null;
|
|
outboundAt: number | null;
|
|
};
|
|
|
|
const activity = new Map<string, ActivityEntry>();
|
|
|
|
function keyFor(provider: ProviderId, accountId: string) {
|
|
return `${provider}:${accountId || "default"}`;
|
|
}
|
|
|
|
function ensureEntry(provider: ProviderId, accountId: string): ActivityEntry {
|
|
const key = keyFor(provider, accountId);
|
|
const existing = activity.get(key);
|
|
if (existing) return existing;
|
|
const created: ActivityEntry = { inboundAt: null, outboundAt: null };
|
|
activity.set(key, created);
|
|
return created;
|
|
}
|
|
|
|
export function recordProviderActivity(params: {
|
|
provider: ProviderId;
|
|
accountId?: string | null;
|
|
direction: ProviderDirection;
|
|
at?: number;
|
|
}) {
|
|
const at = typeof params.at === "number" ? params.at : Date.now();
|
|
const accountId = params.accountId?.trim() || "default";
|
|
const entry = ensureEntry(params.provider, accountId);
|
|
if (params.direction === "inbound") entry.inboundAt = at;
|
|
if (params.direction === "outbound") entry.outboundAt = at;
|
|
}
|
|
|
|
export function getProviderActivity(params: {
|
|
provider: ProviderId;
|
|
accountId?: string | null;
|
|
}): ActivityEntry {
|
|
const accountId = params.accountId?.trim() || "default";
|
|
return (
|
|
activity.get(keyFor(params.provider, accountId)) ?? {
|
|
inboundAt: null,
|
|
outboundAt: null,
|
|
}
|
|
);
|
|
}
|
|
|
|
export function resetProviderActivityForTest() {
|
|
activity.clear();
|
|
}
|