Connection timing

GetStream · Dec 18, 2024 · 2286a7c · 2286a7c
1 parent a048ff9
commit 2286a7c
Show file tree

Hide file tree

Showing 2 changed files with 30 additions and 0 deletions.
diff --git a/stream-video-android-core/src/main/kotlin/io/getstream/video/android/core/Call.kt b/stream-video-android-core/src/main/kotlin/io/getstream/video/android/core/Call.kt
@@ -208,6 +208,9 @@ public class Call(
     internal var session: RtcSession? = null
     var sessionId = UUID.randomUUID().toString()
 
+    internal var connectedAt: Long? = null
+    internal var reconnectAt: Pair<WebsocketReconnectStrategy, Long>? = null
+
     internal val mediaManager by lazy {
         if (testInstanceProvider.mediaManagerCreator != null) {
             testInstanceProvider.mediaManagerCreator!!.invoke()
@@ -463,6 +466,7 @@ public class Call(
         session = if (testInstanceProvider.rtcSessionCreator != null) {
             testInstanceProvider.rtcSessionCreator!!.invoke()
         } else {
+            connectedAt = System.currentTimeMillis()
             RtcSession(
                 sessionId = this.sessionId,
                 apiKey = clientImpl.apiKey,
@@ -617,6 +621,7 @@ public class Call(
                 subscriptions = subscriptionsInfo,
                 reconnect_attempt = reconnectAttepmts,
             )
+            reconnectAt = Pair(WebsocketReconnectStrategy.WEBSOCKET_RECONNECT_STRATEGY_FAST, System.currentTimeMillis())
             session.fastReconnect(reconnectDetails)
         } else {
             logger.e { "[reconnect] Disconnecting" }
@@ -629,6 +634,7 @@ public class Call(
      */
     suspend fun rejoin() = schedule {
         logger.d { "[rejoin] Rejoining" }
+        reconnectAt = Pair(WebsocketReconnectStrategy.WEBSOCKET_RECONNECT_STRATEGY_REJOIN, System.currentTimeMillis())
         reconnectAttepmts++
         state._connection.value = RealtimeConnection.Reconnecting
         location?.let {
@@ -702,6 +708,7 @@ public class Call(
                     reconnect_attempt = reconnectAttepmts,
                 )
                 session.prepareRejoin()
+                reconnectAt = Pair(WebsocketReconnectStrategy.WEBSOCKET_RECONNECT_STRATEGY_MIGRATE, System.currentTimeMillis())
                 val newSession = RtcSession(
                     clientImpl,
                     powerManager,

diff --git a/stream-video-android-core/src/main/kotlin/io/getstream/video/android/core/call/RtcSession.kt b/stream-video-android-core/src/main/kotlin/io/getstream/video/android/core/call/RtcSession.kt
@@ -137,11 +137,13 @@ import stream.video.sfu.models.WebsocketReconnectStrategy
 import stream.video.sfu.signal.ICERestartRequest
 import stream.video.sfu.signal.ICERestartResponse
 import stream.video.sfu.signal.ICETrickleResponse
+import stream.video.sfu.signal.Reconnection
 import stream.video.sfu.signal.SendAnswerRequest
 import stream.video.sfu.signal.SendAnswerResponse
 import stream.video.sfu.signal.SendStatsRequest
 import stream.video.sfu.signal.SetPublisherRequest
 import stream.video.sfu.signal.SetPublisherResponse
+import stream.video.sfu.signal.Telemetry
 import stream.video.sfu.signal.TrackMuteState
 import stream.video.sfu.signal.TrackSubscriptionDetails
 import stream.video.sfu.signal.UpdateMuteStatesRequest
@@ -301,6 +303,9 @@ public class RtcSession internal constructor(
         return setTrack(sessionId, type, track)
     }
 
+    private var connectedAt: Long? = null
+    private var reconnectAt: Pair<WebsocketReconnectStrategy, Long>? = null
+
     /**
      * Connection and WebRTC.
      */
@@ -519,6 +524,7 @@ public class RtcSession internal constructor(
         logger.d { "Connecting RTC, $request" }
         listenToSfuSocket()
         sfuConnectionModule.socketConnection.connect(request)
+        connectedAt = System.currentTimeMillis()
         sfuConnectionModule.socketConnection.whenConnected {
             connectRtc()
         }
@@ -1631,6 +1637,7 @@ public class RtcSession internal constructor(
 
     internal suspend fun sendCallStats(report: CallStatsReport) {
         val result = wrapAPICall {
+            val now = System.currentTimeMillis()
             val androidThermalState =
                 safeCallWithDefault(AndroidThermalState.ANDROID_THERMAL_STATE_UNSPECIFIED) {
                     val thermalState = powerManager?.currentThermalStatus
@@ -1663,6 +1670,22 @@ public class RtcSession internal constructor(
                         thermal_state = androidThermalState,
                         is_power_saver_mode = powerSaving,
                     ),
+                    telemetry = safeCallWithDefault(null) {
+                        if (call.connectedAt != null || call.reconnectAt != null) {
+                            Telemetry(
+                                connection_time_seconds = call.connectedAt?.let { (now - it) / 1000 }
+                                    ?.toFloat(),
+                                reconnection = call.reconnectAt?.let {
+                                    Reconnection(
+                                        time_seconds = ((now - it.second) / 1000).toFloat(),
+                                        strategy = it.first,
+                                    )
+                                },
+                            )
+                        } else {
+                            null
+                        }
+                    },
                 ),
             )
         }