File size: 2,683 Bytes
5cb63c1 | 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 61 62 63 64 65 66 67 68 69 70 71 | import { truncateWithMarker } from "@openclaw/normalization-core/utf16-slice";
/** Name, agent id, and payload text normalization helpers for cron service ops. */
import { normalizeOptionalAgentId } from "../../routing/session-key.js";
import type { CronPayload } from "../types.js";
/** Normalizes a required cron job name and throws the public validation error when absent. */
export function normalizeRequiredName(raw: unknown) {
if (typeof raw !== "string") {
throw new Error("automation name is required");
}
const name = raw.trim();
if (!name) {
throw new Error("automation name is required");
}
return name;
}
function truncateText(input: string, maxLen: number) {
return truncateWithMarker(input, maxLen, { marker: "…", reserve: 1, trimEnd: true });
}
/** Normalizes optional cron agent ids through the canonical session-key agent id rules. */
export { normalizeOptionalAgentId };
/** Infers a compact cron job name from payload text first, then schedule shape. */
export function inferCronJobName(job: {
schedule?: { kind?: unknown; everyMs?: unknown; expr?: unknown };
payload?: { kind?: unknown; text?: unknown; message?: unknown; argv?: unknown };
}) {
const text =
job?.payload?.kind === "systemEvent" && typeof job.payload.text === "string"
? job.payload.text
: job?.payload?.kind === "agentTurn" && typeof job.payload.message === "string"
? job.payload.message
: job?.payload?.kind === "command" && Array.isArray(job.payload.argv)
? job.payload.argv.join(" ")
: "";
const firstLine =
text
.split("\n")
.map((l) => l.trim())
.find(Boolean) ?? "";
if (firstLine) {
// Names appear in CLI lists and alerts; keep them single-line and UTF-16
// safe so emoji/surrogate pairs are not split by truncation.
return truncateText(firstLine, 60);
}
const kind = typeof job?.schedule?.kind === "string" ? job.schedule.kind : "";
if (kind === "cron" && typeof job?.schedule?.expr === "string") {
return `Cron: ${truncateText(job.schedule.expr, 52)}`;
}
if (kind === "every" && typeof job?.schedule?.everyMs === "number") {
return `Every: ${job.schedule.everyMs}ms`;
}
if (kind === "at") {
return "One-shot";
}
return "Automation";
}
/** Extracts the executable text from cron payload variants for main-session queueing. */
export function normalizePayloadToSystemText(payload: CronPayload) {
if (payload.kind === "systemEvent") {
return typeof payload.text === "string" ? payload.text.trim() : "";
}
return payload.kind === "agentTurn" && typeof payload.message === "string"
? payload.message.trim()
: "";
}
|