brk_query 0.3.0-beta.1

An interface to find and format data from BRK
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

use brk_error::Result;
use brk_types::{BlockSizeEntry, BlockSizesWeights, BlockWeightEntry, TimePeriod, Weight};
use vecdb::ReadableVec;

use super::block_window::BlockWindow;
use crate::Query;

impl Query {
    pub fn block_sizes_weights(&self, time_period: TimePeriod) -> Result<BlockSizesWeights> {
        let computer = self.computer();
        let bw = BlockWindow::new(self, time_period);
        let timestamps = bw.timestamps(self);

        // Batch read per-block rolling 24h medians for the range
        let all_sizes = computer
            .blocks
            .size
            .size
            .rolling
            .distribution
            .median
            ._24h
            .height
            .collect_range_at(bw.start, bw.end);
        let all_weights = computer
            .blocks
            .weight
            .weight
            .rolling
            .distribution
            .median
            ._24h
            .height
            .collect_range_at(bw.start, bw.end);

        // Sample at window midpoints
        let mut sizes = Vec::with_capacity(timestamps.len());
        let mut weights = Vec::with_capacity(timestamps.len());

        for ((avg_height, start, _end), ts) in bw.iter().zip(&timestamps) {
            let mid = start - bw.start + (bw.window / 2).min(all_sizes.len().saturating_sub(1));
            if let Some(&size) = all_sizes.get(mid) {
                sizes.push(BlockSizeEntry {
                    avg_height,
                    timestamp: *ts,
                    avg_size: *size,
                });
            }
            if let Some(&weight) = all_weights.get(mid) {
                weights.push(BlockWeightEntry {
                    avg_height,
                    timestamp: *ts,
                    avg_weight: Weight::from(*weight),
                });
            }
        }

        Ok(BlockSizesWeights { sizes, weights })
    }
}