yog 0.0.69

yog: the standalone server for litany loops — the world, the balls and the conversations, behind one wire
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

//! The bootstrap is a door, never a result (bl-9408): the measured router
//! that names one node eight times, a walk whose learned nodes are all silent,
//! and a node being one `(id, address)`.

use super::*;

/// The router as measured from the deployed engine box: its `find_node`
/// answer is one node repeated eight times.
fn eightfold(node: &FakeNode) -> Vec<Node> {
    vec![node.node(); 8]
}

#[test]
fn a_node_named_eight_times_is_learned_asked_and_answered_once() {
    let mut a = FakeNode::bind(id(0x42));
    a.serve(vec![], Mood::Answer, vec![]);
    let door = router(eightfold(&a));
    let mut dht = client(vec![door.addr], quick());
    assert_eq!(dht.lookup(id(0xff)).unwrap(), vec![a.node()]);
}

#[test]
fn a_walk_whose_learned_nodes_are_all_silent_is_dark_not_a_success() {
    let mut a = FakeNode::bind(id(0x42));
    a.serve(vec![], Mood::Silent, vec![]);
    let mut b = FakeNode::bind(id(0x43));
    b.serve(vec![], Mood::Silent, vec![]);
    let mut nodes = eightfold(&a);
    nodes.push(b.node());
    let door = router(nodes);
    let mut dht = client(vec![door.addr], quick());
    let dark = format!("no DHT node answered find_node for {}", "ff".repeat(20));
    assert_eq!(dht.lookup(id(0xff)).unwrap_err(), dark);
    // The BEP 44 verbs inherit it: nothing near the target, nothing to read
    // or write, and the caller is told so rather than handed an empty read.
    let kp = Keypair::from_seed([9u8; 32]).unwrap();
    assert!(
        dht.get(kp.public(), vec![])
            .unwrap_err()
            .starts_with("no DHT node answered get")
    );
}

#[test]
fn a_bootstrap_that_answers_and_names_nobody_is_dark_too() {
    let door = router(vec![]);
    let mut dht = client(vec![door.addr], quick());
    assert!(
        dht.lookup(id(0xff)).is_err(),
        "the router is not near anything"
    );
    let mut refusing = FakeNode::bind(id(0));
    refusing.serve(vec![], Mood::Refuse, vec![]);
    let mut dht = client(vec![refusing.addr], quick());
    assert!(dht.lookup(id(0xff)).is_err(), "nor is its refusal a result");
}

#[test]
fn one_id_at_two_addresses_is_two_nodes() {
    let mut a = FakeNode::bind(id(0x42));
    a.serve(vec![], Mood::Answer, vec![]);
    let mut twin = FakeNode::bind(id(0x42));
    twin.serve(vec![], Mood::Answer, vec![]);
    let door = router(vec![a.node(), twin.node(), a.node(), twin.node()]);
    let mut dht = client(vec![door.addr], quick());
    let mut found = dht.lookup(id(0xff)).unwrap();
    found.sort_by_key(|n| n.addr);
    let mut want = vec![a.node(), twin.node()];
    want.sort_by_key(|n| n.addr);
    assert_eq!(found, want);
}

#[test]
fn the_topology_walk_never_answers_the_bootstrap() {
    let mut nodes = topology();
    serve(&mut nodes, vec![], vec![]);
    let mut dht = client(vec![nodes[0].addr], Config { k: 8, ..quick() });
    let found = dht.lookup(id(0xff)).unwrap();
    assert_eq!(
        found,
        vec![nodes[3].node(), nodes[2].node(), nodes[1].node()]
    );
}