Adjust KnownExceptionValidationBehavior 使用 ValidateAsync 以支持异步验证器

src/AspNetCore/Validation/KnownExceptionValidationBehavior.cs

@@ -19,16 +19,17 @@ public async Task<TResponse> Handle(TRequest request, RequestHandlerDelegate<TRe
         }
 
         var context = new ValidationContext<TRequest>(request);
-        var errorsDictionary = _validators
-            .Select(x => x.Validate(context))
+        var errorsDictionary = (await Task.WhenAll(
+            _validators.Select(x => x.ValidateAsync(context, cancellationToken)))
+            )
             .SelectMany(x => x.Errors)
             .Where(x => x != null).ToList();
         if (errorsDictionary.Any())
         {
             throw new KnownException(message: errorsDictionary[0].ErrorMessage, errorCode: 400,
                 errorData: errorsDictionary.Select(p =>
                     new { errorCode = p.ErrorCode, errorMessage = p.ErrorMessage, propertyName = p.PropertyName }
-                ).ToArray());
+                ).ToArray<object>());
         }
 
         return await next();

test/NetCorePal.Web.UnitTests/ProgramTests.cs

@@ -12,6 +12,7 @@
 using NetCorePal.SkyApm.Diagnostics;
 using NetCorePal.Web.Application.IntegrationEventHandlers;
 using NetCorePal.Web.Application.Queries;
+using NetCorePal.Web.Controllers.Request;
 
 namespace NetCorePal.Web.UnitTests
 {
@@ -122,7 +123,7 @@ public async Task ServiceUnknownExceptionTest()
         public async Task PostTest()
         {
             var client = factory.CreateClient();
-            var response = await client.PostAsJsonAsync("/api/order", new CreateOrderCommand("na", 55, 14), JsonOption);
+            var response = await client.PostAsJsonAsync("/api/order", new CreateOrderRequest("na", 55, 14), JsonOption);
             Assert.True(response.IsSuccessStatusCode);
             var data = await response.Content.ReadFromJsonAsync<OrderId>(JsonOption);
             Assert.NotNull(data);
@@ -145,7 +146,7 @@ public async Task PostTest()
         public async Task SetPaidTest()
         {
             var client = factory.CreateClient();
-            var response = await client.PostAsJsonAsync("/api/order", new CreateOrderCommand("na", 55, 14), JsonOption);
+            var response = await client.PostAsJsonAsync("/api/order", new CreateOrderRequest("na", 55, 14), JsonOption);
             Assert.True(response.IsSuccessStatusCode);
             var data = await response.Content.ReadFromJsonAsync<OrderId>(JsonOption);
             Assert.NotNull(data);
@@ -181,7 +182,7 @@ public async Task SetPaidTest()
         public async Task SetOrderItemNameTest()
         {
             var client = factory.CreateClient();
-            var response = await client.PostAsJsonAsync("/api/order", new CreateOrderCommand("na", 55, 14), JsonOption);
+            var response = await client.PostAsJsonAsync("/api/order", new CreateOrderRequest("na", 55, 14), JsonOption);
             Assert.True(response.IsSuccessStatusCode);
             var data = await response.Content.ReadFromJsonAsync<OrderId>(JsonOption);
             Assert.NotNull(data);
@@ -216,5 +217,24 @@ public async Task Int64StronglyTypedId_FromRoute_Should_Work_Test()
             Assert.True(data.Success);
             Assert.Equal(id, data.Data.Id);
         }
+
+        [Fact]
+        public async Task CreateOrderValidator_Should_ValidateWithAsync_WhenPosting()
+        {
+            var client = factory.CreateClient();
+            var response = await client.PostAsJsonAsync("/api/order", new CreateOrderRequest("na", 55, 14), JsonOption);
+            Assert.True(response.IsSuccessStatusCode);
+            var data = await response.Content.ReadFromJsonAsync<OrderId>(JsonOption);
+            Assert.NotNull(data);
+
+
+            response = await client.PostAsJsonAsync("/api/order", new CreateOrderRequest("na", 55, -1), JsonOption);
+            Assert.True(response.IsSuccessStatusCode);
+            var errData = await response.Content.ReadFromJsonAsync<ResponseData>();
+            Assert.NotNull(errData);
+            Assert.Contains("Count", errData.Message);
+            Assert.Equal(400, errData.Code);
+            Assert.False(errData.Success);
+        }
     }
 }

test/NetCorePal.Web/Application/Commands/CreateOrderCommandValidator.cs

@@ -14,6 +14,10 @@ public CreateOrderCommandValidator()
         {
             RuleFor(x => x.Name).NotEmpty().MaximumLength(10);
             RuleFor(x => x.Price).InclusiveBetween(18, 60);
+            RuleFor(x => x.Count).MustAsync(async (c, ct) => {
+                await Task.CompletedTask;
+                return c > 0;
+                } );
         }
     }
 }

