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
|
//
// This Source Code Form is subject to the terms of the Mozilla Public
// License, v. 2.0. If a copy of the MPL was not distributed with this
// file, You can obtain one at http://mozilla.org/MPL/2.0/.
//
use winnow::Bytes;
use winnow::Parser;
use crate::v5::variable_header::PacketIdentifier;
use crate::v5::variable_header::ReasonString;
use crate::v5::variable_header::UserProperties;
use crate::v5::write::WResult;
use crate::v5::write::WriteMqttPacket;
use crate::v5::MResult;
crate::v5::reason_code::make_combined_reason_code! {
pub enum PubrecReasonCode {
ImplementationSpecificError = crate::v5::reason_code::ImplementationSpecificError,
NoMatchingSubscribers = crate::v5::reason_code::NoMatchingSubscribers,
NotAuthorized = crate::v5::reason_code::NotAuthorized,
PacketIdentifierInUse = crate::v5::reason_code::PacketIdentifierInUse,
PacketIdentifierNotFound = crate::v5::reason_code::PacketIdentifierNotFound,
PayloadFormatInvalid = crate::v5::reason_code::PayloadFormatInvalid,
QuotaExceeded = crate::v5::reason_code::QuotaExceeded,
Success = crate::v5::reason_code::Success,
TopicNameInvalid = crate::v5::reason_code::TopicNameInvalid,
UnspecifiedError = crate::v5::reason_code::UnspecifiedError,
}
}
crate::v5::properties::define_properties![
packet_type: MPubrec,
anker: "_Toc3901135",
pub struct PubrecProperties<'i> {
(anker: "_Toc3901137")
reason_string: ReasonString<'i>,
(anker: "_Toc3901138")
user_properties: UserProperties<'i>,
}
];
#[cfg_attr(feature = "yoke", derive(yoke::Yokeable))]
#[derive(Clone, Debug, PartialEq)]
#[doc = crate::v5::util::md_speclink!("_Toc3901131")]
pub struct MPubrec<'i> {
pub packet_identifier: PacketIdentifier,
pub reason: PubrecReasonCode,
pub properties: PubrecProperties<'i>,
}
impl<'i> MPubrec<'i> {
pub fn parse(input: &mut &'i Bytes) -> MResult<Self> {
winnow::combinator::trace("MPubrec", |input: &mut &'i Bytes| {
let packet_identifier = PacketIdentifier::parse(input)?;
let reason = if input.is_empty() {
PubrecReasonCode::Success
} else {
PubrecReasonCode::parse(input)?
};
let properties = if input.is_empty() {
PubrecProperties::new()
} else {
PubrecProperties::parse(input)?
};
Ok(Self {
packet_identifier,
reason,
properties,
})
})
.parse_next(input)
}
pub fn binary_size(&self) -> u32 {
self.packet_identifier.binary_size()
+ self.reason.binary_size()
+ self.properties.binary_size()
}
pub fn write<W: WriteMqttPacket>(&self, buffer: &mut W) -> WResult<W> {
self.packet_identifier.write(buffer)?;
self.reason.write(buffer)?;
self.properties.write(buffer)
}
}
#[cfg(test)]
mod test {
use crate::v5::packets::pubrec::MPubrec;
use crate::v5::packets::pubrec::PubrecProperties;
use crate::v5::packets::pubrec::PubrecReasonCode;
use crate::v5::variable_header::PacketIdentifier;
use crate::v5::variable_header::ReasonString;
use crate::v5::variable_header::UserProperties;
#[test]
fn test_roundtrip_mauth_no_props() {
crate::v5::test::make_roundtrip_test!(MPubrec {
packet_identifier: PacketIdentifier(123),
reason: PubrecReasonCode::Success,
properties: PubrecProperties {
reason_string: None,
user_properties: None,
}
});
}
#[test]
fn test_roundtrip_mauth_props() {
crate::v5::test::make_roundtrip_test!(MPubrec {
packet_identifier: PacketIdentifier(123),
reason: PubrecReasonCode::Success,
properties: PubrecProperties {
reason_string: Some(ReasonString("fooobasrbbarbabwer")),
user_properties: Some(UserProperties(&[0x0, 0x1, b'f', 0x0, 0x2, b'h', b'j'])),
}
});
}
}
|
