V3.10 create cqrs vertical slice minimal api

.gitignore

@@ -121,3 +121,5 @@
 /BlogWebApp/Aspire/Blog.Aspire/Blog.Aspire.AppHost/bin/Debug/net10.0
 /BlogWebApp/BlogMinimalApi/bin/Debug/net10.0
 /BlogWebApp/BlogMinimalApi/obj
+/BlogWebApp/BlogVerticalSliceCQRSMinimalApi/bin/Debug/net10.0
+/BlogWebApp/BlogVerticalSliceCQRSMinimalApi/obj

BlogWebApp/BlogMinimalApi/ApiEndpoints/AccountsApiEndpoints.cs

@@ -82,8 +82,12 @@ public void InstallApiRoutes(WebApplication app)
                         ? Results.BadRequest("Invalid name or password") 
                         : Results.Ok(jwt);
                 })
-            .Produces<string>()
-            .Produces<string>(400);
+            .WithName("Login")
+            .Produces(200)
+            .Produces<string>(400)
+            .WithSummary("Login")
+            .WithDescription("Login")
+            .HasApiVersion(1.0);
 
 
         // Register
@@ -118,8 +122,12 @@ public void InstallApiRoutes(WebApplication app)
 
                     return Results.NoContent();
                 })
+            .WithName("Register")
             .Produces(204)
-            .Produces<IdentityResult>(400);
+            .Produces<IdentityResult>(400)
+            .WithSummary("Register")
+            .WithDescription("Register")
+            .HasApiVersion(1.0);
 
         // -------------------------
         // PRIVATE ENDPOINTS

BlogWebApp/BlogMinimalApi/ApiEndpoints/CommentsApiEndpoints.cs

@@ -148,8 +148,12 @@ public void InstallApiRoutes(WebApplication app)
                     Id = comment.Id
                 });
             })
+            .WithName("CreateComment")
             .Produces<CreatedResponse<int>>(201)
-            .Produces(400);
+            .Produces(400)
+            .WithSummary("Create comment")
+            .WithDescription("Create comment")
+            .HasApiVersion(1.0);
 
 
         // Edit Comment

BlogWebApp/BlogMinimalApi/ApiEndpoints/HealthCheckApiEndpoints.cs

@@ -31,7 +31,7 @@ public void InstallApiRoutes(WebApplication app)
         publicGroup.MapGet("/health", async (HealthCheckService healthCheckService) =>
             {
                 var report = await healthCheckService.CheckHealthAsync();
-
+                
                 var response = new
                 {
                     Status = report.Status.ToString(),

BlogWebApp/BlogMinimalApi/ApiEndpoints/MessagesApiEndpoints.cs

@@ -130,8 +130,12 @@ public void InstallApiRoutes(WebApplication app)
 
                     return Results.Created($"/messages/{message.Id}", null);
                 })
-            .Produces(201)
-            .Produces(400);
+            .WithName("CreateMessage")
+            .Produces<CreatedResponse<int>>(201)
+            .Produces(400)
+            .WithSummary("Create message")
+            .WithDescription("Create message")
+            .HasApiVersion(1.0);
 
 
         // UPDATE

BlogWebApp/BlogMinimalApi/ApiEndpoints/PostsApiEndpoints.cs

@@ -167,8 +167,12 @@ public void InstallApiRoutes(WebApplication app)
                         $"{ApiRoutes.PostsController.Posts}/{post.Id}",
                         new CreatedResponse<int> { Id = post.Id });
                 })
+            .WithName("CreatePost")
             .Produces<CreatedResponse<int>>(201)
-            .Produces(400);
+            .Produces(400)
+            .WithSummary("Create post")
+            .WithDescription("Create post")
+            .HasApiVersion(1.0);
 
 
         // LIKE POST

BlogWebApp/BlogVerticalSliceCQRSMinimalApi/BlogVerticalSliceCQRSMinimalApi.csproj

