From a3a09e45c349cdb8d63b83f7564aa67c51320c9d Mon Sep 17 00:00:00 2001
From: NotS1mp <xshine555@gmail.com>
Date: Thu, 26 Mar 2026 19:59:44 +0100
Subject: [PATCH] Use variable

---
 .../Activities/Files/UploadFileToBucketActivity.cs          | 6 +++++-
 .../MassTransit/Arguments/UploadFileToBucketArguments.cs    | 2 +-
 2 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/Infrastructure/MassTransit/Activities/Files/UploadFileToBucketActivity.cs b/Infrastructure/MassTransit/Activities/Files/UploadFileToBucketActivity.cs
index 62356ae..4f20d49 100644
--- a/Infrastructure/MassTransit/Activities/Files/UploadFileToBucketActivity.cs
+++ b/Infrastructure/MassTransit/Activities/Files/UploadFileToBucketActivity.cs
@@ -30,9 +30,13 @@ namespace Musify.Infrastructure.MassTransit.Activities.Files
                 0,
                 executeContext.CancellationToken);
 
+            var sourceFilePath = executeContext.GetVariable<string>(executeContext.Arguments.FilePathVariableName);
+            if (string.IsNullOrEmpty(sourceFilePath))
+                throw new InvalidOperationException($"Upload activity requires variable '{executeContext.Arguments.FilePathVariableName}' with source file path.");
+
             try
             {
-                using var fileStream = File.OpenRead(executeContext.Arguments.SourceFilePath);
+                using var fileStream = File.OpenRead(sourceFilePath);
 
                 var uploadResult = await storageHandler.UploadFileAsync(
                     fileStream,
diff --git a/Infrastructure/MassTransit/Arguments/UploadFileToBucketArguments.cs b/Infrastructure/MassTransit/Arguments/UploadFileToBucketArguments.cs
index 7f58fcd..ab6ccda 100644
--- a/Infrastructure/MassTransit/Arguments/UploadFileToBucketArguments.cs
+++ b/Infrastructure/MassTransit/Arguments/UploadFileToBucketArguments.cs
@@ -1,7 +1,7 @@
 namespace Musify.Infrastructure.MassTransit.Arguments
 {
     public record UploadFileToBucketArguments(
-        string SourceFilePath,
+        string FilePathVariableName,
         string ContentType,
         string DestinationBucketName,
         string DestinationKeyName);