Extensions

Author: KSemenenko

Integraions/ManagedCode.Storage.Server/Extensions/Controller/ControllerDownloadExtensions.cs

@@ -0,0 +1,74 @@
+using System.IO;
+using System.Threading;
+using System.Threading.Tasks;
+using ManagedCode.Communication;
+using ManagedCode.MimeTypes;
+using ManagedCode.Storage.Core;
+using ManagedCode.Storage.Core.Models;
+using Microsoft.AspNetCore.Mvc;
+
+namespace ManagedCode.Storage.Server.Extensions;
+
+public static class ControllerDownloadExtensions
+{
+    public static async Task<Result<FileResult>> DownloadFileAsync(
+        this ControllerBase controller,
+        IStorage storage,
+        string blobName,
+        CancellationToken cancellationToken = default)
+    {
+        var result = await storage.DownloadAsync(blobName, cancellationToken);
+        if (result.IsFailed)
+            return Result<FileResult>.Fail(result.Errors);
+
+        var fileStream = new FileStreamResult(result.Value!.FileStream, 
+            MimeHelper.GetMimeType(result.Value.FileInfo.Extension))
+        {
+            FileDownloadName = result.Value.Name
+        };
+
+        return Result<FileResult>.Succeed(fileStream);
+    }
+
+    public static async Task<Result<FileResult>> StreamVideoAsync(
+        this ControllerBase controller,
+        IStorage storage,
+        string blobName,
+        CancellationToken cancellationToken = default)
+    {
+        var result = await storage.DownloadAsync(blobName, cancellationToken);
+        if (result.IsFailed)
+            return Result<FileResult>.Fail(result.Errors);
+
+        var fileStream = new FileStreamResult(result.Value!.FileStream, 
+            MimeHelper.GetMimeType(result.Value.FileInfo.Extension))
+        {
+            EnableRangeProcessing = true,
+            FileDownloadName = result.Value.Name
+        };
+
+        return Result<FileResult>.Succeed(fileStream);
+    }
+
+    public static async Task<Result<FileContentResult>> DownloadAsByteArrayAsync(
+        this ControllerBase controller,
+        IStorage storage,
+        string blobName,
+        CancellationToken cancellationToken = default)
+    {
+        var result = await storage.DownloadAsync(blobName, cancellationToken);
+        if (result.IsFailed)
+            return Result<FileContentResult>.Fail(result.Errors);
+
+        using var memoryStream = new MemoryStream();
+        await result.Value!.FileStream.CopyToAsync(memoryStream, cancellationToken);
+        
+        var fileContent = new FileContentResult(memoryStream.ToArray(), 
+            MimeHelper.GetMimeType(result.Value.FileInfo.Extension))
+        {
+            FileDownloadName = result.Value.Name
+        };
+
+        return Result<FileContentResult>.Succeed(fileContent);
+    }
+}

…s/Controller/ControllerBaseExtensions.cs …Controller/ControllerUploadExtensions.csIntegraions/ManagedCode.Storage.Server/Extensions/Controller/ControllerBaseExtensions.cs renamed to Integraions/ManagedCode.Storage.Server/Extensions/Controller/ControllerUploadExtensions.cs Integraions/ManagedCode.Storage.Server/Extensions/Controller/ControllerBaseExtensions.cs renamed to Integraions/ManagedCode.Storage.Server/Extensions/Controller/ControllerUploadExtensions.cs

@@ -14,27 +14,28 @@
 
 namespace ManagedCode.Storage.Server.Extensions;
 
-public static class ControllerBaseExtensions
+public static class ControllerUploadExtensions
 {
     private const int DefaultMultipartBoundaryLengthLimit = 70;
+    private const int MinLengthForLargeFile = 256 * 1024;
 
-    public static async Task<Result<BlobMetadata>> UploadFromFormFileAsync(
+    public static async Task<Result<BlobMetadata>> UploadFormFileAsync(
         this ControllerBase controller,
         IStorage storage,
         IFormFile file,
         UploadOptions? options = null,
         CancellationToken cancellationToken = default)
     {
-        if (options == null)
+        options ??= new UploadOptions(file.FileName, mimeType: file.ContentType);
+
+        if (file.Length > MinLengthForLargeFile)
         {
-            options = new UploadOptions 
-            { 
-                FileName = file.FileName,
-                MimeType = file.ContentType
-            };
+            var localFile = await file.ToLocalFileAsync(cancellationToken);
+            return await storage.UploadAsync(localFile.FileInfo, options, cancellationToken);
         }
-        
-        return await storage.UploadToStorageAsync(file, options, cancellationToken);
+
+        await using var stream = file.OpenReadStream();
+        return await storage.UploadAsync(stream, options, cancellationToken);
     }
 
     public static async Task<Result<BlobMetadata>> UploadFromBrowserFileAsync(
@@ -44,16 +45,16 @@ public static async Task<Result<BlobMetadata>> UploadFromBrowserFileAsync(
         UploadOptions? options = null,
         CancellationToken cancellationToken = default)
     {
-        if (options == null)
+        options ??= new UploadOptions(file.Name, mimeType: file.ContentType);
+
+        if (file.Size > MinLengthForLargeFile)
         {
-            options = new UploadOptions 
-            { 
-                FileName = file.Name,
-                MimeType = file.ContentType
-            };
+            var localFile = await file.ToLocalFileAsync(cancellationToken);
+            return await storage.UploadAsync(localFile.FileInfo, options, cancellationToken);
         }
-        
-        return await storage.UploadToStorageAsync(file, options);
+
+        await using var stream = file.OpenReadStream();
+        return await storage.UploadAsync(stream, options, cancellationToken);
     }
 
     public static async Task<Result<BlobMetadata>> UploadFromStreamAsync(
@@ -83,14 +84,7 @@ public static async Task<Result<BlobMetadata>> UploadFromStreamAsync(
                 var fileName = contentDisposition.FileName.Value;
                 var contentType = section.ContentType;
 
-                if (options == null)
-                {
-                    options = new UploadOptions 
-                    { 
-                        FileName = fileName,
-                        MimeType = contentType
-                    };
-                }
+                options ??= new UploadOptions(fileName, mimeType: contentType);
 
                 using var memoryStream = new MemoryStream();
                 await section.Body.CopyToAsync(memoryStream, cancellationToken);
@@ -104,13 +98,4 @@ public static async Task<Result<BlobMetadata>> UploadFromStreamAsync(
 
         return Result<BlobMetadata>.Fail(HttpStatusCode.BadRequest, "No file found in request");
     }
-
-    public static async Task<Result<FileResult>> DownloadAsFileResultAsync(
-        this ControllerBase controller,
-        IStorage storage,
-        string blobName,
-        CancellationToken cancellationToken = default)
-    {
-        return await storage.DownloadAsFileResult(blobName, cancellationToken);
-    }
 }