From 7f427d1c9e229bfd70e913db451a873ce561b8db Mon Sep 17 00:00:00 2001
From: Adam Soltys <asoltys@gmail.com>
Date: Fri, 6 Aug 2021 14:58:01 -0700
Subject: fix zmq 6 syntax

---
 routes/bitcoin/receive.js | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

(limited to 'routes/bitcoin')

diff --git a/routes/bitcoin/receive.js b/routes/bitcoin/receive.js
index 572987cc..2e8114dd 100644
--- a/routes/bitcoin/receive.js
+++ b/routes/bitcoin/receive.js
@@ -7,7 +7,7 @@ const bitcoin = require("bitcoinjs-lib");
 
 const zmqRawBlock = new zmq.Subscriber();
 zmqRawBlock.connect(config.bitcoin.zmqrawblock);
-zmqRawBlock.subscribe("rawtx");
+zmqRawBlock.subscribe("rawblock");
 
 const zmqRawTx = new zmq.Subscriber();
 zmqRawTx.connect(config.bitcoin.zmqrawtx);
@@ -18,7 +18,7 @@ const network =
     config.bitcoin.network === "mainnet" ? "bitcoin" : config.bitcoin.network
   ];
 
-let queue = {};
+const queue = {};
 
 (async () => {
   for await (const [topic, message] of zmqRawTx) {
@@ -127,7 +127,9 @@ let queue = {};
       })
     );
   }
+})();
 
+(async () => {
   for await (const [topic, message] of zmqRawBlock) {
     const payments = await db.Payment.findAll({
       where: { confirmed: false },
-- 
cgit v1.2.3