42 lines
1.5 KiB
C#
42 lines
1.5 KiB
C#
using Domain.Exceptions;
|
|
using FluentValidation;
|
|
using MediatR;
|
|
using Microsoft.Extensions.Logging;
|
|
using QRCodeService.Extensions;
|
|
using System.Linq;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace QRCodeService.Application.Behaviors
|
|
{
|
|
public class ValidatorBehavior<TRequest, TResponse> : IPipelineBehavior<TRequest, TResponse>
|
|
{
|
|
private readonly ILogger<ValidatorBehavior<TRequest, TResponse>> _logger;
|
|
private readonly IValidator<TRequest> _validator;
|
|
|
|
public ValidatorBehavior(IValidator<TRequest> validator, ILogger<ValidatorBehavior<TRequest, TResponse>> logger)
|
|
{
|
|
_validator = validator;
|
|
_logger = logger;
|
|
}
|
|
|
|
public async Task<TResponse> Handle(TRequest request, CancellationToken cancellationToken, RequestHandlerDelegate<TResponse> next)
|
|
{
|
|
var typeName = request.GetGenericTypeName();
|
|
|
|
_logger.LogInformation("----- Validating command {CommandType}", typeName);
|
|
|
|
var failures = _validator.Validate(request).Errors;
|
|
|
|
if (failures.Any())
|
|
{
|
|
_logger.LogWarning("Validation errors - {CommandType} - Command: {@Command} - Errors: {@ValidationErrors}", typeName, request, failures);
|
|
|
|
throw new DomainException(
|
|
$"Command Validation Errors for type {typeof(TRequest).Name}", new ValidationException("Validation exception", failures));
|
|
}
|
|
|
|
return await next();
|
|
}
|
|
}
|
|
} |