Reconnect Coordinator always + SFU WS only if during the call + reset reconnection scheduler when WS is being disconnected

Author: sierpinskid

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

@@ -8,6 +8,8 @@ internal interface IReconnectScheduler
     {
         double? NextReconnectTime { get; }
         event Action ReconnectionScheduled;
+
+        void Reset();
     }
     /// <summary>
     /// Schedules next reconnection time based on the past attempts and network availability
@@ -43,8 +45,9 @@ private set
         }
 
         public ReconnectScheduler(ITimeService timeService, IStreamVideoLowLevelClient lowLevelClient,
-            INetworkMonitor networkMonitor)
+            INetworkMonitor networkMonitor, Func<bool> shouldReconnect)
         {
+            _shouldReconnect = shouldReconnect ?? throw new ArgumentNullException(nameof(shouldReconnect));
             _client = lowLevelClient ?? throw new ArgumentNullException(nameof(lowLevelClient));
             _timeService = timeService ?? throw new ArgumentNullException(nameof(timeService));
             _networkMonitor = networkMonitor ?? throw new ArgumentNullException(nameof(networkMonitor));
@@ -98,6 +101,12 @@ void ThrowIfLessOrEqualToZero(float value, string name)
             }
         }
 
+        public void Reset()
+        {
+            NextReconnectTime = default;
+            _reconnectAttempts = 0;
+        }
+
         public void Stop()
         {
             NextReconnectTime = float.MaxValue;
@@ -112,6 +121,7 @@ public void Stop()
         private int _reconnectAttempts;
         private bool _isStopped;
         private double? _nextReconnectTime;
+        private Func<bool> _shouldReconnect;
 
         private void TryScheduleNextReconnectTime()
         {
@@ -120,7 +130,7 @@ private void TryScheduleNextReconnectTime()
                 return;
             }
 
-            if (_isStopped || ReconnectStrategy == ReconnectStrategy.Never)
+            if (_isStopped || ReconnectStrategy == ReconnectStrategy.Never || !_shouldReconnect())
             {
                 return;
             }

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

@@ -143,8 +143,8 @@ public StreamVideoLowLevelClient(IWebsocketClient coordinatorWebSocket, IWebsock
             }
 
             //StreamTodo: move to factory
-            var coordinatorReconnect = new ReconnectScheduler(_timeService, this, _networkMonitor);
-            var sfuReconnect = new ReconnectScheduler(_timeService, this, _networkMonitor);
+            var coordinatorReconnect = new ReconnectScheduler(_timeService, this, _networkMonitor, shouldReconnect: () => true);
+            var sfuReconnect = new ReconnectScheduler(_timeService, this, _networkMonitor, shouldReconnect: () => RtcSession.ActiveCall != null);
 
             //StreamTodo: move to factory
             _coordinatorWS = new CoordinatorWebSocket(coordinatorWebSocket, coordinatorReconnect, authProvider: this,

Packages/StreamVideo/Runtime/Core/LowLevelClient/WebSockets/BasePersistentWebSocket.cs

@@ -228,6 +228,7 @@ protected void OnHealthCheckReceived()
 
         protected virtual Task OnDisconnectingAsync(string closeMessage)
         {
+            _reconnectScheduler.Reset();
             return Task.CompletedTask;
         }