kaspa-notify 0.15.0

Kaspa notification subsystem
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

use crate::{
    events::{EventArray, EventType},
    listener::ListenerId,
    subscription::{compounded, single, CompoundedSubscription, DynSubscription},
};
use std::sync::Arc;

pub struct ArrayBuilder {}

impl ArrayBuilder {
    pub fn single(listener_id: ListenerId, utxos_changed_capacity: Option<usize>) -> EventArray<DynSubscription> {
        EventArray::from_fn(|i| {
            let event_type = EventType::try_from(i).unwrap();
            let subscription: DynSubscription = match event_type {
                EventType::VirtualChainChanged => Arc::<single::VirtualChainChangedSubscription>::default(),
                EventType::UtxosChanged => Arc::new(single::UtxosChangedSubscription::with_capacity(
                    single::UtxosChangedState::None,
                    listener_id,
                    utxos_changed_capacity.unwrap_or_default(),
                )),
                _ => Arc::new(single::OverallSubscription::new(event_type, false)),
            };
            subscription
        })
    }

    pub fn compounded(utxos_changed_capacity: Option<usize>) -> EventArray<CompoundedSubscription> {
        EventArray::from_fn(|i| {
            let event_type = EventType::try_from(i).unwrap();
            let subscription: CompoundedSubscription = match event_type {
                EventType::VirtualChainChanged => Box::<compounded::VirtualChainChangedSubscription>::default(),
                EventType::UtxosChanged => {
                    Box::new(compounded::UtxosChangedSubscription::with_capacity(utxos_changed_capacity.unwrap_or_default()))
                }
                _ => Box::new(compounded::OverallSubscription::new(event_type)),
            };
            subscription
        })
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::events::EVENT_TYPE_ARRAY;

    #[test]
    fn test_array_builder() {
        let single = ArrayBuilder::single(0, None);
        let compounded = ArrayBuilder::compounded(None);
        EVENT_TYPE_ARRAY.into_iter().for_each(|event| {
            assert_eq!(
                event,
                single[event].event_type(),
                "single subscription array item {:?} reports wrong event type {:?}",
                event,
                single[event].event_type()
            );
            assert_eq!(
                event,
                compounded[event].event_type(),
                "compounded subscription array item {:?} reports wrong event type {:?}",
                event,
                compounded[event].event_type()
            );
        });
    }
}