using SIGCM2.Application.Abstractions; using SIGCM2.Application.Abstractions.Persistence; using SIGCM2.Application.Permisos.Dtos; using SIGCM2.Domain.Exceptions; namespace SIGCM2.Application.Permisos.Assign; public sealed class AssignPermisosToRolCommandHandler : ICommandHandler> { private readonly IRolRepository _rolRepository; private readonly IPermisoRepository _permisoRepository; private readonly IRolPermisoRepository _rolPermisoRepository; public AssignPermisosToRolCommandHandler( IRolRepository rolRepository, IPermisoRepository permisoRepository, IRolPermisoRepository rolPermisoRepository) { _rolRepository = rolRepository; _permisoRepository = permisoRepository; _rolPermisoRepository = rolPermisoRepository; } public async Task> 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); } // 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); // 4. Retornar el nuevo set asignado return permisos .Select(p => new PermisoDto(p.Id, p.Codigo, p.Nombre, p.Descripcion, p.Modulo)) .ToList(); } }