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
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

mod features;
mod input;
mod output;
mod policy;
mod sigops;

use brk_types::{OutputType, SigOps};
use rayon::prelude::*;
use vecdb::{likely, unlikely};

use super::ComputedTx;
use crate::TxFeatureFlags;
use crate::processor::{BlockProcessor, txin::InputSource, txout::ProcessedOutput};

pub(super) struct TransactionAnalysis {
    pub(super) total_sigop_cost: SigOps,
    pub(super) explicitly_rbf: bool,
    pub(super) features: TxFeatureFlags,
}

impl BlockProcessor<'_> {
    #[inline]
    pub(crate) fn tracks_executed_legacy_sigops(&self) -> bool {
        policy::tracks_executed_legacy_sigops(self.height)
    }

    pub(super) fn analyze_transactions(
        &self,
        txs: &[ComputedTx<'_>],
        txins: &[InputSource],
        txouts: &[ProcessedOutput],
    ) -> Vec<TransactionAnalysis> {
        let block_first_tx_index = self.lengths.tx_index;
        let track_executed_legacy = self.tracks_executed_legacy_sigops();

        txs.par_iter()
            .map(|tx| {
                let tx_inputs = tx.inputs(txins);
                let tx_outputs = tx.outputs(txouts);
                let is_coinbase = tx.is_coinbase(block_first_tx_index);

                let mut sigops = sigops::Accumulator::new(track_executed_legacy);
                let mut flags = TxFeatureFlags::default();
                let mut explicitly_rbf = false;
                let mut output_scanner = output::Scanner::default();
                let mut policy = policy::Accumulator::new(self.height);

                if unlikely(is_coinbase) {
                    let input = &tx.tx.input[0];
                    explicitly_rbf = input.sequence.is_rbf();
                    sigops.scan_coinbase_input(input);
                } else {
                    for (input, source) in tx.tx.input.iter().zip(tx_inputs) {
                        explicitly_rbf |= input.sequence.is_rbf();
                        let (output_type, legacy_sigops) = resolved_output_facts(source, txouts);
                        let facts = input::analyze(input, output_type, &mut flags);
                        sigops.scan_input(output_type, legacy_sigops, &facts);
                        policy.scan_input(input, output_type, &facts);
                    }
                }

                for (txout, output) in tx.tx.output.iter().zip(tx_outputs) {
                    output_scanner.scan(txout, output, &mut flags);
                    sigops.scan_output(txout, output);
                    if likely(!is_coinbase) {
                        policy.scan_output(txout, output);
                    }
                }

                let sigops = sigops.finish();
                if likely(!is_coinbase) {
                    policy.finish(tx, sigops, &mut flags);
                }

                TransactionAnalysis {
                    total_sigop_cost: sigops.total,
                    explicitly_rbf,
                    features: flags,
                }
            })
            .collect()
    }
}

fn resolved_output_facts(source: &InputSource, txouts: &[ProcessedOutput]) -> (OutputType, SigOps) {
    match source {
        InputSource::PreviousBlock {
            output_type,
            legacy_sigops,
            ..
        } => (*output_type, *legacy_sigops),
        InputSource::SameBlock { txout_offset, .. } => {
            let output = &txouts[*txout_offset];
            (output.output_type, output.legacy_sigops)
        }
        InputSource::Coinbase => unreachable!(),
    }
}