diff options
| author | Adam Soltys <[email protected]> | 2020-03-11 15:10:40 -0700 |
|---|---|---|
| committer | Adam Soltys <[email protected]> | 2020-03-11 15:10:40 -0700 |
| commit | c0888fab024cc9f7c99812bfabf9d7774312dbf7 (patch) | |
| tree | cad95683af97432f6092a2c2bae10fbb7a588db5 /lightningPayments.js | |
| parent | bf2b51f0c2ae9b8f0f330dde6411e45fc0da8a25 (diff) | |
| download | coinos-server-c0888fab024cc9f7c99812bfabf9d7774312dbf7.tar.gz coinos-server-c0888fab024cc9f7c99812bfabf9d7774312dbf7.zip | |
refactor
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); -}; |
