Update to version 0.1.9

Minor fixes

Author: humbertogontijo

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "python-roborock"
-version = "0.1.8"
+version = "0.1.9"
 description = ""
 authors = ["humbertogontijo <humbertogontijo@users.noreply.github.com>"]
 license = "GPL-3.0-only"

roborock/api.py

@@ -106,7 +106,7 @@ def __init__(self, user_data: UserData, device_map: dict[str, RoborockDeviceInfo
         self._mqtt_user = rriot.user
         self._mqtt_domain = rriot.domain
         self._hashed_user = md5hex(self._mqtt_user + ":" + self._mqtt_domain)[2:10]
-        super().__init__(client_id=self._hashed_user, protocol=mqtt.MQTTv5)
+        super().__init__(protocol=mqtt.MQTTv5)
         url = urlparse(rriot.reference.mqtt)
         self._mqtt_host = url.hostname
         self._mqtt_port = url.port
@@ -231,13 +231,6 @@ async def on_disconnect(self, _client: mqtt.Client, _, rc, __=None) -> None:
             message = f"Roborock mqtt client disconnected (rc: {rc})"
             _LOGGER.warning(message)
             connection_queue = self._waiting_queue.get(1)
-            if rc != mqtt.MQTT_ERR_SUCCESS and rc != mqtt.MQTT_ERR_KEEPALIVE:
-                await self.async_disconnect()
-                if connection_queue:
-                    await connection_queue.async_put(
-                        (None, VacuumError(rc, message)), timeout=QUEUE_TIMEOUT
-                    )
-                return
             if connection_queue:
                 await connection_queue.async_put(
                     (True, None), timeout=QUEUE_TIMEOUT