vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-06 11:40:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(cron): use loadCronStore in issue-regression tests for split store compat

Browse Source
This commit is contained in:
Feelw00
2026-04-14 20:58:49 +09:00
committed by Gustavo Madeira Santana
parent a1a08e27db
commit 0844bd521e
1 changed files with 4 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/cron/service.issue-regressions.test.ts
View File

@@ -8,6 +8,7 @@ import {
writeCronStoreSnapshot,
} from "./service.issue-regressions.test-helpers.js";
import { CronService } from "./service.js";
import { loadCronStore } from "./store.js";
import type { CronJob, CronJobState } from "./types.js";
describe("Cron issue regressions", () => {
@@ -92,9 +93,7 @@ describe("Cron issue regressions", () => {
expect(Number.isFinite(isolated?.state.nextRunAtMs)).toBe(true);
expect(Number.isFinite(status.nextWakeAtMs)).toBe(true);
const persisted = JSON.parse(await fs.readFile(store.storePath, "utf8")) as {
jobs: Array<{ id: string; state?: { nextRunAtMs?: number | null } }>;
};
const persisted = await loadCronStore(store.storePath);
const persistedIsolated = persisted.jobs.find((job) => job.id === "legacy-isolated");
expect(typeof persistedIsolated?.state?.nextRunAtMs).toBe("number");
expect(Number.isFinite(persistedIsolated?.state?.nextRunAtMs)).toBe(true);
@@ -187,9 +186,7 @@ describe("Cron issue regressions", () => {
payload: { kind: "systemEvent", text: "other-updated" },
});
const storeData = JSON.parse(await fs.readFile(store.storePath, "utf8")) as {
jobs: Array<{ id: string; state?: { nextRunAtMs?: number } }>;
};
const storeData = await loadCronStore(store.storePath);
const persistedDueJob = storeData.jobs.find((job) => job.id === dueJob.id);
expect(persistedDueJob?.state?.nextRunAtMs).toBe(originalDueNextRunAtMs);
@@ -300,9 +297,7 @@ describe("Cron issue regressions", () => {
const result = await cron.run(job.id, "force");
expect(result).toEqual({ ok: true, ran: true });
const persisted = JSON.parse(await fs.readFile(store.storePath, "utf8")) as {
jobs: CronJob[];
};
const persisted = await loadCronStore(store.storePath);
const persistedJob = persisted.jobs.find((entry) => entry.id === job.id);
expect(persistedJob?.delivery?.to).toBe(rewrittenTarget);
expect(persistedJob?.state.lastStatus).toBe("ok");