avoid duplicate invoices

1 files changed, 4 insertions, 5 deletions

diff --git a/lib/migrate.js b/lib/migrate.js
index 4aa137f8..106a6b5f 100644
--- a/lib/migrate.js
+++ b/lib/migrate.js
@@ -91,11 +91,10 @@ async function migrate(id) {
         let iid;
         while ((iid = await archive.rPop(`${id}:invoices`))) {
           let inv = await ga(`invoice:${iid}`);
-          if (!inv) continue;
-          await multi
-            .lPush(`${id}:invoices`, iid)
-            .set(`invoice:${iid}`, JSON.stringify(inv))
-            .exec();
+          let pos = await db.lPos(`${id}:invoices`, iid);
+            if (!inv || pos) continue;
+          await db.lPush(`${id}:invoices`, iid);
+          await s(`invoice:${iid}`, inv);
 
           await archive.del(`invoice:${iid}`);
         }