Force relay client configuration (#155)

* Update protocol submodule

* Force relay configuration

* tests

@@ -201,6 +201,14 @@ internal constructor(
                     PeerConnection.ContinualGatheringPolicy.GATHER_CONTINUALLY
                     PeerConnection.ContinualGatheringPolicy.GATHER_CONTINUALLY
             }
             }
 
 
+        if (joinResponse.hasClientConfiguration()) {
+            val clientConfig = joinResponse.clientConfiguration
+
+            if (clientConfig.forceRelay == LivekitModels.ClientConfigSetting.ENABLED) {
+                rtcConfig.iceTransportsType = PeerConnection.IceTransportsType.RELAY
+            }
+        }
+
         _publisher?.close()
         _publisher?.close()
         _publisher = pctFactory.create(
         _publisher = pctFactory.create(
             rtcConfig,
             rtcConfig,

@@ -7,7 +7,8 @@ private class MockNativePeerConnectionFactory : NativePeerConnectionFactory {
 }
 }
 
 
 class MockPeerConnection(
 class MockPeerConnection(
-    val observer: PeerConnection.Observer?
+    val rtcConfig: RTCConfiguration,
+    val observer: Observer?
 ) : PeerConnection(MockNativePeerConnectionFactory()) {
 ) : PeerConnection(MockNativePeerConnectionFactory()) {
 
 
     private var closed = false
     private var closed = false

@@ -5,8 +5,10 @@ import io.livekit.android.mock.MockPeerConnection
 import io.livekit.android.util.toOkioByteString
 import io.livekit.android.util.toOkioByteString
 import io.livekit.android.util.toPBByteString
 import io.livekit.android.util.toPBByteString
 import kotlinx.coroutines.ExperimentalCoroutinesApi
 import kotlinx.coroutines.ExperimentalCoroutinesApi
+import livekit.LivekitModels
 import livekit.LivekitRtc
 import livekit.LivekitRtc
 import org.junit.Assert
 import org.junit.Assert
+import org.junit.Assert.assertEquals
 import org.junit.Before
 import org.junit.Before
 import org.junit.Test
 import org.junit.Test
 import org.junit.runner.RunWith
 import org.junit.runner.RunWith
@@ -95,4 +97,21 @@ class RTCEngineMockE2ETest : MockE2ETest() {
         Assert.assertNotEquals(oldToken, newToken)
         Assert.assertNotEquals(oldToken, newToken)
         Assert.assertEquals(SignalClientTest.REFRESH_TOKEN.refreshToken, newToken)
         Assert.assertEquals(SignalClientTest.REFRESH_TOKEN.refreshToken, newToken)
     }
     }
+
+    @Test
+    fun relayConfiguration() = runTest {
+        connect(with(SignalClientTest.JOIN.toBuilder()) {
+            join = with(join.toBuilder()) {
+                clientConfiguration = with(LivekitModels.ClientConfiguration.newBuilder()) {
+                    forceRelay = LivekitModels.ClientConfigSetting.ENABLED
+                    build()
+                }
+                build()
+            }
+            build()
+        })
+
+        val pubPeerConnection = rtcEngine.subscriber.peerConnection as MockPeerConnection
+        assertEquals(PeerConnection.IceTransportsType.RELAY, pubPeerConnection.rtcConfig.iceTransportsType)
+    }
 }
 }

@@ -4,11 +4,11 @@ import io.livekit.android.mock.MockPeerConnection
 
 
 class MockPeerConnectionFactory : PeerConnectionFactory(1L) {
 class MockPeerConnectionFactory : PeerConnectionFactory(1L) {
     override fun createPeerConnectionInternal(
     override fun createPeerConnectionInternal(
-        rtcConfig: PeerConnection.RTCConfiguration?,
+        rtcConfig: PeerConnection.RTCConfiguration,
         constraints: MediaConstraints?,
         constraints: MediaConstraints?,
         observer: PeerConnection.Observer?,
         observer: PeerConnection.Observer?,
         sslCertificateVerifier: SSLCertificateVerifier?
         sslCertificateVerifier: SSLCertificateVerifier?
     ): PeerConnection {
     ): PeerConnection {
-        return MockPeerConnection(observer)
+        return MockPeerConnection(rtcConfig, observer)
     }
     }
 }
 }

--Subproject commit 6ec04e9ca47ebad2f3426be543fb6cbeef58c2b5
++Subproject commit 3f47968225995df268658982f311d5f3942aa223