diff options
| author | Adam Soltys <[email protected]> | 2024-09-23 16:23:19 -0700 |
|---|---|---|
| committer | Adam Soltys <[email protected]> | 2024-09-23 16:23:19 -0700 |
| commit | 12ad5c9abb74cbe35c5d07233fdd9a7b7f5c2b70 (patch) | |
| tree | 8e023771abd75a7b70e407c651aed3bcfe426ea3 /lib/migrate.ts | |
| parent | 01e1686265def675445c0f74a4b92ec4ffd71492 (diff) | |
| download | coinos-server-12ad5c9abb74cbe35c5d07233fdd9a7b7f5c2b70.tar.gz coinos-server-12ad5c9abb74cbe35c5d07233fdd9a7b7f5c2b70.zip | |
reconcile on-chain balance
Diffstat (limited to 'lib/migrate.ts')
| -rw-r--r-- | lib/migrate.ts | 21 |
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}`); |
