Struct BlockchainCacheDatabase

pub struct BlockchainCacheDatabase { /* private fields */ }

Database interface for persisting and retrieving blockchain entities and domain objects.

Implementations

impl BlockchainCacheDatabase

pub async fn init(pg_options: PgConnectOptions) -> Self

Initializes a new database instance by establishing a connection to PostgreSQL.

pub async fn seed_chain(&self, chain: &Chain) -> Result<()>

Seeds the database with a blockchain chain record.

pub async fn add_block(&self, chain_id: u32, block: &Block) -> Result<()>

Inserts or updates a block record in the database.

pub async fn load_block_timestamps( &self, chain: SharedChain, from_block: u64, ) -> Result<Vec<BlockTimestampRow>>

Retrieves block timestamps for a given chain starting from a specific block number.

pub async fn add_dex(&self, dex: &Dex) -> Result<()>

Adds or updates a DEX (Decentralized Exchange) record in the database.

pub async fn add_pool(&self, pool: &Pool) -> Result<()>

Adds or updates a liquidity pool/pair record in the database.

pub async fn add_token(&self, token: &Token) -> Result<()>

Adds or updates a token record in the database.

pub async fn add_swap(&self, chain_id: u32, swap: &PoolSwap) -> Result<()>

Persists a token swap transaction event to the pool_swap table.

pub async fn add_pool_liquidity_update( &self, chain_id: u32, liquidity_update: &PoolLiquidityUpdate, ) -> Result<()>

Persists a liquidity position change (mint/burn) event to the pool_liquidity table.

pub async fn load_tokens(&self, chain: SharedChain) -> Result<Vec<Token>>

Retrieves all token records for the given chain and converts them into Token domain objects.

Trait Implementations

impl Debug for BlockchainCacheDatabase

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.