feat: request/response testing

Author: insthync

SimpleNetworkManager.NET.Tests/Messages/TestRequestMessage.cs

@@ -0,0 +1,17 @@
+using Insthync.SimpleNetworkManager.NET.Messages;
+using MessagePack;
+
+namespace Insthync.SimpleNetworkManager.NET.Tests.Messages
+{
+    [MessagePackObject]
+    public class TestRequestMessage : BaseRequestMessage
+    {
+        [Key(1)]
+        public string? stringVal;
+
+        public override uint GetMessageType()
+        {
+            return 2;
+        }
+    }
+}

SimpleNetworkManager.NET.Tests/Messages/TestRequestMessageHandler.cs

@@ -0,0 +1,18 @@
+using Cysharp.Threading.Tasks;
+using Insthync.SimpleNetworkManager.NET.Messages;
+using Insthync.SimpleNetworkManager.NET.Network;
+
+namespace Insthync.SimpleNetworkManager.NET.Tests.Messages
+{
+    public class TestRequestMessageHandler : BaseRequestMessageHandler<TestRequestMessage, TestResponseMessage>
+    {
+        protected override UniTask<TestResponseMessage> HandleRequestAsync(BaseClientConnection clientConnection, TestRequestMessage request)
+        {
+            return UniTask.FromResult(new TestResponseMessage()
+            {
+                Success = true,
+                stringVal = request.stringVal + '_' + request.stringVal,
+            });
+        }
+    }
+}

SimpleNetworkManager.NET.Tests/Messages/TestResponseMessage.cs

@@ -0,0 +1,17 @@
+using Insthync.SimpleNetworkManager.NET.Messages;
+using MessagePack;
+
+namespace Insthync.SimpleNetworkManager.NET.Tests.Messages
+{
+    [MessagePackObject]
+    public class TestResponseMessage : BaseResponseMessage
+    {
+        [Key(3)]
+        public string? stringVal;
+
+        public override uint GetMessageType()
+        {
+            return 3;
+        }
+    }
+}

SimpleNetworkManager.NET.Tests/Network/TcpTransport/TcpTransportTests.cs

@@ -253,5 +253,36 @@ public async Task TestClientMaxConnections()
 
             Assert.False(server.IsRunning);
         }
+
+        [Fact]
+        public async Task TestRequestResponse()
+        {
+            var server = new TcpNetworkServer(_loggerFactoryMock.Object);
+            var serverTestMsgHandler = new TestRequestMessageHandler();
+            server.MessageRouterService.RegisterHandler(serverTestMsgHandler);
+            var serverCancelSrc = new CancellationTokenSource();
+            await server.StartAsync(7893, serverCancelSrc.Token);
+
+            var client = new TcpNetworkClient(_loggerFactoryMock.Object);
+            var clientCancelSrc = new CancellationTokenSource();
+            await client.ConnectAsync("127.0.0.1", 7893, clientCancelSrc.Token);
+
+            Assert.True(server.IsRunning);
+            Assert.True(client.IsConnected);
+
+            Assert.NotNull(client.ClientConnection);
+            var response = await client.SendRequestAsync<TestResponseMessage>(new TestRequestMessage()
+            {
+                stringVal = "Hello",
+            });
+
+            Assert.Equal("Hello_Hello", response.stringVal);
+
+            await client.DisconnectAsync();
+            await server.StopAsync();
+
+            Assert.False(server.IsRunning);
+            Assert.False(client.IsConnected);
+        }
     }
 }