127 lines
3.3 KiB
Python
127 lines
3.3 KiB
Python
import logging
|
|
import os
|
|
import sys
|
|
|
|
import click
|
|
|
|
from mev_inspect.concurrency import coro
|
|
from mev_inspect.crud.prices import write_prices
|
|
from mev_inspect.db import get_inspect_session, get_trace_session
|
|
from mev_inspect.inspector import MEVInspector
|
|
from mev_inspect.prices import fetch_all_supported_prices
|
|
|
|
RPC_URL_ENV = "RPC_URL"
|
|
|
|
logging.basicConfig(stream=sys.stdout, level=logging.INFO)
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
@click.group()
|
|
def cli():
|
|
pass
|
|
|
|
|
|
@cli.command()
|
|
@click.argument("block_number", type=int)
|
|
@click.option("--rpc", default=lambda: os.environ.get(RPC_URL_ENV, ""))
|
|
@coro
|
|
async def inspect_block_command(block_number: int, rpc: str):
|
|
inspect_db_session = get_inspect_session()
|
|
trace_db_session = get_trace_session()
|
|
|
|
inspector = MEVInspector(rpc)
|
|
|
|
await inspector.inspect_single_block(
|
|
inspect_db_session=inspect_db_session,
|
|
trace_db_session=trace_db_session,
|
|
block=block_number,
|
|
)
|
|
|
|
|
|
@cli.command()
|
|
@click.argument("block_number", type=int)
|
|
@click.option("--rpc", default=lambda: os.environ.get(RPC_URL_ENV, ""))
|
|
@coro
|
|
async def fetch_block_command(block_number: int, rpc: str):
|
|
trace_db_session = get_trace_session()
|
|
|
|
inspector = MEVInspector(rpc)
|
|
block = await inspector.create_from_block(
|
|
block_number=block_number,
|
|
trace_db_session=trace_db_session,
|
|
)
|
|
|
|
print(block.json())
|
|
|
|
|
|
@cli.command()
|
|
@click.argument("after_block", type=int)
|
|
@click.argument("before_block", type=int)
|
|
@click.option("--rpc", default=lambda: os.environ.get(RPC_URL_ENV, ""))
|
|
@click.option(
|
|
"--max-concurrency",
|
|
type=int,
|
|
help="maximum number of concurrent connections",
|
|
default=5,
|
|
)
|
|
@click.option(
|
|
"--request-timeout", type=int, help="timeout for requests to nodes", default=500
|
|
)
|
|
@coro
|
|
async def inspect_many_blocks_command(
|
|
after_block: int,
|
|
before_block: int,
|
|
rpc: str,
|
|
max_concurrency: int,
|
|
request_timeout: int,
|
|
):
|
|
inspect_db_session = get_inspect_session()
|
|
trace_db_session = get_trace_session()
|
|
|
|
inspector = MEVInspector(
|
|
rpc,
|
|
max_concurrency=max_concurrency,
|
|
request_timeout=request_timeout,
|
|
)
|
|
await inspector.inspect_many_blocks(
|
|
inspect_db_session=inspect_db_session,
|
|
trace_db_session=trace_db_session,
|
|
after_block=after_block,
|
|
before_block=before_block,
|
|
)
|
|
|
|
|
|
@cli.command()
|
|
@click.argument("after_block", type=int)
|
|
@click.argument("before_block", type=int)
|
|
@click.argument("batch_size", type=int, default=10)
|
|
def enqueue_many_blocks_command(after_block: int, before_block: int, batch_size: int):
|
|
from worker import ( # pylint: disable=import-outside-toplevel
|
|
inspect_many_blocks_task,
|
|
)
|
|
|
|
for batch_after_block in range(after_block, before_block, batch_size):
|
|
batch_before_block = min(batch_after_block + batch_size, before_block)
|
|
logger.info(f"Sending {batch_after_block} to {batch_before_block}")
|
|
inspect_many_blocks_task.send(batch_after_block, batch_before_block)
|
|
|
|
|
|
@cli.command()
|
|
@coro
|
|
async def fetch_all_prices():
|
|
inspect_db_session = get_inspect_session()
|
|
|
|
logger.info("Fetching prices")
|
|
prices = await fetch_all_supported_prices()
|
|
|
|
logger.info("Writing prices")
|
|
write_prices(inspect_db_session, prices)
|
|
|
|
|
|
def get_rpc_url() -> str:
|
|
return os.environ["RPC_URL"]
|
|
|
|
|
|
if __name__ == "__main__":
|
|
cli()
|