Tests possible fixes, temporarily disable synchronization context cal…

…lback workflow
pubnub · Jan 30, 2025 · 4adc1c0 · 4adc1c0
1 parent 454e631
commit 4adc1c0
Show file tree

Hide file tree

Showing 10 changed files with 147 additions and 72 deletions.
diff --git a/c-sharp-chat/PubnubChatApi/PubNubChatApi.Tests/ChannelTests.cs b/c-sharp-chat/PubnubChatApi/PubNubChatApi.Tests/ChannelTests.cs
@@ -30,6 +30,13 @@ public void Setup()
         talkUser = chat.GetOrCreateUser("talk_user");
     }
 
+    [TearDown]
+    public async Task CleanUp()
+    {
+        chat.Destroy();
+        await Task.Delay(3000);
+    }
+
     [Test]
     public async Task TestGetUserSuggestions()
     {
@@ -157,7 +164,7 @@ public void TestUnPinMessage()
         };
         channel.SendText("message to pin");
 
-        var received = receivedManualEvent.WaitOne(6000);
+        var received = receivedManualEvent.WaitOne(12000);
         Assert.IsTrue(received);
     }
 

diff --git a/c-sharp-chat/PubnubChatApi/PubNubChatApi.Tests/ChatEventTests.cs b/c-sharp-chat/PubnubChatApi/PubNubChatApi.Tests/ChatEventTests.cs
@@ -1,3 +1,4 @@
+using System.Diagnostics;
 using PubNubChatAPI.Entities;
 using PubnubChatApi.Entities.Data;
 
@@ -26,6 +27,15 @@ public void Setup()
         channel.Join();
     }
 
+    [TearDown]
+    public async Task CleanUp()
+    {
+        channel.Leave();
+        await Task.Delay(3000);
+        chat.Destroy();
+        await Task.Delay(3000);
+    }
+
     [Test]
     public void TestModerationEvents()
     {

diff --git a/c-sharp-chat/PubnubChatApi/PubNubChatApi.Tests/ChatTests.cs b/c-sharp-chat/PubnubChatApi/PubNubChatApi.Tests/ChatTests.cs
@@ -25,6 +25,15 @@ public void Setup()
         }
         channel.Join();
     }
+
+    [TearDown]
+    public async Task CleanUp()
+    {
+        channel.Leave();
+        await Task.Delay(3000);
+        chat.Destroy();
+        await Task.Delay(3000);
+    }
 
     [Test]
     public async Task TestGetCurrentUserMentions()
@@ -151,7 +160,7 @@ public void TestForwardMessage()
 
         channel.SendText("message_to_forward");
 
-        var forwarded = messageForwardReceivedManualEvent.WaitOne(6000);
+        var forwarded = messageForwardReceivedManualEvent.WaitOne(12000);
         forwardingChannel.Leave();
         Assert.True(forwarded);
     }
@@ -168,7 +177,7 @@ public void TestEmitEvent()
         channel.Join();
         chat.EmitEvent(PubnubChatEventType.Report, channel.Id, "{\"test\":\"some_nonsense\"}");
 
-        var eventReceived = reportManualEvent.WaitOne(5000);
+        var eventReceived = reportManualEvent.WaitOne(8000);
         Assert.True(eventReceived);
     }
 

diff --git a/c-sharp-chat/PubnubChatApi/PubNubChatApi.Tests/MembershipTests.cs b/c-sharp-chat/PubnubChatApi/PubNubChatApi.Tests/MembershipTests.cs
@@ -26,6 +26,15 @@ public void Setup()
         }
         channel.Join();
     }
+
+    [TearDown]
+    public async Task CleanUp()
+    {
+        channel.Leave();
+        await Task.Delay(3000);
+        chat.Destroy();
+        await Task.Delay(3000);
+    }
 
     [Test]
     public async Task TestGetMemberships()

diff --git a/c-sharp-chat/PubnubChatApi/PubNubChatApi.Tests/MessageTests.cs b/c-sharp-chat/PubnubChatApi/PubNubChatApi.Tests/MessageTests.cs
@@ -27,6 +27,15 @@ public void Setup()
         channel.Join();
     }
 
+    [TearDown]
+    public async Task CleanUp()
+    {
+        channel.Leave();
+        await Task.Delay(3000);
+        chat.Destroy();
+        await Task.Delay(3000);
+    }
+
     [Test]
     public void TestSendAndReceive()
     {
@@ -80,18 +89,19 @@ public void TestReceivingMessageData()
     public void TestTryGetMessage()
     {
         var manualReceiveEvent = new ManualResetEvent(false);
+        var timeToken = string.Empty;
         channel.OnMessageReceived += message =>
         {
             if (message.ChannelId == channel.Id)
             {
-                Assert.True(chat.TryGetMessage(channel.Id, message.TimeToken, out _));
+                timeToken = message.TimeToken;
                 manualReceiveEvent.Set();
             }
         };
         channel.SendText("something");
-
         var received = manualReceiveEvent.WaitOne(4000);
-        Assert.IsTrue(received);
+        Assert.True(received);
+        Assert.True(chat.TryGetMessage(channel.Id, timeToken, out _));
     }
 
     [Test]
@@ -208,7 +218,7 @@ public void TestMessageReactions()
             var reactions = message.Reactions;
             Assert.True(reactions.Count == 1 && reactions.Any(x => x.Value == "happy"));*/
 
-            await Task.Delay(3000);
+            await Task.Delay(5000);
 
             var has = message.HasUserReaction("happy");
             Assert.True(has);
@@ -217,15 +227,14 @@ public void TestMessageReactions()
             manualReset.Set();
         };
         channel.SendText("a_message");
