using System.Threading;
using Dpz.Core.Public.ViewModel.RequestEvent;

namespace Dpz.Core.Service.Event;

public class AddDanmakuCountEvent(
    IRepository<Video> repository,
    IBarrageService barrageService,
    IFusionCache fusionCache
) : IRequestHandler<AddDanmakuCountRequest>
{
    public async Task Handle(AddDanmakuCountRequest request, CancellationToken cancellationToken)
    {
        var count = await barrageService.GetGroupBarrageCountAsync(request.DanmakuGroup);
        var update = Builders<Video>.Update.Set(x => x.DanmakuCount, count);
        await repository.UpdateAsync(x => x.Id == request.DanmakuGroup, update, cancellationToken);

        var key = $"{CacheKey.VideoListKey}:{request.DanmakuGroup}";
        var cacheValue = await fusionCache.TryGetAsync<VmVideo>(key, token: cancellationToken);
        if (cacheValue.HasValue)
        {
            cacheValue.Value.DanmakuCount = count;
            await fusionCache.SetAsync(
                key,
                cacheValue.Value,
                TimeSpan.FromDays(1),
                [CacheKey.VideoListKey],
                token: cancellationToken
            );
        }

        var listCache = await fusionCache.TryGetAsync<List<VmVideo>>(
            CacheKey.VideoListKey,
            token: cancellationToken
        );
        if (listCache.HasValue)
        {
            var video = listCache.Value.FirstOrDefault(x => x.Id == request.DanmakuGroup);
            if (video != null)
            {
                video.DanmakuCount = count;
                await fusionCache.SetAsync(
                    CacheKey.VideoListKey,
                    listCache.Value,
                    TimeSpan.FromDays(1),
                    [CacheKey.VideoListKey],
                    token: cancellationToken
                );
            }
        }
    }
}