Add product feature with CRUD operations, pagination, and MudDataGrid integration

Author: neozhu

.editorconfig

@@ -173,6 +173,9 @@ dotnet_style_prefer_is_null_check_over_reference_equality_method = true:suggesti
 dotnet_style_prefer_auto_properties = true:silent
 dotnet_style_prefer_simplified_boolean_expressions = true:suggestion
 dotnet_style_prefer_conditional_expression_over_assignment = true:silent
+dotnet_style_prefer_inferred_tuple_names = true:suggestion
+dotnet_style_prefer_inferred_anonymous_type_member_names = true:suggestion
+dotnet_style_namespace_match_folder = true:suggestion
 
 # CSharp code style settings:
 [*.cs]
@@ -256,7 +259,7 @@ csharp_preserve_single_line_statements = true
 dotnet_diagnostic.IDE0060.severity = warning
 csharp_using_directive_placement = outside_namespace:silent
 csharp_prefer_simple_using_statement = true:suggestion
-csharp_style_namespace_declarations = block_scoped:silent
+csharp_style_namespace_declarations = file_scoped:suggestion
 csharp_style_prefer_method_group_conversion = true:silent
 csharp_style_prefer_top_level_statements = true:silent
 csharp_style_prefer_primary_constructors = true:suggestion

src/CleanAspire.Api/Endpoints/FileUploadEndpointRegistrar.cs

@@ -12,7 +12,6 @@
 using Microsoft.AspNetCore.StaticFiles;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.AspNetCore.Http.HttpResults;
-using System.Security.Claims;
 
 namespace CleanAspire.Api.Endpoints;
 

src/CleanAspire.Api/Endpoints/ProductEndpointRegistrar.cs

@@ -0,0 +1,58 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+// See the LICENSE file in the project root for more information.
+
+using CleanAspire.Application.Common.Models;
+using CleanAspire.Application.Features.Products.Commands;
+using CleanAspire.Application.Features.Products.DTOs;
+using CleanAspire.Application.Features.Products.Queries;
+using Mediator;
+using Microsoft.AspNetCore.Mvc;
+
+namespace CleanAspire.Api.Endpoints;
+
+public class ProductEndpointRegistrar : IEndpointRegistrar
+{
+    public void RegisterRoutes(IEndpointRouteBuilder routes)
+    {
+        var group = routes.MapGroup("/products").WithTags("products").AllowAnonymous();
+
+        // Get all products
+        group.MapGet("/", async ([FromServices] IMediator mediator) =>
+        {
+            var query = new GetAllProductsQuery();
+            return await mediator.Send(query);
+        })
+        .Produces<IEnumerable<ProductDto>>()
+        .WithSummary("Get all products")
+        .WithDescription("Returns a list of all products in the system.");
+
+        // Get product by ID
+        group.MapGet("/{id}", (IMediator mediator, [FromRoute] string id) => mediator.Send(new GetProductByIdQuery(id)))
+        .Produces<ProductDto>()
+        .WithSummary("Get product by ID")
+        .WithDescription("Returns the details of a specific product by its unique ID.");
+
+        // Create a new product
+        group.MapPost("/", ([FromServices] IMediator mediator, [FromBody] CreateProductCommand command) => mediator.Send(command))
+        .WithSummary("Create a new product")
+        .WithDescription("Creates a new product with the provided details.");
+
+        // Update an existing product
+        group.MapPut("/", ([FromServices] IMediator mediator, [FromBody] UpdateProductCommand command) => mediator.Send(command))
+        .WithSummary("Update an existing product")
+        .WithDescription("Updates the details of an existing product.");
+
+        // Delete products by IDs
+        group.MapDelete("/",  (IMediator mediator, [FromQuery] string[] ids) => mediator.Send(new DeleteProductCommand(ids)))
+        .WithSummary("Delete products by IDs")
+        .WithDescription("Deletes one or more products by their unique IDs.");
+
+        // Get products with pagination and filtering
+        group.MapPost("/pagination",  ([FromServices] IMediator mediator, [FromBody] ProductsWithPaginationQuery query) => mediator.Send(query))
+        .Produces<PaginatedResult<ProductDto>>()
+        .WithSummary("Get products with pagination")
+        .WithDescription("Returns a paginated list of products based on search keywords, page size, and sorting options.");
+    }
+}
+

src/CleanAspire.Api/IdentityApiAdditionalEndpointsExtensions.cs

@@ -13,10 +13,6 @@
 using Microsoft.AspNetCore.WebUtilities;
 using System.Text.Encodings.Web;
 using System.Text;
-using CleanAspire.Application.Common.Interfaces;
-using SixLabors.ImageSharp.Formats.Png;
-using SixLabors.ImageSharp;
-using SixLabors.ImageSharp.Processing;
 namespace CleanAspire.Api;
 
 public static class IdentityApiAdditionalEndpointsExtensions
@@ -31,16 +27,17 @@ public static IEndpointRouteBuilder MapIdentityApiAdditionalEndpoints<TUser>(thi
         var emailSender = endpoints.ServiceProvider.GetRequiredService<IEmailSender<TUser>>();
         var linkGenerator = endpoints.ServiceProvider.GetRequiredService<LinkGenerator>();
         string? confirmEmailEndpointName = null;
-        var identityGroup = endpoints.MapGroup("/identity").RequireAuthorization().WithTags("Authentication", "Identity Management");
-        identityGroup.MapPost("/logout", async (SignInManager<TUser> signInManager) =>
+        var routeGroup = endpoints.MapGroup("/account").WithTags("Authentication", "Account Management");
+        routeGroup.MapPost("/logout", async (SignInManager<TUser> signInManager) =>
         {
             await signInManager.SignOutAsync();
             return Results.Ok();
         })
+        .RequireAuthorization()
         .WithSummary("Log out the current user.")
         .WithDescription("Logs out the currently authenticated user by signing them out of the system. This endpoint requires the user to be authorized before calling, and returns an HTTP 200 OK response upon successful logout.");
 
-        identityGroup.MapGet("/profile", async Task<Results<Ok<ProfileResponse>, ValidationProblem, NotFound>>
+        routeGroup.MapGet("/profile", async Task<Results<Ok<ProfileResponse>, ValidationProblem, NotFound>>
             (ClaimsPrincipal claimsPrincipal, HttpContext context, IServiceProvider sp) =>
         {
             var userManager = sp.GetRequiredService<UserManager<TUser>>();
@@ -50,10 +47,11 @@ public static IEndpointRouteBuilder MapIdentityApiAdditionalEndpoints<TUser>(thi
             }
             return TypedResults.Ok(await CreateInfoResponseAsync(user, userManager));
         })
+            .RequireAuthorization()
         .WithSummary("Retrieve the user's profile")
         .WithDescription("Fetches the profile information of the authenticated user. " +
          "Returns 404 if the user is not found. Requires authorization.");
-        identityGroup.MapPost("/profile", async Task<Results<Ok<ProfileResponse>, ValidationProblem, NotFound>>
+        routeGroup.MapPost("/profile", async Task<Results<Ok<ProfileResponse>, ValidationProblem, NotFound>>
             (ClaimsPrincipal claimsPrincipal, [FromBody] ProfileRequest request, HttpContext context, [FromServices] IServiceProvider sp) =>
         {
             var userManager = sp.GetRequiredService<UserManager<TUser>>();
@@ -89,12 +87,10 @@ public static IEndpointRouteBuilder MapIdentityApiAdditionalEndpoints<TUser>(thi
 
             return TypedResults.Ok(await CreateInfoResponseAsync(user, userManager));
         })
+        .RequireAuthorization()
         .WithSummary("Update user profile information.")
         .WithDescription("Allows users to update their profile, including username, email, nickname, avatar, time zone, and language code.");
 
-
-
-        var routeGroup = endpoints.MapGroup("/account").WithTags("Authentication", "Identity Management");
         routeGroup.MapPost("/signup", async Task<Results<Ok, ValidationProblem>>
             ([FromBody] SignupRequest request, HttpContext context, [FromServices] IServiceProvider sp) =>
         {
@@ -120,7 +116,8 @@ public static IEndpointRouteBuilder MapIdentityApiAdditionalEndpoints<TUser>(thi
             }
             await SendConfirmationEmailAsync(user, userManager, context, request.Email);
             return TypedResults.Ok();
-        }).WithSummary("User Signup")
+        }).AllowAnonymous()
+            .WithSummary("User Signup")
           .WithDescription("Allows a new user to sign up by providing required details such as email, password, and tenant-specific information. This endpoint creates a new user account and sends a confirmation email for verification.");
 
         routeGroup.MapGet("/confirmEmail", async Task<Results<ContentHttpResult, UnauthorizedHttpResult>>
@@ -157,7 +154,8 @@ public static IEndpointRouteBuilder MapIdentityApiAdditionalEndpoints<TUser>(thi
                 return TypedResults.Unauthorized();
             }
             return TypedResults.Text("Thank you for confirming your email.");
-        }).WithSummary("Confirm Email or Update Email Address")
+        }).AllowAnonymous()
+          .WithSummary("Confirm Email or Update Email Address")
         .WithDescription("Processes email confirmation or email change requests for a user. It validates the confirmation code, verifies the user ID, and updates the email if a new one is provided. Returns a success message upon successful confirmation or email update.")
         .Add(endpointBuilder =>
         {

src/CleanAspire.Api/OpenApiTransformersExtensions.cs

@@ -7,7 +7,6 @@
 using Microsoft.AspNetCore.Identity;
 using Microsoft.AspNetCore.Identity.Data;
 using Microsoft.AspNetCore.OpenApi;
-using Microsoft.IdentityModel.Tokens;
 using Microsoft.OpenApi.Any;
 using Microsoft.OpenApi.Models;
 

src/CleanAspire.Api/Program.cs

@@ -1,19 +1,12 @@
 using System.Text.Json.Serialization;
 using CleanAspire.Api;
 using CleanAspire.Application;
-using CleanAspire.Application.Common.Interfaces;
 using CleanAspire.Application.Common.Services;
-using CleanAspire.Domain.Entities;
 using CleanAspire.Domain.Identities;
 using CleanAspire.Infrastructure;
 using CleanAspire.Infrastructure.Persistence;
-using CleanAspire.Infrastructure.Persistence.Seed;
-using CleanAspire.Infrastructure.Services;
 using Microsoft.AspNetCore.Identity;
-using Microsoft.Extensions.DependencyInjection;
-using Mono.TextTemplating;
 using Scalar.AspNetCore;
-using Microsoft.AspNetCore.OpenApi;
 using Microsoft.OpenApi;
 using CleanAspire.Api.Identity;
 using Microsoft.Extensions.FileProviders;
@@ -68,6 +61,7 @@
 {
     // Don't serialize null values
     options.SerializerOptions.DefaultIgnoreCondition = JsonIgnoreCondition.WhenWritingNull;
+    options.SerializerOptions.Converters.Add(new JsonStringEnumConverter());
     // Pretty print JSON
     options.SerializerOptions.WriteIndented = true;
 });
@@ -83,27 +77,7 @@
 // Configure the HTTP request pipeline.
 app.UseExceptionHandler();
 app.MapEndpointDefinitions();
-var summaries = new[]
-{
-    "Freezing", "Bracing", "Chilly", "Cool", "Mild", "Warm", "Balmy", "Hot", "Sweltering", "Scorching"
-};
 app.UseCors("wasm");
-app.MapGet("/weatherforecast", () =>
-{
-
-    var forecast = Enumerable.Range(1, 5).Select(index =>
-        new WeatherForecast
-        (
-            DateOnly.FromDateTime(DateTime.Now.AddDays(index)),
-            Random.Shared.Next(-20, 55),
-            summaries[Random.Shared.Next(summaries.Length)]
-        ))
-        .ToArray();
-    return forecast;
-}).WithTags("Weather")
-  .WithSummary("Get the weather forecast for the next 5 days.")
-  .WithDescription("Returns an array of weather forecast data including the date, temperature, and weather summary for the next 5 days. Each forecast entry provides information about the expected temperature and a brief summary of the weather conditions.");
-
 app.Use(async (context, next) =>
 {
     var currentUserContextSetter = context.RequestServices.GetRequiredService<ICurrentUserContextSetter>();

src/CleanAspire.Application/CleanAspire.Application.csproj

@@ -8,6 +8,8 @@
 
   <ItemGroup>
 
+      <PackageReference Include="Mediator.Abstractions" Version="3.0.0-preview.27" />
+    
       <PackageReference Include="Mediator.SourceGenerator" Version="3.0.0-preview.27">
         <PrivateAssets>all</PrivateAssets>
         <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>

src/CleanAspire.Application/Common/Interfaces/IApplicationDbContext.cs

@@ -1,7 +1,4 @@
-using CleanAspire.Domain.Entities;
-using Microsoft.EntityFrameworkCore;
-
-namespace CleanAspire.Application.Common.Interfaces;
+namespace CleanAspire.Application.Common.Interfaces;
 
 public interface IApplicationDbContext
 {

src/CleanAspire.Application/Common/Interfaces/IDateTime.cs

@@ -2,12 +2,6 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
-
 namespace CleanAspire.Application.Common.Interfaces;
 
 public interface IDateTime

src/CleanAspire.Application/Common/Models/PaginatedResult.cs

@@ -0,0 +1,20 @@
+
+namespace CleanAspire.Application.Common.Models;
+public class PaginatedResult<T>
+{
+    public PaginatedResult(IEnumerable<T> items, int total, int pageIndex, int pageSize)
+    {
+        Items = items;
+        TotalItems = total;
+        CurrentPage = pageIndex;
+        TotalPages = (int)Math.Ceiling(total / (double)pageSize);
+    }
+
+    public int CurrentPage { get; }
+    public int TotalItems { get; private set; }
+    public int TotalPages { get; }
+    public bool HasPreviousPage => CurrentPage > 1;
+    public bool HasNextPage => CurrentPage < TotalPages;
+    public IEnumerable<T> Items { get; set; }
+
+}

src/CleanAspire.Application/Common/QueryableExtensions/QueryableExtensions.cs

@@ -0,0 +1,80 @@
+using System.Linq.Expressions;
+using System.Reflection;
+using CleanAspire.Domain.Common;
+
+namespace CleanAspire.Application.Common;
+public static class QueryableExtensions
+{
+    #region OrderBy
+    public static IOrderedQueryable<T> OrderBy<T>(this IQueryable<T> source, string orderByProperty)
+    {
+        return ApplyOrder(source, orderByProperty, "OrderBy");
+    }
+
+    public static IOrderedQueryable<T> OrderByDescending<T>(this IQueryable<T> source, string orderByProperty)
+    {
+        return ApplyOrder(source, orderByProperty, "OrderByDescending");
+    }
+
+    public static IOrderedQueryable<T> ThenBy<T>(this IOrderedQueryable<T> source, string orderByProperty)
+    {
+        return ApplyOrder(source, orderByProperty, "ThenBy");
+    }
+
+    public static IOrderedQueryable<T> ThenByDescending<T>(this IOrderedQueryable<T> source, string orderByProperty)
+    {
+        return ApplyOrder(source, orderByProperty, "ThenByDescending");
+    }
+
+    private static IOrderedQueryable<T> ApplyOrder<T>(IQueryable<T> source, string property, string methodName)
+    {
+        var type = typeof(T);
+        var propertyInfo = type.GetProperty(property, BindingFlags.Public | BindingFlags.Instance | BindingFlags.IgnoreCase);
+        if (propertyInfo == null)
+        {
+            throw new ArgumentException($"Property '{property}' does not exist on type '{type.Name}'.");
+        }
+
+        var parameter = Expression.Parameter(type, "x");
+        var propertyAccess = Expression.MakeMemberAccess(parameter, propertyInfo);
+        var orderByExpression = Expression.Lambda(propertyAccess, parameter);
+
+        var resultExpression = Expression.Call(
+            typeof(Queryable),
+            methodName,
+            new[] { type, propertyInfo.PropertyType },
+            source.Expression,
+            Expression.Quote(orderByExpression));
+
+        return (IOrderedQueryable<T>)source.Provider.CreateQuery<T>(resultExpression);
+    }
+
+    public static IOrderedQueryable<T> OrderBy<T>(this IQueryable<T> source, string orderBy, string sortDirection)
+    {
+        return sortDirection.Equals("Descending", StringComparison.OrdinalIgnoreCase)
+            ? source.OrderByDescending(orderBy)
+            : source.OrderBy(orderBy);
+    }
+    #endregion
+    public static async Task<PaginatedResult<TResult>> ProjectToPaginatedDataAsync<T, TResult>(
+        this IOrderedQueryable<T> query,
+        Expression<Func<T, bool>>? condition,
+        int pageNumber, 
+        int pageSize,
+        Func<T, TResult> mapperFunc, 
+        CancellationToken cancellationToken = default) where T : class, IEntity
+    {
+        if (condition != null)
+        {
+            query = (IOrderedQueryable<T>)query.Where(condition);
+        }
+        var count = await query.CountAsync(cancellationToken);
+        var data = await query
+            .Skip((pageNumber - 1) * pageSize)
+            .Take(pageSize)
+            .ToListAsync(cancellationToken);
+
+        var items = data.Select(x => mapperFunc(x)).ToList();
+        return new PaginatedResult<TResult>(items, count, pageNumber, pageSize);
+    }
+}

src/CleanAspire.Application/DependencyInjection.cs

@@ -2,14 +2,7 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Reflection;
-using System.Text;
-using System.Threading.Tasks;
 using CleanAspire.Application.Pipeline;
-using Mediator;
 using Microsoft.Extensions.DependencyInjection;
 
 namespace CleanAspire.Application;