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
|
//
// 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::properties::define_properties;
use crate::v5::variable_header::ReasonString;
use crate::v5::variable_header::ServerReference;
use crate::v5::variable_header::SessionExpiryInterval;
use crate::v5::variable_header::UserProperties;
use crate::v5::MResult;
crate::v5::reason_code::make_combined_reason_code! {
pub enum DisconnectReasonCode {
AdministrativeAction = crate::v5::reason_code::AdministrativeAction,
BadAuthenticationMethod = crate::v5::reason_code::BadAuthenticationMethod,
ConnectionRateExceeded = crate::v5::reason_code::ConnectionRateExceeded,
DisconnectWithWillMessage = crate::v5::reason_code::DisconnectWithWillMessage,
ImplementationSpecificError = crate::v5::reason_code::ImplementationSpecificError,
KeepAliveTimeout = crate::v5::reason_code::KeepAliveTimeout,
MalformedPacket = crate::v5::reason_code::MalformedPacket,
MaximumConnectTime = crate::v5::reason_code::MaximumConnectTime,
MessageRateTooHigh = crate::v5::reason_code::MessageRateTooHigh,
NormalDisconnection = crate::v5::reason_code::NormalDisconnection,
NotAuthorized = crate::v5::reason_code::NotAuthorized,
PacketTooLarge = crate::v5::reason_code::PacketTooLarge,
PayloadFormatInvalid = crate::v5::reason_code::PayloadFormatInvalid,
ProtocolError = crate::v5::reason_code::ProtocolError,
QoSNotSupported = crate::v5::reason_code::QoSNotSupported,
QuotaExceeded = crate::v5::reason_code::QuotaExceeded,
ReceiveMaximumExceeded = crate::v5::reason_code::ReceiveMaximumExceeded,
RetainNotSupported = crate::v5::reason_code::RetainNotSupported,
ServerBusy = crate::v5::reason_code::ServerBusy,
ServerMoved = crate::v5::reason_code::ServerMoved,
ServerShuttingDown = crate::v5::reason_code::ServerShuttingDown,
SessionTakenOver = crate::v5::reason_code::SessionTakenOver,
SharedSubscriptionsNotSupported = crate::v5::reason_code::SharedSubscriptionsNotSupported,
SubscriptionIdentifiersNotSupported = crate::v5::reason_code::SubscriptionIdentifiersNotSupported,
TopicAliasInvalid = crate::v5::reason_code::TopicAliasInvalid,
TopicFilterInvalid = crate::v5::reason_code::TopicFilterInvalid,
TopicNameInvalid = crate::v5::reason_code::TopicNameInvalid,
UnspecifiedError = crate::v5::reason_code::UnspecifiedError,
UseAnotherServer = crate::v5::reason_code::UseAnotherServer,
WildcardSubscriptionsNotSupported = crate::v5::reason_code::WildcardSubscriptionsNotSupported,
}
}
define_properties! {
packet_type: MDisconnect,
anker: "_Toc3901209",
pub struct DisconnectProperties<'i> {
(anker: "_Toc3901211")
session_expiry_interval: SessionExpiryInterval,
(anker: "_Toc3901212")
reason_string: ReasonString<'i>,
(anker: "_Toc3901213")
user_properties: UserProperties<'i>,
(anker: "_Toc3901214")
server_reference: ServerReference<'i>
}
}
#[derive(Debug)]
#[doc = crate::v5::util::md_speclink!("_Toc3901205")]
pub struct MDisconnect<'i> {
pub reason_code: DisconnectReasonCode,
pub properties: DisconnectProperties<'i>,
}
impl<'i> MDisconnect<'i> {
pub fn parse(input: &mut &'i Bytes) -> MResult<MDisconnect<'i>> {
winnow::combinator::trace("MDisconnect", |input: &mut &'i Bytes| {
let (reason_code, properties) =
(DisconnectReasonCode::parse, DisconnectProperties::parse).parse_next(input)?;
Ok(MDisconnect {
reason_code,
properties,
})
})
.parse_next(input)
}
}
|
