| import type { SqliteWorkerReply } from "../../infra/sqlite-worker-contract.js"; |
| import { |
| encodeOpenClawStateWorkerError, |
| hydrateOpenClawStateWorkerError, |
| retainOpenClawStateWorkerErrorPayload, |
| } from "../../state/openclaw-state-worker-error.js"; |
|
|
| type CronLoadError = Extract<SqliteWorkerReply, { ok: false }>["error"]; |
|
|
| export function serializeCronLoadError(value: unknown): CronLoadError { |
| const error = value instanceof Error ? value : new Error(String(value)); |
| const code = "code" in error ? error.code : undefined; |
| const sharedState = encodeOpenClawStateWorkerError(error, { includeOrdinary: true }); |
| return { |
| name: error.name, |
| message: error.message, |
| ...(typeof code === "string" || typeof code === "number" ? { code } : {}), |
| ...(sharedState ? { sharedState } : {}), |
| }; |
| } |
|
|
| export function restoreCronLoadError(value: CronLoadError): Error { |
| const error = Object.assign(new Error(value.message), { |
| name: value.name, |
| ...(value.code === undefined ? {} : { code: value.code }), |
| }); |
| if (value.sharedState) { |
| retainOpenClawStateWorkerErrorPayload(error, value.sharedState); |
| } |
| return hydrateOpenClawStateWorkerError(error, { includeOrdinary: true }); |
| } |
|
|
