Skip to content

Commit 63d7bba

Browse files
committed
feat: Add debug lines
1 parent a558e12 commit 63d7bba

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

roborock/devices/mqtt_channel.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,6 @@ def __init__(self, mqtt_session: MqttSession, duid: str, local_key: str, rriot:
3232
self._waiting_queue: dict[int, asyncio.Future[RoborockMessage]] = {}
3333
self._decoder = create_mqtt_decoder(local_key)
3434
self._encoder = create_mqtt_encoder(local_key)
35-
# Use a regular lock since we need to access from sync callback
3635
self._queue_lock = asyncio.Lock()
3736

3837
@property
@@ -61,6 +60,7 @@ def message_handler(payload: bytes) -> None:
6160
_LOGGER.warning("Failed to decode MQTT message: %s", payload)
6261
return
6362
for message in messages:
63+
_LOGGER.debug("Received message: %s", message)
6464
asyncio.create_task(self._resolve_future_with_lock(message))
6565
try:
6666
callback(message)

0 commit comments

Comments
 (0)