Deploy RAQIM 2026-05-02 20:35

artifacts/api-server/src/routes/convert.ts

@@ -1028,9 +1028,11 @@ router.post("/upload", upload.single("file"), async (req: AuthRequest, res) => {
     });
   } catch (err) {
     const e = err instanceof Error ? err : new Error(String(err));
-    console.error("[RAQIM] /upload error:", e.message, e.stack);
-    req.log?.error({ err }, "upload error");
-    res.status(500).json({ error: "server_error", message: e.message || "فشل الرفع" });
+    const cause = (e as NodeJS.ErrnoException & { cause?: Error }).cause;
+    const rootMsg = cause?.message ?? e.message;
+    console.error("[RAQIM] /upload error:", rootMsg, "\n  outer:", e.message, "\n  stack:", e.stack);
+    req.log?.error({ err, cause: cause?.message }, "upload error");
+    res.status(500).json({ error: "server_error", message: rootMsg || "فشل الرفع" });
   }
 });
 
@@ -1096,9 +1098,11 @@ router.post("/upload-split", upload.single("file"), async (req: AuthRequest, res
     res.status(202).json({ jobs });
   } catch (err) {
     const e = err instanceof Error ? err : new Error(String(err));
-    console.error("[RAQIM] /upload-split error:", e.message, e.stack);
-    req.log?.error({ err }, "upload-split error");
-    res.status(500).json({ error: "server_error", message: e.message || "فشل الرفع" });
+    const cause = (e as NodeJS.ErrnoException & { cause?: Error }).cause;
+    const rootMsg = cause?.message ?? e.message;
+    console.error("[RAQIM] /upload-split error:", rootMsg, "\n  outer:", e.message, "\n  stack:", e.stack);
+    req.log?.error({ err, cause: cause?.message }, "upload-split error");
+    res.status(500).json({ error: "server_error", message: rootMsg || "فشل الرفع" });
   }
 });
 

scripts/db-hf-sync.mjs

@@ -10,6 +10,7 @@ import { execSync, spawnSync } from "child_process";
 import fs from "fs";
 import path from "path";
 import { fileURLToPath } from "url";
+import { DatabaseSync } from "node:sqlite";
 
 const __dirname = path.dirname(fileURLToPath(import.meta.url));
 
@@ -65,6 +66,15 @@ export async function pullDb() {
   const srcDb = path.join(CLONE_DIR, "raqim.db");
   if (fs.existsSync(srcDb)) {
     fs.copyFileSync(srcDb, DB_PATH);
+    // Remove any stale WAL/SHM files that belonged to the old DB —
+    // they have different salt values and will confuse SQLite.
+    for (const suffix of ["-wal", "-shm"]) {
+      const stale = DB_PATH + suffix;
+      if (fs.existsSync(stale)) {
+        fs.rmSync(stale);
+        console.log(`[db-sync] Removed stale ${suffix} file.`);
+      }
+    }
     console.log("[db-sync] ✓ DB restored from HF Dataset.");
   } else {
     console.log("[db-sync] No existing DB in dataset — starting fresh.");
@@ -81,6 +91,16 @@ export async function pushDb() {
     run(`git clone --depth=1 "${gitUrl()}" "${CLONE_DIR}"`);
   }
 
+  // Checkpoint WAL into the main DB file before copying so the backup
+  // is a self-contained, consistent snapshot without a dangling WAL.
+  try {
+    const tmpDb = new DatabaseSync(DB_PATH);
+    tmpDb.exec("PRAGMA wal_checkpoint(TRUNCATE)");
+    tmpDb.close();
+  } catch (e) {
+    console.warn("[db-sync] WAL checkpoint failed (non-fatal):", e.message);
+  }
+
   fs.copyFileSync(DB_PATH, path.join(CLONE_DIR, "raqim.db"));
 
   run(`git -C "${CLONE_DIR}" config user.email "sync@raqim.app"`);