KfChatDotNet/KfChatDotNetBot/Services/AlmanacShill.cs

using KfChatDotNetBot.Settings;
using NLog;

namespace KfChatDotNetBot.Services;

public class AlmanacShill(ChatBot kfChatBot) : IDisposable
{
    private readonly Logger _logger = LogManager.GetCurrentClassLogger();
    private Task? _almanacShillTask;
    private CancellationTokenSource _almanacShillCts = new();
    
    private async Task AlmanacShillTask()
    {
        var interval = (await SettingsProvider.GetValueAsync(BuiltIn.Keys.BotAlmanacInterval)).ToType<int>();
        using var timer = new PeriodicTimer(TimeSpan.FromSeconds(interval));
        while (await timer.WaitForNextTickAsync(_almanacShillCts.Token))
        {
            _logger.Info("Time to shill the almanac in chat");
            var text = await SettingsProvider.GetValueAsync(BuiltIn.Keys.BotAlmanacText);
            await kfChatBot.SendChatMessageAsync($":!: {text.Value}", true);
        }
    }

    public bool IsShillTaskRunning()
    {
        _logger.Info($"_almanacShillTask is null? {_almanacShillTask == null}");
        if (_almanacShillTask == null) return false;
        _logger.Info($"_almanacShillTask.Status is {_almanacShillTask.Status}");
        if (_almanacShillTask.Status is not (TaskStatus.Running or TaskStatus.WaitingForActivation)) return false;
        _logger.Info($"_almanacShillCts.IsCancellationRequested is {_almanacShillCts.IsCancellationRequested}");
        if (_almanacShillCts.IsCancellationRequested) return false;
        return true;
    }

    public async Task StopShillTaskAsync()
    {
        await _almanacShillCts.CancelAsync();
        _almanacShillTask?.Dispose();
    }
    
    public void StartShillTask()
    {
        _almanacShillCts = new CancellationTokenSource();
        _almanacShillTask = Task.Run(AlmanacShillTask, _almanacShillCts.Token);
    }

    public void Dispose()
    {
        _almanacShillCts.Cancel();
        _almanacShillTask?.Dispose();
        GC.SuppressFinalize(this);
    }
}