src/auto-reply/reply/queue/recent-message-ids.ts

// Recent-queue message-id dedupe shared by enqueue admission and abandonment release.
import { resolveGlobalDedupeCache } from "../../../infra/dedupe.js";
import type { TurnAdoptionLifecycle } from "../../get-reply-options.types.js";

const RECENT_QUEUE_MESSAGE_ID_TTL_MS = 5 * 60 * 1000;
const RECENT_QUEUE_MESSAGE_ID_MAX_SIZE = 10_000;

/**
 * Keep queued message-id dedupe shared across bundled chunks so redeliveries
 * are rejected no matter which chunk receives the enqueue call.
 */
const RECENT_QUEUE_MESSAGE_IDS = resolveGlobalDedupeCache(
  Symbol.for("openclaw.recentQueueMessageIdOwners"),
  {
    ttlMs: RECENT_QUEUE_MESSAGE_ID_TTL_MS,
    maxSize: RECENT_QUEUE_MESSAGE_ID_MAX_SIZE,
  },
);

export function peekRecentQueueMessageId(key: string, now = Date.now()): boolean {
  return RECENT_QUEUE_MESSAGE_IDS.peek(key, now);
}

export function recordRecentQueueMessageId(
  run: { turnAdoptionLifecycle?: TurnAdoptionLifecycle },
  key: string,
  now = Date.now(),
): void {
  const ownerToken = {};
  RECENT_QUEUE_MESSAGE_IDS.delete(key);
  RECENT_QUEUE_MESSAGE_IDS.check(key, now, ownerToken);
  const lifecycle = run.turnAdoptionLifecycle;
  if (lifecycle) {
    const onAbandoned = lifecycle.onAbandoned;
    lifecycle.onAbandoned = () => {
      // Lifecycle callbacks survive summary cloning. Free only this entry before retry.
      RECENT_QUEUE_MESSAGE_IDS.delete(key, ownerToken);
      onAbandoned?.();
    };
  }
}

export function resetRecentQueuedMessageIdDedupe(): void {
  RECENT_QUEUE_MESSAGE_IDS.clear();
}