From 6510e2e72adc107fb6fb341c8dd4641f84586634 Mon Sep 17 00:00:00 2001 From: Adam Soltys Date: Tue, 10 Aug 2021 16:06:22 -0700 Subject: call webhook for internal transfers --- routes/bitcoin/receive.js | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) (limited to 'routes/bitcoin') diff --git a/routes/bitcoin/receive.js b/routes/bitcoin/receive.js index 603db47b..d9274935 100644 --- a/routes/bitcoin/receive.js +++ b/routes/bitcoin/receive.js @@ -126,17 +126,17 @@ zmqRawTx.on("message", async (topic, message, sequence) => { }); zmqRawBlock.on("message", async (topic, message, sequence) => { - const payments = await db.Payment.findAll({ - where: { confirmed: false }, - }); - - let block = bitcoin.Block.fromHex(message.toString("hex")); - block.transactions.map((tx) => { - let hash = reverse(tx.getHash()).toString("hex"); - if (payments.find((p) => p.hash === hash)) queue[hash] = 1; - }); + const payments = await db.Payment.findAll({ + where: { confirmed: false }, }); + let block = bitcoin.Block.fromHex(message.toString("hex")); + block.transactions.map((tx) => { + let hash = reverse(tx.getHash()).toString("hex"); + if (payments.find((p) => p.hash === hash)) queue[hash] = 1; + }); +}); + setInterval(async () => { try { const arr = Object.keys(queue); -- cgit v1.2.3