Skip to content

Commit 50d20c4

Browse files
committed
fix(testing): set RPC_RESPONSE protocol on pushed simulator messages in push_dps
1 parent b94eb89 commit 50d20c4

1 file changed

Lines changed: 2 additions & 0 deletions

File tree

roborock/testing/a01_simulator.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,7 @@
3535
from roborock.roborock_message import (
3636
RoborockDyadDataProtocol,
3737
RoborockMessage,
38+
RoborockMessageProtocol,
3839
RoborockZeoProtocol,
3940
)
4041
from roborock.testing.simulator import DEFAULT_LOCAL_KEY, RoborockDeviceSimulator
@@ -192,6 +193,7 @@ async def _handle_publish(self, message: RoborockMessage, channel: Any) -> None:
192193
def push_dps(self, dps_updates: dict[int, Any]) -> None:
193194
"""Push encrypted A01 status datapoint updates to subscribers."""
194195
msg = encode_mqtt_payload(dps_updates) # type: ignore[arg-type]
196+
msg.protocol = RoborockMessageProtocol.RPC_RESPONSE
195197
self.mqtt_channel.notify_subscribers(msg)
196198

197199
def trigger_push_update(self) -> None:

0 commit comments

Comments
 (0)