diff --git a/AsbCloudDbDemoData/ControllerLoadTester.cs b/AsbCloudDbDemoData/ControllerLoadTester.cs index 7eccf6bd..9c07a025 100644 --- a/AsbCloudDbDemoData/ControllerLoadTester.cs +++ b/AsbCloudDbDemoData/ControllerLoadTester.cs @@ -33,20 +33,13 @@ namespace AsbCloudDevOperations private async Task SendRequestsAsync(int i, CancellationToken token) { - var json = JsonSerializer.Serialize(new List() - { - new TelemetryDataSaubDto() - }); - - var stringContent = new StringContent(json, Encoding.UTF8, - "application/json"); var uid = $"123123_1"; Console.WriteLine($"Sending telemetry info with uid: {uid}"); var tInfoUri = new Uri($"http://localhost:5000/api/telemetry/{uid}/info"); - var infoResponse = await client.PostAsync(tInfoUri, stringContent, token); + var infoResponse = await client.PostAsync(tInfoUri, MakeTelemetryInfoContent(), token); Console.WriteLine($"Передана telemetry info с: {infoResponse.StatusCode}"); @@ -54,10 +47,31 @@ namespace AsbCloudDevOperations { await Task.Delay(rand.Next(1000, 5000), token); var dataSaubUri = new Uri($"http://localhost:5000/api/telemetryDataSaub/{uid}"); - var saubResponse = await client.PostAsync(dataSaubUri, stringContent, token); + var saubResponse = await client.PostAsync(dataSaubUri, MakeDataSaubContent(), token); Console.WriteLine(saubResponse.StatusCode); } } + + private static StringContent MakeTelemetryInfoContent() + { + var json = JsonSerializer.Serialize(new TelemetryInfoDto{ Cluster = "Cluster" }); + + var stringContent = new StringContent(json, Encoding.UTF8, + "application/json"); + return stringContent; + } + + private static StringContent MakeDataSaubContent() + { + var json = JsonSerializer.Serialize(new List() + { + new TelemetryDataSaubDto() + }); + + var stringContent = new StringContent(json, Encoding.UTF8, + "application/json"); + return stringContent; + } } }