executeSqliteQueryTakeFirstSync,

getNodeSqliteKysely,

} from "../../infra/kysely-sync.js";

import { normalizeSqliteNumber } from "../../infra/sqlite-number.js";

import type { DB as OpenClawStateKyselyDatabase } from "../../state/openclaw-state-db.generated.js";

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

import type { CronDeliveryStatus, CronRunStatus } from "../types.js";

return getNodeSqliteKysely<CronRunLogDatabase>(db);

}

function normalizeNumber(value: number | bigint | null): number | undefined {

if (typeof value === "bigint") {

return Number(value);

}

return typeof value === "number" ? value : undefined;

}

function booleanToInteger(value: boolean | undefined): number | null {

return typeof value === "boolean" ? (value ? 1 : 0) : null;

}

function integerToBoolean(value: number | bigint | null): boolean | undefined {

const normalized = normalizeNumber(value);

const normalized = normalizeSqliteNumber(value);

return normalized == null ? undefined : normalized !== 0;

}

}

return {

...parsed,

ts: normalizeNumber(row.ts) ?? parsed.ts,

ts: normalizeSqliteNumber(row.ts) ?? parsed.ts,

jobId: row.job_id,

status: (row.status as CronRunStatus | null) ?? parsed.status,

error: row.error ?? parsed.error,

sessionId: row.session_id ?? parsed.sessionId,

sessionKey: row.session_key ?? parsed.sessionKey,

runId: row.run_id ?? parsed.runId,

runAtMs: normalizeNumber(row.run_at_ms) ?? parsed.runAtMs,

durationMs: normalizeNumber(row.duration_ms) ?? parsed.durationMs,

nextRunAtMs: normalizeNumber(row.next_run_at_ms) ?? parsed.nextRunAtMs,

runAtMs: normalizeSqliteNumber(row.run_at_ms) ?? parsed.runAtMs,

durationMs: normalizeSqliteNumber(row.duration_ms) ?? parsed.durationMs,

nextRunAtMs: normalizeSqliteNumber(row.next_run_at_ms) ?? parsed.nextRunAtMs,

model: row.model ?? parsed.model,

provider: row.provider ?? parsed.provider,

};

params,

),

);

return normalizeNumber(row?.count ?? null) ?? 0;

return normalizeSqliteNumber(row?.count ?? null) ?? 0;

}

/** Reads a sorted, filtered page of cron run-log rows. */

.where("store_key", "=", storeKey)

.where("job_id", "=", jobId),

);

return (normalizeNumber(row?.seq ?? null) ?? 0) + 1;

return (normalizeSqliteNumber(row?.seq ?? null) ?? 0) + 1;

}

/** Appends a cron run-log entry with a per-job monotonic sequence number. */