Feature/refactor delete channel test to async (#133)

* Fix state update after `channel.truncated` event with a past date

* Add waiting for new message.received event when truncating in a unit test + add max waiting of 60s for a condition

* Add IStreamChannel.FreezeAsync & IStreamChannel.UnfreezeAsync + add unit tests

* Refactor When_deleting_existing_channel_expect_success to async/await and wrap in ConnectAndExecute in order to handle rate exceeded error with additional delay

Author: sierpinskid

Assets/Plugins/StreamChat/Tests/LowLevelClient/Integration/BaseIntegrationTests.cs

@@ -45,7 +45,7 @@ public async void OneTimeTearDown()
         /// Id of other user than currently logged one
         /// </summary>
         protected static string OtherUserId => StreamTestClients.Instance.OtherUserId;
-        
+
         protected static OwnUser LowLevelClientOwnUser => StreamTestClients.Instance.LowLevelClientOwnUser;
 
         protected static IEnumerator ReconnectClient() => StreamTestClients.Instance.ReconnectLowLevelClientClient();
@@ -115,16 +115,15 @@ protected static async Task<T> Try<T>(Func<Task<T>> task, Predicate<T> successCo
             while (attempt <= maxAttempts)
             {
                 attempt++;
-                
+
                 response = await task();
 
                 if (successCondition(response))
                 {
                     return response;
                 }
 
-                var power = Math.Max(attempt, 5);
-                var delay = initTimeoutMs * Math.Pow(2, power);
+                var delay = Math.Min(1000, initTimeoutMs + Math.Pow(2, attempt));
                 await Task.Delay((int)delay);
             }
 
@@ -253,7 +252,7 @@ await LowLevelClient.ChannelApi.DeleteChannelsAsync(new DeleteChannelsRequest
 
             _tempChannelsCidsToDelete.Clear();
         }
-        
+
         private static async Task ExecuteAsync(Func<Task> test)
         {
             const int maxAttempts = 7;
@@ -285,7 +284,8 @@ private static async Task ExecuteAsync(Func<Task> test)
 
             if (!completed)
             {
-                throw new AggregateException($"Failed all attempts. Last Exception: {exceptions.Last().Message} ", exceptions);
+                throw new AggregateException($"Failed all attempts. Last Exception: {exceptions.Last().Message} ",
+                    exceptions);
             }
         }
     }

Assets/Plugins/StreamChat/Tests/LowLevelClient/Integration/ChannelApiIntegrationTests.cs

@@ -312,23 +312,18 @@ private async Task When_start_watching_a_channel_expect_user_included_in_watcher
         }
 
         [UnityTest]
-        public IEnumerator When_deleting_existing_channel_expect_success()
-        {
-            yield return LowLevelClient.WaitForClientToConnect();
+        public IEnumerator When_deleting_existing_channel_expect_success() 
+            => ConnectAndExecute(When_deleting_existing_channel_expect_success_Async);
 
-            var channelType = "messaging";
+        private async Task When_deleting_existing_channel_expect_success_Async()
+        {
+            const string channelType = "messaging";
 
-            ChannelState channelState = null;
-            yield return CreateTempUniqueChannel(channelType, new ChannelGetOrCreateRequest(),
-                state => channelState = state);
+            var channelState = await CreateTempUniqueChannelAsync(channelType, new ChannelGetOrCreateRequest());
             var channelId = channelState.Channel.Id;
 
-            var deleteChannelTask
-                = LowLevelClient.ChannelApi.DeleteChannelAsync(channelType, channelId, isHardDelete: false);
-            yield return deleteChannelTask.RunAsIEnumerator(response =>
-            {
-                Assert.AreEqual(response.Channel.Id, channelId);
-            });
+            var response = await LowLevelClient.ChannelApi.DeleteChannelAsync(channelType, channelId, isHardDelete: false);
+            Assert.AreEqual(response.Channel.Id, channelId);
         }
 
         [UnityTest]