using PostFundManagement.Application.Abstractions;
using PostFundManagement.Application.Abstractions.Services;
using PostFundManagement.Application.Services.Shared;
using PostFundManagement.Domain;
using PostFundManagement.Domain.Models;

namespace PostFundManagement.Application.Services.Users;

public sealed class UserCacheService(UserService service, IDistributedCache cache) : ServiceCacheBase, IUserService
{
    public async ValueTask<Result<User>> GetUserAsync(Guid userId, CancellationToken cancellationToken) =>
        await Result.Try((Func<ValueTask<Result<User>>>)(async () =>
        {
            var cacheKey = HashService.ToMd5Hash($"getuser-{userId}").Value;

            var cached = await cache.GetStringAsync(cacheKey, cancellationToken);

            if(string.IsNullOrWhiteSpace(cached))
            {
                var userResult = await service.GetUserAsync(userId, cancellationToken);

                if (userResult.IsFailed) return userResult;

                await cache.SetStringAsync(cacheKey, JsonSerializer.Serialize(userResult.Value), cacheOptions, cancellationToken);

                return userResult;
            }

            var restored = JsonSerializer.Deserialize<User>(cached)!;

            return Result.Ok(restored);
        }));

    public async ValueTask<Result<User[]>> GetUsersAsync(Pagination pagination, UserFilterRequest request, CancellationToken cancellationToken = default) =>
        await Result.Try((Func<ValueTask<Result<User[]>>>)(async () =>
        {
            var cacheKey = HashService.ToMd5Hash($"getusers-{pagination.Page}-{pagination.PageSize}-{request.Email}-{request.Status}").Value;

            var cached = await cache.GetStringAsync(cacheKey, cancellationToken);

            if (string.IsNullOrWhiteSpace(cached))
            {
                var usersResult = await service.GetUsersAsync(pagination, request, cancellationToken);

                if (usersResult.IsFailed) return usersResult;

                await cache.SetStringAsync(cacheKey, JsonSerializer.Serialize(usersResult.Value), cacheOptions, cancellationToken);

                return usersResult;
            }

            var restored = JsonSerializer.Deserialize<User[]>(cached)!;

            return Result.Ok(restored);
        }));

    public async ValueTask<Result> SyncUserAsync(Guid userId, string email, CancellationToken cancellationToken = default) =>
        await service.SyncUserAsync(userId, email, cancellationToken);

    public async ValueTask<Result> UpdateUserStatusAsync(Guid userId, ActivityStatus status, CancellationToken cancellationToken = default) =>
        await service.UpdateUserStatusAsync(userId, status, cancellationToken);
}