Adding uplink_raw_callback function

Author: huebe

ttn/ttnmqtt.py

@@ -33,6 +33,7 @@ def obj2json(self):
 class MyEvents(Events):
     __events__ = (
         "uplink_msg",
+        "uplink_raw_msg",
         "downlink_msg",
         "connect",
         "close")
@@ -116,6 +117,8 @@ def on_message(client, userdata, msg):
             obj = json2obj(j_msg)
             if self.__events.uplink_msg:
                 self.__events.uplink_msg(obj, client=self)
+            if self.__events.uplink_raw_msg:
+                self.__events.uplink_raw_msg(msg, client=self)
         return on_message
 
     def _on_downlink(self):
@@ -127,6 +130,9 @@ def on_publish(client, userdata, mid):
     def set_uplink_callback(self, callback):
         self.__events.uplink_msg += callback
 
+    def set_uplink_raw_callback(self, callback):
+        self.__events.uplink_raw_msg += callback
+
     def set_downlink_callback(self, callback):
         self.__events.downlink_msg += callback