Removed debugger

.dockerignore

@@ -1 +0,0 @@
-cache

.env

@@ -0,0 +1,13 @@
+# Postgres
+POSTGRES_SERVER=db
+POSTGRES_USER=postgres
+POSTGRES_PASSWORD=password
+POSTGRES_DB=mev_inspect
+
+# PgAdmin
+PGADMIN_LISTEN_PORT=5050
+PGADMIN_DEFAULT_EMAIL=admin@example.com
+PGADMIN_DEFAULT_PASSWORD=password
+
+# SQLAlchemy
+SQLALCHEMY_DATABASE_URI=postgresql://$POSTGRES_USER:$POSTGRES_PASSWORD@$POSTGRES_SERVER/$POSTGRES_DB

.github/workflows/github-actions.yml

@@ -51,8 +51,8 @@ jobs:
 
       - name: Run precommit
         run: |
-          poetry run pre-commit run --all-files
+          poetry run pre-commit
 
       - name: Test with pytest
         shell: bash
-        run: poetry run pytest --cov=mev_inspect tests
+        run: poetry run test

.gitignore

@@ -13,12 +13,3 @@ __pycache__
 # coverage
 htmlcov
 .coverage*
-
-# don't commit cache
-cache
-
-# k8s
-.helm
-
-# env
-.envrc

.pre-commit-config.yaml

@@ -2,15 +2,8 @@ repos:
 -   repo: https://github.com/ambv/black
     rev: 20.8b1
     hooks:
-      - id: black
-        language_version: python3.9
--   repo: local
-    hooks:
-      - id: isort
-        name: isort
-        entry: poetry run isort .
-        language: system
-        types: [python]
+    - id: black
+      language_version: python3.9
 -   repo: local
     hooks:
     - id: pylint
@@ -25,4 +18,3 @@ repos:
       - id: 'mypy'
         additional_dependencies:
           - 'pydantic'
-          - 'types-requests'

.pylintrc

@@ -433,7 +433,7 @@ int-import-graph=
 known-standard-library=
 
 # Force import order to recognize a module as part of a third party library.
-known-third-party=alembic
+known-third-party=enchant
 
 # Couples of modules and preferred modules, separated by a comma.
 preferred-modules=

CONTRIBUTING.md

@@ -1,36 +0,0 @@
-# Contributing guide
-
-Welcome to the Flashbots collective! We just ask you to be nice when you play with us.
-
-## Pre-commit
-
-We use pre-commit to maintain a consistent style, prevent errors, and ensure test coverage.
-
-To set up, install dependencies through `poetry`:
-
-```
-poetry install
-```
-
-Then install pre-commit hooks with:
-
-```
-poetry run pre-commit install
-```
-
-## Tests
-
-Run tests with:
-
-```
-kubectl exec deploy/mev-inspect-deployment -- poetry run pytest --cov=mev_inspect tests
-```
-
-## Send a pull request
-
-- Your proposed changes should be first described and discussed in an issue.
-- Open the branch in a personal fork, not in the team repository.
-- Every pull request should be small and represent a single change. If the problem is complicated, split it in multiple issues and pull requests.
-- Every pull request should be covered by unit tests.
-
-We appreciate you, friend <3.

Dockerfile

@@ -6,17 +6,14 @@ RUN pip install -U pip \
 
 ENV PATH="${PATH}:/root/.poetry/bin"
 
-COPY ./pyproject.toml /app/pyproject.toml
-COPY ./poetry.lock /app/poetry.lock
+COPY . /app
 WORKDIR /app/
 
+# poetry uses virtual env by default, turn this off inside container
 RUN poetry config virtualenvs.create false && \
     poetry install
 
-COPY . /app
-
 # easter eggs 😝
 RUN echo "PS1='🕵️:\[\033[1;36m\]\h \[\033[1;34m\]\W\[\033[0;35m\]\[\033[1;36m\]$ \[\033[0m\]'" >> ~/.bashrc
 
-ENTRYPOINT [ "poetry" ]
-CMD [ "run", "python", "loop.py" ]
+CMD /bin/bash

README.md

@@ -1,239 +1,104 @@
-# mev-inspect-py
+# mev-inspect
+A [WIP] Ethereum MEV Inspector in Python managed by Poetry
 
