/** Orchestrates isolated cron agent turn setup, execution, delivery, and cleanup. */

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

import { retireSessionMcpRuntime } from "../../agents/agent-bundle-mcp-tools.js";

import { hasAnyAuthProfileStoreSource } from "../../agents/auth-profiles/source-check.js";

fallbackUsed: boolean;

delivered: boolean;

}): CronDeliveryTrace {

// Trace both intended and resolved targets so run logs can explain fallback

// delivery without leaking provider-specific raw routing internals.

const intended = normalizeCronTraceTarget({

channel: params.deliveryPlan.channel ?? "last",

to: params.deliveryPlan.to ?? null,

threadId: params.resolvedDelivery.threadId,

};

if (params.deliveryPlan.mode === "webhook") {

// Webhook jobs do not expose chat delivery or message-tool fallback.

return createSourceDeliveryPlan({

owner: "none",

reason: "cron_webhook",

});

}

if (params.deliveryPlan.mode === "none") {

// delivery=none still allows explicit message-tool sends from the agent,

// but cron itself must not auto-announce a final reply.

return createSourceDeliveryPlan({

owner: "none",

reason: "cron_none",

.slice(selectedPreflightCandidateIndex + 1)

.map((candidate) => `${candidate.provider}/${candidate.model}`)

: undefined;

// When preflight skips the first local candidate, trim the fallback chain so

// execution starts at the reachable provider and only falls forward from it.

if (selectedPreflightCandidate && modelFallbacksOverride) {

if (firstUnavailablePreflight?.status === "unavailable") {

logWarn(

: await (

await loadCronAuthProfileRuntime()

).resolveSessionAuthProfileOverride({

// Auth profile resolution can mutate session state; pass the same

// store and key that persistence will later write.

cfg: cfgWithAgentDefaults,

provider,

acceptedProviderIds: listOpenAIAuthProfileProvidersForAgentRuntime({