Fix sync blocks logic

pull/319/head
kompotkot 2021-10-15 09:03:07 +00:00
rodzic 77506af98b
commit 31d9ff6f48
1 zmienionych plików z 8 dodań i 8 usunięć

Wyświetl plik

@ -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,