chore: remove extra exception

Author: Lash-L

roborock/cloud_api.py

@@ -14,7 +14,7 @@
 
 from .api import KEEPALIVE, RoborockClient
 from .containers import DeviceData, UserData
-from .exceptions import RoborockException, RoborockInvalidUserData, VacuumError
+from .exceptions import RoborockException, VacuumError
 from .protocol import (
     Decoder,
     Encoder,
@@ -96,14 +96,7 @@ def _mqtt_on_connect(
             message = f"Failed to connect ({rc})"
             self._logger.error(message)
             if connection_queue:
-                # These are the ReasonCodes relating to authorization issues.
-                if rc.value in {24, 25, 133, 134, 135, 144}:
-                    connection_queue.set_exception(
-                        RoborockInvalidUserData("Failed to connect to mqtt. Invalid user data. Re-auth is needed.")
-                    )
-                else:
-                    connection_queue.set_exception(VacuumError(message))
-            else:
+                connection_queue.set_exception(VacuumError(message))
                 self._logger.debug("Failed to notify connect future, not in queue")
             return
         self._logger.info(f"Connected to mqtt {self._mqtt_host}:{self._mqtt_port}")

roborock/exceptions.py

@@ -77,7 +77,3 @@ class RoborockTooManyRequest(RoborockException):
 
 class RoborockRateLimit(RoborockException):
     """Class for our rate limits exceptions."""
-
-
-class RoborockInvalidUserData(RoborockException):
-    """Class to state the user data is invalid (expired or manipulated)."""

roborock/roborock_future.py

@@ -5,7 +5,7 @@
 
 import async_timeout
 
-from .exceptions import RoborockInvalidUserData, VacuumError
+from .exceptions import VacuumError
 
 
 class RoborockFuture:
@@ -21,11 +21,11 @@ def _set_result(self, item: Any) -> None:
     def set_result(self, item: Any) -> None:
         self.loop.call_soon_threadsafe(self._set_result, item)
 
-    def _set_exception(self, exc: VacuumError | RoborockInvalidUserData) -> None:
+    def _set_exception(self, exc: VacuumError) -> None:
         if not self.fut.cancelled():
             self.fut.set_exception(exc)
 
-    def set_exception(self, exc: VacuumError | RoborockInvalidUserData) -> None:
+    def set_exception(self, exc: VacuumError) -> None:
         self.loop.call_soon_threadsafe(self._set_exception, exc)
 
     async def async_get(self, timeout: float | int) -> tuple[Any, VacuumError | None]: