feature(#6): this commit implements correlation support to improve tracing and observability

Author: https-richardy

Boundaries/Comanda.Stores/Source/Comanda.Stores.WebApi/Constants/Headers.cs

@@ -2,6 +2,11 @@ namespace Comanda.Stores.WebApi.Constants;
 
 public static class Headers
 {
-    public const string Authorization = "Authorization";
+    public const string Credential = "X-Credential";
+    public const string Location = "Location";
+    public const string Link = "Link";
     public const string Pagination = "X-Pagination";
+    public const string Authorization = "Authorization";
+    public const string Idempotency = "Idempotency-Key";
+    public const string Correlation = "Correlation";
 }

Boundaries/Comanda.Stores/Source/Comanda.Stores.WebApi/Extensions/HttpPipelineExtension.cs

@@ -14,6 +14,7 @@ public static void UseHttpPipeline(this IApplicationBuilder app)
         app.UseAuthentication();
         app.UseAuthorization();
 
+        app.UseCorrelationMiddleware();
         app.UseEndpoints(endpoints =>
         {
             endpoints.MapControllers();

Boundaries/Comanda.Stores/Source/Comanda.Stores.WebApi/Extensions/ObservabilityExtension.cs

@@ -24,7 +24,6 @@ public static void AddObservability(this WebApplicationBuilder builder)
                     options.Dsn = settings.Observability.SentryDsn;
                     options.TracesSampleRate = 1.0;
                     options.AttachStacktrace = true;
-                    options.Debug = true;
                 });
         });
     }

Boundaries/Comanda.Stores/Source/Comanda.Stores.WebApi/Middlewares/CorrelationMiddleware.cs

@@ -0,0 +1,29 @@
+namespace Comanda.Stores.WebApi.Middlewares;
+
+public sealed class CorrelationMiddleware(RequestDelegate next)
+{
+    public async Task InvokeAsync(HttpContext context)
+    {
+        var correlationId = context.Request.Headers[Headers.Correlation].FirstOrDefault();
+
+        if (string.IsNullOrWhiteSpace(correlationId))
+            correlationId = context.TraceIdentifier;
+
+        context.Items[Headers.Correlation] = correlationId;
+        context.Response.Headers[Headers.Correlation] = correlationId;
+
+        /* enriches the logging scope with the current correlation identifier, ensuring all logs within this request pipeline share the same identifier */
+        /* more details: https://microsoft.github.io/code-with-engineering-playbook/observability/correlation-id/ */
+
+        using (LogContext.PushProperty(Headers.Correlation, correlationId))
+        using (SentrySdk.PushScope())
+        {
+            SentrySdk.ConfigureScope(scope =>
+            {
+                scope.SetTag("correlation_id", correlationId);
+            });
+
+            await next(context);
+        }
+    }
+}

Boundaries/Comanda.Stores/Source/Comanda.Stores.WebApi/Middlewares/CorrelationMiddlewareExtension.cs

@@ -0,0 +1,10 @@
+namespace Comanda.Stores.WebApi.Middlewares;
+
+[ExcludeFromCodeCoverage(Justification = "contains only dependency injection")]
+public static class CorrelationMiddlewareExtension
+{
+    public static IApplicationBuilder UseCorrelationMiddleware(this IApplicationBuilder app)
+    {
+        return app.UseMiddleware<CorrelationMiddleware>();
+    }
+}

Boundaries/Comanda.Stores/Source/Comanda.Stores.WebApi/Usings.cs

@@ -8,6 +8,7 @@
 
 global using Comanda.Stores.WebApi.Extensions;
 global using Comanda.Stores.WebApi.Constants;
+global using Comanda.Stores.WebApi.Middlewares;
 global using Comanda.Stores.Domain.Errors;
 
 global using Comanda.Stores.Application.Payloads.Establishment;
@@ -29,4 +30,5 @@
 
 global using Scalar.AspNetCore;
 global using Serilog;
+global using Serilog.Context;
 global using FluentValidation.AspNetCore;