Method recomputeNext

src/schedule/store.ts:223–250

* Recompute next_run_at from now. Called after every run and on enable. * * Returns true if this caller successfully advanced next_run_at, false if it * lost a race (another process/tick already advanced the same row). The * advance is atomic: the UPDATE is conditional on the previously-

(scheduleId: string)

   * Callers on the run path MUST treat a false result as "do not fire".
   */
  recomputeNext(scheduleId: string): boolean {
    const e = this.get(scheduleId);
    if (!e) return false;
    let next: Date | null = null;
    try {
      const parsed = parseCron(e.cron);
      next = nextAfter(parsed, new Date());
    } catch (err: any) {
      // Invalid cron — leave next_run_at null so the tick loop ignores it, but
      // warn so the user can learn why this schedule never fires instead of it
      // being silently disabled.
      logger.warn('Schedule has an invalid cron expression; it will never run until fixed', {
        id: e.id,
        name: e.name,
        cron: e.cron,
        err: err?.message ?? String(err),
      });
    }
    // Atomic claim: only advance if next_run_at still holds the value we read.
    // A losing concurrent tick sees changes === 0 and must not fire.
    const prev = e.next_run_at ?? null;
    const res = prev === null
      ? this.db.prepare(`UPDATE schedules SET next_run_at = ? WHERE id = ? AND next_run_at IS NULL`)
          .run(next?.toISOString() ?? null, scheduleId)
      : this.db.prepare(`UPDATE schedules SET next_run_at = ? WHERE id = ? AND next_run_at = ?`)
          .run(next?.toISOString() ?? null, scheduleId, prev);
    return res.changes === 1;
  }

  /** Attach a parsed trust receipt (JSON) to a finished run — the audit record. Best-effort. */
  attachReceipt(runId: number, receiptJson: string): void {