diff options
| author | Adam Soltys <[email protected]> | 2024-01-15 17:01:26 +0000 |
|---|---|---|
| committer | Adam Soltys <[email protected]> | 2024-01-15 17:01:26 +0000 |
| commit | 3ff213f77f531e05ea14202b869838c30bdd75a4 (patch) | |
| tree | 32e28e17c7e2ea0871dce57b8e6f0d6354b07fc4 | |
| parent | c0c672ecd893389d68e4e7d8a417ab3c2035e3ad (diff) | |
| download | coinos-server-3ff213f77f531e05ea14202b869838c30bdd75a4.tar.gz coinos-server-3ff213f77f531e05ea14202b869838c30bdd75a4.zip | |
migrate lock
| -rw-r--r-- | lib/migrate.js | 9 |
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}`); |
