This commit is contained in:
2026-03-23 16:53:23 +01:00
parent 788fb6fa5c
commit f1b7191ccc
11 changed files with 40 additions and 35 deletions
@@ -2,7 +2,6 @@
using Microsoft.Extensions.Logging;
using Musify.Application.Contracts.Infrastructure;
using Musify.Domain.Entities;
using Musify.Infrastructure.Configuration;
using Musify.Infrastructure.Messaging.Activities.Arguments;
namespace Musify.Infrastructure.Messaging.Activities
@@ -10,8 +9,7 @@ namespace Musify.Infrastructure.Messaging.Activities
public class DownloadFileFromBucketActivity(
IStorageHandler storageHandler,
ILogger<DownloadFileFromBucketActivity> logger,
IProcessTrackingStore processTrackingStore,
AudioTranscoderConfiguration audioTranscoderConfiguration)
IProcessTrackingStore processTrackingStore)
: IExecuteActivity<DownloadFileFromBucketArguments>
{
public const string ExecuteEndpointName = "Download-File-From-Bucket";
@@ -8,7 +8,7 @@ namespace Musify.Infrastructure.Messaging.Consumers
{
public class TranscodeAudioFromTrackConsumer(
IBus bus,
AudioTranscoderConfiguration audioTranscoderConfiguration)
WorkerConfiguration workerConfiguration)
: IConsumer<TranscodeAudioFromTrackEvent>
{
public const string QueueName = "Transcode-Audio-From-Track";
@@ -23,7 +23,7 @@ namespace Musify.Infrastructure.Messaging.Consumers
new DownloadFileFromBucketArguments(
consumeContext.Message.SourceBucketName,
consumeContext.Message.SourceKeyName,
audioTranscoderConfiguration.Routes.WorkingDirectory));
workerConfiguration.Routes.TemporaryFilesDirectory));
routingSlipBuilder.AddActivity(
"TranscodeAudio",
@@ -8,7 +8,7 @@ namespace Musify.Infrastructure.Messaging.Consumers
{
public class UpdatePlayListPictureConsumer(
IBus bus,
AudioTranscoderConfiguration audioTranscoderConfiguration)
WorkerConfiguration workerConfiguration)
: IConsumer<UpdatePlayListPictureEvent>
{
public const string QueueName = "Update-PlayList-Picture";
@@ -17,7 +17,7 @@ namespace Musify.Infrastructure.Messaging.Consumers
{
var routingSlipBuilder = new RoutingSlipBuilder(NewId.NextGuid());
var folderName = Guid.NewGuid().ToString();
var workingDirectory = Path.Combine(audioTranscoderConfiguration.Routes.WorkingDirectory, folderName);
var workingDirectory = Path.Combine(workerConfiguration.Routes.TemporaryFilesDirectory, folderName);
routingSlipBuilder.AddActivity(
"DownloadFile",
@@ -8,7 +8,7 @@ namespace Musify.Infrastructure.Messaging.Consumers
{
public class UpdateTrackPictureConsumer(
IBus bus,
AudioTranscoderConfiguration audioTranscoderConfiguration)
WorkerConfiguration workerConfiguration)
: IConsumer<UpdateTrackPictureEvent>
{
public const string QueueName = "Update-Track-Picture";
@@ -17,7 +17,7 @@ namespace Musify.Infrastructure.Messaging.Consumers
{
var routingSlipBuilder = new RoutingSlipBuilder(NewId.NextGuid());
var folderName = Guid.NewGuid().ToString();
var workingDirectory = Path.Combine(audioTranscoderConfiguration.Routes.WorkingDirectory, folderName);
var workingDirectory = Path.Combine(workerConfiguration.Routes.TemporaryFilesDirectory, folderName);
routingSlipBuilder.AddActivity(
"DownloadFile",