using Dpz.Core.Infrastructure;
using Dpz.Core.Public.ViewModel;
using Dpz.Core.Service.ObjectStorage.Services;
using Dpz.Core.Service.RepositoryService;
using Dpz.Core.Shard.Service;
using Microsoft.Extensions.Configuration;
using ZiggyCreatures.Caching.Fusion;

namespace Dpz.Core.Shard.Implement.Service;

public class VideoShardService(
    IVideoService videoService,
    IObjectStorageOperation objectStorageService,
    IFusionCache fusionCache,
    IConfiguration configuration
) : IVideoShardService
{
    private readonly string _cdnSourceHost =
        configuration["CDNSourceHost"] ?? throw new ArgumentNullException(nameof(_cdnSourceHost));

    public async Task<List<VmVideo>> GetVideosAsync()
    {
        var cacheValue = await fusionCache.TryGetAsync<List<VmVideo>>(CacheKey.VideoListKey);
        if (cacheValue.HasValue)
        {
            return cacheValue.Value;
        }

        var list = await videoService.GetVideosAsync();
        var videoList = await objectStorageService.GetFolderListAsync("/Video");
        var videos = videoList
            .Select(x =>
            {
                var video = list.FirstOrDefault(y => y.Id == x.Name.GenerateHashMd5());
                if (video != null)
                {
                    video.Cover = $"{_cdnSourceHost}/Video/{video.Title}/video.webp";
                    video.M3u8 = $"{_cdnSourceHost}/Video/{x.Name}/1080p.m3u8";
                    return video;
                }
                return new VmVideo
                {
                    Id = x.Name.GenerateHashMd5(),
                    Title = x.Name,
                    Cover = $"{_cdnSourceHost}/Video/{x.Name}/video.webp",
                    M3u8 = $"{_cdnSourceHost}/Video/{x.Name}/1080p.m3u8",
                };
            })
            .ToList();
        await fusionCache.SetAsync(
            CacheKey.VideoListKey,
            videos,
            TimeSpan.FromDays(1),
            [CacheKey.VideoListKey]
        );

        return videos;
    }

    public async Task<VmVideo?> GetVideoAsync(string id)
    {
        var key = $"{CacheKey.VideoListKey}:{id}";
        var cacheValue = await fusionCache.TryGetAsync<VmVideo>(key);
        if (cacheValue.HasValue)
        {
            return cacheValue.Value;
        }

        var video = await videoService.GetVideoAsync(id);
        if (video == null)
        {
            var folder = (await objectStorageService.GetFolderListAsync("/Video")).FirstOrDefault(
                x => x.Name.GenerateHashMd5() == id
            );
            if (folder == null)
            {
                return null;
            }

            video = new VmVideo
            {
                Description = "",
                Id = folder.Name.GenerateHashMd5(),
                Name = "",
                SubTitle = "",
                Tags = [],
                Title = folder.Name,
                VideoTitle = "",
                Cover = $"{_cdnSourceHost}/Video/{folder.Name}/video.webp",
                M3u8 = $"{_cdnSourceHost}/Video/{folder.Name}/1080p.m3u8",
                PlayCount = 0,
                DanmakuCount = 0,
                CommentCount = 0,
            };
        }
        await fusionCache.SetAsync(key, video, TimeSpan.FromDays(1), [CacheKey.VideoListKey]);
        return video;
    }

    public async Task AddPlayAsync(string id)
    {
        await videoService.AddPlayAsync(id);
        var key = $"{CacheKey.VideoListKey}:{id}";
        var cacheValue = await fusionCache.TryGetAsync<VmVideo>(key);
        if (cacheValue.HasValue)
        {
            cacheValue.Value.PlayCount++;
            await fusionCache.SetAsync(
                key,
                cacheValue.Value,
                TimeSpan.FromDays(1),
                [CacheKey.VideoListKey]
            );
        }

        var listCache = await fusionCache.TryGetAsync<List<VmVideo>>(CacheKey.VideoListKey);
        if (listCache.HasValue)
        {
            var video = listCache.Value.FirstOrDefault(x => x.Id == id);
            if (video != null)
            {
                video.PlayCount++;
                await fusionCache.SetAsync(
                    CacheKey.VideoListKey,
                    listCache.Value,
                    TimeSpan.FromDays(1),
                    [CacheKey.VideoListKey]
                );
            }
        }
    }
}