test(cron): improve fire-and-forget harness coverage

src/cron/service.every-jobs-fire.test.ts

@@ -1,5 +1,3 @@
-import fs from "node:fs/promises";
-import path from "node:path";
 import { describe, expect, it, vi } from "vitest";
 import { CronService } from "./service.js";
 import {
@@ -7,6 +5,7 @@ import {
   createCronStoreHarness,
   createNoopLogger,
   installCronTestHooks,
+  writeCronStoreSnapshot,
 } from "./service.test-harness.js";
 
 const noopLogger = createNoopLogger();
@@ -120,44 +119,35 @@ describe("CronService interval/cron jobs fire on time", () => {
     const requestHeartbeatNow = vi.fn();
     const nowMs = Date.parse("2025-12-13T00:00:00.000Z");
 
-    await fs.mkdir(path.dirname(store.storePath), { recursive: true });
+    await writeCronStoreSnapshot({
-    await fs.writeFile(
+      storePath: store.storePath,
-      store.storePath,
+      jobs: [
-      JSON.stringify(
         {
-          version: 1,
+          id: "legacy-every",
-          jobs: [
+          name: "legacy every",
-            {
+          enabled: true,
-              id: "legacy-every",
+          createdAtMs: nowMs,
-              name: "legacy every",
+          updatedAtMs: nowMs,
-              enabled: true,
+          schedule: { kind: "every", everyMs: 120_000 },
-              createdAtMs: nowMs,
+          sessionTarget: "main",
-              updatedAtMs: nowMs,
+          wakeMode: "now",
-              schedule: { kind: "every", everyMs: 120_000 },
+          payload: { kind: "systemEvent", text: "sf-tick" },
-              sessionTarget: "main",
+          state: { nextRunAtMs: nowMs + 120_000 },
-              wakeMode: "now",
-              payload: { kind: "systemEvent", text: "sf-tick" },
-              state: { nextRunAtMs: nowMs + 120_000 },
-            },
-            {
-              id: "minute-cron",
-              name: "minute cron",
-              enabled: true,
-              createdAtMs: nowMs,
-              updatedAtMs: nowMs,
-              schedule: { kind: "cron", expr: "* * * * *", tz: "UTC" },
-              sessionTarget: "main",
-              wakeMode: "now",
-              payload: { kind: "systemEvent", text: "minute-tick" },
-              state: { nextRunAtMs: nowMs + 60_000 },
-            },
-          ],
         },
-        null,
+        {
-        2,
+          id: "minute-cron",
-      ),
+          name: "minute cron",
-      "utf-8",
+          enabled: true,
-    );
+          createdAtMs: nowMs,
+          updatedAtMs: nowMs,
+          schedule: { kind: "cron", expr: "* * * * *", tz: "UTC" },
+          sessionTarget: "main",
+          wakeMode: "now",
+          payload: { kind: "systemEvent", text: "minute-tick" },
+          state: { nextRunAtMs: nowMs + 60_000 },
+        },
+      ],
+    });
 
     const cron = new CronService({
       storePath: store.storePath,

src/cron/service.read-ops-nonblocking.test.ts

@@ -3,6 +3,7 @@ import os from "node:os";
 import path from "node:path";
 import { describe, expect, it, vi } from "vitest";
 import { CronService } from "./service.js";
+import { writeCronStoreSnapshot } from "./service.test-harness.js";
 
 const noopLogger = {
   debug: vi.fn(),
@@ -167,29 +168,24 @@ describe("CronService read ops while job is running", () => {
     const requestHeartbeatNow = vi.fn();
     const nowMs = Date.parse("2025-12-13T00:00:00.000Z");
 
-    await fs.mkdir(path.dirname(store.storePath), { recursive: true });
+    await writeCronStoreSnapshot({
-    await fs.writeFile(
+      storePath: store.storePath,
-      store.storePath,
+      jobs: [
-      JSON.stringify({
+        {
-        version: 1,
+          id: "startup-catchup",
-        jobs: [
+          name: "startup catch-up",
-          {
+          enabled: true,
-            id: "startup-catchup",
+          createdAtMs: nowMs - 86_400_000,
-            name: "startup catch-up",
+          updatedAtMs: nowMs - 86_400_000,
-            enabled: true,
+          schedule: { kind: "at", at: new Date(nowMs - 60_000).toISOString() },
-            createdAtMs: nowMs - 86_400_000,
+          sessionTarget: "isolated",
-            updatedAtMs: nowMs - 86_400_000,
+          wakeMode: "next-heartbeat",
-            schedule: { kind: "at", at: new Date(nowMs - 60_000).toISOString() },
+          payload: { kind: "agentTurn", message: "startup replay" },
-            sessionTarget: "isolated",
+          delivery: { mode: "none" },
-            wakeMode: "next-heartbeat",
+          state: { nextRunAtMs: nowMs - 60_000 },
-            payload: { kind: "agentTurn", message: "startup replay" },
+        },
-            delivery: { mode: "none" },
+      ],
-            state: { nextRunAtMs: nowMs - 60_000 },
+    });
-          },
-        ],
-      }),
-      "utf-8",
-    );
 
     const isolatedRun = createDeferredIsolatedRun();
 

src/cron/service.test-harness.ts

@@ -51,6 +51,22 @@ export function createCronStoreHarness(options?: { prefix?: string }) {
   return { makeStorePath };
 }
 
+export async function writeCronStoreSnapshot(params: { storePath: string; jobs: CronJob[] }) {
+  await fs.mkdir(path.dirname(params.storePath), { recursive: true });
+  await fs.writeFile(
+    params.storePath,
+    JSON.stringify(
+      {
+        version: 1,
+        jobs: params.jobs,
+      },
+      null,
+      2,
+    ),
+    "utf-8",
+  );
+}
+
 export function installCronTestHooks(options: {
   logger: ReturnType<typeof createNoopLogger>;
   baseTimeIso?: string;