mirror of
https://github.com/DarkflameUniverse/DarkflameServer.git
synced 2026-10-02 19:03:43 +00:00
13ad679df1
TrafficStats keeps packets and bytes in and out per second and the busiest packet and game message types. dServer counts at its send and receive calls and adds RakNet's connection statistics (datagrams, resends, ping); the report goes to master as SERVER_TRAFFIC (appended), which passes it to the dashboard. Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
57 lines
2.2 KiB
C++
57 lines
2.2 KiB
C++
#include <gtest/gtest.h>
|
|
|
|
#include "master/ServerTraffic.h"
|
|
|
|
using namespace TrafficStats;
|
|
|
|
TEST(ServerTrafficTest, ServerTrafficRoundTrips) {
|
|
ServerTraffic sent;
|
|
sent.serverType = ServiceType::WORLD;
|
|
sent.zoneId = 1100;
|
|
sent.instanceId = 3;
|
|
Second second{ .time = 1700000000, .packetsIn = 5, .packetsOut = 9, .bytesIn = 500, .bytesOut = 9000, .httpRequests = 2 };
|
|
second.httpStatus[1] = 2;
|
|
second.httpLatency.Add(1200);
|
|
second.httpLatency.Add(30000);
|
|
sent.report.seconds = { second, Second{ .time = 1700000001 } };
|
|
sent.report.messages = { MessageCount{ MessageKey{ true, 5, 12, 1234 }, 7, 700 } };
|
|
RouteStats route{ .route = "GET /api/players/:id", .count = 2, .bytesOut = 99 };
|
|
route.status[1] = 2;
|
|
route.latency.Add(800, 2);
|
|
sent.report.routes = { route };
|
|
sent.report.link = { 12, 100, 90, 10000, 9000, 3, 1, 42 };
|
|
sent.report.gauges = { { "workers_busy", 2.0 } };
|
|
|
|
RakNet::BitStream stream;
|
|
sent.WritePacket(stream);
|
|
LUBitStream header;
|
|
ASSERT_TRUE(header.ReadHeader(stream));
|
|
EXPECT_EQ(header.internalPacketID, static_cast<uint32_t>(MessageType::Master::SERVER_TRAFFIC));
|
|
ServerTraffic got;
|
|
ASSERT_TRUE(got.Deserialize(stream));
|
|
EXPECT_EQ(got.serverType, ServiceType::WORLD);
|
|
EXPECT_EQ(got.zoneId, 1100u);
|
|
EXPECT_EQ(got.instanceId, 3u);
|
|
ASSERT_EQ(got.report.seconds.size(), 2u);
|
|
EXPECT_EQ(got.report.seconds[0].bytesOut, 9000u);
|
|
EXPECT_EQ(got.report.seconds[0].httpStatus[1], 2u);
|
|
EXPECT_EQ(got.report.seconds[0].httpLatency.Count(), 2u);
|
|
EXPECT_EQ(got.report.seconds[0].httpLatency.Sum(), 31200u);
|
|
ASSERT_EQ(got.report.messages.size(), 1u);
|
|
EXPECT_EQ(got.report.messages[0].key, (MessageKey{ true, 5, 12, 1234 }));
|
|
ASSERT_EQ(got.report.routes.size(), 1u);
|
|
EXPECT_EQ(got.report.routes[0].route, "GET /api/players/:id");
|
|
EXPECT_EQ(got.report.routes[0].latency.Count(), 2u);
|
|
EXPECT_EQ(got.report.link.averagePingMs, 42u);
|
|
EXPECT_EQ(got.report.link.connections, 12u);
|
|
ASSERT_EQ(got.report.gauges.size(), 1u);
|
|
EXPECT_EQ(got.report.gauges[0].first, "workers_busy");
|
|
|
|
// Truncated reports are refused
|
|
RakNet::BitStream partial(stream.GetData(), stream.GetNumberOfBytesUsed() - 3, true);
|
|
LUBitStream skip;
|
|
ASSERT_TRUE(skip.ReadHeader(partial));
|
|
ServerTraffic broken;
|
|
EXPECT_FALSE(broken.Deserialize(partial));
|
|
}
|