mqute-codec 0.4.2

A full-featured implementation of MQTT protocol serialization in Rust, supporting versions 3.1, 3.1.1 and 5.0.
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

//! # Publish Release (PubRel) Packet - MQTT v5
//!
//! This module implements the MQTT v5 `PubRel` packet, which is the third packet in the
//! Quality of Service 2 (QoS 2) message delivery flow. The `PubRel` packet is sent by the
//! publisher in response to a `PubRec` to indicate it is releasing the stored message.

use crate::protocol::v5::reason::ReasonCode;
use crate::protocol::v5::util::{
    ack, ack_decode_impl, ack_encode_impl, ack_properties, ack_properties_frame_impl,
};
use crate::protocol::{Flags, PacketType, QoS, traits};

/// Validates reason codes for `PubRel` packets
///
/// MQTT v5 specifies only two valid reason codes for `PubRel`:
/// - 0x00 (Success) - Packet released normally
/// - 0x92 (Packet Identifier Not Found) - When the Packet ID is unknown
fn validate_pubrel_reason_code(code: ReasonCode) -> bool {
    matches!(code.into(), 0 | 146)
}

// Defines properties specific to `PubRel` packets
ack_properties!(PubRelProperties);

// Implements the PropertyFrame trait for PubRelProperties
ack_properties_frame_impl!(PubRelProperties);

// Represents an MQTT v5 `PubRel` packet
ack!(PubRel, PubRelProperties, validate_pubrel_reason_code);

// Implements packet decoding for `PubRel`
ack_decode_impl!(
    PubRel,
    PacketType::PubRel,
    Flags::new(QoS::AtLeastOnce),
    validate_pubrel_reason_code
);

// Implements packet encoding for `PubRel`
ack_encode_impl!(PubRel, PacketType::PubRel, Flags::new(QoS::AtLeastOnce));

impl traits::PubRel for PubRel {}