fix: make code dynamic

Author: Lash-L

roborock/devices/mqtt_channel.py

@@ -69,7 +69,7 @@ def message_handler(payload: bytes) -> None:
                 return
             for message in messages:
                 _LOGGER.debug("Received message: %s", message)
-                if message.version == b"1.0":
+                if message.version != b"B01":
                     asyncio.create_task(self._resolve_future_with_lock(message))
                 try:
                     callback(message)

roborock/protocols/b01_protocol.py

@@ -13,6 +13,7 @@
     RoborockMessage,
     RoborockMessageProtocol,
 )
+from roborock.util import get_next_int
 
 _LOGGER = logging.getLogger(__name__)
 
@@ -23,7 +24,15 @@
 
 def encode_mqtt_payload(dps: int, command: CommandType, params: ParamsType) -> RoborockMessage:
     """Encode payload for B01 commands over MQTT."""
-    dps_data = {"dps": {dps: {"method": str(command), "msgId": "1751755654575", "params": params or []}}}
+    dps_data = {
+        "dps": {
+            dps: {
+                "method": str(command),
+                "msgId": str(get_next_int(100000000000, 999999999999)),
+                "params": params or [],
+            }
+        }
+    }
     payload = pad(json.dumps(dps_data).encode("utf-8"), AES.block_size)
     return RoborockMessage(
         protocol=RoborockMessageProtocol.RPC_REQUEST,