1818from roborock .exceptions import RoborockException
1919from roborock .protocol import MessageParser
2020from roborock .roborock_message import (
21+ RoborockDyadDataProtocol ,
2122 RoborockMessage ,
2223 RoborockMessageProtocol ,
2324 RoborockZeoProtocol ,
24- RoborockDyadDataProtocol ,
2525)
2626from roborock .version_a01_apis import RoborockMqttClientA01
2727from tests .mock_data import (
@@ -46,7 +46,9 @@ def category_fixture() -> RoborockCategory:
4646
4747@pytest .fixture (name = "a01_mqtt_client" )
4848async def a01_mqtt_client_fixture (
49- mock_create_connection : None , mock_select : None , category : RoborockCategory ,
49+ mock_create_connection : None ,
50+ mock_select : None ,
51+ category : RoborockCategory ,
5052) -> AsyncGenerator [RoborockMqttClientA01 , None ]:
5153 user_data = UserData .from_dict (USER_DATA )
5254 home_data = HomeData .from_dict (
@@ -60,9 +62,7 @@ async def a01_mqtt_client_fixture(
6062 device = home_data .devices [0 ],
6163 model = home_data .products [0 ].model ,
6264 )
63- client = RoborockMqttClientA01 (
64- user_data , device_info , category , queue_timeout = QUEUE_TIMEOUT
65- )
65+ client = RoborockMqttClientA01 (user_data , device_info , category , queue_timeout = QUEUE_TIMEOUT )
6666 try :
6767 yield client
6868 finally :
@@ -217,7 +217,6 @@ async def test_update_zeo_values(
217217 RoborockZeoProtocol .SOFTENER_EMPTY ,
218218 RoborockZeoProtocol .TIMES_AFTER_CLEAN ,
219219 RoborockZeoProtocol .WASHING_LEFT ,
220-
221220 ]
222221 )
223222 assert data == {
@@ -240,11 +239,11 @@ async def test_update_dyad_values(
240239
241240 message = build_rpc_response (
242241 {
243- 201 : 3 , # charging
244- 215 : 920 , # Brush left
245- 209 : 74 , # Power
246- 222 : 1 , # STAND_LOCK_AUTO_RUN on
247- 224 : 0 , # AUTO_DRY_MODE off
242+ 201 : 3 , # charging
243+ 215 : 920 , # Brush left
244+ 209 : 74 , # Power
245+ 222 : 1 , # STAND_LOCK_AUTO_RUN on
246+ 224 : 0 , # AUTO_DRY_MODE off
248247 }
249248 )
250249 response_queue .put (mqtt_packet .gen_publish (MQTT_PUBLISH_TOPIC , payload = message ))
0 commit comments