using Dpz.Core.Service.ObjectStorage.Services;
using Dpz.Core.Service.RepositoryService;
using Hangfire;
using JetBrains.Annotations;
using MongoDB.Bson;

namespace Dpz.Core.Web.Jobs.Hangfire;

[UsedImplicitly]
public class SteamActivator(
    ISteamGameService steamGameService,
    IObjectStorageOperation objectStorageService
) : JobActivator
{
    [ProlongExpirationTime]
    public async Task UpdateLibraryAsync()
    {
        steamGameService.OnLogoDownloadComplete += SteamGameServiceOnOnLogoDownloadComplete;
        steamGameService.OnAchievementIconDownloadComplete +=
            SteamGameServiceOnOnAchievementIconDownloadComplete;
        steamGameService.OnAchievementIconGrayDownloadComplete +=
            SteamGameServiceOnOnAchievementIconGrayDownloadComplete;

        await steamGameService.UpdateGamesAsync();
    }

    private async Task<string?> SteamGameServiceOnOnAchievementIconGrayDownloadComplete(
        Stream? stream,
        int id,
        string name
    )
    {
        if (stream == null)
            return "";
#if DEBUG
        var path = new[] { "Test", "images", "steam", "gray_icon", id.ToString() };
#else
        var path = new[] { "images", "steam", "gray_icon", id.ToString() };
#endif

        var result = await objectStorageService.UploadAsync(
            stream,
            path,
            $"{ObjectId.GenerateNewId()}.jpg"
        );
        return result.AccessUrl;
    }

    private async Task<string?> SteamGameServiceOnOnAchievementIconDownloadComplete(
        Stream? stream,
        int id,
        string name
    )
    {
        if (stream == null)
            return "";
#if DEBUG
        var path = new[] { "Test", "images", "steam", "icon", id.ToString() };
#else
        var path = new[] { "images", "steam", "icon", id.ToString() };
#endif
        var result = await objectStorageService.UploadAsync(
            stream,
            path,
            $"{ObjectId.GenerateNewId()}.jpg"
        );
        return result.AccessUrl;
    }

    private async Task<string?> SteamGameServiceOnOnLogoDownloadComplete(Stream? stream, int id)
    {
        if (stream == null)
            return "";
        //var bytes = new MemoryStream(stream).ToArray();
#if DEBUG
        var path = new[] { "Test", "images", "steam", "logo", id.ToString() };
#else
        var path = new[] { "images", "steam", "logo", id.ToString() };
#endif
        var result = await objectStorageService.UploadAsync(stream, path, $"{id}.jpg");
        return result.AccessUrl;
    }
}