Update

Author: KhanbalaRashidov

SystemMiddleEarth/Kahin.Common/Entities/ReferenceDocumentId.cs

@@ -5,10 +5,7 @@ public struct ReferenceDocumentId
     public int Head { get; set; }
     public int Source { get; set; }
     public Guid Stamp { get; set; }
-    public override readonly string ToString()
-    {
-        return $"{Head}-{Source}-{Stamp}";
-    }
+    public override readonly string ToString() => $"{Head}-{Source}-{Stamp}";
     public static ReferenceDocumentId Parse(string input)
     {
         if (string.IsNullOrWhiteSpace(input))

SystemMiddleEarth/Kahin.Common/Requests/RedisPayload.cs

@@ -13,10 +13,8 @@ public class RedisPayload
     public EventType EventType { get; set; }
     public TimeSpan ReportExpireTime { get; set; }
 
-    override public string ToString()
-    {
-        return string.Format($"TraceId: {TraceId},EventType: {EventType}, ReferenceDocumentId: {DocumentId}");
-    }
+    public override string ToString() 
+        => string.Format($"TraceId: {TraceId},EventType: {EventType}, ReferenceDocumentId: {DocumentId}");
 
     public static RedisPayload Default() => new()
     {

SystemMiddleEarth/Kahin.EventHost/ServiceController.cs

@@ -8,6 +8,7 @@ public static async Task<bool> IsReportingServiceAlive(HttpClient client, ILogge
     {
         logger.LogInformation("Health check for {Address}", client.BaseAddress);
         var response = await client.GetAsync("/health");
+
         return response.IsSuccessStatusCode;
     }
 }

SystemMiddleEarth/Kahin.EventHost/Worker.cs

@@ -9,10 +9,9 @@
 namespace Kahin.EventHost;
 
 public class Worker(
-    IRedisService redisService
-        , HomeGatewayServiceClient httpGatewayClient
-        , ILogger<Worker> logger)
-        : BackgroundService
+          IRedisService redisService,
+          HomeGatewayServiceClient httpGatewayClient,
+          ILogger<Worker> logger) : BackgroundService
 {
     private readonly IRedisService _redisService = redisService;
     private readonly HomeGatewayServiceClient _httpGatewayClient = httpGatewayClient;

SystemMiddleEarth/Kahin.MQ/RedisService.cs

@@ -34,6 +34,7 @@ public async Task<RedisPayload> Peek(string streamName)
         {
             var jsonPayload = entries[0].Values[0].Value;
             var payload = JsonSerializer.Deserialize<RedisPayload>(jsonPayload);
+
             return payload ?? RedisPayload.Default();
         }
 
@@ -49,6 +50,7 @@ public async Task<RedisPayload> Pop(string streamName)
             await _db.StreamDeleteAsync(streamName, [entries[0].Id]);
 
             var payload = JsonSerializer.Deserialize<RedisPayload>(jsonPayload);
+
             return payload ?? RedisPayload.Default();
         }
 

SystemMiddleEarth/Kahin.Service.ReportingGateway/LoggingExtensions.cs

@@ -6,8 +6,7 @@ namespace Kahin.Service.ReportingGateway;
 public static class LoggingExtensions
 {
     public static LoggerConfiguration UseElasticsearch(this LoggerConfiguration loggerConfiguration, string systemName, string environmentName)
-    {
-        return loggerConfiguration
+        => loggerConfiguration
             .Enrich.FromLogContext()
             .Enrich.WithProperty("System", systemName)
             .Enrich.WithProperty("Environment", environmentName)
@@ -20,5 +19,4 @@ public static LoggerConfiguration UseElasticsearch(this LoggerConfiguration logg
                 BatchAction = ElasticOpType.Create,
                 ModifyConnectionSettings = x => x.ServerCertificateValidationCallback((sender, cert, chain, errors) => true)
             });
-    }
 }

SystemSergeant/JudgeMiddleware/InputOutputBehavior.cs

