Merge pull request #225 from janezd/db-migrations

Implement database migrations

Author: janezd

utils/db.ts

@@ -2,6 +2,7 @@ import sqlite3 from "sqlite3";
 import path from "node:path";
 import { open, Database } from "sqlite";
 import { CONFIG } from "@/utils/config";
+import { migrate } from "@/utils/migrateDb.mjs";
 
 let db: Database;
 
@@ -36,6 +37,7 @@ if (!(process.env.NEXT_PHASE === 'phase-production-build' || process.env.CI)) {
   }
 
   await db.exec("PRAGMA foreign_keys = ON");
+  await migrate(db);
 } else {
   db = {} as unknown as Database;
 }

utils/migrateDb.mjs

@@ -0,0 +1,31 @@
+/* This is not TypeScript because it has await at top-level => must be imported with dynamic import by ingest */
+
+import path from "node:path";
+import fs from "fs";
+import { fileURLToPath } from "node:url";
+
+export const migrate = async (db) => {
+  const filename = fileURLToPath(import.meta.url);
+  const dirname = path.dirname(filename);
+  const migrationsDir = path.resolve(dirname, "db-migrations");
+
+  if (!fs.existsSync(migrationsDir)) {
+    console.warn(`Migrations directory not found at ${migrationsDir}`);
+    return;
+  }
+  const migrationFiles = fs.readdirSync(migrationsDir)
+    .filter((file) => file.endsWith(".sql"))
+    .sort();
+  const { user_version } = await db.get(`PRAGMA user_version`);
+  for (const file of migrationFiles) {
+    const version = parseInt(file.split("-")[0]);
+    if (version > user_version) {
+      const sql = fs.readFileSync(path.join(migrationsDir, file), "utf-8");
+      await db.exec("BEGIN TRANSACTION");
+      await db.exec(sql);
+      await db.exec(`PRAGMA user_version = ${version}`);
+      await db.exec("COMMIT");
+      console.log("Applied migration:", file);
+    }
+  }
+}