Add typehints

src/blockperf/app.py

@@ -27,14 +27,14 @@ class App:
     start_time: int
 
     # holds a dictionairy for each kind of events for each block_hash
-    logevents = {}
+    logevents: dict = {}
     # the list of all published hashes, to not publish a hash twice
-    published_blocks = []
+    published_blocks: list = []
     # Stores the last X hashes before they are deleted from logevents and published_blocks
-    working_hashes = collections.deque()
+    working_hashes: collections.deque = collections.deque()
 
     def __init__(self, config: AppConfig) -> None:
-        self.q = queue.Queue(maxsize=50)
+        self.q: queue.Queue = queue.Queue(maxsize=50)
         self.app_config = config
         self.start_time = int(datetime.now().timestamp())
 
@@ -352,7 +352,7 @@ def logevents_logfile(self):
                         break
 
                     # Yield all events
-                    logger.debug(f"Found {len(logevents)} logevents")
+                    # logger.debug(f"Found {len(logevents)} logevents")
                     yield from logevents
 
                     # If no new_lines are returned check if the symlink changed

src/blockperf/blocksample.py

@@ -74,7 +74,7 @@ class BlockSample:
                               # Take deltaq.G from that FetchRequest
     """
 
-    trace_events = list()
+    trace_events: list = []
 
     def __init__(self, events: list) -> None:
         """Creates LogEvent and orders the events by at field"""

src/blockperf/mqtt.py

@@ -50,12 +50,12 @@ def on_connect(self, client, userdata, flags, reasonCode, properties):
     def on_connect_fail(self, client, obj):
         logger.warning("Connection Failed")
 
-    def on_disconnect(self, client, userdata, reasonCode, properties) -> None:
+    def on_disconnect(self, client, userdata, reasonCode, properties) -> None:  # type: ignore
         """Called when disconnected from broker
         See paho.mqtt.client.py on_disconnect()"""
         logger.warning("Connection disconnected %s", reasonCode)
 
-    def on_publish(self, client, userdata, mid) -> None:
+    def on_publish(self, client, userdata, mid) -> None:  # type: ignore
         """Called when a message is actually received by the broker.
         See paho.mqtt.client.py on_publish()"""
         # There should be a way to know which messages belongs to which
@@ -74,7 +74,7 @@ def __on_log(self, client, userdata, level, buf):
         """
         logger.debug("%s - %s", level, buf)
 
-    def publish(self, topic: str, payload: dict):
+    def publish(self, topic: str, payload: dict):  # type: ignore
         """
 
         MQTTClient publish: