Replace MediatR with source-generated Mediator across application and tests

Directory.Packages.props

@@ -1,4 +1,4 @@
-<Project>
+<Project>
   <PropertyGroup>
     <ManagePackageVersionsCentrally>true</ManagePackageVersionsCentrally>
     <TreatWarningsAsErrors>true</TreatWarningsAsErrors>
@@ -35,7 +35,8 @@
     <PackageVersion Include="GoogleReCaptcha.V3" Version="1.3.1" />
     <PackageVersion Include="Markdig" Version="1.3.2" />
     <PackageVersion Include="MediaInfo.Wrapper.Core" Version="21.9.3" />
-    <PackageVersion Include="MediatR" Version="14.1.0" />
+    <PackageVersion Include="Mediator.Abstractions" Version="3.0.2" />
+    <PackageVersion Include="Mediator.SourceGenerator" Version="3.0.2" />
     <PackageVersion Include="Microsoft.Extensions.Http.Resilience" Version="10.2.0" />
     <PackageVersion Include="Microsoft.Extensions.ServiceDiscovery" Version="10.2.0" />
     <PackageVersion Include="OpenTelemetry.Exporter.OpenTelemetryProtocol" Version="1.15.0" />

src/DevBetterWeb.Core/DevBetterWeb.Core.csproj

@@ -19,7 +19,7 @@
 		<PackageReference Include="Ardalis.SmartEnum" />
 		<PackageReference Include="Ardalis.Specification" />
 		<PackageReference Include="CSharpFunctionalExtensions" />
-		<PackageReference Include="MediatR" />
+		<PackageReference Include="Mediator.Abstractions" />
 		<PackageReference Include="Microsoft.ApplicationInsights.AspNetCore" />
 		<PackageReference Include="Microsoft.Extensions.Identity.Core" />
 		<PackageReference Include="NimblePros.Vimeo" />

src/DevBetterWeb.Core/Events/AppStartedEvent.cs

@@ -1,6 +1,6 @@
 using System;
 using DevBetterWeb.Core.SharedKernel;
-using MediatR;
+using Mediator;
 
 namespace DevBetterWeb.Core.Events;
 

src/DevBetterWeb.Core/Interfaces/IHandle.cs

@@ -2,7 +2,7 @@
 using System.Threading.Tasks;
 using DevBetterWeb.Core.Events;
 using DevBetterWeb.Core.SharedKernel;
-using MediatR;
+using Mediator;
 
 namespace DevBetterWeb.Core.Interfaces;
 

src/DevBetterWeb.Core/SharedKernel/BaseDomainEvent.cs

@@ -1,5 +1,5 @@
 using System;
-using MediatR;
+using Mediator;
 
 namespace DevBetterWeb.Core.SharedKernel;
 

src/DevBetterWeb.Infrastructure/DevBetterWeb.Infrastructure.csproj

@@ -18,7 +18,7 @@
   <ItemGroup>
     <PackageReference Include="Ardalis.Specification.EntityFrameworkCore" />
     <PackageReference Include="Markdig" />
-    <PackageReference Include="MediatR" />
+    <PackageReference Include="Mediator.Abstractions" />
     <PackageReference Include="NimblePros.Vimeo" />
     <PackageReference Include="Ardalis.EFCore.Extensions" />
     <PackageReference Include="Microsoft.AspNetCore.Identity.EntityFrameworkCore" />

src/DevBetterWeb.Infrastructure/DomainEvents/DomainEventHandler.cs

@@ -3,7 +3,7 @@
 using System.Threading.Tasks;
 using DevBetterWeb.Core.Interfaces;
 using DevBetterWeb.Core.SharedKernel;
-using MediatR;
+using Mediator;
 
 namespace DevBetterWeb.Infrastructure.DomainEvents;
 
@@ -17,7 +17,7 @@ public DomainEventHandler(IEnumerable<IHandle<TDomainEvent>> handlers)
 		_handlers = handlers;
 	}
 
