Migrate to Mediato (#63)

- migrated from MediatR to Mediator (#60)
- improved logging and debug logging
- fixed some potential concurrency problems in testing
- formatting changes

Author: skrasekmichael

Directory.Packages.props

@@ -24,13 +24,14 @@
     <PackageVersion Include="Microsoft.Extensions.Options.ConfigurationExtensions" Version="9.0.4" />
     <PackageVersion Include="Microsoft.IdentityModel.Tokens" Version="8.9.0" />
     <PackageVersion Include="Microsoft.NET.Test.Sdk" Version="17.13.0" />
-    <PackageVersion Include="MediatR" Version="12.5.0" />
     <PackageVersion Include="NetArchTest.Rules" Version="1.3.2" />
     <PackageVersion Include="Npgsql.EntityFrameworkCore.PostgreSQL" Version="9.0.4" />
     <PackageVersion Include="Quartz" Version="3.14.0" />
     <PackageVersion Include="Quartz.Extensions.Hosting" Version="3.14.0" />
     <PackageVersion Include="Respawn" Version="6.2.1" />
     <PackageVersion Include="Riok.Mapperly" Version="4.2.1" />
+    <PackageVersion Include="Skrasek.Mediato.Abstractions" Version="1.0.4" />
+    <PackageVersion Include="Skrasek.Mediato.MicrosoftDependencyInjection" Version="1.0.4" />
     <PackageVersion Include="Skrasek.RailwayResult" Version="1.2.0" />
     <PackageVersion Include="Skrasek.RailwayResult.Errors" Version="1.2.0" />
     <PackageVersion Include="Skrasek.RailwayResult.FunctionalExtensions" Version="1.2.0" />

src/TeamUp.Api/Endpoints/Events/CreateEventEndpoint.cs

@@ -1,7 +1,5 @@
-using MediatR;
-
+using Mediato.Abstractions;
 using Microsoft.AspNetCore.Mvc;
-
 using TeamUp.Api.Extensions;
 using TeamUp.Application.Events.CreateEvent;
 using TeamUp.Contracts.Events;
@@ -28,7 +26,7 @@ public void MapEndpoints(RouteGroupBuilder group)
 	public async Task<IResult> CreateEventAsync(
 		[FromRoute] Guid teamId,
 		[FromBody] CreateEventRequest request,
-		[FromServices] ISender sender,
+		[FromServices] IRequestSender sender,
 		[FromServices] LinkGenerator linkGenerator,
 		HttpContext httpContext,
 		CancellationToken ct)
@@ -44,7 +42,7 @@ public async Task<IResult> CreateEventAsync(
 			ReplyClosingTimeBeforeMeetTime: request.ReplyClosingTimeBeforeMeetTime
 		);
 
-		var result = await sender.Send(command, ct);
+		var result = await sender.SendAsync<CreateEventCommand, RailwayResult.Result<EventId>>(command, ct);
 		return result.ToResponse(eventId => TypedResults.Created(
 			linkGenerator.GetPathByName(httpContext, nameof(GetEventEndpoint), new { teamId, eventId = eventId.Value }),
 			eventId

src/TeamUp.Api/Endpoints/Events/GetEventEndpoint.cs

@@ -1,7 +1,5 @@
-using MediatR;
-
+using Mediato.Abstractions;
 using Microsoft.AspNetCore.Mvc;
-
 using TeamUp.Api.Extensions;
 using TeamUp.Application.Events.GetEvent;
 using TeamUp.Contracts.Events;
@@ -27,7 +25,7 @@ public void MapEndpoints(RouteGroupBuilder group)
 	public async Task<IResult> GetEventAsync(
 		[FromRoute] Guid teamId,
 		[FromRoute] Guid eventId,
-		[FromServices] ISender sender,
+		[FromServices] IRequestSender sender,
 		HttpContext httpContext,
 		CancellationToken ct)
 	{
@@ -37,7 +35,7 @@ public async Task<IResult> GetEventAsync(
 			EventId.FromGuid(eventId)
 		);
 
-		var result = await sender.Send(query, ct);
+		var result = await sender.SendAsync<GetEventQuery, RailwayResult.Result<EventResponse>>(query, ct);
 		return result.ToResponse(TypedResults.Ok);
 	}
 }

src/TeamUp.Api/Endpoints/Events/GetEventsEndpoint.cs

@@ -1,7 +1,5 @@
-using MediatR;
-
+using Mediato.Abstractions;
 using Microsoft.AspNetCore.Mvc;
-
 using TeamUp.Api.Extensions;
 using TeamUp.Application.Events.GetEvents;
 using TeamUp.Contracts.Events;
@@ -26,7 +24,7 @@ public void MapEndpoints(RouteGroupBuilder group)
 	public async Task<IResult> GetEventsAsync(
 		[FromRoute] Guid teamId,
 		[FromQuery] DateTime? fromUtc,
-		[FromServices] ISender sender,
+		[FromServices] IRequestSender sender,
 		HttpContext httpContext,
 		CancellationToken ct)
 	{
@@ -36,7 +34,7 @@ public async Task<IResult> GetEventsAsync(
 			fromUtc
 		);
 
-		var result = await sender.Send(query, ct);
+		var result = await sender.SendAsync<GetEventsQuery, RailwayResult.Result<List<EventSlimResponse>>>(query, ct);
 		return result.ToResponse(TypedResults.Ok);
 	}
 }

src/TeamUp.Api/Endpoints/Events/RemoveEventEndpoint.cs

@@ -1,7 +1,5 @@
-using MediatR;
-
+using Mediato.Abstractions;
 using Microsoft.AspNetCore.Mvc;
-
 using TeamUp.Api.Extensions;
 using TeamUp.Application.Events.RemoveEvent;
 using TeamUp.Contracts.Teams;
@@ -25,13 +23,12 @@ public void MapEndpoints(RouteGroupBuilder group)
 	private async Task<IResult> RemoveEventAsync(
 		[FromRoute] Guid teamId,
 		[FromRoute] Guid eventId,
-		[FromServices] ISender sender,
+		[FromServices] IRequestSender sender,
 		HttpContext httpContext,
 		CancellationToken ct)
 	{
 		var command = new RemoveEventCommand(httpContext.GetCurrentUserId(), TeamId.FromGuid(teamId), EventId.FromGuid(eventId));
-		var result = await sender.Send(command, ct);
+		var result = await sender.SendAsync<RemoveEventCommand, RailwayResult.Result>(command, ct);
 		return result.ToResponse(TypedResults.Ok);
 	}
-
 }

src/TeamUp.Api/Endpoints/Events/UpsertEventReplyEndpoint.cs

@@ -1,7 +1,5 @@
-using MediatR;
-
+using Mediato.Abstractions;
 using Microsoft.AspNetCore.Mvc;
-
 using TeamUp.Api.Extensions;
 using TeamUp.Application.Events.UpsertEventReply;
 using TeamUp.Contracts.Events;
@@ -30,7 +28,7 @@ public async Task<IResult> UpsertEventReplyAsync(
 		[FromRoute] Guid teamId,
 		[FromRoute] Guid eventId,
 		[FromBody] UpsertEventReplyRequest request,
-		[FromServices] ISender sender,
+		[FromServices] IRequestSender sender,
 		HttpContext httpContext,
 		CancellationToken ct)
 	{
@@ -42,7 +40,7 @@ public async Task<IResult> UpsertEventReplyAsync(
 			Message: request.Message
 		);
 
-		var result = await sender.Send(command, ct);
+		var result = await sender.SendAsync<UpsertEventReplyCommand, RailwayResult.Result>(command, ct);
 		return result.ToResponse(TypedResults.Ok);
 	}
 }

