decdn-node 0.1.0

The deCDN node daemon (decdn-node): runtime, request handlers, payment settlement, and the admin RPC server
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

use super::*;

fn nid(byte: u8) -> NodeId {
    NodeId::from_bytes([byte; 32])
}

fn addr(byte: u8) -> Address {
    Address::repeat_byte(byte)
}

fn fresh() -> (Arc<RwLock<HashMap<NodeId, Address>>>, Arc<Metrics>) {
    (
        Arc::new(RwLock::new(HashMap::new())),
        Arc::new(Metrics::new()),
    )
}

#[test]
fn static_directory_resolves_known_and_misses_unknown() {
    let mut m = HashMap::new();
    m.insert(nid(1), addr(0xAA));
    let dir = StaticNodeAddressDirectory::new(m);
    assert_eq!(dir.address_of(&nid(1)), Some(addr(0xAA)));
    assert_eq!(dir.address_of(&nid(2)), None);
}

/// `set_binding` inserts and surfaces the address; the size gauge tracks the
/// growing set, and a same-key overwrite keeps cardinality (and the gauge)
/// stable while updating the bound address.
#[test]
fn set_binding_inserts_and_overwrites() {
    let (bindings, metrics) = fresh();
    set_binding(&bindings, &metrics, nid(1), addr(0xAA));
    assert_eq!(
        bindings.read().unwrap().get(&nid(1)).copied(),
        Some(addr(0xAA))
    );
    let text = metrics.encode().unwrap();
    assert!(
        text.lines()
            .any(|l| l == "decdn_node_address_directory_size 1"),
        "gauge should report 1 after one insert:\n{text}"
    );

    // Re-registration of the same node with a rotated address overwrites
    // without changing cardinality.
    set_binding(&bindings, &metrics, nid(1), addr(0xBB));
    assert_eq!(
        bindings.read().unwrap().get(&nid(1)).copied(),
        Some(addr(0xBB))
    );
    assert_eq!(bindings.read().unwrap().len(), 1);
}

/// `remove_binding` drops a present key (and shrinks the gauge) but is a
/// no-op for an absent one.
#[test]
fn remove_binding_present_and_absent() {
    let (bindings, metrics) = fresh();
    set_binding(&bindings, &metrics, nid(1), addr(0xAA));
    set_binding(&bindings, &metrics, nid(2), addr(0xBB));
    remove_binding(&bindings, &metrics, &nid(1));
    assert!(bindings.read().unwrap().get(&nid(1)).is_none());
    assert_eq!(bindings.read().unwrap().len(), 1);
    let text = metrics.encode().unwrap();
    assert!(
        text.lines()
            .any(|l| l == "decdn_node_address_directory_size 1"),
        "gauge should report 1 after removing one of two:\n{text}"
    );

    // Removing an absent key changes nothing.
    remove_binding(&bindings, &metrics, &nid(0xFF));
    assert_eq!(bindings.read().unwrap().len(), 1);
}