using CH.CQRS.Service.Energy;
using CH.CQRS.Service.Energy.Options;
using CH.Dal;
using CH.Dal.DbEntity;
using CH.Dal.Validators;
using CH.Enum;
using FluentValidation;
using Microsoft.EntityFrameworkCore;
using OpenHarbor.CQRS.Abstractions;

namespace CH.CQRS.Command.Energy;

public class CreateEnergyRateExceptionCommand
{
  public long RateId { get; set; }
  public required string Name { get; set; }
  public decimal EnergyThreshold { get; set; }
  public EnergyRateExceptionThresholdResetType ResetType { get; set; }
  public DateTime? StartedAt { get; set; }
  public DateTime? EndedAt { get; set; }
}

public class CreateEnergyRateExceptionCommandHandler(EnergyService energyService) : ICommandHandler<CreateEnergyRateExceptionCommand>
{
  public Task HandleAsync(CreateEnergyRateExceptionCommand command,
    CancellationToken cancellationToken = new CancellationToken())
  {
    return energyService.CreateEnergyRateExceptionAsync(new CreateEnergyRateExceptionCommandOptions
    {
      RateId = command.RateId,
      Name = command.Name,
      EnergyThreshold = command.EnergyThreshold,
      ResetType = command.ResetType,
      StartedAt = command.StartedAt,
      EndedAt = command.EndedAt
    }, cancellationToken);
  }
}
public class CreateEnergyRateExceptionCommandValidator : AbstractValidator<CreateEnergyRateExceptionCommand>
{
  public CreateEnergyRateExceptionCommandValidator(CHDbContext dbContext)
  {
    RuleFor(command => command.Name)
      .NotEmpty()
      .MinimumLength(3)
      .MustAsync(async (name, cancellationToken) =>
      {
        var nameInUse = await dbContext.EnergyRateExceptions.AnyAsync(energyRateException => energyRateException.Name == name, cancellationToken);
        return false == nameInUse;
      })
      .WithMessage("This Name is already in use by another energy rate exception.");
    
    RuleFor(command => command.EnergyThreshold)
      .GreaterThan(0);
    
    RuleFor(command => command.RateId)
      .NotEmpty()
      .SetValidator(new DbEntityExistValidator<EnergyRate,long>(dbContext))
      .WithMessage("The provided Rate Id is invalid.");
  }
}