feat: add generic map methods

Author: ikesnowy

src/Cnblogs.Architecture.Ddd.Cqrs.AspNetCore/CqrsRouteMapper.cs

@@ -4,6 +4,7 @@
 using Cnblogs.Architecture.Ddd.Cqrs.Abstractions;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Http;
+using Microsoft.AspNetCore.Mvc;
 using Microsoft.AspNetCore.Routing;
 using Microsoft.AspNetCore.Routing.Patterns;
 
@@ -206,6 +207,20 @@ public static IEndpointConventionBuilder MapCommand(
         return app.MapPutCommand(route, handler);
     }
 
+    /// <summary>
+    ///     Map a command API, using POST method and get command data from request body.
+    /// </summary>
+    /// <param name="app"><see cref="ApplicationBuilder"/></param>
+    /// <param name="route">The route template.</param>
+    /// <typeparam name="TCommand">The type of command.</typeparam>
+    /// <returns></returns>
+    public static IEndpointConventionBuilder MapPostCommand<TCommand>(
+        this IEndpointRouteBuilder app,
+        [StringSyntax("Route")] string route)
+    {
+        return app.MapPostCommand(route, ([FromBody] TCommand command) => command);
+    }
+
     /// <summary>
     ///     Map a command API, using POST method.
     /// </summary>
@@ -222,6 +237,20 @@ public static IEndpointConventionBuilder MapPostCommand(
         return app.MapPost(route, handler).AddEndpointFilter<CommandEndpointHandler>();
     }
 
+    /// <summary>
+    ///     Map a command API, using PUT method and get command data from request body.
+    /// </summary>
+    /// <param name="app"><see cref="IEndpointRouteBuilder"/></param>
+    /// <param name="route">The route template.</param>
+    /// <typeparam name="TCommand">The type of command.</typeparam>
+    /// <returns></returns>
+    public static IEndpointConventionBuilder MapPutCommand<TCommand>(
+        this IEndpointRouteBuilder app,
+        [StringSyntax("Route")] string route)
+    {
+        return app.MapPutCommand(route, ([FromBody] TCommand command) => command);
+    }
+
     /// <summary>
     ///     Map a command API, using PUT method.
     /// </summary>
@@ -238,6 +267,20 @@ public static IEndpointConventionBuilder MapPutCommand(
         return app.MapPut(route, handler).AddEndpointFilter<CommandEndpointHandler>();
     }
 
+    /// <summary>
+    ///     Map a command API, using DELETE method and get command from route/query parameters.
+    /// </summary>
+    /// <param name="app"><see cref="IEndpointRouteBuilder"/></param>
+    /// <param name="route">The route template.</param>
+    /// <typeparam name="TCommand">The type of command.</typeparam>
+    /// <returns></returns>
+    public static IEndpointConventionBuilder MapDeleteCommand<TCommand>(
+        this IEndpointRouteBuilder app,
+        [StringSyntax("Route")] string route)
+    {
+        return app.MapDeleteCommand(route, ([AsParameters] TCommand command) => command);
+    }
+
     /// <summary>
     ///     Map a command API, using DELETE method.
     /// </summary>

test/Cnblogs.Architecture.IntegrationTestProject/Program.cs

@@ -45,6 +45,11 @@
     (int id, UpdatePayload payload) => new UpdateCommand(id, payload.NeedValidationError, payload.NeedExecutionError));
 v1.MapCommand<DeleteCommand>("strings/{id:int}");
 
+// generic command map
+v1.MapPostCommand<CreateCommand>("generic-map/strings");
+v1.MapPutCommand<UpdateCommand>("generic-map/strings");
+v1.MapDeleteCommand<DeleteCommand>("generic-map/strings/{id:int}");
+
 app.Run();
 
 namespace Cnblogs.Architecture.IntegrationTestProject

test/Cnblogs.Architecture.IntegrationTests/CqrsRouteMapperTests.cs

@@ -2,6 +2,7 @@
 using System.Net.Http.Json;
 using Cnblogs.Architecture.Ddd.Infrastructure.Abstractions;
 using Cnblogs.Architecture.IntegrationTestProject;
+using Cnblogs.Architecture.IntegrationTestProject.Application.Commands;
 using FluentAssertions;
 using Microsoft.AspNetCore.Mvc.Testing;
 
@@ -132,4 +133,48 @@ public async Task GetItem_MapHeadAndGet_SuccessAsync()
         // Assert
         responses.Should().Match(x => x.All(y => y.IsSuccessStatusCode));
     }
+
+    [Fact]
+    public async Task PostItem_GenericMap_SuccessAsync()
+    {
+        // Arrange
+        var builder = new WebApplicationFactory<Program>();
+
+        // Act
+        var response = await builder.CreateClient().PostAsJsonAsync(
+            "/api/v1/generic-map/strings",
+            new CreateCommand(false, "data"));
+
+        // Assert
+        response.Should().BeSuccessful();
+    }
+
+    [Fact]
+    public async Task PutItem_GenericMap_SuccessAsync()
+    {
+        // Arrange
+        var builder = new WebApplicationFactory<Program>();
+
+        // Act
+        var response = await builder.CreateClient().PutAsJsonAsync(
+            "/api/v1/generic-map/strings",
+            new UpdateCommand(1, false, false));
+
+        // Assert
+        response.Should().BeSuccessful();
+    }
+
+    [Fact]
+    public async Task DeleteCommand_GenericMap_SuccessAsync()
+    {
+        // Arrange
+        var builder = new WebApplicationFactory<Program>();
+
+        // Act
+        var queryBuilder = new QueryStringBuilder().Add("needError", false);
+        var response = await builder.CreateClient().DeleteAsync("/api/v1/generic-map/strings/1" + queryBuilder.Build());
+
+        // Assert
+        response.Should().BeSuccessful();
+    }
 }