From e0fc9e7776278941b5c1535768d15a35106ba0f8 Mon Sep 17 00:00:00 2001 From: Luke Van Seters Date: Fri, 4 Feb 2022 13:09:46 -0500 Subject: [PATCH] Add a shell of a command to do the export --- cli.py | 8 ++++++++ mev | 23 +++++++++++++++-------- pyproject.toml | 1 + 3 files changed, 24 insertions(+), 8 deletions(-) diff --git a/cli.py b/cli.py index 3730e0f..2885de7 100644 --- a/cli.py +++ b/cli.py @@ -120,6 +120,14 @@ def fetch_all_prices(): write_prices(inspect_db_session, prices) +@cli.command() +@click.argument("after_block_number", type=int) +@click.argument("before_block_number", type=int) +def s3_export(after_block_number: int, before_block_number: int): + logger.info(after_block_number) + logger.info(before_block_number) + + @cli.command() @click.argument("after", type=click.DateTime(formats=["%Y-%m-%d", "%m-%d-%Y"])) @click.argument("before", type=click.DateTime(formats=["%Y-%m-%d", "%m-%d-%Y"])) diff --git a/mev b/mev index eb81fc6..65a3556 100755 --- a/mev +++ b/mev @@ -46,11 +46,11 @@ case "$1" in kubectl exec -ti deploy/mev-inspect -- ./listener $2 ;; backfill) - start_block_number=$2 - end_block_number=$3 + after_block_number=$2 + before_block_number=$3 - echo "Backfilling from $start_block_number to $end_block_number" - kubectl exec -ti deploy/mev-inspect -- poetry run enqueue-many-blocks $start_block_number $end_block_number + echo "Backfilling from $after_block_number to $before_block_number" + kubectl exec -ti deploy/mev-inspect -- poetry run enqueue-many-blocks $after_block_number $before_block_number ;; inspect) block_number=$2 @@ -58,11 +58,11 @@ case "$1" in kubectl exec -ti deploy/mev-inspect -- poetry run inspect-block $block_number ;; inspect-many) - start_block_number=$2 - end_block_number=$3 - echo "Inspecting from block $start_block_number to $end_block_number" + after_block_number=$2 + before_block_number=$3 + echo "Inspecting from block $after_block_number to $before_block_number" kubectl exec -ti deploy/mev-inspect -- \ - poetry run inspect-many-blocks $start_block_number $end_block_number + poetry run inspect-many-blocks $after_block_number $before_block_number ;; test) shift @@ -94,6 +94,13 @@ case "$1" in exit 1 esac ;; + s3-export) + after_block_number=$2 + before_block_number=$3 + + echo "Exporting from $after_block_number to $before_block_number" + kubectl exec -ti deploy/mev-inspect -- poetry run s3-export $after_block_number $before_block_number + ;; exec) shift kubectl exec -ti deploy/mev-inspect -- $@ diff --git a/pyproject.toml b/pyproject.toml index 457288c..4dd0b34 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -41,6 +41,7 @@ enqueue-many-blocks = 'cli:enqueue_many_blocks_command' fetch-block = 'cli:fetch_block_command' fetch-all-prices = 'cli:fetch_all_prices' fetch-range = 'cli:fetch_range' +s3-export = 'cli:s3_export' [tool.black] exclude = '''