ErsatzTV/ErsatzTV.Core/Scheduling/YamlScheduling/Handlers/YamlPlayoutPadUntilHandler.cs

using ErsatzTV.Core.Interfaces.Scheduling;
using ErsatzTV.Core.Scheduling.YamlScheduling.Models;
using Microsoft.Extensions.Logging;
using NCalc;

namespace ErsatzTV.Core.Scheduling.YamlScheduling.Handlers;

public class YamlPlayoutPadUntilHandler(EnumeratorCache enumeratorCache) : YamlPlayoutDurationHandler(enumeratorCache)
{
    public override async Task<bool> Handle(
        YamlPlayoutContext context,
        YamlPlayoutInstruction instruction,
        PlayoutBuildMode mode,
        Func<string, Task> executeSequence,
        ILogger<YamlPlayoutBuilder> logger,
        CancellationToken cancellationToken)
    {
        if (instruction is not YamlPlayoutPadUntilInstruction padUntil)
        {
            return false;
        }

        DateTimeOffset targetTime = context.CurrentTime;

        if (TimeOnly.TryParse(padUntil.PadUntil, out TimeOnly result))
        {
            //logger.LogDebug("Will pad until time {Time}", result);

            var dayOnly = DateOnly.FromDateTime(targetTime.LocalDateTime);
            var timeOnly = TimeOnly.FromDateTime(targetTime.LocalDateTime);

            if (timeOnly > result)
            {
                var expression = new Expression(padUntil.Tomorrow);
                expression.EvaluateParameter += (name, e) =>
                {
                    e.Result = name switch
                    {
                        "now" => timeOnly.Hour + timeOnly.Minute / 60.0 + timeOnly.Second / 3600.0,
                        _ => e.Result
                    };
                };

                if (expression.Evaluate() as bool? == true)
                {
                    // this is wrong when offset changes
                    dayOnly = dayOnly.AddDays(1);
                    targetTime = new DateTimeOffset(dayOnly, result, targetTime.Offset);
                }
            }
            else
            {
                // this is wrong when offset changes
                targetTime = new DateTimeOffset(dayOnly, result, targetTime.Offset);
            }
        }

        // logger.LogDebug(
        //     "Padding from {CurrentTime} until {TargetTime}",
        //     context.CurrentTime,
        //     targetTime);

        Option<IMediaCollectionEnumerator> maybeEnumerator = await GetContentEnumerator(
            context,
            instruction.Content,
            logger,
            cancellationToken);

        Option<IMediaCollectionEnumerator> fallbackEnumerator = await GetContentEnumerator(
            context,
            padUntil.Fallback,
            logger,
            cancellationToken);

        foreach (IMediaCollectionEnumerator enumerator in maybeEnumerator)
        {
            context.CurrentTime = await Schedule(
                context,
                padUntil.Content,
                padUntil.Fallback,
                targetTime,
                padUntil.StopBeforeEnd,
                padUntil.DiscardAttempts,
                padUntil.Trim,
                padUntil.OfflineTail,
                GetFillerKind(padUntil, context),
                padUntil.CustomTitle,
                padUntil.DisableWatermarks,
                enumerator,
                fallbackEnumerator,
                executeSequence,
                logger);

            return true;
        }

        return false;
    }
}