fix reverse

2 files changed, 2 insertions, 5 deletions

diff --git a/lib/db.ts b/lib/db.ts
index 50c78e85..053ecefb 100644
--- a/lib/db.ts
+++ b/lib/db.ts
@@ -38,7 +38,7 @@ local pid = KEYS[6]
 local total = tonumber(ARGV[1])
 local credit = tonumber(ARGV[2])
 
-local payment = cjson.decode(redis.call('get', paymentKey))
+local payment = redis.call('get', paymentKey)
 
 if payment ~= nil then
   redis.call('incrby', balanceKey, total)
diff --git a/lib/payments.ts b/lib/payments.ts
index aeb16aa3..b01c926c 100644
--- a/lib/payments.ts
+++ b/lib/payments.ts
@@ -1,6 +1,5 @@
 import config from "$config";
 import { generate } from "$lib/invoices";
-import { emit } from "$lib/sockets";
 import { v4 } from "uuid";
 import { notify } from "$lib/notifications";
 import { db, g, s } from "$lib/db";
@@ -257,11 +256,10 @@ export let completePayment = async (inv, p, user) => {
       }
     }
 
-    notify(p, user, withdrawal);
   }
 
+  notify(p, user, withdrawal);
   l(username, "received", p.type, p.amount);
-  emit(user.id, "payment", p);
   callWebhook(inv, p);
 };
 
@@ -486,7 +484,6 @@ export let sendLightning = async ({
       console.log("failed to process payment", e, p);
     }
   } catch (e) {
-    await reverse(p);
     throw e;
   }