NotS1mp/Musify
0
0
Fork 0
Code Issues 23 Pull Requests Actions Packages Projects Releases Wiki Activity

Remove DispatchR and use Mediator

Browse Source
This commit is contained in:
Admin
2026-03-29 20:17:32 +02:00
parent 9e4d5158e8
commit b9f03eb03c
33 changed files with 85 additions and 81 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Application/Tracks/Handler/CreateTrackCommandHandler.cs
+3 -3
View File
@@ -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
+3 -3
View File
@@ -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
+3 -3
View File
@@ -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
+3 -3
View File
@@ -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
+3 -3
View File
@@ -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;