From 4f000298fae662f8c0bdec7735ed407d6341f573 Mon Sep 17 00:00:00 2001
From: Sergi Delgado Segura <sergi.delgado.s@gmail.com>
Date: Fri, 31 Jan 2020 13:11:59 +0100
Subject: [PATCH] Removes zmq_subscriber

The ZMQSubscriber was merged into the ChainMonitor but never deleted
---
 pisa/utils/zmq_subscriber.py | 36 ------------------------------------
 1 file changed, 36 deletions(-)
 delete mode 100644 pisa/utils/zmq_subscriber.py

diff --git a/pisa/utils/zmq_subscriber.py b/pisa/utils/zmq_subscriber.py
deleted file mode 100644
index 5bf29f5..0000000
--- a/pisa/utils/zmq_subscriber.py
+++ /dev/null
@@ -1,36 +0,0 @@
-import zmq
-import binascii
-from common.logger import Logger
-from pisa.conf import FEED_PROTOCOL, FEED_ADDR, FEED_PORT
-
-
-# ToDo: #7-add-async-back-to-zmq
-class ZMQSubscriber:
-    """ Adapted from https://github.com/bitcoin/bitcoin/blob/master/contrib/zmq/zmq_sub.py"""
-
-    def __init__(self, config, parent):
-        self.zmqContext = zmq.Context()
-        self.zmqSubSocket = self.zmqContext.socket(zmq.SUB)
-        self.zmqSubSocket.setsockopt(zmq.RCVHWM, 0)
-        self.zmqSubSocket.setsockopt_string(zmq.SUBSCRIBE, "hashblock")
-        self.zmqSubSocket.connect(
-            "%s://%s:%s" % (config.get("FEED_PROTOCOL"), config.get("FEED_ADDR"), config.get("FEED_PORT"))
-        )
-        self.logger = Logger("ZMQSubscriber-{}".format(parent))
-
-        self.terminate = False
-
-    def handle(self, block_queue):
-        while not self.terminate:
-            msg = self.zmqSubSocket.recv_multipart()
-
-            # Terminate could have been set wile the thread was blocked in recv
-            if not self.terminate:
-                topic = msg[0]
-                body = msg[1]
-
-                if topic == b"hashblock":
-                    block_hash = binascii.hexlify(body).decode("utf-8")
-                    block_queue.put(block_hash)
-
-                    self.logger.info("New block received via ZMQ", block_hash=block_hash)