brk_computer 0.11.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

use brk_traversable::Traversable;
use brk_types::{Cents, Height, Version};
use vecdb::CachedBoxedVec;

use crate::{
    blocks, indexes,
    internal::{CentsTimesTenths, LazyPerBlock, LazyPriceWithRatioPerBlock, Price},
};

use super::cached_sma_source::CachedSmaSource;

#[derive(Clone, Traversable)]
pub struct SmaVecs {
    pub _1w: LazyPriceWithRatioPerBlock,
    pub _8d: LazyPriceWithRatioPerBlock,
    pub _13d: LazyPriceWithRatioPerBlock,
    pub _21d: LazyPriceWithRatioPerBlock,
    pub _1m: LazyPriceWithRatioPerBlock,
    pub _34d: LazyPriceWithRatioPerBlock,
    pub _55d: LazyPriceWithRatioPerBlock,
    pub _89d: LazyPriceWithRatioPerBlock,
    pub _111d: LazyPriceWithRatioPerBlock,
    pub _144d: LazyPriceWithRatioPerBlock,
    pub _200d: LazyPriceWithRatioPerBlock,
    pub _350d: LazyPriceWithRatioPerBlock,
    pub _1y: LazyPriceWithRatioPerBlock,
    pub _2y: LazyPriceWithRatioPerBlock,
    pub _200w: LazyPriceWithRatioPerBlock,
    pub _4y: LazyPriceWithRatioPerBlock,
    #[traversable(wrap = "200d", rename = "x2_4")]
    pub _200d_x2_4: Price<LazyPerBlock<Cents, Cents>>,
    #[traversable(wrap = "200d", rename = "x0_8")]
    pub _200d_x0_8: Price<LazyPerBlock<Cents, Cents>>,
    #[traversable(wrap = "350d", rename = "x2")]
    pub _350d_x2: Price<LazyPerBlock<Cents, Cents>>,
}

const VERSION: Version = Version::ONE;

impl SmaVecs {
    pub(super) fn new(
        version: Version,
        indexes: &indexes::Vecs,
        lookback: &blocks::LookbackVecs,
        spot_price: CachedBoxedVec<Height, Cents>,
    ) -> Self {
        let version = version + VERSION;
        let source = CachedSmaSource::new(version, spot_price);

        macro_rules! sma {
            ($name:literal, $days:expr) => {
                source.price(
                    concat!("price_sma_", $name),
                    version,
                    lookback.start_vec($days),
                    indexes,
                )
            };
        }

        let _200d = sma!("200d", 200);
        let _350d = sma!("350d", 350);

        let _200d_x2_4 = Price::from_lazy_cents_source::<CentsTimesTenths<24>, _>(
            "price_sma_200d_x2_4",
            version,
            &_200d.cents,
        );
        let _200d_x0_8 = Price::from_lazy_cents_source::<CentsTimesTenths<8>, _>(
            "price_sma_200d_x0_8",
            version,
            &_200d.cents,
        );
        let _350d_x2 = Price::from_lazy_cents_source::<CentsTimesTenths<20>, _>(
            "price_sma_350d_x2",
            version,
            &_350d.cents,
        );

        Self {
            _1w: sma!("1w", 7),
            _8d: sma!("8d", 8),
            _13d: sma!("13d", 13),
            _21d: sma!("21d", 21),
            _1m: sma!("1m", 30),
            _34d: sma!("34d", 34),
            _55d: sma!("55d", 55),
            _89d: sma!("89d", 89),
            _111d: sma!("111d", 111),
            _144d: sma!("144d", 144),
            _200d,
            _350d,
            _1y: sma!("1y", 365),
            _2y: sma!("2y", 2 * 365),
            _200w: sma!("200w", 200 * 7),
            _4y: sma!("4y", 4 * 365),
            _200d_x2_4,
            _200d_x0_8,
            _350d_x2,
        }
    }
}