Backend-Api/ProgramManager/src/Application/GozareshgirProgramManager.Application/Modules/TaskChat/Commands/DeleteMessage/DeleteMessageCommand.cs

using GozareshgirProgramManager.Application._Common.Models;
using GozareshgirProgramManager.Application._Common.Interfaces;
using GozareshgirProgramManager.Domain._Common.Exceptions;
using GozareshgirProgramManager.Domain.TaskChatAgg.Repositories;

namespace GozareshgirProgramManager.Application.Modules.TaskChat.Commands.DeleteMessage;

public record DeleteMessageCommand(Guid MessageId) : IBaseCommand;

public class DeleteMessageCommandHandler : IBaseCommandHandler<DeleteMessageCommand>
{
    private readonly ITaskChatMessageRepository _repository;
    private readonly IAuthHelper _authHelper;

    public DeleteMessageCommandHandler(ITaskChatMessageRepository repository, IAuthHelper authHelper)
    {
        _repository = repository;
        _authHelper = authHelper;
    }

    public async Task<OperationResult> Handle(DeleteMessageCommand request, CancellationToken cancellationToken)
    {
        var currentUserId = _authHelper.GetCurrentUserId()??
                            throw new UnAuthorizedException("کاربر احراز هویت نشده است");

        var message = await _repository.GetByIdAsync(request.MessageId);
        if (message == null)
        {
            return OperationResult.NotFound("پیام یافت نشد");
        }

        try
        {
            message.DeleteMessage(currentUserId);
            await _repository.UpdateAsync(message);
            await _repository.SaveChangesAsync();

            // TODO: SignalR notification

            return OperationResult.Success();
        }
        catch (Exception ex)
        {
            return OperationResult.ValidationError(ex.Message);
        }
    }
}