From 31d9ff6f48931aecfe769f6b6859793d9911f969 Mon Sep 17 00:00:00 2001 From: kompotkot Date: Fri, 15 Oct 2021 09:03:07 +0000 Subject: [PATCH] Fix sync blocks logic --- crawlers/mooncrawl/mooncrawl/ethcrawler.py | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/crawlers/mooncrawl/mooncrawl/ethcrawler.py b/crawlers/mooncrawl/mooncrawl/ethcrawler.py index e04d6dae..e89e4781 100644 --- a/crawlers/mooncrawl/mooncrawl/ethcrawler.py +++ b/crawlers/mooncrawl/mooncrawl/ethcrawler.py @@ -97,6 +97,13 @@ def ethcrawler_blocks_sync_handler(args: argparse.Namespace) -> None: ) if latest_stored_block_number is None: latest_stored_block_number = 0 + + if latest_stored_block_number >= latest_block_number: + logger.info( + f"Synchronization is unnecessary for blocks {latest_stored_block_number}-{latest_block_number - 1}" + ) + time.sleep(5) + continue block_number_difference = latest_block_number - 1 - latest_stored_block_number @@ -108,17 +115,10 @@ def ethcrawler_blocks_sync_handler(args: argparse.Namespace) -> None: time.sleep(5) continue else: - bottom_block_number = latest_block_number - args.confirmations + bottom_block_number = latest_stored_block_number + 1 else: bottom_block_number = max(latest_stored_block_number + 1, args.start) - if latest_stored_block_number >= latest_block_number: - logger.info( - f"Synchronization is unnecessary for blocks {latest_stored_block_number}-{latest_block_number - 1}" - ) - time.sleep(5) - continue - for blocks_numbers_list in yield_blocks_numbers_lists( f"{bottom_block_number}-{latest_block_number}", order=args.order,