SDK will now notify the coordinator which SFUs it already failed to join during a migration or reconnect

demo-app/src/main/kotlin/io/getstream/video/android/ui/menu/MenuDefinitions.kt

@@ -82,6 +82,7 @@ fun defaultStreamMenu(
     onDeviceSelected: (StreamAudioDevice) -> Unit,
     onSfuRejoinClick: () -> Unit,
     onSfuFastReconnectClick: () -> Unit,
+    onSimulateSfuFullClick: () -> Unit,
     onSelectScaleType: (VideoScalingType) -> Unit,
     availableDevices: List<StreamAudioDevice>,
     loadRecordings: suspend () -> List<MenuItem>,
@@ -161,6 +162,7 @@ fun defaultStreamMenu(
                     onSwitchSfuClick,
                     onSfuRejoinClick,
                     onSfuFastReconnectClick,
+                    onSimulateSfuFullClick,
                     onSelectScaleType,
                     loadRecordings,
                     onShowFeedback,
@@ -234,6 +236,7 @@ fun reconnectMenu(
     onSwitchSfuClick: () -> Unit,
     onSfuRejoinClick: () -> Unit,
     onSfuFastReconnectClick: () -> Unit,
+    onSimulateSfuFullClick: () -> Unit,
 ) = listOf(
     ActionMenuItem(
         title = "Publisher - ICE restart",
@@ -260,6 +263,11 @@ fun reconnectMenu(
         icon = Icons.Default.RestartAlt,
         action = onSfuFastReconnectClick,
     ),
+    ActionMenuItem(
+        title = "Simulate SFU Full (700)",
+        icon = Icons.Default.Feedback,
+        action = onSimulateSfuFullClick,
+    ),
 )
 
 fun scaleTypeMenu(onSelectScaleType: (VideoScalingType) -> Unit): List<MenuItem> = listOf(
@@ -337,6 +345,7 @@ fun debugSubmenu(
     onSwitchSfuClick: () -> Unit,
     onSfuRejoinClick: () -> Unit,
     onSfuFastReconnectClick: () -> Unit,
+    onSimulateSfuFullClick: () -> Unit,
     onSelectScaleType: (VideoScalingType) -> Unit,
     loadRecordings: suspend () -> List<MenuItem>,
     onShowFeedback: () -> Unit,
@@ -459,6 +468,7 @@ fun debugSubmenu(
             onSwitchSfuClick,
             onSfuRejoinClick,
             onSfuFastReconnectClick,
+            onSimulateSfuFullClick,
         ),
     ),
 )

demo-app/src/main/kotlin/io/getstream/video/android/ui/menu/SettingsMenu.kt

@@ -163,6 +163,12 @@ internal fun SettingsMenu(
         Toast.makeText(context, "Fast Reconnect SFU", Toast.LENGTH_SHORT).show()
     }
 
+    val onSimulateSfuFullClick: () -> Unit = {
+        call.debug.simulateSfuFull()
+        onDismissed.invoke()
+        Toast.makeText(context, "Simulating SFU Full (700) → migrate", Toast.LENGTH_SHORT).show()
+    }
+
     val codecInfos = remember {
         MediaCodecList(MediaCodecList.ALL_CODECS).codecInfos.filter {
             it.name.contains("encoder") && it.supportedTypes.firstOrNull {
@@ -341,6 +347,7 @@ internal fun SettingsMenu(
                 onToggleIncomingVideoEnabled = { onToggleIncomingVideoVisibility(it) },
                 onSfuRejoinClick = onSfuRejoinClick,
                 onSfuFastReconnectClick = onSfuFastReconnectClick,
+                onSimulateSfuFullClick = onSimulateSfuFullClick,
                 onSelectScaleType = onSelectScaleType,
                 loadRecordings = onLoadRecordings,
                 onToggleClosedCaptions = onClosedCaptionsToggle,
@@ -407,6 +414,7 @@ private fun SettingsMenuPreview() {
                 onRestartPublisherIceClick = { },
                 onSfuRejoinClick = { },
                 onSfuFastReconnectClick = {},
+                onSimulateSfuFullClick = {},
                 onSwitchSfuClick = { },
                 availableDevices = emptyList(),
                 onDeviceSelected = {},

demo-app/src/main/kotlin/io/getstream/video/android/ui/menu/base/DynamicMenu.kt

@@ -277,6 +277,7 @@ private fun DynamicMenuPreview() {
                 onRestartPublisherIceClick = { },
                 onSfuRejoinClick = { },
                 onSfuFastReconnectClick = {},
+                onSimulateSfuFullClick = {},
                 onSwitchSfuClick = { },
                 availableDevices = emptyList(),
                 onDeviceSelected = {},
@@ -315,6 +316,7 @@ private fun DynamicMenuDebugOptionPreview() {
                 onRestartPublisherIceClick = { },
                 onSfuRejoinClick = { },
                 onSfuFastReconnectClick = {},
+                onSimulateSfuFullClick = {},
                 onSwitchSfuClick = { },
                 availableDevices = emptyList(),
                 onDeviceSelected = {},
@@ -348,6 +350,7 @@ private fun DynamicMenuDebugPreview() {
                 onCodecSelected = {},
                 onSfuRejoinClick = { },
                 onSfuFastReconnectClick = {},
+                onSimulateSfuFullClick = {},
                 onRestartPublisherIceClick = { },
                 onRestartSubscriberIceClick = { },
                 onToggleAudioFilterClick = { },
@@ -377,6 +380,7 @@ private fun DynamicMenuReconnectPreview() {
             items = reconnectMenu(
                 onSfuRejoinClick = { },
                 onSfuFastReconnectClick = {},
+                onSimulateSfuFullClick = {},
                 onRestartPublisherIceClick = { },
                 onRestartSubscriberIceClick = { },
                 onSwitchSfuClick = { },

stream-video-android-core/api/stream-video-android-core.api

@@ -3890,24 +3890,26 @@ public final class io/getstream/android/video/generated/models/IngressVideoLayer
 }
 
 public final class io/getstream/android/video/generated/models/JoinCallRequest {
-	public fun <init> (Ljava/lang/String;Ljava/lang/Boolean;Ljava/lang/Integer;Ljava/lang/String;Ljava/lang/Boolean;Ljava/lang/Boolean;Ljava/lang/Boolean;Lio/getstream/android/video/generated/models/CallRequest;)V
-	public synthetic fun <init> (Ljava/lang/String;Ljava/lang/Boolean;Ljava/lang/Integer;Ljava/lang/String;Ljava/lang/Boolean;Ljava/lang/Boolean;Ljava/lang/Boolean;Lio/getstream/android/video/generated/models/CallRequest;ILkotlin/jvm/internal/DefaultConstructorMarker;)V
+	public fun <init> (Ljava/lang/String;Ljava/lang/Boolean;Ljava/lang/Integer;Ljava/lang/String;Ljava/util/List;Ljava/lang/Boolean;Ljava/lang/Boolean;Ljava/lang/Boolean;Lio/getstream/android/video/generated/models/CallRequest;)V
+	public synthetic fun <init> (Ljava/lang/String;Ljava/lang/Boolean;Ljava/lang/Integer;Ljava/lang/String;Ljava/util/List;Ljava/lang/Boolean;Ljava/lang/Boolean;Ljava/lang/Boolean;Lio/getstream/android/video/generated/models/CallRequest;ILkotlin/jvm/internal/DefaultConstructorMarker;)V
 	public final fun component1 ()Ljava/lang/String;
 	public final fun component2 ()Ljava/lang/Boolean;
 	public final fun component3 ()Ljava/lang/Integer;
 	public final fun component4 ()Ljava/lang/String;
-	public final fun component5 ()Ljava/lang/Boolean;
+	public final fun component5 ()Ljava/util/List;
 	public final fun component6 ()Ljava/lang/Boolean;
 	public final fun component7 ()Ljava/lang/Boolean;
-	public final fun component8 ()Lio/getstream/android/video/generated/models/CallRequest;
-	public final fun copy (Ljava/lang/String;Ljava/lang/Boolean;Ljava/lang/Integer;Ljava/lang/String;Ljava/lang/Boolean;Ljava/lang/Boolean;Ljava/lang/Boolean;Lio/getstream/android/video/generated/models/CallRequest;)Lio/getstream/android/video/generated/models/JoinCallRequest;
-	public static synthetic fun copy$default (Lio/getstream/android/video/generated/models/JoinCallRequest;Ljava/lang/String;Ljava/lang/Boolean;Ljava/lang/Integer;Ljava/lang/String;Ljava/lang/Boolean;Ljava/lang/Boolean;Ljava/lang/Boolean;Lio/getstream/android/video/generated/models/CallRequest;ILjava/lang/Object;)Lio/getstream/android/video/generated/models/JoinCallRequest;
+	public final fun component8 ()Ljava/lang/Boolean;
+	public final fun component9 ()Lio/getstream/android/video/generated/models/CallRequest;
+	public final fun copy (Ljava/lang/String;Ljava/lang/Boolean;Ljava/lang/Integer;Ljava/lang/String;Ljava/util/List;Ljava/lang/Boolean;Ljava/lang/Boolean;Ljava/lang/Boolean;Lio/getstream/android/video/generated/models/CallRequest;)Lio/getstream/android/video/generated/models/JoinCallRequest;
+	public static synthetic fun copy$default (Lio/getstream/android/video/generated/models/JoinCallRequest;Ljava/lang/String;Ljava/lang/Boolean;Ljava/lang/Integer;Ljava/lang/String;Ljava/util/List;Ljava/lang/Boolean;Ljava/lang/Boolean;Ljava/lang/Boolean;Lio/getstream/android/video/generated/models/CallRequest;ILjava/lang/Object;)Lio/getstream/android/video/generated/models/JoinCallRequest;
 	public fun equals (Ljava/lang/Object;)Z
 	public final fun getCreate ()Ljava/lang/Boolean;
 	public final fun getData ()Lio/getstream/android/video/generated/models/CallRequest;
 	public final fun getLocation ()Ljava/lang/String;
 	public final fun getMembersLimit ()Ljava/lang/Integer;
 	public final fun getMigratingFrom ()Ljava/lang/String;
+	public final fun getMigratingFromList ()Ljava/util/List;
 	public final fun getNotify ()Ljava/lang/Boolean;
 	public final fun getRing ()Ljava/lang/Boolean;
 	public final fun getVideo ()Ljava/lang/Boolean;

stream-video-android-core/build.gradle.kts

@@ -99,6 +99,15 @@ android {
         }
     }
 
+    buildTypes {
+        debug {
+            buildConfigField("boolean", "DEBUG_TOOLS_ENABLED", "true")
+        }
+        release {
+            buildConfigField("boolean", "DEBUG_TOOLS_ENABLED", "false")
+        }
+    }
+
     val envProps: File = rootProject.file(".env.properties")
     if (envProps.exists()) {
         val properties = Properties()

stream-video-android-core/src/main/kotlin/io/getstream/android/video/generated/models/JoinCallRequest.kt

@@ -51,6 +51,9 @@ data class JoinCallRequest (
     @Json(name = "migrating_from")
     val migratingFrom: kotlin.String? = null,
 
+    @Json(name = "migrating_from_list")
+    val migratingFromList: kotlin.collections.List<kotlin.String>? = null,
+
     @Json(name = "notify")
     val notify: kotlin.Boolean? = null,
 

stream-video-android-core/src/main/kotlin/io/getstream/video/android/core/Call.kt

@@ -92,6 +92,7 @@
 import io.getstream.video.android.core.utils.AtomicUnitCall
 import io.getstream.video.android.core.utils.RampValueUpAndDownHelper
 import io.getstream.video.android.core.utils.StreamSingleFlightProcessorImpl
+import io.getstream.video.android.core.utils.debugOnly
 import io.getstream.video.android.core.utils.safeCall
 import io.getstream.video.android.core.utils.safeCallWithDefault
 import io.getstream.video.android.core.utils.toQueriedMembers
@@ -234,12 +235,18 @@
      */
     private var isDestroyed = false
 
     /** Session handles all real time communication for video and audio */
     internal val session: MutableStateFlow<RtcSession?> = MutableStateFlow(null)
 
     var sessionId = UUID.randomUUID().toString()
     internal val unifiedSessionId = UUID.randomUUID().toString()
 
+    /**
+     * SFU IDs (edge names) we failed to connect to (e.g. SFU_FULL). Sent in migrating_from_list
+     * when requesting new credentials so the coordinator can exclude them.
+     */
+    private val failedSfuIds: MutableSet<String> = ConcurrentHashMap.newKeySet()
+
     internal var connectStartTime = 0L
     internal var reconnectStartTime = 0L
 
@@ -642,6 +649,7 @@
         val sfuToken = result.value.credentials.token
         val sfuUrl = result.value.credentials.server.url
         val sfuWsUrl = result.value.credentials.server.wsEndpoint
+        val sfuName = result.value.credentials.server.edgeName
         val iceServers = result.value.credentials.iceServers.map { it.toIceServer() }
         try {
             val localSession = if (testInstanceProvider.rtcSessionCreator != null) {
@@ -656,6 +664,7 @@
                     sfuUrl = sfuUrl,
                     sfuWsUrl = sfuWsUrl,
                     sfuToken = sfuToken,
+                    sfuName = sfuName,
                     remoteIceServers = iceServers,
                     powerManager = powerManager,
                 )
@@ -842,6 +851,7 @@
                             cred.server.url,
                             cred.server.wsEndpoint,
                             cred.token,
+                            cred.server.edgeName,
                             cred.iceServers.map { ice ->
                                 ice.toIceServer()
                             },
@@ -876,15 +886,16 @@
         state._connection.value = RealtimeConnection.Migrating
         location?.let {
             reconnectStartTime = System.currentTimeMillis()
+            session.value?.sfuName?.let { addFailedSfuId(it) }
 
-            val joinResponse = joinRequest(location = it)
+            val joinResponse = joinRequest(location = it, migratingFrom = session.value?.sfuName)
             if (joinResponse is Success) {
                 // switch to the new SFU
                 val cred = joinResponse.value.credentials
                 val session = this.session.value!!
                 val currentOptions = this.session.value?.publisher?.value?.currentOptions()
-                val oldSfuUrl = session.sfuUrl
-                logger.i { "Rejoin SFU $oldSfuUrl to ${cred.server.url}" }
+                val oldSfuName = session.sfuName
+                logger.i { "Migrate SFU $oldSfuName to ${cred.server.edgeName}" }
 
                 this.sessionId = UUID.randomUUID().toString()
                 val (prevSessionId, subscriptionsInfo, publishingInfo) = session.currentSfuInfo()
@@ -893,7 +904,7 @@
                     strategy = WebsocketReconnectStrategy.WEBSOCKET_RECONNECT_STRATEGY_MIGRATE,
                     announced_tracks = publishingInfo,
                     subscriptions = subscriptionsInfo,
-                    from_sfu_id = oldSfuUrl,
+                    from_sfu_id = oldSfuName,
                     reconnect_attempt = reconnectAttepmts,
                 )
                 session.prepareRejoin()
@@ -909,6 +920,7 @@
                         cred.server.url,
                         cred.server.wsEndpoint,
                         cred.token,
+                        cred.server.edgeName,
                         cred.iceServers.map { ice ->
                             ice.toIceServer()
                         },
@@ -1497,14 +1509,38 @@
         return clientImpl.muteUsers(type, id, request)
     }
 
+    /** Adds the given SFU ID (edge name) to the failed set (for migrating_from_list). */
+    private fun addFailedSfuId(sfuId: String) {
+        if (sfuId.isBlank()) return
+        failedSfuIds.add(sfuId)
+    }
+
+    /** Returns a snapshot of failed SFU IDs to send as migrating_from_list. */
+    private fun getFailedSfuIdsSnapshot(): List<String> = failedSfuIds.toList()
+
+    /** Clears the failed SFU list (e.g. after a successful join). */
+    private fun clearFailedSfuIds() {
+        failedSfuIds.clear()
+    }
+
+    /**
+     * Called by [RtcSession] when connection to the SFU is established successfully.
+     * Clears the failed SFU list so we don't exclude this SFU on future requests.
+     */
+    internal fun onSfuConnectionEstablished() {
+        clearFailedSfuIds()
+    }
+
     @VisibleForTesting
     internal suspend fun joinRequest(
         create: CreateCallOptions? = null,
         location: String,
         migratingFrom: String? = null,
+        migratingFromList: List<String>? = null,
         ring: Boolean = false,
         notify: Boolean = false,
     ): Result<JoinCallResponse> {
+        val migratingFromList = migratingFromList ?: getFailedSfuIdsSnapshot().takeIf { it.isNotEmpty() }
         val result = clientImpl.joinCall(
             type, id,
             create = create != null,
@@ -1517,6 +1553,7 @@
             notify = notify,
             location = location,
             migratingFrom = migratingFrom,
+            migratingFromList = migratingFromList,
         )
         result.onSuccess {
             state.updateFromResponse(it)
@@ -1571,7 +1608,7 @@
     /**
      * Should outlive both the call scope and the service scope and needs to be executed in the client-level scope.
      * Because the call scope or service scope may be cancelled or finished while the network request is still in flight
      * TODO: Run this in clientImpl.scope internally
      */
     suspend fun reject(reason: RejectReason? = null): Result<RejectCallResponse> {
         logger.d { "[reject] #ringing; rejectReason: $reason, call_id:$id" }
@@ -1773,6 +1810,10 @@
             }
         }
 
+        fun simulateSfuFull() = debugOnly {
+            call.session.value?.simulateSfuFull()
+        }
+
         fun fastReconnect(reason: String = "Debug") {
             call.scope.launch {
                 call.fastReconnect(reason)

stream-video-android-core/src/main/kotlin/io/getstream/video/android/core/StreamVideoClient.kt

@@ -796,7 +796,8 @@ internal class StreamVideoClient internal constructor(
         ring: Boolean = false,
         notify: Boolean = false,
         location: String,
-        migratingFrom: String?,
+        migratingFrom: String? = null,
+        migratingFromList: List<String>? = null,
     ): Result<JoinCallResponse> {
         val joinCallRequest = JoinCallRequest(
             create = create,
@@ -811,6 +812,7 @@ internal class StreamVideoClient internal constructor(
             notify = notify,
             location = location,
             migratingFrom = migratingFrom,
+            migratingFromList = migratingFromList,
         )
 
         val result = apiCall {