merge pull request #7 from https-richardy/feature/06-implement-correlation-support

[#6] - implements correlation support

Author: https-richardy

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

@@ -8,4 +8,5 @@ public static class Headers
     public const string Pagination = "X-Pagination";
     public const string Authorization = "Authorization";
     public const string Idempotency = "Idempotency-Key";
+    public const string Correlation = "Correlation";
 }

Boundaries/Comanda.Orchestrator/Source/Comanda.Orchestrator.WebApi/Extensions/ClientsExtension.cs

@@ -9,6 +9,7 @@ public static void AddHttpClients(this IServiceCollection services)
 
         // registers the header propagation service
         // essential for receiving an authenticated request and forwarding it to another service
+        services.AddTransient<CorrelationInterceptor>();
         services.AddHeaderPropagation(options =>
         {
             options.Headers.Add(Headers.Authorization);
@@ -63,14 +64,27 @@ public static void AddHttpClients(this IServiceCollection services)
         });
 
         customersClient.AddHeaderPropagation();
+        customersClient.AddHttpMessageHandler<CorrelationInterceptor>();
+
         ownersClient.AddHeaderPropagation();
+        ownersClient.AddHttpMessageHandler<CorrelationInterceptor>();
 
         paymentsClient.AddHeaderPropagation();
+        paymentsClient.AddHttpMessageHandler<CorrelationInterceptor>();
+
         storesClient.AddHeaderPropagation();
+        storesClient.AddHttpMessageHandler<CorrelationInterceptor>();
+
         productsClient.AddHeaderPropagation();
+        productsClient.AddHttpMessageHandler<CorrelationInterceptor>();
 
         subscriptionsClient.AddHeaderPropagation();
+        subscriptionsClient.AddHttpMessageHandler<CorrelationInterceptor>();
+
         ordersClient.AddHeaderPropagation();
+        ordersClient.AddHttpMessageHandler<CorrelationInterceptor>();
+
         credentialsClient.AddHeaderPropagation();
+        credentialsClient.AddHttpMessageHandler<CorrelationInterceptor>();
     }
 }

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

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

Boundaries/Comanda.Orchestrator/Source/Comanda.Orchestrator.WebApi/Interceptors/CorrelationInterceptor.cs

@@ -0,0 +1,17 @@
+namespace Comanda.Orchestrator.WebApi.Interceptors;
+
+public sealed class CorrelationInterceptor(IHttpContextAccessor accessor) : DelegatingHandler
+{
+    protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
+    {
+        var correlation = accessor.HttpContext?.Items[Headers.Correlation]?.ToString();
+
+        if (!string.IsNullOrWhiteSpace(correlation))
+        {
+            request.Headers.Remove(Headers.Correlation);
+            request.Headers.Add(Headers.Correlation, correlation);
+        }
+
+        return await base.SendAsync(request, cancellationToken);
+    }
+}

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

@@ -0,0 +1,29 @@
+namespace Comanda.Orchestrator.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.Orchestrator/Source/Comanda.Orchestrator.WebApi/Middlewares/CorrelationMiddlewareExtension.cs

@@ -0,0 +1,10 @@
+namespace Comanda.Orchestrator.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.Orchestrator/Source/Comanda.Orchestrator.WebApi/Usings.cs

@@ -21,6 +21,7 @@
 global using Comanda.Orchestrator.WebApi.Extensions;
 global using Comanda.Orchestrator.WebApi.Constants;
 global using Comanda.Orchestrator.WebApi.Middlewares;
+global using Comanda.Orchestrator.WebApi.Interceptors;
 global using Comanda.Orchestrator.WebApi.Providers;
 
 global using Comanda.Orchestrator.Application.Payloads.Payments;
@@ -38,5 +39,6 @@
 
 global using Scalar.AspNetCore;
 global using Serilog;
+global using Serilog.Context;
 global using FluentValidation.AspNetCore;
 

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

@@ -0,0 +1,12 @@
+namespace Comanda.Orders.WebApi.Constants;
+
+public static class Headers
+{
+    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.Orders/Source/Comanda.Orders.WebApi/Extensions/HttpPipelineExtension.cs

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

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

@@ -0,0 +1,29 @@
+namespace Comanda.Orders.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);
+        }
+    }
+}