From 471de1021747e679740654165c2c8568a9b0e93a Mon Sep 17 00:00:00 2001 From: Adam Soltys Date: Tue, 5 Mar 2024 19:45:08 -0800 Subject: avoid duplicate invoices --- lib/migrate.js | 9 ++++----- 1 file 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}`); } -- cgit v1.2.3