vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-03-12 07:20:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

Reply: share queued message dedupe state

Browse Source
This commit is contained in:
Vincent Koc
2026-03-11 19:50:06 -04:00
parent 412818bbaf
commit 6ab0f0e1f7
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/auto-reply/reply/queue/enqueue.ts
View File

@@ -4,10 +4,17 @@ import { kickFollowupDrainIfIdle } from "./drain.js";
import { getExistingFollowupQueue, getFollowupQueue } from "./state.js"; import { getExistingFollowupQueue, getFollowupQueue } from "./state.js";
import type { FollowupRun, QueueDedupeMode, QueueSettings } from "./types.js"; import type { FollowupRun, QueueDedupeMode, QueueSettings } from "./types.js";
const RECENT_QUEUE_MESSAGE_IDS = createDedupeCache({ /**
* Keep queued message-id dedupe shared across bundled chunks so redeliveries
* are rejected no matter which chunk receives the enqueue call.
*/
const _g = globalThis as typeof globalThis & {
__openclaw_recent_queue_message_ids__?: ReturnType<typeof createDedupeCache>;
};
const RECENT_QUEUE_MESSAGE_IDS = (_g.__openclaw_recent_queue_message_ids__ ??= createDedupeCache({
ttlMs: 5 * 60 * 1000, ttlMs: 5 * 60 * 1000,
maxSize: 10_000, maxSize: 10_000,
}); }));
function buildRecentMessageIdKey(run: FollowupRun, queueKey: string): string | undefined { function buildRecentMessageIdKey(run: FollowupRun, queueKey: string): string | undefined {
const messageId = run.messageId?.trim(); const messageId = run.messageId?.trim();