Class ScheduleStore

src/schedule/store.ts:87–263

}

export class ScheduleStore {
  private db: Database.Database;

  constructor(dbPath: string = QODEX_SESSION_DB) {
    this.db = openDatabase(dbPath);
    this.db.exec(SCHEMA);
    // Migrate DBs created before deliver/recipe existed. ADD COLUMN throws on an existing
    // column, so each is guarded — idempotent and safe to run every startup.
    for (const col of ['deliver TEXT', 'recipe TEXT']) {
      try { this.db.exec(`ALTER TABLE schedules ADD COLUMN ${col}`); } catch { /* already present */ }
    }
    try { this.db.exec(`ALTER TABLE schedule_runs ADD COLUMN receipt TEXT`); } catch { /* already present */ }
  }

  add(input: {
    name: string;
    cron: string;
    prompt: string;
    cwd: string;
    model?: string;
    allowedTools?: string[];
    deliver?: string;
    recipe?: string;
  }): ScheduleEntry {
    const parsed = parseCron(input.cron); // throws on invalid
    const next = nextAfter(parsed, new Date());
    const id = uuidv4();
    const allowed = input.allowedTools && input.allowedTools.length > 0 ? JSON.stringify(input.allowedTools) : null;
    this.db.prepare(`
      INSERT INTO schedules (id, name, cron, prompt, cwd, model, allowed_tools, next_run_at, deliver, recipe)
      VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
    `).run(id, input.name, input.cron, input.prompt, input.cwd, input.model ?? null, allowed, next?.toISOString() ?? null,
           input.deliver ?? null, input.recipe ?? null);
    return this.get(id)!;
  }

  remove(idOrName: string): boolean {
    const e = this.resolve(idOrName);
    if (!e) return false;
    this.db.prepare(`DELETE FROM schedules WHERE id = ?`).run(e.id);
    return true;
  }

  setEnabled(idOrName: string, enabled: boolean): ScheduleEntry | null {
    const e = this.resolve(idOrName);
    if (!e) return null;
    this.db.prepare(`UPDATE schedules SET enabled = ? WHERE id = ?`).run(enabled ? 1 : 0, e.id);
    if (enabled) this.recomputeNext(e.id);
    return this.get(e.id) ?? null;
  }

  get(id: string): ScheduleEntry | undefined {
    return this.db.prepare(`SELECT * FROM schedules WHERE id = ?`).get(id) as ScheduleEntry | undefined;
  }

  /** Find by exact id, id prefix (>=4 chars), or exact name. */
  resolve(idOrName: string): ScheduleEntry | undefined {
    const exact = this.get(idOrName);