aboutsummaryrefslogtreecommitdiffstats
path: root/lib/migrate.ts
diff options
context:
space:
mode:
authorAdam Soltys <[email protected]>2024-09-23 16:23:19 -0700
committerAdam Soltys <[email protected]>2024-09-23 16:23:19 -0700
commit12ad5c9abb74cbe35c5d07233fdd9a7b7f5c2b70 (patch)
tree8e023771abd75a7b70e407c651aed3bcfe426ea3 /lib/migrate.ts
parent01e1686265def675445c0f74a4b92ec4ffd71492 (diff)
downloadcoinos-server-12ad5c9abb74cbe35c5d07233fdd9a7b7f5c2b70.tar.gz
coinos-server-12ad5c9abb74cbe35c5d07233fdd9a7b7f5c2b70.zip
reconcile on-chain balance
Diffstat (limited to 'lib/migrate.ts')
-rw-r--r--lib/migrate.ts21
1 files changed, 1 insertions, 20 deletions
diff --git a/lib/migrate.ts b/lib/migrate.ts
index d26c8581..1ff280ea 100644
--- a/lib/migrate.ts
+++ b/lib/migrate.ts
@@ -12,26 +12,7 @@ async function migrate(id) {
let user = await g(`user:${id}`);
if (typeof user === "string") user = await g(`user:${user}`);
-
- if (user) {
- let k = `lock:${user.id}:accounts`;
- const lock = await db.set(k, "1", { NX: true, PX: 5000 });
- if (!lock) return user;
- try {
- let accounts = await db.lLen(`${user.id}:accounts`);
-
- if (!accounts) {
- await db.set(
- `account:${user.id}`,
- JSON.stringify({ id: user.id, name: "Cash", type: types.ecash }),
- );
- await db.lPush(`${user.id}:accounts`, user.id);
- }
- return user;
- } finally {
- await db.del(k);
- }
- }
+ if (user) return user;
user = await ga(`user:${id}`);