fix: make migrations resilient for 1.1.1

Author: lnikell

package.json

@@ -1,6 +1,6 @@
 {
   "name": "Loopndroll",
-  "version": "1.1.0",
+  "version": "1.1.1",
   "private": true,
   "type": "module",
   "packageManager": "pnpm@10.33.0",

src/bun/db/migrations.ts

@@ -705,6 +705,29 @@ function nowIsoString() {
   return new Date().toISOString();
 }
 
+function shouldIgnoreMigrationStatementError(
+  sqlite: Database,
+  statement: string,
+  error: unknown,
+) {
+  const message = error instanceof Error ? error.message : String(error);
+  if (!message.toLowerCase().includes("duplicate column name:")) {
+    return false;
+  }
+
+  const match = /^\s*alter\s+table\s+(\w+)\s+add\s+column\s+(\w+)/i.exec(statement);
+  if (!match) {
+    return false;
+  }
+
+  const [, tableName, columnName] = match;
+  const rows = sqlite.query(`pragma table_info(${tableName})`).all() as Array<{
+    name?: string;
+  }>;
+
+  return rows.some((row) => row.name === columnName);
+}
+
 export function applyAppMigrations(
   sqlite: Database,
   migrations: readonly AppMigration[] = appMigrations,
@@ -727,7 +750,15 @@ export function applyAppMigrations(
 
   const applyMigration = sqlite.transaction((migration: AppMigration) => {
     for (const statement of migration.statements) {
-      sqlite.exec(statement);
+      try {
+        sqlite.exec(statement);
+      } catch (error) {
+        if (shouldIgnoreMigrationStatementError(sqlite, statement, error)) {
+          continue;
+        }
+
+        throw error;
+      }
     }
 
     insertAppliedMigration.run(migration.id, migration.name, nowIsoString());

src/bun/loopndroll.ts

@@ -2476,6 +2476,22 @@ function configureDatabase(db) {
   }
 }
 
+function shouldIgnoreMigrationStatementError(db, statement, error) {
+  const message = error instanceof Error ? error.message : String(error);
+  if (!message.toLowerCase().includes("duplicate column name:")) {
+    return false;
+  }
+
+  const match = /^\\s*alter\\s+table\\s+(\\w+)\\s+add\\s+column\\s+(\\w+)/i.exec(statement);
+  if (!match) {
+    return false;
+  }
+
+  const [, tableName, columnName] = match;
+  const rows = db.query(\`pragma table_info(\${tableName})\`).all();
+  return rows.some((row) => row.name === columnName);
+}
+
 function applyMigrations(db) {
   db.exec(\`create table if not exists schema_migrations (
     id integer primary key,
@@ -2490,7 +2506,15 @@ function applyMigrations(db) {
   );
   const applyMigration = db.transaction((migration) => {
     for (const statement of migration.statements) {
-      db.exec(statement);
+      try {
+        db.exec(statement);
+      } catch (error) {
+        if (shouldIgnoreMigrationStatementError(db, statement, error)) {
+          continue;
+        }
+
+        throw error;
+      }
     }
 
     insertMigration.run(migration.id, migration.name, nowIsoString());