Outbox pattern implementation

Author: andrey-serdyuk

Directory.Build.props

@@ -4,7 +4,7 @@
 		<ImplicitUsings>enable</ImplicitUsings>
 		<Nullable>enable</Nullable>
 		<IsPackable>true</IsPackable>
-		<Version>2.2.73</Version>
+		<Version>2.2.88</Version>
 		<Authors>Andrey Serdyuk</Authors>
 		<Company>TaskHub</Company>
 		<Title>TaskHub.Shared - Reusable Primitives for .NET Microservices</Title>

README.md

@@ -19,8 +19,8 @@ TaskHub.Shared contains the fundamental components and patterns used across all
 ## Persistence
 - **TaskHub.Shared.Persistence.Abstractions** — Interfaces for read/write repositories, unit of work, and persistence contracts.
 - **TaskHub.Shared.Persistence.EntityFramework** — EntityFramework Core helpers, base configurations, and interceptors for database integration.
+- **TaskHub.Shared.Persistence.Outbox** - Outbox pattern abstractions.
 - **TaskHub.Shared.Redis** — Integration with Redis for caching and distributed state management.
-- **TaskHub.Shared.Persistence.Outbox** - Outbox pattern implementation for reliable event publishing.
 
 ## Authorization
 - **TaskHub.Shared.Authorization.Abstractions** — Authorization contracts, roles/permissions abstractions, and policies shared across services.

TaskHub.Observability.Traces/Service/ITracesService.cs

@@ -6,6 +6,7 @@ namespace TaskHub.Observability.Traces.Service;
 
 public interface ITracesService : IService
 {
+    string CorrelationId { get; }
     Activity? Current { get; }
     Activity? StartSpan(string spanName, [CallerMemberName] string caller = "");
     Activity? StartSpan<T>(string spanName, T data, [CallerMemberName] string caller = "");

TaskHub.Observability.Traces/Service/TracesService.cs

@@ -1,16 +1,20 @@
-using System.Diagnostics;
+using Microsoft.AspNetCore.Http;
+using Microsoft.Extensions.Primitives;
+using System.Diagnostics;
 using System.Reflection;
 using System.Runtime.CompilerServices;
 using TaskHub.Shared.Refactoring.Abstractions;
 
 namespace TaskHub.Observability.Traces.Service;
 
-public sealed class TracesService(ServiceInfo appInfo) : ITracesService
+public sealed class TracesService(ServiceInfo appInfo, IHttpContextAccessor http) : ITracesService
 {
     private readonly ActivitySource Source = new(appInfo.Name);
 
     public Activity? Current => Activity.Current;
 
+    public string CorrelationId => ResolveCorrelationId();
+
     public Activity? StartSpan(string spanName, [CallerMemberName] string caller = "")
     {
         var act = Source.StartActivity(spanName, ActivityKind.Internal);
@@ -89,4 +93,32 @@ private static void SetTagTyped(Activity? act, string key, object value)
                 break;
         }
     }
-}
+
+    private static readonly string[] KnownHeaders = 
+    [
+        "X-Correlation-Id",
+        "Correlation-Id",
+        "X-Request-Id",
+        "Request-Id",
+        "traceparent",
+        "uber-trace-id",
+        "x-b3-traceid",
+        "x-b3-spanid",
+        "X-Amzn-Trace-Id",
+        "X-Cloud-Trace-Context",
+    ];
+
+    public string ResolveCorrelationId()
+    {
+        foreach (var h in KnownHeaders)
+        {
+            if (http.HttpContext.Request.Headers.TryGetValue(h, out var value) && !StringValues.IsNullOrEmpty(value))
+            {
+                return value.ToString();
+            }
+        }
+
+        return Activity.Current?.TraceId.ToString()
+            ?? Guid.NewGuid().ToString();
+    }
+}

TaskHub.Observability.Traces/TaskHub.Observability.Traces.csproj

@@ -9,6 +9,10 @@
 		<Nullable>enable</Nullable>
 	</PropertyGroup>
 
+	<ItemGroup>
+	  <PackageReference Include="Microsoft.AspNetCore.Http" Version="2.3.0" />
+	</ItemGroup>
+
 	<ItemGroup>
 	  <ProjectReference Include="..\TaskHub.Shared.Refactoring.Implementation\TaskHub.Shared.Refactoring.Implementation.csproj" />
 	  <ProjectReference Include="..\TaskHub.Shared.Services.Abstractions\TaskHub.Shared.Services.Abstractions.csproj" />

TaskHub.Shared.Authorization.Abstractions/IGuidUserService.cs

@@ -0,0 +1,3 @@
+namespace TaskHub.Shared.Authorization.Abstractions;
+
+public interface IGuidUserService : IUserService<Guid>;

TaskHub.Shared.Authorization.Abstractions/IIntUserService.cs

@@ -0,0 +1,3 @@
+namespace TaskHub.Shared.Authorization.Abstractions;
+
+public interface IIntUserService : IUserService<int>;

TaskHub.Shared.Authorization.Abstractions/IStringUserService.cs

@@ -0,0 +1,3 @@
+namespace TaskHub.Shared.Authorization.Abstractions;
+
+public interface IStringUserService : IUserService<string>;

TaskHub.Shared.Authorization.Abstractions/IUserService.cs

@@ -1,9 +1,7 @@
-using TaskHub.Shared.Refactoring.Abstractions;
-using TaskHub.Shared.Services.Abstractions;
+using TaskHub.Shared.Services.Abstractions;
 
 namespace TaskHub.Shared.Authorization.Abstractions;
 
-[Unresolvable]
 public interface IUserService<T> : IService where T : IEquatable<T>
 {
     T UserId { get; }

TaskHub.Shared.Authorization.Identity/Bootstrap/AuthorizationBootsrap.cs

@@ -1,11 +1,9 @@
 using Microsoft.AspNetCore.Authentication.JwtBearer;
-using Microsoft.AspNetCore.Http;
 using Microsoft.Extensions.Caching.Distributed;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.IdentityModel.Tokens;
 using System.Security.Claims;
 using TaskHub.Shared.Authorization.Abstractions;
-using TaskHub.Shared.Authorization.Identity.Exceptions;
 using TaskHub.Shared.Authorization.Identity.Options;
 using TaskHub.Shared.Authorization.Identity.Services;
 
@@ -17,6 +15,11 @@ public static void AddAppAuthorization(this IServiceCollection services, Action<
     {
         var options = new JwtOptions();
         action(options);
+        services.AddSingleton(options);
+        services.AddScoped<IGuidUserService, GuidUserService>();
+        services.AddScoped<IIntUserService, IntUserService>();
+        services.AddScoped<IGuidUserService, GuidUserService>();
+
         services.AddAuthentication(o =>
         {
             o.DefaultAuthenticateScheme = JwtBearerDefaults.AuthenticationScheme;
@@ -69,15 +72,4 @@ public static void AddAppAuthorization(this IServiceCollection services, Action<
             };
         });
     }
-
-    public static void AddAppUserService<T>(this IServiceCollection services, Func<ClaimsPrincipal, T> resolveUserId)
-    where T : IEquatable<T>
-    {
-        services.AddScoped<IUserService<T>>(sp =>
-        {
-            var http = sp.GetRequiredService<IHttpContextAccessor>();
-            var user = http.HttpContext?.User ?? throw new AuthorizationException("No HttpContext");
-            return new UserService<T>(resolveUserId(user));
-        });
-    }
 }