Merge pull request #118 from HathorNetwork/dev

Release v0.1.17

package.json

@@ -1,6 +1,6 @@
 {
   "name": "hathor-explorer-service",
-  "version": "0.1.16",
+  "version": "0.1.17",
   "description": "Hathor Explorer Service Serverless deps",
   "dependencies": {
     "serverless": "^2.44.0",

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "hathor-explorer-service"
-version = "0.1.16"
+version = "0.1.17"
 description = ""
 authors = ["Hathor Labs <[email protected]>"]
 license = "MIT"

tests/unit/usecases/test_collect_nodes_statuses.py

@@ -22,6 +22,11 @@ def node_gateway(self):
     @patch('usecases.collect_nodes_statuses.HATHOR_NODES', ['a', 'b'])
     async def test_collect(self, node_gateway):
         node = Node.from_status_dict(HATHOR_CORE_MAINNET_GET_STATUS)
+        # XXX: filtering known_peers based on connected_peers
+        connected_peer_ids = map(lambda p: p.id, node.connected_peers)
+        node.known_peers = [
+            peer_id for peer_id in connected_peer_ids if peer_id in node.known_peers
+        ]
 
         node_gateway.get_node_status_async = AsyncMock(side_effect=lambda x: x(HATHOR_CORE_MAINNET_GET_STATUS))
         with patch.object(NodeGateway, 'get_node_status_async', new=node_gateway.get_node_status_async):

usecases/collect_nodes_statuses.py

@@ -29,4 +29,11 @@ def _send(self, data: dict) -> None:
             self.log.warning("collect_status_error", error=data['error'])
             return
         node = Node.from_status_dict(data)
+        # XXX: https://github.com/HathorNetwork/internal-issues/issues/73
+        # A big enough known_peers list can reach the limit of data passed to a lambda.
+        # This filters the unnecessary peer ids.
+        connected_peer_ids = map(lambda p: p.id, node.connected_peers)
+        node.known_peers = [
+            peer_id for peer_id in connected_peer_ids if peer_id in node.known_peers
+        ]
         self.node_gateway.send_node_to_data_aggregator(node)