new formatting rules

Author: dudanov

examples/discovering.py

@@ -8,7 +8,9 @@
 
 async def run():
     async for dev, machine_type in discover_ftms_devices():
-        print(f"Found {machine_type.name}: name: {dev.name}, address: {dev.address}")
+        print(
+            f"Found {machine_type.name}: name: {dev.name}, address: {dev.address}"
+        )
 
 
 asyncio.run(run())

src/pyftms/client/__init__.py

@@ -154,7 +154,9 @@ async def get_client_from_address(
     - `FitnessMachine` instance if device found successfully.
     """
 
-    async for dev, machine_type in discover_ftms_devices(scan_timeout, kwargs=kwargs):
+    async for dev, machine_type in discover_ftms_devices(
+        scan_timeout, kwargs=kwargs
+    ):
         if dev.address.lower() == address.lower():
             return get_client(
                 dev,

src/pyftms/client/backends/controller.py

@@ -22,7 +22,13 @@
     TrainingStatusFlags,
     TrainingStatusModel,
 )
-from ..const import CONTROL_POINT_UUID, PAUSE, STATUS_UUID, STOP, TRAINING_STATUS_UUID
+from ..const import (
+    CONTROL_POINT_UUID,
+    PAUSE,
+    STATUS_UUID,
+    STOP,
+    TRAINING_STATUS_UUID,
+)
 from .event import (
     ControlEvent,
     FtmsCallback,
@@ -62,7 +68,11 @@ def _simple_status_events(m: MachineStatusModel) -> ControlEvent | None:
             return ControlEvent(event_id="reset", event_source="other")
 
         case MachineStatusCode.STOP_PAUSE:
-            value = STOP if StopPauseCode(m.stop_pause) == StopPauseCode.STOP else PAUSE
+            value = (
+                STOP
+                if StopPauseCode(m.stop_pause) == StopPauseCode.STOP
+                else PAUSE
+            )
             return ControlEvent(event_id=value, event_source="user")
 
         case MachineStatusCode.STOP_SAFETY:
@@ -79,7 +89,11 @@ def _simple_control_events(m: ControlModel) -> ControlEvent | None:
             return ControlEvent(event_id="reset", event_source="callback")
 
         case ControlCode.STOP_PAUSE:
-            value = STOP if StopPauseCode(m.stop_pause) == StopPauseCode.STOP else PAUSE
+            value = (
+                STOP
+                if StopPauseCode(m.stop_pause) == StopPauseCode.STOP
+                else PAUSE
+            )
             return ControlEvent(event_id=value, event_source="callback")
 
         case ControlCode.START_RESUME:
@@ -216,7 +230,9 @@ async def write_command(
 
         return ResultCode.SUCCESS
 
-    def _on_machine_status(self, c: BleakGATTCharacteristic, data: bytearray) -> None:
+    def _on_machine_status(
+        self, c: BleakGATTCharacteristic, data: bytearray
+    ) -> None:
         """Machine Status notification callback."""
         bio = io.BytesIO(data)
         status = MachineStatusModel._deserialize(bio)
@@ -241,7 +257,9 @@ def _on_machine_status(self, c: BleakGATTCharacteristic, data: bytearray) -> Non
 
         self._cb(event)
 
-    def _on_training_status(self, c: BleakGATTCharacteristic, data: bytearray) -> None:
+    def _on_training_status(
+        self, c: BleakGATTCharacteristic, data: bytearray
+    ) -> None:
         """Training Status notification callback."""
         bio = io.BytesIO(data)
         status = TrainingStatusModel._deserialize(bio)
@@ -250,7 +268,9 @@ def _on_training_status(self, c: BleakGATTCharacteristic, data: bytearray) -> No
 
         if TrainingStatusFlags.STRING_PRESENT in status.flags:
             if b := bio.read():
-                status_data["training_status_string"] = b.decode(encoding="utf-8")
+                status_data["training_status_string"] = b.decode(
+                    encoding="utf-8"
+                )
 
         event = UpdateEvent(event_id="update", event_data=status_data)
 

src/pyftms/client/backends/updater.py

@@ -17,7 +17,9 @@
 class DataUpdater:
     _serializer: ModelSerializer[RealtimeData]
 
-    def __init__(self, model: type[RealtimeData], callback: FtmsCallback) -> None:
+    def __init__(
+        self, model: type[RealtimeData], callback: FtmsCallback
+    ) -> None:
         self._cb = callback
         self._serializer = get_serializer(model)
         self._prev: dict[str, Any] = {}

src/pyftms/client/client.py

@@ -286,7 +286,9 @@ async def _connect(self) -> None:
 
     # COMMANDS
 
-    async def _write_command(self, code: ControlCode | None = None, *args, **kwargs):
+    async def _write_command(
+        self, code: ControlCode | None = None, *args, **kwargs
+    ):
         if self._need_connect:
             await self._connect()
             return await self._controller.write_command(

src/pyftms/client/manager.py

@@ -43,7 +43,9 @@ def _on_event(self, e: FtmsEvents) -> None:
         """Real-time training data update handler."""
         if e.event_id == "update":
             self._properties |= e.event_data
-            self._live_properties.update(k for k, v in e.event_data.items() if v)
+            self._live_properties.update(
+                k for k, v in e.event_data.items() if v
+            )
         elif e.event_id == "setup":
             self._settings |= e.event_data
 

src/pyftms/client/properties/features.py

@@ -155,7 +155,9 @@ async def _read_range(
 async def read_features(
     cli: BleakClient,
     mt: MachineType,
-) -> tuple[MachineFeatures, MachineSettings, MappingProxyType[str, SettingRange]]:
+) -> tuple[
+    MachineFeatures, MachineSettings, MappingProxyType[str, SettingRange]
+]:
     _LOGGER.debug("Reading features and settings...")
 
     if (c := cli.services.get_characteristic(FEATURE_UUID)) is None:

src/pyftms/client/properties/machine_type.py

@@ -48,7 +48,9 @@ class MachineType(Flag):
     """Indoor Bike Machine."""
 
 
-def get_machine_type_from_service_data(adv_data: AdvertisementData) -> MachineType:
+def get_machine_type_from_service_data(
+    adv_data: AdvertisementData,
+) -> MachineType:
     """Returns fitness machine type from Bluetooth advertisement data.
 
     Parameters:

src/pyftms/models/__init__.py

@@ -1,8 +1,17 @@
 # Copyright 2024, Sergey Dudanov
 # SPDX-License-Identifier: Apache-2.0
 
-from .common import CodeSwitchModel, IndoorBikeSimulationParameters, StopPauseCode
-from .control_point import ControlCode, ControlIndicateModel, ControlModel, ResultCode
+from .common import (
+    CodeSwitchModel,
+    IndoorBikeSimulationParameters,
+    StopPauseCode,
+)
+from .control_point import (
+    ControlCode,
+    ControlIndicateModel,
+    ControlModel,
+    ResultCode,
+)
 from .machine_status import MachineStatusCode, MachineStatusModel
 from .realtime_data import (
     CrossTrainerData,
@@ -11,7 +20,11 @@
     RowerData,
     TreadmillData,
 )
-from .spin_down import SpinDownControlCode, SpinDownSpeedData, SpinDownStatusCode
+from .spin_down import (
+    SpinDownControlCode,
+    SpinDownSpeedData,
+    SpinDownStatusCode,
+)
 from .training_status import (
     TrainingStatusCode,
     TrainingStatusFlags,

src/pyftms/models/realtime_data/cross_trainer.py

@@ -168,5 +168,9 @@ class CrossTrainerData(RealtimeSpeedData):
     """Movement Direction"""
 
     def __post_init__(self, mask: int):
-        md = MovementDirection.BACKWARD if mask & 0x8000 else MovementDirection.FORWARD
+        md = (
+            MovementDirection.BACKWARD
+            if mask & 0x8000
+            else MovementDirection.FORWARD
+        )
         object.__setattr__(self, "movement_direction", md)