src/TeamUp.Api/Endpoints/Invitations/AcceptInvitaionEndpoint.cs

@@ -1,7 +1,5 @@
-using MediatR;
-
+using Mediato.Abstractions;
 using Microsoft.AspNetCore.Mvc;
-
 using TeamUp.Api.Extensions;
 using TeamUp.Application.Invitations.AcceptInvitation;
 using TeamUp.Contracts.Invitations;
@@ -24,12 +22,12 @@ public void MapEndpoints(RouteGroupBuilder group)
 
 	private async Task<IResult> AcceptInvitationAsync(
 		[FromRoute] Guid invitationId,
-		[FromServices] ISender sender,
+		[FromServices] IRequestSender sender,
 		HttpContext httpContext,
 		CancellationToken ct)
 	{
 		var command = new AcceptInvitationCommand(httpContext.GetCurrentUserId(), InvitationId.FromGuid(invitationId));
-		var result = await sender.Send(command, ct);
+		var result = await sender.SendAsync<AcceptInvitationCommand, RailwayResult.Result>(command, ct);
 		return result.ToResponse(TypedResults.Ok);
 	}
 }

src/TeamUp.Api/Endpoints/Invitations/GetMyInvitationsEndpoint.cs

@@ -1,7 +1,5 @@
-using MediatR;
-
+using Mediato.Abstractions;
 using Microsoft.AspNetCore.Mvc;
