fix: some misc bug changes

Author: Lash-L

roborock/protocol.py

@@ -517,15 +517,11 @@ def decode(bytes_data: bytes) -> list[RoborockMessage]:
     return decode
 
 
-def create_local_encoder(
-    local_key: str, connect_nonce: int | None = None, ack_nonce: int | None = None, prefixed: bool = True
-) -> Encoder:
+def create_local_encoder(local_key: str, connect_nonce: int | None = None, ack_nonce: int | None = None) -> Encoder:
     """Create an encoder for local API messages."""
 
     def encode(message: RoborockMessage) -> bytes:
         """Called when data is sent to the transport."""
-        return MessageParser.build(
-            message, local_key=local_key, connect_nonce=connect_nonce, ack_nonce=ack_nonce, prefixed=prefixed
-        )
+        return MessageParser.build(message, local_key=local_key, connect_nonce=connect_nonce, ack_nonce=ack_nonce)
 
     return encode

roborock/version_1_apis/roborock_local_client_v1.py

@@ -63,8 +63,11 @@ def __init__(self, device_data: DeviceData, queue_timeout: int = 4, version: str
         self._version = version
         self._connect_nonce: int | None = None
         self._ack_nonce: int | None = None
-        self._encoder: Encoder = create_local_encoder(device_data.device.local_key)
-        self._decoder: Decoder = create_local_decoder(device_data.device.local_key)
+        if version == "L01":
+            self._set_l01_encoder_decoder()
+        else:
+            self._encoder: Encoder = create_local_encoder(device_data.device.local_key)
+            self._decoder: Decoder = create_local_decoder(device_data.device.local_key)
         self.queue_timeout = queue_timeout
         self._logger = RoborockLoggerAdapter(device_data.device.name, _LOGGER)
 
@@ -121,10 +124,9 @@ async def async_disconnect(self) -> None:
         async with self._mutex:
             self._sync_disconnect()
 
-    def _reinitialize_encoder_decoder(self):
-        self._encoder = create_local_encoder(
-            self.device_info.device.local_key, self._connect_nonce, self._ack_nonce, prefixed=False
-        )
+    def _set_l01_encoder_decoder(self):
+        """Tell the system to use the L01 encoder/decoder."""
+        self._encoder = create_local_encoder(self.device_info.device.local_key, self._connect_nonce, self._ack_nonce)
         self._decoder = create_local_decoder(self.device_info.device.local_key, self._connect_nonce, self._ack_nonce)
 
     async def _do_hello(self, version: str) -> bool:
@@ -145,13 +147,13 @@ async def _do_hello(self, version: str) -> bool:
             )
             if response.version.decode() == "L01":
                 self._ack_nonce = response.random
-                self._reinitialize_encoder_decoder()
+                self._set_l01_encoder_decoder()
             self._version = version
             self._logger.debug(f"Client {self.device_info.device.duid} speaks the {version} protocol.")
             return True
         except RoborockException as e:
             self._logger.debug(
-                f"Client {self.device_info.device.duid} does not respond or does not speak the {version} protocol. {e}"
+                f"Client {self.device_info.device.duid} did not respond or does not speak the {version} protocol. {e}"
             )
             return False
 
@@ -191,7 +193,6 @@ async def _send_command(
             raise RoborockException(f"Method {method} is not supported over local connection")
         if self._version == "L01":
             request_id = get_next_int(10000, 999999)
-            # For L01, the payload is a JSON string with a "dps" field.
             dps_payload = {
                 "id": request_id,
                 "method": method,
@@ -208,7 +209,6 @@ async def _send_command(
                 version=self._version.encode(),
                 timestamp=ts,
             )
-            roborock_message.seq = request_id
             self._logger.debug("Building message id %s for method %s", request_id, method)
             return await self._send_message(
                 roborock_message,