1 files changed, 38 insertions, 34 deletions
diff --git a/lib/sync.js b/lib/sync.js
index ab1e81f0..1a98c121 100644
--- a/lib/sync.js
+++ b/lib/sync.js
@@ -1,7 +1,9 @@
-import { differenceInDays } from 'date-fns';
-import fs from 'fs';
-import read from '../lib/read.js';
-import { Op } from 'sequelize';
+import db from "../db/index.js";
+import app from "../app.js";
+import { differenceInDays } from "date-fns";
+import fs from "fs";
+import read from "../lib/read.js";
+import { Op } from "@sequelize/core";
 
 const init = async () => {
   try {
@@ -134,7 +136,12 @@ const sync = async () => {
           }
         }
       } catch (e) {
-        l.error("problem syncing lightning payment", JSON.stringify(missed[i]), e.message, e.stack);
+        l.error(
+          "problem syncing lightning payment",
+          JSON.stringify(missed[i]),
+          e.message,
+          e.stack
+        );
       }
     }
 
@@ -311,34 +318,31 @@ const sync = async () => {
 
 setTimeout(sync, 5000);
 
-app.get(
-  "/conversions",
-  ah(async (req, res) => {
-    const transactions = [
-      ...(await bc.listTransactions("*", 500)),
-      ...(await lq.listTransactions("*", 500))
-    ].filter(tx => ["receive"].includes(tx.category));
+app.get("/conversions", 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"]
+  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)
+        );
       })
-    ).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))
-    );
-  })
-);
+      .filter(c => !payments.includes(c))
+  );
+});