test/NetCorePal.Web/Controllers/OrderController.cs

@@ -8,6 +8,7 @@
 using NetCorePal.Web.Application.IntegrationEventHandlers;
 using NetCorePal.Web.Application.Queries;
 using NetCorePal.Web.Application.Sagas;
+using NetCorePal.Web.Controllers.Request;
 using SkyApm.Tracing;
 
 namespace NetCorePal.Web.Controllers
@@ -40,12 +41,12 @@ public IActionResult Get()
         /// <summary>
         /// 
         /// </summary>
-        /// <param name="command"></param>
+        /// <param name="request"></param>
         /// <returns></returns>
         [HttpPost]
-        public async Task<OrderId> Post([FromBody] CreateOrderCommand command)
+        public async Task<OrderId> Post([FromBody] CreateOrderRequest request)
         {
-            var id = await mediator.Send(command, HttpContext.RequestAborted);
+            var id = await mediator.Send(new CreateOrderCommand(request.Name, request.Price, request.Count), HttpContext.RequestAborted);
             return id;
         }
 
@@ -75,7 +76,7 @@ public async Task<ResponseData> SetPaid(OrderId id)
             await mediator.Send(new OrderPaidCommand(id), HttpContext.RequestAborted);
             return true.AsResponseData();
         }
-        
+
         /// <summary>
         /// 
         /// </summary>
@@ -84,7 +85,7 @@ public async Task<ResponseData> SetPaid(OrderId id)
         /// <returns></returns>
         [HttpPost]
         [Route("/setorderItemName")]
-        public async Task<ResponseData> SetOrderItemName([FromQuery]long id, [FromQuery]string name)
+        public async Task<ResponseData> SetOrderItemName([FromQuery] long id, [FromQuery] string name)
         {
             await mediator.Send(new SetOrderItemNameCommand(new OrderId(id), name), HttpContext.RequestAborted);
             return true.AsResponseData();

test/NetCorePal.Web/Controllers/Request/CreateOrderRequest.cs

@@ -0,0 +1,4 @@
+namespace NetCorePal.Web.Controllers.Request
+{
+    public record CreateOrderRequest(string Name, int Price, int Count);
+}

test/NetCorePal.Web/HostedServices/CreateOrderCommandBackgroundService.cs

@@ -27,7 +27,7 @@ protected override async Task ExecuteAsync(CancellationToken stoppingToken)
             {
                 await using (handler)
                 {
-                    var command = new CreateOrderCommand("abc", 10, 20);
+                    var command = new CreateOrderCommand("abc", 20, 20);
                     await mediator.Send(command, stoppingToken);
                     await Task.Delay(100, stoppingToken);
                 }

test/NetCorePal.Web/Program.cs

@@ -139,7 +139,8 @@
 
     builder.Services.AddContext().AddEnvContext().AddCapContextProcessor();
     builder.Services.AddMediatR(cfg =>
-        cfg.RegisterServicesFromAssemblies(Assembly.GetExecutingAssembly()).AddUnitOfWorkBehaviors());
+        cfg.RegisterServicesFromAssemblies(Assembly.GetExecutingAssembly()).AddUnitOfWorkBehaviors()
+        .AddKnownExceptionValidationBehavior());
     builder.Services.AddRepositories(typeof(ApplicationDbContext).Assembly);
     builder.Services.AddDbContext<ApplicationDbContext>(options =>
     {