npsd 0.2.0

Network payload serializer / deserializer framework
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
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140

#[cfg(feature = "sync")]
use std::fmt::Debug;

#[cfg(feature = "sync")]
use npsd::{Payload};

#[cfg(feature = "sync")]
fn test_send_recv<'p, T, E>(src: T, dst: E)
    where
        T: Payload<'p, ()>,
        E: Payload<'p, ()> + PartialEq + Debug,
{
    use pretty_hex::PrettyHex;


    #[cfg(feature = "info")]
    use npsd::NextTrace;

    #[cfg(not(feature = "info"))]
    use npsd::Next;

    let mut ctx = ();

    // Create Middleware
    #[cfg(not(feature = "info"))]
    let mut next = Next::default();

    #[cfg(feature = "info")]
    let mut next = NextTrace::default();

    src.into_packet(&mut ctx, &mut next).unwrap();

    println!("Encoded: {:?}", next.serialized().hex_dump());

    let deserialized = E::from_packet(&mut ctx, &mut next).unwrap();

    assert_eq!(deserialized, dst);
}

macro_rules! test_tuples {
    ($value:expr) => {
        {
            test_send_recv($value, $value);
            test_send_recv(($value), ($value));
            test_send_recv(($value, $value), ($value, $value));
            test_send_recv(($value, $value, $value), ($value, $value, $value));
            test_send_recv(($value, $value, $value, $value), ($value, $value, $value, $value));
            test_send_recv(($value, $value, $value, $value, $value), ($value, $value, $value, $value, $value));
            test_send_recv(($value, $value, $value, $value, $value, $value), ($value, $value, $value, $value, $value, $value));
            test_send_recv(($value, $value, $value, $value, $value, $value, $value), ($value, $value, $value, $value, $value, $value, $value));
            test_send_recv(($value, $value, $value, $value, $value, $value, $value, $value), ($value, $value, $value, $value, $value, $value, $value, $value));
        }
    };
}

#[cfg(feature = "sync")]
#[test]
fn test_tuple() {
    test_tuples!(());
    test_tuples!(true);
    test_tuples!(false);
    test_tuples!('H');
    test_tuples!('\u{00e9}');

    test_tuples!(-42i8);
    test_tuples!(42u8);
    test_tuples!(-2700i16);
    test_tuples!(42203u16);
    test_tuples!(-245500i32);
    test_tuples!(42235603u32);
    test_tuples!(-24558573920i64);
    test_tuples!(42235848723603u64);
    test_tuples!(-2455857399409220i128);
    test_tuples!(42235848723983488603u128);
    test_tuples!(-1337isize);
    test_tuples!(1337usize);

    test_tuples!(Some(-42i8));
    test_tuples!(Some(42u8));
    test_tuples!(Some(-2700i16));
    test_tuples!(Some(42203u16));
    test_tuples!(Some(-245500i32));
    test_tuples!(Some(42235603u32));
    test_tuples!(Some(-24558573920i64));
    test_tuples!(Some(42235848723603u64));
    test_tuples!(Some(-2455857399409220i128));
    test_tuples!(Some(42235848723983488603u128));
    test_tuples!(Some(-1337isize));
    test_tuples!(Some(1337usize));
    test_tuples!(None::<u8>);

    test_tuples!([-42i8; 64]);
    test_tuples!([42u8; 64]);
    test_tuples!([-2700i16; 64]);
    test_tuples!([42203u16; 64]);
    test_tuples!([-245500i32; 64]);
    test_tuples!([42235603u32; 64]);
    test_tuples!([-24558573920i64; 64]);
    test_tuples!([42235848723603u64; 64]);
    test_tuples!([-2455857399409220i128; 64]);
    test_tuples!([42235848723983488603u128; 64]);
    test_tuples!([-1337isize; 64]);
    test_tuples!([1337usize; 64]);

    test_tuples!(vec![-42i8, -42i8, -42i8, -42i8, -42i8]);
    test_tuples!(vec![42u8, 42u8, 42u8, 42u8, 42u8]);
    test_tuples!(vec![-2700i16, -2700i16, -2700i16, -2700i16]);
    test_tuples!(vec![42203u16, 42203u16, 42203u16, 42203u16]);
    test_tuples!(vec![-245500i32, -245500i32, -245500i32]);
    test_tuples!(vec![42235603u32, 42235603u32, 42235603u32]);
    test_tuples!(vec![-24558573920i64, -24558573920i64, -24558573920i64]);
    test_tuples!(vec![42235848723603u64, 42235848723603u64, 42235848723603u64]);
    test_tuples!(vec![-2455857399409220i128, -2455857399409220i128]);
    test_tuples!(vec![42235848723983488603u128, 42235848723983488603u128]);
    test_tuples!(vec![-1337isize, -1337isize, -1337isize]);
    test_tuples!(vec![1337usize, 1337usize, 1337usize]);

    test_tuples!(vec![Some(-42i8), None]);
    test_tuples!(vec![Some(42u8), None]);
    test_tuples!(vec![Some(-2700i16), None]);
    test_tuples!(vec![Some(42203u16), None]);
    test_tuples!(vec![Some(-245500i32), None]);
    test_tuples!(vec![Some(42235603u32), None]);
    test_tuples!(vec![Some(-24558573920i64), None]);
    test_tuples!(vec![Some(42235848723603u64), None]);
    test_tuples!(vec![Some(-2455857399409220i128), None]);
    test_tuples!(vec![Some(42235848723983488603u128), None]);
    test_tuples!(vec![Some(-1337isize), None]);
    test_tuples!(vec![Some(1337usize), None]);

    test_tuples!("Test String".to_string());
    test_tuples!("Test String".as_bytes().to_vec());

    test_send_recv(&vec!["Test".to_string(), "Hello".to_string()], vec!["Test".to_string(), "Hello".to_string()]);

    let data = ['H', 'e', 'l', 'l', 'o', ' ', 'W', 'o', 'r', 'l', 'd', '!'];

    test_send_recv(data, data);

}