Implemented fast reconnection

CHANGELOG.md

@@ -10,6 +10,7 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/).
 
 ### ✅ Added
 - Add support for pre-built XCFrameworks
+- Fast reconnection
 
 ### 🔄 Changed
 - You can now focus on a desired point in the local video stream. [#221](https://github.com/GetStream/stream-video-swift/pull/221)

README.md

@@ -193,11 +193,11 @@ Video roadmap and changelog is available [here](https://github.com/GetStream/pro
 
 ### 0.5.0 milestone
 
+- [x] Tap to focus
+- [x] Complete reconnection flows
 - [ ] Video UIKit tutorial
 - [ ] Improve logging / Sentry integration
 - [ ] Camera controls
-- [x] Tap to focus
-- [ ] Complete reconnection flows
 - [ ] Complete Livestreaming APIs and Tutorials for hosting & watching
 - [ ] Dynascale 2.0
 - [ ] Buttons to simulate ice-restart and SFU switching

Sources/StreamVideo/WebRTC/PeerConnection.swift

@@ -32,6 +32,10 @@ class PeerConnection: NSObject, RTCPeerConnectionDelegate, @unchecked Sendable {
     var onStreamRemoved: ((RTCMediaStream) -> Void)?
 
     var paused = false
+
+    var connectionState: RTCPeerConnectionState {
+        pc.connectionState
+    }
 
     init(
         sessionId: String,
@@ -167,6 +171,10 @@ class PeerConnection: NSObject, RTCPeerConnectionDelegate, @unchecked Sendable {
         }
         try await add(candidate: iceCandidate)
     }
+
+    func restartIce() {
+        pc.restartIce()
+    }
 
     func close() {
         pc.close()

Sources/StreamVideo/WebRTC/SfuMiddleware.swift

@@ -14,7 +14,7 @@ class SfuMiddleware: EventMiddleware {
     var signalService: Stream_Video_Sfu_Signal_SignalServer
     private var subscriber: PeerConnection?
     private var publisher: PeerConnection?
-    var onSocketConnected: (() -> Void)?
+    var onSocketConnected: ((Bool) -> Void)?
     var onParticipantCountUpdated: ((UInt32) -> ())?
     var onSessionMigrationEvent: (() -> Void)?
     var onPinsChanged: (([Stream_Video_Sfu_Models_Pin]) -> ())?
@@ -71,7 +71,7 @@ class SfuMiddleware: EventMiddleware {
             case .dominantSpeakerChanged(let event):
                 await handleDominantSpeakerChanged(event)
             case .joinResponse(let event):
-                onSocketConnected?()
+                onSocketConnected?(event.reconnected)
                 await loadParticipants(from: event)
             case .healthCheckResponse(let event):
                 onParticipantCountUpdated?(event.participantCount.total)