cs-codex-dist-tests/Tools/TestNetRewarder/TimeSegmenter.cs

using Logging;
using Utils;

namespace TestNetRewarder
{
    public interface ITimeSegmentHandler
    {
        Task OnNewSegment(TimeRange timeRange);
    }

    public class TimeSegmenter
    {
        private readonly ILog log;
        private readonly ITimeSegmentHandler handler;
        private readonly TimeSpan segmentSize;
        private DateTime latest;

        public TimeSegmenter(ILog log, TimeSpan segmentSize, DateTime historyStartUtc, ITimeSegmentHandler handler)
        {
            this.log = log;
            this.handler = handler;
            this.segmentSize = segmentSize;
            latest = historyStartUtc;

            log.Log("Starting time segments at " + latest);
            log.Log("Segment size: " + Time.FormatDuration(segmentSize));
        }

        public bool IsRealtime { get; private set; } = false;

        public async Task ProcessNextSegment()
        {
            var end = latest + segmentSize;
            IsRealtime = await WaitUntilTimeSegmentInPast(end);

            if (Program.CancellationToken.IsCancellationRequested) return;

            var postfix = "(Catching up...)";
            if (IsRealtime) postfix = "(Real-time)";
            log.Log($"Time segment [{latest} to {end}] {postfix}");
            
            var range = new TimeRange(latest, end);
            latest = end;

            await handler.OnNewSegment(range);
        }

        private async Task<bool> WaitUntilTimeSegmentInPast(DateTime end)
        {
            await Task.Delay(TimeSpan.FromSeconds(3), Program.CancellationToken);

            var now = DateTime.UtcNow;
            while (end > now)
            {
                var delay = (end - now) + TimeSpan.FromSeconds(3);
                await Task.Delay(delay, Program.CancellationToken);
                return true;
            }
            return false;
        }
    }
}