Add video server disconnection callback

Author: sierpinskid

Packages/StreamVideo/Runtime/Core/LowLevelClient/RtcSession.cs

@@ -85,6 +85,7 @@ internal sealed class RtcSession : IMediaInputProvider, IDisposable
         public event Action PublisherAudioTrackChanged;
         public event Action PublisherVideoTrackChanged;
 
+        public event Action PeerConnectionDisconnectedDuringSession;
 
         public bool PublisherAudioTrackIsEnabled
         {
@@ -1098,6 +1099,8 @@ private void OnSfuTrackUnpublished(TrackUnpublished trackUnpublished)
             var sessionId = trackUnpublished.SessionId;
             var type = trackUnpublished.Type.ToPublicEnum();
             var cause = trackUnpublished.Cause;
+            
+            // StreamTODO: test if this works well with other user muting this user
             var updateLocalParticipantState = cause != TrackUnpublishReason.Unspecified && cause != TrackUnpublishReason.UserMuted;
 
             // Optionally available. Read TrackUnpublished.participant comment in events.proto
@@ -1850,6 +1853,7 @@ private void CreatePublisher(IEnumerable<ICEServer> iceServers)
             Publisher.NegotiationNeeded += OnPublisherNegotiationNeeded;
             Publisher.PublisherAudioTrackChanged += OnPublisherAudioTrackChanged;
             Publisher.PublisherVideoTrackChanged += OnPublisherVideoTrackChanged;
+            Publisher.Disconnected += PublisherOnDisconnected;
 
             Publisher.InitPublisherTracks();
 
@@ -1865,6 +1869,7 @@ private void DisposePublisher()
                 Publisher.NegotiationNeeded -= OnPublisherNegotiationNeeded;
                 Publisher.PublisherAudioTrackChanged -= OnPublisherAudioTrackChanged;
                 Publisher.PublisherVideoTrackChanged -= OnPublisherVideoTrackChanged;
+                Publisher.Disconnected += PublisherOnDisconnected;
                 Publisher.Dispose();
                 Publisher = null;
             }
@@ -1880,6 +1885,14 @@ private void OnPublisherVideoTrackChanged(VideoStreamTrack videoTrack)
         {
             PublisherVideoTrackChanged?.Invoke();
         }
+        
+        void PublisherOnDisconnected()
+        {
+            if (CallState == CallingState.Joined || CallState == CallingState.Joining)
+            {
+                PeerConnectionDisconnectedDuringSession?.Invoke();
+            }
+        }
 
         private void OnSfuWebSocketDisconnected()
         {
@@ -1899,6 +1912,7 @@ private static bool AssertCallIdMatch(IStreamCall activeCall, string callId, ILo
 
             return true;
         }
+        
 
         private void SubscribeToSfuEvents()
         {

Packages/StreamVideo/Runtime/Core/LowLevelClient/StreamPeerConnection.cs

@@ -31,6 +31,8 @@ internal class StreamPeerConnection : IDisposable
         public event Action<VideoStreamTrack> PublisherVideoTrackChanged;
         public event Action<AudioStreamTrack> PublisherAudioTrackChanged;
 
+        public event Action Disconnected;
+
         public bool IsRemoteDescriptionAvailable
         {
             get
@@ -403,6 +405,11 @@ private void OnConnectionStateChange(RTCPeerConnectionState state)
             _logs.Warning($"[{_peerType}] OnConnectionStateChange to: {state}");
 #endif
             _tracer?.Trace(PeerConnectionTraceKey.OnConnectionStateChange, state.ToString());
+
+            if (state == RTCPeerConnectionState.Disconnected)
+            {
+                Disconnected?.Invoke();
+            }
         }
 
         private void OnTrack(RTCTrackEvent trackEvent)

Packages/StreamVideo/Runtime/Core/StreamVideoClient.cs

@@ -47,6 +47,8 @@ public enum DisconnectReason
         /// 
         /// </summary>
         CoordinatorWsDisconnected,
+        
+        VideoServerDisconnected,
     }
 
     public delegate void CallHandler(IStreamCall call);
@@ -556,6 +558,12 @@ private void SubscribeTo(StreamVideoLowLevelClient lowLevelClient)
 
             lowLevelClient.Disconnected += OnLowLevelClientDisconnected;
             lowLevelClient.SfuDisconnected += OnLowLevelClientSfuDisconnected;
+            lowLevelClient.RtcSession.PeerConnectionDisconnectedDuringSession += OnRtcPeerConnectionDisconnectedDuringSession;
+        }
+
+        private void OnRtcPeerConnectionDisconnectedDuringSession()
+        {
+            Disconnected?.Invoke(DisconnectReason.VideoServerDisconnected);
         }
 
         private void UnsubscribeFrom(StreamVideoLowLevelClient lowLevelClient)
@@ -594,6 +602,8 @@ private void UnsubscribeFrom(StreamVideoLowLevelClient lowLevelClient)
 
             lowLevelClient.Disconnected -= OnLowLevelClientDisconnected;
             lowLevelClient.SfuDisconnected -= OnLowLevelClientSfuDisconnected;
+            
+            lowLevelClient.RtcSession.PeerConnectionDisconnectedDuringSession -= OnRtcPeerConnectionDisconnectedDuringSession;
         }
 
         private void InternalLowLevelClientOnConnected()