locks

1 files changed, 7 insertions, 4 deletions

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 () => {