Struct IndexerDatabase

pub struct IndexerDatabase { /* private fields */ }

SQLite database for the indexer.

Implementations

impl IndexerDatabase

pub async fn open(path: &Path, network: Network) -> Result<Self, Error>

Opens or creates the indexer database at the given path.

The database file is stored in a network-specific subdirectory to prevent mixing data from different networks (mainnet, testnet, signet, etc.).

pub fn pool(&self) -> &SqlitePool

Get the underlying connection pool.

pub fn network(&self) -> Network

Get the Bitcoin network.

pub async fn load_state(&self) -> Result<Option<IndexerState>, Error>

Load indexer state from database.

pub async fn save_state(&self, state: &IndexerState) -> Result<(), Error>

Save indexer state to database.

pub async fn insert_block( &self, height: u32, hash: &[u8; 32], timestamp: u32, ) -> Result<(), Error>

Insert a block record.

pub async fn last_block_height(&self) -> Result<Option<u32>, Error>

Get the last indexed block height.

pub async fn insert_transaction( &self, txid: &Txid, block_height: u32, tx_index: u32, ) -> Result<(), Error>

Insert a transaction record.

pub async fn get_transaction( &self, txid: &Txid, ) -> Result<Option<(u32, u32)>, Error>

Get transaction position by txid.

pub async fn insert_output( &self, txid: &Txid, vout: u32, script_pubkey: &ScriptBuf, value: u64, block_height: u32, ) -> Result<(), Error>

Insert an output record.

pub async fn mark_output_spent( &self, outpoint: &OutPoint, spent_txid: &Txid, spent_vout: u32, spent_block_height: u32, ) -> Result<(), Error>

Mark an output as spent.

pub async fn get_output_info( &self, outpoint: &OutPoint, ) -> Result<Option<(String, u64)>, Error>

Get the address for an output (for computing deltas during spending).

pub async fn insert_address_history( &self, address: &str, txid: &Txid, block_height: u32, delta: i64, ) -> Result<(), Error>

Insert an address history entry.

pub async fn revert_to_height(&self, height: u32) -> Result<(), Error>

Revert all data above the given block height (for handling reorgs).

pub async fn begin_transaction(&self) -> Result<Transaction<'_, Sqlite>, Error>

Begin a database transaction for batch operations.

pub fn parse_txid(bytes: &[u8]) -> Result<Txid, Error>

Parse a txid from database bytes.

pub async fn index_block( &self, height: u32, block: &Block, network: Network, ) -> Result<(), Error>

Index a single block in a database transaction (for live sync).

pub async fn index_blocks_batch( &self, blocks: &[(u32, Block)], network: Network, ) -> Result<(), Error>

Index multiple blocks in a single database transaction for better performance. Used during historical sync for batching, and indirectly for single blocks during live sync.

Optimized with:

1. Bulk pre-fetch of outputs (eliminates N+1 queries)
2. Collect all data in memory first, then bulk insert by table
3. Pre-aggregate address history deltas (avoids ON CONFLICT overhead)

Trait Implementations

impl Clone for IndexerDatabase

fn clone(&self) -> IndexerDatabase

Returns a duplicate of the value.

const fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.