@@ -2,6 +2,8 @@ import fs from "node:fs/promises";
22import path from "node:path";
33import { describe, expect, it, vi } from "vitest";
44import { setupCronServiceSuite } from "../service.test-harness.js";
5+import { saveCronStore } from "../store.js";
6+import type { CronJob } from "../types.js";
57import { findJobOrThrow } from "./jobs.js";
68import { createCronServiceState } from "./state.js";
79import { ensureLoaded, persist } from "./store.js";
@@ -40,6 +42,22 @@ function createStoreTestState(storePath: string) {
4042});
4143}
424445+function createReloadCronJob(params?: Partial<CronJob>): CronJob {
46+return {
47+id: "reload-cron-expr-job",
48+name: "reload cron expr job",
49+enabled: true,
50+createdAtMs: STORE_TEST_NOW - 60_000,
51+updatedAtMs: STORE_TEST_NOW - 60_000,
52+schedule: { kind: "cron", expr: "0 6 * * *", tz: "UTC" },
53+sessionTarget: "main",
54+wakeMode: "now",
55+payload: { kind: "systemEvent", text: "tick" },
56+state: {},
57+ ...params,
58+};
59+}
60+4361describe("cron service store seam coverage", () => {
4462it("loads stored jobs, recomputes next runs, and does not rewrite the store on load", async () => {
4563const { storePath } = await makeStorePath();
@@ -189,4 +207,183 @@ describe("cron service store seam coverage", () => {
189207expect.stringContaining("invalid persisted sessionTarget"),
190208);
191209});
210+211+it("clears stale nextRunAtMs after force reload when cron schedule expression changes", async () => {
212+const { storePath } = await makeStorePath();
213+const staleNextRunAtMs = STORE_TEST_NOW + 3_600_000;
214+215+await saveCronStore(storePath, {
216+version: 1,
217+jobs: [
218+createReloadCronJob({
219+state: { nextRunAtMs: staleNextRunAtMs },
220+}),
221+],
222+});
223+224+const state = createStoreTestState(storePath);
225+await ensureLoaded(state, { skipRecompute: true });
226+expect(findJobOrThrow(state, "reload-cron-expr-job").state.nextRunAtMs).toBe(staleNextRunAtMs);
227+228+await writeSingleJobStore(storePath, {
229+id: "reload-cron-expr-job",
230+name: "reload cron expr job",
231+enabled: true,
232+createdAtMs: STORE_TEST_NOW - 60_000,
233+updatedAtMs: STORE_TEST_NOW - 30_000,
234+schedule: { kind: "cron", expr: "30 6 * * 0,6", tz: "UTC" },
235+sessionTarget: "main",
236+wakeMode: "now",
237+payload: { kind: "systemEvent", text: "tick" },
238+state: {},
239+});
240+241+await ensureLoaded(state, { forceReload: true, skipRecompute: true });
242+243+const reloadedJob = findJobOrThrow(state, "reload-cron-expr-job");
244+expect(reloadedJob.schedule).toEqual({ kind: "cron", expr: "30 6 * * 0,6", tz: "UTC" });
245+expect(reloadedJob.state.nextRunAtMs).toBeUndefined();
246+});
247+248+it("preserves nextRunAtMs after force reload when cron schedule key order changes only", async () => {
249+const { storePath } = await makeStorePath();
250+const dueNextRunAtMs = STORE_TEST_NOW - 1_000;
251+252+await saveCronStore(storePath, {
253+version: 1,
254+jobs: [
255+createReloadCronJob({
256+state: { nextRunAtMs: dueNextRunAtMs },
257+}),
258+],
259+});
260+261+const state = createStoreTestState(storePath);
262+await ensureLoaded(state, { skipRecompute: true });
263+264+await writeSingleJobStore(storePath, {
265+id: "reload-cron-expr-job",
266+name: "reload cron expr job",
267+enabled: true,
268+createdAtMs: STORE_TEST_NOW - 60_000,
269+updatedAtMs: STORE_TEST_NOW - 30_000,
270+schedule: { expr: "0 6 * * *", kind: "cron", tz: "UTC" },
271+sessionTarget: "main",
272+wakeMode: "now",
273+payload: { kind: "systemEvent", text: "tick" },
274+state: {},
275+});
276+277+await ensureLoaded(state, { forceReload: true, skipRecompute: true });
278+279+expect(findJobOrThrow(state, "reload-cron-expr-job").state.nextRunAtMs).toBe(dueNextRunAtMs);
280+});
281+282+it("preserves nextRunAtMs after force reload when scheduling inputs are unchanged", async () => {
283+const { storePath } = await makeStorePath();
284+const originalNextRunAtMs = STORE_TEST_NOW + 3_600_000;
285+286+await writeSingleJobStore(storePath, {
287+ ...createReloadCronJob({ state: { nextRunAtMs: originalNextRunAtMs } }),
288+});
289+290+const state = createStoreTestState(storePath);
291+await ensureLoaded(state, { skipRecompute: true });
292+await writeSingleJobStore(storePath, {
293+ ...createReloadCronJob({
294+updatedAtMs: STORE_TEST_NOW,
295+state: { nextRunAtMs: originalNextRunAtMs + 60_000 },
296+}),
297+});
298+299+await ensureLoaded(state, { forceReload: true, skipRecompute: true });
300+301+expect(findJobOrThrow(state, "reload-cron-expr-job").state.nextRunAtMs).toBe(
302+originalNextRunAtMs + 60_000,
303+);
304+});
305+306+it("clears stale nextRunAtMs after force reload when enabled state changes", async () => {
307+const { storePath } = await makeStorePath();
308+const staleNextRunAtMs = STORE_TEST_NOW + 3_600_000;
309+310+await writeSingleJobStore(storePath, {
311+ ...createReloadCronJob({
312+enabled: true,
313+state: { nextRunAtMs: staleNextRunAtMs },
314+}),
315+});
316+317+const state = createStoreTestState(storePath);
318+await ensureLoaded(state, { skipRecompute: true });
319+await writeSingleJobStore(storePath, {
320+ ...createReloadCronJob({
321+enabled: false,
322+updatedAtMs: STORE_TEST_NOW,
323+state: { nextRunAtMs: staleNextRunAtMs },
324+}),
325+});
326+327+await ensureLoaded(state, { forceReload: true, skipRecompute: true });
328+329+expect(findJobOrThrow(state, "reload-cron-expr-job").state.nextRunAtMs).toBeUndefined();
330+});
331+332+it("clears stale nextRunAtMs after force reload when every schedule anchor changes", async () => {
333+const { storePath } = await makeStorePath();
334+const jobId = "reload-every-anchor-job";
335+const staleNextRunAtMs = STORE_TEST_NOW + 3_600_000;
336+337+await writeSingleJobStore(storePath, {
338+ ...createReloadCronJob({
339+id: jobId,
340+schedule: { kind: "every", everyMs: 60_000, anchorMs: STORE_TEST_NOW - 60_000 },
341+state: { nextRunAtMs: staleNextRunAtMs },
342+}),
343+});
344+345+const state = createStoreTestState(storePath);
346+await ensureLoaded(state, { skipRecompute: true });
347+await writeSingleJobStore(storePath, {
348+ ...createReloadCronJob({
349+id: jobId,
350+updatedAtMs: STORE_TEST_NOW,
351+schedule: { kind: "every", everyMs: 60_000, anchorMs: STORE_TEST_NOW },
352+state: { nextRunAtMs: staleNextRunAtMs },
353+}),
354+});
355+356+await ensureLoaded(state, { forceReload: true, skipRecompute: true });
357+358+expect(findJobOrThrow(state, jobId).state.nextRunAtMs).toBeUndefined();
359+});
360+361+it("clears stale nextRunAtMs after force reload when at schedule target changes", async () => {
362+const { storePath } = await makeStorePath();
363+const jobId = "reload-at-target-job";
364+const staleNextRunAtMs = STORE_TEST_NOW + 3_600_000;
365+366+await writeSingleJobStore(storePath, {
367+ ...createReloadCronJob({
368+id: jobId,
369+schedule: { kind: "at", at: "2026-03-23T13:00:00.000Z" },
370+state: { nextRunAtMs: staleNextRunAtMs },
371+}),
372+});
373+374+const state = createStoreTestState(storePath);
375+await ensureLoaded(state, { skipRecompute: true });
376+await writeSingleJobStore(storePath, {
377+ ...createReloadCronJob({
378+id: jobId,
379+updatedAtMs: STORE_TEST_NOW,
380+schedule: { kind: "at", at: "2026-03-23T14:00:00.000Z" },
381+state: { nextRunAtMs: staleNextRunAtMs },
382+}),
383+});
384+385+await ensureLoaded(state, { forceReload: true, skipRecompute: true });
386+387+expect(findJobOrThrow(state, jobId).state.nextRunAtMs).toBeUndefined();
388+});
192389});
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。