@@ -0,0 +1,34 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <TargetFramework>net10.0</TargetFramework>
+    <Nullable>enable</Nullable>
+    <ImplicitUsings>enable</ImplicitUsings>
+  </PropertyGroup>
+
+	<PropertyGroup>
+		<GenerateDocumentationFile>true</GenerateDocumentationFile>
+		<NoWarn>$(NoWarn);1591</NoWarn>
+	</PropertyGroup>
+
+  <ItemGroup>
+	  <PackageReference Include="Carter" Version="10.0.0" />
+	  <PackageReference Include="Mapster" Version="7.4.0" />
+	  <PackageReference Include="MediatR" Version="14.1.0" />
+	  <PackageReference Include="Microsoft.AspNetCore.Authentication.JwtBearer" Version="10.0.3" />
+	  <PackageReference Include="Microsoft.Extensions.Caching.StackExchangeRedis" Version="10.0.3" />
+	  <PackageReference Include="Microsoft.Extensions.Diagnostics.HealthChecks.EntityFrameworkCore" Version="10.0.3" />
+	  <PackageReference Include="Asp.Versioning.Http" Version="8.1.1" />
+	  <PackageReference Include="Asp.Versioning.Mvc.ApiExplorer" Version="8.1.1" />
+	  <PackageReference Include="AspNetCore.HealthChecks.Redis" Version="9.0.0" />
+	  <PackageReference Include="Swashbuckle.AspNetCore" Version="10.1.4" />
+	  <PackageReference Include="Swashbuckle.AspNetCore.Filters" Version="10.0.1" />
+	  <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="10.0.3" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\Aspire\Blog.Aspire\Blog.Aspire.ServiceDefaults\Blog.Aspire.ServiceDefaults.csproj" />
+    <ProjectReference Include="..\Services\Blog.Services\Blog.EntityServices.csproj" />
+  </ItemGroup>
+
+</Project>

BlogWebApp/BlogVerticalSliceCQRSMinimalApi/BlogVerticalSliceCQRSMinimalApi.csproj.user

@@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="utf-8"?>
+<Project ToolsVersion="Current" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
+  <PropertyGroup>
+    <ActiveDebugProfile>http</ActiveDebugProfile>
+  </PropertyGroup>
+  <PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'">
+    <DebuggerFlavor>ProjectDebugger</DebuggerFlavor>
+  </PropertyGroup>
+</Project>

BlogWebApp/BlogVerticalSliceCQRSMinimalApi/BlogVerticalSliceCQRSMinimalApi.http

@@ -0,0 +1,6 @@
+@BlogVerticalSliceCQRSMinimalApi_HostAddress = http://localhost:5037
+
+GET {{BlogVerticalSliceCQRSMinimalApi_HostAddress}}/weatherforecast/
+Accept: application/json
+
+###

BlogWebApp/BlogVerticalSliceCQRSMinimalApi/CQRSExtensions/ICommand.cs

@@ -0,0 +1,16 @@
+using MediatR;
+
+namespace BlogVerticalSliceCQRSMinimalApi.CQRSExtensions;
+
+/// <summary>
+/// 
+/// </summary>
+//will not return any response
+public interface ICommand : ICommand<Unit>;
+
+/// <summary>
+/// 
+/// </summary>
+/// <typeparam name="TResponse"></typeparam>
+//will return TResponse
+public interface ICommand<out TResponse> : IRequest<TResponse>;

BlogWebApp/BlogVerticalSliceCQRSMinimalApi/CQRSExtensions/ICommandHandler.cs

@@ -0,0 +1,14 @@
+using MediatR;
+
+namespace BlogVerticalSliceCQRSMinimalApi.CQRSExtensions;
+
+//will not return any response
+public interface ICommandHandler<in TCommand>
+    : IRequestHandler<TCommand, Unit>
+    where TCommand : ICommand<Unit>;
+
+//will return TResponse
+public interface ICommandHandler<in TCommand, TResponse>
+    : IRequestHandler<TCommand, TResponse>
+    where TCommand : ICommand<TResponse>
+    where TResponse : notnull;

BlogWebApp/BlogVerticalSliceCQRSMinimalApi/CQRSExtensions/IQuery.cs

@@ -0,0 +1,6 @@
+using MediatR;
+
+namespace BlogVerticalSliceCQRSMinimalApi.CQRSExtensions;
+
+public interface IQuery<out TResponse> : IRequest<TResponse>
+    where TResponse : notnull;

BlogWebApp/BlogVerticalSliceCQRSMinimalApi/CQRSExtensions/IQueryHandler.cs

@@ -0,0 +1,9 @@
+using MediatR;
+
+namespace BlogVerticalSliceCQRSMinimalApi.CQRSExtensions;
+
+//will return TResponse
+public interface IQueryHandler<in TQuery, TResponse>
+    : IRequestHandler<TQuery, TResponse>
+    where TQuery : IQuery<TResponse>
+    where TResponse : notnull;

