using Brizco.Repository.Abstracts;

namespace Brizco.Repository.Handlers.Position;

public class CreatePositionUserCommandHandler : IRequestHandler<CreatePositionUserCommand,bool>
{
    private readonly IRepositoryWrapper _repositoryWrapper;

    public CreatePositionUserCommandHandler(IRepositoryWrapper repositoryWrapper)
    {
        _repositoryWrapper = repositoryWrapper;
    }
    public async Task<bool> Handle(CreatePositionUserCommand request, CancellationToken cancellationToken)
    {
        try
        {
            await _repositoryWrapper.BeginTransaction(cancellationToken);



            var entity = await _repositoryWrapper.SetRepository<Domain.Entities.Complex.Position>().TableNoTracking
                .FirstOrDefaultAsync(p => p.Id == request.PositionId, cancellationToken);
            if (entity == null)
                throw new AppException("Position not found");
            entity.AddUser(request.UserId,request.ShiftPlanId);
            _repositoryWrapper.SetRepository<Domain.Entities.Complex.Position>().Update(entity);
            await _repositoryWrapper.SaveChangesAsync(cancellationToken);
            await _repositoryWrapper.CommitAsync(cancellationToken);
            return true;
        }
        catch (Exception)
        {
            await _repositoryWrapper.RollBackAsync(cancellationToken);
            throw;
        }
    }
}