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

namespace SIGCM2.Application.Medios.Create;

public sealed class CreateMedioCommandHandler : ICommandHandler<CreateMedioCommand, MedioCreatedDto>
{
    private readonly IMedioRepository _repo;
    private readonly IAuditLogger _audit;

    public CreateMedioCommandHandler(IMedioRepository repo, IAuditLogger audit)
    {
        _repo = repo;
        _audit = audit;
    }

    public async Task<MedioCreatedDto> Handle(CreateMedioCommand command)
    {
        var codigoNorm = command.Codigo.ToUpperInvariant();

        var exists = await _repo.ExistsByCodigoAsync(codigoNorm);
        if (exists)
            throw new MedioCodigoDuplicadoException(codigoNorm);

        var medio = Medio.ForCreation(codigoNorm, command.Nombre, command.Tipo, command.PlataformaEmpresaId);

        using var tx = new TransactionScope(
            TransactionScopeOption.Required,
            new TransactionOptions { IsolationLevel = System.Transactions.IsolationLevel.ReadCommitted },
            TransactionScopeAsyncFlowOption.Enabled);

        var newId = await _repo.AddAsync(medio);

        await _audit.LogAsync(
            action: "medio.create",
            targetType: "Medio",
            targetId: newId.ToString(),
            metadata: new
            {
                after = new
                {
                    medio.Codigo,
                    medio.Nombre,
                    medio.Tipo,
                    medio.PlataformaEmpresaId,
                },
            });

        tx.Complete();

        return new MedioCreatedDto(
            Id: newId,
            Codigo: medio.Codigo,
            Nombre: medio.Nombre,
            Tipo: medio.Tipo,
            PlataformaEmpresaId: medio.PlataformaEmpresaId,
            Activo: medio.Activo);
    }
}
