ColaFlow/colaflow-api/src/Modules/IssueManagement/ColaFlow.Modules.IssueManagement.Application/Commands/ChangeIssueStatus/ChangeIssueStatusCommandHandler.cs

using MediatR;
using ColaFlow.Modules.IssueManagement.Domain.Entities;
using ColaFlow.Modules.IssueManagement.Domain.Repositories;
using ColaFlow.Modules.IssueManagement.Domain.Exceptions;

namespace ColaFlow.Modules.IssueManagement.Application.Commands.ChangeIssueStatus;

public sealed class ChangeIssueStatusCommandHandler : IRequestHandler<ChangeIssueStatusCommand, Unit>
{
    private readonly IIssueRepository _issueRepository;
    private readonly IUnitOfWork _unitOfWork;
    private readonly IPublisher _publisher;

    public ChangeIssueStatusCommandHandler(
        IIssueRepository issueRepository,
        IUnitOfWork unitOfWork,
        IPublisher publisher)
    {
        _issueRepository = issueRepository;
        _unitOfWork = unitOfWork;
        _publisher = publisher;
    }

    public async Task<Unit> Handle(ChangeIssueStatusCommand request, CancellationToken cancellationToken)
    {
        var issue = await _issueRepository.GetByIdAsync(request.IssueId, cancellationToken);
        if (issue == null)
            throw new NotFoundException(nameof(Issue), request.IssueId);

        issue.ChangeStatus(request.NewStatus);

        await _issueRepository.UpdateAsync(issue, cancellationToken);
        await _unitOfWork.SaveChangesAsync(cancellationToken);

        foreach (var domainEvent in issue.DomainEvents)
        {
            await _publisher.Publish(domainEvent, cancellationToken);
        }
        issue.ClearDomainEvents();

        return Unit.Value;
    }
}