aboutsummaryrefslogtreecommitdiffstats
path: root/lib/migrate.js
diff options
context:
space:
mode:
authorAdam Soltys <[email protected]>2024-08-16 14:27:56 -0700
committerAdam Soltys <[email protected]>2024-08-16 14:27:56 -0700
commitf8cfd7e189c62c6325a126df1dda3b24cb1bbc36 (patch)
tree08d12f40589b3675ddb0453d586b83a79ac68691 /lib/migrate.js
parente17a531ce983a3e2fcc233a606b9b3678e22266a (diff)
downloadcoinos-server-f8cfd7e189c62c6325a126df1dda3b24cb1bbc36.tar.gz
coinos-server-f8cfd7e189c62c6325a126df1dda3b24cb1bbc36.zip
transfer ecash
Diffstat (limited to 'lib/migrate.js')
-rw-r--r--lib/migrate.js4
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);