baguette/aspnetcore-extensions
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

Add Mediator endpoint route builder extensions and refactor SendEndpointRequestFilter

Browse Source
This commit is contained in:
Jens De Craecker 2025-09-12 16:26:51 +02:00
parent 96018137cc
commit 544d23a397
2 changed files with 17 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/Baguette.Extensions.AspNetCore.Mediator/MediatorEndpointRouteBuilderExtensions.cs Normal file
View File

@ -0,0 +1,17 @@
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Http;
namespace Baguette.Extensions.AspNetCore.Mediator;
public static class MediatorEndpointRouteBuilderExtensions
{
public static RouteHandlerBuilder SendRequest<TResponse>(this RouteHandlerBuilder builder)
{
return builder.AddEndpointFilter<SendEndpointRequestFilter<TResponse>>().Produces<TResponse>();
}
public static RouteHandlerBuilder SendRequest(this RouteHandlerBuilder builder)
{
return builder.AddEndpointFilter<SendEndpointRequestFilter>().Produces(StatusCodes.Status200OK);
}
}

14
src/Baguette.Extensions.AspNetCore.Mediator/SendEndpointRequestFilter.cs
View File

@ -1,4 +1,3 @@
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Http; using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.DependencyInjection;
@ -39,16 +38,3 @@ public class SendEndpointRequestFilter : IEndpointFilter
: throw new InvalidOperationException(); // TODO: Handle case where request can't be sent : throw new InvalidOperationException(); // TODO: Handle case where request can't be sent
} }
} }
public static class MediatorEndpointRouteBuilderExtensions
{
public static RouteHandlerBuilder SendRequest<TResponse>(this RouteHandlerBuilder builder)
{
return builder.AddEndpointFilter<SendEndpointRequestFilter<TResponse>>().Produces<TResponse>();
}
public static RouteHandlerBuilder SendRequest(this RouteHandlerBuilder builder)
{
return builder.AddEndpointFilter<SendEndpointRequestFilter>().Produces(StatusCodes.Status200OK);
}
}