mesher 0.8.0

A library to make anonymized mesh networking easier.
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
103
104
105

use mesher::prelude::*;

mod common;
use common::make_signed as make_mesher;

#[test]
fn direct() {
  let (signer_pk, signer_sk) = sign::gen_keypair();

  let (mut sender, sender_pk) = make_mesher("direct_sender", &signer_pk);
  let (mut dest1, dest1_pk) = make_mesher("direct_dest1", &signer_pk);
  let (mut dest2, dest2_pk) = make_mesher("direct_dest2", &signer_pk);

  let mut packet = Packet::signed(signer_sk);
  packet.add_hop("inmem:direct_dest1".to_owned(), &sender_pk);
  packet.add_hop("inmem:direct_dest2".to_owned(), &sender_pk);
  packet.add_message(&[1], &dest1_pk);
  packet.add_message(&[2], &dest2_pk);

  sender.launch(packet).expect("failed to launch");

  let received1 = dest1.receive().expect("failed to receive at 1");
  assert_eq!(
    vec![vec![1]],
    received1.iter().map(|m| m.contents()).collect::<Vec<_>>()
  );

  let received2 = dest2.receive().expect("failed to receive at 2");
  assert_eq!(
    vec![vec![2]],
    received2.iter().map(|m| m.contents()).collect::<Vec<_>>()
  );
}

#[test]
fn one_hop() {
  let (signer_pk, signer_sk) = sign::gen_keypair();

  let (mut sender, sender_pk) = make_mesher("onehop_sender", &signer_pk);
  let (mut im, im_pk) = make_mesher("onehop_im", &signer_pk);
  let (mut dest1, dest1_pk) = make_mesher("onehop_dest1", &signer_pk);
  let (mut dest2, dest2_pk) = make_mesher("onehop_dest2", &signer_pk);

  let mut packet = Packet::signed(signer_sk);
  packet.add_hop("inmem:onehop_im".to_owned(), &sender_pk);
  packet.add_hop("inmem:onehop_dest1".to_owned(), &im_pk);
  packet.add_hop("inmem:onehop_dest2".to_owned(), &im_pk);
  packet.add_message(&[1], &dest1_pk);
  packet.add_message(&[2], &dest2_pk);

  sender.launch(packet).expect("failed to launch");

  // will bounce the message along to dest1 and dest2
  im.receive().expect("failed to receive at im");

  let received1 = dest1.receive().expect("failed to receive at 1");
  assert_eq!(
    vec![vec![1]],
    received1.iter().map(|m| m.contents()).collect::<Vec<_>>()
  );

  let received2 = dest2.receive().expect("failed to receive at 2");
  assert_eq!(
    vec![vec![2]],
    received2.iter().map(|m| m.contents()).collect::<Vec<_>>()
  );
}

#[test]
fn two_hop() {
  let (signer_pk, signer_sk) = sign::gen_keypair();

  let (mut sender, sender_pk) = make_mesher("twohops_sender", &signer_pk);
  let (mut im1, im1_pk) = make_mesher("twohops_im1", &signer_pk);
  let (mut im2, im2_pk) = make_mesher("twohops_im2", &signer_pk);
  let (mut dest1, dest1_pk) = make_mesher("twohops_dest1", &signer_pk);
  let (mut dest2, dest2_pk) = make_mesher("twohops_dest2", &signer_pk);

  let mut packet = Packet::signed(signer_sk);
  packet.add_hop("inmem:twohops_im1".to_owned(), &sender_pk);
  packet.add_hop("inmem:twohops_im2".to_owned(), &im1_pk);
  packet.add_hop("inmem:twohops_dest1".to_owned(), &im2_pk);
  packet.add_hop("inmem:twohops_dest2".to_owned(), &im2_pk);
  packet.add_message(&[1], &dest1_pk);
  packet.add_message(&[2], &dest2_pk);

  sender.launch(packet).expect("failed to launch");

  // will bounce the message along to im2
  im1.receive().expect("failed to receive at im1");
  // will bounce the message along to dest1 and dest2
  im2.receive().expect("failed to receive at im2");

  let received1 = dest1.receive().expect("failed to receive at 1");
  assert_eq!(
    vec![vec![1]],
    received1.iter().map(|m| m.contents()).collect::<Vec<_>>()
  );

  let received2 = dest2.receive().expect("failed to receive at 2");
  assert_eq!(
    vec![vec![2]],
    received2.iter().map(|m| m.contents()).collect::<Vec<_>>()
  );
}