diff options
| author | Derrick <[email protected]> | 2021-07-09 14:25:51 -0600 |
|---|---|---|
| committer | Derrick <[email protected]> | 2021-07-09 14:25:51 -0600 |
| commit | bf37962b00b323c412c2ea89bf60d24fbe4aa87b (patch) | |
| tree | 70ca171462fa40108495542c1b02c9844200859e /routes/bitcoin | |
| parent | d7ef5e9ab7c6e04267bd1797466add8f57673598 (diff) | |
| parent | 4bde8faf1b9d91898447bdf2c63b0afd227f978c (diff) | |
| download | coinos-server-masterZ.tar.gz coinos-server-masterZ.zip | |
Merge branch 'master' into masterZmasterZ
Diffstat (limited to 'routes/bitcoin')
| -rw-r--r-- | routes/bitcoin/receive.js | 21 |
1 files changed, 6 insertions, 15 deletions
diff --git a/routes/bitcoin/receive.js b/routes/bitcoin/receive.js index 45199976..d782627d 100644 --- a/routes/bitcoin/receive.js +++ b/routes/bitcoin/receive.js @@ -2,9 +2,6 @@ const reverse = require("buffer-reverse"); const zmq = require("zeromq/v5-compat"); const { Op } = require("sequelize"); const { fromBase58 } = require("bip32"); -const wretch = require("wretch"); -const fetch = require("node-fetch"); -wretch().polyfills({ fetch }); const bitcoin = require("bitcoinjs-lib"); @@ -117,6 +114,7 @@ zmqRawTx.on("message", async (topic, message, sequence) => { emit(user.username, "payment", payment); l.info("bitcoin detected", user.username, value); notify(user, `${value} SAT payment detected`); + await callWebhook(invoice, payment); } } catch (e) { console.log(e); @@ -155,26 +153,18 @@ setInterval(async () => { as: "account" }, { - model: db.User, - as: "user" - }, - { model: db.Invoice, as: "invoice" + }, + { + model: db.User, + as: "user" } ], lock: transaction.LOCK.UPDATE, transaction }); - if (p.invoice && p.invoice.webhook) { - l.info("calling webhook", p.invoice.webhook); - console.log(await wretch() - .url(p.invoice.webhook) - .post({ oh: "yeah" }) - .json()); - } - if (p && p.address) address = p.address; if (p && p.user) user = p.user; @@ -199,6 +189,7 @@ setInterval(async () => { emit(user.username, "payment", p); l.info("bitcoin confirmed", user.username, p.amount, p.tip); notify(user, `${total} SAT payment confirmed`); + await callWebhook(p.invoice, p); } else { l.warn("couldn't find bitcoin payment", hash); } |
