Change on filter

This commit is contained in:
2026-05-28 22:06:09 +02:00
parent 76b5c0b49d
commit 1deab7731b
4 changed files with 24 additions and 29 deletions
+7 -5
View File
@@ -12,8 +12,7 @@ public static class PlayListEndpoints
public static IEndpointRouteBuilder MapPlayListEndpoints(this IEndpointRouteBuilder app)
{
var group = app.MapGroup("/playlists")
.WithTags("PlayLists")
.AddEndpointFilter<ValidationFilter>();
.WithTags("PlayLists");
group.MapGet("/", GetPlayLists)
.WithName("GetPlayLists")
@@ -29,11 +28,13 @@ public static class PlayListEndpoints
group.MapPost("/users/{userId}", CreatePlayList)
.WithName("CreatePlayList")
.WithSummary("Create a new playlist.");
.WithSummary("Create a new playlist.")
.AddEndpointFilter<ValidationFilter<CreatePlayListRequest>>();
group.MapPut("/{playlistId}/users/{userId}", UpdatePlayList)
.WithName("UpdatePlayList")
.WithSummary("Update an existing playlist.");
.WithSummary("Update an existing playlist.")
.AddEndpointFilter<ValidationFilter<UpdatePlayListRequest>>();
group.MapDelete("/{playlistId}/users/{userId}", DeletePlayList)
.WithName("DeletePlayList")
@@ -41,7 +42,8 @@ public static class PlayListEndpoints
group.MapPost("/upload-picture/users/{userId}", RequestPlayListPictureUpload)
.WithName("RequestPlayListPictureUpload")
.WithSummary("Request a pre-signed URL to upload a playlist picture.");
.WithSummary("Request a pre-signed URL to upload a playlist picture.")
.AddEndpointFilter<ValidationFilter<RequestPlayListPictureUploadRequest>>();
return app;
}
+5 -4
View File
@@ -12,8 +12,7 @@ public static class TrackEndpoints
public static IEndpointRouteBuilder MapTrackEndpoints(this IEndpointRouteBuilder app)
{
var group = app.MapGroup("/tracks")
.WithTags("Tracks")
.AddEndpointFilter<ValidationFilter>();
.WithTags("Tracks");
group.MapGet("/", GetTracks)
.WithName("GetTracks")
@@ -29,7 +28,8 @@ public static class TrackEndpoints
group.MapPost("/users/{userId}", CreateTrack)
.WithName("CreateTrack")
.WithSummary("Create a new track.");
.WithSummary("Create a new track.")
.AddEndpointFilter<ValidationFilter<CreateTrackRequest>>();
group.MapDelete("/{trackId}/users/{userId}", DeleteTrack)
.WithName("DeleteTrack")
@@ -37,7 +37,8 @@ public static class TrackEndpoints
group.MapPost("/upload-urls/users/{userId}", RequestTrackUploadUrls)
.WithName("RequestTrackUploadUrls")
.WithSummary("Request pre-signed URLs to upload track picture and audio.");
.WithSummary("Request pre-signed URLs to upload track picture and audio.")
.AddEndpointFilter<ValidationFilter<RequestTrackUploadUrlsRequest>>();
return app;
}
+3 -3
View File
@@ -12,8 +12,7 @@ public static class UserEndpoints
public static IEndpointRouteBuilder MapUserEndpoints(this IEndpointRouteBuilder app)
{
var group = app.MapGroup("/users")
.WithTags("Users")
.AddEndpointFilter<ValidationFilter>();
.WithTags("Users");
group.MapGet("/", GetUsers)
.WithName("GetUsers")
@@ -29,7 +28,8 @@ public static class UserEndpoints
group.MapPost("/", CreateUser)
.WithName("CreateUser")
.WithSummary("Create a new user.");
.WithSummary("Create a new user.")
.AddEndpointFilter<ValidationFilter<CreateUserRequest>>();
return app;
}
+9 -17
View File
@@ -2,27 +2,19 @@ using FluentValidation;
namespace WebApi.Filters;
public sealed class ValidationFilter : IEndpointFilter
public sealed class ValidationFilter<T>(IValidator<T> validator) : IEndpointFilter where T : class
{
public async ValueTask<object?> InvokeAsync(EndpointFilterInvocationContext context, EndpointFilterDelegate next)
{
foreach (var argument in context.Arguments)
{
var argument = context.Arguments.OfType<T>().FirstOrDefault();
if (argument is null)
continue;
var validatorType = typeof(IValidator<>).MakeGenericType(argument.GetType());
if (context.HttpContext.RequestServices.GetService(validatorType) is not IValidator validator)
continue;
var validationContext = new ValidationContext<object>(argument);
var result = await validator.ValidateAsync(validationContext, context.HttpContext.RequestAborted);
if (!result.IsValid)
return Results.ValidationProblem(result.ToDictionary());
}
return await next(context);
var result = await validator.ValidateAsync(argument, context.HttpContext.RequestAborted);
return result.IsValid
? await next(context)
: Results.ValidationProblem(result.ToDictionary());
}
}