asp extensions

Author: KSemenenko

Directory.Build.props

@@ -14,8 +14,8 @@
         <PackageLicenseExpression>MIT</PackageLicenseExpression>
         <PackageReadmeFile>README.md</PackageReadmeFile>
         <Product>Managed Code - Storage</Product>
-        <Version>2.1.2</Version>
-        <PackageVersion>2.1.2</PackageVersion>
+        <Version>2.1.3</Version>
+        <PackageVersion>2.1.3</PackageVersion>
     </PropertyGroup>
     <PropertyGroup Condition="'$(GITHUB_ACTIONS)' == 'true'">
         <ContinuousIntegrationBuild>true</ContinuousIntegrationBuild>

ManagedCode.Storage.AspNetExtensions/FormFileExtensions.cs

@@ -12,11 +12,8 @@ public static class FormFileExtensions
 {
     public static async Task<LocalFile> ToLocalFileAsync(this IFormFile formFile, CancellationToken cancellationToken = default)
     {
-        var tempPath = Path.GetTempPath();
-        LocalFile localFile = new($"{tempPath}/{formFile.FileName}");
-
+        LocalFile localFile = LocalFile.FromFileName(formFile.FileName);
         await formFile.CopyToAsync(localFile.FileStream, cancellationToken);
-
         return localFile;
     }
 

ManagedCode.Storage.AspNetExtensions/StorageExtensions.cs

@@ -1,3 +1,4 @@
+using System;
 using System.Collections.Generic;
 using System.Runtime.CompilerServices;
 using System.Threading;
@@ -28,7 +29,27 @@ public static async Task<Result<BlobMetadata>> UploadToStorageAsync(this IStorag
             return await storage.UploadAsync(localFile.FileInfo, options, cancellationToken);
         }
 
-        using (var stream = formFile.OpenReadStream())
+        await using (var stream = formFile.OpenReadStream())
+        {
+            return await storage.UploadAsync(stream, options, cancellationToken);
+        }
+    }
+    
+    public static async Task<Result<BlobMetadata>> UploadToStorageAsync(this IStorage storage,
+        IFormFile formFile,
+        Action<UploadOptions> options,
+        CancellationToken cancellationToken = default)
+    {
+        var newOptions = new UploadOptions(formFile.FileName, mimeType: formFile.ContentType);
+        options.Invoke(newOptions);
+
+        if (formFile.Length > MinLengthForLargeFile)
+        {
+            var localFile = await formFile.ToLocalFileAsync(cancellationToken);
+            return await storage.UploadAsync(localFile.FileInfo, options, cancellationToken);
+        }
+
+        await using (var stream = formFile.OpenReadStream())
         {
             return await storage.UploadAsync(stream, options, cancellationToken);
         }
@@ -44,6 +65,17 @@ public static async IAsyncEnumerable<Result<BlobMetadata>> UploadToStorageAsync(
             yield return await storage.UploadToStorageAsync(formFile, options, cancellationToken);
         }
     }
+    
+    public static async IAsyncEnumerable<Result<BlobMetadata>> UploadToStorageAsync(this IStorage storage,
+        IFormFileCollection formFiles,
+        Action<UploadOptions> options,
+        [EnumeratorCancellation] CancellationToken cancellationToken = default)
+    {
+        foreach (var formFile in formFiles)
+        {
+            yield return await storage.UploadToStorageAsync(formFile, options, cancellationToken);
+        }
+    }
 
     public static async Task<Result<FileResult>> DownloadAsFileResult(this IStorage storage,
         string blobName,

ManagedCode.Storage.Core/BaseStorage.cs

@@ -277,7 +277,7 @@ protected UploadOptions SetUploadOptions(UploadOptions options)
     {
         if (string.IsNullOrWhiteSpace(options.FileName))
         {
-            options.FileName = $"{Guid.NewGuid():N}";
+            options.FileName = Guid.NewGuid().ToString("N");
         }
 
         if (!string.IsNullOrWhiteSpace(options.FileNamePrefix))

ManagedCode.Storage.Core/Models/LocalFile.cs

@@ -149,4 +149,13 @@ public static async Task<LocalFile> FromStreamAsync(Stream stream)
 
         return file;
     }
+    public static LocalFile FromFileName(string fileName)
+    {
+        return new LocalFile(Path.Combine(Path.GetTempPath(), fileName));
+    }
+    
+    public static LocalFile FromTempFile()
+    {
+        return new LocalFile();
+    }
 }