Decompose Call into focused internal components

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

@@ -1515,7 +1515,8 @@ class MediaManagerImpl(
      *
      * Once released, [runOnAudioTrackIfAvailable] / [runOnVideoTrackIfAvailable] become no-ops. Set
      * only on the terminal [cleanup] path and NOT in [disposeTracksAndSources], because
-     * [Call.recreateFactoryAndAudioTracks] disposes and then deliberately recreates before joining.
+     * CallMediaManager.recreateFactoryAndAudioTracks disposes and then deliberately recreates
+     * before joining.
      */
     private var released = false
 

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

@@ -48,6 +48,7 @@
 import io.getstream.video.android.core.StreamVideoClient
 import io.getstream.video.android.core.analytics.call.observer.SfuAnalytics
 import io.getstream.video.android.core.analytics.reporting.model.AnalyticsCallAbortReason
+import io.getstream.video.android.core.call.components.CallSessionManager
 import io.getstream.video.android.core.call.connection.Publisher
 import io.getstream.video.android.core.call.connection.StreamPeerConnection
 import io.getstream.video.android.core.call.connection.Subscriber
@@ -255,6 +256,7 @@
     private val sessionCounter: Int = 0,
     private val powerManager: PowerManager?,
     private val call: Call,
+    private val sessionManager: CallSessionManager,
     private val sessionId: String,
     private val apiKey: String,
     private val lifecycle: Lifecycle,
@@ -554,8 +556,8 @@
     private val connectionConfiguration: PeerConnection.RTCConfiguration
         get() = buildConnectionConfiguration(iceServers)
 
     internal val subscriber: MutableStateFlow<Subscriber?> = MutableStateFlow(null)
     internal val publisher: MutableStateFlow<Publisher?> = MutableStateFlow(null)
 
     internal lateinit var sfuConnectionModule: SfuConnectionModule
 
@@ -778,7 +780,7 @@
         }
     }
 
     private fun startIceMonitoring() {
         if (iceMonitoringJob?.isActive == true) return
         iceMonitoringJob = coroutineScope.launch {
             val badIceStates = setOf(
@@ -902,7 +904,7 @@
         message = "Use connectInternal() which returns SfuConnectionResult instead of throwing.",
         replaceWith = ReplaceWith("connectInternal(reconnectDetails, options)"),
     )
     suspend fun connect(
         reconnectDetails: ReconnectDetails? = null,
         options: List<PublishOption>? = null,
     ) {
@@ -1056,7 +1058,7 @@
     ): JoinRequest = JoinRequest(
         subscriber_sdp = throwawaySubscriberSdpAndOptions(),
         publisher_sdp = throwawayPublisherSdpAndOptions(),
-        unified_session_id = call.unifiedSessionId,
+        unified_session_id = sessionManager.unifiedSessionId,
         session_id = sessionId,
         token = sfuToken,
         fast_reconnect = false,
@@ -1071,13 +1073,13 @@
         if (reconnectStrategy == null) {
             sendCallStats(
                 report = call.collectStats(),
-                connectionTimeSeconds = (System.currentTimeMillis() - call.connectStartTime) / 1000f,
+                connectionTimeSeconds = sessionManager.connectionTimeSeconds(),
             )
         } else {
             sendCallStats(
                 report = call.collectStats(),
                 reconnectionTimeSeconds = Pair(
-                    (System.currentTimeMillis() - call.reconnectStartTime) / 1000f,
+                    sessionManager.reconnectionTimeSeconds(),
                     reconnectStrategy,
                 ),
             )
@@ -1597,7 +1599,7 @@
                                 paused = false,
                             )
 
                             if (event.trackType == TrackType.TRACK_TYPE_AUDIO) {
                                 if (event.sessionId == sessionId) {
                                     val isMicDisabled = !call.mediaManager.microphone.isEnabled.value
                                     if (isMicDisabled) {
@@ -1899,7 +1901,7 @@
             val sendStatsRequest = SendStatsRequest(
                 session_id = sessionId,
                 sdk = "stream-android",
-                unified_session_id = call.unifiedSessionId,
+                unified_session_id = sessionManager.unifiedSessionId,
                 sdk_version = BuildConfig.STREAM_VIDEO_VERSION,
                 webrtc_version = BuildConfig.STREAM_WEBRTC_VERSION,
                 publisher_stats = report?.toJson(StreamPeerType.PUBLISHER) ?: "",
@@ -1999,7 +2001,7 @@
         subscriber.value?.setTrackDimension(viewportId, sessionId, trackType, visible, dimensions)
         coroutineScope.launch {
             serialProcessor.submit("updateTrackDimensions") {
-                if (sessionId != call.sessionId) {
+                if (sessionId != sessionManager.sessionId) {
                     // dimension updated for another participant
                     subscriber.value?.setVideoSubscriptions(
                         trackOverridesHandler,