From 0b5490845192768c5fe47610e24c41a80561e822 Mon Sep 17 00:00:00 2001 From: Adam Soltys Date: Wed, 2 Oct 2024 06:41:17 +0000 Subject: fix payment check --- lib/payments.ts | 25 +++++++++++++++---------- 1 file changed, 15 insertions(+), 10 deletions(-) (limited to 'lib') 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) => { -- cgit v1.2.3