Log fatal migration context

src/server.js

@@ -14,6 +14,9 @@ async function start() {
     await runMigrations();
   } catch (err) {
     console.error('[Boot] Migration failed — aborting:', err.message);
+    if (err.migrationContext) {
+      console.error('[Boot] Migration context:', JSON.stringify(err.migrationContext));
+    }
     process.exit(1);
   }
 

src/utils/migrate.js

@@ -406,9 +406,28 @@ function repairBlockingMariaArtifacts() {
   return repaired;
 }
 
+function buildMigrationFailureContext(index, sql, table, err) {
+  return {
+    index,
+    targetTable: table,
+    errno: err?.errno ?? null,
+    code: err?.code ?? null,
+    sqlState: err?.sqlState ?? null,
+    message: err?.message ?? null,
+    sql: summarizeSql(sql),
+    dbDir: DB_DIR,
+    dbDirExists: fs.existsSync(DB_DIR),
+  };
+}
+
+function logFatalMigrationFailure(context) {
+  console.error('[migration-error] Fatal migration failure:', JSON.stringify(context));
+}
+
 async function runMigrations() {
   console.log('[migrate] Running schema migrations...');
-  for (const sql of migrations) {
+  for (let i = 0; i < migrations.length; i += 1) {
+    const sql = migrations[i];
     const targetTable = extractTargetTable(sql);
     try {
       await db.query(sql);
@@ -426,11 +445,20 @@ async function runMigrations() {
         console.warn(`[migrate] Skipping already-satisfied migration after MariaDB alter failure: ${col}`);
       } else if (err.errno === 21 && repairBlockingMariaArtifacts()) {
         console.warn(`[migrate] Retrying after artifact repair for table ${targetTable}`);
-        await db.query(sql);
-        const col = sql.match(/(?:ADD|MODIFY) COLUMN (\w+)/i)?.[1] ?? sql.slice(0, 60);
-        console.log(`[migrate] Applied after repair: ${col}`);
+        try {
+          await db.query(sql);
+          const col = sql.match(/(?:ADD|MODIFY) COLUMN (\w+)/i)?.[1] ?? sql.slice(0, 60);
+          console.log(`[migrate] Applied after repair: ${col}`);
+        } catch (retryErr) {
+          const context = buildMigrationFailureContext(i + 1, sql, targetTable, retryErr);
+          retryErr.migrationContext = context;
+          logFatalMigrationFailure(context);
+          throw retryErr;
+        }
       } else {
-        console.error('[migrate] Migration failed:', err.message);
+        const context = buildMigrationFailureContext(i + 1, sql, targetTable, err);
+        err.migrationContext = context;
+        logFatalMigrationFailure(context);
         throw err;
       }
     }