brk_mempool 0.3.1

use brk_types::{OutpointPrefix, Transaction, TxidPrefix};
use rustc_hash::FxHashMap;

/// Mempool index from spent outpoint to spending mempool tx.
///
/// Keys are `OutpointPrefix` (8 bytes txid + 2 bytes vout). Prefix
/// collisions are possible, so callers must verify the candidate
/// spender's input list. Values are the spender's `TxidPrefix`,
/// looked up against `TxStore` to recover the full spender record.
#[derive(Default)]
pub struct OutpointSpends(FxHashMap<OutpointPrefix, TxidPrefix>);

impl OutpointSpends {
    pub fn len(&self) -> usize {
        self.0.len()
    }

    pub fn insert_spends(&mut self, tx: &Transaction, spender: TxidPrefix) {
        for key in Self::spent_outpoints(tx) {
            self.0.insert(key, spender);
        }
    }

    /// Only removes entries whose stored prefix still matches `spender`,
    /// so an outpoint already re-claimed by a later spender is left alone.
    pub fn remove_spends(&mut self, tx: &Transaction, spender: TxidPrefix) {
        for key in Self::spent_outpoints(tx) {
            if self.0.get(&key) == Some(&spender) {
                self.0.remove(&key);
            }
        }
    }

    #[inline]
    pub fn get(&self, key: &OutpointPrefix) -> Option<TxidPrefix> {
        self.0.get(key).copied()
    }

    fn spent_outpoints(tx: &Transaction) -> impl Iterator<Item = OutpointPrefix> + '_ {
        tx.input
            .iter()
            .filter(|i| !i.is_coinbase)
            .map(|i| OutpointPrefix::new(TxidPrefix::from(&i.txid), i.vout))
    }
}