using Dpz.Core.Entity.Base.PublicStruct;
using Dpz.Core.Shard.Service;

namespace Dpz.Core.Service.ObjectStorage.Services.Impl;

public class CloudFileService(IObjectStorageOperation objectStorageService) : ICloudFileService
{
    public async Task<FileAddress?> UploadFileAsync(CloudFile file)
    {
        return await objectStorageService.UploadFileAsync(file);
    }

    public async Task<List<FileAddress>?> UploadFilesAsync(params CloudFile[] files)
    {
        return await UploadFilesAsync((ICollection<CloudFile>)files);
    }

    public async Task<List<FileAddress>?> UploadFilesAsync(ICollection<CloudFile> files)
    {
        var addresses = new List<FileAddress>();
        await Parallel.ForEachAsync(
            files,
            async (x, _) =>
            {
                var address = await objectStorageService.UploadFileAsync(x);
                if (address.HasValue)
                {
                    addresses.Add(address.Value);
                }
            }
        );
        return addresses;
    }

    public async Task DeleteAsync(params string[] pathToFile)
    {
        var url = string.Join("/", pathToFile.Select(Uri.EscapeDataString));
        await objectStorageService.DeleteAsync(url);
    }
}