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

//! MQTT v3.1.1
//!
//! See the [specification] for details.
//!
//! [specification]: (http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/os/mqtt-v3.1.1-os.html)

mod connack;
mod connect;
mod publish;
mod suback;

pub use connack::{ConnackResult, ConnectCode, ConnectError, CONNACK_LEN};
pub use connect::Connect;
pub use publish::{Publish, PublishBuilder, PublishDe};
pub use suback::{SubCode, SubError, SubackResult};

#[cfg(feature = "std")]
pub use connect::ConnectAlloc;

/// Control packet types.
///
/// See [Table 2.1 - Control packet types](http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/os/mqtt-v3.1.1-os.html#_Table_2.1_-)
#[derive(Debug, PartialEq, Eq, Clone, Copy)]
#[repr(u8)]
#[allow(clippy::upper_case_acronyms)]
pub enum CtrlPkt {
    CONNECT = 0x1,
    CONNACK = 0x2,
    PUBLISH = 0x3,
    PUBACK = 0x4,
    PUBREC = 0x5,
    PUBREL = 0x6,
    PUBCOMP = 0x7,
    SUBSCRIBE = 0x8,
    SUBACK = 0x9,
    UNSUBSCRIBE = 0xA,
    UNSUBACK = 0xB,
    PINGREQ = 0xC,
    PINGRESP = 0xD,
    DISCONNECT = 0xE,
}

impl From<CtrlPkt> for u8 {
    #[inline]
    fn from(ctrl_pkt: CtrlPkt) -> Self {
        ctrl_pkt as u8
    }
}

impl TryFrom<u8> for CtrlPkt {
    type Error = u8;

    fn try_from(val: u8) -> Result<Self, Self::Error> {
        match val {
            x if x == CtrlPkt::CONNECT as u8 => Ok(CtrlPkt::CONNECT),
            x if x == CtrlPkt::CONNACK as u8 => Ok(CtrlPkt::CONNACK),
            x if x == CtrlPkt::PUBLISH as u8 => Ok(CtrlPkt::PUBLISH),
            x if x == CtrlPkt::PUBACK as u8 => Ok(CtrlPkt::PUBACK),
            x if x == CtrlPkt::PUBREC as u8 => Ok(CtrlPkt::PUBREC),
            x if x == CtrlPkt::PUBREL as u8 => Ok(CtrlPkt::PUBREL),
            x if x == CtrlPkt::PUBCOMP as u8 => Ok(CtrlPkt::PUBCOMP),
            x if x == CtrlPkt::SUBSCRIBE as u8 => Ok(CtrlPkt::SUBSCRIBE),
            x if x == CtrlPkt::SUBACK as u8 => Ok(CtrlPkt::SUBACK),
            x if x == CtrlPkt::UNSUBSCRIBE as u8 => Ok(CtrlPkt::UNSUBSCRIBE),
            x if x == CtrlPkt::UNSUBACK as u8 => Ok(CtrlPkt::UNSUBACK),
            x if x == CtrlPkt::PINGREQ as u8 => Ok(CtrlPkt::PINGREQ),
            x if x == CtrlPkt::PINGRESP as u8 => Ok(CtrlPkt::PINGRESP),
            x if x == CtrlPkt::DISCONNECT as u8 => Ok(CtrlPkt::DISCONNECT),
            x => Err(x),
        }
    }
}

/// Quality of service.
///
/// [Table 3.2 - QoS definitions](http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/os/mqtt-v3.1.1-os.html#_Table_3.11_-)
#[repr(u8)]
#[derive(Debug, PartialEq, Eq, Clone, Copy)]
pub enum QoS {
    /// QoS 0
    AtMostOnce = 0b00,
    /// QoS 1
    AtLeastOnce = 0b01,
    /// QoS 2
    ExactlyOnce = 0b10,
}

impl TryFrom<u8> for QoS {
    type Error = u8;

    fn try_from(val: u8) -> Result<Self, Self::Error> {
        match val {
            x if x == QoS::AtMostOnce as u8 => Ok(QoS::AtMostOnce),
            x if x == QoS::AtLeastOnce as u8 => Ok(QoS::AtLeastOnce),
            x if x == QoS::ExactlyOnce as u8 => Ok(QoS::ExactlyOnce),
            x => Err(x),
        }
    }
}

impl From<QoS> for u8 {
    #[inline]
    fn from(qos: QoS) -> Self {
        qos as u8
    }
}