ucloud: Fix exception when using an old version of CBOR2.

Outdated versions of the CBOR2 library will not raise an exception.

Signed-off-by: iabdalkader <[email protected]>

Author: iabdalkader

src/arduino_iot_cloud/ucloud.py

@@ -22,7 +22,7 @@ class InvalidStateError(Exception):
 try:
     from arduino_iot_cloud._version import __version__
 except (ImportError, AttributeError):
-    __version__ = "1.3.0"
+    __version__ = "1.3.1"
 
 # Server/port for basic auth.
 _DEFAULT_SERVER = "iot.arduino.cc"
@@ -199,14 +199,6 @@ def __init__(
         self.async_mode = not sync_mode
         self.connected = False
 
-        if "pin" in ssl_params:
-            try:
-                # Use M2Crypto to load key and cert from HSM.
-                import M2Crypto  # noqa
-            except (ImportError, AttributeError):
-                logging.error("The m2crypto module is required to use HSM.")
-                sys.exit(1)
-
         # Convert args to bytes if they are passed as strings.
         if isinstance(device_id, str):
             device_id = bytes(device_id, "utf-8")
@@ -372,9 +364,11 @@ def poll_discovery(self, aiot=None):
                 self.mqtt.subscribe(self.create_topic("shadow", "i"), qos=1)
                 self.mqtt.publish(self.create_topic("shadow", "o"), self.senmlpack.to_cbor(), qos=1)
 
-            # Push library version and mode.
-            libv = "%s-%s" % (__version__, "async" if self.async_mode else "sync")
-            self.mqtt.publish(self.command_topic, cbor2.dumps(cbor2.CBORTag(67328, [libv])), qos=1)
+            if hasattr(cbor2, "dumps"):
+                # Push library version and mode.
+                libv = "%s-%s" % (__version__, "async" if self.async_mode else "sync")
+                # Note we have to add the tag manually because python-ecosys's cbor2 doesn't suppor CBORTags.
+                self.mqtt.publish(self.command_topic, b"\xda\x00\x01\x07\x00" + cbor2.dumps([libv]), qos=1)
             logging.info("Device configured via discovery protocol.")
             if self.async_mode:
                 raise DoneException()