diff options
Diffstat (limited to 'lib/migrate.js')
| -rw-r--r-- | lib/migrate.js | 8 |
1 files changed, 6 insertions, 2 deletions
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 () => { |