[PATCH] support for paho.mqtt.python 2.0.0 (#211)

Author: IanBoden

src/wiotp/sdk/client.py

@@ -128,7 +128,13 @@ def __init__(
             pahoVersion,
             wiotpVersion,
         )
-        self.client = paho.Client(self.clientId, transport=transport, clean_session=(not cleanStart))
+
+        # paho 2.0.0 has a breaking change for callbacks to support both 2.0.0 and 1.x we need
+        # to create a client in version1 mode if using 2.0.0
+        if pahoVersion >= "2.0.0":
+            self.client = paho.Client(paho.CallbackAPIVersion.VERSION1, self.clientId, transport=transport, clean_session=(not cleanStart))
+        else:
+            self.client = paho.Client(self.clientId, transport=transport, clean_session=(not cleanStart))
 
         # Normal usage puts the client in an auto-detect mode, where it will try to use
         # TLS, and fall back to unencrypted mode ONLY if TLS 1.2 is unavailable.