From be2e1b629f02f5c1ab0b8ed5f0e59086308c84ab Mon Sep 17 00:00:00 2001
From: Kousthub Raja <kousthub.raja@gmail.com>
Date: Mon, 14 Mar 2022 14:05:47 +0530
Subject: [PATCH] delete unresponsive peer

---
 app/codes/updater.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/app/codes/updater.py b/app/codes/updater.py
index 58edd17..140975b 100644
--- a/app/codes/updater.py
+++ b/app/codes/updater.py
@@ -10,7 +10,7 @@
 from .minermanager import am_i_in_current_committee, broadcast_miner_update, get_miner_for_current_block, should_i_mine
 from ..nvalues import TREASURY_WALLET_ADDRESS
 from ..constants import ALLOWED_FEE_PAYMENT_TOKENS, BLOCK_RECEIVE_TIMEOUT_SECONDS, BLOCK_TIME_INTERVAL_SECONDS, IS_TEST, NEWRL_DB, NEWRL_PORT, NO_RECEIPT_COMMITTEE_TIMEOUT, REQUEST_TIMEOUT, MEMPOOL_PATH, TIME_BETWEEN_BLOCKS_SECONDS, TIME_MINER_BROADCAST_INTERVAL
-from .p2p.peers import get_peers
+from .p2p.peers import get_peers, remove_peer
 from .p2p.utils import is_my_address
 from .utils import BufferedLog, get_time_ms
 from .blockchain import Blockchain
@@ -164,6 +164,8 @@ def broadcast_block(block):
             # requests.post(url + '/receive-block', json={'block': block_payload}, timeout=REQUEST_TIMEOUT)
         except Exception as e:
             print(f'Error broadcasting block to peer: {url}')
+            print(f'Delete peer {peer}')
+            remove_peer(peer)
             print(e)
     return True