Update connection-files

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,7 +230,9 @@ 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,
     ) -> PlugwiseResponse | None:
         """Submit request to queue and return response."""
         if not suppress_node_errors:

plugwise_usb/connection/queue.py

@@ -90,6 +90,8 @@ async def submit(self, request: PlugwiseRequest) -> PlugwiseResponse | None:
                 )
             await self._add_request_to_queue(request)
             try:
+                if not request.node_response_expected:
+                    return None
                 response: PlugwiseResponse = await request.response_future()
                 return response
             except (NodeTimeout, StickTimeout) as e:

plugwise_usb/connection/receiver.py

@@ -511,5 +511,4 @@ async def _notify_node_response_subscribers(
             name=f"Postpone subscription task for {node_response.seq_id!r} retry {node_response.retries}",
         )
 
-
 # endregion

plugwise_usb/connection/sender.py

@@ -81,7 +81,8 @@ async def write_request_to_port(self, request: PlugwiseRequest) -> None:
         serialized_data = request.serialize()
         _LOGGER.debug("write_request_to_port | Write %s to port as %s", request, serialized_data)
         self._transport.write(serialized_data)
-        request.start_response_timeout()
+        if request.node_response_expected:
+            request.start_response_timeout()
 
         # Wait for USB stick to accept request
         try:
@@ -118,7 +119,7 @@ async def write_request_to_port(self, request: PlugwiseRequest) -> None:
                         self._receiver.subscribe_to_stick_responses,
                         self._receiver.subscribe_to_node_responses,
                     )
-                _LOGGER.debug("write_request_to_port | request has subscribed : %s", request)
+                    _LOGGER.debug("write_request_to_port | request has subscribed : %s", request)
             elif response.response_type == StickResponseType.TIMEOUT:
                 _LOGGER.warning(
                     "USB-Stick directly responded with communication timeout for %s",