endpoint to get missed conversions

1 files changed, 34 insertions, 5 deletions

diff --git a/lib/sync.js b/lib/sync.js
index ba8d0a48..dd1ff9aa 100644
--- a/lib/sync.js
+++ b/lib/sync.js
@@ -48,17 +48,17 @@ const init = async () => {
   } catch (e) {
     console.log(e);
   }
+};
+
+init();
 
-  payments = (
+const sync = async () => {
+  const payments = (
     await db.Payment.findAll({
       attributes: ["hash"]
     })
   ).map(p => p.hash);
-};
-
-init();
 
-const sync = async () => {
   try {
     let { invoices } = await lnp.listInvoices({
       reversed: true,
@@ -271,3 +271,32 @@ const sync = async () => {
 
 setTimeout(sync, 5000);
 setInterval(sync, 720000);
+
+app.get(
+  "/conversions",
+  ah(async (req, res) => {
+
+    const transactions = [
+      ...(await bc.listTransactions("*", 500)),
+      ...(await lq.listTransactions("*", 500))
+    ].filter(tx => ["receive"].includes(tx.category));
+
+    const { addr } = req.query;
+    const { invoices } = require("./invoices");
+    const persist = require("./persist");
+    let conversions = persist("data/conversions.json");
+    const payments = (
+      await db.Payment.findAll({
+        attributes: ["hash"]
+      })
+    ).map(p => p.hash);
+    res.send(
+      Object.keys(conversions)
+        .filter(c => conversions[c].address === addr)
+        .filter(c => {
+          return invoices.find(i => i.payment_request === c && i.state === 'SETTLED') || transactions.find(tx => tx.txid === c)
+        })
+        .filter(c => !payments.includes(c))
+    );
+  })
+);