SIG-CM2.0/src/api/SIGCM2.Application/Permisos/Assign/AssignPermisosToRolCommandHandler.cs

using System.Transactions;
using SIGCM2.Application.Abstractions;
using SIGCM2.Application.Abstractions.Persistence;
using SIGCM2.Application.Audit;
using SIGCM2.Application.Permisos.Dtos;
using SIGCM2.Domain.Exceptions;

namespace SIGCM2.Application.Permisos.Assign;

public sealed class AssignPermisosToRolCommandHandler : ICommandHandler<AssignPermisosToRolCommand, IReadOnlyList<PermisoDto>>
{
    private readonly IRolRepository _rolRepository;
    private readonly IPermisoRepository _permisoRepository;
    private readonly IRolPermisoRepository _rolPermisoRepository;
    private readonly IAuditLogger _audit;

    public AssignPermisosToRolCommandHandler(
        IRolRepository rolRepository,
        IPermisoRepository permisoRepository,
        IRolPermisoRepository rolPermisoRepository,
        IAuditLogger audit)
    {
        _rolRepository = rolRepository;
        _permisoRepository = permisoRepository;
        _rolPermisoRepository = rolPermisoRepository;
        _audit = audit;
    }

    public async Task<IReadOnlyList<PermisoDto>> Handle(AssignPermisosToRolCommand command)
    {
        // 1. Validar que el rol existe
        var rol = await _rolRepository.GetByCodigoAsync(command.RolCodigo);
        if (rol is null)
            throw new RolNotFoundException(command.RolCodigo);

        // 2. Validar que todos los códigos existen en BD
        var codigosList = command.Codigos.ToList();
        var permisos = await _permisoRepository.GetByCodigosAsync(codigosList);

        if (permisos.Count != codigosList.Count)
        {
            // Detectar el primer código que no fue encontrado
            var foundCodigos = permisos.Select(p => p.Codigo).ToHashSet();
            var missing = codigosList.First(c => !foundCodigos.Contains(c));
            throw new PermisoNotFoundException(missing);
        }

        // Capture "before" snapshot for audit diff
        var previousPermisos = await _rolPermisoRepository.GetByRolCodigoAsync(rol.Codigo);
        var beforeCodigos = previousPermisos.Select(p => p.Codigo).OrderBy(c => c, StringComparer.Ordinal).ToArray();
        var afterCodigos = permisos.Select(p => p.Codigo).OrderBy(c => c, StringComparer.Ordinal).ToArray();

        using (var tx = new TransactionScope(
            TransactionScopeOption.Required,
            new TransactionOptions { IsolationLevel = IsolationLevel.ReadCommitted },
            TransactionScopeAsyncFlowOption.Enabled))
        {
            // 3. Reemplazar el set (DELETE+INSERT en transacción dentro del repo)
            var permisoIds = permisos.Select(p => p.Id);
            await _rolPermisoRepository.ReplaceForRolAsync(rol.Id, permisoIds);

            await _audit.LogAsync(
                action: "rol.permisos_update",
                targetType: "Rol",
                targetId: rol.Id.ToString(),
                metadata: new { before = beforeCodigos, after = afterCodigos });

            tx.Complete();
        }

        // 4. Retornar el nuevo set asignado
        return permisos
            .Select(p => new PermisoDto(p.Id, p.Codigo, p.Nombre, p.Descripcion, p.Modulo))
            .ToList();
    }
}