Method sync_mempool

src/indexer.rs:366–379

Update missing/outdated mempool entries for unconfirmed mempool transactions (or all mempool entries when force_refresh is set, during the initial sync or following a chain tip update)

(&mut self, force_refresh: bool)

    /// Update missing/outdated mempool entries for unconfirmed mempool transactions (or all mempool
    /// entries when force_refresh is set, during the initial sync or following a chain tip update)
    fn sync_mempool(&mut self, force_refresh: bool) {
        let mempool = self.store.mempool_mut();

        for (txid, opt_entry) in mempool.iter_mut() {
            if force_refresh || opt_entry.is_none() {
                match self.rpc.get_mempool_entry(txid) {
                    Ok(rpc_entry) => *opt_entry = Some(rpc_entry.into()),
                    Err(e) => warn!("failed fetching mempool entry for {}: {}", txid, e),
                }
            }
        }

        // TODO use batch rpc
    }

    /// Get historical events that happened at or after `min_block_height`, including unconfirmed,
    /// ordered with oldest first.