antenna-protocol 0.1.0

SansIO core driving the antenna P2P mesh protocol.
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

#[cfg(test)]
mod test {
    use std::collections::HashMap;

    use crate::{
        MeshNodeFSM, PeerID,
        test::{assert_full_mesh_connectivity, drive_bootstrap_handshake, join_mesh},
    };

    #[test]
    fn three_peer_mesh() {
        let mut alice = MeshNodeFSM::new();
        let alice_id = alice.id().clone();
        let mut bob = MeshNodeFSM::new();
        let bob_id = bob.id().clone();

        let mut peers: HashMap<PeerID, MeshNodeFSM> = HashMap::new();

        drive_bootstrap_handshake::<()>(&mut alice, &mut bob);

        peers.insert(alice_id.clone(), alice);
        peers.insert(bob_id.clone(), bob);

        assert_full_mesh_connectivity(&peers);
        assert_eq!(peers.len(), 2);

        let charlie = MeshNodeFSM::new();
        let charlie_id = charlie.id().clone();
        peers.insert(charlie_id.clone(), charlie);

        join_mesh(&charlie_id, &bob_id, &mut peers);

        assert_full_mesh_connectivity(&peers);
        assert_eq!(peers.len(), 3);

        for mesh in peers.values() {
            assert_eq!(mesh.connected_number(), 2);
        }
    }

    #[test]
    fn incremental() {
        let mut alice = MeshNodeFSM::new();
        let alice_id = alice.id().clone();
        let mut bob = MeshNodeFSM::new();
        let bob_id = bob.id().clone();

        let mut peers: HashMap<PeerID, MeshNodeFSM> = HashMap::new();

        drive_bootstrap_handshake::<()>(&mut alice, &mut bob);

        peers.insert(alice_id.clone(), alice);
        peers.insert(bob_id.clone(), bob);

        assert_full_mesh_connectivity(&peers);
        assert_eq!(peers.len(), 2);

        let charlie = MeshNodeFSM::new();
        let charlie_id = charlie.id().clone();
        peers.insert(charlie_id.clone(), charlie);

        join_mesh(&charlie_id, &bob_id, &mut peers);

        assert_full_mesh_connectivity(&peers);
        assert_eq!(peers.len(), 3);

        let dave = MeshNodeFSM::new();
        let dave_id = dave.id().clone();
        peers.insert(dave_id.clone(), dave);

        join_mesh(&dave_id, &alice_id, &mut peers);

        assert_full_mesh_connectivity(&peers);
        assert_eq!(peers.len(), 4);

        let eve = MeshNodeFSM::new();
        let eve_id = eve.id().clone();
        peers.insert(eve_id.clone(), eve);

        join_mesh(&eve_id, &charlie_id, &mut peers);

        assert_full_mesh_connectivity(&peers);
        assert_eq!(peers.len(), 5);

        for mesh in peers.values() {
            assert_eq!(mesh.connected_number(), 4);
        }
    }
}