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

Merge pull request #194 from flashbots/bug-all

Browse Source 
Inspect block should write all
This commit is contained in:
Luke Van Seters 2021-12-29 11:26:08 -05:00 committed by GitHub
commit f9ccd8dca2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 26 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
mev_inspect/crud/blocks.py
View File

@ -1,4 +1,5 @@
from datetime import datetime from datetime import datetime
from typing import List
from mev_inspect.schemas.blocks import Block from mev_inspect.schemas.blocks import Block
@ -23,15 +24,20 @@ def delete_blocks(
db_session.commit() db_session.commit()
def write_block( def write_blocks(
db_session, db_session,
block: Block, blocks: List[Block],
) -> None: ) -> None:
db_session.execute( block_params = [
"INSERT INTO blocks (block_number, block_timestamp) VALUES (:block_number, :block_timestamp)", {
params={
"block_number": block.block_number, "block_number": block.block_number,
"block_timestamp": datetime.fromtimestamp(block.block_timestamp), "block_timestamp": datetime.fromtimestamp(block.block_timestamp),
}, }
for block in blocks
]
db_session.execute(
"INSERT INTO blocks (block_number, block_timestamp) VALUES (:block_number, :block_timestamp)",
params=block_params,
) )
db_session.commit() db_session.commit()

28
mev_inspect/inspect_block.py
View File

@ -8,7 +8,7 @@ from mev_inspect.arbitrages import get_arbitrages
from mev_inspect.block import create_from_block_number from mev_inspect.block import create_from_block_number
from mev_inspect.classifiers.trace import TraceClassifier from mev_inspect.classifiers.trace import TraceClassifier
from mev_inspect.crud.arbitrages import delete_arbitrages_for_blocks, write_arbitrages from mev_inspect.crud.arbitrages import delete_arbitrages_for_blocks, write_arbitrages
from mev_inspect.crud.blocks import delete_blocks, write_block from mev_inspect.crud.blocks import delete_blocks, write_blocks
from mev_inspect.crud.liquidations import ( from mev_inspect.crud.liquidations import (
delete_liquidations_for_blocks, delete_liquidations_for_blocks,
write_liquidations, write_liquidations,
@ -92,7 +92,7 @@ async def inspect_many_blocks(
all_transfers: List[Transfer] = [] all_transfers: List[Transfer] = []
all_swaps: List[Swap] = [] all_swaps: List[Swap] = []
all_arbitrages: List[Arbitrage] = [] all_arbitrages: List[Arbitrage] = []
all_liqudations: List[Liquidation] = [] all_liquidations: List[Liquidation] = []
all_sandwiches: List[Sandwich] = [] all_sandwiches: List[Sandwich] = []
all_punk_bids: List[PunkBid] = [] all_punk_bids: List[PunkBid] = []
@ -161,7 +161,7 @@ async def inspect_many_blocks(
all_transfers.extend(transfers) all_transfers.extend(transfers)
all_swaps.extend(swaps) all_swaps.extend(swaps)
all_arbitrages.extend(arbitrages) all_arbitrages.extend(arbitrages)
all_liqudations.extend(liquidations) all_liquidations.extend(liquidations)
all_sandwiches.extend(sandwiches) all_sandwiches.extend(sandwiches)
all_punk_bids.extend(punk_bids) all_punk_bids.extend(punk_bids)
@ -173,51 +173,51 @@ async def inspect_many_blocks(
all_miner_payments.extend(miner_payments) all_miner_payments.extend(miner_payments)
delete_blocks(inspect_db_session, after_block_number, before_block_number) delete_blocks(inspect_db_session, after_block_number, before_block_number)
write_block(inspect_db_session, block) write_blocks(inspect_db_session, all_blocks)
if should_write_classified_traces: if should_write_classified_traces:
delete_classified_traces_for_blocks( delete_classified_traces_for_blocks(
inspect_db_session, after_block_number, before_block_number inspect_db_session, after_block_number, before_block_number
) )
write_classified_traces(inspect_db_session, classified_traces) write_classified_traces(inspect_db_session, all_classified_traces)
delete_transfers_for_blocks( delete_transfers_for_blocks(
inspect_db_session, after_block_number, before_block_number inspect_db_session, after_block_number, before_block_number
) )
write_transfers(inspect_db_session, transfers) write_transfers(inspect_db_session, all_transfers)
delete_swaps_for_blocks(inspect_db_session, after_block_number, before_block_number) delete_swaps_for_blocks(inspect_db_session, after_block_number, before_block_number)
write_swaps(inspect_db_session, swaps) write_swaps(inspect_db_session, all_swaps)
delete_arbitrages_for_blocks( delete_arbitrages_for_blocks(
inspect_db_session, after_block_number, before_block_number inspect_db_session, after_block_number, before_block_number
) )
write_arbitrages(inspect_db_session, arbitrages) write_arbitrages(inspect_db_session, all_arbitrages)
delete_liquidations_for_blocks( delete_liquidations_for_blocks(
inspect_db_session, after_block_number, before_block_number inspect_db_session, after_block_number, before_block_number
) )
write_liquidations(inspect_db_session, liquidations) write_liquidations(inspect_db_session, all_liquidations)
delete_sandwiches_for_blocks( delete_sandwiches_for_blocks(
inspect_db_session, after_block_number, before_block_number inspect_db_session, after_block_number, before_block_number
) )
write_sandwiches(inspect_db_session, sandwiches) write_sandwiches(inspect_db_session, all_sandwiches)
delete_punk_bids_for_blocks( delete_punk_bids_for_blocks(
inspect_db_session, after_block_number, before_block_number inspect_db_session, after_block_number, before_block_number
) )
write_punk_bids(inspect_db_session, punk_bids) write_punk_bids(inspect_db_session, all_punk_bids)
delete_punk_bid_acceptances_for_blocks( delete_punk_bid_acceptances_for_blocks(
inspect_db_session, after_block_number, before_block_number inspect_db_session, after_block_number, before_block_number
) )
write_punk_bid_acceptances(inspect_db_session, punk_bid_acceptances) write_punk_bid_acceptances(inspect_db_session, all_punk_bid_acceptances)
delete_punk_snipes_for_blocks( delete_punk_snipes_for_blocks(
inspect_db_session, after_block_number, before_block_number inspect_db_session, after_block_number, before_block_number
) )
write_punk_snipes(inspect_db_session, punk_snipes) write_punk_snipes(inspect_db_session, all_punk_snipes)
delete_nft_trades_for_blocks( delete_nft_trades_for_blocks(
inspect_db_session, after_block_number, before_block_number inspect_db_session, after_block_number, before_block_number
@ -227,4 +227,4 @@ async def inspect_many_blocks(
delete_miner_payments_for_blocks( delete_miner_payments_for_blocks(
inspect_db_session, after_block_number, before_block_number inspect_db_session, after_block_number, before_block_number
) )
write_miner_payments(inspect_db_session, miner_payments) write_miner_payments(inspect_db_session, all_miner_payments)