From c1641e80d3dc113e4adbc48c1bc8e54a5fd68f7c Mon Sep 17 00:00:00 2001
From: Adam Soltys <asoltys@gmail.com>
Date: Tue, 5 Mar 2024 15:12:55 -0800
Subject: locks

---
 lib/migrate.js | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

(limited to 'lib/migrate.js')

diff --git a/lib/migrate.js b/lib/migrate.js
index 1425cbac..38520ee9 100644
--- a/lib/migrate.js
+++ b/lib/migrate.js
@@ -6,14 +6,13 @@ import { wait } from "$lib/utils";
 let queued = {};
 let migrating = {};
 async function migrate(id) {
+  try {
   if (id) id = id.replace(/\s/g, "").toLowerCase();
 
   let user = await g(`user:${id}`);
   if (typeof user === "string") user = await g(`user:${user}`);
-  if (user) {
-    delete migrating[id];
-    return user;
-  }
+    if (user) return user;
+
 
   user = await ga(`user:${id}`);
 
@@ -108,6 +107,10 @@ async function migrate(id) {
     delete migrating[id];
     return user;
   }
+  } catch(e) {
+    delete migrating[id];
+    throw e;
+  }
 }
 
 let keepMigrating = async () => {
-- 
cgit v1.2.3