From da2ffb000ede4972052fec69480caee57481cc09 Mon Sep 17 00:00:00 2001 From: Victor Shyba Date: Mon, 25 Jul 2022 09:27:45 -0300 Subject: [PATCH] skip peers with bad ports without raising --- scripts/dht_crawler.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/scripts/dht_crawler.py b/scripts/dht_crawler.py index 3345a6852..a2f34d11b 100644 --- a/scripts/dht_crawler.py +++ b/scripts/dht_crawler.py @@ -206,8 +206,12 @@ class Crawler: self.probed_streams_metric.labels("global").inc() if response and response.found: self.announced_streams_metric.labels("global").inc() - blob_peers = [decode_tcp_peer_from_compact_address(compact_addr) - for compact_addr in response.found_compact_addresses] + blob_peers = [] + for compact_addr in response.found_compact_addresses: + try: + blob_peers.append(decode_tcp_peer_from_compact_address(compact_addr)) + except ValueError as e: + log.error("Error decoding compact peers: %s", e) for blob_peer in blob_peers: response = await self.request_peers(blob_peer.address, blob_peer.tcp_port, blob_peer.node_id, sd_hash) if response: