From 1654935a71179e4ffe3a93bd34f4967c0932c5b8 Mon Sep 17 00:00:00 2001
From: coderr01 <130430442+coderr01@users.noreply.github.com>
Date: Tue, 30 May 2023 17:03:32 +0530
Subject: [PATCH] feat: read unsubscribe packet in v5 (#626)

---
 rumqttd/CHANGELOG.md           | 1 +
 rumqttd/src/protocol/v5/mod.rs | 4 ++++
 2 files changed, 5 insertions(+)

diff --git a/rumqttd/CHANGELOG.md b/rumqttd/CHANGELOG.md
index 36354e95..d4a32715 100644
--- a/rumqttd/CHANGELOG.md
+++ b/rumqttd/CHANGELOG.md
@@ -18,6 +18,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 ### Removed
 
 ### Fixed
+- MQTTv5: Read the Unsubscribe package in match arms (#625)
 
 ### Security
 
diff --git a/rumqttd/src/protocol/v5/mod.rs b/rumqttd/src/protocol/v5/mod.rs
index a2840831..fb0e27c7 100644
--- a/rumqttd/src/protocol/v5/mod.rs
+++ b/rumqttd/src/protocol/v5/mod.rs
@@ -404,6 +404,10 @@ impl Protocol for V5 {
                 let (suback, properties) = suback::read(fixed_header, packet)?;
                 Packet::SubAck(suback, properties)
             }
+            Packet::Unsubscribe => {
+                let (unsubscribe, properties) = unsubscribe::read(fixed_header, packet)?;
+                Packet::Unsubscribe(unsubscribe, properties)
+            }
             PacketType::PingReq => Packet::PingReq(PingReq),
             PacketType::PingResp => Packet::PingResp(PingResp),
             PacketType::Disconnect => {