1 files changed, 5 insertions, 2 deletions
diff --git a/lib/payments.ts b/lib/payments.ts
index 705245e8..a073bec7 100644
--- a/lib/payments.ts
+++ b/lib/payments.ts
@@ -512,6 +512,7 @@ export let sendLightning = async ({
   if (pays.find((p) => p.status === "pending"))
     fail("Payment is already underway");
 
+  await db.sAdd("pending", pr);
   p = await debit({
     hash: pr,
     amount: total,
@@ -533,8 +534,10 @@ export let sendLightning = async ({
     });
 
     try {
-      if (r.status === "complete") p = await finalize(r, p);
-      else await db.sAdd("pending", pr);
+      if (r.status === "complete") {
+        p = await finalize(r, p);
+        await db.sRem("pending", pr);
+      }
     } catch (e) {
       console.log("failed to process payment", e, p);
     }