From 4c63b720c4545efa909904fba0d5f9ee63f36482 Mon Sep 17 00:00:00 2001
From: Nicolas Jouanin <nico@beerfactory.org>
Date: Sat, 11 Jul 2015 21:08:03 +0200
Subject: [PATCH] Add logging for unhandled messages

---
 hbmqtt/mqtt/protocol/handler.py | 23 +++++++++++++++--------
 1 file changed, 15 insertions(+), 8 deletions(-)

diff --git a/hbmqtt/mqtt/protocol/handler.py b/hbmqtt/mqtt/protocol/handler.py
index 18f2f66..b2cc247 100644
--- a/hbmqtt/mqtt/protocol/handler.py
+++ b/hbmqtt/mqtt/protocol/handler.py
@@ -18,6 +18,7 @@ from hbmqtt.mqtt.puback import PubackPacket
 from hbmqtt.mqtt.pubrec import PubrecPacket
 from hbmqtt.mqtt.pubcomp import PubcompPacket
 from hbmqtt.mqtt.suback import SubackPacket
+from hbmqtt.mqtt.subscribe import SubscribePacket
 from hbmqtt.mqtt.unsuback import UnsubackPacket
 from hbmqtt.mqtt.disconnect import DisconnectPacket
 from hbmqtt.session import Session
@@ -153,6 +154,8 @@ class ProtocolHandler:
 
                     if packet.fixed_header.packet_type == PacketType.CONNACK:
                         asyncio.Task(self.handle_connack(packet))
+                    elif packet.fixed_header.packet_type == PacketType.SUBSCRIBE:
+                        asyncio.Task(self.handle_subscribe(packet))
                     elif packet.fixed_header.packet_type == PacketType.SUBACK:
                         asyncio.Task(self.handle_suback(packet))
                     elif packet.fixed_header.packet_type == PacketType.UNSUBACK:
@@ -231,35 +234,39 @@ class ProtocolHandler:
         return inflight_message
 
     def handle_keepalive(self):
-        pass
+        self.logger.warn('keepalive unhandled')
 
     @asyncio.coroutine
     def handle_connack(self, connack: ConnackPacket):
-        pass
+        self.logger.warn('CONNACK unhandled')
 
     @asyncio.coroutine
     def handle_connect(self, connect: ConnectPacket):
-        pass
+        self.logger.warn('CONNECT unhandled')
+
+    @asyncio.coroutine
+    def handle_subscribe(self, subscribe: SubscribePacket):
+        self.logger.warn('SUBSCRIBE unhandled')
 
     @asyncio.coroutine
     def handle_suback(self, suback: SubackPacket):
-        pass
+        self.logger.warn('SUBACK unhandled')
 
     @asyncio.coroutine
     def handle_unsuback(self, unsuback: UnsubackPacket):
-        pass
+        self.logger.warn('UNSUBACK unhandled')
 
     @asyncio.coroutine
     def handle_pingresp(self, pingresp: PingRespPacket):
-        pass
+        self.logger.warn('PINGRESP unhandled')
 
     @asyncio.coroutine
     def handle_pingreq(self, pingreq: PingReqPacket):
-        pass
+        self.logger.warn('PINGREQ unhandled')
 
     @asyncio.coroutine
     def handle_disconnect(self, disconnect: DisconnectPacket):
-        pass
+        self.logger.warn('DISCONNECT unhandled')
 
     @asyncio.coroutine
     def handle_puback(self, puback: PubackPacket):