[Fix]Reconnection issue (#895)

Author: ipavlidakis

CHANGELOG.md

@@ -7,6 +7,9 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/).
 ### ✅ Added
 - `ClientCapabilities` have been added to support remote subscriber track pause. [#888](https://github.com/GetStream/stream-video-swift/pull/888)
 
+### 🐞 Fixed
+- An issue causing a reconnection loop when connection was recoevered. [#895](https://github.com/GetStream/stream-video-swift/pull/895)
+
 # [1.28.1](https://github.com/GetStream/stream-video-swift/releases/tag/1.28.1)
 _July 11, 2025_
 

Sources/StreamVideo/Utils/Logger/Logger.swift

@@ -292,7 +292,7 @@ public enum LogConfig {
 
     public static var webRTCLogsEnabled: Bool {
         get { WebRTCLogger.default.enabled }
-        set { WebRTCLogger.default.enabled = true }
+        set { WebRTCLogger.default.enabled = newValue }
     }
 
     /// Invalidates the current logger instance so it can be recreated.

Sources/StreamVideo/WebRTC/v2/StateMachine/Stages/WebRTCCoordinator+Disconnected.swift

@@ -110,6 +110,7 @@ extension WebRTCCoordinator.StateMachine.Stage {
         private func execute() {
             context.sfuEventObserver = nil
             context.disconnectionSource = nil
+            context.lastHealthCheckReceivedAt = nil
             Task(disposableBag: disposableBag) { [weak self] in
                 guard let self else { return }
                 let statsAdapter = await context

StreamVideoTests/WebRTC/v2/StateMachine/Stages/WebRTCCoordinatorStateMachine_DisconnectedStageTests.swift

@@ -91,6 +91,22 @@ final class WebRTCCoordinatorStateMachine_DisconnectedStageTests: XCTestCase, @u
         }
     }
 
+    func test_transition_cleansUpLastHealthCheckReceivedAt() async throws {
+        subject.context.lastHealthCheckReceivedAt = .init()
+
+        await assertTransitionAfterTrigger(trigger: {}) { target in
+            XCTAssertNil(target.context.lastHealthCheckReceivedAt)
+        }
+    }
+
+    func test_transition_cleansUpDisconnectionSource() async throws {
+        subject.context.disconnectionSource = .noPongReceived
+
+        await assertTransitionAfterTrigger(trigger: {}) { target in
+            XCTAssertNil(target.context.disconnectionSource)
+        }
+    }
+
     func test_transition_scheduleStatsReportingWasCalled() async throws {
         let statsAdapter = MockWebRTCStatsAdapter()
         await mockCoordinatorStack.coordinator.stateAdapter.set(