ruff check --fix

Author: ArnoutD

plugwise_usb/__init__.py

@@ -10,7 +10,7 @@
 from collections.abc import Callable, Coroutine
 from functools import wraps
 import logging
-from typing import Any, TypeVar, cast, Final
+from typing import Any, Final, TypeVar, cast
 
 from .api import NodeEvent, PlugwiseNode, StickEvent
 from .connection import StickController
@@ -295,7 +295,7 @@ async def connect(self, port: str | None = None) -> None:
                 "Unable to connect. " +
                 "Path to USB-Stick is not defined, set port property first"
             )
-        
+
         await self._controller.connect_to_stick(
             self._port,
         )

plugwise_usb/connection/manager.py

@@ -38,9 +38,24 @@ def __init__(self) -> None:
 
     @property
     def queue_depth(self) -> int:
+        """Calculate and return the current depth of the message queue.
+
+        Returns:
+            int: The number of expected responses that have not yet been processed.
+
+        """
         return self._sender.expected_responses - self._receiver.processed_messages
 
     def correct_received_messages(self, correction: int) -> None:
+        """Adjusts the count of received messages by applying a correction value.
+
+        Args:
+            correction (int): The number to adjust the processed messages count by. Positive values increase the count, negative values decrease it.
+
+        Returns:
+            None
+
+        """
         self._receiver.correct_processed_messages(correction)
 
     @property

plugwise_usb/connection/queue.py

@@ -76,7 +76,6 @@ async def stop(self) -> None:
 
     async def submit(self, request: PlugwiseRequest) -> PlugwiseResponse | None:
         """Add request to queue and return the received node-response when applicable.
-        
         Raises an error when something fails.
         """
         if request.waiting_for_response:

plugwise_usb/connection/sender.py

@@ -48,7 +48,7 @@ def __init__(self, stick_receiver: StickReceiver, transport: Transport) -> None:
     def expected_responses(self) -> int:
         """Return the number of processed messages."""
         return self._expected_responses
-    
+
     async def start(self) -> None:
         """Start the sender."""
         # Subscribe to ACCEPT stick responses, which contain the seq_id we need.

plugwise_usb/constants.py

@@ -31,7 +31,7 @@
 
 # Max timeout in seconds
 # Stick responds with timeout messages within 10s.
-STICK_TIME_OUT: Final = 11 
+STICK_TIME_OUT: Final = 11
 # In bigger networks a response from a Node could take up a while, so lets use 15 seconds.
 NODE_TIME_OUT: Final = 15
 

plugwise_usb/helpers/cache.py

@@ -59,7 +59,7 @@ async def initialize_cache(self, create_root_folder: bool = False) -> None:
             cache_dir = self._get_writable_os_dir()
         await makedirs(cache_dir, exist_ok=True)
         self._cache_path = cache_dir
-        
+
         self._cache_file = os_path_join(self._cache_path, self._file_name)
         self._cache_file_exists = await ospath.exists(self._cache_file)
         self._initialized = True

plugwise_usb/messages/properties.py

@@ -391,7 +391,7 @@ def serialize(self) -> bytes:
     def deserialize(self, val: bytes) -> None:
         """Convert data into integer value based on log address formatted data."""
         if val == b"00000000":
-            self._value = int(0)
+            self._value = 0
             return
         Int.deserialize(self, val)
         self._value = (self.value - LOGADDR_OFFSET) // 32

plugwise_usb/messages/requests.py

@@ -1264,7 +1264,7 @@ class CircleMeasureIntervalRequest(PlugwiseRequest):
 
     FIXME: Make sure production interval is a multiply of consumption !!
 
-    Response message: NodeResponse with ack-type POWER_LOG_INTERVAL_ACCEPTED 
+    Response message: NodeResponse with ack-type POWER_LOG_INTERVAL_ACCEPTED
     """
 
     _identifier = b"0057"

plugwise_usb/network/__init__.py

@@ -15,8 +15,8 @@
 from ..constants import UTF8
 from ..exceptions import CacheError, MessageError, NodeError, StickError, StickTimeout
 from ..messages.requests import (
-    CirclePlusAllowJoiningRequest,
     CircleMeasureIntervalRequest,
+    CirclePlusAllowJoiningRequest,
     NodePingRequest,
 )
 from ..messages.responses import (

plugwise_usb/nodes/circle.py

@@ -5,10 +5,10 @@
 from asyncio import Task, create_task, gather
 from collections.abc import Awaitable, Callable
 from dataclasses import replace
-from math import floor
 from datetime import UTC, datetime
 from functools import wraps
 import logging
+from math import floor
 from typing import Any, TypeVar, cast
 
 from ..api import (
@@ -447,7 +447,7 @@ async def get_missing_energy_logs(self) -> None:
                 "Start with initial energy request for the last 10 log addresses for node %s.",
                 self._mac_in_str,
             )
-            
+
             total_addresses = int(floor(datetime.now(tz=UTC).hour / 4) + 1)
             log_address = self._current_log_address
             while total_addresses > 0: