resolveCronRunLogPruneOptions,

} from "../cron/run-log.js";

import { CronService } from "../cron/service.js";

import { assertSafeCronSessionTargetId } from "../cron/session-target.js";

import {

resolveCronDeliverySessionKey,

resolveCronSessionTargetSessionKey,

} from "../cron/session-target.js";

import { resolveCronStorePath } from "../cron/store.js";

import { normalizeHttpWebhookUrl } from "../cron/webhook-url.js";

import { formatErrorMessage } from "../infra/errors.js";

import { fetchWithSsrFGuard } from "../infra/net/fetch-guard.js";

import { SsrFBlockedError } from "../infra/net/ssrf.js";

import { deliverOutboundPayloads } from "../infra/outbound/deliver.js";

import { buildOutboundSessionContext } from "../infra/outbound/session-context.js";

import { enqueueSystemEvent } from "../infra/system-events.js";

import { getChildLogger } from "../logging.js";

import { normalizeAgentId, toAgentStoreSessionKey } from "../routing/session-key.js";

},

runIsolatedAgentJob: async ({ job, message, abortSignal }) => {

const { agentId, cfg: runtimeConfig } = resolveCronAgent(job.agentId);

let sessionKey = `cron:${job.id}`;

if (job.sessionTarget.startsWith("session:")) {

sessionKey = assertSafeCronSessionTargetId(job.sessionTarget.slice(8));

}

const sessionKey = resolveCronSessionTargetSessionKey(job.sessionTarget) ?? `cron:${job.id}`;

try {

return await runCronIsolatedAgentTurn({

cfg: runtimeConfig,

return;

}

const deliverySessionKey = resolveCronDeliverySessionKey(job);

const target = await resolveDeliveryTarget(runtimeConfig, agentId, {

channel,

to,

accountId,

sessionKey: deliverySessionKey,

});

if (!target.ok) {

throw target.error;

}

const session = buildOutboundSessionContext({

cfg: runtimeConfig,

agentId,

sessionKey: deliverySessionKey ?? `cron:${job.id}:failure`,

});

await deliverOutboundPayloads({

cfg: runtimeConfig,

channel: target.channel,

threadId: target.threadId,

payloads: [{ text }],

deps: createOutboundSendDeps(params.deps),

session,

});

},

log: getChildLogger({ module: "cron", storePath }),

if (!isBestEffort) {

const failureMessage = `Cron job "${job.name}" failed: ${evt.error ?? "unknown error"}`;

const failureDest = resolveFailureDestination(job, params.cfg.cron?.failureDestination);

const deliverySessionKey = resolveCronDeliverySessionKey(job);

if (failureDest) {

// Explicit failureDestination configured — use it

channel: failureDest.channel,

to: failureDest.to,

accountId: failureDest.accountId,

sessionKey: job.sessionKey,

sessionKey: deliverySessionKey,

},

`⚠️ ${failureMessage}`,

);

channel: primaryPlan.channel,

to: primaryPlan.to,

accountId: primaryPlan.accountId,

sessionKey: job.sessionKey,

sessionKey: deliverySessionKey,

},

`⚠️ ${failureMessage}`,

);