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 followup queue runtime state

Browse Source
This commit is contained in:
Vincent Koc
2026-03-11 19:49:49 -04:00
parent a744a48a0d
commit 1a5794f65a
1 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/auto-reply/reply/queue/state.ts
View File

@@ -18,7 +18,17 @@ export const DEFAULT_QUEUE_DEBOUNCE_MS = 1000;
export const DEFAULT_QUEUE_CAP = 20;
export const DEFAULT_QUEUE_DROP: QueueDropPolicy = "summarize";
export const FOLLOWUP_QUEUES = new Map<string, FollowupQueueState>();
/**
* Share followup queues across bundled chunks so busy-session enqueue/drain
* logic observes one queue registry per process.
*/
const _g = globalThis as typeof globalThis & {
__openclaw_followup_queues__?: Map<string, FollowupQueueState>;
};
export const FOLLOWUP_QUEUES = (_g.__openclaw_followup_queues__ ??= new Map<
string,
FollowupQueueState
>());
export function getExistingFollowupQueue(key: string): FollowupQueueState | undefined {
const cleaned = key.trim();