aboutsummaryrefslogtreecommitdiffstats
path: root/lib
diff options
context:
space:
mode:
authorAdam Soltys <[email protected]>2024-01-15 17:01:26 +0000
committerAdam Soltys <[email protected]>2024-01-15 17:01:26 +0000
commit3ff213f77f531e05ea14202b869838c30bdd75a4 (patch)
tree32e28e17c7e2ea0871dce57b8e6f0d6354b07fc4 /lib
parentc0c672ecd893389d68e4e7d8a417ab3c2035e3ad (diff)
downloadcoinos-server-3ff213f77f531e05ea14202b869838c30bdd75a4.tar.gz
coinos-server-3ff213f77f531e05ea14202b869838c30bdd75a4.zip
migrate lock
Diffstat (limited to 'lib')
-rw-r--r--lib/migrate.js9
1 files changed, 7 insertions, 2 deletions
diff --git a/lib/migrate.js b/lib/migrate.js
index ecadbfc2..1585aced 100644
--- a/lib/migrate.js
+++ b/lib/migrate.js
@@ -5,13 +5,18 @@ import { archive, db, g, ga, s } from "$lib/db";
let q = {};
let inProgress = {};
async function migrate(id) {
+ if (id) id = id.replace(/\s/g, "").toLowerCase();
+
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}`);
- if (user) return user;
+ if (user) {
+ delete inProgress[id];
+ return user;
+ }
user = await ga(`user:${id}`);