-	public async Task Handle(TDomainEvent notification, CancellationToken cancellationToken)
+	public async ValueTask Handle(TDomainEvent notification, CancellationToken cancellationToken)
 	{
 		foreach (var handler in _handlers)
 		{

src/DevBetterWeb.Infrastructure/DomainEvents/MediatRDomainEventDispatcher.cs → src/DevBetterWeb.Infrastructure/DomainEvents/MediatorDomainEventDispatcher.cs

@@ -3,17 +3,17 @@
 using System.Threading.Tasks;
 using DevBetterWeb.Core.Interfaces;
 using DevBetterWeb.Core.SharedKernel;
-using MediatR;
+using Mediator;
 using Microsoft.Extensions.Logging;
 
 namespace DevBetterWeb.Infrastructure.DomainEvents;
 
-public class MediatRDomainEventDispatcher : IDomainEventDispatcher
+public class MediatorDomainEventDispatcher : IDomainEventDispatcher
 {
 	private readonly IMediator _mediator;
-	private readonly ILogger<MediatRDomainEventDispatcher> _logger;
+	private readonly ILogger<MediatorDomainEventDispatcher> _logger;
 
-	public MediatRDomainEventDispatcher(IMediator mediator, ILogger<MediatRDomainEventDispatcher> logger)
+	public MediatorDomainEventDispatcher(IMediator mediator, ILogger<MediatorDomainEventDispatcher> logger)
 	{
 		_mediator = mediator;
 		_logger = logger;

src/DevBetterWeb.Infrastructure/Handlers/DiscordLogVideoAddedHandler.cs

@@ -3,7 +3,7 @@
 using DevBetterWeb.Core.Events;
 using DevBetterWeb.Core.Interfaces;
 using DevBetterWeb.Infrastructure.DiscordWebooks;
-using MediatR;
+using Mediator;
 
 namespace DevBetterWeb.Core.Handlers;
 

src/DevBetterWeb.Infrastructure/InfrastructureServiceCollectionExtensions.cs

@@ -31,7 +31,7 @@ public static IServiceCollection AddInfrastructureServices(this IServiceCollecti
 		}
 
 		// Common Dependencies
-		services.AddScoped<IDomainEventDispatcher,MediatRDomainEventDispatcher>();
+		services.AddScoped<IDomainEventDispatcher, MediatorDomainEventDispatcher>();
 //		services.AddScoped<IDomainEventDispatcher>(sp => sp.GetRequiredService<DomainEventDispatcher>());
 
 		services.AddScoped<IMemberRegistrationService, MemberRegistrationService>();

src/DevBetterWeb.Infrastructure/Services/AspNetCoreIdentityUserEmailConfirmationService.cs

@@ -3,7 +3,7 @@
 using DevBetterWeb.Core.Exceptions;
 using DevBetterWeb.Core.Interfaces;
 using DevBetterWeb.Infrastructure.Identity.Data;
-using MediatR;
+using Mediator;
 using Microsoft.AspNetCore.Identity;
 using Microsoft.EntityFrameworkCore;
 

src/DevBetterWeb.Infrastructure/Services/AspNetCoreIdentityUserRoleMembershipService.cs

@@ -3,7 +3,7 @@
 using DevBetterWeb.Core.Exceptions;
 using DevBetterWeb.Core.Interfaces;
 using DevBetterWeb.Infrastructure.Identity.Data;
-using MediatR;
+using Mediator;
 using Microsoft.AspNetCore.Identity;
 using Microsoft.EntityFrameworkCore;
 

src/DevBetterWeb.Web/Areas/Identity/Pages/Account/ForgotPassword.cshtml.cs

@@ -6,7 +6,7 @@
 using DevBetterWeb.Core.Events;
 using DevBetterWeb.Infrastructure.DomainEvents;
 using DevBetterWeb.Infrastructure.Identity.Data;
-using MediatR;
+using Mediator;
 using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Identity;
 using Microsoft.AspNetCore.Identity.UI.Services;

src/DevBetterWeb.Web/Areas/Identity/Pages/Account/NewMemberRegister.cshtml.cs

@@ -8,7 +8,7 @@
 using DevBetterWeb.Core.Interfaces;
 using DevBetterWeb.Infrastructure.Identity.Data;
 using GoogleReCaptcha.V3.Interface;
-using MediatR;
+using Mediator;
 using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Identity;
 using Microsoft.AspNetCore.Mvc;

src/DevBetterWeb.Web/Areas/Identity/Pages/Account/Register.cshtml.cs

@@ -6,7 +6,7 @@
 using DevBetterWeb.Core.Interfaces;
 using DevBetterWeb.Infrastructure.Identity.Data;
 using GoogleReCaptcha.V3.Interface;
-using MediatR;
+using Mediator;
 using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Identity;
 using Microsoft.AspNetCore.Mvc;

src/DevBetterWeb.Web/Controllers/HomeController.cs

@@ -1,5 +1,5 @@
 using DevBetterWeb.Core.Events;
-using MediatR;
+using Mediator;
 using Microsoft.AspNetCore.Diagnostics;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.AspNetCore.Mvc;

src/DevBetterWeb.Web/DevBetterWeb.Web.csproj

@@ -21,7 +21,8 @@
 		<PackageReference Include="CSharpFunctionalExtensions" />
 		<PackageReference Include="Dapper" />
 		<PackageReference Include="GoogleReCaptcha.V3" />
-		<PackageReference Include="MediatR" />
+		<PackageReference Include="Mediator.Abstractions" />
+		<PackageReference Include="Mediator.SourceGenerator" />
 		<PackageReference Include="Microsoft.ApplicationInsights.AspNetCore" />
 		<PackageReference Include="Microsoft.AspNetCore.AzureAppServices.HostingStartup" />
 		<PackageReference Include="Microsoft.AspNetCore.Mvc.Razor.RuntimeCompilation" />

src/DevBetterWeb.Web/Pages/User/MyProfile/EditAvatar.cshtml.cs

@@ -9,7 +9,7 @@
 using DevBetterWeb.Core.Interfaces;
 using DevBetterWeb.Core.Specs;
 using DevBetterWeb.Infrastructure.Identity.Data;
-using MediatR;
+using Mediator;
 using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Identity;

src/DevBetterWeb.Web/Program.cs

@@ -91,11 +91,15 @@
 
 builder.Services.AddInfrastructureServices(isDevelopment, vimeoToken);
 
-builder.Services.AddMediatR(cfg =>
-	cfg.RegisterServicesFromAssemblies(
-		typeof(IAggregateRoot).Assembly,
-		typeof(AppDbContext).Assembly,
-		typeof(Program).Assembly));
+builder.Services.AddMediator(options =>
+{
+	options.Assemblies =
+	[
+		typeof(IAggregateRoot),
+		typeof(AppDbContext),
+		typeof(Program)
+	];
+});
 
 builder.Services.AddScoped(typeof(IRepository<>), typeof(EfRepository<>));
 

src/DevBetterWeb.Web/Services/DailyCheckService.cs

@@ -5,7 +5,7 @@
 using DevBetterWeb.Core.Events;
 using DevBetterWeb.Core.Interfaces;
 using DevBetterWeb.Core.Specs;
-using MediatR;
+using Mediator;
 using Microsoft.Extensions.Hosting;
 using Microsoft.Extensions.Logging;
 

src/DevBetterWeb.Web/Services/StartupNotificationService.cs

@@ -3,7 +3,7 @@
 using System.Threading.Tasks;
 using DevBetterWeb.Core.Events;
 using DevBetterWeb.Core.Interfaces;
-using MediatR;
+using Mediator;
 using Microsoft.Extensions.Hosting;
 using Microsoft.Extensions.Logging;
 

tests/DevBetterWeb.FunctionalTests/CustomWebApplicationFactory.cs

@@ -6,7 +6,7 @@
 using DevBetterWeb.Web;
 using DevBetterWeb.Web.Areas.Identity;
 using DevBetterWeb.Web.Models;
-using MediatR;
+using Mediator;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.AspNetCore.Identity;
 using Microsoft.AspNetCore.Mvc.Testing;

tests/DevBetterWeb.FunctionalTests/DevBetterWeb.FunctionalTests.csproj

@@ -6,7 +6,7 @@
 	</PropertyGroup>
 
     <ItemGroup>
-        <PackageReference Include="MediatR" />
+        <PackageReference Include="Mediator.Abstractions" />
         <PackageReference Include="Microsoft.Extensions.Identity.Core" />
         <PackageReference Include="Microsoft.NET.Test.Sdk" />
         <PackageReference Include="xunit" />

tests/DevBetterWeb.FunctionalTests/NoOpMediator.cs

@@ -1,11 +1,11 @@
 using System.Collections.Generic;
 using System.Threading;
 using System.Threading.Tasks;
-using MediatR;
+using Mediator;
 
 namespace DevBetterWeb.FunctionalTests;
 
 public class NoOpMediator : IMediator
 {
 	public IAsyncEnumerable<TResponse> CreateStream<TResponse>(IStreamRequest<TResponse> request, CancellationToken cancellationToken = default)
 	{