chore: ruff format

Author: zarcell

src/flockwave/server/command_handlers/color.py

@@ -65,12 +65,10 @@ async def _color_command_handler(
         return "Color override turned off"
 
 
-def create_color_command_handler() -> (
-    Callable[
-        [UAVDriver, UAV, Optional[Union[str, int]], Optional[int], Optional[int]],
-        Awaitable[str],
-    ]
-):
+def create_color_command_handler() -> Callable[
+    [UAVDriver, UAV, Optional[Union[str, int]], Optional[int], Optional[int]],
+    Awaitable[str],
+]:
     """Creates a generic async command handler function that allows the user to
     set the color of the LED lights on the UAV, assuming that the UAV
     has an async or sync method named `set_led_color()`.

src/flockwave/server/message_hub.py

@@ -242,9 +242,9 @@ async def broadcast_message(self, message: FlockwaveNotification) -> Request:
             the request object that identifies this message in the outbound
             message queue. It can be used to wait until the message is delivered
         """
-        assert isinstance(
-            message, FlockwaveNotification
-        ), "only notifications may be broadcast"
+        assert isinstance(message, FlockwaveNotification), (
+            "only notifications may be broadcast"
+        )
 
         request = Request(message)
         await self._queue_tx.send(request)
@@ -379,9 +379,9 @@ def enqueue_broadcast_message(self, message: FlockwaveNotification) -> None:
         Parameters:
             message: the notification to enqueue
         """
-        assert isinstance(
-            message, FlockwaveNotification
-        ), "only notifications may be broadcast"
+        assert isinstance(message, FlockwaveNotification), (
+            "only notifications may be broadcast"
+        )
 
         # Don't return the request here because it is not guaranteed that it
         # ends up in the queue; it may be dropped
@@ -423,9 +423,9 @@ def enqueue_message(
                 message, in_response_to=in_response_to
             )
         if to is None:
-            assert isinstance(
-                message, FlockwaveNotification
-            ), "broadcast messages cannot be sent in response to a particular message"
+            assert isinstance(message, FlockwaveNotification), (
+                "broadcast messages cannot be sent in response to a particular message"
+            )
             return self.enqueue_broadcast_message(message)
         else:
             # Don't return the request here because it is not guaranteed that it
@@ -549,12 +549,12 @@ def _commit_broadcast_methods(
         """Calculates the list of methods to call when the message hub
         wishes to broadcast a message to all the connected clients.
         """
-        assert (
-            self._client_registry is not None
-        ), "message hub does not have a client registry yet"
-        assert (
-            self._channel_type_registry is not None
-        ), "message hub does not have a channel type registry yet"
+        assert self._client_registry is not None, (
+            "message hub does not have a client registry yet"
+        )
+        assert self._channel_type_registry is not None, (
+            "message hub does not have a channel type registry yet"
+        )
 
         result = []
         clients_for = self._client_registry.client_ids_for_channel_type
@@ -832,9 +832,9 @@ async def send_message(
             )
 
         if to is None:
-            assert isinstance(
-                message, FlockwaveNotification
-            ), "broadcast messages cannot be sent in response to a particular message"
+            assert isinstance(message, FlockwaveNotification), (
+                "broadcast messages cannot be sent in response to a particular message"
+            )
             return await self.broadcast_message(message)
         else:
             request = Request(message, to=to, in_response_to=in_response_to)
@@ -1068,9 +1068,9 @@ async def _send_message(
         in_response_to: Optional[FlockwaveMessage] = None,
         done: Optional[Callable[[], None]] = None,
     ):
-        assert (
-            self._client_registry is not None
-        ), "message hub does not have a client registry yet"
+        assert self._client_registry is not None, (
+            "message hub does not have a client registry yet"
+        )
 
         if not isinstance(to, Client):
             try:

src/flockwave/server/model/devices.py

@@ -338,7 +338,7 @@ def _add_child(self, id: str, node: C) -> C:
             self.children = {}
         if id in self.children:
             raise ValueError(
-                "another child node already exists with " "ID={0!r}".format(id)
+                "another child node already exists with ID={0!r}".format(id)
             )
         self.children[id] = node
 

src/flockwave/server/registries/channels.py

@@ -140,9 +140,9 @@ def create_channel_for(self, channel_id):
                 type.
         """
         result = self._entries[channel_id].factory()
-        assert isinstance(
-            result, CommunicationChannel
-        ), "communication channel factory did not return a CommunicationChannel"
+        assert isinstance(result, CommunicationChannel), (
+            "communication channel factory did not return a CommunicationChannel"
+        )
         return result
 
     @property

src/flockwave/server/registries/connections.py

@@ -80,8 +80,9 @@ def add(
         """
         if name in self:
             raise KeyError(
-                "another connection is already registered "
-                "with this name: {0!r}".format(name)
+                "another connection is already registered with this name: {0!r}".format(
+                    name
+                )
             )
 
         purpose = purpose if purpose is not None else ConnectionPurpose.other