Revert all no_node_response_expected changes

Author: bouwew

plugwise_usb/connection/queue.py

@@ -94,8 +94,6 @@ 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 exc:

plugwise_usb/connection/sender.py

@@ -81,8 +81,7 @@ 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)
-        if request.node_response_expected:
-            request.start_response_timeout()
+        request.start_response_timeout()
 
         # Wait for USB stick to accept request
         try:

plugwise_usb/messages/requests.py

@@ -68,7 +68,6 @@ def __init__(
         send_fn: Callable[[PlugwiseRequest, bool], Awaitable[PlugwiseResponse | None]]
         | None,
         mac: bytes | None,
-        node_response=True,
     ) -> None:
         """Initialize request message."""
         super().__init__()
@@ -106,11 +105,9 @@ def __init__(
         self._unsubscribe_node_response: Callable[[], None] | None = None
         self._response_timeout: TimerHandle | None = None
         self._response_future: Future[PlugwiseResponse] | None = None
-        if node_response:
-            self._response_future = self._loop.create_future()
+        self._response_future = self._loop.create_future()
         self._waiting_for_response = False
 
-        self.node_response_expected: bool = node_response
 
     def __repr__(self) -> str:
         """Convert request into writable str."""
@@ -176,13 +173,12 @@ async def subscribe_to_response(
         self._unsubscribe_stick_response = await stick_subscription_fn(
             self._process_stick_response, self._seq_id, None
         )
-        if self.node_response_expected:
-            self._unsubscribe_node_response = await node_subscription_fn(
-                self.process_node_response,
-                self._mac,
-                (self._reply_identifier,),
-                self._seq_id,
-            )
+        self._unsubscribe_node_response = await node_subscription_fn(
+            self.process_node_response,
+            self._mac,
+            (self._reply_identifier,),
+            self._seq_id,
+        )
 
     def _unsubscribe_from_stick(self) -> None:
         """Unsubscribe from StickResponse messages."""
@@ -227,8 +223,7 @@ def _response_timeout_expired(self, stick_timeout: bool = False) -> None:
             )
         self._seq_id = None
         self._unsubscribe_from_stick()
-        if self.node_response_expected:
-            self._unsubscribe_from_node()
+        self._unsubscribe_from_node()
         if stick_timeout:
             self._response_future.set_exception(
                 StickTimeout(f"USB-stick responded with time out to {self}")
@@ -244,8 +239,7 @@ def assign_error(self, error: BaseException) -> None:
         """Assign error for this request."""
         self.stop_response_timeout()
         self._unsubscribe_from_stick()
-        if self.node_response_expected:
-            self._unsubscribe_from_node()
+        self._unsubscribe_from_node()
         if self._response_future.done():
             return
         self._waiting_for_response = False
@@ -274,8 +268,7 @@ async def process_node_response(self, response: PlugwiseResponse) -> bool:
         self._response = copy(response)
         self.stop_response_timeout()
         self._unsubscribe_from_stick()
-        if self.node_response_expected:
-            self._unsubscribe_from_node()
+        self._unsubscribe_from_node()
         if self._send_counter > 1:
             _LOGGER.debug(
                 "Received %s after %s retries as reply to %s",