wayk_proto 0.1.0

WaykNow packet encoder-decoder and sequencing utilities
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

use crate::message::status::{DisconnectStatusCode, NowStatus};

#[derive(Encode, Decode, Debug, PartialEq, Clone)]
pub struct NowTerminateMsg {
    flags: u32,
    pub status: NowStatus<DisconnectStatusCode>,
}

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

impl NowTerminateMsg {
    pub fn new(status: NowStatus<DisconnectStatusCode>) -> Self {
        Self { flags: 0, status }
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::{
        message::status::{SeverityLevel, StatusType},
        serialization::{Decode, Encode},
    };

    #[rustfmt::skip]
    const TERMINATE_MSG: [u8; 8] = [
        // flags
        0x00, 0x00, 0x00, 0x00,
        // status
        0x01, 0x00, 0x01, 0x00,
    ];

    #[test]
    fn decoding() {
        let msg = NowTerminateMsg::decode(&TERMINATE_MSG).unwrap();
        assert_eq!(msg.flags, 0);
        let status = msg.status;
        assert_eq!(status.severity(), SeverityLevel::Info);
        assert_eq!(status.status_type(), StatusType::Disconnect);
        assert_eq!(status.code(), DisconnectStatusCode::ByLocalUser);
    }

    #[test]
    fn encoding() {
        let status = NowStatus::builder(DisconnectStatusCode::ByLocalUser)
            .severity(SeverityLevel::Info)
            .status_type(StatusType::Disconnect)
            .build();
        let msg = NowTerminateMsg::new(status);
        assert_eq!(msg.encode().unwrap(), TERMINATE_MSG.to_vec());
    }
}