feat: add rtc_config (#67)

Author: theomonnom

livekit/__init__.py

@@ -21,6 +21,9 @@
     ConnectionState,
     DataPacketKind,
     TrackPublishOptions,
+    IceTransportType,
+    ContinualGatheringPolicy,
+    IceServer
 )
 from ._proto.e2ee_pb2 import (EncryptionType, EncryptionState)
 from ._proto.track_pb2 import StreamState, TrackKind, TrackSource
@@ -29,7 +32,7 @@
 from .audio_source import AudioSource
 from .audio_stream import AudioStream
 from .participant import LocalParticipant, Participant, RemoteParticipant
-from .room import ConnectError, Room, RoomOptions
+from .room import ConnectError, Room, RoomOptions, RtcConfiguration
 from .track import (
     LocalAudioTrack,
     LocalVideoTrack,

livekit/room.py

@@ -15,7 +15,7 @@
 import asyncio
 import ctypes
 import logging
-from dataclasses import dataclass
+from dataclasses import dataclass, field
 from typing import Optional
 
 from pyee.asyncio import EventEmitter
@@ -33,11 +33,21 @@
 from .track_publication import RemoteTrackPublication
 
 
+@dataclass
+class RtcConfiguration:
+    ice_transport_type: proto_room.IceTransportType = \
+        proto_room.IceTransportType.TRANSPORT_ALL
+    continual_gathering_policy: proto_room.ContinualGatheringPolicy = \
+        proto_room.ContinualGatheringPolicy.GATHER_CONTINUALLY
+    ice_servers: list[proto_room.IceServer] = field(default_factory=list)
+
+
 @dataclass
 class RoomOptions:
     auto_subscribe: bool = True
     dynacast: bool = False
     e2ee: Optional[E2EEOptions] = None
+    rtc_config: Optional[RtcConfiguration] = None
 
 
 class ConnectError(Exception):
@@ -102,6 +112,14 @@ async def connect(self,
             req.connect.options.e2ee.key_provider_options.ratchet_window_size = \
                 options.e2ee.key_provider_options.ratchet_window_size
 
+        if options.rtc_config:
+            req.connect.options.rtc_config.ice_transport_type = \
+                options.rtc_config.ice_transport_type  # type: ignore
+            req.connect.options.rtc_config.continual_gathering_policy = \
+                options.rtc_config.continual_gathering_policy  # type: ignore
+            req.connect.options.rtc_config.ice_servers.extend(
+                options.rtc_config.ice_servers)
+
         try:
             queue = ffi_client.queue.subscribe(self._loop)
             resp = ffi_client.request(req)