From 995e24088219bfd055b27ae47ea1621b145ffbb7 Mon Sep 17 00:00:00 2001 From: Nicolas Jouanin Date: Wed, 19 Aug 2015 23:26:35 +0200 Subject: [PATCH] Add missing file --- hbmqtt/plugins/packet_logger.py | 31 +++++++++++++++++++++++++++++++ 1 file changed, 31 insertions(+) create mode 100644 hbmqtt/plugins/packet_logger.py diff --git a/hbmqtt/plugins/packet_logger.py b/hbmqtt/plugins/packet_logger.py new file mode 100644 index 0000000..543ab1c --- /dev/null +++ b/hbmqtt/plugins/packet_logger.py @@ -0,0 +1,31 @@ +# Copyright (c) 2015 Nicolas JOUANIN +# +# See the file license.txt for copying permission. + +import logging +import asyncio +from functools import partial + + +class PacketLoggerPlugin: + def __init__(self, context): + self.logger = logging.getLogger(__name__) + self.context = context + + @asyncio.coroutine + def on_mqtt_packet_received(self, *args, **kwargs): + packet = kwargs.get('packet') + session = kwargs.get('session', None) + if session: + self.logger.debug("%s <-in-- %s" % (session.client_id, repr(packet))) + else: + self.logger.debug("<-in-- %s" % repr(packet)) + + @asyncio.coroutine + def on_mqtt_packet_sent(self, *args, **kwargs): + packet = kwargs.get('packet') + session = kwargs.get('session', None) + if session: + self.logger.debug("%s -out-> %s" % (session.client_id, repr(packet))) + else: + self.logger.debug("-out-> %s" % repr(packet))