aboutsummaryrefslogtreecommitdiffstats
path: root/routes/bitcoin/receive.js
diff options
context:
space:
mode:
authorDerrick <[email protected]>2021-07-09 14:25:51 -0600
committerDerrick <[email protected]>2021-07-09 14:25:51 -0600
commitbf37962b00b323c412c2ea89bf60d24fbe4aa87b (patch)
tree70ca171462fa40108495542c1b02c9844200859e /routes/bitcoin/receive.js
parentd7ef5e9ab7c6e04267bd1797466add8f57673598 (diff)
parent4bde8faf1b9d91898447bdf2c63b0afd227f978c (diff)
downloadcoinos-server-masterZ.tar.gz
coinos-server-masterZ.zip
Merge branch 'master' into masterZmasterZ
Diffstat (limited to 'routes/bitcoin/receive.js')
-rw-r--r--routes/bitcoin/receive.js21
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);
}