Remove all request/response counter related

Author: bouwew

plugwise_usb/connection/manager.py

@@ -36,10 +36,6 @@ def __init__(self) -> None:
         ] = {}
         self._unsubscribe_stick_events: Callable[[], None] | None = None
 
-    def correct_received_messages(self, correction: int) -> None:
-        """Correct received messages count."""
-        self._receiver.correct_processed_messages(correction)
-
     @property
     def serial_path(self) -> str:
         """Return current port."""

plugwise_usb/connection/queue.py

@@ -153,21 +153,17 @@ async def submit(self, request: PlugwiseRequest) -> PlugwiseResponse | None:
                         "%s, cancel because timeout is expected for NodePingRequests",
                         exc,
                     )
-                    self._stick.correct_received_messages(1)
                 elif request.resend:
                     _LOGGER.debug("%s, retrying", exc)
                 else:
                     _LOGGER.warning("%s, cancel request", exc)  # type: ignore[unreachable]
-                    self._stick.correct_received_messages(1)
             except StickError as exc:
                 _LOGGER.error(exc)
-                self._stick.correct_received_messages(1)
                 raise StickError(
                     f"No response received for {request.__class__.__name__} "
                     + f"to {request.mac_decoded}"
                 ) from exc
             except BaseException as exc:
-                self._stick.correct_received_messages(1)
                 raise StickError(
                     f"No response received for {request.__class__.__name__} "
                     + f"to {request.mac_decoded}"

plugwise_usb/connection/receiver.py

@@ -99,7 +99,6 @@ def __init__(
         self._data_worker_task: Task[None] | None = None
 
         # Message processing
-        self._processed_msgs = 0
         self._message_queue: PriorityQueue[PlugwiseResponse] = PriorityQueue()
         self._last_processed_messages: list[bytes] = []
         self._current_seq_id: bytes | None = None
@@ -138,20 +137,11 @@ def connection_lost(self, exc: Exception | None = None) -> None:
         self._transport = None
         self._connection_state = False
 
-    @property
-    def processed_messages(self) -> int:
-        """Return the number of processed messages."""
-        return self._processed_msgs
-
     @property
     def is_connected(self) -> bool:
         """Return current connection state of the USB-Stick."""
         return self._connection_state
 
-    def correct_processed_messages(self, correction: int) -> None:
-        """Correct the number of processed messages."""
-        self._processed_msgs += correction
-
     def connection_made(self, transport: SerialTransport) -> None:
         """Call when the serial connection to USB-Stick is established."""
         _LOGGER.info("Connection made")
@@ -291,7 +281,6 @@ async def _message_queue_worker(self) -> None:
                 await self._notify_stick_subscribers(response)
             else:
                 await self._notify_node_response_subscribers(response)
-                self._processed_msgs += 1
             self._message_queue.task_done()
             await sleep(0)
         _LOGGER.debug("Message queue worker stopped")

plugwise_usb/connection/sender.py

@@ -38,17 +38,11 @@ def __init__(self, stick_receiver: StickReceiver, transport: Transport) -> None:
         self._loop = get_running_loop()
         self._receiver = stick_receiver
         self._transport = transport
-        self._processed_msgs = 0
         self._stick_response: Future[StickResponse] | None = None
         self._stick_lock = Lock()
         self._current_request: None | PlugwiseRequest = None
         self._unsubscribe_stick_response: Callable[[], None] | None = None
 
-    @property
-    def processed_messages(self) -> int:
-        """Return the number of processed messages."""
-        return self._processed_msgs
-
     async def start(self) -> None:
         """Start the sender."""
         # Subscribe to ACCEPT stick responses, which contain the seq_id we need.
@@ -149,7 +143,6 @@ async def write_request_to_port(self, request: PlugwiseRequest) -> None:
         finally:
             self._stick_response.cancel()
             self._stick_lock.release()
-            self._processed_msgs += 1
 
     async def _process_stick_response(self, response: StickResponse) -> None:
         """Process stick response."""