Skip to content

Commit 1789f74

Browse files
committed
Implement for NodeAddRequest and test
1 parent eefb97c commit 1789f74

File tree

2 files changed

+7
-4
lines changed

2 files changed

+7
-4
lines changed

plugwise_usb/messages/requests.py

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -304,12 +304,14 @@ async def _process_stick_response(self, stick_response: StickResponse) -> None:
304304
)
305305

306306
async def _send_request(
307-
self, suppress_node_errors=False
307+
self, suppress_node_errors=False, no_response_expected=False
308308
) -> PlugwiseResponse | None:
309309
"""Send request."""
310310
if self._send_fn is None:
311311
return None
312-
return await self._send_fn(self, suppress_node_errors)
312+
return await self._send_fn(
313+
self, suppress_node_errors, no_response_expected
314+
)
313315

314316
@property
315317
def max_retries(self) -> int:
@@ -428,7 +430,7 @@ def __init__(
428430
async def send(self) -> None:
429431
"""Send request."""
430432
if (
431-
result := await self._send_request()
433+
result := await self._send_request(no_response_expected=True)
432434
) is not None:
433435
raise MessageError(
434436
f"Invalid response message. Received {result.__class__.__name__}, expected no Response"

tests/test_usb.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -252,7 +252,8 @@ def dummy_method() -> None:
252252
async def send(
253253
self,
254254
request: pw_requests.PlugwiseRequest, # type: ignore[name-defined]
255-
suppress_node_errors: bool = True,
255+
suppress_node_errors=True,
256+
no_response_expected=False,
256257
) -> pw_responses.PlugwiseResponse | None: # type: ignore[name-defined]
257258
"""Submit request to queue and return response."""
258259
return self.send_response

0 commit comments

Comments
 (0)