Musify/Application/Pictures/PictureService.cs

using Ardalis.Result;
using MassTransit;
using Microsoft.Extensions.Logging;
using Musify.Application.Configuration;
using Musify.Application.Contracts.Application;
using Musify.Application.Contracts.Infrastructure;
using Musify.Application.Pictures.Commands.ResizePicture;
using Musify.Application.Pictures.Contracts;
using Musify.Application.Pictures.Events;
using Musify.Domain.Entities;

namespace Musify.Application.Pictures
{
    public class PictureService(IStorageHandler storageHandler, IDatabase database, IPublishEndpoint publishEndpoint,
        ILogger<ResizeCommandHandler> logger, StorageConfiguration storageConfiguration)
        : IPictureService
    {
        public async Task<Result<Guid>> ResizePictureAsync(string keyName, string contentType, Stream pictureStream, PictureResize[] pictureResizes,
            CancellationToken cancellationToken)
        {
            var pictureId = Guid.NewGuid();

            var upload = new Upload
            {
                Id = pictureId,
                KeyName = $"{storageConfiguration.Routes.Uploads}/{pictureId}",
                ContentType = contentType,
                BucketName = storageConfiguration.BucketName,
            };

            await database.Uploads.AddAsync(upload, cancellationToken);

            await database.SaveChangesAsync(cancellationToken);

            var uploadResult = await storageHandler.UploadFileAsync(
                pictureStream,
                contentType,
                storageConfiguration.BucketName,
                $"{storageConfiguration.Routes.Uploads}/{pictureId}",
                cancellationToken);

            if (!uploadResult.IsSuccess)
            {
                logger.LogError("Failed to upload the picture with ID {PictureId} to bucket {BucketName}.", pictureId, storageConfiguration.BucketName);
                return Result.Error("Failed to upload the picture.");
            }

            await publishEndpoint.Publish(new PictureResizeEvent(pictureId, pictureResizes));

            return Result.Success();
        }
    }
}