mqrstt 0.1.3

Pure rust MQTTv5 client implementation for Smol, Tokio and soon sync too.
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

use std::string::FromUtf8Error;

use thiserror::Error;

use super::{PacketType, PropertyType};

#[derive(Error, Clone, Debug)]
pub enum DeserializeError {
    #[error("Malformed packet: {0}")]
    MalformedPacketWithInfo(String),

    #[error("Malformed packet")]
    MalformedPacket,

    #[error("Malformed FixedHeader {0:b}")]
    UnknownFixedHeader(u8),

    #[error("Unsupported protocol version")]
    UnsupportedProtocolVersion,

    #[error("Unknown protocol version")]
    UnknownProtocolVersion,

    #[error("There is insufficient for {0} data ({1}) to take {2} bytes")]
    InsufficientData(String, usize, usize),

    #[error("There is insufficient to read the protocol version.")]
    InsufficientDataForProtocolVersion,

    #[error("Reason code {0} is not allowed for packet type {1:?}")]
    UnexpectedReasonCode(u8, PacketType),

    #[error("Property field {0:?} was found at least twice")]
    DuplicateProperty(PropertyType),

    #[error("Property type {0:?} is not allowed for packet type {1:?}")]
    UnexpectedProperty(PropertyType, PacketType),

    #[error("Property with id {0} is unknown.")]
    UnknownProperty(u8),

    #[error("Encountered an QoS higher than 2, namely {0:?}")]
    UnknownQoS(u8),

    #[error("Encountered an error when reading in a UTF-8 string. {0}")]
    Utf8Error(FromUtf8Error),
}

impl From<String> for DeserializeError {
    fn from(s: String) -> Self {
        DeserializeError::MalformedPacketWithInfo(s)
    }
}

#[derive(Error, Clone, Debug)]
pub enum ReadBytes<T> {
    #[error("Normal error")]
    Err(#[from] T),

    #[error("Should read more data from the stream.")]
    InsufficientBytes(usize),
}

#[derive(Error, Debug)]
pub enum SerializeError {
    #[error("Can not write {0} in a 4 byte variable integer.")]
    VariableIntegerOverflow(usize),

    #[error("Authentication data without authentication method")]
    AuthDataWithoutAuthMethod,
}