brk_computer 0.3.0-beta.9

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

use brk_cohort::ByAddrType;
use brk_types::{Height, OutputType, Sats};
use derive_more::{Deref, DerefMut};
use vecdb::ReadableVec;

use super::vecs::AddrSupplyVecs;

/// Per-addr-type running-total of a supply category (sats). Shared across
/// predicate-based supply categories (exposed, reused, respent).
#[derive(Debug, Default, Deref, DerefMut)]
pub struct AddrTypeToSupply(ByAddrType<Sats>);

impl AddrTypeToSupply {
    #[inline]
    pub(crate) fn sum(&self) -> Sats {
        self.0.values().copied().sum()
    }

    /// Apply a signed `after - before` delta to the slot for `output_type`.
    /// Sats is unsigned, so branch on sign.
    #[inline]
    pub(crate) fn apply_delta(&mut self, output_type: OutputType, before: Sats, after: Sats) {
        let slot = self.get_mut_unwrap(output_type);
        if after >= before {
            *slot += after - before;
        } else {
            *slot -= before - after;
        }
    }
}

impl From<ByAddrType<Sats>> for AddrTypeToSupply {
    #[inline]
    fn from(value: ByAddrType<Sats>) -> Self {
        Self(value)
    }
}

impl From<(&AddrSupplyVecs, Height)> for AddrTypeToSupply {
    #[inline]
    fn from((vecs, starting_height): (&AddrSupplyVecs, Height)) -> Self {
        let Some(prev_height) = starting_height.decremented() else {
            return Self::default();
        };
        vecs.by_addr_type
            .map_with_name(|_, v| v.sats.height.collect_one(prev_height).unwrap())
            .into()
    }
}