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

Compare commits

base: baguette:feature/mediator
Branches Tags
baguette:main
baguette:feature/mediator
..
compare: baguette:main
Branches Tags
baguette:feature/mediator
baguette:main

No commits in common. "feature/mediator" and "main" have entirely different histories.
feature/me ... main

8 changed files with 0 additions and 149 deletions
Show Stats Expand all files Collapse all files

14
Baguette.Extensions.AspNetCore.sln
View File

@ -1,22 +1,8 @@
 
Microsoft Visual Studio Solution File, Format Version 12.00 Microsoft Visual Studio Solution File, Format Version 12.00
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Baguette.Extensions.AspNetCore.Mediator", "src\Baguette.Extensions.AspNetCore.Mediator\Baguette.Extensions.AspNetCore.Mediator.csproj", "{9C7970CB-13DB-4016-A9D4-B52C8788BFBC}"
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Baguette.Extensions.AspNetCore.Mediator.MediatR", "src\Baguette.Extensions.AspNetCore.Mediator.MediatR\Baguette.Extensions.AspNetCore.Mediator.MediatR.csproj", "{2A0764B1-6C7D-4729-8A10-071897166AE4}"
EndProject
Global Global
GlobalSection(SolutionConfigurationPlatforms) = preSolution GlobalSection(SolutionConfigurationPlatforms) = preSolution
Debug|Any CPU = Debug|Any CPU Debug|Any CPU = Debug|Any CPU
Release|Any CPU = Release|Any CPU Release|Any CPU = Release|Any CPU
EndGlobalSection EndGlobalSection
GlobalSection(ProjectConfigurationPlatforms) = postSolution
{9C7970CB-13DB-4016-A9D4-B52C8788BFBC}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{9C7970CB-13DB-4016-A9D4-B52C8788BFBC}.Debug|Any CPU.Build.0 = Debug|Any CPU
{9C7970CB-13DB-4016-A9D4-B52C8788BFBC}.Release|Any CPU.ActiveCfg = Release|Any CPU
{9C7970CB-13DB-4016-A9D4-B52C8788BFBC}.Release|Any CPU.Build.0 = Release|Any CPU
{2A0764B1-6C7D-4729-8A10-071897166AE4}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{2A0764B1-6C7D-4729-8A10-071897166AE4}.Debug|Any CPU.Build.0 = Debug|Any CPU
{2A0764B1-6C7D-4729-8A10-071897166AE4}.Release|Any CPU.ActiveCfg = Release|Any CPU
{2A0764B1-6C7D-4729-8A10-071897166AE4}.Release|Any CPU.Build.0 = Release|Any CPU
EndGlobalSection
EndGlobal EndGlobal

17
src/Baguette.Extensions.AspNetCore.Mediator.MediatR/Baguette.Extensions.AspNetCore.Mediator.MediatR.csproj
View File

@ -1,17 +0,0 @@
<Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup>
<TargetFramework>net8.0</TargetFramework>
<ImplicitUsings>enable</ImplicitUsings>
<Nullable>enable</Nullable>
</PropertyGroup>
<ItemGroup>
<ProjectReference Include="..\Baguette.Extensions.AspNetCore.Mediator\Baguette.Extensions.AspNetCore.Mediator.csproj" />
</ItemGroup>
<ItemGroup>
<PackageReference Include="MediatR" Version="13.0.0" />
</ItemGroup>
</Project>

27
src/Baguette.Extensions.AspNetCore.Mediator.MediatR/MediatRService.cs
View File

@ -1,27 +0,0 @@
using System.Diagnostics.CodeAnalysis;
using MediatR;
namespace Baguette.Extensions.AspNetCore.Mediator.MediatR;
public class MediatRService(ISender sender) : IMediatorService
{
public async ValueTask<bool> TrySendAsync(object? value, CancellationToken cancellationToken = default)
{
if (value is not IRequest request)
return false;
await sender.Send(request, cancellationToken);
return true;
}
public async ValueTask<(bool IsSucess, TResponse? Response)> TrySendAsync<TResponse>(object? value, CancellationToken cancellationToken = default)
{
if (value is not IRequest<TResponse> request)
return (false, default);
var response = await sender.Send(request, cancellationToken);
return (true, response);
}
}

13
src/Baguette.Extensions.AspNetCore.Mediator/Baguette.Extensions.AspNetCore.Mediator.csproj
View File

@ -1,13 +0,0 @@
<Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup>
<TargetFramework>net8.0</TargetFramework>
<ImplicitUsings>enable</ImplicitUsings>
<Nullable>enable</Nullable>
</PropertyGroup>
<ItemGroup>
<FrameworkReference Include="Microsoft.AspNetCore.App"/>
</ItemGroup>
</Project>

10
src/Baguette.Extensions.AspNetCore.Mediator/IMediatorService.cs
View File

@ -1,10 +0,0 @@
using System.Diagnostics.CodeAnalysis;
namespace Baguette.Extensions.AspNetCore.Mediator;
public interface IMediatorService
{
ValueTask<bool> TrySendAsync(object? value, CancellationToken cancellationToken = default);
ValueTask<(bool IsSucess, TResponse? Response)> TrySendAsync<TResponse>(object? value, CancellationToken cancellationToken = default);
}

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

@ -1,17 +0,0 @@
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);
}
}

8
src/Baguette.Extensions.AspNetCore.Mediator/MediatorOptions.cs
View File

@ -1,8 +0,0 @@
using Microsoft.AspNetCore.Http;
namespace Baguette.Extensions.AspNetCore.Mediator;
public class MediatorOptions
{
public Func<EndpointFilterInvocationContext, object?, ValueTask<IResult>> OnRequestSendFailed { get; set; } = (_, _) => throw new NotImplementedException();
}

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

@ -1,43 +0,0 @@
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Options;
namespace Baguette.Extensions.AspNetCore.Mediator;
public class SendEndpointRequestFilter<TResponse> : IEndpointFilter
{
public async ValueTask<object?> InvokeAsync(EndpointFilterInvocationContext context, EndpointFilterDelegate next)
{
var mediator = context.HttpContext.RequestServices.GetRequiredService<IMediatorService>();
var options = context.HttpContext.RequestServices.GetRequiredService<IOptionsSnapshot<MediatorOptions>>().Value;
var value = await next(context);
if (value is IResult)
return value; // If the next delegate already returned an IResult, just return it
var (success, response) = await mediator.TrySendAsync<TResponse>(value);
return success
? Results.Ok(response)
: await options.OnRequestSendFailed(context, value);
}
}
public class SendEndpointRequestFilter : IEndpointFilter
{
public async ValueTask<object?> InvokeAsync(EndpointFilterInvocationContext context, EndpointFilterDelegate next)
{
var mediator = context.HttpContext.RequestServices.GetRequiredService<IMediatorService>();
var options = context.HttpContext.RequestServices.GetRequiredService<IOptionsSnapshot<MediatorOptions>>().Value;
var value = await next(context);
if (value is IResult)
return value; // If the next delegate already returned an IResult, just return it
return await mediator.TrySendAsync(value)
? Results.Ok()
: await options.OnRequestSendFailed(context, value);
}
}