Routes

Application/Events/UpdatePlayListPictureEvent.cs

@@ -2,5 +2,15 @@
 {
     public record UpdatePlayListPictureEvent(
         Guid PlayListId,
-        string OriginalPictureKeyName);
+        string BucketName,
+        string OriginalPictureKeyName,
+        string SmallPictureKeyName,
+        int SmallPictureWidth,
+        int SmallPictureHeight,
+        string MediumPictureKeyName,
+        int MediumPictureWidth,
+        int MediumPictureHeight,
+        string LargePictureKeyName,
+        int LargePictureWidth,
+        int LargePictureHeight);
 }

Application/PlayLists/Commands/CreatePlayList/CreatePlayListCommandHandler.cs

@@ -11,7 +11,8 @@ using Musify.Domain.Entities;
 namespace Musify.Application.PlayLists.Commands.CreatePlayList
 {
     public class CreatePlayListCommandHandler(IEventBus eventBus, IDatabase database, IStorageHandler storageHandler,
-        ILogger<CreatePlayListCommandHandler> logger, ApplicationStorageConfiguration storageConfiguration, PlayListConfiguration playListConfiguration)
+        ILogger<CreatePlayListCommandHandler> logger, ApplicationStorageConfiguration storageConfiguration,
+        PlayListConfiguration playListConfiguration, IPictureHandler pictureHandler)
         : IRequestHandler<CreatePlayListCommand, Task<Result<PlayListResponse>> >
     {
         public async Task<Result<PlayListResponse>> Handle(CreatePlayListCommand request, CancellationToken cancellationToken)
@@ -58,9 +59,31 @@ namespace Musify.Application.PlayLists.Commands.CreatePlayList
                 playList.OriginalPictureKeyName = pictureName;
                 logger.LogInformation("Playlist image uploaded successfully for PlayList with Id={PlayListId}.", playList.Id);
 
+                var smallPictureKeyName = Path.Combine(
+                    playListConfiguration.Routes.SmallPictures,
+                    $"{playList.Id}.{pictureHandler.FileExtension}");
+                var mediumPictureKeyName = Path.Combine(
+                    playListConfiguration.Routes.MediumPictures,
+                    $"{playList.Id}.{pictureHandler.FileExtension}");
+                var largePictureKeyName = Path.Combine(
+                    playListConfiguration.Routes.LargePictures,
+                    $"{playList.Id}.{pictureHandler.FileExtension}");
+
                 try
                 {
-                    await eventBus.PublishAsync(new UpdatePlayListPictureEvent(playList.Id, playList.OriginalPictureKeyName), cancellationToken);
+                    await eventBus.PublishAsync(new UpdatePlayListPictureEvent(
+                        playList.Id,
+                        storageConfiguration.BucketName,
+                        originalImageStorageKey,
+                        smallPictureKeyName,
+                        playListConfiguration.PicturesSizes.SmallPictureWidth,
+                        playListConfiguration.PicturesSizes.SmallPictureHeight,
+                        mediumPictureKeyName,
+                        playListConfiguration.PicturesSizes.MediumPictureWidth,
+                        playListConfiguration.PicturesSizes.MediumPictureHeight,
+                        largePictureKeyName,
+                        playListConfiguration.PicturesSizes.LargePictureWidth,
+                        playListConfiguration.PicturesSizes.LargePictureHeight), cancellationToken);
                 }
                 catch (Exception exception)
                 {

Application/PlayLists/Commands/UpdatePlayList/UpdatePlayListCommandHandler.cs

@@ -10,7 +10,8 @@ using Musify.Application.PlayLists.Contracts;
 namespace Musify.Application.PlayLists.Commands.UpdatePlayList
 {
     public class UpdatePlayListCommandHandler(IEventBus eventBus, IDatabase database, IStorageHandler storageHandler,
-        ILogger<UpdatePlayListCommandHandler> logger, ApplicationStorageConfiguration storageConfiguration, PlayListConfiguration playListConfiguration)
+        ILogger<UpdatePlayListCommandHandler> logger, ApplicationStorageConfiguration storageConfiguration,
+        PlayListConfiguration playListConfiguration, IPictureHandler pictureHandler)
         : IRequestHandler<UpdatePlayListCommand, Task<Result<PlayListResponse>> >
     {
         public async Task<Result<PlayListResponse>> Handle(UpdatePlayListCommand request, CancellationToken cancellationToken)
@@ -131,9 +132,31 @@ namespace Musify.Application.PlayLists.Commands.UpdatePlayList
 
             playList.OriginalPictureKeyName = pictureName;
 
+            var smallPictureKeyName = Path.Combine(
+                playListConfiguration.Routes.SmallPictures,
+                $"{playList.Id}.{pictureHandler.FileExtension}");
+            var mediumPictureKeyName = Path.Combine(
+                playListConfiguration.Routes.MediumPictures,
+                $"{playList.Id}.{pictureHandler.FileExtension}");
+            var largePictureKeyName = Path.Combine(
+                playListConfiguration.Routes.LargePictures,
+                $"{playList.Id}.{pictureHandler.FileExtension}");
+
             try
             {
-                await eventBus.PublishAsync(new UpdatePlayListPictureEvent(playList.Id, playList.OriginalPictureKeyName), cancellationToken);
+                await eventBus.PublishAsync(new UpdatePlayListPictureEvent(
+                    playList.Id,
+                    storageConfiguration.BucketName,
+                    newImageStorageKey,
+                    smallPictureKeyName,
+                    playListConfiguration.PicturesSizes.SmallPictureWidth,
+                    playListConfiguration.PicturesSizes.SmallPictureHeight,
+                    mediumPictureKeyName,
+                    playListConfiguration.PicturesSizes.MediumPictureWidth,
+                    playListConfiguration.PicturesSizes.MediumPictureHeight,
+                    largePictureKeyName,
+                    playListConfiguration.PicturesSizes.LargePictureWidth,
+                    playListConfiguration.PicturesSizes.LargePictureHeight), cancellationToken);
             }
             catch (Exception exception)
             {

Infrastructure/Messaging/Consumers/UpdatePlayListPictureConsumer.cs

@@ -1,14 +1,11 @@
 using MassTransit;
-using Musify.Application.Configuration;
-using Musify.Application.Contracts.Infrastructure;
 using Musify.Application.Events;
 using Musify.Infrastructure.Messaging.Activities;
 using Musify.Infrastructure.Messaging.Activities.Arguments;
 
 namespace Musify.Infrastructure.Messaging.Consumers
 {
-    public class UpdatePlayListPictureConsumer(IBus bus, IPictureHandler pictureHandler,
+    public class UpdatePlayListPictureConsumer(IBus bus)
-        ApplicationStorageConfiguration storageSettings, PlayListConfiguration playListConfiguration)
         : IConsumer<UpdatePlayListPictureEvent>
     {
         public const string QueueName = "Update-PlayList-Picture";
@@ -17,53 +14,46 @@ namespace Musify.Infrastructure.Messaging.Consumers
         {
             var routingSlipBuilder = new RoutingSlipBuilder(NewId.NextGuid());
 
-            var smallPictureKeyName = Path.Combine(
-                playListConfiguration.Routes.SmallPictures,
-                $"{consumeContext.Message.PlayListId}_small.{pictureHandler.FileExtension}");
-            var mediumPictureKeyName = Path.Combine(
-                playListConfiguration.Routes.MediumPictures,
-                $"{consumeContext.Message.PlayListId}_medium.{pictureHandler.FileExtension}");
-            var largePictureKeyName = Path.Combine(
-                playListConfiguration.Routes.LargePictures,
-                $"{consumeContext.Message.PlayListId}_large.{pictureHandler.FileExtension}");
-
             AddResizeActivity(
                 routingSlipBuilder,
                 "ResizeSmall",
-                smallPictureKeyName,
+                consumeContext.Message.SmallPictureKeyName,
-                playListConfiguration.PicturesSizes.SmallPictureWidth,
+                consumeContext.Message.SmallPictureWidth,
-                playListConfiguration.PicturesSizes.SmallPictureHeight,
+                consumeContext.Message.SmallPictureHeight,
-                consumeContext.Message.OriginalPictureKeyName);
+                consumeContext.Message.OriginalPictureKeyName,
+                consumeContext.Message.BucketName);
 
             AddResizeActivity(
                 routingSlipBuilder,
                 "ResizeMedium",
-                mediumPictureKeyName,
+                consumeContext.Message.MediumPictureKeyName,
-                playListConfiguration.PicturesSizes.MediumPictureWidth,
+                consumeContext.Message.MediumPictureWidth,
-                playListConfiguration.PicturesSizes.MediumPictureHeight,
+                consumeContext.Message.MediumPictureHeight,
-                consumeContext.Message.OriginalPictureKeyName);
+                consumeContext.Message.OriginalPictureKeyName,
+                consumeContext.Message.BucketName);
 
             AddResizeActivity(
                 routingSlipBuilder,
                 "ResizeLarge",
-                largePictureKeyName,
+                consumeContext.Message.LargePictureKeyName,
-                playListConfiguration.PicturesSizes.LargePictureWidth,
+                consumeContext.Message.LargePictureWidth,
-                playListConfiguration.PicturesSizes.LargePictureHeight,
+                consumeContext.Message.LargePictureHeight,
-                consumeContext.Message.OriginalPictureKeyName);
+                consumeContext.Message.OriginalPictureKeyName,
+                consumeContext.Message.BucketName);
 
             routingSlipBuilder.AddActivity(
                 "DeleteOriginal",
                 BuildExecuteUri(RemoveFilesActivity.ExecuteEndpointName),
-                new RemoveFileArguments(storageSettings.BucketName, consumeContext.Message.OriginalPictureKeyName));
+                new RemoveFileArguments(consumeContext.Message.BucketName, consumeContext.Message.OriginalPictureKeyName));
 
             routingSlipBuilder.AddActivity(
                 "UpdatePlayListPicture",
                 BuildExecuteUri(UpdatePlayListPictureActivity.ExecuteEndpointName),
                 new UpdatePlayListPictureArguments(
                     consumeContext.Message.PlayListId,
-                    smallPictureKeyName,
+                    consumeContext.Message.SmallPictureKeyName,
-                    mediumPictureKeyName,
+                    consumeContext.Message.MediumPictureKeyName,
-                    largePictureKeyName));
+                    consumeContext.Message.LargePictureKeyName));
 
             var routingSlip = routingSlipBuilder.Build();
             await bus.Execute(routingSlip);
@@ -75,15 +65,16 @@ namespace Musify.Infrastructure.Messaging.Consumers
             string destinationKeyName,
             int width,
             int height,
-            string originalPictureKeyName)
+            string originalPictureKeyName,
+            string bucketName)
         {
             routingSlipBuilder.AddActivity(
                 activityName,
                 BuildExecuteUri(ResizePictureActivity.ExecuteEndpointName),
                 new ResizePictureArgument(
-                    storageSettings.BucketName,
+                    bucketName,
                     originalPictureKeyName,
-                    storageSettings.BucketName,
+                    bucketName,
                     destinationKeyName,
                     width,
                     height));