[AND-549] Improve call rejection/decline/timeout flow by fixing coroutines scope usage (#1420)

* fix: Run the timeout timer in user scope instead of call scope. As Calls are cleaned up when they are left

* fix: defer supervisorJob.cancel() until all child jobs complete

Replaces direct supervisorJob.cancel() with graceful shutdown using join()
inside UserScope(ClientScope()). Prevents abrupt termination of active coroutines

* fix: defer supervisorJob.cancel() until all child jobs complete

Replaces direct supervisorJob.cancel() with graceful shutdown using join()
inside UserScope(ClientScope()). Prevents abrupt termination of active coroutines

* chore: refactor

---------

Co-authored-by: Aleksandar Apostolov <[email protected]>

Author: rahul-lohra

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

@@ -77,6 +77,8 @@ import io.getstream.video.android.core.model.SortField
 import io.getstream.video.android.core.model.UpdateUserPermissionsData
 import io.getstream.video.android.core.model.VideoTrack
 import io.getstream.video.android.core.model.toIceServer
+import io.getstream.video.android.core.socket.common.scope.ClientScope
+import io.getstream.video.android.core.socket.common.scope.UserScope
 import io.getstream.video.android.core.utils.AtomicUnitCall
 import io.getstream.video.android.core.utils.RampValueUpAndDownHelper
 import io.getstream.video.android.core.utils.safeCallWithDefault
@@ -1223,12 +1225,20 @@ public class Call(
     fun cleanup() {
         // monitor.stop()
         session?.cleanup()
-        supervisorJob.cancel()
+        shutDownJobsGracefully()
         callStatsReportingJob?.cancel()
         mediaManager.cleanup()
         session = null
     }
 
+    // This will allow the Rest APIs to be executed which are in queue before leave
+    private fun shutDownJobsGracefully() {
+        UserScope(ClientScope()).launch {
+            supervisorJob.children.forEach { it.join() }
+            supervisorJob.cancel()
+        }
+    }
+
     suspend fun ring(): Result<GetCallResponse> {
         logger.d { "[ring] #ringing; no args" }
         return clientImpl.ring(type, id)

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

@@ -103,6 +103,8 @@ import io.getstream.video.android.core.model.VisibilityOnScreenState
 import io.getstream.video.android.core.permission.PermissionRequest
 import io.getstream.video.android.core.pinning.PinType
 import io.getstream.video.android.core.pinning.PinUpdateAtTime
+import io.getstream.video.android.core.socket.common.scope.ClientScope
+import io.getstream.video.android.core.socket.common.scope.UserScope
 import io.getstream.video.android.core.sorting.SortedParticipantsState
 import io.getstream.video.android.core.utils.mapState
 import io.getstream.video.android.core.utils.toUser
@@ -1138,7 +1140,7 @@ public class CallState(
 
     private fun startRingingTimer() {
         ringingTimerJob?.cancel()
-        ringingTimerJob = scope.launch {
+        ringingTimerJob = UserScope(ClientScope()).launch {
             val autoCancelTimeout = settings.value?.ring?.autoCancelTimeoutMs
 
             if (autoCancelTimeout != null && autoCancelTimeout > 0) {