BlogWebApp/BlogVerticalSliceCQRSMinimalApi/CQRSExtensions/SearchParametersQuery.cs

@@ -0,0 +1,4 @@
+namespace BlogVerticalSliceCQRSMinimalApi.CQRSExtensions;
+
+public record SearchParametersQuery(string OrderBy, string SortBy, int? CurrentPage, int? PageSize, string DisplayType)
+    : SortParametersQuery(OrderBy, SortBy, CurrentPage, PageSize, DisplayType);

BlogWebApp/BlogVerticalSliceCQRSMinimalApi/CQRSExtensions/SortParametersQuery.cs

@@ -0,0 +1,3 @@
+namespace BlogVerticalSliceCQRSMinimalApi.CQRSExtensions;
+
+public record SortParametersQuery(string OrderBy, string SortBy, int? CurrentPage, int? PageSize, string DisplayType);

BlogWebApp/BlogVerticalSliceCQRSMinimalApi/Cache/CachedAttribute.cs

@@ -0,0 +1,88 @@
+namespace BlogVerticalSliceCQRSMinimalApi.Cache;
+
+using System;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.Http;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.AspNetCore.Mvc.Filters;
+using Microsoft.Extensions.DependencyInjection;
+using Blog.CommonServices.Interfaces;
+using Blog.Core.Configuration;
+
+/// <summary>
+/// Cached attribute.
+/// </summary>
+/// <seealso cref="Attribute" />
+/// <seealso cref="IAsyncActionFilter" />
+/// <remarks>
+/// Initializes a new instance of the <see cref="CachedAttribute"/> class.
+/// </remarks>
+/// <param name="lifeTimeSeconds">The lifetime seconds.</param>
+[AttributeUsage(AttributeTargets.Class | AttributeTargets.Method)]
+public class CachedAttribute(int lifeTimeSeconds)
+    : Attribute, IAsyncActionFilter
+{
+    /// <summary>
+    /// The lifetime seconds.
+    /// </summary>
+    private readonly int _lifeTimeSeconds = lifeTimeSeconds;
+
+    /// <summary>
+    /// Called asynchronously before the action, after model binding is complete.
+    /// </summary>
+    /// <param name="context">The <see cref="T:Microsoft.AspNetCore.Mvc.Filters.ActionExecutingContext" />.</param>
+    /// <param name="next">The <see cref="T:Microsoft.AspNetCore.Mvc.Filters.ActionExecutionDelegate" />. Invoked to execute the next action filter or the action itself.</param>
+    public async Task OnActionExecutionAsync(ActionExecutingContext context, ActionExecutionDelegate next)
+    {
+        var cacheSettings = context.HttpContext.RequestServices.GetRequiredService<RedisCacheConfiguration>();
+        if (!cacheSettings.Enabled)
+        {
+            await next();
+            return;
+        }
+
+        var cachedService = context.HttpContext.RequestServices.GetRequiredService<IResponseCacheService>();
+        var cachedKey = GenerateCacheKeyFromRequest(context.HttpContext.Request);
+
+        var cachedResponse = await cachedService.GetCachedResponseAsync(cachedKey);
+        if (!string.IsNullOrEmpty(cachedResponse))
+        {
+            var contentResult = new ContentResult
+            {
+                Content = cachedResponse,
+                ContentType = "application/json",
+                StatusCode = 200,
+            };
+
+            context.Result = contentResult;
+
+            return;
+        }
+
+        var executedContext = await next();
+        if (executedContext.Result is OkObjectResult okObjectResult)
+        {
+            await cachedService.CacheResponseAsync(cachedKey, okObjectResult.Value, TimeSpan.FromSeconds(_lifeTimeSeconds));
+        }
+    }
+
+    /// <summary>
+    /// Generates the cache key from request.
+    /// </summary>
+    /// <param name="request">The request.</param>
+    /// <returns></returns>
+    private static string GenerateCacheKeyFromRequest(HttpRequest request)
+    {
+        var keyBuilder = new StringBuilder();
+        keyBuilder.Append($"{request.Path}");
+
+        foreach (var (key, value) in request.Query.OrderBy(x => x.Key))
+        {
+            keyBuilder.Append($"{key}-{value}");
+        }
+
+        return keyBuilder.ToString();
+    }
+}

BlogWebApp/BlogVerticalSliceCQRSMinimalApi/Features/Accounts/GetAllUsers/GetAllUsersQuery.cs

