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

fix missing sessions

Browse Source
This commit is contained in:
carlomazzaferro 2021-11-28 13:33:02 +01:00
parent 3fa19b6cfe
commit 26b64487b7
No known key found for this signature in database
GPG Key ID: 0CED3103EF7B2187
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
listener.py
View File

@ -36,12 +36,13 @@ async def run():
inspector = MEVInspector(rpc) inspector = MEVInspector(rpc)
base_provider = get_base_provider(rpc) base_provider = get_base_provider(rpc)
_, inspect_session = get_sessions() trace_session, inspect_session = get_sessions()
while not killer.kill_now: while not killer.kill_now:
await inspect_next_block( await inspect_next_block(
inspector, inspector,
inspect_session, inspect_session,
trace_session,
base_provider, base_provider,
healthcheck_url, healthcheck_url,
) )
@ -52,6 +53,7 @@ async def run():
async def inspect_next_block( async def inspect_next_block(
inspector: MEVInspector, inspector: MEVInspector,
inspect_db_session, inspect_db_session,
trace_db_session,
base_provider, base_provider,
healthcheck_url, healthcheck_url,
): ):
@ -74,7 +76,11 @@ async def inspect_next_block(
logger.info(f"Writing block: {block_number}") logger.info(f"Writing block: {block_number}")
await inspector.inspect_single_block(block=block_number) await inspector.inspect_single_block(
block=block_number,
inspect_session=inspect_db_session,
trace_session=trace_db_session,
)
update_latest_block(inspect_db_session, block_number) update_latest_block(inspect_db_session, block_number)
if healthcheck_url: if healthcheck_url: