brk_indexer 0.1.6

A Bitcoin indexer built on top of brk_reader
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

use brk_error::Result;
use brk_traversable::Traversable;
use brk_types::{Height, OutputType, Sats, TxIndex, TxOutIndex, TypeIndex, Version};
use rayon::prelude::*;
use vecdb::{AnyStoredVec, BytesVec, Database, GenericStoredVec, ImportableVec, PcoVec, Stamp};

use crate::parallel_import;

#[derive(Clone, Traversable)]
pub struct OutputsVecs {
    pub first_txoutindex: PcoVec<Height, TxOutIndex>,
    pub value: BytesVec<TxOutIndex, Sats>,
    pub outputtype: BytesVec<TxOutIndex, OutputType>,
    pub typeindex: BytesVec<TxOutIndex, TypeIndex>,
    pub txindex: PcoVec<TxOutIndex, TxIndex>,
}

impl OutputsVecs {
    pub fn forced_import(db: &Database, version: Version) -> Result<Self> {
        let (
            first_txoutindex,
            value,
            outputtype,
            typeindex,
            txindex,
        ) = parallel_import! {
            first_txoutindex = PcoVec::forced_import(db, "first_txoutindex", version),
            value = BytesVec::forced_import(db, "value", version),
            outputtype = BytesVec::forced_import(db, "outputtype", version),
            typeindex = BytesVec::forced_import(db, "typeindex", version),
            txindex = PcoVec::forced_import(db, "txindex", version),
        };
        Ok(Self {
            first_txoutindex,
            value,
            outputtype,
            typeindex,
            txindex,
        })
    }

    pub fn truncate(&mut self, height: Height, txoutindex: TxOutIndex, stamp: Stamp) -> Result<()> {
        self.first_txoutindex
            .truncate_if_needed_with_stamp(height, stamp)?;
        self.value
            .truncate_if_needed_with_stamp(txoutindex, stamp)?;
        self.outputtype
            .truncate_if_needed_with_stamp(txoutindex, stamp)?;
        self.typeindex
            .truncate_if_needed_with_stamp(txoutindex, stamp)?;
        self.txindex
            .truncate_if_needed_with_stamp(txoutindex, stamp)?;
        Ok(())
    }

    pub fn par_iter_mut_any(&mut self) -> impl ParallelIterator<Item = &mut dyn AnyStoredVec> {
        [
            &mut self.first_txoutindex as &mut dyn AnyStoredVec,
            &mut self.value,
            &mut self.outputtype,
            &mut self.typeindex,
            &mut self.txindex,
        ]
        .into_par_iter()
    }
}