/** Shared SQLite database helper for the queue gallery demo. */
import type { DatabaseAdapter } from "tina4-nodejs/orm";

let _db: DatabaseAdapter | null = null;

export const MAX_RETRIES = 3;

export async function getQueueDb(): Promise<DatabaseAdapter> {
  if (_db) return _db;
  const orm = await import("tina4-nodejs/orm");
  _db = await orm.initDatabase({ type: "sqlite", path: "./data/gallery_queue.db" });
  try {
    _db.execute(`CREATE TABLE IF NOT EXISTS tina4_queue (
      id INTEGER PRIMARY KEY AUTOINCREMENT,
      topic TEXT NOT NULL,
      data TEXT NOT NULL,
      status TEXT NOT NULL DEFAULT 'pending',
      priority INTEGER NOT NULL DEFAULT 0,
      attempts INTEGER NOT NULL DEFAULT 0,
      error TEXT,
      available_at TEXT NOT NULL,
      created_at TEXT NOT NULL,
      completed_at TEXT,
      reserved_at TEXT
    )`);
  } catch (_e) { /* table already exists */ }
  return _db;
}

export function now(): string {
  return new Date().toISOString();
}