Implement MqttPacketFree

1 files changed, 26 insertions, 1 deletions

diff --git a/src/packet.c b/src/packet.c
index 1e05330..e50dc13 100644
--- a/src/packet.c
+++ b/src/packet.c
@@ -78,7 +78,32 @@ MqttPacket *MqttPacketWithIdNew(int type, uint16_t id)
 
 void MqttPacketFree(MqttPacket *packet)
 {
-    /* TODO: implement MqttPacketFree */
+    if (MqttPacketType(packet) == MqttPacketTypeConnect)
+    {
+        MqttPacketConnect *p = (MqttPacketConnect *) packet;
+        StringBufDeinit(&p->clientId);
+        StringBufDeinit(&p->willTopic);
+        StringBufDeinit(&p->willMessage);
+        StringBufDeinit(&p->userName);
+        StringBufDeinit(&p->password);
+    }
+    else if (MqttPacketType(packet) == MqttPacketTypePublish)
+    {
+        MqttPacketPublish *p = (MqttPacketPublish *) packet;
+        StringBufDeinit(&p->topicName);
+        StringBufDeinit(&p->message);
+    }
+    else if (MqttPacketType(packet) == MqttPacketTypeSubscribe)
+    {
+        MqttPacketSubscribe *p = (MqttPacketSubscribe *) packet;
+        StringBufDeinit(&p->topicFilter);
+    }
+    else if (MqttPacketType(packet) == MqttPacketTypeUnsubscribe)
+    {
+        MqttPacketUnsubscribe *p = (MqttPacketUnsubscribe *) packet;
+        StringBufDeinit(&p->topicFilter);
+    }
+    free(packet);
 }
 
 int MqttPacketHasId(const MqttPacket *packet)