wip

Author: KSemenenko

Integraions/ManagedCode.Storage.Server/BaseController.cs

@@ -0,0 +1,116 @@
+using System.IO;
+using System.Net;
+using System.Threading;
+using System.Threading.Tasks;
+using ManagedCode.Communication;
+using ManagedCode.Storage.Core;
+using ManagedCode.Storage.Core.Models;
+using ManagedCode.Storage.Server.Helpers;
+using Microsoft.AspNetCore.Components.Forms;
+using Microsoft.AspNetCore.Http;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.AspNetCore.WebUtilities;
+using Microsoft.Net.Http.Headers;
+
+namespace ManagedCode.Storage.Server.Extensions;
+
+public static class ControllerBaseExtensions
+{
+    private const int DefaultMultipartBoundaryLengthLimit = 70;
+
+    public static async Task<Result<BlobMetadata>> UploadFromFormFileAsync(
+        this ControllerBase controller,
+        IStorage storage,
+        IFormFile file,
+        UploadOptions? options = null,
+        CancellationToken cancellationToken = default)
+    {
+        if (options == null)
+        {
+            options = new UploadOptions 
+            { 
+                FileName = file.FileName,
+                MimeType = file.ContentType
+            };
+        }
+        
+        return await storage.UploadToStorageAsync(file, options, cancellationToken);
+    }
+
+    public static async Task<Result<BlobMetadata>> UploadFromBrowserFileAsync(
+        this ControllerBase controller,
+        IStorage storage,
+        IBrowserFile file,
+        UploadOptions? options = null,
+        CancellationToken cancellationToken = default)
+    {
+        if (options == null)
+        {
+            options = new UploadOptions 
+            { 
+                FileName = file.Name,
+                MimeType = file.ContentType
+            };
+        }
+        
+        return await storage.UploadToStorageAsync(file, options);
+    }
+
+    public static async Task<Result<BlobMetadata>> UploadFromStreamAsync(
+        this ControllerBase controller,
+        IStorage storage,
+        HttpRequest request,
+        UploadOptions? options = null,
+        CancellationToken cancellationToken = default)
+    {
+        if (!StreamHelper.IsMultipartContentType(request.ContentType))
+        {
+            return Result<BlobMetadata>.Fail(HttpStatusCode.BadRequest, "Not a multipart request");
+        }
+
+        var boundary = StreamHelper.GetBoundary(
+            MediaTypeHeaderValue.Parse(request.ContentType),
+            DefaultMultipartBoundaryLengthLimit);
+
+        var multipartReader = new MultipartReader(boundary, request.Body);
+        var section = await multipartReader.ReadNextSectionAsync(cancellationToken);
+
+        while (section != null)
+        {
+            if (ContentDispositionHeaderValue.TryParse(section.ContentDisposition, out var contentDisposition)
+                && StreamHelper.HasFileContentDisposition(contentDisposition))
+            {
+                var fileName = contentDisposition.FileName.Value;
+                var contentType = section.ContentType;
+
+                if (options == null)
+                {
+                    options = new UploadOptions 
+                    { 
+                        FileName = fileName,
+                        MimeType = contentType
+                    };
+                }
+
+                using var memoryStream = new MemoryStream();
+                await section.Body.CopyToAsync(memoryStream, cancellationToken);
+                memoryStream.Position = 0;
+                
+                return await storage.UploadAsync(memoryStream, options, cancellationToken);
+            }
+
+            section = await multipartReader.ReadNextSectionAsync(cancellationToken);
+        }
+
+        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);
+    }
+}

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

@@ -8,4 +8,4 @@ public static IServiceCollection AddStorageSetupService(this IServiceCollection
     {
         return services.AddHostedService<StorageSetupBackgroundService>();
     }
-}
+}

…ns/StorageServiceCollectionExtensions.cs …on/StorageServiceCollectionExtensions.csIntegraions/ManagedCode.Storage.Server/Extensions/StorageServiceCollectionExtensions.cs renamed to Integraions/ManagedCode.Storage.Server/Extensions/DependencyInjection/StorageServiceCollectionExtensions.cs Integraions/ManagedCode.Storage.Server/Extensions/StorageServiceCollectionExtensions.cs renamed to Integraions/ManagedCode.Storage.Server/Extensions/DependencyInjection/StorageServiceCollectionExtensions.cs

@@ -13,4 +13,4 @@ public static async Task<LocalFile> ToLocalFileAsync(this IBrowserFile formFile,
         await localFile.CopyFromStreamAsync(formFile.OpenReadStream());
         return localFile;
     }
-}
+}

…rver/Extensions/BrowserFileExtensions.cs …Extensions/File/BrowserFileExtensions.csIntegraions/ManagedCode.Storage.Server/Extensions/BrowserFileExtensions.cs renamed to Integraions/ManagedCode.Storage.Server/Extensions/File/BrowserFileExtensions.cs Integraions/ManagedCode.Storage.Server/Extensions/BrowserFileExtensions.cs renamed to Integraions/ManagedCode.Storage.Server/Extensions/File/BrowserFileExtensions.cs

@@ -22,4 +22,4 @@ public static async IAsyncEnumerable<LocalFile> ToLocalFilesAsync(this IFormFile
         foreach (var formFile in formFileCollection)
             yield return await formFile.ToLocalFileAsync(cancellationToken);
     }
-}
+}

….Server/Extensions/FormFileExtensions.cs …er/Extensions/File/FormFileExtensions.csIntegraions/ManagedCode.Storage.Server/Extensions/FormFileExtensions.cs renamed to Integraions/ManagedCode.Storage.Server/Extensions/File/FormFileExtensions.cs Integraions/ManagedCode.Storage.Server/Extensions/FormFileExtensions.cs renamed to Integraions/ManagedCode.Storage.Server/Extensions/File/FormFileExtensions.cs

@@ -46,4 +46,4 @@ public static async Task<Result<BlobMetadata>> UploadToStorageAsync(this IStorag
             return await storage.UploadAsync(stream, options, cancellationToken);
         }
     }
-}
+}