brk_computer 0.3.0-alpha.2

A Bitcoin dataset computer built on top of brk_indexer
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
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127

use brk_error::Result;
use brk_indexer::Indexer;
use brk_types::Indexes;
use vecdb::Exit;

use super::Vecs;

impl Vecs {
    pub(crate) fn compute(
        &mut self,
        indexer: &Indexer,
        starting_indexes: &Indexes,
        exit: &Exit,
    ) -> Result<()> {
        self.p2a.compute(starting_indexes.height, exit, |v| {
            Ok(v.compute_count_from_indexes(
                starting_indexes.height,
                &indexer.vecs.addrs.p2a.first_index,
                &indexer.vecs.addrs.p2a.bytes,
                exit,
            )?)
        })?;

        self.p2ms.compute(starting_indexes.height, exit, |v| {
            Ok(v.compute_count_from_indexes(
                starting_indexes.height,
                &indexer.vecs.scripts.p2ms.first_index,
                &indexer.vecs.scripts.p2ms.to_tx_index,
                exit,
            )?)
        })?;

        self.p2pk33.compute(starting_indexes.height, exit, |v| {
            Ok(v.compute_count_from_indexes(
                starting_indexes.height,
                &indexer.vecs.addrs.p2pk33.first_index,
                &indexer.vecs.addrs.p2pk33.bytes,
                exit,
            )?)
        })?;

        self.p2pk65.compute(starting_indexes.height, exit, |v| {
            Ok(v.compute_count_from_indexes(
                starting_indexes.height,
                &indexer.vecs.addrs.p2pk65.first_index,
                &indexer.vecs.addrs.p2pk65.bytes,
                exit,
            )?)
        })?;

        self.p2pkh.compute(starting_indexes.height, exit, |v| {
            Ok(v.compute_count_from_indexes(
                starting_indexes.height,
                &indexer.vecs.addrs.p2pkh.first_index,
                &indexer.vecs.addrs.p2pkh.bytes,
                exit,
            )?)
        })?;

        self.p2sh.compute(starting_indexes.height, exit, |v| {
            Ok(v.compute_count_from_indexes(
                starting_indexes.height,
                &indexer.vecs.addrs.p2sh.first_index,
                &indexer.vecs.addrs.p2sh.bytes,
                exit,
            )?)
        })?;

        self.p2tr.compute(starting_indexes.height, exit, |v| {
            Ok(v.compute_count_from_indexes(
                starting_indexes.height,
                &indexer.vecs.addrs.p2tr.first_index,
                &indexer.vecs.addrs.p2tr.bytes,
                exit,
            )?)
        })?;

        self.p2wpkh.compute(starting_indexes.height, exit, |v| {
            Ok(v.compute_count_from_indexes(
                starting_indexes.height,
                &indexer.vecs.addrs.p2wpkh.first_index,
                &indexer.vecs.addrs.p2wpkh.bytes,
                exit,
            )?)
        })?;

        self.p2wsh.compute(starting_indexes.height, exit, |v| {
            Ok(v.compute_count_from_indexes(
                starting_indexes.height,
                &indexer.vecs.addrs.p2wsh.first_index,
                &indexer.vecs.addrs.p2wsh.bytes,
                exit,
            )?)
        })?;

        self.op_return.compute(starting_indexes.height, exit, |v| {
            Ok(v.compute_count_from_indexes(
                starting_indexes.height,
                &indexer.vecs.scripts.op_return.first_index,
                &indexer.vecs.scripts.op_return.to_tx_index,
                exit,
            )?)
        })?;

        self.unknown_output
            .compute(starting_indexes.height, exit, |v| {
                Ok(v.compute_count_from_indexes(
                    starting_indexes.height,
                    &indexer.vecs.scripts.unknown.first_index,
                    &indexer.vecs.scripts.unknown.to_tx_index,
                    exit,
                )?)
            })?;

        self.empty_output
            .compute(starting_indexes.height, exit, |v| {
                Ok(v.compute_count_from_indexes(
                    starting_indexes.height,
                    &indexer.vecs.scripts.empty.first_index,
                    &indexer.vecs.scripts.empty.to_tx_index,
                    exit,
                )?)
            })?;

        Ok(())
    }
}