-
 using TeamUp.Api.Extensions;
 using TeamUp.Application.Invitations.GetMyInvitations;
 using TeamUp.Contracts.Invitations;
@@ -20,12 +18,12 @@ public void MapEndpoints(RouteGroupBuilder group)
 	}
 
 	private async Task<IResult> GetTeamInvitationsAsync(
-		[FromServices] ISender sender,
+		[FromServices] IRequestSender sender,
 		HttpContext httpContext,
 		CancellationToken ct)
 	{
 		var query = new GetMyInvitationsQuery(httpContext.GetCurrentUserId());
-		var result = await sender.Send(query, ct);
+		var result = await sender.SendAsync<GetMyInvitationsQuery, RailwayResult.Result<List<InvitationResponse>>>(query, ct);
 		return result.ToResponse(TypedResults.Ok);
 	}
 }

src/TeamUp.Api/Endpoints/Invitations/GetTeamInvitationsEndpoint.cs

@@ -1,7 +1,5 @@
-using MediatR;
-
+using Mediato.Abstractions;
 using Microsoft.AspNetCore.Mvc;
-
 using TeamUp.Api.Extensions;
 using TeamUp.Application.Invitations.GetTeamInvitations;
 using TeamUp.Contracts.Invitations;
@@ -24,12 +22,12 @@ public void MapEndpoints(RouteGroupBuilder group)
 
 	private async Task<IResult> GetTeamInvitationsAsync(
 		[FromRoute] Guid teamId,
-		[FromServices] ISender sender,
+		[FromServices] IRequestSender sender,
 		HttpContext httpContext,
 		CancellationToken ct)
 	{
 		var query = new GetTeamInvitationsQuery(httpContext.GetCurrentUserId(), TeamId.FromGuid(teamId));
-		var result = await sender.Send(query, ct);
+		var result = await sender.SendAsync<GetTeamInvitationsQuery, RailwayResult.Result<List<TeamInvitationResponse>>>(query, ct);
 		return result.ToResponse(TypedResults.Ok);
 	}
 }

src/TeamUp.Api/Endpoints/Invitations/InviteUserEndpoint.cs

@@ -1,7 +1,5 @@
-using MediatR;
-
+using Mediato.Abstractions;
 using Microsoft.AspNetCore.Mvc;
-
 using TeamUp.Api.Extensions;
 using TeamUp.Application.Invitations.InviteUser;
 using TeamUp.Contracts.Invitations;
@@ -24,14 +22,14 @@ public void MapEndpoints(RouteGroupBuilder group)
 
 	private async Task<IResult> InviteUserAsync(
 		[FromBody] InviteUserRequest request,
-		[FromServices] ISender sender,
+		[FromServices] IRequestSender sender,
 		[FromServices] LinkGenerator linkGenerator,
 		HttpContext httpContext,
 		CancellationToken ct)
 	{
 		var command = new InviteUserCommand(httpContext.GetCurrentUserId(), request.TeamId, request.Email);
 
-		var result = await sender.Send(command, ct);
+		var result = await sender.SendAsync<InviteUserCommand, RailwayResult.Result<InvitationId>>(command, ct);
 		return result.ToResponse(invitationId => TypedResults.Created(
 			uri: linkGenerator.GetPathByName(httpContext, nameof(GetTeamInvitationsEndpoint), request.TeamId.Value),
 			value: invitationId