feat(a01): add push listener for unsolicited device state

Author: piitaya

roborock/devices/traits/a01/__init__.py

@@ -138,9 +138,6 @@ def convert_zeo_value(protocol_value: RoborockZeoProtocol, value: Any) -> Any:
     return None
 
 
-# RoborockDyadDataProtocol._missing_ maps any unknown code to its first member
-# instead of raising, so incoming data points must be checked against this set
-# before being converted to a protocol.
 _DYAD_PROTOCOL_VALUES = frozenset(protocol.value for protocol in RoborockDyadDataProtocol)
 
 

tests/devices/traits/a01/test_init.py

@@ -141,7 +141,6 @@ async def test_dyad_add_listener(dyad_api: DyadApi, fake_channel: FakeChannel):
     received: list[dict[RoborockDyadDataProtocol, Any]] = []
     unsub = await dyad_api.add_listener(received.append)
 
-    # 999 is not a known protocol: it must be skipped, not mapped to the first enum member.
     fake_channel.notify_subscribers(build_a01_message({206: 3, 209: 80, 216: 0, 999: 1}))
 
     assert received == [
@@ -154,7 +153,7 @@ async def test_dyad_add_listener(dyad_api: DyadApi, fake_channel: FakeChannel):
 
     unsub()
     fake_channel.notify_subscribers(build_a01_message({206: 1}))
-    assert len(received) == 1  # no callback fires after unsubscribing
+    assert len(received) == 1
 
 
 async def test_zeo_api_query_values(zeo_api: ZeoApi, fake_channel: FakeChannel):