Handle response-less requests, clean up

Author: bouwew

plugwise_usb/connection/__init__.py

@@ -214,7 +214,7 @@ async def get_node_details(
                 self.send, bytes(mac, UTF8), retries=1
             )
             try:
-                ping_response = await ping_request.send(suppress_node_errors=True)
+                ping_response = await ping_request.send()
             except StickError:
                 return (None, None)
             if ping_response is None:
@@ -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: bool
+    ) -> 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: