aboutsummaryrefslogtreecommitdiffstats
path: root/lib
diff options
context:
space:
mode:
authorAdam Soltys <[email protected]>2024-10-02 06:41:17 +0000
committerAdam Soltys <[email protected]>2024-10-02 06:41:17 +0000
commit0b5490845192768c5fe47610e24c41a80561e822 (patch)
tree316fe663fb53e45ebbe4080ac94bbffe6c8f0fad /lib
parenta59d10ef183d2f40772f231116890c13b235fbb2 (diff)
downloadcoinos-server-0b5490845192768c5fe47610e24c41a80561e822.tar.gz
coinos-server-0b5490845192768c5fe47610e24c41a80561e822.zip
fix payment check
Diffstat (limited to 'lib')
-rw-r--r--lib/payments.ts25
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) => {