@@ -0,0 +1,6 @@
+using Blog.Contracts.V1.Responses.UsersResponses;
+using BlogVerticalSliceCQRSMinimalApi.CQRSExtensions;
+
+namespace BlogVerticalSliceCQRSMinimalApi.Features.Accounts.GetAllUsers;
+
+public record GetAllUsersQuery : IQuery<List<AccountResponse>>;

BlogWebApp/BlogVerticalSliceCQRSMinimalApi/Features/Accounts/GetAllUsers/GetAllUsersQueryHandler.cs

@@ -0,0 +1,23 @@
+using AutoMapper;
+using Blog.Contracts.V1.Responses.UsersResponses;
+using Blog.Data.Models;
+using BlogVerticalSliceCQRSMinimalApi.CQRSExtensions;
+using Microsoft.AspNetCore.Identity;
+using Microsoft.EntityFrameworkCore;
+
+namespace BlogVerticalSliceCQRSMinimalApi.Features.Accounts.GetAllUsers;
+
+public class GetAllUsersQueryHandler(
+    UserManager<ApplicationUser> userManager,
+    IMapper mapper)
+    : IQueryHandler<GetAllUsersQuery, List<AccountResponse>>
+{
+    public async Task<List<AccountResponse>> Handle(GetAllUsersQuery query, CancellationToken cancellationToken)
+    {
+        var users = await userManager.Users
+            .Include(u => u.Roles)
+            .ToListAsync(cancellationToken: cancellationToken);
+
+        return mapper.Map<List<AccountResponse>>(users);
+    }
+}

BlogWebApp/BlogVerticalSliceCQRSMinimalApi/Features/Accounts/Initialize/InitializeQuery.cs

@@ -0,0 +1,6 @@
+using Blog.Contracts.V1.Responses.UsersResponses;
+using BlogVerticalSliceCQRSMinimalApi.CQRSExtensions;
+
+namespace BlogVerticalSliceCQRSMinimalApi.Features.Accounts.Initialize;
+
+public record InitializeQuery(string UserId) : IQuery<List<RoleResponse>>;

BlogWebApp/BlogVerticalSliceCQRSMinimalApi/Features/Accounts/Initialize/InitializeQueryHandler.cs

@@ -0,0 +1,21 @@
+using AutoMapper;
+using Blog.Contracts.V1.Responses.UsersResponses;
+using Blog.Data.Models;
+using BlogVerticalSliceCQRSMinimalApi.CQRSExtensions;
+using Microsoft.AspNetCore.Identity;
+using Microsoft.EntityFrameworkCore;
+
+namespace BlogVerticalSliceCQRSMinimalApi.Features.Accounts.Initialize;
+
+public class InitializeQueryHandler(
+    RoleManager<ApplicationRole> roleManager,
+    IMapper mapper)
+    : IQueryHandler<InitializeQuery, List<RoleResponse>>
+{
+    public async Task<List<RoleResponse>> Handle(InitializeQuery query, CancellationToken cancellationToken)
+    {
+        var roles = await roleManager.Roles.ToListAsync(cancellationToken: cancellationToken);
+
+        return mapper.Map<List<RoleResponse>>(roles);
+    }
+}

BlogWebApp/BlogVerticalSliceCQRSMinimalApi/Features/Accounts/Login/LoginCommand.cs

@@ -0,0 +1,6 @@
+using BlogVerticalSliceCQRSMinimalApi.CQRSExtensions;
+
+namespace BlogVerticalSliceCQRSMinimalApi.Features.Accounts.Login;
+
+public record LoginCommand(string Email, string Password)
+    : ICommand<string>;

BlogWebApp/BlogVerticalSliceCQRSMinimalApi/Features/Accounts/Login/LoginCommandHandler.cs

@@ -0,0 +1,11 @@
+using Blog.EntityServices.EntityFrameworkServices.Identity.Auth;
+using BlogVerticalSliceCQRSMinimalApi.CQRSExtensions;
+
+namespace BlogVerticalSliceCQRSMinimalApi.Features.Accounts.Login;
+
+public class LoginCommandHandler(IAuthService authService)
+    : ICommandHandler<LoginCommand, string>
+{
+    public async Task<string> Handle(LoginCommand command, CancellationToken cancellationToken)
+        => await authService.GetJwtAsync(command.Email, command.Password);
+}