add delegate

Author: Sanyyazzz

ManagedCode.Storage.Client/IStorageClient.cs

@@ -1,4 +1,5 @@
-using System.IO;
+using System;
+using System.IO;
 using System.Threading;
 using System.Threading.Tasks;
 using ManagedCode.Communication;
@@ -12,6 +13,6 @@ public interface IStorageClient
     Task<Result<BlobMetadata>> UploadFile(FileInfo fileInfo, string apiUrl, string contentName, CancellationToken cancellationToken = default);
     Task<Result<BlobMetadata>> UploadFile(byte[] bytes, string apiUrl, string contentName, CancellationToken cancellationToken = default);
     Task<Result<BlobMetadata>> UploadFile(string base64, string apiUrl, string contentName, CancellationToken cancellationToken = default);
-    Task<Result> UploadLargeFile(Stream file, string сreateApiUrl, string uploadApiUrl, string completeApiUrl, CancellationToken cancellationToken = default);
+    Task<Result> UploadLargeFile(Stream file, string сreateApiUrl, string uploadApiUrl, string completeApiUrl, Action<double>? onProgressChanged, CancellationToken cancellationToken = default);
     Task<Result<LocalFile>> DownloadFile(string fileName, string apiUrl, string? path = null, CancellationToken cancellationToken = default);
 }

ManagedCode.Storage.Client/StorageClient.cs

@@ -128,13 +128,15 @@ public async Task<Result> UploadLargeFile(Stream file,
         string сreateApiUrl,  
         string uploadApiUrl, 
         string completeApiUrl, 
+        Action<double>? onProgressChanged,
         CancellationToken cancellationToken)
     {
         var bufferSize = 4096000; //TODO: chunk size get from config
         var buffer = new byte[bufferSize];
         int bytesRead;
         int chunkIndex = 1;
         var fileCRC = Crc32Helper.Calculate(file);
+        var partOfProgress = file.Length / bufferSize;
 
         var createdFileResponse = await _httpClient.PostAsync(сreateApiUrl, JsonContent.Create(file.Length), cancellationToken);
         var createdFile = await createdFileResponse.Content.ReadFromJsonAsync<Result<BlobMetadata>>(cancellationToken: cancellationToken);
@@ -162,6 +164,8 @@ public async Task<Result> UploadLargeFile(Stream file,
 
                             _httpClient.PostAsync(uploadApiUrl, chunk, cancellationToken);
                         }
+                        
+                        onProgressChanged?.Invoke(partOfProgress * chunkIndex);
                     }
                 }
                 finally

ManagedCode.Storage.IntegrationTests/Tests/BaseUploadControllerTests.cs

@@ -128,7 +128,7 @@ public async Task UploadFileInChunks_WhenFileValid_ReturnSuccess()
 
          // Act
          var result = await storageClient.UploadLargeFile(localFile.FileStream, _uploadChunksEndpoint + "/create", 
-             _uploadChunksEndpoint + "/upload", _uploadChunksEndpoint + "/complete", new CancellationToken());
+             _uploadChunksEndpoint + "/upload", _uploadChunksEndpoint + "/complete", null, new CancellationToken());
 
          // Assert
          result.IsSuccess.Should().BeTrue();