Reenable tests

GetStream · Sep 18, 2024 · c6c9128 · c6c9128
1 parent d4b3ebb
commit c6c9128
Show file tree

Hide file tree

Showing 4 changed files with 457 additions and 465 deletions.
diff --git a/Sources/StreamVideo/Controllers/CallController.swift b/Sources/StreamVideo/Controllers/CallController.swift
@@ -391,9 +391,7 @@ class CallController: @unchecked Sendable {
     func cleanUp() {
         guard call != nil else { return }
         call = nil
-        Task {
-            await webRTCCoordinator.cleanUp()
-        }
+        Task { await webRTCCoordinator.cleanUp() }
     }
 
     /// Collects user feedback asynchronously.

diff --git a/StreamVideoTests/Call/Call_Tests.swift b/StreamVideoTests/Call/Call_Tests.swift
@@ -303,6 +303,41 @@ final class Call_Tests: StreamVideoTestCase {
         XCTAssertTrue(Int(duration) >= 1)
     }
 
+    // MARK: - Update State from Coordinator events
+
+    func test_coordinatorEventReceived_startedRecording_updatesStateCorrectly() async throws {
+        try await assertCoordinatorEventReceived(
+            .typeCallRecordingStartedEvent(
+                CallRecordingStartedEvent(callCid: callCid, createdAt: Date())
+            )
+        ) { call in await fulfillment { call.state.recordingState == .recording } }
+    }
+
+    func test_coordinatorEventReceived_startedRecordingForAnotherCall_doesNotUpdateState() async throws {
+        try await assertCoordinatorEventReceived(
+            .typeCallRecordingStartedEvent(
+                CallRecordingStartedEvent(callCid: .unique, createdAt: Date())
+            )
+        ) { @MainActor call in
+            await wait(for: 1)
+            XCTAssertEqual(call.state.recordingState, .noRecording)
+        }
+    }
+
+    private func assertCoordinatorEventReceived(
+        _ event: VideoEvent,
+        fulfillmentHandler: @MainActor (Call) async throws -> Void
+    ) async throws {
+        let streamVideo = try XCTUnwrap(streamVideo)
+        let call = streamVideo.call(callType: callType, callId: callId)
+
+        streamVideo
+            .eventNotificationCenter
+            .process(.coordinatorEvent(event))
+
+        try await fulfillmentHandler(call)
+    }
+
     // MARK: - join
 
     func test_join_callControllerWasCalledOnlyOnce() async throws {