From c0c672ecd893389d68e4e7d8a417ab3c2035e3ad Mon Sep 17 00:00:00 2001
From: Adam Soltys <asoltys@gmail.com>
Date: Mon, 15 Jan 2024 16:50:19 +0000
Subject: migrate lock

---
 lib/migrate.js | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

(limited to 'lib/migrate.js')

diff --git a/lib/migrate.js b/lib/migrate.js
index ef15c738..ecadbfc2 100644
--- a/lib/migrate.js
+++ b/lib/migrate.js
@@ -3,7 +3,11 @@ import { types } from "$lib/payments";
 import { archive, db, g, ga, s } from "$lib/db";
 
 let q = {};
+let inProgress = {};
 async function migrate(id) {
+  delete q[id];
+  if (inProgress[id]) return;
+  inProgress[id] = true;
   if (id) id = id.replace(/\s/g, "").toLowerCase();
   let user = await g(`user:${id}`);
   if (typeof user === "string") user = await g(`user:${user}`);
@@ -96,10 +100,10 @@ async function migrate(id) {
       warn("failed to migrate", username, e.message, line());
     }
 
-    delete q[id];
-
     return user;
   }
+
+  delete inProgress[id];
 }
 
 let keepMigrating = async () => {
-- 
cgit v1.2.3