Merge branch 'main' of https://github.com/soferreira/copy-alternatives

soferreira · Dec 15, 2022 · 5f12937 · 5f12937
2 parents b76b90d + 37aac01
commit 5f12937
Showing 1 changed file with 13 additions and 8 deletions.
diff --git a/aca/Controllers/BlobController.cs b/aca/Controllers/BlobController.cs
@@ -55,14 +55,18 @@ public async Task<ActionResult<string>> CopyBlob(BlobRequest item)
             await CopyContainer(sourceBlobClient,targetBlobClient,5000,sas);
             return $"Copied container {item.SourceContainer} to {item.TargetContainer}";
         }else if(SAMPLE.Equals(item.RequestType)){
+            _logger.LogInformation($"BlobController::CopyBlob::Creating samples.");
             BlobContainerClient localBlobClient = new BlobContainerClient(sourceCS,TEMP_LOC);
-            BlobClient localBlob = localBlobClient.GetBlobClient("datafile.json");
-            Uri uri = new Uri(sampleFileUri);
-            await localBlob.StartCopyFromUriAsync(uri);            
-            await CreateSample(localBlob,targetBlobClient,item.SampleSize);
+            _logger.LogInformation($"BlobController::CopyBlob::Creating samples. local blob client created");
+            BlobClient localBlob = localBlobClient.GetBlobClient("temp.data");
+            // Uri uri = new Uri(sampleFileUri);
+            // _logger.LogInformation($"BlobController::CopyBlob::Creating samples. uri created: {uri.AbsoluteUri}");
+            // localBlob.StartCopyFromUri(uri);          
+            _logger.LogInformation($"BlobController::CopyBlob::Creating samples. copy started");  
+            await CreateSample(localBlob,targetBlobClient,item.SampleSize,sas);
 
             // creating data samples
-            return "Invalid input provided. ";
+            return $"Created {item.SampleSize} samples in {item.TargetContainer} ";
         }else{
 
             // wrong type passed
@@ -79,12 +83,13 @@ public async Task<ActionResult<string>> CopyBlob(BlobRequest item)
 
 
 
-    private async Task CreateSample(BlobClient localBlob, BlobContainerClient destBlobContainer, int sampleSize)
+    private async Task CreateSample(BlobClient localBlob, BlobContainerClient destBlobContainer, int sampleSize, string sas)
     {
         for (int i = 0; i < sampleSize; i++)
         {
-            BlobClient destBlob = destBlobContainer.GetBlobClient($"datafile{i}.json");
-            await destBlob.StartCopyFromUriAsync(localBlob.Uri);
+            await CopySingle(localBlob,destBlobContainer.GetBlobClient($"datafile{i}.json"),sas);
+            // BlobClient destBlob = destBlobContainer.GetBlobClient($"datafile{i}.json");
+            // await destBlob.StartCopyFromUriAsync(localBlob.Uri);
         }
     }