diff options
| author | Adam Soltys <[email protected]> | 2026-02-14 15:46:01 -0800 |
|---|---|---|
| committer | Adam Soltys <[email protected]> | 2026-02-14 15:46:01 -0800 |
| commit | 526b21bc668c453250ebce8dece9ba330bac0133 (patch) | |
| tree | 5e9c84a2cca6b4a5766c6cdc9f33f6c62f5776f3 /lib/migrate.ts | |
| parent | 843c343db567cd224dadf347ac16736bdc8b24a8 (diff) | |
| download | coinos-server-526b21bc668c453250ebce8dece9ba330bac0133.tar.gz coinos-server-526b21bc668c453250ebce8dece9ba330bac0133.zip | |
custodial ark sends
Diffstat (limited to 'lib/migrate.ts')
| -rw-r--r-- | lib/migrate.ts | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/lib/migrate.ts b/lib/migrate.ts index d0e38276..79f9546c 100644 --- a/lib/migrate.ts +++ b/lib/migrate.ts @@ -1,4 +1,4 @@ -import { db, g, s } from "$lib/db"; +import { db, g, s, scan } from "$lib/db"; import { findLastUsedIndex, parseDescriptor } from "$lib/esplora"; import { l, warn } from "$lib/logging"; import { @@ -64,7 +64,7 @@ export const migrateBalancesToTB = async () => { let count = 0; // Migrate balance:* keys - for await (const k of db.scanIterator({ MATCH: "balance:*" })) { + for await (const k of scan("balance:*")) { try { const id = k.split(":")[1]; const balance = Number.parseInt((await db.get(k)) || "0"); @@ -77,7 +77,7 @@ export const migrateBalancesToTB = async () => { } // Migrate pending:* keys - for await (const k of db.scanIterator({ MATCH: "pending:*" })) { + for await (const k of scan("pending:*")) { try { const id = k.split(":")[1]; const pending = Number.parseInt((await db.get(k)) || "0"); @@ -88,7 +88,7 @@ export const migrateBalancesToTB = async () => { } // Migrate credit:*:* keys - for await (const k of db.scanIterator({ MATCH: "credit:*:*" })) { + for await (const k of scan("credit:*:*")) { try { const parts = k.split(":"); const type = parts[1]; @@ -113,7 +113,7 @@ export const migrateToMicrosats = async () => { let count = 0; // Iterate through all users and multiply their TB balances - for await (const k of db.scanIterator({ MATCH: "user:*" })) { + for await (const k of scan("user:*")) { try { const raw = await db.get(k); if (!raw) continue; @@ -142,7 +142,7 @@ export const migrateAutowithdraw = async () => { let count = 0; - for await (const k of db.scanIterator({ MATCH: "user:*" })) { + for await (const k of scan("user:*")) { try { const raw = await db.get(k); if (!raw || !raw.startsWith("{")) continue; |
