File size: 2,019 Bytes
4440aec | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 | // Normalizes queue config values from user and persisted settings.
import { normalizeOptionalLowercaseString } from "@openclaw/normalization-core/string-coerce";
import type { QueueMode } from "../../../../packages/gateway-protocol/src/schema/logs-chat.js";
import type { QueueDropPolicy } from "./types.js";
/** Normalizes user-entered queue mode aliases from directives/config. */
export function normalizeQueueMode(raw?: string): QueueMode | undefined {
const cleaned = normalizeOptionalLowercaseString(raw);
if (!cleaned) {
return undefined;
}
if (cleaned === "interrupt" || cleaned === "interrupts" || cleaned === "abort") {
return "interrupt";
}
if (cleaned === "steer" || cleaned === "steering") {
return "steer";
}
if (cleaned === "followup" || cleaned === "follow-ups" || cleaned === "followups") {
return "followup";
}
if (cleaned === "collect" || cleaned === "coalesce") {
return "collect";
}
return undefined;
}
/** Normalizes persisted legacy queue mode aliases into current queue modes. */
export function normalizePersistedQueueMode(raw?: string): QueueMode | undefined {
const normalized = normalizeQueueMode(raw);
if (normalized) {
return normalized;
}
const cleaned = normalizeOptionalLowercaseString(raw);
if (cleaned === "queue" || cleaned === "queued") {
return "steer";
}
if (cleaned === "steer+backlog" || cleaned === "steer-backlog" || cleaned === "steer_backlog") {
return "followup";
}
return undefined;
}
/** Normalizes queue drop policy aliases from directives/config. */
export function normalizeQueueDropPolicy(raw?: string): QueueDropPolicy | undefined {
const cleaned = normalizeOptionalLowercaseString(raw);
if (!cleaned) {
return undefined;
}
if (cleaned === "old" || cleaned === "oldest") {
return "old";
}
if (cleaned === "new" || cleaned === "newest") {
return "new";
}
if (cleaned === "summarize" || cleaned === "summary") {
return "summarize";
}
return undefined;
}
|