-        var reacted = manualReset.WaitOne(10000);
+        var reacted = manualReset.WaitOne(12000);
         Assert.True(reacted);
     }
 
     [Test]
     public void TestMessageReport()
     {
         var reportManualEvent = new ManualResetEvent(false);
-        channel.Join();
         chat.StartListeningForReportEvents(channel.Id);
         chat.OnReportEvent += reportEvent =>
         {
@@ -255,6 +264,7 @@ public async Task TestCreateThread()
             }
             catch (Exception e)
             {
+                Debug.WriteLine(e);
                 Console.WriteLine(e);
                 Assert.Fail();
             }
@@ -263,7 +273,7 @@ public async Task TestCreateThread()
             Assert.True(message.TryGetThread(out var threadChannel));
             message.RemoveThread();
 
-            await Task.Delay(8000);
+            await Task.Delay(12000);
 
             //TODO: temporary way to get latest message pointer since remove_thread doesn't return a new pointer
             chat.TryGetMessage(channel.Id, message.Id, out message);
@@ -273,7 +283,7 @@ public async Task TestCreateThread()
         };
         channel.SendText("thread_start_message");
 
-        var received = manualReceiveEvent.WaitOne(20000);
+        var received = manualReceiveEvent.WaitOne(30000);
         Assert.IsTrue(received);
     }
 }
diff --git a/c-sharp-chat/PubnubChatApi/PubNubChatApi.Tests/RestrictionsTests.cs b/c-sharp-chat/PubnubChatApi/PubNubChatApi.Tests/RestrictionsTests.cs
@@ -1,3 +1,4 @@
+using System.Diagnostics;
 using PubNubChatAPI.Entities;
 using PubnubChatApi.Entities.Data;
 
@@ -17,6 +18,13 @@ public void Setup()
             "restrictions_tests_user")
         );
     }
+
+    [TearDown]
+    public async Task CleanUp()
+    {
+        chat.Destroy();
+        await Task.Delay(3000);
+    }
 
     [Test]
     public async Task TestSetRestrictions()

diff --git a/c-sharp-chat/PubnubChatApi/PubNubChatApi.Tests/ThreadsTests.cs b/c-sharp-chat/PubnubChatApi/PubNubChatApi.Tests/ThreadsTests.cs
@@ -26,9 +26,18 @@ public void Setup()
         }
         channel.Join();
     }
+
+    [TearDown]
+    public async Task CleanUp()
+    {
+        channel.Leave();
+        await Task.Delay(3000);
+        chat.Destroy();
+        await Task.Delay(3000);
+    }
 
     [Test]
-    public void TestGetThreadHistory()
+    public async Task TestGetThreadHistory()
     {
         var historyReadReset = new ManualResetEvent(false);
         channel.OnMessageReceived += async message =>

diff --git a/c-sharp-chat/PubnubChatApi/PubNubChatApi.Tests/UserTests.cs b/c-sharp-chat/PubnubChatApi/PubNubChatApi.Tests/UserTests.cs
@@ -27,6 +27,15 @@ public void Setup()
         }
         channel.Join();
     }
+
+    [TearDown]
+    public async Task CleanUp()
+    {
+        channel.Leave();
+        await Task.Delay(3000);
+        chat.Destroy();
+        await Task.Delay(3000);
+    }
 
     [Test]
     public async Task TestUserActive()

diff --git a/c-sharp-chat/PubnubChatApi/PubnubChatApi.sln b/c-sharp-chat/PubnubChatApi/PubnubChatApi.sln
@@ -14,8 +14,8 @@ Global
 	GlobalSection(ProjectConfigurationPlatforms) = postSolution
 		{8D3851D4-6FD7-4DE5-9960-DA386442603E}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{8D3851D4-6FD7-4DE5-9960-DA386442603E}.Release|Any CPU.Build.0 = Release|Any CPU
-		{8D3851D4-6FD7-4DE5-9960-DA386442603E}.Debug|Any CPU.ActiveCfg = Release|Any CPU
-		{8D3851D4-6FD7-4DE5-9960-DA386442603E}.Debug|Any CPU.Build.0 = Release|Any CPU
+		{8D3851D4-6FD7-4DE5-9960-DA386442603E}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{8D3851D4-6FD7-4DE5-9960-DA386442603E}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{54ACBC4B-510A-499F-9494-24F9F90F7B67}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
 		{54ACBC4B-510A-499F-9494-24F9F90F7B67}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{54ACBC4B-510A-499F-9494-24F9F90F7B67}.Release|Any CPU.ActiveCfg = Release|Any CPU