diff options
| author | Adam Soltys <[email protected]> | 2024-10-02 06:41:17 +0000 |
|---|---|---|
| committer | Adam Soltys <[email protected]> | 2024-10-02 06:41:17 +0000 |
| commit | 0b5490845192768c5fe47610e24c41a80561e822 (patch) | |
| tree | 316fe663fb53e45ebbe4080ac94bbffe6c8f0fad /lib | |
| parent | a59d10ef183d2f40772f231116890c13b235fbb2 (diff) | |
| download | coinos-server-0b5490845192768c5fe47610e24c41a80561e822.tar.gz coinos-server-0b5490845192768c5fe47610e24c41a80561e822.zip | |
fix payment check
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/payments.ts | 25 |
1 files changed, 15 insertions, 10 deletions
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) => { |
