diff options
| author | Adam Soltys <[email protected]> | 2024-08-16 14:27:56 -0700 |
|---|---|---|
| committer | Adam Soltys <[email protected]> | 2024-08-16 14:27:56 -0700 |
| commit | f8cfd7e189c62c6325a126df1dda3b24cb1bbc36 (patch) | |
| tree | 08d12f40589b3675ddb0453d586b83a79ac68691 /lib/migrate.js | |
| parent | e17a531ce983a3e2fcc233a606b9b3678e22266a (diff) | |
| download | coinos-server-f8cfd7e189c62c6325a126df1dda3b24cb1bbc36.tar.gz coinos-server-f8cfd7e189c62c6325a126df1dda3b24cb1bbc36.zip | |
transfer ecash
Diffstat (limited to 'lib/migrate.js')
| -rw-r--r-- | lib/migrate.js | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/lib/migrate.js b/lib/migrate.js index 15ce4a16..cee5e946 100644 --- a/lib/migrate.js +++ b/lib/migrate.js @@ -5,6 +5,7 @@ import { wait } from "$lib/utils"; let queued = {}; let migrating = {}; + async function migrate(id) { try { delete queued[id]; @@ -12,6 +13,7 @@ async function migrate(id) { let user = await g(`user:${id}`); if (typeof user === "string") user = await g(`user:${user}`); + if (user) return user; user = await ga(`user:${id}`); @@ -92,7 +94,7 @@ async function migrate(id) { while ((iid = await archive.rPop(`${id}:invoices`))) { let inv = await ga(`invoice:${iid}`); let pos = await db.lPos(`${id}:invoices`, iid); - if (!inv || pos) continue; + if (!inv || pos) continue; await db.lPush(`${id}:invoices`, iid); await s(`invoice:${iid}`, inv); |
