using HrynCo.NotificationService.DAL.Abstract;
using HrynCo.NotificationService.DAL.Abstract.Repositories;
using HrynCo.NotificationService.Services.Core;
using HrynCo.NotificationService.Services.Logging;
using static HrynCo.NotificationService.Services.Core.ServiceResultHelper;

namespace HrynCo.NotificationService.Services.EmailChannels.Update;

internal sealed class UpdateEmailChannelHandler
    : RequestHandler<UpdateEmailChannelCommand, ServiceResult<Unit>>
{
    private readonly IEmailChannelRepository _channels;

    public UpdateEmailChannelHandler(
        IContextualSerilogLogger<UpdateEmailChannelCommand> logger,
        IUnitOfWork unitOfWork,
        IEmailChannelRepository channels)
        : base(logger, unitOfWork)
    {
        _channels = channels;
    }

    protected override async Task<ServiceResult<Unit>> DoOnHandle(
        UpdateEmailChannelCommand request, CancellationToken cancellationToken)
    {
        var channel = await _channels.GetByIdAsync(request.Id, cancellationToken);

        if (channel is null)
            return Failure<Unit>("Email channel not found.", ServiceErrorCode.NotFound);

        channel.Priority = request.Priority;
        channel.Settings = request.Settings;
        channel.DailyLimit = request.DailyLimit;
        channel.MonthlyLimit = request.MonthlyLimit;
        channel.WarnThresholdPercent = request.WarnThresholdPercent;
        channel.IsActive = request.IsActive;
        channel.Updated = DateTimeOffset.UtcNow;

        await _channels.UpdateAsync(channel, cancellationToken);

        return Success(Unit.Value);
    }
}