fix queuing

1 files changed, 5 insertions, 5 deletions

diff --git a/lib/migrate.js b/lib/migrate.js
index 4a44ea87..4aa137f8 100644
--- a/lib/migrate.js
+++ b/lib/migrate.js
@@ -7,6 +7,7 @@ let queued = {};
 let migrating = {};
 async function migrate(id) {
   try {
+    delete queued[id];
     if (id) id = id.replace(/\s/g, "").toLowerCase();
 
     let user = await g(`user:${id}`);
@@ -80,10 +81,8 @@ async function migrate(id) {
             if (!recipient) queued[p.ref] = true;
           }
 
-          await multi
-            .lPush(`${id}:payments`, pid)
-            .set(`payment:${pid}`, JSON.stringify(p))
-            .exec();
+          await db.lPush(`${id}:payments`, pid);
+          await s(`payment:${pid}`, p);
 
           await archive.del(`payment:${pid}`);
         }
@@ -119,7 +118,8 @@ async function migrate(id) {
 let keepMigrating = async () => {
   try {
     if (Object.keys(queued).length) {
-      await migrate(Object.keys(queued)[0]);
+      let next = Object.keys(queued)[0];
+      await migrate(next);
     }
   } catch (e) {
     err("problem migrating", e.message);