brk_indexer 0.11.1

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
67
68
69
70

use brk_error::Result;
use brk_traversable::Traversable;
use brk_types::{Height, OpReturnIndex, OpReturnKind, StoredU32, TxIndex, Version};
use rayon::prelude::*;
use vecdb::{AnyStoredVec, Database, ImportableVec, PcoVec, Rw, Stamp, StorageMode, WritableVec};

use crate::parallel_import;

#[derive(Traversable)]
pub struct OpReturnVecs<M: StorageMode = Rw> {
    pub first_index: M::Stored<PcoVec<Height, OpReturnIndex>>,
    pub to_tx_index: M::Stored<PcoVec<OpReturnIndex, TxIndex>>,
    pub kind: M::Stored<PcoVec<OpReturnIndex, OpReturnKind>>,
    pub post_op_return_bytes: M::Stored<PcoVec<OpReturnIndex, StoredU32>>,
}

impl OpReturnVecs {
    pub fn forced_import(db: &Database, version: Version) -> Result<Self> {
        let (first_index, to_tx_index, kind, post_op_return_bytes) = parallel_import! {
            first_index = PcoVec::forced_import(db, "first_op_return_index", version),
            to_tx_index = PcoVec::forced_import(db, "tx_index", version),
            kind = PcoVec::forced_import(db, "kind", version),
            post_op_return_bytes =
                PcoVec::forced_import(db, "op_return_post_op_return_bytes", version),
        };
        Ok(Self {
            first_index,
            to_tx_index,
            kind,
            post_op_return_bytes,
        })
    }

    pub fn truncate(
        &mut self,
        height: Height,
        op_return_index: OpReturnIndex,
        stamp: Stamp,
    ) -> Result<()> {
        self.first_index
            .truncate_if_needed_with_stamp(height, stamp)?;
        self.to_tx_index
            .truncate_if_needed_with_stamp(op_return_index, stamp)?;
        self.kind
            .truncate_if_needed_with_stamp(op_return_index, stamp)?;
        self.post_op_return_bytes
            .truncate_if_needed_with_stamp(op_return_index, stamp)?;
        Ok(())
    }

    pub fn par_iter_mut_any(&mut self) -> impl ParallelIterator<Item = &mut dyn AnyStoredVec> {
        [
            &mut self.first_index as &mut dyn AnyStoredVec,
            &mut self.to_tx_index,
            &mut self.kind,
            &mut self.post_op_return_bytes,
        ]
        .into_par_iter()
    }

    pub fn iter_any(&self) -> impl Iterator<Item = &dyn AnyStoredVec> {
        [
            &self.first_index as &dyn AnyStoredVec,
            &self.to_tx_index,
            &self.kind,
            &self.post_op_return_bytes,
        ]
        .into_iter()
    }
}