fix payment check

3 files changed, 16 insertions, 11 deletions

diff --git a/.gitignore b/.gitignore
index 15957b79..f4b1ed6a 100644
--- a/.gitignore
+++ b/.gitignore
@@ -11,3 +11,4 @@ watcher.sh
 *.js
 routes/**/*.js
 lib/**/*.js
+watcher.log
diff --git a/lib/payments.ts b/lib/payments.ts
index 1f67bb1f..c34a4739 100644
--- a/lib/payments.ts
+++ b/lib/payments.ts
@@ -768,21 +768,26 @@ export let reconcile = async (account, initial = false) => {
 };
 
 export let check = async () => {
-  let payments = await db.sMembers("pending");
+  try {
+    let payments = await db.sMembers("pending");
 
-  for (let pr of payments) {
-    let p = await getPayment(pr);
-    if (!p) continue;
-    let { pays } = await ln.listpays(pr);
+    for (let pr of payments) {
+      let p = await getPayment(pr);
+      if (!p) continue;
+      let { pays } = await ln.listpays(pr);
 
-    let failed = !pays.length || pays.every((p) => p.status === "failed");
-    let completed = pays.find((p) => p.status === "complete");
+      let failed = !pays.length || pays.every((p) => p.status === "failed");
+      let completed = pays.find((p) => p.status === "complete");
 
-    if (completed) await finalize(completed, p);
-    else if (failed) await reverse(p);
+      if (completed) await finalize(completed, p);
+      else if (failed) await reverse(p);
 
-    setTimeout(check, 2000);
+    }
+  } catch(e) {
+    console.log("payment check failed", e);
   }
+
+  setTimeout(check, 2000);
 };
 
 let finalize = async (r, p) => {
diff --git a/routes/payments.ts b/routes/payments.ts
index ec646c59..d8213e2a 100644
--- a/routes/payments.ts
+++ b/routes/payments.ts
@@ -72,7 +72,6 @@ export default {
 
       res.send(p);
     } catch (e) {
-      console.log(e);
       warn(user.username, "payment failed", amount, balance, hash, payreq);
       err(e.message);
       bail(res, e.message);