[Fix]CallViewModel ending outgoing group call when one of the participants rejects (#901)

Author: ipavlidakis

CHANGELOG.md

@@ -4,7 +4,8 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/).
 
 # Upcoming
 
-### 🔄 Changed
+### 🐞 Fixed
+- An issue that caused the CallViewModel to end outgoing group calls prematurely when a participant rejected the call. [#901](https://github.com/GetStream/stream-video-swift/pull/901)
 
 # [1.29.0](https://github.com/GetStream/stream-video-swift/releases/tag/1.29.0)
 _July 21, 2025_

Sources/StreamVideoSwiftUI/CallViewModel.swift

@@ -64,6 +64,18 @@ open class CallViewModel: ObservableObject {
                 .sink(receiveValue: { [weak self] settings in
                     self?.callSettings = settings
                 })
+
+            // We only update the outgoingCallMembers if they are empty (which
+            // means that the call was created externally)
+            outgoingCallMembersUpdates = call?
+                .state
+                .$members
+                .filter { [weak self] _ in
+                    self?.outgoingCallMembers.isEmpty == true
+                        && self?.callingState == .outgoing
+                }
+                .receive(on: RunLoop.main)
+                .assign(to: \.outgoingCallMembers, onWeak: self)
             if let callSettings = call?.state.callSettings {
                 self.callSettings = callSettings
             }
@@ -162,6 +174,7 @@ open class CallViewModel: ObservableObject {
     private var recordingUpdates: AnyCancellable?
     private var screenSharingUpdates: AnyCancellable?
     private var callSettingsUpdates: AnyCancellable?
+    private var outgoingCallMembersUpdates: AnyCancellable?
     private var applicationLifecycleUpdates: AnyCancellable?
 
     private var ringingCancellable: AnyCancellable?
@@ -921,7 +934,9 @@ open class CallViewModel: ObservableObject {
             let accepted = outgoingCall.state.session?.acceptedBy.count ?? 0
             if accepted == 0, rejections >= outgoingMembersCount {
                 Task(disposableBag: disposableBag, priority: .userInitiated) { [weak self] in
-                    _ = try? await outgoingCall.reject()
+                    _ = try? await outgoingCall.reject(
+                        reason: "Call rejected by all \(outgoingMembersCount) outgoing call members."
+                    )
                     self?.leaveCall()
                 }
             }

StreamVideo.xcodeproj/project.pbxproj

@@ -341,6 +341,7 @@
 		4072A5922DAEB41500108E8F /* PictureInPictureDelegateProxy.swift in Sources */ = {isa = PBXBuildFile; fileRef = 4072A5912DAEB41500108E8F /* PictureInPictureDelegateProxy.swift */; };
 		4072A5942DAF992400108E8F /* PictureInPictureParticipantModifier.swift in Sources */ = {isa = PBXBuildFile; fileRef = 4072A5932DAF992400108E8F /* PictureInPictureParticipantModifier.swift */; };
 		4072A5962DAF99E000108E8F /* PictureInPictureContentProvider.swift in Sources */ = {isa = PBXBuildFile; fileRef = 4072A5952DAF99E000108E8F /* PictureInPictureContentProvider.swift */; };
+		4073BC992E326DAF001E8965 /* MockDefaultAPI.swift in Sources */ = {isa = PBXBuildFile; fileRef = 404A81302DA3C5F0001F7FA8 /* MockDefaultAPI.swift */; };
 		407508312DE861E100155CC8 /* DispatchQueueExecutor.swift in Sources */ = {isa = PBXBuildFile; fileRef = 407508302DE861E100155CC8 /* DispatchQueueExecutor.swift */; };
 		4075F0782DCE3FFC0062A4CC /* WebRTCTrackStorage.swift in Sources */ = {isa = PBXBuildFile; fileRef = 4075F0772DCE3FFC0062A4CC /* WebRTCTrackStorage.swift */; };
 		407AF7142B615D3300E9E3E7 /* CallDurationView_Tests.swift in Sources */ = {isa = PBXBuildFile; fileRef = 407AF7132B615D3300E9E3E7 /* CallDurationView_Tests.swift */; };
@@ -8641,6 +8642,7 @@
 			isa = PBXSourcesBuildPhase;
 			buildActionMask = 2147483647;
 			files = (
+				4073BC992E326DAF001E8965 /* MockDefaultAPI.swift in Sources */,
 				40B575D02DCCEBA900F489B8 /* PictureInPictureEnforcedStopAdapterTests.swift in Sources */,
 				82FF40BE2A17C73500B4D95E /* CallConnectingView_Tests.swift in Sources */,
 				407AF7182B61619900E9E3E7 /* ParticipantListButton_Tests.swift in Sources */,

StreamVideoSwiftUITests/CallViewModel_Tests.swift

@@ -17,7 +17,14 @@ final class CallViewModel_Tests: XCTestCase, @unchecked Sendable {
     private lazy var callId: String! = UUID().uuidString
     private lazy var participants: [Member]! = [firstUser, secondUser]
     private var streamVideo: MockStreamVideo!
-    private lazy var mockCall: MockCall! = .init(.dummy(callType: callType, callId: callId))
+    private lazy var mockCoordinatorClient: MockDefaultAPI! = .init()
+    private lazy var mockCall: MockCall! = .init(
+        .dummy(
+            callType: callType,
+            callId: callId,
+            coordinatorClient: mockCoordinatorClient
+        )
+    )
 
     private var subject: CallViewModel!
 
@@ -31,6 +38,7 @@ final class CallViewModel_Tests: XCTestCase, @unchecked Sendable {
         thirdUser = nil
         secondUser = nil
         firstUser = nil
+        mockCoordinatorClient = nil
         try await super.tearDown()
     }
 
@@ -210,6 +218,62 @@ final class CallViewModel_Tests: XCTestCase, @unchecked Sendable {
         await assertCallingState(.idle)
     }
 
+    func test_outgoingCall_callCreatedPriorToStarting_rejectedEventFromOneParticipantCallRemainsOngoing() async throws {
+        LogConfig.level = .debug
+        // Given
+        let memberResponses = (participants + [thirdUser]).map {
+            MemberResponse(
+                createdAt: .init(),
+                custom: [:],
+                updatedAt: .init(),
+                user: .dummy(id: $0.id),
+                userId: $0.userId
+            )
+        }
+        mockCoordinatorClient.stub(
+            for: .getOrCreateCall,
+            with: GetOrCreateCallResponse(
+                call: .dummy(
+                    cid: callCid(from: callId, callType: callType),
+                    settings: .dummy(ring: .dummy(autoCancelTimeoutMs: 15000))
+                ),
+                created: true,
+                duration: "",
+                members: memberResponses,
+                ownCapabilities: []
+            )
+        )
+        await prepare()
+        mockCall.stub(for: .create, with: ()) // We stub with something irrelevant to cause the mock to forward to super the request
+
+        subject.startCall(
+            callType: .default,
+            callId: callId,
+            members: [],
+            ring: true
+        )
+        await assertCallingState(.outgoing)
+
+        // When
+        streamVideo.process(
+            .coordinatorEvent(
+                .typeCallRejectedEvent(.dummy(
+                    call: .dummy(
+                        cid: cId,
+                        session: .dummy(
+                            rejectedBy: [secondUser.userId: Date()]
+                        )
+                    ),
+                    callCid: cId,
+                    createdAt: Date(),
+                    user: secondUser.user.toUserResponse()
+                ))
+            )
+        )
+        await wait(for: 1.0)
+        await assertCallingState(.outgoing)
+    }
+
     func test_outgoingCall_callEndedEvent() async throws {
         // Given
         await prepare()
@@ -969,8 +1033,6 @@ final class CallViewModel_Tests: XCTestCase, @unchecked Sendable {
         file: StaticString = #file,
         line: UInt = #line
     ) async {
-        LogConfig.level = .debug
-
         mockCall.stub(
             for: .join,
             with: JoinCallResponse.dummy(

StreamVideoTests/Mock/MockCall.swift

@@ -100,7 +100,26 @@ final class MockCall: Call, Mockable, @unchecked Sendable {
         video: Bool? = nil,
         transcription: TranscriptionSettingsRequest? = nil
     ) async throws -> CallResponse {
-        stubbedFunction[.create] as! CallResponse
+        if let response = stubbedFunction[.create] as? CallResponse {
+            return response
+        } else if let error = stubbedFunction[.create] as? Error {
+            throw error
+        } else {
+            return try await super.create(
+                members: members,
+                memberIds: memberIds,
+                custom: custom,
+                startsAt: startsAt,
+                team: team,
+                ring: ring,
+                notify: notify,
+                maxDuration: maxDuration,
+                maxParticipants: maxParticipants,
+                backstage: backstage,
+                video: video,
+                transcription: transcription
+            )
+        }
     }
 
     override func get(

StreamVideoTests/Mock/MockDefaultAPI.swift

@@ -11,11 +11,13 @@ final class MockDefaultAPI: DefaultAPI, Mockable, @unchecked Sendable {
     enum MockFunctionKey: Hashable, CaseIterable {
         case acceptCall
         case rejectCall
+        case getOrCreateCall
     }
 
     enum MockFunctionInputKey: Payloadable {
         case acceptCall(type: String, id: String)
         case rejectCall(type: String, id: String, request: RejectCallRequest)
+        case getOrCreateCall(type: String, id: String, getOrCreateCallRequest: GetOrCreateCallRequest)
 
         var payload: Any {
             switch self {
@@ -24,6 +26,9 @@ final class MockDefaultAPI: DefaultAPI, Mockable, @unchecked Sendable {
 
             case let .rejectCall(type, id, request):
                 return (type, id, request)
+
+            case let .getOrCreateCall(type, id, request):
+                return (type, id, request)
             }
         }
     }
@@ -52,6 +57,31 @@ final class MockDefaultAPI: DefaultAPI, Mockable, @unchecked Sendable {
 
     // MARK: - Mocks
 
+    override func getOrCreateCall(
+        type: String,
+        id: String,
+        getOrCreateCallRequest: GetOrCreateCallRequest
+    ) async throws -> GetOrCreateCallResponse {
+        stubbedFunctionInput[.getOrCreateCall]?.append(
+            .getOrCreateCall(
+                type: type,
+                id: id,
+                getOrCreateCallRequest: getOrCreateCallRequest
+            )
+        )
+        if let response = stubbedFunction[.getOrCreateCall] as? GetOrCreateCallResponse {
+            return response
+        } else if let error = stubbedFunction[.getOrCreateCall] as? Error {
+            throw error
+        } else {
+            return try await super.getOrCreateCall(
+                type: type,
+                id: id,
+                getOrCreateCallRequest: getOrCreateCallRequest
+            )
+        }
+    }
+
     override func acceptCall(
         type: String,
         id: String