@@ -39,6 +39,7 @@ private static async Task<string> FormatRequest(HttpRequest request)
         await body.ReadAsync(buffer);
         var bodyAsText = Encoding.UTF8.GetString(buffer);
         request.Body.Seek(0, SeekOrigin.Begin);
+
         return $"{request.Scheme} {request.Host}{request.Path} {request.QueryString} {bodyAsText}";
     }
 
@@ -47,6 +48,7 @@ private static async Task<string> FormatResponse(HttpResponse response)
         response.Body.Seek(0, SeekOrigin.Begin);
         var text = await new StreamReader(response.Body).ReadToEndAsync();
         response.Body.Seek(0, SeekOrigin.Begin);
+
         return $"StatusCode: {response.StatusCode}, Body: {text}";
     }
 }

SystemSergeant/Resistance/Inconsistency/DataInconsistencyBehavior.cs

@@ -7,10 +7,10 @@
 
 namespace Resistance.Inconsistency;
 public class DataInconsistencyBehavior(
-    RequestDelegate next
-    , DataInconsistencyProbability inconsistencyProbability
-    , IOptionsMonitor<ResistanceFlags> optionsMonitor
-    , ILogger<DataInconsistencyBehavior> logger)
+      RequestDelegate next,
+      DataInconsistencyProbability inconsistencyProbability,
+      IOptionsMonitor<ResistanceFlags> optionsMonitor,
+      ILogger<DataInconsistencyBehavior> logger)
 {
     private readonly RequestDelegate _next = next;
     private readonly Random _random = new();
@@ -75,6 +75,7 @@ private string AddSomething(string originalData)
         catch (Exception ex)
         {
             _logger.LogError(ex, "Error while adding extra json data.");
+
             return originalData;
         }
     }

SystemSergeant/Resistance/Latency/LatencyBehavior.cs

@@ -5,7 +5,11 @@
 
 namespace Resistance.Latency;
 
-public class LatencyBehavior(RequestDelegate next, LatencyPeriod period, ILogger<LatencyBehavior> logger, IOptionsMonitor<ResistanceFlags> optionsMonitor)
+public class LatencyBehavior(
+    RequestDelegate next,
+    LatencyPeriod period,
+    ILogger<LatencyBehavior> logger,
+    IOptionsMonitor<ResistanceFlags> optionsMonitor)
 {
     private readonly RequestDelegate _next = next;
     private readonly Random _random = new();

SystemSergeant/Resistance/NetworkFailure/NetworkFailureBehavior.cs

@@ -7,16 +7,17 @@
 namespace Resistance.NetworkFailure;
 
 public class NetworkFailureBehavior(
-    RequestDelegate next
-    , NetworkFailureProbability failureProbability
-    , IOptionsMonitor<ResistanceFlags> optionsMonitor
-    , ILogger<NetworkFailureBehavior> logger)
+    RequestDelegate next,
+    NetworkFailureProbability failureProbability,
+    IOptionsMonitor<ResistanceFlags> optionsMonitor,
+    ILogger<NetworkFailureBehavior> logger)
 {
     private readonly RequestDelegate _next = next;
     private readonly Random _random = new();
     private readonly int _failureProbability = (int)failureProbability;
     private readonly ILogger<NetworkFailureBehavior> _logger = logger;
     private readonly IOptionsMonitor<ResistanceFlags> _optionsMonitor = optionsMonitor;
+
     public async Task InvokeAsync(HttpContext context)
     {
         if (!_optionsMonitor.CurrentValue.NetworkFailureIsActive)

SystemSergeant/Resistance/Outage/OutageBehavior.cs

@@ -7,10 +7,10 @@
 namespace Resistance.Outage;
 
 public class OutageBehavior(
-    RequestDelegate next
-    , ILogger<OutageBehavior> logger
-    , IOptionsMonitor<ResistanceFlags> optionsMonitor
-    , OutagePeriod outagePeriod)
+    RequestDelegate next,
+    ILogger<OutageBehavior> logger,
+    IOptionsMonitor<ResistanceFlags> optionsMonitor,
+    OutagePeriod outagePeriod)
 {
     private readonly RequestDelegate _next = next;
     private static bool _serviceOutage = false;