-[![standard-readme compliant](https://img.shields.io/badge/readme%20style-standard-brightgreen.svg?style=flat-square)](https://github.com/RichardLitt/standard-readme)
-[![Discord](https://img.shields.io/discord/755466764501909692)](https://discord.gg/7hvTycdNcK)
+## Containers
+mev-inspect's local setup is built on [Docker Compose](https://docs.docker.com/compose/)
 
-[Maximal extractable value](https://ethereum.org/en/developers/docs/mev/) inspector for Ethereum, to illuminate the [dark forest](https://www.paradigm.xyz/2020/08/ethereum-is-a-dark-forest/) 🌲💡
+By default it starts up:
+- `mev-insepct` - a container with the code in this repo used for running scripts
+- `db` - a postgres database instance
+- `pgadmin` - a postgres DB UI for querying and more (avaiable at localhost:5050)
 
-Given a block, mev-inspect finds:
-- miner payments (gas + coinbase)
-- tokens transfers and profit
-- swaps and [arbitrages](https://twitter.com/bertcmiller/status/1427632028263059462)
-- ...and more
-
-Data is stored in Postgres for analysis.
-
-## Install
-
-mev-inspect-py is built to run on kubernetes locally and in production.
-
-### Dependencies
-
-- [docker](https://www.docker.com/products/docker-desktop)
-- [kind](https://kind.sigs.k8s.io/docs/user/quick-start), or a similar tool for running local Kubernetes clusters
-- [kubectl](https://kubernetes.io/docs/tasks/tools/)
-- [helm](https://helm.sh/docs/intro/install/)
-- [tilt](https://docs.tilt.dev/install.html)
-
-### Set up
-
-Create a new cluster with:
+## Running locally
+Setup [Docker](https://www.docker.com/products/docker-desktop)
+Setup [Poetry](https://python-poetry.org/docs/#osx--linux--bashonwindows-install-instructions)
 
+Install dependencies through poetry
 ```
-kind create cluster
+poetry install
 ```
 
-Set an environment variable `RPC_URL` to an RPC for fetching blocks.
-
-mev-inspect-py currently requires a node with support for Erigon traces and receipts (not geth yet 😔).
-
-[pokt.network](pokt.network)'s "Ethereum Mainnet Archival with trace calls" is a good hosted option.
-
-Example:
-
+Start the services (optionally as daemon)
 ```
-export RPC_URL="http://111.111.111.111:8546"
+poetry run start [-d]
+```
+
+Apply the latest migrations against the local DB:
+```
+poetry run exec alembic upgrade head
+``` 
+
+Run inspect on a block
+```
+poetry run inspect -b/--block-number 11931270 -r/--rpc 'http://111.11.11.111:8545/'
+``` 
+
+To stop the services (if running in the background, otherwise just ctrl+c)
+```
+poetry run stop
+```
+
+MEV container can be attached via
+```
+poetry run attach
+```
+
+Running additional compose commands are possible through standard `docker
+compose ...` calls.  Check `docker compose help` for more tools available
+
+## Executing scripts
+Any script can be run from the mev-inspect container like
+```
+poetry run exec <your command here>
+```
+
+For example
+```
+poetry run exec python examples/uniswap_inspect.py -block_number=123 -rpc='111.111.111'
+```
+
+### Poetry Scripts
+```bash
+# code check
+poetry run lint # linting via Pylint
+poetry run test # testing and code coverage with Pytest
+poetry run isort # fixing imports 
+poetry run mypy # type checking 
+poetry run black # style guide 
+poetry run pre-commit run --all-files # runs Black, PyLint and MyPy
+# docker management
+poetry run start [-d] # starts all services, optionally as a daemon
+poetry run stop # shutsdown all services or just ctrl + c if foreground
+poetry run build # rebuilds containers
+poetry run attach # enters the mev-inspect container in interactive mode
+# launches inspection script
+poetry run inspect -b/--block-number 11931270 -r/--rpc 'http://111.11.11.111:8545/'
 ```
 
 
-Next, start all services with:
-
+## Rebuilding containers
+After changes to the app's Dockerfile, rebuild with
 ```
-tilt up
+poetry run build
 ```
 
-Press "space" to see a browser of the services starting up.
+## Using PGAdmin
 
-On first startup, you'll need to apply database migrations with:
+1. Go to [localhost:5050](localhost:5050)
 
-```
-./mev exec alembic upgrade head
-```
+2. Login with the PGAdmin username and password in `.env`
 
-## Usage
-
-### Inspect a single block
-
-Inspecting block [12914944](https://twitter.com/mevalphaleak/status/1420416437575901185):
-
-```
-./mev inspect 12914944
-```
-
-### Inspect many blocks
-
-Inspecting blocks 12914944 to 12914954:
-
-```
-./mev inspect-many 12914944 12914954
-```
-
-### Inspect all incoming blocks
-
-Start a block listener with:
-
-```
-./mev listener start
-```
-
-By default, it will pick up wherever you left off.
-If running for the first time, listener starts at the latest block.
-
-Tail logs for the listener with:
-
-```
-./mev listener tail
-```
-
-And stop the listener with:
-
-```
-./mev listener stop
-```
-
-### Backfilling
-
-For larger backfills, you can inspect many blocks in parallel using kubernetes
-
-To inspect blocks 12914944 to 12915044 divided across 10 worker pods:
-```
-./mev backfill 12914944 12915044 10
-```
-
-You can see worker pods spin up then complete by watching the status of all pods
-```
-watch kubectl get pods
-```
-
-To watch the logs for a given pod, take its pod name using the above, then run:
-```
-kubectl logs -f pod/mev-inspect-backfill-abcdefg
-```
-
-(where `mev-inspect-backfill-abcdefg` is your actual pod name)
-
-
-### Exploring
-
-All inspect output data is stored in Postgres.
-
-To connect to the local Postgres database for querying, launch a client container with:
-
-```
-./mev db
-```
-
-When you see the prompt:
-
-```
-mev_inspect=#
-```
-
-You're ready to query!
-
-Try finding the total number of swaps decoded with UniswapV3Pool:
-
-```
-SELECT COUNT(*) FROM swaps WHERE abi_name='UniswapV3Pool';
-```
-
-or top 10 arbs by gross profit that took profit in WETH:
-
-```
-SELECT *
-FROM arbitrages
-WHERE profit_token_address = '0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2'
-ORDER BY profit_amount DESC
-LIMIT 10;
-```
-
-Postgres tip: Enter `\x` to enter "Explanded display" mode which looks nicer for results with many columns.
-
-## FAQ
-
-### How do I delete / reset my local postgres data?
-
-Stop the system if running:
-
-```
-tilt down
-```
-
-Delete it with:
-
-```
-kubectl delete pvc data-postgresql-postgresql-0
-```
-
-Start back up again:
-
-```
-tilt up
-```
-
-And rerun migrations to create the tables again:
-
-```
-./mev exec alembic upgrade head
-```
-
-### I was using the docker-compose setup and want to switch to kube, now what?
-
-Re-add the old `docker-compose.yml` file to your mev-inspect-py directory.
-
-A copy can be found [here](https://github.com/flashbots/mev-inspect-py/blob/ef60c097719629a7d2dc56c6e6c9a100fb706f76/docker-compose.yml)
-
-Tear down docker-compose resources:
-
-```
-docker compose down
-```
-
-Then go through the steps in the current README for kube setup.
-
-### Error from server (AlreadyExists): pods "postgres-client" already exists
-
-This means the postgres client container didn't shut down correctly.
-
-Delete this one with:
-
-```
-kubectl delete pod/postgres-client
-```
-
-Then start it back up again.
-
-## Maintainers
-
-- [@lukevs](https://github.com/lukevs)
-- [@gheise](https://github.com/gheise)
-- [@bertmiller](https://github.com/bertmiller)
+3. Add a new engine for mev_inspect with
+    - host: db
+    - user / password: see `.env`
 
 ## Contributing
 
-[Flashbots](https://flashbots.net) is a research and development collective working on mitigating the negative externalities of decentralized economies. We contribute with the larger free software community to illuminate the dark forest.
+Pre-commit is used to maintain a consistent style, prevent errors and ensure test coverage. 
 
-You are welcome here <3.
+Install pre-commit with:
+```
+poetry run pre-commit install
+```
 
-- If you want to join us, come and say hi in our [Discord chat](https://discord.gg/7hvTycdNcK).
-- If you have a question, feedback or a bug report for this project, please [open a new Issue](https://github.com/flashbots/mev-inspect-py/issues).
-- If you would like to contribute with code, check the [CONTRIBUTING file](CONTRIBUTING.md).
-- We just ask you to be nice.
-
-## Security
-
-If you find a security vulnerability on this project or any other initiative related to Flashbots, please let us know sending an email to security@flashbots.net.
-
----
-
-Made with ☀️  by the ⚡🤖 collective.
+Update README if needed

Tiltfile

@@ -1,50 +0,0 @@
-load("ext://helm_remote", "helm_remote")
-load("ext://secret", "secret_from_dict")
-load("ext://configmap", "configmap_from_dict")
-
-helm_remote("postgresql",
-            repo_name="bitnami",
-            repo_url="https://charts.bitnami.com/bitnami",
-            set=["postgresqlPassword=password", "postgresqlDatabase=mev_inspect"],
-)
-
-k8s_yaml(configmap_from_dict("mev-inspect-rpc", inputs = {
-    "url" : os.environ["RPC_URL"],
-}))
-
-k8s_yaml(configmap_from_dict("mev-inspect-listener-healthcheck", inputs = {
-    "url" : os.getenv("LISTENER_HEALTHCHECK_URL", default=""),
-}))
-
-k8s_yaml(secret_from_dict("mev-inspect-db-credentials", inputs = {
-    "username" : "postgres",
-    "password": "password",
-    "host": "postgresql",
-}))
-
-# if using https://github.com/taarushv/trace-db
-# k8s_yaml(secret_from_dict("trace-db-credentials", inputs = {
-#     "username" : "username",
-#     "password": "password",
-#     "host": "trace-db-postgresql",
-# }))
-
-docker_build("mev-inspect-py", ".",
-    live_update=[
-        sync(".", "/app"),
-        run("cd /app && poetry install",
-            trigger="./pyproject.toml"),
-    ],
-)
-k8s_yaml(helm('./k8s/mev-inspect', name='mev-inspect'))
-k8s_resource(workload="mev-inspect", resource_deps=["postgresql-postgresql"])
-
-# uncomment to enable price monitor
-# k8s_yaml(helm('./k8s/mev-inspect-prices', name='mev-inspect-prices'))
-# k8s_resource(workload="mev-inspect-prices", resource_deps=["postgresql-postgresql"])
-
-local_resource(
-    'pg-port-forward',
-    serve_cmd='kubectl port-forward --namespace default svc/postgresql 5432:5432',
-    resource_deps=["postgresql-postgresql"]
-)

alembic/env.py

@@ -1,14 +1,16 @@
+import os
+
 from logging.config import fileConfig
 
-from alembic import context
-from sqlalchemy import engine_from_config, pool
+from sqlalchemy import engine_from_config
+from sqlalchemy import pool
 
-from mev_inspect.db import get_inspect_database_uri
+from alembic import context
 
 # this is the Alembic Config object, which provides
 # access to the values within the .ini file in use.
 config = context.config
-config.set_main_option("sqlalchemy.url", get_inspect_database_uri())
+config.set_main_option("sqlalchemy.url", os.environ["SQLALCHEMY_DATABASE_URI"])
 
 # Interpret the config file for Python logging.
 # This line sets up loggers basically.

alembic/versions/04a3bb3740c3_change_miner_payments_and_transfers_.py

@@ -1,54 +0,0 @@
-"""Change miner payments and transfers primary keys to include block number
-
-Revision ID: 04a3bb3740c3
-Revises: a10d68643476
-Create Date: 2021-11-02 22:42:01.702538
-
-"""
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "04a3bb3740c3"
-down_revision = "a10d68643476"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    # transfers
-    op.execute("ALTER TABLE transfers DROP CONSTRAINT transfers_pkey")
-    op.create_primary_key(
-        "transfers_pkey",
-        "transfers",
-        ["block_number", "transaction_hash", "trace_address"],
-    )
-    op.drop_index("ix_transfers_block_number")
-
-    # miner_payments
-    op.execute("ALTER TABLE miner_payments DROP CONSTRAINT miner_payments_pkey")
-    op.create_primary_key(
-        "miner_payments_pkey",
-        "miner_payments",
-        ["block_number", "transaction_hash"],
-    )
-    op.drop_index("ix_block_number")
-
-
-def downgrade():
-    # transfers
-    op.execute("ALTER TABLE transfers DROP CONSTRAINT transfers_pkey")
-    op.create_index("ix_transfers_block_number", "transfers", ["block_number"])
-    op.create_primary_key(
-        "transfers_pkey",
-        "transfers",
-        ["transaction_hash", "trace_address"],
-    )
-
-    # miner_payments
-    op.execute("ALTER TABLE miner_payments DROP CONSTRAINT miner_payments_pkey")
-    op.create_index("ix_block_number", "miner_payments", ["block_number"])
-    op.create_primary_key(
-        "miner_payments_pkey",
-        "miner_payments",
-        ["transaction_hash"],
-    )

alembic/versions/04b76ab1d2af_change_blocks_timestamp_to_timestamp.py

@@ -1,35 +0,0 @@
-"""Change blocks.timestamp to timestamp
-
-Revision ID: 04b76ab1d2af
-Revises: 2c90b2b8a80b
-Create Date: 2021-11-26 15:31:21.111693
-
-"""
-import sqlalchemy as sa
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "04b76ab1d2af"
-down_revision = "0cef835f7b36"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.alter_column(
-        "blocks",
-        "block_timestamp",
-        type_=sa.TIMESTAMP,
-        nullable=False,
-        postgresql_using="TO_TIMESTAMP(block_timestamp)",
-    )
-
-
-def downgrade():
-    op.alter_column(
-        "blocks",
-        "block_timestamp",
-        type_=sa.Numeric,
-        nullable=False,
-        postgresql_using="extract(epoch FROM block_timestamp)",
-    )

alembic/versions/070819d86587_create_punk_snipe.py

@@ -1,34 +0,0 @@
-"""empty message
-
-Revision ID: 070819d86587
-Revises: d498bdb0a641
-Create Date: 2021-11-26 18:25:13.402822
-
-"""
-import sqlalchemy as sa
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "d498bdb0a641"
-down_revision = "b9fa1ecc9929"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.create_table(
-        "punk_snipes",
-        sa.Column("created_at", sa.TIMESTAMP, server_default=sa.func.now()),
-        sa.Column("block_number", sa.Numeric, nullable=False),
-        sa.Column("transaction_hash", sa.String(66), nullable=False),
-        sa.Column("trace_address", sa.String(256), nullable=False),
-        sa.Column("from_address", sa.String(256), nullable=False),
-        sa.Column("punk_index", sa.Numeric, nullable=False),
-        sa.Column("min_acceptance_price", sa.Numeric, nullable=False),
-        sa.Column("acceptance_price", sa.Numeric, nullable=False),
-        sa.PrimaryKeyConstraint("block_number", "transaction_hash", "trace_address"),
-    )
-
-
-def downgrade():
-    op.drop_table("punk_snipes")

alembic/versions/083978d6e455_create_miner_payments_table.py

@@ -1,35 +0,0 @@
-"""Create miner_payments table
-
-Revision ID: 083978d6e455
-Revises: 92f28a2b4f52
-Create Date: 2021-08-30 17:42:25.548130
-
-"""
-import sqlalchemy as sa
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "083978d6e455"
-down_revision = "92f28a2b4f52"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.create_table(
-        "miner_payments",
-        sa.Column("created_at", sa.TIMESTAMP, server_default=sa.func.now()),
-        sa.Column("block_number", sa.Numeric, nullable=False),
-        sa.Column("transaction_hash", sa.String(66), primary_key=True),
-        sa.Column("transaction_index", sa.Numeric, nullable=False),
-        sa.Column("miner_address", sa.String(256), nullable=False),
-        sa.Column("coinbase_transfer", sa.Numeric, nullable=False),
-        sa.Column("base_fee_per_gas", sa.Numeric, nullable=False),
-        sa.Column("gas_price", sa.Numeric, nullable=False),
-        sa.Column("gas_price_with_coinbase_transfer", sa.Numeric, nullable=False),
-        sa.Column("gas_used", sa.Numeric, nullable=False),
-    )
-
-
-def downgrade():
-    op.drop_table("miner_payments")

alembic/versions/0cef835f7b36_rename_pool_address_to_contract_address.py

@@ -1,26 +0,0 @@
-"""Rename pool_address to contract_address
-
-Revision ID: 0cef835f7b36
-Revises: 5427d62a2cc0
-Create Date: 2021-11-19 15:36:15.152622
-
-"""
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "0cef835f7b36"
-down_revision = "5427d62a2cc0"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.alter_column(
-        "swaps", "pool_address", nullable=False, new_column_name="contract_address"
-    )
-
-
-def downgrade():
-    op.alter_column(
-        "swaps", "contract_address", nullable=False, new_column_name="pool_address"
-    )

alembic/versions/15ba9c27ee8a_add_nullable_transaction_position_field_.py

@@ -1,28 +0,0 @@
-"""Add nullable transaction_position field to swaps and traces
-
-Revision ID: 15ba9c27ee8a
-Revises: 04b76ab1d2af
-Create Date: 2021-12-02 18:24:18.218880
-
-"""
-import sqlalchemy as sa
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "15ba9c27ee8a"
-down_revision = "ead7eb8283b9"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.add_column(
-        "classified_traces",
-        sa.Column("transaction_position", sa.Numeric, nullable=True),
-    )
-    op.add_column("swaps", sa.Column("transaction_position", sa.Numeric, nullable=True))
-
-
-def downgrade():
-    op.drop_column("classified_traces", "transaction_position")
-    op.drop_column("swaps", "transaction_position")

alembic/versions/205ce02374b3_add_received_collateral_address_to_liquidations.py

@@ -1,26 +0,0 @@
-"""Add received_collateral_address to liquidations
-
-Revision ID: 205ce02374b3
-Revises: c8363617aa07
-Create Date: 2021-10-04 19:52:40.017084
-
-"""
-import sqlalchemy as sa
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "205ce02374b3"
-down_revision = "c8363617aa07"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.add_column(
-        "liquidations",
-        sa.Column("received_token_address", sa.String(256), nullable=True),
-    )
-
-
-def downgrade():
-    op.drop_column("liquidations", "received_token_address")

alembic/versions/2116e2f36a19_create_swaps_table.py

@@ -1,39 +0,0 @@
-"""Create swaps table
-
-Revision ID: 2116e2f36a19
-Revises: c5da44eb072c
-Create Date: 2021-08-05 21:06:33.340456
-
-"""
-import sqlalchemy as sa
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "2116e2f36a19"
-down_revision = "c5da44eb072c"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.create_table(
-        "swaps",
-        sa.Column("created_at", sa.TIMESTAMP, server_default=sa.func.now()),
-        sa.Column("abi_name", sa.String(1024), nullable=False),
-        sa.Column("transaction_hash", sa.String(66), nullable=False),
-        sa.Column("block_number", sa.Numeric, nullable=False),
-        sa.Column("trace_address", sa.String(256), nullable=False),
-        sa.Column("protocol", sa.String(256), nullable=True),
-        sa.Column("pool_address", sa.String(256), nullable=False),
-        sa.Column("from_address", sa.String(256), nullable=False),
-        sa.Column("to_address", sa.String(256), nullable=False),
-        sa.Column("token_in_address", sa.String(256), nullable=False),
-        sa.Column("token_in_amount", sa.Numeric, nullable=False),
-        sa.Column("token_out_address", sa.String(256), nullable=False),
-        sa.Column("token_out_amount", sa.Numeric, nullable=False),
-        sa.PrimaryKeyConstraint("transaction_hash", "trace_address"),
-    )
-
-
-def downgrade():
-    op.drop_table("swaps")

alembic/versions/2c90b2b8a80b_add_blocks_table.py

@@ -1,28 +0,0 @@
-"""Add blocks table
-
-Revision ID: 2c90b2b8a80b
-Revises: 04a3bb3740c3
-Create Date: 2021-11-17 18:29:13.065944
-
-"""
-import sqlalchemy as sa
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "2c90b2b8a80b"
-down_revision = "04a3bb3740c3"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.create_table(
-        "blocks",
-        sa.Column("block_number", sa.Numeric, nullable=False),
-        sa.Column("block_timestamp", sa.Numeric, nullable=False),
-        sa.PrimaryKeyConstraint("block_number"),
-    )
-
-
-def downgrade():
-    op.drop_table("blocks")

alembic/versions/320e56b0a99f_add_index_on_block_number_for_miner_.py

@@ -1,22 +0,0 @@
-"""Add index on block_number for miner_payments
-
-Revision ID: 320e56b0a99f
-Revises: a02f3f2c469f
-Create Date: 2021-09-14 11:11:41.559137
-
-"""
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "320e56b0a99f"
-down_revision = "a02f3f2c469f"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.create_index("ix_block_number", "miner_payments", ["block_number"])
-
-
-def downgrade():
-    op.drop_index("ix_block_number", "miner_payments")

alembic/versions/3417f49d97b3_cahnge_swap_primary_key_to_include_.py

@@ -1,45 +0,0 @@
-"""Cahnge swap primary key to include block number
-
-Revision ID: 3417f49d97b3
-Revises: 205ce02374b3
-Create Date: 2021-11-02 20:50:32.854996
-
-"""
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "3417f49d97b3"
-down_revision = "205ce02374b3"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.execute("ALTER TABLE swaps DROP CONSTRAINT swaps_pkey CASCADE")
-    op.create_primary_key(
-        "swaps_pkey",
-        "swaps",
-        ["block_number", "transaction_hash", "trace_address"],
-    )
-    op.create_index(
-        "arbitrage_swaps_swaps_idx",
-        "arbitrage_swaps",
-        ["swap_transaction_hash", "swap_trace_address"],
-    )
-
-
-def downgrade():
-    op.drop_index("arbitrage_swaps_swaps_idx")
-    op.execute("ALTER TABLE swaps DROP CONSTRAINT swaps_pkey CASCADE")
-    op.create_primary_key(
-        "swaps_pkey",
-        "swaps",
-        ["transaction_hash", "trace_address"],
-    )
-    op.create_foreign_key(
-        "arbitrage_swaps_swaps_fkey",
-        "arbitrage_swaps",
-        "swaps",
-        ["swap_transaction_hash", "swap_trace_address"],
-        ["transaction_hash", "trace_address"],
-    )

alembic/versions/52d75a7e0533_add_punk_bid_acceptances.py

@@ -1,33 +0,0 @@
-"""empty message
-
-Revision ID: 52d75a7e0533
-Revises: 7cf0eeb41da0
-Create Date: 2021-11-26 20:35:58.954138
-
-"""
-import sqlalchemy as sa
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "52d75a7e0533"
-down_revision = "7cf0eeb41da0"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.create_table(
-        "punk_bid_acceptances",
-        sa.Column("created_at", sa.TIMESTAMP, server_default=sa.func.now()),
-        sa.Column("block_number", sa.Numeric, nullable=False),
-        sa.Column("transaction_hash", sa.String(66), nullable=False),
-        sa.Column("trace_address", sa.String(256), nullable=False),
-        sa.Column("from_address", sa.String(256), nullable=False),
-        sa.Column("punk_index", sa.Numeric, nullable=False),
-        sa.Column("min_price", sa.Numeric, nullable=False),
-        sa.PrimaryKeyConstraint("block_number", "transaction_hash", "trace_address"),
-    )
-
-
-def downgrade():
-    op.drop_table("punk_bid_acceptances")

alembic/versions/5427d62a2cc0_change_transfers_trace_address_to_array.py

@@ -1,46 +0,0 @@
-"""Change transfers trace address to ARRAY
-
-Revision ID: 5427d62a2cc0
-Revises: d540242ae368
-Create Date: 2021-11-19 13:25:11.252774
-
-"""
-import sqlalchemy as sa
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "5427d62a2cc0"
-down_revision = "d540242ae368"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.drop_constraint("transfers_pkey", "transfers")
-    op.alter_column(
-        "transfers",
-        "trace_address",
-        type_=sa.ARRAY(sa.Integer),
-        nullable=False,
-        postgresql_using="trace_address::int[]",
-    )
-    op.create_primary_key(
-        "transfers_pkey",
-        "transfers",
-        ["block_number", "transaction_hash", "trace_address"],
-    )
-
-
-def downgrade():
-    op.drop_constraint("transfers_pkey", "transfers")
-    op.alter_column(
-        "transfers",
-        "trace_address",
-        type_=sa.String(256),
-        nullable=False,
-    )
-    op.create_primary_key(
-        "transfers_pkey",
-        "transfers",
-        ["block_number", "transaction_hash", "trace_address"],
-    )

alembic/versions/7cf0eeb41da0_add_punk_bids.py

@@ -1,33 +0,0 @@
-"""empty message
-
-Revision ID: 7cf0eeb41da0
-Revises: d498bdb0a641
-Create Date: 2021-11-26 20:27:28.936516
-
-"""
-import sqlalchemy as sa
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "7cf0eeb41da0"
-down_revision = "d498bdb0a641"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.create_table(
-        "punk_bids",
-        sa.Column("created_at", sa.TIMESTAMP, server_default=sa.func.now()),
-        sa.Column("block_number", sa.Numeric, nullable=False),
-        sa.Column("transaction_hash", sa.String(66), nullable=False),
-        sa.Column("trace_address", sa.String(256), nullable=False),
-        sa.Column("from_address", sa.String(256), nullable=False),
-        sa.Column("punk_index", sa.Numeric, nullable=False),
-        sa.Column("price", sa.Numeric, nullable=False),
-        sa.PrimaryKeyConstraint("block_number", "transaction_hash", "trace_address"),
-    )
-
-
-def downgrade():
-    op.drop_table("punk_bids")

alembic/versions/7eec417a4f3e_change_trace_addresses_to_array_types.py

@@ -1,49 +0,0 @@
-"""Change trace addresses to array types
-
-Revision ID: 7eec417a4f3e
-Revises: 9d8c69b3dccb
-Create Date: 2021-08-06 15:58:04.556762
-
-"""
-import sqlalchemy as sa
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "7eec417a4f3e"
-down_revision = "9d8c69b3dccb"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.drop_constraint("swaps_pkey", "swaps")
-    op.drop_column("swaps", "trace_address")
-    op.add_column("swaps", sa.Column("trace_address", sa.ARRAY(sa.Integer)))
-    op.create_primary_key("swaps_pkey", "swaps", ["transaction_hash", "trace_address"])
-
-    op.drop_constraint("classified_traces_pkey", "classified_traces")
-    op.drop_column("classified_traces", "trace_address")
-    op.add_column("classified_traces", sa.Column("trace_address", sa.ARRAY(sa.Integer)))
-    op.create_primary_key(
-        "classified_traces_pkey",
-        "classified_traces",
-        ["transaction_hash", "trace_address"],
-    )
-
-
-def downgrade():
-    op.drop_constraint("swaps_pkey", "swaps")
-    op.drop_column("swaps", "trace_address")
-    op.add_column("swaps", sa.Column("trace_address", sa.String))
-
-    op.create_primary_key("swaps_pkey", "swaps", ["transaction_hash", "trace_address"])
-
-    op.drop_constraint("classified_traces_pkey", "classified_traces")
-    op.drop_column("classified_traces", "trace_address")
-    op.add_column("classified_traces", sa.Column("trace_address", sa.String))
-
-    op.create_primary_key(
-        "classified_traces_pkey",
-        "classified_traces",
-        ["transaction_hash", "trace_address"],
-    )

alembic/versions/92f28a2b4f52_add_error_column_to_swaps.py

@@ -1,23 +0,0 @@
-"""Add error column to swaps
-
-Revision ID: 92f28a2b4f52
-Revises: 9b8ae51c5d56
-Create Date: 2021-08-17 03:46:21.498821
-
-"""
-import sqlalchemy as sa
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "92f28a2b4f52"
-down_revision = "9b8ae51c5d56"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.add_column("swaps", sa.Column("error", sa.String(256), nullable=True))
-
-
-def downgrade():
-    op.drop_column("swaps", "error")

alembic/versions/9b8ae51c5d56_add_swap_arbitrage_join_table.py

@@ -1,37 +0,0 @@
-"""Add swap arbitrage join table
-
-Revision ID: 9b8ae51c5d56
-Revises: 7eec417a4f3e
-Create Date: 2021-08-06 17:06:55.364516
-
-"""
-import sqlalchemy as sa
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "9b8ae51c5d56"
-down_revision = "7eec417a4f3e"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.create_table(
-        "arbitrage_swaps",
-        sa.Column("created_at", sa.TIMESTAMP, server_default=sa.func.now()),
-        sa.Column("arbitrage_id", sa.String(1024), primary_key=True),
-        sa.Column("swap_transaction_hash", sa.String(66), primary_key=True),
-        sa.Column("swap_trace_address", sa.ARRAY(sa.Integer), primary_key=True),
-        sa.ForeignKeyConstraint(
-            ["arbitrage_id"], ["arbitrages.id"], ondelete="CASCADE"
-        ),
-        sa.ForeignKeyConstraint(
-            ["swap_transaction_hash", "swap_trace_address"],
-            ["swaps.transaction_hash", "swaps.trace_address"],
-            ondelete="CASCADE",
-        ),
-    )
-
-
-def downgrade():
-    op.drop_table("arbitrage_swaps")

alembic/versions/9d8c69b3dccb_add_arbitrages_and_swap_join_table.py

@@ -1,34 +0,0 @@
-"""Add arbitrages and swap join table
-
-Revision ID: 9d8c69b3dccb
-Revises: 2116e2f36a19
-Create Date: 2021-08-05 21:46:35.209199
-
-"""
-import sqlalchemy as sa
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "9d8c69b3dccb"
-down_revision = "2116e2f36a19"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.create_table(
-        "arbitrages",
-        sa.Column("id", sa.String(256), primary_key=True),
-        sa.Column("created_at", sa.TIMESTAMP, server_default=sa.func.now()),
-        sa.Column("account_address", sa.String(256), nullable=False),
-        sa.Column("profit_token_address", sa.String(256), nullable=False),
-        sa.Column("block_number", sa.Numeric, nullable=False),
-        sa.Column("transaction_hash", sa.String(256), nullable=False),
-        sa.Column("start_amount", sa.Numeric, nullable=False),
-        sa.Column("end_amount", sa.Numeric, nullable=False),
-        sa.Column("profit_amount", sa.Numeric, nullable=False),
-    )
-
-
-def downgrade():
-    op.drop_table("arbitrages")

alembic/versions/a02f3f2c469f_create_latest_block_table.py

@@ -1,27 +0,0 @@
-"""Create latest block table
-
-Revision ID: a02f3f2c469f
-Revises: d70c08b4db6f
-Create Date: 2021-09-13 21:32:27.181344
-
-"""
-import sqlalchemy as sa
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "a02f3f2c469f"
-down_revision = "d70c08b4db6f"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.create_table(
-        "latest_block_update",
-        sa.Column("block_number", sa.Numeric, primary_key=True),
-        sa.Column("updated_at", sa.TIMESTAMP, server_default=sa.func.now()),
-    )
-
-
-def downgrade():
-    op.drop_table("latest_block_update")

alembic/versions/a10d68643476_change_classified_traces_primary_key_to_.py

@@ -1,34 +0,0 @@
-"""Change classified traces primary key to include block number
-
-Revision ID: a10d68643476
-Revises: 3417f49d97b3
-Create Date: 2021-11-02 22:03:26.312317
-
-"""
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "a10d68643476"
-down_revision = "3417f49d97b3"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.execute("ALTER TABLE classified_traces DROP CONSTRAINT classified_traces_pkey")
-    op.create_primary_key(
-        "classified_traces_pkey",
-        "classified_traces",
-        ["block_number", "transaction_hash", "trace_address"],
-    )
-    op.drop_index("i_block_number")
-
-
-def downgrade():
-    op.execute("ALTER TABLE classified_traces DROP CONSTRAINT classified_traces_pkey")
-    op.create_index("i_block_number", "classified_traces", ["block_number"])
-    op.create_primary_key(
-        "classified_traces_pkey",
-        "classified_traces",
-        ["transaction_hash", "trace_address"],
-    )

alembic/versions/b9fa1ecc9929_remove_liq_column.py

@@ -1,26 +0,0 @@
-"""Remove collateral_token_address column
-
-Revision ID: b9fa1ecc9929
-Revises: 04b76ab1d2af
-Create Date: 2021-12-01 23:32:40.574108
-
-"""
-import sqlalchemy as sa
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "b9fa1ecc9929"
-down_revision = "04b76ab1d2af"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.drop_column("liquidations", "collateral_token_address")
-
-
-def downgrade():
-    op.add_column(
-        "liquidations",
-        sa.Column("collateral_token_address", sa.String(256), nullable=False),
-    )

alembic/versions/c5da44eb072c_add_index_for_classified_traces_block_.py

@@ -6,17 +6,19 @@ Create Date: 2021-07-30 17:37:27.335475
 
 """
 from alembic import op
+import sqlalchemy as sa
+
 
 # revision identifiers, used by Alembic.
-revision = "c5da44eb072c"
-down_revision = "0660432b9840"
+revision = 'c5da44eb072c'
+down_revision = '0660432b9840'
 branch_labels = None
 depends_on = None
 
 
 def upgrade():
-    op.create_index("i_block_number", "classified_traces", ["block_number"])
+    op.create_index('i_block_number', 'classified_traces', ['block_number'])
 
 
 def downgrade():
-    op.drop_index("i_block_number", "classified_traces")
+    op.drop_index('i_block_number', 'classified_traces')

alembic/versions/c8363617aa07_create_liquidations_table.py

@@ -1,37 +0,0 @@
-"""Create liquidations table
-
-Revision ID: c8363617aa07
-Revises: cd96af55108e
-Create Date: 2021-09-29 14:00:06.857103
-
-"""
-import sqlalchemy as sa
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "c8363617aa07"
-down_revision = "cd96af55108e"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.create_table(
-        "liquidations",
-        sa.Column("created_at", sa.TIMESTAMP, server_default=sa.func.now()),
-        sa.Column("liquidated_user", sa.String(256), nullable=False),
-        sa.Column("liquidator_user", sa.String(256), nullable=False),
-        sa.Column("collateral_token_address", sa.String(256), nullable=False),
-        sa.Column("debt_token_address", sa.String(256), nullable=False),
-        sa.Column("debt_purchase_amount", sa.Numeric, nullable=False),
-        sa.Column("received_amount", sa.Numeric, nullable=False),
-        sa.Column("protocol", sa.String(256), nullable=True),
-        sa.Column("transaction_hash", sa.String(66), nullable=False),
-        sa.Column("trace_address", sa.String(256), nullable=False),
-        sa.Column("block_number", sa.Numeric, nullable=False),
-        sa.PrimaryKeyConstraint("transaction_hash", "trace_address"),
-    )
-
-
-def downgrade():
-    op.drop_table("liquidations")

alembic/versions/cd96af55108e_add_transfers_table.py

@@ -1,38 +0,0 @@
-"""Add transfers table
-
-Revision ID: cd96af55108e
-Revises: 5437dc68f4df
-Create Date: 2021-09-17 12:44:45.245137
-
-"""
-import sqlalchemy as sa
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "cd96af55108e"
-down_revision = "320e56b0a99f"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.create_table(
-        "transfers",
-        sa.Column("created_at", sa.TIMESTAMP, server_default=sa.func.now()),
-        sa.Column("block_number", sa.Numeric, nullable=False),
-        sa.Column("transaction_hash", sa.String(66), nullable=False),
-        sa.Column("trace_address", sa.String(256), nullable=False),
-        sa.Column("protocol", sa.String(256), nullable=True),
-        sa.Column("from_address", sa.String(256), nullable=False),
-        sa.Column("to_address", sa.String(256), nullable=False),
-        sa.Column("token_address", sa.String(256), nullable=False),
-        sa.Column("amount", sa.Numeric, nullable=False),
-        sa.Column("error", sa.String(256), nullable=True),
-        sa.PrimaryKeyConstraint("transaction_hash", "trace_address"),
-    )
-    op.create_index("ix_transfers_block_number", "transfers", ["block_number"])
-
-
-def downgrade():
-    op.drop_index("ix_transfers_block_number", "transfers")
-    op.drop_table("transfers")

alembic/versions/d540242ae368_create_usd_prices_table.py

@@ -1,29 +0,0 @@
-"""Create usd_prices table
-
-Revision ID: d540242ae368
-Revises: 2c90b2b8a80b
-Create Date: 2021-11-18 04:30:06.802857
-
-"""
-import sqlalchemy as sa
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "d540242ae368"
-down_revision = "2c90b2b8a80b"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.create_table(
-        "prices",
-        sa.Column("timestamp", sa.TIMESTAMP),
-        sa.Column("usd_price", sa.Numeric, nullable=False),
-        sa.Column("token_address", sa.String(256), nullable=False),
-        sa.PrimaryKeyConstraint("token_address", "timestamp"),
-    )
-
-
-def downgrade():
-    op.drop_table("prices")

alembic/versions/d70c08b4db6f_add_to_address_and_from_address_to_.py

@@ -1,31 +0,0 @@
-"""Add to_address and from_address to miner_payments table
-
-Revision ID: d70c08b4db6f
-Revises: 083978d6e455
-Create Date: 2021-08-30 22:10:04.186251
-
-"""
-import sqlalchemy as sa
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "d70c08b4db6f"
-down_revision = "083978d6e455"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.add_column(
-        "miner_payments",
-        sa.Column("transaction_to_address", sa.String(256), nullable=True),
-    )
-    op.add_column(
-        "miner_payments",
-        sa.Column("transaction_from_address", sa.String(256), nullable=True),
-    )
-
-
-def downgrade():
-    op.drop_column("miner_payments", "transaction_to_address")
-    op.drop_column("miner_payments", "transaction_from_address")

alembic/versions/ead7eb8283b9_create_sandwiches_and_sandwiched_swaps_.py

@@ -1,69 +0,0 @@
-"""Create sandwiches and sandwiched swaps tables
-
-Revision ID: ead7eb8283b9
-Revises: a5d80460f0e6
-Create Date: 2021-12-03 16:37:28.077158
-
-"""
-import sqlalchemy as sa
-from alembic import op
-
-# revision identifiers, used by Alembic.
-revision = "ead7eb8283b9"
-down_revision = "52d75a7e0533"
-branch_labels = None
-depends_on = None
-
-
-def upgrade():
-    op.create_table(
-        "sandwiches",
-        sa.Column("id", sa.String(256), primary_key=True),
-        sa.Column("created_at", sa.TIMESTAMP, server_default=sa.func.now()),
-        sa.Column("block_number", sa.Numeric, nullable=False),
-        sa.Column("sandwicher_address", sa.String(256), nullable=False),
-        sa.Column("frontrun_swap_transaction_hash", sa.String(256), nullable=False),
-        sa.Column("frontrun_swap_trace_address", sa.ARRAY(sa.Integer), nullable=False),
-        sa.Column("backrun_swap_transaction_hash", sa.String(256), nullable=False),
-        sa.Column("backrun_swap_trace_address", sa.ARRAY(sa.Integer), nullable=False),
-    )
-
-    op.create_index(
-        "ik_sandwiches_frontrun",
-        "sandwiches",
-        [
-            "block_number",
-            "frontrun_swap_transaction_hash",
-            "frontrun_swap_trace_address",
-        ],
-    )
-
-    op.create_index(
-        "ik_sandwiches_backrun",
-        "sandwiches",
-        ["block_number", "backrun_swap_transaction_hash", "backrun_swap_trace_address"],
-    )
-
-    op.create_table(
-        "sandwiched_swaps",
-        sa.Column("created_at", sa.TIMESTAMP, server_default=sa.func.now()),
-        sa.Column("sandwich_id", sa.String(1024), primary_key=True),
-        sa.Column("block_number", sa.Numeric, primary_key=True),
-        sa.Column("transaction_hash", sa.String(66), primary_key=True),
-        sa.Column("trace_address", sa.ARRAY(sa.Integer), primary_key=True),
-        sa.ForeignKeyConstraint(["sandwich_id"], ["sandwiches.id"], ondelete="CASCADE"),
-    )
-
-    op.create_index(
-        "ik_sandwiched_swaps_secondary",
-        "sandwiched_swaps",
-        ["block_number", "transaction_hash", "trace_address"],
-    )
-
-
-def downgrade():
-    op.drop_index("ik_sandwiched_swaps_secondary")
-    op.drop_table("sandwiched_swaps")
-    op.drop_index("ik_sandwiches_frontrun")
-    op.drop_index("ik_sandwiches_backrun")
-    op.drop_table("sandwiches")

backfill.py

@@ -1,57 +0,0 @@
-import subprocess
-import sys
-from typing import Iterator, Tuple
-
-
-def get_block_after_before_chunks(
-    after_block: int,
-    before_block: int,
-    n_workers: int,
-) -> Iterator[Tuple[int, int]]:
-    n_blocks = before_block - after_block
-    remainder = n_blocks % n_workers
-    floor_chunk_size = n_blocks // n_workers
-
-    last_before_block = None
-
-    for worker_index in range(n_workers):
-        chunk_size = floor_chunk_size
-
-        if worker_index < remainder:
-            chunk_size += 1
-
-        batch_after_block = (
-            last_before_block if last_before_block is not None else after_block
-        )
-
-        batch_before_block = batch_after_block + chunk_size
-        yield batch_after_block, batch_before_block
-        last_before_block = batch_before_block
-
-
-def backfill(after_block: int, before_block: int, n_workers: int):
-    if n_workers <= 0:
-        raise ValueError("Need at least one worker")
-
-    for batch_after_block, batch_before_block in get_block_after_before_chunks(
-        after_block,
-        before_block,
-        n_workers,
-    ):
-        print(f"Backfilling {batch_after_block} to {batch_before_block}")
-        backfill_command = f"sh backfill.sh {batch_after_block} {batch_before_block}"
-        process = subprocess.Popen(backfill_command.split(), stdout=subprocess.PIPE)
-        output, _ = process.communicate()
-        print(output)
-
-
-def main():
-    after_block = int(sys.argv[1])
-    before_block = int(sys.argv[2])
-    n_workers = int(sys.argv[3])
-
-    backfill(after_block, before_block, n_workers)
-
-
-if __name__ == "__main__":
-    main()

backfill.sh

@@ -1,6 +0,0 @@
-current_image=$(kubectl get deployment mev-inspect -o=jsonpath='{$.spec.template.spec.containers[:1].image}')
-
-helm template mev-inspect-backfill ./k8s/mev-inspect-backfill \
-    --set image.repository=$current_image \
-    --set command.startBlockNumber=$1 \
-    --set command.endBlockNumber=$2 | kubectl apply -f -

cli.py

@@ -1,102 +0,0 @@
-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, inspect_db_session, trace_db_session)
-    await inspector.inspect_single_block(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):
-    inspect_db_session = get_inspect_session()
-    trace_db_session = get_trace_session()
-
-    inspector = MEVInspector(rpc, inspect_db_session, trace_db_session)
-    block = await inspector.create_from_block(block_number=block_number)
-    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,
-        inspect_db_session,
-        trace_db_session,
-        max_concurrency=max_concurrency,
-        request_timeout=request_timeout,
-    )
-    await inspector.inspect_many_blocks(
-        after_block=after_block, before_block=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()

docker-compose.yml

@@ -0,0 +1,33 @@
+services:
+  mev-inspect:
+    build: .
+    depends_on:
+      - db
+    env_file:
+      - .env
+    volumes:
+      - .:/app
+    tty: true
+
+  db:
+    image: postgres:12
+    volumes:
+      - mev-inspect-db-data:/var/lib/postgresql/data/pgdata
+    env_file:
+      - .env
+    environment:
+      - PGDATA=/var/lib/postgresql/data/pgdata
+
+  pgadmin:
+    image: dpage/pgadmin4
+    networks:
+      - default
+    depends_on:
+      - db
+    env_file:
+      - .env
+    ports:
+      - "5050:5050"
+
+volumes:
+  mev-inspect-db-data:

k8s/mev-inspect-backfill/.helmignore

@@ -1,23 +0,0 @@
-# Patterns to ignore when building packages.
-# This supports shell glob matching, relative path matching, and
-# negation (prefixed with !). Only one pattern per line.
-.DS_Store
-# Common VCS dirs
-.git/
-.gitignore
-.bzr/
-.bzrignore
-.hg/
-.hgignore
-.svn/
-# Common backup files
-*.swp
-*.bak
-*.tmp
-*.orig
-*~
-# Various IDEs
-.project
-.idea/
-*.tmproj
-.vscode/

k8s/mev-inspect-backfill/Chart.yaml

@@ -1,24 +0,0 @@
-apiVersion: v2
-name: mev-inspect-backfill
-description: A Helm chart for Kubernetes
-
-# A chart can be either an 'application' or a 'library' chart.
-#
-# Application charts are a collection of templates that can be packaged into versioned archives
-# to be deployed.
-#
-# Library charts provide useful utilities or functions for the chart developer. They're included as
-# a dependency of application charts to inject those utilities and functions into the rendering
-# pipeline. Library charts do not define any templates and therefore cannot be deployed.
-type: application
-
-# This is the chart version. This version number should be incremented each time you make changes
-# to the chart and its templates, including the app version.
-# Versions are expected to follow Semantic Versioning (https://semver.org/)
-version: 0.1.0
-
-# This is the version number of the application being deployed. This version number should be
-# incremented each time you make changes to the application. Versions are not expected to
-# follow Semantic Versioning. They should reflect the version the application is using.
-# It is recommended to use it with quotes.
-appVersion: "1.16.0"

k8s/mev-inspect-backfill/templates/_helpers.tpl

@@ -1,62 +0,0 @@
-{{/*
-Expand the name of the chart.
-*/}}
-{{- define "mev-inspect-backfill.name" -}}
-{{- default .Chart.Name .Values.nameOverride | trunc 63 | trimSuffix "-" }}
-{{- end }}
-
-{{/*
-Create a default fully qualified app name.
-We truncate at 63 chars because some Kubernetes name fields are limited to this (by the DNS naming spec).
-If release name contains chart name it will be used as a full name.
-*/}}
-{{- define "mev-inspect-backfill.fullname" -}}
-{{- if .Values.fullnameOverride }}
-{{- .Values.fullnameOverride | trunc 63 | trimSuffix "-" }}
-{{- else }}
-{{- $name := default .Chart.Name .Values.nameOverride }}
-{{- if contains $name .Release.Name }}
-{{- .Release.Name | trunc 63 | trimSuffix "-" }}
-{{- else }}
-{{- printf "%s-%s" .Release.Name $name | trunc 63 | trimSuffix "-" }}
-{{- end }}
-{{- end }}
-{{- end }}
-
-{{/*
-Create chart name and version as used by the chart label.
-*/}}
-{{- define "mev-inspect-backfill.chart" -}}
-{{- printf "%s-%s" .Chart.Name .Chart.Version | replace "+" "_" | trunc 63 | trimSuffix "-" }}
-{{- end }}
-
-{{/*
-Common labels
-*/}}
-{{- define "mev-inspect-backfill.labels" -}}
-helm.sh/chart: {{ include "mev-inspect-backfill.chart" . }}
-{{ include "mev-inspect-backfill.selectorLabels" . }}
-{{- if .Chart.AppVersion }}
-app.kubernetes.io/version: {{ .Chart.AppVersion | quote }}
-{{- end }}
-app.kubernetes.io/managed-by: {{ .Release.Service }}
-{{- end }}
-
-{{/*
-Selector labels
-*/}}
-{{- define "mev-inspect-backfill.selectorLabels" -}}
-app.kubernetes.io/name: {{ include "mev-inspect-backfill.name" . }}
-app.kubernetes.io/instance: {{ .Release.Name }}
-{{- end }}
-
-{{/*
-Create the name of the service account to use
-*/}}
-{{- define "mev-inspect-backfill.serviceAccountName" -}}
-{{- if .Values.serviceAccount.create }}
-{{- default (include "mev-inspect-backfill.fullname" .) .Values.serviceAccount.name }}
-{{- else }}
-{{- default "default" .Values.serviceAccount.name }}
-{{- end }}
-{{- end }}

k8s/mev-inspect-backfill/templates/job.yaml

@@ -1,68 +0,0 @@
-apiVersion: batch/v1
-kind: Job
-metadata:
-  name: {{ include "mev-inspect-backfill.fullname" . }}-{{ randAlphaNum 5 | lower }}
-  labels:
-    {{- include "mev-inspect-backfill.labels" . | nindent 4 }}
-spec:
-  completions: 1
-  parallelism: 1
-  ttlSecondsAfterFinished: 5
-  template:
-    metadata:
-      {{- with .Values.podAnnotations }}
-      annotations:
-        {{- toYaml . | nindent 8 }}
-      {{- end }}
-    spec:
-      containers:
-        - name: {{ .Chart.Name }}
-          securityContext:
-            {{- toYaml .Values.securityContext | nindent 12 }}
-          image: "{{ .Values.image.repository }}"
-          imagePullPolicy: {{ .Values.image.pullPolicy }}
-          args:
-            - run
-            - inspect-many-blocks
-            - {{ .Values.command.startBlockNumber | quote }}
-            - {{ .Values.command.endBlockNumber | quote }}
-          env:
-          - name: POSTGRES_HOST
-            valueFrom:
-              secretKeyRef:
-                name: mev-inspect-db-credentials
-                key: host
-          - name: POSTGRES_USER
-            valueFrom:
-              secretKeyRef:
-                name: mev-inspect-db-credentials
-                key: username
-          - name: POSTGRES_PASSWORD
-            valueFrom:
-              secretKeyRef:
-                name: mev-inspect-db-credentials
-                key: password
-          - name: TRACE_DB_HOST
-            valueFrom:
-              secretKeyRef:
-                name: trace-db-credentials
-                key: host
-                optional: true
-          - name: TRACE_DB_USER
-            valueFrom:
-              secretKeyRef:
-                name: trace-db-credentials
-                key: username
-                optional: true
-          - name: TRACE_DB_PASSWORD
-            valueFrom:
-              secretKeyRef:
-                name: trace-db-credentials
-                key: password
-                optional: true
-          - name: RPC_URL
-            valueFrom:
-              configMapKeyRef:
-                name: mev-inspect-rpc
-                key: url
-      restartPolicy: OnFailure

k8s/mev-inspect-backfill/values.yaml

@@ -1,42 +0,0 @@
-# Default values for mev-inspect.
-# This is a YAML-formatted file.
-# Declare variables to be passed into your templates.
-
-image:
-  repository: mev-inspect-py
-  pullPolicy: IfNotPresent
-
-imagePullSecrets: []
-nameOverride: ""
-fullnameOverride: ""
-
-podAnnotations: {}
-
-podSecurityContext: {}
-  # fsGroup: 2000
-
-securityContext: {}
-  # capabilities:
-  #   drop:
-  #   - ALL
-  # readOnlyRootFilesystem: true
-  # runAsNonRoot: true
-  # runAsUser: 1000
-
-resources: {}
-  # We usually recommend not to specify default resources and to leave this as a conscious
-  # choice for the user. This also increases chances charts run on environments with little
-  # resources, such as Minikube. If you do want to specify resources, uncomment the following
-  # lines, adjust them as necessary, and remove the curly braces after 'resources:'.
-  # limits:
-  #   cpu: 100m
-  #   memory: 128Mi
-  # requests:
-  #   cpu: 100m
-  #   memory: 128Mi
-
-nodeSelector: {}
-
-tolerations: []
-
-affinity: {}

k8s/mev-inspect-prices/.helmignore

@@ -1,23 +0,0 @@
-# Patterns to ignore when building packages.
-# This supports shell glob matching, relative path matching, and
-# negation (prefixed with !). Only one pattern per line.
-.DS_Store
-# Common VCS dirs
-.git/
-.gitignore
-.bzr/
-.bzrignore
-.hg/
-.hgignore
-.svn/
-# Common backup files
-*.swp
-*.bak
-*.tmp
-*.orig
-*~
-# Various IDEs
-.project
-.idea/
-*.tmproj
-.vscode/

k8s/mev-inspect-prices/Chart.yaml

@@ -1,24 +0,0 @@
-apiVersion: v2
-name: mev-inspect-prices
-description: A Helm chart for Kubernetes
-
-# A chart can be either an 'application' or a 'library' chart.
-#
-# Application charts are a collection of templates that can be packaged into versioned archives
-# to be deployed.
-#
-# Library charts provide useful utilities or functions for the chart developer. They're included as
-# a dependency of application charts to inject those utilities and functions into the rendering
-# pipeline. Library charts do not define any templates and therefore cannot be deployed.
-type: application
-
-# This is the chart version. This version number should be incremented each time you make changes
-# to the chart and its templates, including the app version.
-# Versions are expected to follow Semantic Versioning (https://semver.org/)
-version: 0.1.0
-
-# This is the version number of the application being deployed. This version number should be
-# incremented each time you make changes to the application. Versions are not expected to
-# follow Semantic Versioning. They should reflect the version the application is using.
-# It is recommended to use it with quotes.
-appVersion: "1.16.0"

k8s/mev-inspect-prices/templates/_helpers.tpl

@@ -1,62 +0,0 @@
-{{/*
-Expand the name of the chart.
-*/}}
-{{- define "mev-inspect-prices.name" -}}
-{{- default .Chart.Name .Values.nameOverride | trunc 63 | trimSuffix "-" }}
-{{- end }}
-
-{{/*
-Create a default fully qualified app name.
-We truncate at 63 chars because some Kubernetes name fields are limited to this (by the DNS naming spec).
-If release name contains chart name it will be used as a full name.
-*/}}
-{{- define "mev-inspect-prices.fullname" -}}
-{{- if .Values.fullnameOverride }}
-{{- .Values.fullnameOverride | trunc 63 | trimSuffix "-" }}
-{{- else }}
-{{- $name := default .Chart.Name .Values.nameOverride }}
-{{- if contains $name .Release.Name }}
-{{- .Release.Name | trunc 63 | trimSuffix "-" }}
-{{- else }}
-{{- printf "%s-%s" .Release.Name $name | trunc 63 | trimSuffix "-" }}
-{{- end }}
-{{- end }}
-{{- end }}
-
-{{/*
-Create chart name and version as used by the chart label.
-*/}}
-{{- define "mev-inspect-prices.chart" -}}
-{{- printf "%s-%s" .Chart.Name .Chart.Version | replace "+" "_" | trunc 63 | trimSuffix "-" }}
-{{- end }}
-
-{{/*
-Common labels
-*/}}
-{{- define "mev-inspect-prices.labels" -}}
-helm.sh/chart: {{ include "mev-inspect-prices.chart" . }}
-{{ include "mev-inspect-prices.selectorLabels" . }}
-{{- if .Chart.AppVersion }}
-app.kubernetes.io/version: {{ .Chart.AppVersion | quote }}
-{{- end }}
-app.kubernetes.io/managed-by: {{ .Release.Service }}
-{{- end }}
-
-{{/*
-Selector labels
-*/}}
-{{- define "mev-inspect-prices.selectorLabels" -}}
-app.kubernetes.io/name: {{ include "mev-inspect-prices.name" . }}
-app.kubernetes.io/instance: {{ .Release.Name }}
-{{- end }}
-
-{{/*
-Create the name of the service account to use
-*/}}
-{{- define "mev-inspect-prices.serviceAccountName" -}}
-{{- if .Values.serviceAccount.create }}
-{{- default (include "mev-inspect-prices.fullname" .) .Values.serviceAccount.name }}
-{{- else }}
-{{- default "default" .Values.serviceAccount.name }}
-{{- end }}
-{{- end }}

k8s/mev-inspect-prices/templates/cronjob.yaml

@@ -1,35 +0,0 @@
-apiVersion: batch/v1
-kind: CronJob
-metadata:
-  name: {{ include "mev-inspect-prices.fullname" . }}
-spec:
-  schedule: "0 */1 * * *"
-  successfulJobsHistoryLimit: 0
-  jobTemplate:
-    spec:
-      template:
-        spec:
-          containers:
-            - name: {{ .Chart.Name }}
-              image: "{{ .Values.image.repository }}"
-              imagePullPolicy: {{ .Values.image.pullPolicy }}
-              args:
-              - run
-              - fetch-all-prices
-              env:
-              - name: POSTGRES_HOST
-                valueFrom:
-                  secretKeyRef:
-                    name: mev-inspect-db-credentials
-                    key: host
-              - name: POSTGRES_USER
-                valueFrom:
-                  secretKeyRef:
-                    name: mev-inspect-db-credentials
-                    key: username
-              - name: POSTGRES_PASSWORD
-                valueFrom:
-                  secretKeyRef:
-                    name: mev-inspect-db-credentials
-                    key: password
-          restartPolicy: Never

k8s/mev-inspect-prices/values.yaml

@@ -1,7 +0,0 @@
-image:
-  repository: mev-inspect-py
-  pullPolicy: IfNotPresent
-
-imagePullSecrets: []
-nameOverride: ""
-fullnameOverride: ""

k8s/mev-inspect/.helmignore

@@ -1,23 +0,0 @@
-# Patterns to ignore when building packages.
-# This supports shell glob matching, relative path matching, and
-# negation (prefixed with !). Only one pattern per line.
-.DS_Store
-# Common VCS dirs
-.git/
-.gitignore
-.bzr/
-.bzrignore
-.hg/
-.hgignore
-.svn/
-# Common backup files
-*.swp
-*.bak
-*.tmp
-*.orig
-*~
-# Various IDEs
-.project
-.idea/
-*.tmproj
-.vscode/

k8s/mev-inspect/Chart.yaml

@@ -1,24 +0,0 @@
-apiVersion: v2
-name: mev-inspect
-description: A Helm chart for Kubernetes
-
-# A chart can be either an 'application' or a 'library' chart.
-#
-# Application charts are a collection of templates that can be packaged into versioned archives
-# to be deployed.
-#
-# Library charts provide useful utilities or functions for the chart developer. They're included as
-# a dependency of application charts to inject those utilities and functions into the rendering
-# pipeline. Library charts do not define any templates and therefore cannot be deployed.
-type: application
-
-# This is the chart version. This version number should be incremented each time you make changes
-# to the chart and its templates, including the app version.
-# Versions are expected to follow Semantic Versioning (https://semver.org/)
-version: 0.1.0
-
-# This is the version number of the application being deployed. This version number should be
-# incremented each time you make changes to the application. Versions are not expected to
-# follow Semantic Versioning. They should reflect the version the application is using.
-# It is recommended to use it with quotes.
-appVersion: "1.16.0"

k8s/mev-inspect/templates/_helpers.tpl

@@ -1,62 +0,0 @@
-{{/*
-Expand the name of the chart.
-*/}}
-{{- define "mev-inspect.name" -}}
-{{- default .Chart.Name .Values.nameOverride | trunc 63 | trimSuffix "-" }}
-{{- end }}
-
-{{/*
-Create a default fully qualified app name.
-We truncate at 63 chars because some Kubernetes name fields are limited to this (by the DNS naming spec).
-If release name contains chart name it will be used as a full name.
-*/}}
-{{- define "mev-inspect.fullname" -}}
-{{- if .Values.fullnameOverride }}
-{{- .Values.fullnameOverride | trunc 63 | trimSuffix "-" }}
-{{- else }}
-{{- $name := default .Chart.Name .Values.nameOverride }}
-{{- if contains $name .Release.Name }}
-{{- .Release.Name | trunc 63 | trimSuffix "-" }}
-{{- else }}
-{{- printf "%s-%s" .Release.Name $name | trunc 63 | trimSuffix "-" }}
-{{- end }}
-{{- end }}
-{{- end }}
-
-{{/*
-Create chart name and version as used by the chart label.
-*/}}
-{{- define "mev-inspect.chart" -}}
-{{- printf "%s-%s" .Chart.Name .Chart.Version | replace "+" "_" | trunc 63 | trimSuffix "-" }}
-{{- end }}
-
-{{/*
-Common labels
-*/}}
-{{- define "mev-inspect.labels" -}}
-helm.sh/chart: {{ include "mev-inspect.chart" . }}
-{{ include "mev-inspect.selectorLabels" . }}
-{{- if .Chart.AppVersion }}
-app.kubernetes.io/version: {{ .Chart.AppVersion | quote }}
-{{- end }}
-app.kubernetes.io/managed-by: {{ .Release.Service }}
-{{- end }}
-
-{{/*
-Selector labels
-*/}}
-{{- define "mev-inspect.selectorLabels" -}}
-app.kubernetes.io/name: {{ include "mev-inspect.name" . }}
-app.kubernetes.io/instance: {{ .Release.Name }}
-{{- end }}
-
-{{/*
-Create the name of the service account to use
-*/}}
-{{- define "mev-inspect.serviceAccountName" -}}
-{{- if .Values.serviceAccount.create }}
-{{- default (include "mev-inspect.fullname" .) .Values.serviceAccount.name }}
-{{- else }}
-{{- default "default" .Values.serviceAccount.name }}
-{{- end }}
-{{- end }}

k8s/mev-inspect/templates/deployment.yaml

@@ -1,99 +0,0 @@
-apiVersion: apps/v1
-kind: Deployment
-metadata:
-  name: {{ include "mev-inspect.fullname" . }}
-  labels:
-    {{- include "mev-inspect.labels" . | nindent 4 }}
-spec:
-  replicas: {{ .Values.replicaCount }}
-  selector:
-    matchLabels:
-      {{- include "mev-inspect.selectorLabels" . | nindent 6 }}
-  template:
-    metadata:
-      {{- with .Values.podAnnotations }}
-      annotations:
-        {{- toYaml . | nindent 8 }}
-      {{- end }}
-      labels:
-        {{- include "mev-inspect.selectorLabels" . | nindent 8 }}
-    spec:
-      {{- with .Values.imagePullSecrets }}
-      imagePullSecrets:
-        {{- toYaml . | nindent 8 }}
-      {{- end }}
-      securityContext:
-        {{- toYaml .Values.podSecurityContext | nindent 8 }}
-      containers:
-        - name: {{ .Chart.Name }}
-          securityContext:
-            {{- toYaml .Values.securityContext | nindent 12 }}
-          image: "{{ .Values.image.repository }}"
-          imagePullPolicy: {{ .Values.image.pullPolicy }}
-          args: ["run", "python", "loop.py"]
-          livenessProbe:
-            exec:
-              command:
-              - ls
-              - /
-            initialDelaySeconds: 20
-            periodSeconds: 5
-          resources:
-            {{- toYaml .Values.resources | nindent 12 }}
-          env:
-          - name: POSTGRES_HOST
-            valueFrom:
-              secretKeyRef:
-                name: mev-inspect-db-credentials
-                key: host
-          - name: POSTGRES_USER
-            valueFrom:
-              secretKeyRef:
-                name: mev-inspect-db-credentials
-                key: username
-          - name: POSTGRES_PASSWORD
-            valueFrom:
-              secretKeyRef:
-                name: mev-inspect-db-credentials
-                key: password
-          - name: TRACE_DB_HOST
-            valueFrom:
-              secretKeyRef:
-                name: trace-db-credentials
-                key: host
-                optional: true
-          - name: TRACE_DB_USER
-            valueFrom:
-              secretKeyRef:
-                name: trace-db-credentials
-                key: username
-                optional: true
-          - name: TRACE_DB_PASSWORD
-            valueFrom:
-              secretKeyRef:
-                name: trace-db-credentials
-                key: password
-                optional: true
-          - name: RPC_URL
-            valueFrom:
-              configMapKeyRef:
-                name: mev-inspect-rpc
-                key: url
-          - name: LISTENER_HEALTHCHECK_URL
-            valueFrom:
-              configMapKeyRef:
-                name: mev-inspect-listener-healthcheck
-                key: url
-                optional: true
-      {{- with .Values.nodeSelector }}
-      nodeSelector:
-        {{- toYaml . | nindent 8 }}
-      {{- end }}
-      {{- with .Values.affinity }}
-      affinity:
-        {{- toYaml . | nindent 8 }}
-      {{- end }}
-      {{- with .Values.tolerations }}
-      tolerations:
-        {{- toYaml . | nindent 8 }}
-      {{- end }}

k8s/mev-inspect/values.yaml

@@ -1,44 +0,0 @@
-# Default values for mev-inspect.
-# This is a YAML-formatted file.
-# Declare variables to be passed into your templates.
-
-replicaCount: 1
-
-image:
-  repository: mev-inspect-py:latest
-  pullPolicy: IfNotPresent
-
-imagePullSecrets: []
-nameOverride: ""
-fullnameOverride: ""
-
-podAnnotations: {}
-
-podSecurityContext: {}
-  # fsGroup: 2000
-
-securityContext: {}
-  # capabilities:
-  #   drop:
-  #   - ALL
-  # readOnlyRootFilesystem: true
-  # runAsNonRoot: true
-  # runAsUser: 1000
-
-resources: {}
-  # We usually recommend not to specify default resources and to leave this as a conscious
-  # choice for the user. This also increases chances charts run on environments with little
-  # resources, such as Minikube. If you do want to specify resources, uncomment the following
-  # lines, adjust them as necessary, and remove the curly braces after 'resources:'.
-  # limits:
-  #   cpu: 100m
-  #   memory: 128Mi
-  # requests:
-  #   cpu: 100m
-  #   memory: 128Mi
-
-nodeSelector: {}
-
-tolerations: []
-
-affinity: {}

liquidation_inspector.py

@@ -0,0 +1,105 @@
+# Internal imports
+from mev_inspect import utils
+from mev_inspect.config import load_config
+from mev_inspect.schemas.blocks import NestedTrace, TraceType
+from mev_inspect.schemas.classified_traces import Classification, ClassifiedTrace
+from mev_inspect.schemas.strategy import StrategyType, Strategy, Liquidation
+from mev_inspect.classifier_specs import CLASSIFIER_SPECS
+from mev_inspect.trace_classifier import TraceClassifier
+from mev_inspect import block
+
+# External Libraries
+import json
+import pandas as pd
+from typing import Optional
+from web3 import Web3
+from typing import List, Optional
+
+# TODO: adjust profit to new model
+#        unit test
+#        coinbase check / collateral source
+
+liquidations = []
+result = []
+
+# Protocol contract address must be in included, below is AaveLendingPoolCoreV1
+addrs = ['0x3dfd23A6c5E8BbcFc9581d2E864a68feb6a076d3']
+# Used to remove double-counted 'from' transfers
+from_doubles = []
+transfers_to = []
+transfers_from = []
+# Inspect list of classified traces and identify liquidation
+def find_liquidations(traces: List[ClassifiedTrace]):
+    tx = []
+
+    # For each trace
+    for count, trace in enumerate(traces):
+
+        # Check for liquidation and register trace and unique liquidator
+        if (
+            trace.classification == Classification.liquidate and
+            trace.transaction_hash not in tx
+            ):
+
+            liquidations.append(trace)
+            addrs.append(trace.from_address)
+            tx.append(trace.transaction_hash)
+
+            # Found liquidation, now parse inputs for data
+            for i in trace.inputs:
+
+                if(i == '_purchaseAmount'):
+                    liquidation_amount = trace.inputs[i]
+                elif (i == '_collateral'):
+                    collateral_type = trace.inputs[i]
+                    #This will be the address of the sent token
+                elif (i == '_reserve'):
+                    reserve = trace.inputs[i]
+                    #This will be the address of the received token
+                elif(i == '_user'):
+                    liquidated_usr = trace.inputs[i]
+            # Register liquidation
+            result.append(
+                            Liquidation(collateral_type=collateral_type,
+                                            collateral_amount=liquidation_amount,
+                                            collateral_source="",
+                                            reserve=reserve,
+                                            strategy=StrategyType.liquidation,
+                                            protocols=[trace.protocol],)
+                          )
+
+        # Check for transfer from a liquidator
+        elif (
+              trace.classification  ==  Classification.transfer and
+              'sender' in trace.inputs and
+              trace.inputs['sender'] in addrs and
+              trace.transaction_hash not in from_doubles
+             ):
+
+             #Add the transfer
+             liquidator = next(addrs[i] for i in range(len(addrs)) if trace.inputs['sender'] == addrs[i])
+             transfers_from.append(["from", liquidator, trace.transaction_hash, trace.inputs['amount']])
+             from_doubles.append(trace.transaction_hash)
+
+        # Check for transfer to a liquidator
+        elif (
+              trace.classification == Classification.transfer and
+              trace.inputs['recipient'] in addrs
+             ):
+             #Add the transfer
+             liquidator = next(addrs[i] for i in range(len(addrs)) if trace.inputs['recipient'] == addrs[i])
+             transfers_to.append(["to", liquidator, trace.transaction_hash, trace.inputs['amount']])
+
+    for count, trace in enumerate(liquidations):
+        tx = trace.transaction_hash
+        #convert token to ETH
+        #profit = transfers[count][2] - transfers[count+1][2]
+
+
+
+    #for count, trace in enumerate(transfers_to):
+        #profits.append({"liquidator" : transfers_to[count][1],
+                        #"transaction" : transfers_to[count][2],
+                        #"profit" : transfers_to[count][3] - transfers_from[count][3]})
+
+    return result

listener

@@ -1,50 +0,0 @@
-#!/bin/sh
-
-set -e
-
-NAME=listener
-PIDFILE=/var/run/$NAME.pid
-DAEMON=/root/.poetry/bin/poetry
-DAEMON_OPTS="run python listener.py"
-
-case "$1" in
-  start)
-        echo -n "Starting daemon: "$NAME
-	start-stop-daemon \
-        --background \
-        --chdir /app \
-        --start \
-        --quiet \
-        --pidfile $PIDFILE \
-        --make-pidfile \
-        --startas $DAEMON -- $DAEMON_OPTS
-        echo "."
-	;;
-  stop)
-        echo -n "Stopping daemon: "$NAME
-	start-stop-daemon --stop --quiet --oknodo --pidfile $PIDFILE
-        echo "."
-	;;
-  tail)
-        tail -f listener.log
-	;;
-  restart)
-        echo -n "Restarting daemon: "$NAME
-	start-stop-daemon --stop --quiet --oknodo --retry 30 --pidfile $PIDFILE
-	start-stop-daemon \
-        --background \
-        --chdir /app \
-        --start \
-        --quiet \
-        --pidfile $PIDFILE \
-        --make-pidfile \
-        --startas $DAEMON -- $DAEMON_OPTS
-        echo "."
-    ;;
-
-  *)
-	echo "Usage: "$1" {start|stop|restart|tail}"
-	exit 1
-esac
-
-exit 0

listener.py

@@ -1,98 +0,0 @@
-import asyncio
-import logging
-import os
-
-import aiohttp
-
-from mev_inspect.block import get_latest_block_number
-from mev_inspect.concurrency import coro
-from mev_inspect.crud.latest_block_update import (
-    find_latest_block_update,
-    update_latest_block,
-)
-from mev_inspect.db import get_inspect_session, get_trace_session
-from mev_inspect.inspector import MEVInspector
-from mev_inspect.provider import get_base_provider
-from mev_inspect.signal_handler import GracefulKiller
-
-logging.basicConfig(filename="listener.log", filemode="a", level=logging.INFO)
-logger = logging.getLogger(__name__)
-
-# lag to make sure the blocks we see are settled
-BLOCK_NUMBER_LAG = 5
-
-
-@coro
-async def run():
-    rpc = os.getenv("RPC_URL")
-    if rpc is None:
-        raise RuntimeError("Missing environment variable RPC_URL")
-
-    healthcheck_url = os.getenv("LISTENER_HEALTHCHECK_URL")
-
-    logger.info("Starting...")
-
-    killer = GracefulKiller()
-
-    inspect_db_session = get_inspect_session()
-    trace_db_session = get_trace_session()
-
-    inspector = MEVInspector(rpc, inspect_db_session, trace_db_session)
-    base_provider = get_base_provider(rpc)
-
-    while not killer.kill_now:
-        await inspect_next_block(
-            inspector,
-            inspect_db_session,
-            base_provider,
-            healthcheck_url,
-        )
-
-    logger.info("Stopping...")
-
-
-async def inspect_next_block(
-    inspector: MEVInspector,
-    inspect_db_session,
-    base_provider,
-    healthcheck_url,
-):
-    latest_block_number = await get_latest_block_number(base_provider)
-    last_written_block = find_latest_block_update(inspect_db_session)
-
-    logger.info(f"Latest block: {latest_block_number}")
-    logger.info(f"Last written block: {last_written_block}")
-
-    if last_written_block is None:
-        # maintain lag if no blocks written yet
-        last_written_block = latest_block_number - 1
-
-    if last_written_block < (latest_block_number - BLOCK_NUMBER_LAG):
-        block_number = (
-            latest_block_number
-            if last_written_block is None
-            else last_written_block + 1
-        )
-
-        logger.info(f"Writing block: {block_number}")
-
-        await inspector.inspect_single_block(block=block_number)
-        update_latest_block(inspect_db_session, block_number)
-
-        if healthcheck_url:
-            await ping_healthcheck_url(healthcheck_url)
-    else:
-        await asyncio.sleep(5)
-
-
-async def ping_healthcheck_url(url):
-    async with aiohttp.ClientSession() as session:
-        async with session.get(url):
-            pass
-
-
-if __name__ == "__main__":
-    try:
-        run()
-    except Exception as e:
-        logger.error(e)

loop.py

@@ -1,21 +0,0 @@
-import logging
-import time
-
-from mev_inspect.signal_handler import GracefulKiller
-
-logging.basicConfig(filename="loop.log", level=logging.INFO)
-logger = logging.getLogger(__name__)
-
-
-def run():
-    logger.info("Starting...")
-
-    killer = GracefulKiller()
-    while not killer.kill_now:
-        time.sleep(1)
-
-    logger.info("Stopping...")
-
-
-if __name__ == "__main__":
-    run()

mev

@@ -1,82 +0,0 @@
-#!/usr/bin/env bash
-
-set -e
-
-DB_NAME=mev_inspect
-
-function get_kube_db_secret(){
-    kubectl get secrets mev-inspect-db-credentials -o jsonpath="{.data.$1}" | base64 --decode
-}
-
-function db(){
-    host=$(get_kube_db_secret "host")
-    username=$(get_kube_db_secret "username")
-    password=$(get_kube_db_secret "password")
-
-    kubectl run -i --rm --tty postgres-client \
-        --env="PGPASSWORD=$password"  \
-        --image=jbergknoff/postgresql-client \
-        -- $DB_NAME --host=$host --user=$username
-}
-
-case "$1" in
-  db)
-        echo "Connecting to $DB_NAME"
-        db
-	;;
-  listener)
-        kubectl exec -ti deploy/mev-inspect -- ./listener $2
-	;;
-  backfill)
-        start_block_number=$2
-        end_block_number=$3
-        n_workers=$4
-
-        echo "Backfilling from $start_block_number to $end_block_number with $n_workers workers"
-        python backfill.py $start_block_number $end_block_number $n_workers
-	;;
-  inspect)
-        block_number=$2
-        echo "Inspecting block $block_number"
-        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"
-        kubectl exec -ti deploy/mev-inspect -- \
-            poetry run inspect-many-blocks $start_block_number $end_block_number
-	;;
-  test)
-        shift
-        echo "Running tests"
-        kubectl exec -ti deploy/mev-inspect -- poetry run pytest tests $@
-	;;
-  fetch)
-      block_number=$2
-      echo "Fetching block $block_number"
-      kubectl exec -ti deploy/mev-inspect -- poetry run fetch-block $block_number
-  ;;
-  prices)
-        shift
-        case "$1" in
-          fetch-all)
-                echo "Running price fetch-all"
-                kubectl exec -ti deploy/mev-inspect -- \
-                    poetry run fetch-all-prices
-            ;;
-          *)
-            echo "prices usage: "$1" {fetch-all}"
-            exit 1
-        esac
-  ;;
-  exec)
-        shift
-        kubectl exec -ti deploy/mev-inspect -- $@
-  ;;
-  *)
-	echo "Usage: "$1" {db|backfill|inspect|test}"
-	exit 1
-esac
-
-exit 0

mev_inspect/aave_liquidations.py

@@ -1,100 +0,0 @@
-from typing import List, Optional, Tuple
-
-from mev_inspect.schemas.liquidations import Liquidation
-from mev_inspect.schemas.traces import (
-    CallTrace,
-    Classification,
-    ClassifiedTrace,
-    DecodedCallTrace,
-    Protocol,
-)
-from mev_inspect.schemas.transfers import Transfer
-from mev_inspect.traces import get_child_traces, is_child_of_any_address
-from mev_inspect.transfers import get_transfer
-
-AAVE_CONTRACT_ADDRESSES: List[str] = [
-    # AAVE Proxy
-    "0x398ec7346dcd622edc5ae82352f02be94c62d119",
-    # AAVE V2
-    "0x7d2768de32b0b80b7a3454c06bdac94a69ddc7a9",
-    # AAVE V1
-    "0x3dfd23a6c5e8bbcfc9581d2e864a68feb6a076d3",
-    # AAVE V2 WETH
-    "0x030ba81f1c18d280636f32af80b9aad02cf0854e",
-    # AAVE AMM Market DAI
-    "0x79be75ffc64dd58e66787e4eae470c8a1fd08ba4",
-    # AAVE i
-    "0x030ba81f1c18d280636f32af80b9aad02cf0854e",
-    "0xbcca60bb61934080951369a648fb03df4f96263c",
-]
-
-
-def get_aave_liquidations(
-    traces: List[ClassifiedTrace],
-) -> List[Liquidation]:
-
-    """Inspect list of classified traces and identify liquidation"""
-    liquidations: List[Liquidation] = []
-    parent_liquidations: List[List[int]] = []
-
-    for trace in traces:
-
-        if (
-            trace.classification == Classification.liquidate
-            and isinstance(trace, DecodedCallTrace)
-            and not is_child_of_any_address(trace, parent_liquidations)
-            and trace.protocol == Protocol.aave
-        ):
-
-            parent_liquidations.append(trace.trace_address)
-            liquidator = trace.from_address
-
-            child_traces = get_child_traces(
-                trace.transaction_hash, trace.trace_address, traces
-            )
-
-            (
-                received_token_address,
-                received_amount,
-            ) = _get_payback_token_and_amount(trace, child_traces, liquidator)
-
-            liquidations.append(
-                Liquidation(
-                    liquidated_user=trace.inputs["_user"],
-                    debt_token_address=trace.inputs["_reserve"],
-                    liquidator_user=liquidator,
-                    debt_purchase_amount=trace.inputs["_purchaseAmount"],
-                    protocol=Protocol.aave,
-                    received_amount=received_amount,
-                    received_token_address=received_token_address,
-                    transaction_hash=trace.transaction_hash,
-                    trace_address=trace.trace_address,
-                    block_number=trace.block_number,
-                )
-            )
-
-    return liquidations
-
-
-def _get_payback_token_and_amount(
-    liquidation: DecodedCallTrace, child_traces: List[ClassifiedTrace], liquidator: str
-) -> Tuple[str, int]:
-
-    """Look for and return liquidator payback from liquidation"""
-
-    for child in child_traces:
-
-        if isinstance(child, CallTrace):
-
-            child_transfer: Optional[Transfer] = get_transfer(child)
-
-            if child_transfer is not None:
-
-                if (
-                    child_transfer.to_address == liquidator
-                    and child.from_address in AAVE_CONTRACT_ADDRESSES
-                ):
-
-                    return child_transfer.token_address, child_transfer.amount
-
-    return liquidation.inputs["_collateral"], 0

mev_inspect/abi.py

@@ -4,39 +4,24 @@ from typing import Optional
 
 from pydantic import parse_obj_as
 
-from mev_inspect.schemas.abi import ABI
-from mev_inspect.schemas.traces import Protocol
+from mev_inspect.schemas import ABI
+from mev_inspect.schemas.classified_traces import Protocol
+
 
 THIS_FILE_DIRECTORY = Path(__file__).parents[0]
 ABI_DIRECTORY_PATH = THIS_FILE_DIRECTORY / "abis"
 
 
-def get_abi_path(abi_name: str, protocol: Optional[Protocol]) -> Optional[Path]:
+def get_abi(abi_name: str, protocol: Optional[Protocol]) -> Optional[ABI]:
+
     abi_filename = f"{abi_name}.json"
     abi_path = (
         ABI_DIRECTORY_PATH / abi_filename
         if protocol is None
         else ABI_DIRECTORY_PATH / protocol.value / abi_filename
     )
+
     if abi_path.is_file():
-        return abi_path
-
-    return None
-
-
-# raw abi, for instantiating contract for queries (as opposed to classification, see below)
-def get_raw_abi(abi_name: str, protocol: Optional[Protocol]) -> Optional[str]:
-    abi_path = get_abi_path(abi_name, protocol)
-    if abi_path is not None:
-        with abi_path.open() as abi_file:
-            return abi_file.read()
-
-    return None
-
-
-def get_abi(abi_name: str, protocol: Optional[Protocol]) -> Optional[ABI]:
-    abi_path = get_abi_path(abi_name, protocol)
-    if abi_path is not None:
         with abi_path.open() as abi_file:
             abi_json = json.load(abi_file)
             return parse_obj_as(ABI, abi_json)

mev_inspect/abis/0x/IBatchFillNativeOrdersFeature.json

@@ -1 +0,0 @@
-[{"inputs":[{"components":[{"internalType":"contract IERC20TokenV06","name":"makerToken","type":"address"},{"internalType":"contract IERC20TokenV06","name":"takerToken","type":"address"},{"internalType":"uint128","name":"makerAmount","type":"uint128"},{"internalType":"uint128","name":"takerAmount","type":"uint128"},{"internalType":"uint128","name":"takerTokenFeeAmount","type":"uint128"},{"internalType":"address","name":"maker","type":"address"},{"internalType":"address","name":"taker","type":"address"},{"internalType":"address","name":"sender","type":"address"},{"internalType":"address","name":"feeRecipient","type":"address"},{"internalType":"bytes32","name":"pool","type":"bytes32"},{"internalType":"uint64","name":"expiry","type":"uint64"},{"internalType":"uint256","name":"salt","type":"uint256"}],"internalType":"struct LibNativeOrder.LimitOrder[]","name":"orders","type":"tuple[]"},{"components":[{"internalType":"enum LibSignature.SignatureType","name":"signatureType","type":"uint8"},{"internalType":"uint8","name":"v","type":"uint8"},{"internalType":"bytes32","name":"r","type":"bytes32"},{"internalType":"bytes32","name":"s","type":"bytes32"}],"internalType":"struct LibSignature.Signature[]","name":"signatures","type":"tuple[]"},{"internalType":"uint128[]","name":"takerTokenFillAmounts","type":"uint128[]"},{"internalType":"bool","name":"revertIfIncomplete","type":"bool"}],"name":"batchFillLimitOrders","outputs":[{"internalType":"uint128[]","name":"takerTokenFilledAmounts","type":"uint128[]"},{"internalType":"uint128[]","name":"makerTokenFilledAmounts","type":"uint128[]"}],"stateMutability":"payable","type":"function"},{"inputs":[{"components":[{"internalType":"contract IERC20TokenV06","name":"makerToken","type":"address"},{"internalType":"contract IERC20TokenV06","name":"takerToken","type":"address"},{"internalType":"uint128","name":"makerAmount","type":"uint128"},{"internalType":"uint128","name":"takerAmount","type":"uint128"},{"internalType":"address","name":"maker","type":"address"},{"internalType":"address","name":"taker","type":"address"},{"internalType":"address","name":"txOrigin","type":"address"},{"internalType":"bytes32","name":"pool","type":"bytes32"},{"internalType":"uint64","name":"expiry","type":"uint64"},{"internalType":"uint256","name":"salt","type":"uint256"}],"internalType":"struct LibNativeOrder.RfqOrder[]","name":"orders","type":"tuple[]"},{"components":[{"internalType":"enum LibSignature.SignatureType","name":"signatureType","type":"uint8"},{"internalType":"uint8","name":"v","type":"uint8"},{"internalType":"bytes32","name":"r","type":"bytes32"},{"internalType":"bytes32","name":"s","type":"bytes32"}],"internalType":"struct LibSignature.Signature[]","name":"signatures","type":"tuple[]"},{"internalType":"uint128[]","name":"takerTokenFillAmounts","type":"uint128[]"},{"internalType":"bool","name":"revertIfIncomplete","type":"bool"}],"name":"batchFillRfqOrders","outputs":[{"internalType":"uint128[]","name":"takerTokenFilledAmounts","type":"uint128[]"},{"internalType":"uint128[]","name":"makerTokenFilledAmounts","type":"uint128[]"}],"stateMutability":"nonpayable","type":"function"}]

mev_inspect/abis/0x/IBootstrapFeature.json

@@ -1 +0,0 @@
-[{"inputs":[{"internalType":"address","name":"target","type":"address"},{"internalType":"bytes","name":"callData","type":"bytes"}],"name":"bootstrap","outputs":[],"stateMutability":"nonpayable","type":"function"}]

mev_inspect/abis/0x/IFeature.json

@@ -1 +0,0 @@
-[{"inputs":[],"name":"FEATURE_NAME","outputs":[{"internalType":"string","name":"name","type":"string"}],"stateMutability":"view","type":"function"},{"inputs":[],"name":"FEATURE_VERSION","outputs":[{"internalType":"uint256","name":"version","type":"uint256"}],"stateMutability":"view","type":"function"}]

mev_inspect/abis/0x/IFundRecoveryFeature.json

@@ -1 +0,0 @@
-[{"inputs":[{"internalType":"contract IERC20TokenV06","name":"erc20","type":"address"},{"internalType":"uint256","name":"amountOut","type":"uint256"},{"internalType":"address payable","name":"recipientWallet","type":"address"}],"name":"transferTrappedTokensTo","outputs":[],"stateMutability":"nonpayable","type":"function"}]

mev_inspect/abis/0x/ILiquidityProviderFeature.json

@@ -1 +0,0 @@
-[{"anonymous":false,"inputs":[{"indexed":false,"internalType":"contract IERC20TokenV06","name":"inputToken","type":"address"},{"indexed":false,"internalType":"contract IERC20TokenV06","name":"outputToken","type":"address"},{"indexed":false,"internalType":"uint256","name":"inputTokenAmount","type":"uint256"},{"indexed":false,"internalType":"uint256","name":"outputTokenAmount","type":"uint256"},{"indexed":false,"internalType":"contract ILiquidityProvider","name":"provider","type":"address"},{"indexed":false,"internalType":"address","name":"recipient","type":"address"}],"name":"LiquidityProviderSwap","type":"event"},{"inputs":[{"internalType":"contract IERC20TokenV06","name":"inputToken","type":"address"},{"internalType":"contract IERC20TokenV06","name":"outputToken","type":"address"},{"internalType":"contract ILiquidityProvider","name":"provider","type":"address"},{"internalType":"address","name":"recipient","type":"address"},{"internalType":"uint256","name":"sellAmount","type":"uint256"},{"internalType":"uint256","name":"minBuyAmount","type":"uint256"},{"internalType":"bytes","name":"auxiliaryData","type":"bytes"}],"name":"sellToLiquidityProvider","outputs":[{"internalType":"uint256","name":"boughtAmount","type":"uint256"}],"stateMutability":"payable","type":"function"}]

mev_inspect/abis/0x/IMultiplexFeature.json

@@ -1 +0,0 @@
-[{"inputs":[{"internalType":"contract IERC20TokenV06","name":"outputToken","type":"address"},{"components":[{"internalType":"enum IMultiplexFeature.MultiplexSubcall","name":"id","type":"uint8"},{"internalType":"uint256","name":"sellAmount","type":"uint256"},{"internalType":"bytes","name":"data","type":"bytes"}],"internalType":"struct IMultiplexFeature.BatchSellSubcall[]","name":"calls","type":"tuple[]"},{"internalType":"uint256","name":"minBuyAmount","type":"uint256"}],"name":"multiplexBatchSellEthForToken","outputs":[{"internalType":"uint256","name":"boughtAmount","type":"uint256"}],"stateMutability":"payable","type":"function"},{"inputs":[{"internalType":"contract IERC20TokenV06","name":"inputToken","type":"address"},{"components":[{"internalType":"enum IMultiplexFeature.MultiplexSubcall","name":"id","type":"uint8"},{"internalType":"uint256","name":"sellAmount","type":"uint256"},{"internalType":"bytes","name":"data","type":"bytes"}],"internalType":"struct IMultiplexFeature.BatchSellSubcall[]","name":"calls","type":"tuple[]"},{"internalType":"uint256","name":"sellAmount","type":"uint256"},{"internalType":"uint256","name":"minBuyAmount","type":"uint256"}],"name":"multiplexBatchSellTokenForEth","outputs":[{"internalType":"uint256","name":"boughtAmount","type":"uint256"}],"stateMutability":"nonpayable","type":"function"},{"inputs":[{"internalType":"contract IERC20TokenV06","name":"inputToken","type":"address"},{"internalType":"contract IERC20TokenV06","name":"outputToken","type":"address"},{"components":[{"internalType":"enum IMultiplexFeature.MultiplexSubcall","name":"id","type":"uint8"},{"internalType":"uint256","name":"sellAmount","type":"uint256"},{"internalType":"bytes","name":"data","type":"bytes"}],"internalType":"struct IMultiplexFeature.BatchSellSubcall[]","name":"calls","type":"tuple[]"},{"internalType":"uint256","name":"sellAmount","type":"uint256"},{"internalType":"uint256","name":"minBuyAmount","type":"uint256"}],"name":"multiplexBatchSellTokenForToken","outputs":[{"internalType":"uint256","name":"boughtAmount","type":"uint256"}],"stateMutability":"nonpayable","type":"function"},{"inputs":[{"internalType":"address[]","name":"tokens","type":"address[]"},{"components":[{"internalType":"enum IMultiplexFeature.MultiplexSubcall","name":"id","type":"uint8"},{"internalType":"bytes","name":"data","type":"bytes"}],"internalType":"struct IMultiplexFeature.MultiHopSellSubcall[]","name":"calls","type":"tuple[]"},{"internalType":"uint256","name":"minBuyAmount","type":"uint256"}],"name":"multiplexMultiHopSellEthForToken","outputs":[{"internalType":"uint256","name":"boughtAmount","type":"uint256"}],"stateMutability":"payable","type":"function"},{"inputs":[{"internalType":"address[]","name":"tokens","type":"address[]"},{"components":[{"internalType":"enum IMultiplexFeature.MultiplexSubcall","name":"id","type":"uint8"},{"internalType":"bytes","name":"data","type":"bytes"}],"internalType":"struct IMultiplexFeature.MultiHopSellSubcall[]","name":"calls","type":"tuple[]"},{"internalType":"uint256","name":"sellAmount","type":"uint256"},{"internalType":"uint256","name":"minBuyAmount","type":"uint256"}],"name":"multiplexMultiHopSellTokenForEth","outputs":[{"internalType":"uint256","name":"boughtAmount","type":"uint256"}],"stateMutability":"nonpayable","type":"function"},{"inputs":[{"internalType":"address[]","name":"tokens","type":"address[]"},{"components":[{"internalType":"enum IMultiplexFeature.MultiplexSubcall","name":"id","type":"uint8"},{"internalType":"bytes","name":"data","type":"bytes"}],"internalType":"struct IMultiplexFeature.MultiHopSellSubcall[]","name":"calls","type":"tuple[]"},{"internalType":"uint256","name":"sellAmount","type":"uint256"},{"internalType":"uint256","name":"minBuyAmount","type":"uint256"}],"name":"multiplexMultiHopSellTokenForToken","outputs":[{"internalType":"uint256","name":"boughtAmount","type":"uint256"}],"stateMutability":"nonpayable","type":"function"}]

mev_inspect/abis/0x/IOwnableFeature.json

@@ -1 +0,0 @@
-[{"anonymous":false,"inputs":[{"indexed":false,"internalType":"address","name":"caller","type":"address"},{"indexed":false,"internalType":"address","name":"migrator","type":"address"},{"indexed":false,"internalType":"address","name":"newOwner","type":"address"}],"name":"Migrated","type":"event"},{"anonymous":false,"inputs":[{"indexed":true,"internalType":"address","name":"previousOwner","type":"address"},{"indexed":true,"internalType":"address","name":"newOwner","type":"address"}],"name":"OwnershipTransferred","type":"event"},{"inputs":[{"internalType":"address","name":"target","type":"address"},{"internalType":"bytes","name":"data","type":"bytes"},{"internalType":"address","name":"newOwner","type":"address"}],"name":"migrate","outputs":[],"stateMutability":"nonpayable","type":"function"},{"inputs":[],"name":"owner","outputs":[{"internalType":"address","name":"ownerAddress","type":"address"}],"stateMutability":"view","type":"function"},{"inputs":[{"internalType":"address","name":"newOwner","type":"address"}],"name":"transferOwnership","outputs":[],"stateMutability":"nonpayable","type":"function"}]

mev_inspect/abis/0x/IPancakeSwapFeature.json

@@ -1 +0,0 @@
-[{"inputs":[{"internalType":"contract IERC20TokenV06[]","name":"tokens","type":"address[]"},{"internalType":"uint256","name":"sellAmount","type":"uint256"},{"internalType":"uint256","name":"minBuyAmount","type":"uint256"},{"internalType":"enum IPancakeSwapFeature.ProtocolFork","name":"fork","type":"uint8"}],"name":"sellToPancakeSwap","outputs":[{"internalType":"uint256","name":"buyAmount","type":"uint256"}],"stateMutability":"payable","type":"function"}]

mev_inspect/abis/0x/ISimpleFunctionRegistryFeature.json

@@ -1 +0,0 @@
-[{"anonymous":false,"inputs":[{"indexed":true,"internalType":"bytes4","name":"selector","type":"bytes4"},{"indexed":false,"internalType":"address","name":"oldImpl","type":"address"},{"indexed":false,"internalType":"address","name":"newImpl","type":"address"}],"name":"ProxyFunctionUpdated","type":"event"},{"inputs":[{"internalType":"bytes4","name":"selector","type":"bytes4"},{"internalType":"address","name":"impl","type":"address"}],"name":"extend","outputs":[],"stateMutability":"nonpayable","type":"function"},{"inputs":[{"internalType":"bytes4","name":"selector","type":"bytes4"},{"internalType":"uint256","name":"idx","type":"uint256"}],"name":"getRollbackEntryAtIndex","outputs":[{"internalType":"address","name":"impl","type":"address"}],"stateMutability":"view","type":"function"},{"inputs":[{"internalType":"bytes4","name":"selector","type":"bytes4"}],"name":"getRollbackLength","outputs":[{"internalType":"uint256","name":"rollbackLength","type":"uint256"}],"stateMutability":"view","type":"function"},{"inputs":[{"internalType":"bytes4","name":"selector","type":"bytes4"},{"internalType":"address","name":"targetImpl","type":"address"}],"name":"rollback","outputs":[],"stateMutability":"nonpayable","type":"function"}]

mev_inspect/abis/0x/ITestSimpleFunctionRegistryFeature.json

@@ -1 +0,0 @@
-[{"inputs":[],"name":"testFn","outputs":[{"internalType":"uint256","name":"id","type":"uint256"}],"stateMutability":"view","type":"function"}]

mev_inspect/abis/0x/ITokenSpenderFeature.json

@@ -1 +0,0 @@
-[{"inputs":[{"internalType":"contract IERC20TokenV06","name":"token","type":"address"},{"internalType":"address","name":"owner","type":"address"},{"internalType":"address","name":"to","type":"address"},{"internalType":"uint256","name":"amount","type":"uint256"}],"name":"_spendERC20Tokens","outputs":[],"stateMutability":"nonpayable","type":"function"},{"inputs":[],"name":"getAllowanceTarget","outputs":[{"internalType":"address","name":"target","type":"address"}],"stateMutability":"view","type":"function"},{"inputs":[{"internalType":"contract IERC20TokenV06","name":"token","type":"address"},{"internalType":"address","name":"owner","type":"address"}],"name":"getSpendableERC20BalanceOf","outputs":[{"internalType":"uint256","name":"amount","type":"uint256"}],"stateMutability":"view","type":"function"}]

mev_inspect/abis/0x/ITransformERC20Feature.json

@@ -1 +0,0 @@
-[{"anonymous":false,"inputs":[{"indexed":false,"internalType":"address","name":"quoteSigner","type":"address"}],"name":"QuoteSignerUpdated","type":"event"},{"anonymous":false,"inputs":[{"indexed":true,"internalType":"address","name":"taker","type":"address"},{"indexed":false,"internalType":"address","name":"inputToken","type":"address"},{"indexed":false,"internalType":"address","name":"outputToken","type":"address"},{"indexed":false,"internalType":"uint256","name":"inputTokenAmount","type":"uint256"},{"indexed":false,"internalType":"uint256","name":"outputTokenAmount","type":"uint256"}],"name":"TransformedERC20","type":"event"},{"anonymous":false,"inputs":[{"indexed":false,"internalType":"address","name":"transformerDeployer","type":"address"}],"name":"TransformerDeployerUpdated","type":"event"},{"inputs":[{"components":[{"internalType":"address payable","name":"taker","type":"address"},{"internalType":"contract IERC20TokenV06","name":"inputToken","type":"address"},{"internalType":"contract IERC20TokenV06","name":"outputToken","type":"address"},{"internalType":"uint256","name":"inputTokenAmount","type":"uint256"},{"internalType":"uint256","name":"minOutputTokenAmount","type":"uint256"},{"components":[{"internalType":"uint32","name":"deploymentNonce","type":"uint32"},{"internalType":"bytes","name":"data","type":"bytes"}],"internalType":"struct ITransformERC20Feature.Transformation[]","name":"transformations","type":"tuple[]"},{"internalType":"bool","name":"useSelfBalance","type":"bool"},{"internalType":"address payable","name":"recipient","type":"address"}],"internalType":"struct ITransformERC20Feature.TransformERC20Args","name":"args","type":"tuple"}],"name":"_transformERC20","outputs":[{"internalType":"uint256","name":"outputTokenAmount","type":"uint256"}],"stateMutability":"payable","type":"function"},{"inputs":[],"name":"createTransformWallet","outputs":[{"internalType":"contract IFlashWallet","name":"wallet","type":"address"}],"stateMutability":"nonpayable","type":"function"},{"inputs":[],"name":"getQuoteSigner","outputs":[{"internalType":"address","name":"signer","type":"address"}],"stateMutability":"view","type":"function"},{"inputs":[],"name":"getTransformWallet","outputs":[{"internalType":"contract IFlashWallet","name":"wallet","type":"address"}],"stateMutability":"view","type":"function"},{"inputs":[],"name":"getTransformerDeployer","outputs":[{"internalType":"address","name":"deployer","type":"address"}],"stateMutability":"view","type":"function"},{"inputs":[{"internalType":"address","name":"quoteSigner","type":"address"}],"name":"setQuoteSigner","outputs":[],"stateMutability":"nonpayable","type":"function"},{"inputs":[{"internalType":"address","name":"transformerDeployer","type":"address"}],"name":"setTransformerDeployer","outputs":[],"stateMutability":"nonpayable","type":"function"},{"inputs":[{"internalType":"contract IERC20TokenV06","name":"inputToken","type":"address"},{"internalType":"contract IERC20TokenV06","name":"outputToken","type":"address"},{"internalType":"uint256","name":"inputTokenAmount","type":"uint256"},{"internalType":"uint256","name":"minOutputTokenAmount","type":"uint256"},{"components":[{"internalType":"uint32","name":"deploymentNonce","type":"uint32"},{"internalType":"bytes","name":"data","type":"bytes"}],"internalType":"struct ITransformERC20Feature.Transformation[]","name":"transformations","type":"tuple[]"}],"name":"transformERC20","outputs":[{"internalType":"uint256","name":"outputTokenAmount","type":"uint256"}],"stateMutability":"payable","type":"function"}]

mev_inspect/abis/0x/IUniswapFeature.json

@@ -1 +0,0 @@
-[{"inputs":[{"internalType":"contract IERC20TokenV06[]","name":"tokens","type":"address[]"},{"internalType":"uint256","name":"sellAmount","type":"uint256"},{"internalType":"uint256","name":"minBuyAmount","type":"uint256"},{"internalType":"bool","name":"isSushi","type":"bool"}],"name":"sellToUniswap","outputs":[{"internalType":"uint256","name":"buyAmount","type":"uint256"}],"stateMutability":"payable","type":"function"}]

mev_inspect/abis/0x/IUniswapV3Feature.json

@@ -1 +0,0 @@
-[{"inputs":[{"internalType":"bytes","name":"encodedPath","type":"bytes"},{"internalType":"uint256","name":"sellAmount","type":"uint256"},{"internalType":"uint256","name":"minBuyAmount","type":"uint256"},{"internalType":"address","name":"recipient","type":"address"}],"name":"_sellHeldTokenForTokenToUniswapV3","outputs":[{"internalType":"uint256","name":"buyAmount","type":"uint256"}],"stateMutability":"nonpayable","type":"function"},{"inputs":[{"internalType":"bytes","name":"encodedPath","type":"bytes"},{"internalType":"uint256","name":"minBuyAmount","type":"uint256"},{"internalType":"address","name":"recipient","type":"address"}],"name":"sellEthForTokenToUniswapV3","outputs":[{"internalType":"uint256","name":"buyAmount","type":"uint256"}],"stateMutability":"payable","type":"function"},{"inputs":[{"internalType":"bytes","name":"encodedPath","type":"bytes"},{"internalType":"uint256","name":"sellAmount","type":"uint256"},{"internalType":"uint256","name":"minBuyAmount","type":"uint256"},{"internalType":"address payable","name":"recipient","type":"address"}],"name":"sellTokenForEthToUniswapV3","outputs":[{"internalType":"uint256","name":"buyAmount","type":"uint256"}],"stateMutability":"nonpayable","type":"function"},{"inputs":[{"internalType":"bytes","name":"encodedPath","type":"bytes"},{"internalType":"uint256","name":"sellAmount","type":"uint256"},{"internalType":"uint256","name":"minBuyAmount","type":"uint256"},{"internalType":"address","name":"recipient","type":"address"}],"name":"sellTokenForTokenToUniswapV3","outputs":[{"internalType":"uint256","name":"buyAmount","type":"uint256"}],"stateMutability":"nonpayable","type":"function"},{"inputs":[{"internalType":"int256","name":"amount0Delta","type":"int256"},{"internalType":"int256","name":"amount1Delta","type":"int256"},{"internalType":"bytes","name":"data","type":"bytes"}],"name":"uniswapV3SwapCallback","outputs":[],"stateMutability":"nonpayable","type":"function"}]

mev_inspect/abis/0x/affiliateFeeTransformer.json

@@ -1 +0,0 @@
-[{"inputs":[],"name":"deployer","outputs":[{"internalType":"address","name":"","type":"address"}],"stateMutability":"view","type":"function"},{"inputs":[{"internalType":"address payable","name":"ethRecipient","type":"address"}],"name":"die","outputs":[],"stateMutability":"nonpayable","type":"function"},{"inputs":[{"components":[{"internalType":"address payable","name":"sender","type":"address"},{"internalType":"address payable","name":"taker","type":"address"},{"internalType":"bytes","name":"data","type":"bytes"}],"internalType":"struct IERC20Transformer.TransformContext","name":"context","type":"tuple"}],"name":"transform","outputs":[{"internalType":"bytes4","name":"success","type":"bytes4"}],"stateMutability":"nonpayable","type":"function"}]

mev_inspect/abis/0x/etherToken.json

@@ -1 +0,0 @@
-[{"constant":true,"inputs":[],"name":"name","outputs":[{"name":"","type":"string"}],"payable":false,"stateMutability":"view","type":"function"},{"constant":false,"inputs":[{"name":"guy","type":"address"},{"name":"wad","type":"uint256"}],"name":"approve","outputs":[{"name":"","type":"bool"}],"payable":false,"stateMutability":"nonpayable","type":"function"},{"constant":true,"inputs":[],"name":"totalSupply","outputs":[{"name":"","type":"uint256"}],"payable":false,"stateMutability":"view","type":"function"},{"constant":false,"inputs":[{"name":"src","type":"address"},{"name":"dst","type":"address"},{"name":"wad","type":"uint256"}],"name":"transferFrom","outputs":[{"name":"","type":"bool"}],"payable":false,"stateMutability":"nonpayable","type":"function"},{"constant":false,"inputs":[{"name":"wad","type":"uint256"}],"name":"withdraw","outputs":[],"payable":false,"stateMutability":"nonpayable","type":"function"},{"constant":true,"inputs":[],"name":"decimals","outputs":[{"name":"","type":"uint8"}],"payable":false,"stateMutability":"view","type":"function"},{"constant":true,"inputs":[{"name":"","type":"address"}],"name":"balanceOf","outputs":[{"name":"","type":"uint256"}],"payable":false,"stateMutability":"view","type":"function"},{"constant":true,"inputs":[],"name":"symbol","outputs":[{"name":"","type":"string"}],"payable":false,"stateMutability":"view","type":"function"},{"constant":false,"inputs":[{"name":"dst","type":"address"},{"name":"wad","type":"uint256"}],"name":"transfer","outputs":[{"name":"","type":"bool"}],"payable":false,"stateMutability":"nonpayable","type":"function"},{"constant":false,"inputs":[],"name":"deposit","outputs":[],"payable":true,"stateMutability":"payable","type":"function"},{"constant":true,"inputs":[{"name":"","type":"address"},{"name":"","type":"address"}],"name":"allowance","outputs":[{"name":"","type":"uint256"}],"payable":false,"stateMutability":"view","type":"function"},{"payable":true,"stateMutability":"payable","type":"fallback"},{"anonymous":false,"inputs":[{"indexed":true,"name":"src","type":"address"},{"indexed":true,"name":"guy","type":"address"},{"indexed":false,"name":"wad","type":"uint256"}],"name":"Approval","type":"event"},{"anonymous":false,"inputs":[{"indexed":true,"name":"src","type":"address"},{"indexed":true,"name":"dst","type":"address"},{"indexed":false,"name":"wad","type":"uint256"}],"name":"Transfer","type":"event"},{"anonymous":false,"inputs":[{"indexed":true,"name":"dst","type":"address"},{"indexed":false,"name":"wad","type":"uint256"}],"name":"Deposit","type":"event"},{"anonymous":false,"inputs":[{"indexed":true,"name":"src","type":"address"},{"indexed":false,"name":"wad","type":"uint256"}],"name":"Withdrawal","type":"event"}]

mev_inspect/abis/0x/exchangeProxy.json

@@ -1 +0,0 @@
-[{"inputs":[],"stateMutability":"nonpayable","type":"constructor"},{"stateMutability":"payable","type":"fallback"},{"inputs":[{"internalType":"bytes4","name":"selector","type":"bytes4"}],"name":"getFunctionImplementation","outputs":[{"internalType":"address","name":"impl","type":"address"}],"stateMutability":"view","type":"function"},{"stateMutability":"payable","type":"receive"}]

mev_inspect/abis/0x/exchangeProxyAllowanceTarget.json

@@ -1 +0,0 @@
-[{"anonymous":false,"inputs":[{"indexed":true,"internalType":"address","name":"target","type":"address"},{"indexed":true,"internalType":"address","name":"caller","type":"address"}],"name":"AuthorizedAddressAdded","type":"event"},{"anonymous":false,"inputs":[{"indexed":true,"internalType":"address","name":"target","type":"address"},{"indexed":true,"internalType":"address","name":"caller","type":"address"}],"name":"AuthorizedAddressRemoved","type":"event"},{"anonymous":false,"inputs":[{"indexed":true,"internalType":"address","name":"previousOwner","type":"address"},{"indexed":true,"internalType":"address","name":"newOwner","type":"address"}],"name":"OwnershipTransferred","type":"event"},{"inputs":[{"internalType":"address","name":"target","type":"address"}],"name":"addAuthorizedAddress","outputs":[],"stateMutability":"nonpayable","type":"function"},{"inputs":[{"internalType":"uint256","name":"","type":"uint256"}],"name":"authorities","outputs":[{"internalType":"address","name":"","type":"address"}],"stateMutability":"view","type":"function"},{"inputs":[{"internalType":"address","name":"","type":"address"}],"name":"authorized","outputs":[{"internalType":"bool","name":"","type":"bool"}],"stateMutability":"view","type":"function"},{"inputs":[{"internalType":"address payable","name":"target","type":"address"},{"internalType":"bytes","name":"callData","type":"bytes"}],"name":"executeCall","outputs":[{"internalType":"bytes","name":"resultData","type":"bytes"}],"stateMutability":"nonpayable","type":"function"},{"inputs":[],"name":"getAuthorizedAddresses","outputs":[{"internalType":"address[]","name":"","type":"address[]"}],"stateMutability":"view","type":"function"},{"inputs":[],"name":"owner","outputs":[{"internalType":"address","name":"","type":"address"}],"stateMutability":"view","type":"function"},{"inputs":[{"internalType":"address","name":"target","type":"address"}],"name":"removeAuthorizedAddress","outputs":[],"stateMutability":"nonpayable","type":"function"},{"inputs":[{"internalType":"address","name":"target","type":"address"},{"internalType":"uint256","name":"index","type":"uint256"}],"name":"removeAuthorizedAddressAtIndex","outputs":[],"stateMutability":"nonpayable","type":"function"},{"inputs":[{"internalType":"address","name":"newOwner","type":"address"}],"name":"transferOwnership","outputs":[],"stateMutability":"nonpayable","type":"function"}]

mev_inspect/abis/0x/exchangeProxyFlashWallet.json

@@ -1 +0,0 @@
-[{"inputs":[],"stateMutability":"nonpayable","type":"constructor"},{"inputs":[{"internalType":"address payable","name":"target","type":"address"},{"internalType":"bytes","name":"callData","type":"bytes"},{"internalType":"uint256","name":"value","type":"uint256"}],"name":"executeCall","outputs":[{"internalType":"bytes","name":"resultData","type":"bytes"}],"stateMutability":"payable","type":"function"},{"inputs":[{"internalType":"address payable","name":"target","type":"address"},{"internalType":"bytes","name":"callData","type":"bytes"}],"name":"executeDelegateCall","outputs":[{"internalType":"bytes","name":"resultData","type":"bytes"}],"stateMutability":"payable","type":"function"},{"inputs":[{"internalType":"address","name":"","type":"address"},{"internalType":"address","name":"","type":"address"},{"internalType":"uint256[]","name":"","type":"uint256[]"},{"internalType":"uint256[]","name":"","type":"uint256[]"},{"internalType":"bytes","name":"","type":"bytes"}],"name":"onERC1155BatchReceived","outputs":[{"internalType":"bytes4","name":"success","type":"bytes4"}],"stateMutability":"pure","type":"function"},{"inputs":[{"internalType":"address","name":"","type":"address"},{"internalType":"address","name":"","type":"address"},{"internalType":"uint256","name":"","type":"uint256"},{"internalType":"uint256","name":"","type":"uint256"},{"internalType":"bytes","name":"","type":"bytes"}],"name":"onERC1155Received","outputs":[{"internalType":"bytes4","name":"success","type":"bytes4"}],"stateMutability":"pure","type":"function"},{"inputs":[],"name":"owner","outputs":[{"internalType":"address","name":"","type":"address"}],"stateMutability":"view","type":"function"},{"inputs":[{"internalType":"bytes4","name":"interfaceID","type":"bytes4"}],"name":"supportsInterface","outputs":[{"internalType":"bool","name":"hasSupport","type":"bool"}],"stateMutability":"pure","type":"function"},{"inputs":[{"internalType":"address","name":"","type":"address"},{"internalType":"uint256","name":"","type":"uint256"},{"internalType":"bytes","name":"","type":"bytes"}],"name":"tokenFallback","outputs":[],"stateMutability":"pure","type":"function"},{"stateMutability":"payable","type":"receive"}]

mev_inspect/abis/0x/exchangeProxyLiquidityProviderSandbox.json

@@ -1 +0,0 @@
-[{"inputs":[{"internalType":"address","name":"owner_","type":"address"}],"stateMutability":"nonpayable","type":"constructor"},{"inputs":[{"internalType":"address","name":"provider","type":"address"},{"internalType":"address","name":"outputToken","type":"address"},{"internalType":"address","name":"recipient","type":"address"},{"internalType":"uint256","name":"minBuyAmount","type":"uint256"},{"internalType":"bytes","name":"auxiliaryData","type":"bytes"}],"name":"executeSellEthForToken","outputs":[],"stateMutability":"nonpayable","type":"function"},{"inputs":[{"internalType":"address","name":"provider","type":"address"},{"internalType":"address","name":"inputToken","type":"address"},{"internalType":"address","name":"recipient","type":"address"},{"internalType":"uint256","name":"minBuyAmount","type":"uint256"},{"internalType":"bytes","name":"auxiliaryData","type":"bytes"}],"name":"executeSellTokenForEth","outputs":[],"stateMutability":"nonpayable","type":"function"},{"inputs":[{"internalType":"address","name":"provider","type":"address"},{"internalType":"address","name":"inputToken","type":"address"},{"internalType":"address","name":"outputToken","type":"address"},{"internalType":"address","name":"recipient","type":"address"},{"internalType":"uint256","name":"minBuyAmount","type":"uint256"},{"internalType":"bytes","name":"auxiliaryData","type":"bytes"}],"name":"executeSellTokenForToken","outputs":[],"stateMutability":"nonpayable","type":"function"},{"inputs":[],"name":"owner","outputs":[{"internalType":"address","name":"","type":"address"}],"stateMutability":"view","type":"function"}]

mev_inspect/abis/0x/exchangeProxyTransformerDeployer.json

@@ -1 +0,0 @@
-[{"inputs":[{"internalType":"address[]","name":"initialAuthorities","type":"address[]"}],"stateMutability":"nonpayable","type":"constructor"},{"anonymous":false,"inputs":[{"indexed":true,"internalType":"address","name":"target","type":"address"},{"indexed":true,"internalType":"address","name":"caller","type":"address"}],"name":"AuthorizedAddressAdded","type":"event"},{"anonymous":false,"inputs":[{"indexed":true,"internalType":"address","name":"target","type":"address"},{"indexed":true,"internalType":"address","name":"caller","type":"address"}],"name":"AuthorizedAddressRemoved","type":"event"},{"anonymous":false,"inputs":[{"indexed":false,"internalType":"address","name":"deployedAddress","type":"address"},{"indexed":false,"internalType":"uint256","name":"nonce","type":"uint256"},{"indexed":false,"internalType":"address","name":"sender","type":"address"}],"name":"Deployed","type":"event"},{"anonymous":false,"inputs":[{"indexed":false,"internalType":"address","name":"target","type":"address"},{"indexed":false,"internalType":"address","name":"sender","type":"address"}],"name":"Killed","type":"event"},{"anonymous":false,"inputs":[{"indexed":true,"internalType":"address","name":"previousOwner","type":"address"},{"indexed":true,"internalType":"address","name":"newOwner","type":"address"}],"name":"OwnershipTransferred","type":"event"},{"inputs":[{"internalType":"address","name":"target","type":"address"}],"name":"addAuthorizedAddress","outputs":[],"stateMutability":"nonpayable","type":"function"},{"inputs":[{"internalType":"uint256","name":"","type":"uint256"}],"name":"authorities","outputs":[{"internalType":"address","name":"","type":"address"}],"stateMutability":"view","type":"function"},{"inputs":[{"internalType":"address","name":"","type":"address"}],"name":"authorized","outputs":[{"internalType":"bool","name":"","type":"bool"}],"stateMutability":"view","type":"function"},{"inputs":[{"internalType":"bytes","name":"bytecode","type":"bytes"}],"name":"deploy","outputs":[{"internalType":"address","name":"deployedAddress","type":"address"}],"stateMutability":"payable","type":"function"},{"inputs":[],"name":"getAuthorizedAddresses","outputs":[{"internalType":"address[]","name":"","type":"address[]"}],"stateMutability":"view","type":"function"},{"inputs":[{"internalType":"contract IKillable","name":"target","type":"address"},{"internalType":"address payable","name":"ethRecipient","type":"address"}],"name":"kill","outputs":[],"stateMutability":"nonpayable","type":"function"},{"inputs":[],"name":"nonce","outputs":[{"internalType":"uint256","name":"","type":"uint256"}],"stateMutability":"view","type":"function"},{"inputs":[],"name":"owner","outputs":[{"internalType":"address","name":"","type":"address"}],"stateMutability":"view","type":"function"},{"inputs":[{"internalType":"address","name":"target","type":"address"}],"name":"removeAuthorizedAddress","outputs":[],"stateMutability":"nonpayable","type":"function"},{"inputs":[{"internalType":"address","name":"target","type":"address"},{"internalType":"uint256","name":"index","type":"uint256"}],"name":"removeAuthorizedAddressAtIndex","outputs":[],"stateMutability":"nonpayable","type":"function"},{"inputs":[{"internalType":"address","name":"","type":"address"}],"name":"toDeploymentNonce","outputs":[{"internalType":"uint256","name":"","type":"uint256"}],"stateMutability":"view","type":"function"},{"inputs":[{"internalType":"address","name":"newOwner","type":"address"}],"name":"transferOwnership","outputs":[],"stateMutability":"nonpayable","type":"function"}]

mev_inspect/abis/0x/fillQuoteTransformer.json

@@ -1 +0,0 @@
-[{"inputs":[{"internalType":"contract IExchange","name":"exchange_","type":"address"},{"internalType":"contract IBridgeAdapter","name":"bridgeAdapter_","type":"address"}],"stateMutability":"nonpayable","type":"constructor"},{"anonymous":false,"inputs":[{"indexed":false,"internalType":"bytes32","name":"orderHash","type":"bytes32"}],"name":"ProtocolFeeUnfunded","type":"event"},{"inputs":[],"name":"bridgeAdapter","outputs":[{"internalType":"contract IBridgeAdapter","name":"","type":"address"}],"stateMutability":"view","type":"function"},{"inputs":[],"name":"deployer","outputs":[{"internalType":"address","name":"","type":"address"}],"stateMutability":"view","type":"function"},{"inputs":[{"internalType":"address payable","name":"ethRecipient","type":"address"}],"name":"die","outputs":[],"stateMutability":"nonpayable","type":"function"},{"inputs":[],"name":"erc20Proxy","outputs":[{"internalType":"address","name":"","type":"address"}],"stateMutability":"view","type":"function"},{"inputs":[],"name":"exchange","outputs":[{"internalType":"contract IExchange","name":"","type":"address"}],"stateMutability":"view","type":"function"},{"inputs":[{"components":[{"internalType":"address payable","name":"sender","type":"address"},{"internalType":"address payable","name":"taker","type":"address"},{"internalType":"bytes","name":"data","type":"bytes"}],"internalType":"struct IERC20Transformer.TransformContext","name":"context","type":"tuple"}],"name":"transform","outputs":[{"internalType":"bytes4","name":"success","type":"bytes4"}],"stateMutability":"nonpayable","type":"function"}]

mev_inspect/abis/0x/payTakerTransformer.json

@@ -1 +0,0 @@
-[{"inputs":[],"stateMutability":"nonpayable","type":"constructor"},{"inputs":[],"name":"deployer","outputs":[{"internalType":"address","name":"","type":"address"}],"stateMutability":"view","type":"function"},{"inputs":[{"internalType":"address payable","name":"ethRecipient","type":"address"}],"name":"die","outputs":[],"stateMutability":"nonpayable","type":"function"},{"inputs":[{"components":[{"internalType":"address payable","name":"sender","type":"address"},{"internalType":"address payable","name":"taker","type":"address"},{"internalType":"bytes","name":"data","type":"bytes"}],"internalType":"struct IERC20Transformer.TransformContext","name":"context","type":"tuple"}],"name":"transform","outputs":[{"internalType":"bytes4","name":"success","type":"bytes4"}],"stateMutability":"nonpayable","type":"function"}]