Remove DispatchR and use Mediator

Application/Application.csproj

@@ -9,8 +9,12 @@
 
   <ItemGroup>
     <PackageReference Include="Ardalis.Result" Version="10.1.0" />
-    <PackageReference Include="DispatchR.Mediator" Version="2.1.1" />
     <PackageReference Include="MassTransit" Version="9.0.1" />
+    <PackageReference Include="Mediator.Abstractions" Version="3.0.2" />
+    <PackageReference Include="Mediator.SourceGenerator" Version="3.0.2">
+      <PrivateAssets>all</PrivateAssets>
+      <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
+    </PackageReference>
     <PackageReference Include="Microsoft.EntityFrameworkCore" Version="10.0.5" />
     <PackageReference Include="Microsoft.Extensions.Configuration" Version="10.0.5" />
     <PackageReference Include="Microsoft.Extensions.Configuration.Binder" Version="10.0.5" />

Application/PlayLists/Commands/CreatePlayListCommand.cs

@@ -1,5 +1,5 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Musify.Application.Contracts.Application;
 using Musify.Application.PlayLists.Responses;
 using Musify.Domain.Entities;
@@ -11,7 +11,7 @@ namespace Musify.Application.PlayLists.Commands
         string Name,
         string Description,
         IFileData? Picture)
-        : IRequest<CreatePlayListCommand, Task<Result<PlayListResponse>> >
+        : ICommand<Result<PlayListResponse>>
     {
         public static PlayList ToEntity(CreatePlayListCommand command, string originalKey, string smallKey, string mediumKey, string largeKey)
         {

Application/PlayLists/Commands/DeletePlayListCommand.cs

@@ -1,8 +1,8 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 
 namespace Musify.Application.PlayLists.Commands
 {
     public record DeletePlayListCommand(Guid UserId, Guid PlayListId)
-        : IRequest<DeletePlayListCommand, Task<Result> >;
+        : ICommand<Result>;
 }

Application/PlayLists/Commands/UpdatePlayListCommand.cs

@@ -1,5 +1,5 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Musify.Application.Contracts.Application;
 using Musify.Application.PlayLists.Responses;
 
@@ -11,5 +11,5 @@ namespace Musify.Application.PlayLists.Commands
         string? NewName,
         string? NewDescription,
         IFileData? NewPicture)
-        : IRequest<UpdatePlayListCommand, Task<Result<PlayListResponse>> >;
+        : ICommand<Result<PlayListResponse>>;
 }

Application/PlayLists/Handlers/CreatePlayListCommandHandler.cs

@@ -1,5 +1,5 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Logging;
 using Musify.Application.Configuration;
