twamp-rs 0.2.0

Implementation of TWAMP (RFC 5357)
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

use super::command_number::CommandNumber;
use deku::prelude::*;

/// Server Greeting sent by `Server` to `Control-Client` after `Control-Client` opens up a TCP
/// connection.
///
/// See details in [RFC 4656](https://datatracker.ietf.org/doc/html/rfc4656#section-3.1).
#[derive(Clone, Debug, PartialEq, DekuRead, DekuWrite)]
#[deku(endian = "big")]
pub struct StartSessions {
    #[deku(assert_eq = "CommandNumber::StartSessions")]
    command_number: CommandNumber,
    #[deku(assert_eq = "[0u8; 15]")]
    mbz: [u8; 15],
    hmac: [u8; 16],
}

impl StartSessions {
    pub fn new() -> Self {
        StartSessions {
            command_number: CommandNumber::StartSessions,
            mbz: [0; 15],
            hmac: [0; 16],
        }
    }
}

impl Default for StartSessions {
    fn default() -> Self {
        Self::new()
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use deku::{DekuContainerRead, DekuContainerWrite};

    const START_SESSIONS_LENGTH_IN_BYTES: usize = 32;

    #[test]
    fn command_number_is_correct() {
        let start_sessions = StartSessions::new();
        assert_eq!(start_sessions.command_number, CommandNumber::StartSessions);
    }

    #[test]
    fn mbz_is_zero() {
        let start_sessions = StartSessions::new();
        assert_eq!(start_sessions.mbz, [0; 15]);
    }

    #[test]
    #[ignore]
    fn hmac_is_assigned() {
        todo!();
    }

    #[test]
    fn serialize_to_bytes() {
        let start_sessions = StartSessions::new().to_bytes().unwrap();
        assert_eq!(start_sessions.len(), START_SESSIONS_LENGTH_IN_BYTES);
    }

    #[test]
    fn deserialize_to_struct() {
        let start_sessions_as_bytes = [
            0x02, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
            0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
            0x00, 0x00, 0x00, 0x00,
        ];
        let (_rest, start_sessions) =
            StartSessions::from_bytes((&start_sessions_as_bytes, 0)).unwrap();
        assert_eq!(start_sessions.command_number, CommandNumber::StartSessions);
        assert_eq!(start_sessions.mbz, [0u8; 15]);
        assert_eq!(start_sessions.hmac, [0u8; 16]);
    }
}