From ed16492a753e8b4106dfeeea0c21cb3f4f1f595a Mon Sep 17 00:00:00 2001 From: Jonathan Zernik Date: Tue, 12 Jan 2021 14:05:36 -0800 Subject: [PATCH] Remove check for blockchain synced (#621) --- squeaknode/core/squeak_controller.py | 3 --- squeaknode/core/squeak_core.py | 9 --------- squeaknode/server/squeak_server_handler.py | 12 ------------ squeaknode/sync/squeak_sync_status.py | 4 ---- 4 files changed, 28 deletions(-) diff --git a/squeaknode/core/squeak_controller.py b/squeaknode/core/squeak_controller.py index 49005bf9..b9c2837f 100644 --- a/squeaknode/core/squeak_controller.py +++ b/squeaknode/core/squeak_controller.py @@ -297,9 +297,6 @@ class SqueakController: def get_network(self): return self.config.core.network - def is_blockchain_synced(self): - return self.squeak_core.is_blockchain_synced() - def get_offer(self, squeak: CSqueak, offer: Offer, peer: SqueakPeer) -> ReceivedOffer: return self.squeak_core.unpack_offer(squeak, offer, peer) diff --git a/squeaknode/core/squeak_core.py b/squeaknode/core/squeak_core.py index 94075168..9793939a 100644 --- a/squeaknode/core/squeak_core.py +++ b/squeaknode/core/squeak_core.py @@ -292,12 +292,3 @@ class SqueakCore: client_addr=sent_offer.client_addr, ) yield received_payment - - def is_blockchain_synced(self) -> bool: - """Check if the blockchain is synced. - - Returns: - bool: True if the blockchain is synced. - """ - get_info_response = self.lightning_client.get_info() - return get_info_response.synced_to_chain diff --git a/squeaknode/server/squeak_server_handler.py b/squeaknode/server/squeak_server_handler.py index 73c3458c..f6d60086 100644 --- a/squeaknode/server/squeak_server_handler.py +++ b/squeaknode/server/squeak_server_handler.py @@ -16,25 +16,16 @@ class SqueakServerHandler(object): self.squeak_controller = squeak_controller def handle_posted_squeak(self, squeak: CSqueak): - if not self.squeak_controller.is_blockchain_synced(): - raise Exception("Blockchain not synced.") - logger.info( "Handle posted squeak with hash: {}".format(get_hash(squeak).hex())) # Save the squeak self.squeak_controller.save_uploaded_squeak(squeak) def handle_get_squeak(self, squeak_hash: bytes): - if not self.squeak_controller.is_blockchain_synced(): - raise Exception("Blockchain not synced.") - logger.info("Handle get squeak by hash: {}".format(squeak_hash.hex())) return self.squeak_controller.get_public_squeak(squeak_hash) def handle_lookup_squeaks(self, request): - if not self.squeak_controller.is_blockchain_synced(): - raise Exception("Blockchain not synced.") - addresses = request.addresses min_block = request.min_block max_block = request.max_block @@ -58,9 +49,6 @@ class SqueakServerHandler(object): ) def handle_get_offer(self, squeak_hash: bytes, client_addr: str): - if not self.squeak_controller.is_blockchain_synced(): - raise Exception("Blockchain not synced.") - logger.info( "Handle get offer by hash: {} from client_addr: {}".format( squeak_hash.hex(), client_addr diff --git a/squeaknode/sync/squeak_sync_status.py b/squeaknode/sync/squeak_sync_status.py index 657e671e..2912fe9e 100644 --- a/squeaknode/sync/squeak_sync_status.py +++ b/squeaknode/sync/squeak_sync_status.py @@ -14,10 +14,6 @@ class SqueakSyncController: self.squeak_controller = squeak_controller def sync_timeline(self): - if not self.squeak_controller.is_blockchain_synced(): - logger.error( - "Failed to sync timeline because blockchain out of sync.") - return try: block_height = self.squeak_controller.get_best_block_height() except Exception: