Try

Author: bouwew

plugwise_usb/connection/__init__.py

@@ -230,13 +230,16 @@ async def get_node_details(
         return (info_response, ping_response)
 
     async def send(
-        self, request: PlugwiseRequest, suppress_node_errors: bool = True
+        self,
+        request: PlugwiseRequest,
+        suppress_node_errors=True,
+        no_response_expected=False,
     ) -> PlugwiseResponse | None:
         """Submit request to queue and return response."""
         if not suppress_node_errors:
-            return await self._queue.submit(request)
+            return await self._queue.submit(request, no_response_expected)
         try:
-            return await self._queue.submit(request)
+            return await self._queue.submit(request, no_response_expected)
         except (NodeError, StickError):
             return None
 

plugwise_usb/connection/queue.py

@@ -74,7 +74,9 @@ async def stop(self) -> None:
         self._stick = None
         _LOGGER.debug("queue stopped")
 
-    async def submit(self, request: PlugwiseRequest) -> PlugwiseResponse | None:
+    async def submit(
+        self, request: PlugwiseRequest, no_response_expected=False
+    ) -> PlugwiseResponse | None:
         """Add request to queue and return the response of node. Raises an error when something fails."""
         if request.waiting_for_response:
             raise MessageError(
@@ -90,6 +92,8 @@ async def submit(self, request: PlugwiseRequest) -> PlugwiseResponse | None:
                 )
             await self._add_request_to_queue(request)
             try:
+                if no_response_expected:
+                    return None
                 response: PlugwiseResponse = await request.response_future()
                 return response
             except (NodeTimeout, StickTimeout) as e:

plugwise_usb/connection/sender.py

@@ -86,6 +86,7 @@ async def write_request_to_port(self, request: PlugwiseRequest) -> None:
         # Wait for USB stick to accept request
         try:
             async with timeout(STICK_TIME_OUT):
+                _LOGGER.debug("HOI start waiting for response")
                 response: StickResponse = await self._stick_response
         except TimeoutError:
             _LOGGER.warning(

plugwise_usb/messages/requests.py

@@ -304,12 +304,14 @@ async def _process_stick_response(self, stick_response: StickResponse) -> None:
             )
 
     async def _send_request(
-        self, suppress_node_errors: bool = False
+        self, suppress_node_errors=False, no_response_expected=False,
     ) -> PlugwiseResponse | None:
         """Send request."""
         if self._send_fn is None:
             return None
-        return await self._send_fn(self, suppress_node_errors)
+        return await self._send_fn(
+            self, suppress_node_errors, no_response_expected
+        )
 
     @property
     def max_retries(self) -> int:
@@ -429,9 +431,13 @@ def __init__(
         accept_value = 1 if accept else 0
         self._args.append(Int(accept_value, length=2))
 
-    async def send(self, suppress_node_errors: bool = False) -> None:
+    async def send(self, suppress_node_errors=False, no_response_expected=True) -> None:
         """Send request."""
-        if (result := await self._send_request(suppress_node_errors)) is not None:
+        if (
+            result := await self._send_request(
+                suppress_node_errors=False, no_response_expected=True
+            )
+        ) is not None:
             raise MessageError(
                 f"Invalid response message. Received {result.__class__.__name__}, expected no Response"
         )