CompleteTaskCommand.cs

Go to the documentation of this file.

using MediatR;
using TaskManagement.Application.Interfaces;
using TaskManagement.Domain.Common;
 
namespace TaskManagement.Application.Commands;
 
public sealed class CompleteTaskCommand : IRequest<Result>
{
    public Guid TaskId { get; }
 
    public CompleteTaskCommand(Guid taskId)
    {
        TaskId = taskId;
    }
}
 
public sealed class CompleteTaskCommandHandler : IRequestHandler<CompleteTaskCommand, Result>
{
    private readonly ITaskRepository _taskRepository;
    private readonly IUnitOfWork _unitOfWork;
    private readonly IDomainEventDispatcher _eventDispatcher;
 
    public CompleteTaskCommandHandler(
        ITaskRepository taskRepository,
        IUnitOfWork unitOfWork,
        IDomainEventDispatcher eventDispatcher)
    {
        _taskRepository = taskRepository;
        _unitOfWork = unitOfWork;
        _eventDispatcher = eventDispatcher;
    }
 
    public async Task<Result> Handle(CompleteTaskCommand request, CancellationToken cancellationToken)
    {
        ArgumentNullException.ThrowIfNull(request);
 
        var task = await _taskRepository.GetByIdAsync(request.TaskId, cancellationToken).ConfigureAwait(false);
        if (task is null)
            return Result.Failure(TaskErrors.NotFound(request.TaskId));
 
        var result = task.Complete();
        if (result.IsFailure)
            return result;
 
        // La tarea fue cargada con AsNoTracking; adjuntarla para que los cambios de estado se persistan.
        _taskRepository.Update(task);
        await _unitOfWork.SaveChangesAsync(cancellationToken).ConfigureAwait(false);
        await _eventDispatcher.DispatchAsync(task.DomainEvents, cancellationToken).ConfigureAwait(false);
        task.ClearDomainEvents();
 
        return Result.Success();
    }
}