Fast track publication support (#612)

* protocol update * Fast track publication support
livekit · Feb 26, 2025 · f683209 · f683209
1 parent b712807
commit f683209
Show file tree

Hide file tree

Showing 12 changed files with 193 additions and 91 deletions.
diff --git a/.changeset/six-flowers-hunt.md b/.changeset/six-flowers-hunt.md
@@ -0,0 +1,5 @@
+---
+"client-sdk-android": minor
+---
+
+Fast track publication support
diff --git a/.idea/inspectionProfiles/Project_Default.xml b/.idea/inspectionProfiles/Project_Default.xml
diff --git a/.idea/scopes/Library_Projects.xml b/.idea/scopes/Library_Projects.xml
diff --git a/livekit-android-sdk/src/main/java/io/livekit/android/room/PeerConnectionTransport.kt b/livekit-android-sdk/src/main/java/io/livekit/android/room/PeerConnectionTransport.kt
@@ -1,5 +1,5 @@
 /*
- * Copyright 2023-2024 LiveKit, Inc.
+ * Copyright 2023-2025 LiveKit, Inc.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -131,7 +131,7 @@ constructor(
         return result
     }
 
-    val negotiate = debounce<MediaConstraints?, Unit>(100, coroutineScope) {
+    val negotiate = debounce<MediaConstraints?, Unit>(20, coroutineScope) {
         if (it != null) {
             createAndSendOffer(it)
         } else {

diff --git a/livekit-android-sdk/src/main/java/io/livekit/android/room/RTCEngine.kt b/livekit-android-sdk/src/main/java/io/livekit/android/room/RTCEngine.kt
@@ -156,7 +156,7 @@ internal constructor(
     private val publisherObserver = PublisherTransportObserver(this, client)
     private val subscriberObserver = SubscriberTransportObserver(this, client)
 
-    private var publisher: PeerConnectionTransport? = null
+    internal var publisher: PeerConnectionTransport? = null
     private var subscriber: PeerConnectionTransport? = null
 
     private var reliableDataChannel: DataChannel? = null
@@ -214,7 +214,7 @@ internal constructor(
         configure(joinResponse, options)
 
         // create offer
-        if (!isSubscriberPrimary) {
+        if (!isSubscriberPrimary || joinResponse.fastPublish) {
             negotiatePublisher()
         }
         client.onReadyForResponses()
@@ -1082,6 +1082,10 @@ internal constructor(
             LivekitModels.DataPacket.ValueCase.STREAM_CHUNK -> {
                 // TODO
             }
+
+            LivekitModels.DataPacket.ValueCase.STREAM_TRAILER -> {
+                // TODO
+            }
         }
     }
 

diff --git a/livekit-android-sdk/src/main/java/io/livekit/android/room/Room.kt b/livekit-android-sdk/src/main/java/io/livekit/android/room/Room.kt
@@ -585,6 +585,7 @@ constructor(
         }
 
         localParticipant.updateFromInfo(response.participant)
+        localParticipant.setEnabledPublishCodecs(response.enabledPublishCodecsList)
 
         if (response.otherParticipantsList.isNotEmpty()) {
             response.otherParticipantsList.forEach { info ->