remove cancelled ln payments

1 files changed, 26 insertions, 2 deletions

diff --git a/lib/sync.js b/lib/sync.js
index 536bd582..57f0c507 100644
--- a/lib/sync.js
+++ b/lib/sync.js
@@ -75,12 +75,14 @@ const sync = async () => {
       ]
     });
 
-    let { invoices } = await getInvoices({ lnd, limit: 200 });
+    let { invoices } = await getInvoices({ lnd, limit: 1000 });
+    let x = invoices.find(i => i.request.includes('lnbc10100u1p333l3lpp5znwsrpr9g'));
+    let cancelled = invoices.filter(i => i.is_canceled);
 
     let recent = invoices
       .filter(
         i =>
-          i.secret &&
+          i.is_confirmed &&
           differenceInDays(new Date(), new Date(i.created_at)) < 2
       )
       .map(i => ({
@@ -98,6 +100,28 @@ const sync = async () => {
       })
     ).map(p => p.preimage);
 
+    for (let i = 0; i < cancelled.length; i++) {
+      let c = cancelled[i];
+      if (settled.includes(c.secret)) {
+        await db.transaction(async transaction => {
+          let p = await db.Payment.findOne({
+            where: {
+              preimage: c.secret
+            },
+            include: {
+              model: db.Account,
+              as: "account"
+            },
+            transaction
+          }); 
+
+          console.log("destroying", p.id);
+          await p.account.decrement({ balance: p.amount }, { transaction });
+          await p.destroy({ transaction });
+        });
+      }
+    } 
+
     let missed = recent.filter(i => !settled.includes(i.preimage));
     for (let i = 0; i < missed.length; i++) {
       let { amount, preimage, pr: text, createdAt } = missed[i];