/** Mutates and persists isolated cron session state around one run. */

import fs from "node:fs";

import type { LiveSessionModelSelection } from "../../agents/live-model-switch.js";

import type { SessionEntry } from "../../config/sessions.js";

/** Repairs legacy cron job identity fields into the canonical id shape. */

import { normalizeOptionalString } from "@openclaw/normalization-core/string-coerce";

/** Normalizes mutable cron job rows from old `jobId` storage into the canonical `id` field. */

/** Normalizes cron create/patch payloads before validation and persistence. */

import { timestampMsToIsoString } from "@openclaw/normalization-core/number-coercion";

import {

normalizeLowercaseStringOrEmpty,

delete next.accountId;

}

if ("failureDestination" in next) {

// Null is an explicit clear signal in patches; invalid objects are dropped.

if (next.failureDestination === null) {

next.failureDestination = null;

} else if (isRecord(next.failureDestination)) {

}

}

if ("completionDestination" in next) {

// Completion destinations are currently webhook-only, so other shapes are

// discarded before they can persist as ambiguous config.

if (next.completionDestination === null) {

next.completionDestination = null;

} else {

}

if (options.applyDefaults) {

// Defaults apply only on create; patch normalization must preserve omitted

// fields so partial updates do not rewrite unrelated cron settings.

if (!next.wakeMode) {

next.wakeMode = "now";

}

/** Parses cron schedule timestamps from user-facing absolute time strings. */

import { parseStrictPositiveInteger } from "../infra/parse-finite-number.js";

const ISO_TZ_RE = /(Z|[+-]\d{2}:?\d{2})$/i;

/** Validates persisted cron job records before loading them from disk/state. */

import { parseAbsoluteTimeMs } from "./parse.js";

/** Structural rejection code for persisted cron jobs that cannot be loaded safely. */

/** Classifies cron run failures for retry policy decisions. */

import type { CronRetryOn } from "../config/types.cron.js";

/** Cron retry classifier output consumed by scheduler retry policy. */

/** Builds bounded, redacted diagnostics for cron run logs and UI surfaces. */

import { normalizeOptionalString } from "@openclaw/normalization-core/string-coerce";

import { getReplyPayloadMetadata } from "../auto-reply/reply-payload.js";

import { redactSensitiveText } from "../logging/redact.js";

/** Legacy JSONL run-log parser used during migrations/imports. */

import type { CronRunLogEntry } from "./run-log-types.js";

import { parseCronRunLogEntryObject } from "./run-log/entry-codec.js";

/** Shared cron run-log entry shape for SQLite and legacy JSONL stores. */

import type { FailoverReason } from "../agents/embedded-agent-helpers/types.js";

import type {

CronDeliveryStatus,

/** Public cron run-log API with serialized writes and paged reads. */

import {

normalizeLowercaseStringOrEmpty,

normalizeOptionalString,

const offset = Math.max(0, Math.floor(opts.offset ?? 0));

if (!query) {

// Without a text query SQLite can page directly; query mode filters in JS

// because diagnostics and derived job names are not all indexed columns.

const total = countCronRunLogRows({

db,

storeKey,