70783d34ce198e3d82a13c9ecf0aa9771d8646c2

Author: doghappy

src/SocketIOClient.UnitTest/ProcessorTests/EngineIOProtocolProcessorTest.cs

@@ -22,5 +22,37 @@ public void Open()
             Assert.AreEqual(typeof(OpenedProcessor), processor.NextProcessor.GetType());
             mockOpenedHandler.Verify(x => x(It.IsAny<string>(), It.IsAny<int>(), It.IsAny<int>()), Times.Once());
         }
+
+        [TestMethod]
+        public void Ping()
+        {
+            var mockPingHandler = new Mock<OnPing>();
+
+            var processor = new EngineIOProtocolProcessor();
+            processor.Process(new MessageContext
+            {
+                Message = "2",
+                PingHandler = mockPingHandler.Object
+            });
+
+            Assert.AreEqual(typeof(PingProcessor), processor.NextProcessor.GetType());
+            mockPingHandler.Verify(x => x(), Times.Once());
+        }
+
+        [TestMethod]
+        public void Pong()
+        {
+            var mockPongHandler = new Mock<OnPong>();
+
+            var processor = new EngineIOProtocolProcessor();
+            processor.Process(new MessageContext
+            {
+                Message = "3",
+                PongHandler = mockPongHandler.Object
+            });
+
+            Assert.AreEqual(typeof(PongProcessor), processor.NextProcessor.GetType());
+            mockPongHandler.Verify(x => x(), Times.Once());
+        }
     }
 }

src/SocketIOClient.UnitTest/ProcessorTests/EventProcessorTest.cs

@@ -0,0 +1,62 @@
+using Microsoft.VisualStudio.TestTools.UnitTesting;
+using SocketIOClient.Processors;
+using System.Collections.Generic;
+using System.Text.Json;
+
+namespace SocketIOClient.UnitTest.ProcessorTests
+{
+    [TestClass]
+    public class EventProcessorTest
+    {
+        [TestMethod]
+        public void TestWithoutNamespace()
+        {
+            int packetId = 0;
+            string eventName = null;
+            List<JsonElement> array = null;
+
+            var processor = new EventProcessor();
+            processor.Process(new MessageContext
+            {
+                Message = "[\"hi\",\"vvv\"]",
+                EventReceivedHandler = (id, name, arr) =>
+                {
+                    packetId = id;
+                    eventName = name;
+                    array = arr;
+                }
+            });
+
+            Assert.AreEqual(0, packetId);
+            Assert.AreEqual("hi", eventName);
+            Assert.AreEqual(1, array.Count);
+            Assert.AreEqual("vvv", array[0].GetString());
+        }
+
+        [TestMethod]
+        public void TestWithNamespace()
+        {
+            int packetId = 0;
+            string eventName = null;
+            List<JsonElement> array = null;
+
+            var processor = new EventProcessor();
+            processor.Process(new MessageContext
+            {
+                Namespace = "/ms",
+                Message = "/ms,[\"hi\",\"vvv\"]",
+                EventReceivedHandler = (id, name, arr) =>
+                {
+                    packetId = id;
+                    eventName = name;
+                    array = arr;
+                }
+            });
+
+            Assert.AreEqual(0, packetId);
+            Assert.AreEqual("hi", eventName);
+            Assert.AreEqual(1, array.Count);
+            Assert.AreEqual("vvv", array[0].GetString());
+        }
+    }
+}

src/SocketIOClient.UnitTest/ProcessorTests/OpenedProcessorTest.cs

@@ -0,0 +1,33 @@
+using Microsoft.VisualStudio.TestTools.UnitTesting;
+using SocketIOClient.Processors;
+
+namespace SocketIOClient.UnitTest.ProcessorTests
+{
+    [TestClass]
+    public class OpenedProcessorTest
+    {
+        [TestMethod]
+        public void TestOpenedProcessor()
+        {
+            string sid = null;
+            int pingInterval = 0;
+            int pingTimeout = 0;
+
+            var processor = new OpenedProcessor();
+            processor.Process(new MessageContext
+            {
+                Message = "{\"sid\":\"6lV4Ef7YOyGF-5dCBvKy\",\"upgrades\":[],\"pingInterval\":10000,\"pingTimeout\":5000}",
+                OpenedHandler = (id, interval, timeout) =>
+                {
+                    sid = id;
+                    pingInterval = interval;
+                    pingTimeout = timeout;
+                }
+            });
+
+            Assert.AreEqual("6lV4Ef7YOyGF-5dCBvKy", sid);
+            Assert.AreEqual(10000, pingInterval);
+            Assert.AreEqual(5000, pingTimeout);
+        }
+    }
+}