diff --git a/src/sakia/data/connectors/bma.py b/src/sakia/data/connectors/bma.py index 090164cc35476e47bfa2ba26e37bfcd3f6dcde9e..e6721bb87bf707147b6a85cad4e976b4763541b5 100644 --- a/src/sakia/data/connectors/bma.py +++ b/src/sakia/data/connectors/bma.py @@ -215,7 +215,7 @@ class BmaConnector: else: answers[data_hash].append(node) finally: - session.close() + await session.close() if len(answers_data) > 0: if request is bma.wot.lookup: diff --git a/src/sakia/services/network.py b/src/sakia/services/network.py index 7645013d2f9aeac8370cca1010106c57139747f4..8599f223b685626d4c2b890acfc900feae6a0904 100644 --- a/src/sakia/services/network.py +++ b/src/sakia/services/network.py @@ -3,7 +3,7 @@ import logging import time from collections import Counter -from PyQt5.QtCore import pyqtSignal, pyqtSlot, QObject +from PyQt5.QtCore import pyqtSignal, pyqtSlot, QObject, Qt from duniterpy.api import errors from duniterpy.key import VerifyingKey from sakia.data.connectors import NodeConnector @@ -167,10 +167,10 @@ class NetworkService(QObject): Add a nod to the network. """ self._connectors.append(node_connector) - node_connector.changed.connect(self.handle_change) - node_connector.error.connect(self.handle_error) - node_connector.identity_changed.connect(self.handle_identity_change) - node_connector.neighbour_found.connect(self.handle_new_node) + node_connector.changed.connect(self.handle_change, type=Qt.UniqueConnection|Qt.QueuedConnection) + node_connector.error.connect(self.handle_error, type=Qt.UniqueConnection|Qt.QueuedConnection) + node_connector.identity_changed.connect(self.handle_identity_change, type=Qt.UniqueConnection|Qt.QueuedConnection) + node_connector.neighbour_found.connect(self.handle_new_node, type=Qt.UniqueConnection|Qt.QueuedConnection) self._logger.debug("{:} connected".format(node_connector.node.pubkey[:5])) @asyncify