feat(bl): copy one bucket to another and create shareable url of the …

…object (#183) Co-authored-by: jaybeeelsdon <justin@chi.swan.ac.uk>
SwanseaUniversityMedical · Oct 6, 2023 · c315136 · c315136
1 parent 41f8cf0
commit c315136
Show file tree

Hide file tree

Showing 2 changed files with 36 additions and 0 deletions.
diff --git a/src/BL/Services/IMinioHelper.cs b/src/BL/Services/IMinioHelper.cs
@@ -12,6 +12,8 @@ public interface IMinioHelper
         Task<bool> FetchAndStoreObject(string url, MinioSettings minioSettings, string bucketName, string key);
         Task<bool> RabbitExternalObject(FetchFileMQ msgBytes);
         Task<bool> CreateBucketPolicy(string bucketName);
+        Task<bool> CopyObject(MinioSettings minioSettings, string sourceBucketName, string destinationBucketName, string sourceObjectKey, string destinationObjectKey);
+        Task<string> ShareMinioObject(MinioSettings minioSettings, string bucketName, string objectKey);
 
     }
 }
diff --git a/src/BL/Services/MinioHelper.cs b/src/BL/Services/MinioHelper.cs
@@ -225,6 +225,40 @@ public async Task<bool> CreateBucketPolicy(string bucketName)
             return true;
         }
 
+        public async Task<bool> CopyObject(MinioSettings minioSettings, string sourceBucketName, string destinationBucketName, string sourceObjectKey, string destinationObjectKey)
+        {
+            var amazonS3Client = GenerateAmazonS3Client(minioSettings);
+
+            var request = new CopyObjectRequest
+            {
+                SourceBucket = sourceBucketName,
+                DestinationBucket = destinationBucketName,
+                SourceKey = sourceObjectKey,
+                DestinationKey = destinationObjectKey
+            };
+
+            var result = await amazonS3Client.CopyObjectAsync(request);
+
+            return true;
+        }
+
+        public async Task<string> ShareMinioObject(MinioSettings minioSettings, string bucketName, string objectKey)
+        {
+            var amazonS3Client = GenerateAmazonS3Client(minioSettings);
+
+            var expiration = DateTime.Now.AddHours(1);
+
+
+            var url = amazonS3Client.GetPreSignedURL(new GetPreSignedUrlRequest
+            {
+                BucketName = bucketName,
+                Key = objectKey,
+                Expires = expiration,
+            });
+
+            return url;
+        }
+
         #region PrivateHelpers
         private AmazonS3Config GenerateAmazonS3Config(MinioSettings minioSettings)
         {