pub struct BlockchainCacheDatabase { /* private fields */ }Expand description
Database interface for persisting and retrieving blockchain entities and domain objects.
Implementations§
Source§impl BlockchainCacheDatabase
impl BlockchainCacheDatabase
Sourcepub async fn init(pg_options: PgConnectOptions) -> Self
pub async fn init(pg_options: PgConnectOptions) -> Self
Initializes a new database instance by establishing a connection to PostgreSQL.
§Panics
Panics if unable to connect to PostgreSQL with the provided options.
Sourcepub async fn connect(pg_options: PgConnectOptions) -> Result<Self>
pub async fn connect(pg_options: PgConnectOptions) -> Result<Self>
Establishes a connection to PostgreSQL and returns a new database instance.
§Errors
Returns an error if a connection cannot be established with the provided options.
Sourcepub async fn seed_chain(&self, chain: &Chain) -> Result<()>
pub async fn seed_chain(&self, chain: &Chain) -> Result<()>
Seeds the database with a blockchain chain record.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn create_block_partition(&self, chain: &Chain) -> Result<String>
pub async fn create_block_partition(&self, chain: &Chain) -> Result<String>
Creates a table partition for the block table specific to the given chain
by calling the existing PostgreSQL function create_block_partition.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn create_token_partition(&self, chain: &Chain) -> Result<String>
pub async fn create_token_partition(&self, chain: &Chain) -> Result<String>
Creates a table partition for the token table specific to the given chain
by calling the existing PostgreSQL function create_token_partition.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn get_block_consistency_status(
&self,
chain: &Chain,
) -> Result<CachedBlocksConsistencyStatus>
pub async fn get_block_consistency_status( &self, chain: &Chain, ) -> Result<CachedBlocksConsistencyStatus>
Returns the highest block number that maintains data continuity in the database.
§Errors
Returns an error if the database query fails.
Sourcepub async fn add_block(&self, chain_id: u32, block: &Block) -> Result<()>
pub async fn add_block(&self, chain_id: u32, block: &Block) -> Result<()>
Inserts or updates a block record in the database.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn add_blocks_batch(
&self,
chain_id: u32,
blocks: &[Block],
) -> Result<()>
pub async fn add_blocks_batch( &self, chain_id: u32, blocks: &[Block], ) -> Result<()>
Inserts multiple blocks in a single database operation using UNNEST for optimal performance.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn add_pool_event_blocks_batch(
&self,
chain_id: u32,
blocks: &[Block],
) -> Result<()>
pub async fn add_pool_event_blocks_batch( &self, chain_id: u32, blocks: &[Block], ) -> Result<()>
Inserts block timestamps observed while streaming pool events.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn ensure_pool_event_block_hash_schema(&self) -> Result<()>
pub async fn ensure_pool_event_block_hash_schema(&self) -> Result<()>
Adds block-hash storage to databases created before hash-bound profiler checkpoints.
§Errors
Returns an error if the schema update fails.
Sourcepub async fn add_blocks_copy(
&self,
chain_id: u32,
blocks: &[Block],
) -> Result<()>
pub async fn add_blocks_copy( &self, chain_id: u32, blocks: &[Block], ) -> Result<()>
Inserts blocks using PostgreSQL COPY BINARY for maximum performance.
This method is significantly faster than INSERT for bulk operations as it bypasses SQL parsing and uses PostgreSQL’s native binary protocol.
§Errors
Returns an error if the COPY operation fails.
Sourcepub async fn add_tokens_copy(
&self,
chain_id: u32,
tokens: &[Token],
) -> Result<()>
pub async fn add_tokens_copy( &self, chain_id: u32, tokens: &[Token], ) -> Result<()>
Inserts tokens using PostgreSQL COPY BINARY for maximum performance.
§Errors
Returns an error if the COPY operation fails.
Sourcepub async fn add_pools_copy(&self, chain_id: u32, pools: &[Pool]) -> Result<()>
pub async fn add_pools_copy(&self, chain_id: u32, pools: &[Pool]) -> Result<()>
Inserts pools using PostgreSQL COPY BINARY for maximum performance.
§Errors
Returns an error if the COPY operation fails.
Sourcepub async fn add_pool_swaps_copy(
&self,
chain_id: u32,
swaps: &[PoolSwap],
) -> Result<()>
pub async fn add_pool_swaps_copy( &self, chain_id: u32, swaps: &[PoolSwap], ) -> Result<()>
Inserts pool swaps using PostgreSQL COPY BINARY for maximum performance.
This method is significantly faster than INSERT for bulk operations as it bypasses SQL parsing and uses PostgreSQL’s native binary protocol.
§Errors
Returns an error if the COPY operation fails.
Sourcepub async fn add_pool_liquidity_updates_copy(
&self,
chain_id: u32,
updates: &[PoolLiquidityUpdate],
) -> Result<()>
pub async fn add_pool_liquidity_updates_copy( &self, chain_id: u32, updates: &[PoolLiquidityUpdate], ) -> Result<()>
Inserts pool liquidity updates using PostgreSQL COPY BINARY for maximum performance.
This method is significantly faster than INSERT for bulk operations as it bypasses SQL parsing and uses PostgreSQL’s native binary protocol.
§Errors
Returns an error if the COPY operation fails.
Sourcepub async fn copy_pool_fee_collects_batch(
&self,
chain_id: u32,
collects: &[PoolFeeCollect],
) -> Result<()>
pub async fn copy_pool_fee_collects_batch( &self, chain_id: u32, collects: &[PoolFeeCollect], ) -> Result<()>
Inserts pool fee collect events using PostgreSQL COPY BINARY for maximum performance.
This method is significantly faster than INSERT for bulk operations as it bypasses SQL parsing and most database validation checks.
§Errors
Returns an error if the COPY operation fails.
Sourcepub async fn load_block_timestamps(
&self,
chain: SharedChain,
from_block: u64,
) -> Result<Vec<BlockTimestampRow>>
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.
§Errors
Returns an error if the database query fails.
Sourcepub async fn add_dex(&self, dex: SharedDex) -> Result<()>
pub async fn add_dex(&self, dex: SharedDex) -> Result<()>
Adds or updates a DEX (Decentralized Exchange) record in the database.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn add_pool(&self, pool: &Pool) -> Result<()>
pub async fn add_pool(&self, pool: &Pool) -> Result<()>
Adds or updates a liquidity pool/pair record in the database.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn add_pools_batch(&self, pools: &[Pool]) -> Result<()>
pub async fn add_pools_batch(&self, pools: &[Pool]) -> Result<()>
Inserts multiple pools in a single database operation using UNNEST for optimal performance.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn add_pool_swaps_batch(
&self,
chain_id: u32,
swaps: &[PoolSwap],
) -> Result<()>
pub async fn add_pool_swaps_batch( &self, chain_id: u32, swaps: &[PoolSwap], ) -> Result<()>
Inserts multiple pool swaps in a single database operation using UNNEST for optimal performance.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn add_pool_liquidity_updates_batch(
&self,
chain_id: u32,
updates: &[PoolLiquidityUpdate],
) -> Result<()>
pub async fn add_pool_liquidity_updates_batch( &self, chain_id: u32, updates: &[PoolLiquidityUpdate], ) -> Result<()>
Inserts multiple pool liquidity updates in a single database operation using UNNEST for optimal performance.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn add_token(&self, token: &Token) -> Result<()>
pub async fn add_token(&self, token: &Token) -> Result<()>
Adds or updates a token record in the database.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn add_invalid_token(
&self,
chain_id: u32,
address: &Address,
error_string: &str,
) -> Result<()>
pub async fn add_invalid_token( &self, chain_id: u32, address: &Address, error_string: &str, ) -> Result<()>
Records an invalid token address with associated error information.
§Errors
Returns an error if the database insertion fails.
Sourcepub async fn add_swap(&self, chain_id: u32, swap: &PoolSwap) -> Result<()>
pub async fn add_swap(&self, chain_id: u32, swap: &PoolSwap) -> Result<()>
Persists a token swap transaction event to the pool_swap table.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn add_pool_liquidity_update(
&self,
chain_id: u32,
liquidity_update: &PoolLiquidityUpdate,
) -> Result<()>
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.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn load_tokens(&self, chain: SharedChain) -> Result<Vec<Token>>
pub async fn load_tokens(&self, chain: SharedChain) -> Result<Vec<Token>>
Retrieves all valid token records for the given chain and converts them into Token domain objects.
Only returns tokens that do not contain error information, filtering out invalid tokens that were previously recorded with error details.
§Errors
Returns an error if the database query fails.
Sourcepub async fn load_invalid_token_addresses(
&self,
chain_id: u32,
) -> Result<Vec<Address>>
pub async fn load_invalid_token_addresses( &self, chain_id: u32, ) -> Result<Vec<Address>>
Retrieves all invalid token addresses for a given chain.
§Errors
Returns an error if the database query fails or address validation fails.
Sourcepub async fn load_pools(
&self,
chain: SharedChain,
dex_id: &str,
) -> Result<Vec<PoolRow>>
pub async fn load_pools( &self, chain: SharedChain, dex_id: &str, ) -> Result<Vec<PoolRow>>
Loads pool data from the database for the specified chain and DEX.
§Errors
Returns an error if the database query fails, the connection to the database is lost, or the query parameters are invalid.
Sourcepub async fn load_pool(
&self,
chain: SharedChain,
dex_id: &str,
pool_identifier: &PoolIdentifier,
) -> Result<Option<PoolRow>>
pub async fn load_pool( &self, chain: SharedChain, dex_id: &str, pool_identifier: &PoolIdentifier, ) -> Result<Option<PoolRow>>
Loads a single pool row by its identifier.
Returns None when the pool is not present in the database. Lets per-pool tools load only
the pool they analyze instead of the whole DEX pool set (see load_pools).
§Errors
Returns an error if the database query fails.
Sourcepub async fn toggle_perf_sync_settings(&self, enable: bool) -> Result<()>
pub async fn toggle_perf_sync_settings(&self, enable: bool) -> Result<()>
Toggles performance optimization settings for sync operations.
When enabled (true), applies settings for maximum write performance:
synchronous_commit= OFFwork_memincreased for bulk operations
When disabled (false), restores default safe settings:
synchronous_commit= ON (data safety)work_memback to default
§Errors
Returns an error if the database operations fail.
Sourcepub async fn update_dex_last_synced_block(
&self,
chain_id: u32,
dex: &DexType,
block_number: u64,
) -> Result<()>
pub async fn update_dex_last_synced_block( &self, chain_id: u32, dex: &DexType, block_number: u64, ) -> Result<()>
Saves the checkpoint block number indicating the last completed pool synchronization for a specific DEX.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn update_pool_last_synced_block(
&self,
chain_id: u32,
dex: &DexType,
pool_identifier: &PoolIdentifier,
block_number: u64,
) -> Result<()>
pub async fn update_pool_last_synced_block( &self, chain_id: u32, dex: &DexType, pool_identifier: &PoolIdentifier, block_number: u64, ) -> Result<()>
Updates the last synced block number for a pool.
§Errors
Returns an error if the database update fails.
Sourcepub async fn get_dex_last_synced_block(
&self,
chain_id: u32,
dex: &DexType,
) -> Result<Option<u64>>
pub async fn get_dex_last_synced_block( &self, chain_id: u32, dex: &DexType, ) -> Result<Option<u64>>
Retrieves the saved checkpoint block number from the last completed pool synchronization for a specific DEX.
§Errors
Returns an error if the database query fails.
Sourcepub async fn get_pool_last_synced_block(
&self,
chain_id: u32,
dex: &DexType,
pool_identifier: &PoolIdentifier,
) -> Result<Option<u64>>
pub async fn get_pool_last_synced_block( &self, chain_id: u32, dex: &DexType, pool_identifier: &PoolIdentifier, ) -> Result<Option<u64>>
Retrieves the last synced block number for a pool.
§Errors
Returns an error if the database query fails.
Sourcepub async fn get_table_last_block(
&self,
chain_id: u32,
table_name: &str,
pool_identifier: &PoolIdentifier,
) -> Result<Option<u64>>
pub async fn get_table_last_block( &self, chain_id: u32, table_name: &str, pool_identifier: &PoolIdentifier, ) -> Result<Option<u64>>
Retrieves the maximum block number from a specific table for a given pool. This is useful to detect orphaned data where events were inserted but progress wasn’t updated.
§Errors
Returns an error if the database query fails.
Sourcepub async fn add_pool_collects_batch(
&self,
chain_id: u32,
collects: &[PoolFeeCollect],
) -> Result<()>
pub async fn add_pool_collects_batch( &self, chain_id: u32, collects: &[PoolFeeCollect], ) -> Result<()>
Adds a batch of pool fee collect events to the database using batch operations.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn add_pool_flash_batch(
&self,
chain_id: u32,
flash_events: &[PoolFlash],
) -> Result<()>
pub async fn add_pool_flash_batch( &self, chain_id: u32, flash_events: &[PoolFlash], ) -> Result<()>
Inserts multiple pool flash events in a single database operation using UNNEST for optimal performance.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn add_pool_fee_protocol_updates_batch(
&self,
chain_id: u32,
updates: &[PoolFeeProtocolUpdate],
) -> Result<()>
pub async fn add_pool_fee_protocol_updates_batch( &self, chain_id: u32, updates: &[PoolFeeProtocolUpdate], ) -> Result<()>
Inserts multiple pool fee-protocol update events in a single database operation using UNNEST.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn add_pool_fee_protocol_collect_batch(
&self,
chain_id: u32,
collects: &[PoolFeeProtocolCollect],
) -> Result<()>
pub async fn add_pool_fee_protocol_collect_batch( &self, chain_id: u32, collects: &[PoolFeeProtocolCollect], ) -> Result<()>
Inserts multiple pool protocol-fee withdrawal events in a single database operation using UNNEST.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn add_pool_snapshot(
&self,
chain_id: u32,
dex_name: &DexType,
pool_identifier: &PoolIdentifier,
snapshot: &PoolSnapshot,
) -> Result<()>
pub async fn add_pool_snapshot( &self, chain_id: u32, dex_name: &DexType, pool_identifier: &PoolIdentifier, snapshot: &PoolSnapshot, ) -> Result<()>
Sourcepub async fn add_pool_positions_batch(
&self,
chain_id: u32,
snapshot_block: u64,
snapshot_transaction_index: u32,
snapshot_log_index: u32,
positions: &[(PoolIdentifier, PoolPosition)],
) -> Result<()>
pub async fn add_pool_positions_batch( &self, chain_id: u32, snapshot_block: u64, snapshot_transaction_index: u32, snapshot_log_index: u32, positions: &[(PoolIdentifier, PoolPosition)], ) -> Result<()>
Inserts multiple pool positions in a single database operation using UNNEST for optimal performance.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn add_pool_ticks_batch(
&self,
chain_id: u32,
snapshot_block: u64,
snapshot_transaction_index: u32,
snapshot_log_index: u32,
ticks: &[(PoolIdentifier, &PoolTick)],
) -> Result<()>
pub async fn add_pool_ticks_batch( &self, chain_id: u32, snapshot_block: u64, snapshot_transaction_index: u32, snapshot_log_index: u32, ticks: &[(PoolIdentifier, &PoolTick)], ) -> Result<()>
Inserts multiple pool ticks in a single database operation using UNNEST for optimal performance.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn update_pool_initial_price_tick(
&self,
chain_id: u32,
initialize_event: &InitializeEvent,
) -> Result<()>
pub async fn update_pool_initial_price_tick( &self, chain_id: u32, initialize_event: &InitializeEvent, ) -> Result<()>
Updates the initial price and tick for a pool.
§Errors
Returns an error if the database update fails.
Sourcepub async fn load_latest_valid_pool_snapshot(
&self,
chain_id: u32,
pool_identifier: &PoolIdentifier,
) -> Result<Option<PoolSnapshot>>
pub async fn load_latest_valid_pool_snapshot( &self, chain_id: u32, pool_identifier: &PoolIdentifier, ) -> Result<Option<PoolSnapshot>>
Loads the latest usable pool snapshot from the database.
Returns the most recent snapshot usable as a replay start point: on-chain validated or replay-derived. Snapshots that failed on-chain validation are excluded.
§Errors
Returns an error if the database query fails.
Sourcepub async fn load_latest_pool_snapshot(
&self,
chain_id: u32,
pool_identifier: &PoolIdentifier,
max_block: Option<u64>,
require_valid: bool,
) -> Result<Option<PoolSnapshot>>
pub async fn load_latest_pool_snapshot( &self, chain_id: u32, pool_identifier: &PoolIdentifier, max_block: Option<u64>, require_valid: bool, ) -> Result<Option<PoolSnapshot>>
Loads the latest pool snapshot from the database, optionally bounded by block.
When max_block is Some, only snapshots at or before that block are considered, so a
backtest can restore pool state as of a replay start. When require_valid is true,
snapshots that failed on-chain validation are excluded (both on-chain validated and
replay-derived snapshots are returned).
§Errors
Returns an error if the database query fails.
Sourcepub async fn set_pool_snapshot_validation_state(
&self,
chain_id: u32,
pool_identifier: &PoolIdentifier,
block: u64,
transaction_index: u32,
log_index: u32,
state: &str,
) -> Result<()>
pub async fn set_pool_snapshot_validation_state( &self, chain_id: u32, pool_identifier: &PoolIdentifier, block: u64, transaction_index: u32, log_index: u32, state: &str, ) -> Result<()>
Sets the validation state of a pool snapshot after a validation attempt.
state is one of on_chain (hydrated and matched), replay (replay-derived, not checked),
or invalid (hydrated and mismatched).
§Errors
Returns an error if the database operation fails.
Sourcepub async fn get_pool_snapshot_validation_state(
&self,
chain_id: u32,
pool_identifier: &PoolIdentifier,
block: u64,
transaction_index: u32,
log_index: u32,
) -> Result<Option<String>>
pub async fn get_pool_snapshot_validation_state( &self, chain_id: u32, pool_identifier: &PoolIdentifier, block: u64, transaction_index: u32, log_index: u32, ) -> Result<Option<String>>
Reads the stored validation_state for the snapshot at the given watermark.
Returns None when no snapshot row exists at that position. Used to report the persisted
verdict (rather than re-deriving replay) when on-chain validation cannot reach the block.
§Errors
Returns an error if the database query fails.
Sourcepub async fn load_pool_positions_for_snapshot(
&self,
chain_id: u32,
pool_identifier: &PoolIdentifier,
snapshot_block: u64,
snapshot_transaction_index: u32,
snapshot_log_index: u32,
) -> Result<Vec<PoolPosition>>
pub async fn load_pool_positions_for_snapshot( &self, chain_id: u32, pool_identifier: &PoolIdentifier, snapshot_block: u64, snapshot_transaction_index: u32, snapshot_log_index: u32, ) -> Result<Vec<PoolPosition>>
Sourcepub async fn load_pool_ticks_for_snapshot(
&self,
chain_id: u32,
pool_identifier: &PoolIdentifier,
snapshot_block: u64,
snapshot_transaction_index: u32,
snapshot_log_index: u32,
) -> Result<Vec<PoolTick>>
pub async fn load_pool_ticks_for_snapshot( &self, chain_id: u32, pool_identifier: &PoolIdentifier, snapshot_block: u64, snapshot_transaction_index: u32, snapshot_log_index: u32, ) -> Result<Vec<PoolTick>>
Sourcepub fn stream_pool_events<'a>(
&'a self,
chain: SharedChain,
dex: SharedDex,
instrument_id: InstrumentId,
pool_identifier: PoolIdentifier,
from_position: Option<BlockPosition>,
to_block: Option<u64>,
) -> Pin<Box<dyn Stream<Item = Result<DexPoolData, Error>> + Send + 'a>>
pub fn stream_pool_events<'a>( &'a self, chain: SharedChain, dex: SharedDex, instrument_id: InstrumentId, pool_identifier: PoolIdentifier, from_position: Option<BlockPosition>, to_block: Option<u64>, ) -> Pin<Box<dyn Stream<Item = Result<DexPoolData, Error>> + Send + 'a>>
Streams pool events from all event tables (swap, liquidity, collect) for a specific pool.
Creates a unified stream of pool events from multiple tables, ordering them chronologically by block number, transaction index, and log index. Optionally resumes from a specific block position and stops at a maximum block.
§Returns
A stream of DexPoolData events in chronological order.
§Errors
Returns an error if the database query fails or if event transformation fails.
Sourcepub async fn add_execution_transaction(
&self,
chain_id: u32,
wallet_address: &str,
nonce: u64,
transaction_hash: &str,
purpose: &str,
status: &str,
client_order_id: Option<&str>,
) -> Result<()>
pub async fn add_execution_transaction( &self, chain_id: u32, wallet_address: &str, nonce: u64, transaction_hash: &str, purpose: &str, status: &str, client_order_id: Option<&str>, ) -> Result<()>
Persists an execution transaction record to the execution_transaction table.
Records are written before broadcast so a signed transaction is never forgotten;
the unique (chain_id, transaction_hash) constraint makes an exact re-insertion
idempotent. Signer nonce ownership and order IDs are unique before broadcast. Order
submission records carry the client order ID; operator transactions (wrap, approve)
store NULL.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn ensure_execution_transaction_schema(&self) -> Result<()>
pub async fn ensure_execution_transaction_schema(&self) -> Result<()>
Installs execution schema version 2 without changing existing transaction rows.
The migration locks the legacy transaction table, refuses unresolved version 1 rows, installs the versioned intent and hash-history tables, and fences older writers before releasing the lock. This prevents a mixed-version process from bypassing the new signer ownership constraints.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn reserve_execution_intent(
&self,
intent: &ExecutionIntentInsert,
) -> Result<ExecutionIntentRow>
pub async fn reserve_execution_intent( &self, intent: &ExecutionIntentInsert, ) -> Result<ExecutionIntentRow>
Reserves durable ownership of a signer slot and optional client order before signing.
§Errors
Returns a stage-classified error if the signer or client order is already owned, or persistence fails. A commit-stage error does not prove the transaction rolled back.
Sourcepub async fn assign_execution_intent_nonce(
&self,
intent_id: i64,
nonce: u64,
) -> Result<()>
pub async fn assign_execution_intent_nonce( &self, intent_id: i64, nonce: u64, ) -> Result<()>
Assigns the signer nonce to a prepared execution intent.
Repeating the same assignment is idempotent. A different nonce or non-prepared state fails closed.
§Errors
Returns an error if the intent cannot own the nonce or persistence fails.
Sourcepub async fn mark_execution_intent_recoverable(
&self,
intent_id: i64,
) -> Result<()>
pub async fn mark_execution_intent_recoverable( &self, intent_id: i64, ) -> Result<()>
Releases an intent when no broadcast attempt can have occurred.
§Errors
Returns an error if the intent advanced to broadcast or persistence fails.
Sourcepub async fn add_execution_transaction_hash(
&self,
intent_id: i64,
chain_id: u32,
transaction_hash: &str,
raw_transaction: &[u8],
) -> Result<ExecutionTransactionHashRow>
pub async fn add_execution_transaction_hash( &self, intent_id: i64, chain_id: u32, transaction_hash: &str, raw_transaction: &[u8], ) -> Result<ExecutionTransactionHashRow>
Persists a signed transaction and advances its intent before broadcast.
§Errors
Returns an error if the intent is not prepared, lacks a nonce, conflicts with a stored hash, or persistence fails.
Sourcepub async fn record_execution_status(
&self,
intent_id: i64,
transaction_hash: &str,
status: TransactionStatus,
block_number: Option<u64>,
block_hash: Option<&str>,
receipt_success: Option<bool>,
gas_used: Option<u64>,
effective_gas_price: Option<&str>,
) -> Result<()>
pub async fn record_execution_status( &self, intent_id: i64, transaction_hash: &str, status: TransactionStatus, block_number: Option<u64>, block_hash: Option<&str>, receipt_success: Option<bool>, gas_used: Option<u64>, effective_gas_price: Option<&str>, ) -> Result<()>
Records an idempotent transaction observation and advances its intent state.
§Errors
Returns an error if the transition is invalid, the hash is unknown, or persistence fails.
Sourcepub async fn get_active_execution_intent(
&self,
chain_id: u32,
wallet_address: &str,
) -> Result<Option<ExecutionIntentRow>>
pub async fn get_active_execution_intent( &self, chain_id: u32, wallet_address: &str, ) -> Result<Option<ExecutionIntentRow>>
Loads the active intent owned by a signer after any concurrent reservation completes.
§Errors
Returns an error if the query fails.
Sourcepub async fn has_recoverable_signed_execution(
&self,
chain_id: u32,
wallet_address: &str,
) -> Result<bool>
pub async fn has_recoverable_signed_execution( &self, chain_id: u32, wallet_address: &str, ) -> Result<bool>
Reports whether a released legacy intent still retains a broadcastable signature.
§Errors
Returns an error if the query fails.
Sourcepub async fn get_execution_transaction_hashes(
&self,
intent_id: i64,
) -> Result<Vec<ExecutionTransactionHashRow>>
pub async fn get_execution_transaction_hashes( &self, intent_id: i64, ) -> Result<Vec<ExecutionTransactionHashRow>>
Loads all transaction hashes for an intent in insertion order.
§Errors
Returns an error if the query fails.
Sourcepub async fn mark_execution_event_emitted(
&self,
intent_id: i64,
event: &str,
) -> Result<()>
pub async fn mark_execution_event_emitted( &self, intent_id: i64, event: &str, ) -> Result<()>
Marks one order event as emitted after dispatch.
§Errors
Returns an error if the event kind is unknown, the intent is absent, the opposing terminal marker is already set, or persistence fails.
Sourcepub async fn update_execution_transaction_status(
&self,
chain_id: u32,
transaction_hash: &str,
status: &str,
) -> Result<()>
pub async fn update_execution_transaction_status( &self, chain_id: u32, transaction_hash: &str, status: &str, ) -> Result<()>
Updates the status of a persisted execution transaction record.
§Errors
Returns an error if the database operation fails.
Sourcepub async fn get_execution_transaction(
&self,
chain_id: u32,
transaction_hash: &str,
) -> Result<Option<ExecutionTransactionRow>>
pub async fn get_execution_transaction( &self, chain_id: u32, transaction_hash: &str, ) -> Result<Option<ExecutionTransactionRow>>
Loads an execution transaction record by chain ID and transaction hash.
§Errors
Returns an error if the database operation fails.
Trait Implementations§
Source§impl Clone for BlockchainCacheDatabase
impl Clone for BlockchainCacheDatabase
Source§fn clone(&self) -> BlockchainCacheDatabase
fn clone(&self) -> BlockchainCacheDatabase
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreAuto Trait Implementations§
impl !RefUnwindSafe for BlockchainCacheDatabase
impl !UnwindSafe for BlockchainCacheDatabase
impl Freeze for BlockchainCacheDatabase
impl Send for BlockchainCacheDatabase
impl Sync for BlockchainCacheDatabase
impl Unpin for BlockchainCacheDatabase
impl UnsafeUnpin for BlockchainCacheDatabase
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more