Changes to work with the latest miniMQTT updates

Author: Jim Bennett

adafruit_azureiot/constants.py

@@ -13,7 +13,7 @@
 """
 
 # The version of the IoT Central MQTT API this code is built against
-IOTC_API_VERSION = "2016-11-14"
+IOTC_API_VERSION = "2019-03-30"
 
 # The version of the Azure Device Provisioning Service this code is built against
 DPS_API_VERSION = "2018-11-01"

adafruit_azureiot/device_registration.py

@@ -59,10 +59,11 @@ def _parse_http_status(status_code: int, status_reason: str) -> None:
                 )
 
     def __init__(
-        self, socket, id_scope: str, device_id: str, key: str, logger: Logger = None
+        self, socket, iface, id_scope: str, device_id: str, key: str, logger: Logger = None
     ):
         """Creates an instance of the device registration service
         :param socket: The network socket
+        :param iface: The network interface
         :param str id_scope: The ID scope of the device to register
         :param str device_id: The device ID of the device to register
         :param str key: The primary or secondary key of the device to register
@@ -73,7 +74,8 @@ def __init__(
         self._key = key
         self._logger = logger if logger is not None else logging.getLogger("log")
 
-        requests.set_socket(socket)
+        socket.set_interface(iface)
+        requests.set_socket(socket, iface)
 
     def _loop_assign(self, operation_id, headers) -> str:
         uri = "https://%s/%s/registrations/%s/operations/%s?api-version=%s" % (

adafruit_azureiot/iot_mqtt.py

@@ -118,10 +118,10 @@ def _create_mqtt_client(self) -> None:
             port=8883,
             keep_alive=120,
             is_ssl=True,
-            client_id=self._device_id,
-            log=True,
+            client_id=self._device_id
         )
 
+        self._mqtts.logger = self._logger
         self._mqtts.logger.setLevel(self._logger.getEffectiveLevel())
 
         # set actions to take throughout connection lifecycle

adafruit_azureiot/iotcentral_device.py

@@ -136,7 +136,12 @@ def connect(self) -> None:
         :raises RuntimeError: if the internet connection is not responding or is unable to connect
         """
         self._device_registration = DeviceRegistration(
-            self._socket, self._id_scope, self._device_id, self._key, self._logger
+            self._socket,
+            self._iface,
+            self._id_scope,
+            self._device_id,
+            self._key,
+            self._logger
         )
 
         token_expiry = int(time.time() + self._token_expires)
@@ -152,6 +157,10 @@ def connect(self) -> None:
             self._logger,
         )
 
+        self._logger.debug("Hostname: " + hostname)
+        self._logger.debug("Device Id: " + self._device_id)
+        self._logger.debug("Shared Access Key: " + self._key)
+
         self._mqtt.connect()
         self._mqtt.subscribe_to_twins()