fix(cron): run legacy cron store migration in gateway fast path

openperf · openperf · commit c4a83293efc2 · 2026-06-15T23:52:37.000+08:00
diff --git a/src/cli/gateway-cli/run.ts b/src/cli/gateway-cli/run.ts
@@ -546,6 +546,21 @@ export async function runGatewayCommand(opts: GatewayRunOpts) {
   void maybeLogPendingControlUiBuild(cfg).catch((err: unknown) => {
     gatewayLog.warn(`Control UI asset check failed: ${String(err)}`);
   });
+  // Gateway fast path skips ensureCliExecutionBootstrap, so the normal state migration
+  // preflight never runs. Without this the scheduler loads 0 jobs from empty SQLite.
+  try {
+    const { repairLegacyCronStoreWithoutPrompt } =
+      await import("../../commands/doctor/cron/index.js");
+    const cronMigration = await repairLegacyCronStoreWithoutPrompt({ cfg });
+    for (const change of cronMigration.changes) {
+      gatewayLog.info(change);
+    }
+    for (const warning of cronMigration.warnings) {
+      gatewayLog.warn(warning);
+    }
+  } catch (err) {
+    gatewayLog.warn(`Cron store migration check failed: ${formatErrorMessage(err)}`);
+  }
   const portOverride = parsePort(opts.port);
   if (opts.port !== undefined && portOverride === null) {
     defaultRuntime.error(formatInvalidPortOption("--port"));
diff --git a/src/commands/doctor/cron/index.test.ts b/src/commands/doctor/cron/index.test.ts
@@ -16,6 +16,7 @@ import {
   collectLegacyWhatsAppCrontabHealthWarning,
   maybeRepairLegacyCronStore,
   noteLegacyWhatsAppCrontabHealthCheck,
+  repairLegacyCronStoreWithoutPrompt,
 } from "./index.js";
 
 type TerminalNote = (message: string, title?: string) => void;
@@ -1058,3 +1059,32 @@ describe("legacy WhatsApp crontab health check", () => {
     expect(noteMock).not.toHaveBeenCalled();
   });
 });
+
+describe("repairLegacyCronStoreWithoutPrompt", () => {
+  it("migrates legacy JSON cron store to SQLite and returns a change summary", async () => {
+    const storePath = await makeTempStorePath();
+    await writeCronStore(storePath, [createLegacyCronJob()]);
+
+    const result = await repairLegacyCronStoreWithoutPrompt({
+      cfg: createCronConfig(storePath),
+    });
+
+    expect(result.changes).toHaveLength(1);
+    expect(result.changes[0]).toContain("Cron store migrated to SQLite");
+    expect(result.warnings).toHaveLength(0);
+    const jobs = await readPersistedJobs(storePath);
+    expect(jobs).toHaveLength(1);
+  });
+
+  it("returns empty result when no legacy store exists", async () => {
+    const storePath = await makeTempStorePath();
+    await writeCurrentCronStore(storePath, [createCurrentCronJob()]);
+
+    const result = await repairLegacyCronStoreWithoutPrompt({
+      cfg: createCronConfig(storePath),
+    });
+
+    expect(result.changes).toHaveLength(0);
+    expect(result.warnings).toHaveLength(0);
+  });
+});
