diff options
Diffstat (limited to 'lightningPayments.js')
| -rw-r--r-- | lightningPayments.js | 38 |
1 files changed, 0 insertions, 38 deletions
diff --git a/lightningPayments.js b/lightningPayments.js deleted file mode 100644 index 096655bf..00000000 --- a/lightningPayments.js +++ /dev/null @@ -1,38 +0,0 @@ -const l = require("pino")(); - -module.exports = (app, db, lna, lnb, emit, payments) => { - const handlePayment = async msg => { - if (!msg.settled) return; - - let payment = await db.Payment.findOne({ - include: { model: db.User, as: "user" }, - where: { - hash: msg.payment_request - } - }); - - if (!payment) return; - - const { user } = payment; - - payment.received = true; - user.balance += parseInt(msg.value); - payment.rate = app.get("rates")[user.currency]; - payment.confirmed = true; - payment.currency = user.currency; - - await payment.save(); - await user.save(); - payments.push(msg.payment_request); - l.info("lightning payment received", user.username, payment.amount); - - emit(user.username, "payment", payment); - emit(user.username, "user", user); - }; - - const invoices = lna.subscribeInvoices({}); - invoices.on("data", handlePayment); - - const invoicesb = lnb.subscribeInvoices({}); - invoicesb.on("data", handlePayment); -}; |
