From f883305b3e716dda2337bdf2094d9afb3adaa381 Mon Sep 17 00:00:00 2001 From: SirLynix Date: Sat, 24 Feb 2024 20:38:42 +0100 Subject: [PATCH] Fix network unit tests --- .../Engine/Network/SocketPollerTest.cpp | 1 - tests/UnitTests/Engine/Network/TCPTest.cpp | 21 +++++++++++++------ .../Engine/Network/UdpSocketTest.cpp | 15 +++++++------ 3 files changed, 24 insertions(+), 13 deletions(-) diff --git a/tests/UnitTests/Engine/Network/SocketPollerTest.cpp b/tests/UnitTests/Engine/Network/SocketPollerTest.cpp index 48f091cc0..2beaa751b 100644 --- a/tests/UnitTests/Engine/Network/SocketPollerTest.cpp +++ b/tests/UnitTests/Engine/Network/SocketPollerTest.cpp @@ -1,5 +1,4 @@ #include -#include #include #include #include diff --git a/tests/UnitTests/Engine/Network/TCPTest.cpp b/tests/UnitTests/Engine/Network/TCPTest.cpp index b84277b2d..0064ed436 100644 --- a/tests/UnitTests/Engine/Network/TCPTest.cpp +++ b/tests/UnitTests/Engine/Network/TCPTest.cpp @@ -1,5 +1,6 @@ +#include +#include #include -#include #include #include #include @@ -41,10 +42,14 @@ SCENARIO("TCP", "[NETWORK][TCP]") { CHECK(serverToClient.EndOfStream()); - Nz::NetPacket packet(1); + Nz::ByteArray byteArray; + Nz::ByteStream packet(&byteArray); Nz::Vector3f vector123(1.f, 2.f, 3.f); packet << vector123; - REQUIRE(client.SendPacket(packet)); + + std::size_t sent; + REQUIRE(client.Send(byteArray.GetConstBuffer(), byteArray.GetSize(), &sent)); + CHECK(sent == byteArray.GetSize()); std::this_thread::sleep_for(std::chrono::milliseconds(10)); @@ -52,11 +57,15 @@ SCENARIO("TCP", "[NETWORK][TCP]") { CHECK(!serverToClient.EndOfStream()); - Nz::NetPacket resultPacket; - REQUIRE(serverToClient.ReceivePacket(&resultPacket)); + Nz::ByteArray resultPacket(byteArray.GetSize()); + std::size_t received; + REQUIRE(serverToClient.Receive(resultPacket.GetBuffer(), resultPacket.GetSize(), &received)); + CHECK(received == resultPacket.GetSize()); + + Nz::ByteStream packetOut(&resultPacket); Nz::Vector3f result; - resultPacket >> result; + packetOut >> result; CHECK(result == vector123); } diff --git a/tests/UnitTests/Engine/Network/UdpSocketTest.cpp b/tests/UnitTests/Engine/Network/UdpSocketTest.cpp index f969dc3a8..fb5b81c15 100644 --- a/tests/UnitTests/Engine/Network/UdpSocketTest.cpp +++ b/tests/UnitTests/Engine/Network/UdpSocketTest.cpp @@ -1,6 +1,7 @@ +#include +#include #include #include -#include #include #include @@ -22,19 +23,21 @@ SCENARIO("UdpSocket", "[NETWORK][UDPSOCKET]") WHEN("We send data from client") { - Nz::NetPacket packet(1); + Nz::ByteArray byteArray; + Nz::ByteStream packet(&byteArray); Nz::Vector3f vector123(1.f, 2.f, 3.f); packet << vector123; - REQUIRE(client.SendPacket(serverIP, packet)); + REQUIRE(client.Send(serverIP, byteArray.GetConstBuffer(), byteArray.GetSize(), nullptr)); THEN("We should get it on the server") { - Nz::NetPacket resultPacket; + Nz::ByteArray resultPacket(byteArray.GetSize()); Nz::IpAddress fromIp; - REQUIRE(server.ReceivePacket(&resultPacket, &fromIp)); + REQUIRE(server.Receive(resultPacket.GetBuffer(), resultPacket.GetSize(), &fromIp, nullptr)); + Nz::ByteStream packetOut(&resultPacket); Nz::Vector3f result; - resultPacket >> result; + packetOut >> result; REQUIRE(result == vector123); } }