migrate script

1 files changed, 22 insertions, 7 deletions

diff --git a/lib/migrate.js b/lib/migrate.js
index e8ae5993..81743934 100644
--- a/lib/migrate.js
+++ b/lib/migrate.js
@@ -1,6 +1,8 @@
+import { types } from "$lib/payments";
 import { archive, db, g } from "$lib/db";
 
-export default async (id) => {
+let q = {};
+async function migrate(id) {
   let user = JSON.parse(await archive.get(`user:${id}`));
 
   if (typeof user === "string") {
@@ -14,11 +16,14 @@ export default async (id) => {
       .set(`user:${user.username}`, id)
       .set(`user:${user.pubkey}`, id)
       .set(`user:${id}`, JSON.stringify(user))
-        .set(`${id}:contacts`, await archive.get(`${id}:contacts`))
-      .set(`credit:bitcoin:${id}`, await archive.get(`credit:bitcoin:${id}`) || 0)
+      .set(`${id}:contacts`, await archive.get(`${id}:contacts`) || '[]')
+      .set(
+        `credit:bitcoin:${id}`,
+        (await archive.get(`credit:bitcoin:${id}`)) || 0,
+      )
       .set(
         `credit:lightning:${id}`,
-        await archive.get(`credit:lightning:${id}`) || 0,
+        (await archive.get(`credit:lightning:${id}`)) || 0,
       )
       .set(`${id}:lastlen`, (await archive.get(`${id}:lastlen`)) || 0)
       .set(`${id}:cindex`, (await archive.get(`${id}:cindex`)) || 0)
@@ -28,10 +33,15 @@ export default async (id) => {
     let payments = await archive.lRange(`${id}:payments`, 0, -1);
     await Promise.all(
       payments.map(async (pid) => {
-        let p = await archive.get(`payment:${pid}`);
+        let p = JSON.parse(await archive.get(`payment:${pid}`));
+        if (p.type === types.internal && p.ref) {
+          let recipient = await g(`user:${p.ref}`);
+          if (!recipient) q[p.ref] = true;
+        }
+
         multi = await multi
           .lPush(`${id}:payments`, pid)
-          .set(`payment:${pid}`, p);
+          .set(`payment:${pid}`, JSON.stringify(p));
       }),
     );
 
@@ -47,6 +57,11 @@ export default async (id) => {
 
     await multi.exec();
 
+    delete q[id];
+    await migrate(Object.keys(q)[0]);
+
     return user;
   }
-};
+}
+
+export default migrate;