(#272) [.Net 9] Add HybridCache

Author: phongnguyend

src/Monolith/ClassifiedAds.Infrastructure/Caching/CachingServiceCollectionExtensions.cs

@@ -38,6 +38,10 @@ public static IServiceCollection AddCaches(this IServiceCollection services, Cac
             });
         }
 
+        services.AddHybridCache(options =>
+        {
+        });
+
         return services;
     }
 }

src/Monolith/ClassifiedAds.Infrastructure/ClassifiedAds.Infrastructure.csproj

@@ -33,9 +33,9 @@
     <PackageReference Include="Microsoft.AspNetCore.SignalR.Protocols.MessagePack" Version="9.0.1" />
     <PackageReference Include="Microsoft.Azure.AppConfiguration.AspNetCore" Version="8.0.0" />
     <PackageReference Include="Microsoft.EntityFrameworkCore" Version="9.0.1" />
+    <PackageReference Include="Microsoft.Extensions.Caching.Hybrid" Version="9.4.0" />
     <PackageReference Include="Microsoft.Extensions.Caching.Redis" Version="2.3.0" />
     <PackageReference Include="Microsoft.Extensions.Caching.SqlServer" Version="9.0.1" />
-    <PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="9.0.1" />
     <PackageReference Include="Microsoft.Extensions.Logging.AzureAppServices" Version="9.0.1" />
     <PackageReference Include="Microsoft.Extensions.Logging.EventLog" Version="9.0.1" />
     <PackageReference Include="Microsoft.Graph" Version="5.68.0" />

src/Monolith/ClassifiedAds.WebAPI/ClaimsTransformations/CustomClaimsTransformation.cs

@@ -0,0 +1,59 @@
+using Microsoft.AspNetCore.Authentication;
+using Microsoft.Extensions.Caching.Hybrid;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Security.Claims;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace ClassifiedAds.WebAPI.ClaimsTransformations;
+
+public class CustomClaimsTransformation : IClaimsTransformation
+{
+    private readonly HybridCache _cache;
+
+    public CustomClaimsTransformation(HybridCache cache)
+    {
+        _cache = cache;
+    }
+
+    public async Task<ClaimsPrincipal> TransformAsync(ClaimsPrincipal principal)
+    {
+        var identity = principal.Identities.FirstOrDefault(x => x.IsAuthenticated);
+        if (identity == null)
+        {
+            return principal;
+        }
+
+        var userClaim = principal.Claims.FirstOrDefault(x => x.Type == ClaimTypes.NameIdentifier);
+
+        if (Guid.TryParse(userClaim?.Value, out var userId))
+        {
+            var jti = principal.Claims.FirstOrDefault(x => x.Type == "jti").Value;
+            var issuedAt = principal.Claims.FirstOrDefault(x => x.Type == "iat").Value;
+
+            var cacheKey = $"permissions/{userId}/{jti}/{issuedAt}";
+
+            var permissions = await _cache.GetOrCreateAsync(cacheKey,
+                async (cancellationToken) => await GetPermissionsAsync(userId, cancellationToken),
+                tags: ["permissions", $"permissions/{userId}"]);
+
+            var claims = new List<Claim>();
+            claims.AddRange(permissions.Select(p => new Claim("Permission", p)));
+            claims.AddRange(principal.Claims);
+
+            var newIdentity = new ClaimsIdentity(claims, identity.AuthenticationType);
+            return new ClaimsPrincipal(newIdentity);
+        }
+
+        return principal;
+    }
+
+    private Task<List<string>> GetPermissionsAsync(Guid userId, CancellationToken cancellationToken)
+    {
+        // TODO: Get from Db
+        var claims = new List<string>();
+        return Task.FromResult(claims);
+    }
+}

src/Monolith/ClassifiedAds.WebAPI/Program.cs

@@ -15,10 +15,12 @@
 using ClassifiedAds.Infrastructure.Web.ExceptionHandlers;
 using ClassifiedAds.Persistence;
 using ClassifiedAds.WebAPI.Authorization;
+using ClassifiedAds.WebAPI.ClaimsTransformations;
 using ClassifiedAds.WebAPI.ConfigurationOptions;
 using ClassifiedAds.WebAPI.Hubs;
 using ClassifiedAds.WebAPI.RateLimiterPolicies;
 using ClassifiedAds.WebAPI.Tenants;
+using Microsoft.AspNetCore.Authentication;
 using Microsoft.AspNetCore.Authentication.JwtBearer;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.DataProtection;
@@ -133,6 +135,8 @@
     };
 });
 
+services.AddSingleton<IClaimsTransformation, CustomClaimsTransformation>();
+
 services.AddAuthorizationPolicies(Assembly.GetExecutingAssembly(), AuthorizationPolicyNames.GetPolicyNames());
 
 services.AddRateLimiter(options =>