Fix RoborockSession

Author: allenporter

roborock/mqtt/roborock_session.py

@@ -31,7 +31,7 @@
 BACKOFF_MULTIPLIER = 1.5
 
 
-class RoorockMqttSession(MqttSession):
+class RoborockMqttSession(MqttSession):
     """An MQTT session for sending and receiving messages.
 
     You can start a session invoking the start() method which will connect to
@@ -74,7 +74,7 @@ async def start(self) -> None:
         await start_future
 
     async def close(self) -> None:
-        """Cancels the mqtt loop and shutdown the client library."""
+        """Cancels the MQTT loop and shutdown the client library."""
         if self._background_task:
             self._background_task.cancel()
             try:
@@ -158,7 +158,7 @@ async def _mqtt_client(self, params: MqttParams) -> aiomqtt.Client:
                 self._client = None
 
     async def _process_message_loop(self, client: aiomqtt.Client) -> None:
-        _LOGGER.debug("Processing mqtt messages")
+        _LOGGER.debug("Processing MQTT messages")
         async for message in client.messages:
             _LOGGER.debug("Received message: %s", message)
             for listener in self._listeners.get(message.topic.value) or []:
@@ -208,6 +208,6 @@ async def create_mqtt_session(params: MqttParams) -> MqttSession:
     raise an exception if initial attempt to connect fails. Once connected,
     the session will retry connecting on failure in the background.
     """
-    session = RoorockMqttSession(params)
+    session = RoborockMqttSession(params)
     await session.start()
     return session