@@ -14,9 +14,9 @@ namespace Musify.Application.PlayLists.Handlers
 {
     public class CreatePlayListCommandHandler(IEventBus eventBus, IDatabase database, IStorageService storageHandler,
         ILogger<CreatePlayListCommandHandler> logger, ApplicationStorageConfiguration storageConfiguration, PlayListConfiguration playListConfiguration)
-        : IRequestHandler<CreatePlayListCommand, Task<Result<PlayListResponse>> >
+        : ICommandHandler<CreatePlayListCommand, Result<PlayListResponse>> 
     {
-        public async Task<Result<PlayListResponse>> Handle(CreatePlayListCommand request, CancellationToken cancellationToken)
+        public async ValueTask<Result<PlayListResponse>> Handle(CreatePlayListCommand request, CancellationToken cancellationToken)
         {
             var userExists = await database.Users.AnyAsync(u => u.Id == request.UserId, cancellationToken);
             if (!userExists)

Application/PlayLists/Handlers/DeletePlayListCommandHandler.cs

@@ -1,5 +1,5 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Microsoft.Extensions.Logging;
 using Musify.Application.Configuration;
 using Musify.Application.Contracts.Infrastructure;
@@ -10,9 +10,9 @@ namespace Musify.Application.PlayLists.Handlers
 {
     public class DeletePlayListCommandHandler(IDatabase database, IEventBus eventBus,
         ApplicationStorageConfiguration storageConfiguration, PlayListConfiguration playListConfiguration, ILogger<DeletePlayListCommandHandler> logger)
-        : IRequestHandler<DeletePlayListCommand, Task<Result>>
+        : ICommandHandler<DeletePlayListCommand, Result>
     {
-        public async Task<Result> Handle(DeletePlayListCommand request, CancellationToken cancellationToken)
+        public async ValueTask<Result> Handle(DeletePlayListCommand request, CancellationToken cancellationToken)
         {
             var playList = await database.PlayLists.FindAsync(
                 [request.PlayListId],

Application/PlayLists/Handlers/GetPlayListByIdQueryHandler.cs

@@ -1,16 +1,16 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
 using Microsoft.EntityFrameworkCore;
 using Musify.Application.Contracts.Infrastructure;
 using Musify.Application.PlayLists.Responses;
 using Musify.Application.PlayLists.Queries;
+using Mediator;
 
 namespace Musify.Application.PlayLists.Handlers
 {
     public class GetPlayListByIdQueryHandler(IDatabase database)
-        : IRequestHandler<GetPlayListByIdQuery, Task<Result<PlayListResponse>> >
+        : IQueryHandler<GetPlayListByIdQuery, Result<PlayListResponse>>
     {
-        public async Task<Result<PlayListResponse>> Handle(GetPlayListByIdQuery request, CancellationToken cancellationToken)
+        public async ValueTask<Result<PlayListResponse>> Handle(GetPlayListByIdQuery request, CancellationToken cancellationToken)
         {
             var playList = await database.PlayLists
                 .AsNoTracking()

Application/PlayLists/Handlers/GetPlayListsByUserIdQueryHandler.cs

@@ -1,18 +1,18 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
 using Microsoft.EntityFrameworkCore;
 using Musify.Application.Contracts.Application;
 using Musify.Application.Contracts.Infrastructure;
 using Musify.Application.PlayLists.Responses;
 using Musify.Application.PlayLists.Queries;
 using X.PagedList.EF;
+using Mediator;
 
 namespace Musify.Application.PlayLists.Handlers
 {
     public class GetPlayListsByUserIdQueryHandler(IDatabase database)
-        : IRequestHandler<GetPlayListsByUserIdQuery, Task<Result<PaginatedResponse<PlayListResponse> > >>
+        : IQueryHandler<GetPlayListsByUserIdQuery, Result<PaginatedResponse<PlayListResponse> > >
     {
-        public async Task<Result<PaginatedResponse<PlayListResponse> >> Handle(GetPlayListsByUserIdQuery request, CancellationToken cancellationToken)
+        public async ValueTask<Result<PaginatedResponse<PlayListResponse> >> Handle(GetPlayListsByUserIdQuery request, CancellationToken cancellationToken)
         {
             var pageNumber = request.PageNumber < 1 ? 1 : request.PageNumber;
             var pageSize = request.PageSize < 1 ? 10 : request.PageSize;

Application/PlayLists/Handlers/GetPlayListsQueryHandler.cs

@@ -1,18 +1,18 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
 using Microsoft.EntityFrameworkCore;
 using Musify.Application.Contracts.Application;
 using Musify.Application.Contracts.Infrastructure;
 using Musify.Application.PlayLists.Responses;
 using Musify.Application.PlayLists.Queries;
 using X.PagedList.EF;
+using Mediator;
 
 namespace Musify.Application.PlayLists.Handlers
 {
     public class GetPlayListsQueryHandler(IDatabase database)
-        : IRequestHandler<GetPlayListsQuery, Task<Result<PaginatedResponse<PlayListResponse> >> >
+        : IQueryHandler<GetPlayListsQuery, Result<PaginatedResponse<PlayListResponse> >>
     {
-        public async Task<Result<PaginatedResponse<PlayListResponse> >> Handle(GetPlayListsQuery request, CancellationToken cancellationToken)
+        public async ValueTask<Result<PaginatedResponse<PlayListResponse> >> Handle(GetPlayListsQuery request, CancellationToken cancellationToken)
         {
             var pageNumber = request.PageNumber < 1 ? 1 : request.PageNumber;
             var pageSize = request.PageSize < 1 ? 10 : request.PageSize;

Application/PlayLists/Handlers/UpdatePlayListCommandHandler.cs

@@ -1,5 +1,5 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Microsoft.Extensions.Logging;
 using Musify.Application.Configuration;
 using Musify.Application.Contracts.Application;
@@ -14,9 +14,9 @@ namespace Musify.Application.PlayLists.Handlers
     public class UpdatePlayListCommandHandler(IEventBus eventBus, IDatabase database, IStorageService storageHandler,
         ILogger<UpdatePlayListCommandHandler> logger, ApplicationStorageConfiguration storageConfiguration,
         PlayListConfiguration playListConfiguration)
-        : IRequestHandler<UpdatePlayListCommand, Task<Result<PlayListResponse>> >
+        : ICommandHandler<UpdatePlayListCommand, Result<PlayListResponse>>
     {
-        public async Task<Result<PlayListResponse>> Handle(UpdatePlayListCommand request, CancellationToken cancellationToken)
+        public async ValueTask<Result<PlayListResponse>> Handle(UpdatePlayListCommand request, CancellationToken cancellationToken)
         {
             var playListEntity = await database.PlayLists.FindAsync(
                 [request.PlayListId],

Application/PlayLists/Queries/GetPlayListByIdQuery.cs

@@ -1,9 +1,9 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Musify.Application.PlayLists.Responses;
 
 namespace Musify.Application.PlayLists.Queries
 {
     public record GetPlayListByIdQuery(Guid Id)
-        : IRequest<GetPlayListByIdQuery, Task<Result<PlayListResponse>>>;
+        : IQuery<Result<PlayListResponse>>;
 }

Application/PlayLists/Queries/GetPlayListsByUserIdQuery.cs

@@ -1,5 +1,5 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Musify.Application.Contracts.Application;
 using Musify.Application.PlayLists.Responses;
 
@@ -10,5 +10,5 @@ namespace Musify.Application.PlayLists.Queries
         string Name = "",
         int PageNumber = 1,
         int PageSize = 10)
-        : IRequest<GetPlayListsByUserIdQuery, Task<Result<PaginatedResponse<PlayListResponse>> >>;
+        : IQuery<Result<PaginatedResponse<PlayListResponse>> >;
 }

Application/PlayLists/Queries/GetPlayListsQuery.cs

@@ -1,10 +1,10 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Musify.Application.Contracts.Application;
 using Musify.Application.PlayLists.Responses;
 
 namespace Musify.Application.PlayLists.Queries
 {
     public record GetPlayListsQuery(int PageNumber = 1, int PageSize = 10)
-        : IRequest<GetPlayListsQuery, Task<Result<PaginatedResponse<PlayListResponse>> >>;
+        : IQuery<Result<PaginatedResponse<PlayListResponse>> >;
 }

Application/Tracks/Commands/CreateTrackCommand.cs

@@ -1,5 +1,5 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Musify.Application.Contracts.Application;
 using Musify.Application.Tracks.Responses;
 using Musify.Domain.Entities;
@@ -11,7 +11,7 @@ namespace Musify.Application.Tracks.Commands
         string Title,
         IFileData Picture,
         IFileData Audio)
-        : IRequest<CreateTrackCommand, Task<Result<TrackResponse> >>
+        : ICommand<Result<TrackResponse> >
     {
         public static Track ToEntity(CreateTrackCommand command, string smallPictureName, string mediumPictureName, string largePictureName)
         {

Application/Tracks/Commands/DeleteTrackCommand.cs

@@ -1,10 +1,10 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 
 namespace Musify.Application.Tracks.Commands
 {
     public record DeleteTrackCommand(
         Guid UserId,
         Guid TrackId)
-        : IRequest<DeleteTrackCommand, Task<Result>>;
+        : ICommand<Result>;
 }

Application/Tracks/Handler/CreateTrackCommandHandler.cs

@@ -1,5 +1,5 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Microsoft.Extensions.Logging;
 using Musify.Application.Configuration;
 using Musify.Application.Contracts.Infrastructure;
@@ -12,9 +12,9 @@ namespace Musify.Application.Tracks.Handler
 {
     public class CreateTrackCommandHandler(IDatabase database, IEventBus eventBus, IStorageService storageHandler,
         ILogger<CreateTrackCommandHandler> logger, ApplicationStorageConfiguration storageConfiguration, TrackConfiguration trackConfiguration)
-        : IRequestHandler<CreateTrackCommand, Task<Result<TrackResponse> >>
+        : ICommandHandler<CreateTrackCommand, Result<TrackResponse> >
     {
-        public async Task<Result<TrackResponse>> Handle(CreateTrackCommand request, CancellationToken cancellationToken)
+        public async ValueTask<Result<TrackResponse>> Handle(CreateTrackCommand request, CancellationToken cancellationToken)
         {
             var userExists = await database.Users.FindAsync(request.UserId, cancellationToken);
             if (userExists is null)

Application/Tracks/Handler/DeleteTrackCommandHandler.cs

@@ -1,5 +1,5 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Microsoft.Extensions.Logging;
 using Musify.Application.Configuration;
 using Musify.Application.Contracts.Infrastructure;
@@ -10,9 +10,9 @@ namespace Musify.Application.Tracks.Handler
 {
     public class DeleteTrackCommandHandler(IDatabase database, IStorageService storageHandler, ILogger<DeleteTrackCommandHandler> logger,
         TrackConfiguration trackConfiguration, ApplicationStorageConfiguration storageConfiguration)
-        : IRequestHandler<DeleteTrackCommand, Task<Result>>
+        : ICommandHandler<DeleteTrackCommand, Result>
     {
-        public async Task<Result> Handle(DeleteTrackCommand request, CancellationToken cancellationToken)
+        public async ValueTask<Result> Handle(DeleteTrackCommand request, CancellationToken cancellationToken)
         {
             var track = await database.Tracks.FindAsync(request.TrackId, cancellationToken);
             if (track is null)

Application/Tracks/Handler/GetTrackByIdQueryHandler.cs

@@ -1,5 +1,5 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Musify.Application.Contracts.Infrastructure;
 using Musify.Application.Tracks.Queries;
 using Musify.Application.Tracks.Responses;
@@ -7,9 +7,9 @@ using Musify.Application.Tracks.Responses;
 namespace Musify.Application.Tracks.Handler
 {
     public class GetTrackByIdQueryHandler(IDatabase database)
-        : IRequestHandler<GetTrackByIdQuery, Task<Result<TrackResponse> >>
+        : IQueryHandler<GetTrackByIdQuery, Result<TrackResponse> >
     {
-        public async Task<Result<TrackResponse>> Handle(GetTrackByIdQuery request, CancellationToken cancellationToken)
+        public async ValueTask<Result<TrackResponse>> Handle(GetTrackByIdQuery request, CancellationToken cancellationToken)
         {
             var track = await database.Tracks.FindAsync(request.TrackId);
 

Application/Tracks/Handler/GetTracksByUserIdQueryHandler.cs

@@ -1,5 +1,5 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Microsoft.EntityFrameworkCore;
 using Musify.Application.Contracts.Application;
 using Musify.Application.Contracts.Infrastructure;
@@ -10,9 +10,9 @@ using X.PagedList.EF;
 namespace Musify.Application.Tracks.Handler
 {
     public class GetTracksByUserIdQueryHandler(IDatabase database)
-        : IRequestHandler<GetTracksByUserIdQuery, Task<Result<PaginatedResponse<TrackResponse>> >>
+        : IQueryHandler<GetTracksByUserIdQuery, Result<PaginatedResponse<TrackResponse>> >
     {
-        public async Task<Result<PaginatedResponse<TrackResponse> >> Handle(GetTracksByUserIdQuery request, CancellationToken cancellationToken)
+        public async ValueTask<Result<PaginatedResponse<TrackResponse> >> Handle(GetTracksByUserIdQuery request, CancellationToken cancellationToken)
         {
             var pageNumber = request.PageNumber < 1 ? 1 : request.PageNumber;
             var pageSize = request.PageSize < 1 ? 10 : request.PageSize;

Application/Tracks/Handler/GetTracksQueryHandler.cs

@@ -1,5 +1,5 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Microsoft.EntityFrameworkCore;
 using Musify.Application.Contracts.Application;
 using Musify.Application.Contracts.Infrastructure;
@@ -10,9 +10,9 @@ using X.PagedList.EF;
 namespace Musify.Application.Tracks.Handler
 {
     public class GetTracksQueryHandler(IDatabase database)
-        : IRequestHandler<GetTracksQuery, Task<Result<PaginatedResponse<TrackResponse>> > >
+        : IQueryHandler<GetTracksQuery, Result<PaginatedResponse<TrackResponse>> >
     {
-        public async Task<Result<PaginatedResponse<TrackResponse> >> Handle(GetTracksQuery request, CancellationToken cancellationToken)
+        public async ValueTask<Result<PaginatedResponse<TrackResponse> >> Handle(GetTracksQuery request, CancellationToken cancellationToken)
         {
             var pageNumber = request.PageNumber < 1 ? 1 : request.PageNumber;
             var pageSize = request.PageSize < 1 ? 10 : request.PageSize;

Application/Tracks/Queries/GetTrackByIdQuery.cs

@@ -1,9 +1,9 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Musify.Application.Tracks.Responses;
 
 namespace Musify.Application.Tracks.Queries
 {
     public record GetTrackByIdQuery(Guid TrackId)
-        : IRequest<GetTrackByIdQuery, Task<Result<TrackResponse> >>;
+        : IQuery<Result<TrackResponse>>;
 }

Application/Tracks/Queries/GetTracksByUserIdQuery.cs

@@ -1,5 +1,5 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Musify.Application.Contracts.Application;
 using Musify.Application.Tracks.Responses;
 
@@ -10,5 +10,5 @@ namespace Musify.Application.Tracks.Queries
         string Name = "",
         int PageNumber = 1,
         int PageSize = 10)
-        : IRequest<GetTracksByUserIdQuery, Task<Result<PaginatedResponse<TrackResponse> > >>;
+        : IQuery<Result<PaginatedResponse<TrackResponse> > >;
 }

Application/Tracks/Queries/GetTracksQuery.cs

@@ -1,10 +1,10 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Musify.Application.Contracts.Application;
 using Musify.Application.Tracks.Responses;
 
 namespace Musify.Application.Tracks.Queries
 {
     public record GetTracksQuery(int PageNumber = 1, int PageSize = 10)
-        : IRequest<GetTracksQuery, Task<Result<PaginatedResponse<TrackResponse> >> >;
+        : IQuery<Result<PaginatedResponse<TrackResponse> >>;
 }

Application/Users/Commands/CreateUserCommand.cs

@@ -1,12 +1,12 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Musify.Application.Users.Responses;
 using Musify.Domain.Entities;
 
 namespace Musify.Application.Users.Commands
 {
     public record CreateUserCommand(Guid Id)
-        : IRequest<CreateUserCommand, Task<Result<UserResponse>> >
+        : ICommand<Result<UserResponse>>
     {
         public static User ToEntity(CreateUserCommand command)
         {

Application/Users/Commands/DeleteUserCommand.cs

@@ -1,8 +1,8 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 
 namespace Musify.Application.Users.Commands
 {
     public record DeleteUserCommand(Guid Id)
-        : IRequest<DeleteUserCommand, Task<Result>>;
+        : ICommand<Result>;
 }

Application/Users/Handlers/CreateUserCommandHandler.cs

@@ -1,5 +1,5 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Logging;
 using Musify.Application.Contracts.Infrastructure;
@@ -9,9 +9,9 @@ using Musify.Application.Users.Responses;
 namespace Musify.Application.Users.Handlers
 {
     public class CreateUserCommandHandler(IDatabase database, IKeycloakUserService keycloakUserClient, ILogger<CreateUserCommandHandler> logger)
-        : IRequestHandler<CreateUserCommand, Task<Result<UserResponse> >>
+        : ICommandHandler<CreateUserCommand, Result<UserResponse> >
     {
-        public async Task<Result<UserResponse>> Handle(CreateUserCommand request, CancellationToken cancellationToken)
+        public async ValueTask<Result<UserResponse>> Handle(CreateUserCommand request, CancellationToken cancellationToken)
         {
             var userExists = await database.Users.AnyAsync(u => u.Id == request.Id, cancellationToken);
             if (userExists)

Application/Users/Handlers/DeleteUserCommandHandler.cs

@@ -1,13 +1,13 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Musify.Application.Contracts.Infrastructure;
 
 namespace Musify.Application.Users.Commands
 {
     public class DeleteUserCommandHandler(IDatabase database)
-        : IRequestHandler<DeleteUserCommand, Task<Result>>
+        : ICommandHandler<DeleteUserCommand, Result>
     {
-        public async Task<Result> Handle(DeleteUserCommand request, CancellationToken cancellationToken)
+        public async ValueTask<Result> Handle(DeleteUserCommand request, CancellationToken cancellationToken)
         {
             var existingUser = await database.Users.FindAsync(request.Id, cancellationToken);
             if (existingUser is null)

Application/Users/Handlers/GetUserByIdQueryHandler.cs

@@ -1,5 +1,5 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Microsoft.EntityFrameworkCore;
 using Musify.Application.Contracts.Infrastructure;
 using Musify.Application.Users.Queries;
@@ -8,9 +8,9 @@ using Musify.Application.Users.Responses;
 namespace Musify.Application.Users.Handlers
 {
     public class GetUserByIdQueryHandler(IDatabase database, IKeycloakUserService keycloakUserClient)
-        : IRequestHandler<GetUserByIdQuery, Task<Result<UserResponse> >>
+        : IQueryHandler<GetUserByIdQuery, Result<UserResponse> >
     {
-        public async Task<Result<UserResponse>> Handle(GetUserByIdQuery request, CancellationToken cancellationToken)
+        public async ValueTask<Result<UserResponse>> Handle(GetUserByIdQuery request, CancellationToken cancellationToken)
         {
             var user = await database.Users
                 .AsNoTracking()

Application/Users/Handlers/GetUserByKeycloakQueryHandler.cs

@@ -1,5 +1,5 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Microsoft.EntityFrameworkCore;
 using Musify.Application.Contracts.Infrastructure;
 using Musify.Application.Users.Queries;
@@ -8,9 +8,9 @@ using Musify.Application.Users.Responses;
 namespace Musify.Application.Users.Handlers
 {
     public class GetUserByKeycloakQueryHandler(IDatabase database, IKeycloakUserService keycloakUserClient)
-        : IRequestHandler<GetUserByKeycloakQuery, Task<Result<UserResponse> >>
+        : IQueryHandler<GetUserByKeycloakQuery, Result<UserResponse> >
     {
-        public async Task<Result<UserResponse>> Handle(GetUserByKeycloakQuery request, CancellationToken cancellationToken)
+        public async ValueTask<Result<UserResponse>> Handle(GetUserByKeycloakQuery request, CancellationToken cancellationToken)
         {
             var user = await database.Users
                 .AsNoTracking()

Application/Users/Handlers/GetUsersQueryHandler.cs

@@ -1,5 +1,5 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Microsoft.EntityFrameworkCore;
 using Musify.Application.Contracts.Application;
 using Musify.Application.Contracts.Infrastructure;
@@ -11,9 +11,9 @@ using X.PagedList.Extensions;
 namespace Musify.Application.Users.Handlers
 {
     public class GetUsersQueryHandler(IDatabase database, IKeycloakUserService keycloakUserClient)
-        : IRequestHandler<GetUsersQuery, Task<Result<PaginatedResponse<UserResponse> > >>
+        : IQueryHandler<GetUsersQuery, Result<PaginatedResponse<UserResponse> > >
     {
-        public async Task<Result<PaginatedResponse<UserResponse> >> Handle(GetUsersQuery request, CancellationToken cancellationToken)
+        public async ValueTask<Result<PaginatedResponse<UserResponse> >> Handle(GetUsersQuery request, CancellationToken cancellationToken)
         {
             var pageNumber = request.PageNumber < 1 ? 1 : request.PageNumber;
             var pageSize = request.PageSize < 1 ? 10 : request.PageSize;

Application/Users/Queries/GetUserByIdQuery.cs

@@ -1,9 +1,9 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Musify.Application.Users.Responses;
 
 namespace Musify.Application.Users.Queries
 {
     public record GetUserByIdQuery(Guid Id)
-        : IRequest<GetUserByIdQuery, Task<Result<UserResponse> >>;
+        : IQuery<Result<UserResponse> >;
 }

Application/Users/Queries/GetUserByKeycloakQuery.cs

@@ -1,9 +1,9 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Musify.Application.Users.Responses;
 
 namespace Musify.Application.Users.Queries
 {
     public record GetUserByKeycloakQuery(Guid Id)
-        : IRequest<GetUserByKeycloakQuery, Task<Result<UserResponse> >>;
+        : IQuery<Result<UserResponse> >;
 }

Application/Users/Queries/GetUsersQuery.cs

@@ -1,10 +1,10 @@
 using Ardalis.Result;
-using DispatchR.Abstractions.Send;
+using Mediator;
 using Musify.Application.Contracts.Application;
 using Musify.Application.Users.Responses;
 
 namespace Musify.Application.Users.Queries
 {
     public record GetUsersQuery(int PageNumber, int PageSize, string UsernameSearch)
-        : IRequest<GetUsersQuery, Task<Result<PaginatedResponse<UserResponse> >> >;
+        : IQuery<Result<PaginatedResponse<UserResponse> >>;
 }