import { normalizeOptionalString } from "../../shared/string-coerce.js";

import { resolveCronDeliveryPlan, type CronDeliveryPlan } from "../delivery-plan.js";

import type {

CronAgentExecutionStarted,

CronDeliveryTrace,

CronDeliveryTraceMessageTarget,

CronDeliveryTraceTarget,

message: string;

abortSignal?: AbortSignal;

signal?: AbortSignal;

onExecutionStarted?: () => void;

onExecutionStarted?: (info?: CronAgentExecutionStarted) => void;

sessionKey: string;

agentId?: string;

lane?: string;

message: string;

abortSignal?: AbortSignal;

signal?: AbortSignal;

onExecutionStarted?: () => void;

onExecutionStarted?: (info?: CronAgentExecutionStarted) => void;

sessionKey: string;

agentId?: string;

lane?: string;

if (!prepared.ok) {

return prepared.result;

}

const notifyExecutionStarted = () =>

params.onExecutionStarted?.({

jobId: params.job.id,

agentId: prepared.context.agentId,

sessionId: prepared.context.runSessionId,

sessionKey: prepared.context.runSessionKey,

});

try {

const { executeCronRun } = await loadCronExecutorRuntime();

commandBody: prepared.context.commandBody,

persistSessionEntry: prepared.context.persistSessionEntry,

abortSignal,

onExecutionStarted: params.onExecutionStarted,

onExecutionStarted: notifyExecutionStarted,

abortReason,

isAborted,

thinkLevel: prepared.context.thinkLevel,