Standalone AaveV3 liquidation bot, unlikely to be profitable nowadays.

Components:

• contracts/ - contains example contract used to execute liquidations
• src/ - contains the offchain logic responsible for tracking and managing liquidation opportunities
• migrations/ - holds the database migrations

The setup is abstracted enough to work on any and all Aave forks, on all EVM-compatible chains, so long as you know the deployment address of the protocol's:

• Pool
• PoolAddressesProvider
• UiPoolDataProviderV3

Idiosyncrasies

• all reserves's real time value is tracked by listening for AnswerUpdated, emitted by Chainlink's price aggregators.
• users's open positions & exposure is kept both in-memory and in postgres for later usage
• the smart contract executing the liquidation relies on flashloan to execute the liquidation

Example usage

• deploy the contract (perhaps locally through anvil fork anvil --fork-url https://eth.merkle.io)

• start postgres

docker-compose up -d postgres

run the offchain service

# the used pubkey & privkey are the default ones provided by anvil.
cargo r -- \
    --network ethereum --protocol aave_v3 \
    --ws-url=wss://eth.merkle.io \
    --account-pubkey=0xd8dA6BF26964aF9D7eEd9e03E53415D37aA96045 \
    --account-privkey=0xac0974bec39a17e36ba4a6b4d238ff944bacb478cbed5efcae784d7bf4f2ff80 \
    --bot-addr=0x95222290DD7278Aa3Ddd389Cc1E1d165CC4BAfe5

Flow

The flow of execution goes like

sequenceDiagram
participant DB as DBActor participant Fanatic as FanaticActor participant Follower as FollowerActor participant Executor as ExecutorActor
Fanatic ->> DB: GetProtocolDetailsId Fanatic ->> DB: GetProtocolContracts Fanatic ->> DB: GetReservesUsers
Fanatic -> Fanatic: init_reserves()
Fanatic ->> Follower: SendFanaticAddr Fanatic ->> Follower: StartListeningForOraclePrices Fanatic ->> Follower: StartListeningForEvents
rect rgb(30, 30, 30)     Follower ->> Follower: listenoracleprices()     Follower ->> DB: UpdateOraclePrice     Follower ->> Fanatic: UpdateReservePrice     Fanatic ->> Fanatic: verify health factors     Fanatic ->> Fanatic: update in memory state     Fanatic ->> Executor: liquidation request     Executor --> Executor: verify opportunity is profitable     Executor --> Executor: execute liquidation end
rect rgb(30, 30, 30)     Follower ->> Follower: listen_events()     rect rgb(40, 40, 40)         Follower ->> Fanatic: DoSmthWithLiquidationCall         Fanatic ->> DB: InsertLiquidation     end
rect rgb(50, 50, 50)         Follower ->> Fanatic: UpdateReserveUser         Fanatic ->> Fanatic: verify health factor         Fanatic ->> Fanatic: update in memory state         Fanatic ->> Executor: liquidation request         Executor --> Executor: verify opportunity is profitable         Executor --> Executor: execute tx     end
rect rgb(60, 60, 60)         Follower ->> DB: UpsertReserveStats     end end

Database schema

erDiagram
    NETWORKS ||--o{ PROTOCOLS_DETAILS : has
    PROTOCOLS ||--o{ PROTOCOLS_DETAILS : has
    PROTOCOLS ||--o{ PROTOCOLS : forks
    PROTOCOLSDETAILS ||--o{ PROTOCOLSCONTRACTS : contains
    NETWORKS ||--o{ ERC20_DETAILS : has
    ERC20 ||--o{ ERC20_DETAILS : has
    PROTOCOLSDETAILS ||--o{ AAV3USERS : has
    PROTOCOLSDETAILS ||--o{ AAV3RESERVES : has
    AAV3USERS ||--o{ AAV3USERS_STATS : tracks
    ERC20DETAILS ||--o{ AAV3RESERVES : provides
    AAV3RESERVES ||--o{ AAV3RESERVES_STATS : tracks
    AAV3USERS ||--o{ AAV3POSITIONS : has
    AAV3RESERVES ||--o{ AAV3POSITIONS : uses
    PROTOCOLSDETAILS ||--o{ AAV3LIQUIDATIONS : records
    AAV3RESERVES ||--o{ AAV3LIQUIDATIONS : involves
NETWORKS {         VARCHAR(50) id PK         INTEGER chain_id         TIMESTAMP created_at     }
PROTOCOLS {         VARCHAR(50) id PK         VARCHAR(100) name         VARCHAR(50) kind         VARCHAR(50) fork FK         TIMESTAMP created_at     }
PROTOCOLS_DETAILS {         SERIAL id PK         VARCHAR(50) protocol_id FK         VARCHAR(50) network_id FK         BIGINT deployed_block         TIMESTAMP deployed_at         TIMESTAMP created_at     }
PROTOCOLS_CONTRACTS {         SERIAL id PK         INTEGER protocoldetailsid FK         VARCHAR(100) name         CHAR(42) address         TIMESTAMP created_at     }
ERC20 {         SERIAL id PK         VARCHAR(10) symbol         VARCHAR(100) name         TIMESTAMP created_at     }
ERC20_DETAILS {         SERIAL id PK         CHAR(42) address         INTEGER decimals         INTEGER erc20_id FK         CHAR(50) network_id FK         TIMESTAMP created_at     }
AAV3_USERS {         CHAR(42) address PK         INTEGER protocoldetailsid FK         TIMESTAMP created_at     }
AAV3USERSSTATS {         CHAR(42) user_address PK,FK         DOUBLEPRECISION healthfactor         TIMESTAMP updated_at     }
AAV3_RESERVES {         CHAR(42) reserve PK,FK         INTEGER protocoldetailsid FK         DOUBLEPRECISION liquidationthreshold         DOUBLEPRECISION liquidationbonus         BOOLEAN flashloan_enabled         CHAR(42) oracle_addr         CHAR(42) aggregator_addr         TIMESTAMP created_at     }
AAV3RESERVESSTATS {         CHAR(42) reserve PK,FK         DOUBLEPRECISION liquidityindex         DOUBLEPRECISION liquidityrate         DOUBLEPRECISION variableborrow_rate         DOUBLEPRECISION variableborrow_index         DOUBLEPRECISION priceusd         TIMESTAMP updated_at         TIMESTAMP created_at     }
AAV3_POSITIONS {         SERIAL id PK         CHAR(42) user_address FK         CHAR(42) reserve FK         DOUBLEPRECISION supplyamount         DOUBLEPRECISION borrowamount         TIMESTAMP updated_at         TIMESTAMP created_at     }
AAV3_LIQUIDATIONS {         SERIAL id PK         INTEGER protocoldetailsid FK         CHAR(42) user_address         CHAR(42) collateral_asset FK         CHAR(42) debt_asset FK         TIMESTAMP timestamp     }