Added TextWebSocketClientTests

Author: theSlyest

Parse.Tests/TextWebSocketClientTests.cs

@@ -0,0 +1,50 @@
+using System;
+using System.Diagnostics;
+using System.Threading;
+using System.Threading.Tasks;
+using Microsoft.VisualStudio.TestTools.UnitTesting;
+using Parse.Infrastructure.Execution;
+
+namespace Parse.Tests;
+
+[TestClass]
+public class TextWebSocketClientTests
+{
+    [TestMethod]
+    public void TestConstructor()
+    {
+        TextWebSocketClient client = new TextWebSocketClient(4096);
+        Assert.IsNotNull(client);
+
+        client.Dispose();
+    }
+
+    [TestMethod]
+    public async Task TestSendAndReceive()
+    {
+        TextWebSocketClient client = new TextWebSocketClient(32);
+        await client.OpenAsync("wss://echo.websocket.org", CancellationToken.None);
+
+        TaskCompletionSource ConnectionSignal = new TaskCompletionSource();
+        CancellationTokenSource cts = new CancellationTokenSource();
+
+        client.MessageReceived += (_, e) =>
+        {
+            if (e.Message.StartsWith("Request served by"))
+            {
+                return;
+            }
+            Assert.AreEqual("Hello world, WebSocket listening!", e.Message);
+            ConnectionSignal?.TrySetResult();
+        };
+
+        await client.SendAsync("Hello world, WebSocket listening!", cts.Token);
+        cts.CancelAfter(5000);
+        await ConnectionSignal.Task.WaitAsync(cts.Token);
+        ConnectionSignal = null;
+        await client.CloseAsync();
+        client.Dispose();
+    }
+
+    
+}

Parse/Infrastructure/Execution/TextWebSocketClient.cs

@@ -120,7 +120,7 @@ private async Task ListenForMessages(CancellationToken cancellationToken)
                 else
                 {
                     // Accumulate bytes to handle UTF-8 characters split across boundaries
-                    using var messageStream = new MemoryStream();
+                    MemoryStream messageStream = new MemoryStream();
                     messageStream.Write(buffer, 0, result.Count);
                     while (!result.EndOfMessage)
                     {

Parse/Platform/LiveQueries/ParseLiveQueryController.cs

@@ -452,7 +452,7 @@ private async Task SendAndWaitForSignalAsync(IDictionary<string, object> message
         {
             await SendMessage(message, cancellationToken);
 
-            using CancellationTokenSource cts = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken);
+            CancellationTokenSource cts = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken);
             cts.CancelAfter(Timeout);
 
             await tcs.Task.WaitAsync(cts.Token);