import type { RuntimeEnv } from "../../runtime.js";

import {

coerceCronDeliveryPreviews,

enrichCronJsonWithStatus,

getCronChannelOptions,

parseAt,

parseCronToolsAllow,

parseDurationMs,

printCronList,

printCronShow,

} from "./shared.js";

const hoisted = vi.hoisted(() => ({

expect(parseDurationMs(`9${"0".repeat(15)}ms`)).toBe(9_000_000_000_000_000);

});

});

describe("cron status rendering", () => {

beforeEach(() => {

hoisted.listChannelPluginsMock.mockReset();

hoisted.listChannelPluginsMock.mockReturnValue([]);

});

// `lastRunStatus` is the primary execution-status field (`lastStatus` is the

// deprecated alias). The human `cron list`/`cron show` output must resolve it

// the same way the `--json` status field does, instead of showing "idle".

it("renders lastRunStatus (matching the --json status), not idle, when lastStatus is unset", () => {

const now = Date.now();

const job = createBaseJob({

id: "status-job",

sessionTarget: "isolated",

state: { nextRunAtMs: now + 3_600_000, lastRunStatus: "ok" },

});

const show = createRuntimeLogCapture();

printCronShow(job, show.runtime);

expectLogsToInclude(show.logs, "status: ok");

expect(show.logs.join("\n")).not.toContain("status: idle");

const list = createRuntimeLogCapture();

printCronList([job], list.runtime);

const dataLine = list.logs.find((line) => line.includes("status-job")) ?? "";

expect(dataLine).toContain("ok");

expect(dataLine).not.toContain("idle");

// The computed --json status must agree with the human render.

expect(enrichCronJsonWithStatus(job)).toMatchObject({ status: "ok" });

});

});

if (res?.enabled === true) {

return;

}

const store = typeof res?.sqlitePath === "string" ? res.sqlitePath

: typeof res?.storePath === "string" ? res.storePath

: "";

const store =

typeof res?.sqlitePath === "string"

? res.sqlitePath

: typeof res?.storePath === "string"

? res.storePath

: "";

defaultRuntime.error(

[

"warning: cron scheduler is disabled in the Gateway; jobs are saved but will not run automatically.",

return `${base} (stagger ${formatDurationHuman(staggerMs)})`;

};

const formatStatus = (job: CronJob) => {

if (!job.enabled) {

return "disabled";

}

const state = job.state ?? {};

if (state.runningAtMs) {

return "running";

}

return state.lastStatus ?? "idle";

};

export function coerceCronDeliveryPreviews(value: unknown): Map<string, CronDeliveryPreview> {

const previews =

value && typeof value === "object"

CRON_NEXT_PAD,

);

const lastLabel = pad(formatRelative(state.lastRunAtMs, now), CRON_LAST_PAD);

const statusRaw = formatStatus(job);

const statusRaw = computeStatus(job);

const statusLabel = pad(statusRaw, CRON_STATUS_PAD);

const targetLabel = pad(job.sessionTarget ?? "-", CRON_TARGET_PAD);

const deliveryPreview = opts?.deliveryPreviews?.get(job.id);

runtime.log(`delivery: ${preview.label} (${preview.detail})`);

runtime.log(`next: ${formatRelative(job.state.nextRunAtMs, Date.now())}`);

runtime.log(`last: ${formatRelative(job.state.lastRunAtMs, Date.now())}`);

runtime.log(`status: ${formatStatus(job)}`);

runtime.log(`status: ${computeStatus(job)}`);

runtime.log(`diagnostic: ${job.state.lastDiagnosticSummary ?? "-"}`);

}