ruff

Author: typester

livekit-rtc/livekit/rtc/audio_filter.py

@@ -6,21 +6,21 @@
 
 class AudioFilter:
     def __init__(
-        self,
-        path: str,
-        url: str,
-        token: str,
-        dependencies: list[str] = None
+        self, path: str, url: str, token: str, dependencies: list[str] = None
     ) -> None:
         self._path = path
 
         req = proto_ffi.FfiRequest()
         req.load_audio_filter_plugin.plugin_path = path
-        req.load_audio_filter_plugin.dependencies[:] = dependencies if dependencies is not None else []
-        req.load_audio_filter_plugin.options = json.dumps({
-            "url": url,
-            "token": token,
-        })
+        req.load_audio_filter_plugin.dependencies[:] = (
+            dependencies if dependencies is not None else []
+        )
+        req.load_audio_filter_plugin.options = json.dumps(
+            {
+                "url": url,
+                "token": token,
+            }
+        )
 
         resp = FfiClient.instance.request(req)
 

livekit-rtc/livekit/rtc/room.py

@@ -127,7 +127,11 @@ def __init__(self, message: str):
 
 
 class Room(EventEmitter[EventTypes]):
-    def __init__(self, loop: Optional[asyncio.AbstractEventLoop] = None, filters: Optional[List[Any]] = None) -> None:
+    def __init__(
+        self,
+        loop: Optional[asyncio.AbstractEventLoop] = None,
+        filters: Optional[List[Any]] = None,
+    ) -> None:
         """Initializes a new Room instance.
 
         Parameters:
@@ -375,15 +379,15 @@ def on_participant_connected(participant):
             )
 
         for f in self._filters:
-            if hasattr(f, 'dependencies_path'):
+            if hasattr(f, "dependencies_path"):
                 deps = f.dependencies_path() or []
             else:
                 deps = []
             self._filter_instances[f] = AudioFilter(
-                path = f.plugin_path(),
-                url = url,
-                token = token,
-                dependencies = deps,
+                path=f.plugin_path(),
+                url=url,
+                token=token,
+                dependencies=deps,
             )
 
         # subscribe before connecting so we don't miss any events
@@ -421,7 +425,6 @@ def on_participant_connected(participant):
                 publication = RemoteTrackPublication(owned_publication_info)
                 rp._track_publications[publication.sid] = publication
 
-
         # start listening to room events
         self._task = self._loop.create_task(self._listen_task())
 
@@ -573,7 +576,7 @@ def _on_room_event(self, event: proto_room.RoomEvent):
                 )
             elif track_info.kind == TrackKind.KIND_AUDIO:
                 remote_audio_track = RemoteAudioTrack(owned_track_info)
-                remote_audio_track._set_room(self) # set room ref for audio filter
+                remote_audio_track._set_room(self)  # set room ref for audio filter
                 rpublication.track = remote_audio_track
                 self.emit(
                     "track_subscribed", remote_audio_track, rpublication, rparticipant