crowetic/mev-inspect-py
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix check for n blocks

Browse Source
This commit is contained in:
Luke Van Seters 2022-01-18 18:49:39 -05:00
parent d5eaeaf00d
commit 125d59f712
1 changed files with 6 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
listener.py
View File

@ -45,6 +45,7 @@ async def run():
inspector = MEVInspector(rpc) inspector = MEVInspector(rpc)
base_provider = get_base_provider(rpc) base_provider = get_base_provider(rpc)
blocks_written = 0
while not killer.kill_now: while not killer.kill_now:
await inspect_next_block( await inspect_next_block(
@ -55,6 +56,11 @@ async def run():
healthcheck_url, healthcheck_url,
) )
if (blocks_written % UPDATE_PRICES_EVERY_N_BLOCKS) == 0:
await _refresh_prices(inspect_db_session)
blocks_written += 1
logger.info("Stopping...") logger.info("Stopping...")
@ -68,8 +74,6 @@ async def inspect_next_block(
latest_block_number = await get_latest_block_number(base_provider) latest_block_number = await get_latest_block_number(base_provider)
last_written_block = find_latest_block_update(inspect_db_session) last_written_block = find_latest_block_update(inspect_db_session)
blocks_written = 0
logger.info(f"Latest block: {latest_block_number}") logger.info(f"Latest block: {latest_block_number}")
logger.info(f"Last written block: {last_written_block}") logger.info(f"Last written block: {last_written_block}")
@ -89,16 +93,10 @@ async def inspect_next_block(
) )
update_summary_for_block(inspect_db_session, block_number) update_summary_for_block(inspect_db_session, block_number)
if (blocks_written % UPDATE_PRICES_EVERY_N_BLOCKS) == 0:
await _refresh_prices(inspect_db_session)
update_latest_block(inspect_db_session, block_number) update_latest_block(inspect_db_session, block_number)
if healthcheck_url: if healthcheck_url:
await ping_healthcheck_url(healthcheck_url) await ping_healthcheck_url(healthcheck_url)
blocks_written += 1
else: else:
await asyncio.sleep(5) await asyncio.sleep(5)