multipart works

Author: gencebay

.gitignore

@@ -240,3 +240,6 @@ ModelManifest.xml
 
 # FAKE - F# Make
 .fake/
+
+# DB
+musicdb.sqlite

src/NetCoreStack.Proxy/DefaultProxyContentStreamProvider.cs

@@ -24,6 +24,13 @@ protected virtual StringContent SerializeToString(object value)
             return new StringContent(JsonConvert.SerializeObject(value), Encoding.UTF8, "application/json");
         }
 
+        protected virtual MultipartFormDataContent GetMultipartFormDataContent()
+        {
+            MultipartFormDataContent multipartFormDataContent = new MultipartFormDataContent();
+
+            return multipartFormDataContent;
+        }
+
         protected virtual HttpContent CreateHttpContent(object value)
         {
             HttpContent content;

src/NetCoreStack.Proxy/Extensions/DictionaryExtensions.cs

@@ -35,7 +35,7 @@ public static void Merge(this IDictionary<string, object> instance, IDictionary<
             }
         }
 
-        public static void MergeArgs(this IDictionary<string, object> dictionary, object[] args, ParameterDescriptor[] parameters)
+        public static void MergeArgs(this IDictionary<string, object> dictionary, object[] args, ProxyParameterDescriptor[] parameters)
         {
             if (args.Length == 0)
                 return;

src/NetCoreStack.Proxy/Internal/DefaultProxyTypeManager.cs

@@ -1,4 +1,5 @@
-using Microsoft.AspNetCore.Mvc.Abstractions;
+using Microsoft.AspNetCore.Http;
+using Microsoft.AspNetCore.Mvc.Abstractions;
 using Microsoft.AspNetCore.Mvc.ModelBinding;
 using NetCoreStack.Contracts;
 using NetCoreStack.Proxy.Extensions;
@@ -88,13 +89,16 @@ private IList<ProxyDescriptor> GetProxyDescriptors()
                         proxyMethodDescriptor.HttpMethod = HttpMethod.Get;
                     }
 
-                    proxyMethodDescriptor.Parameters = new List<ParameterDescriptor>();
+                    proxyMethodDescriptor.Parameters = new List<ProxyParameterDescriptor>();
                     foreach (var parameter in method.GetParameters())
                     {
-                        proxyMethodDescriptor.Parameters.Add(new ParameterDescriptor()
+                        var parameterType = parameter.ParameterType;
+                        var properties = parameterType.GetProperties().ToList();
+
+                        proxyMethodDescriptor.Parameters.Add(new ProxyParameterDescriptor(properties)
                         {
                             Name = parameter.Name,
-                            ParameterType = parameter.ParameterType,
+                            ParameterType = parameterType,
                             BindingInfo = BindingInfo.GetBindingInfo(parameter.GetCustomAttributes().OfType<object>())
                         });
                     }

src/NetCoreStack.Proxy/ProxyMethodDescriptor.cs

@@ -1,5 +1,4 @@
 using Microsoft.AspNetCore.Mvc;
-using Microsoft.AspNetCore.Mvc.Abstractions;
 using NetCoreStack.Contracts;
 using NetCoreStack.Proxy.Extensions;
 using System;
@@ -23,7 +22,7 @@ public class ProxyMethodDescriptor
 
         public TimeSpan? Timeout { get; set; }
 
-        public List<ParameterDescriptor> Parameters { get; set; }
+        public List<ProxyParameterDescriptor> Parameters { get; set; }
 
         public bool IsVoidReturn { get; }
         public bool IsTaskReturn { get; }

src/NetCoreStack.Proxy/ProxyParameterDescriptor.cs

@@ -0,0 +1,25 @@
+using Microsoft.AspNetCore.Http;
+using Microsoft.AspNetCore.Mvc.Abstractions;
+using System.Collections.Generic;
+using System.Linq;
+using System.Reflection;
+
+namespace NetCoreStack.Proxy
+{
+    public class ProxyParameterDescriptor : ParameterDescriptor
+    {
+        public List<PropertyInfo> Properties { get; }
+
+        public bool EnsureMultipartFormData { get; }
+
+
+
+        public ProxyParameterDescriptor(List<PropertyInfo> properties)
+        {
+            Properties = properties;
+            EnsureMultipartFormData = Properties
+                .Where(p => typeof(IFormFile).IsAssignableFrom(p.PropertyType) ||
+                typeof(byte[]).IsAssignableFrom(p.PropertyType)).Any();
+        }
+    }
+}

test/NetCoreStack.Api.Hosting/Controllers/AlbumController.cs

@@ -1,10 +1,13 @@
-using Microsoft.AspNetCore.Mvc;
+using Microsoft.AspNetCore.Http.Internal;
+using Microsoft.AspNetCore.Mvc;
 using NetCoreStack.Contracts;
 using NetCoreStack.Data.Interfaces;
 using NetCoreStack.Domain.Contracts;
 using NetCoreStack.Domain.Contracts.ApiContracts;
 using NetCoreStack.Mvc.Extensions;
+using System.IO;
 using System.Linq;
+using System.Text;
 using System.Threading.Tasks;
 
 namespace NetCoreStack.WebClient.Hosting.Controllers
@@ -99,6 +102,43 @@ public async Task<AlbumViewModel> SaveAlbum([FromBody]AlbumViewModel model)
             return model;
         }
 
+        [HttpPost(nameof(SaveAlbumSubmit))]
+        public async Task<AlbumViewModel> SaveAlbumSubmit(AlbumViewModelSubmit model)
+        {
+            await Task.CompletedTask;
+            var req = HttpContext.Request;
+            req.EnableRewind();
+
+            // Arguments: Stream, Encoding, detect encoding, buffer size 
+            // AND, the most important: keep stream opened
+            using (StreamReader reader = new StreamReader(req.Body, Encoding.UTF8, true, 1024, true))
+            {
+                var bodyStr = reader.ReadToEnd();
+            }
+
+            long id = 0;
+            var objectState = ObjectState.Added;
+            if (!model.IsNew)
+            {
+                id = model.Id;
+                objectState = ObjectState.Modified;
+            }
+
+            var album = new Album
+            {
+                AlbumArtUrl = model.AlbumArtUrl,
+                ArtistId = model.ArtistId,
+                GenreId = model.GenreId,
+                Id = id,
+                ObjectState = objectState,
+                Price = model.Price,
+                Title = model.Title
+            };
+
+            _unitOfWork.Repository<Album>().SaveAllChanges(album);
+            return model;
+        }
+
         [HttpPut(nameof(UpdateAlbum))]
         public async Task<AlbumViewModel> UpdateAlbum(long id, [FromBody]AlbumViewModel model)
         {

test/NetCoreStack.Domain.Contracts/AlbumViewModel.cs

@@ -1,4 +1,5 @@
-using NetCoreStack.Contracts;
+using Microsoft.AspNetCore.Http;
+using NetCoreStack.Contracts;
 using System.ComponentModel.DataAnnotations;
 
 namespace NetCoreStack.Domain.Contracts
@@ -48,4 +49,9 @@ public class AlbumBsonViewModel
         [PropertyDescriptor(EnableFilter = true)]
         public string AlbumArtUrl { get; set; }
     }
+
+    public class AlbumViewModelSubmit : AlbumViewModel
+    {
+        public IFormFile Image { get; set; }
+    }
 }

test/NetCoreStack.Domain.Contracts/ApiContracts/IAlbumApi.cs

@@ -13,6 +13,9 @@ public interface IAlbumApi : IApiContract
         [HttpPostMarker]
         Task<AlbumViewModel> SaveAlbum(AlbumViewModel model);
 
+        [HttpPostMarker]
+        Task<AlbumViewModel> SaveAlbumSubmit(AlbumViewModelSubmit model);        
+
         [HttpPutMarker]
         Task<AlbumViewModel> UpdateAlbum(long id, AlbumViewModel model);
 

test/NetCoreStack.WebClient.Hosting/Controllers/HomeController.cs

@@ -48,6 +48,12 @@ public async Task<IActionResult> Index()
             return View();
         }
 
+        public async Task<IActionResult> IndexSubmit()
+        {
+            await IndexInitializer();
+            return View();
+        }
+
         public async Task<IActionResult> IndexMongo()
         {
             await IndexInitializer();
@@ -80,6 +86,13 @@ public async Task<IActionResult> SaveAlbum([FromBody]AlbumViewModel model)
             return Ok();
         }
 
+        [HttpPost]
+        public async Task<IActionResult> SaveAlbumSubmit(AlbumViewModelSubmit model)
+        {
+            var albumCollection = await _albumApi.SaveAlbumSubmit(model);
+            return Ok();
+        }
+
         [HttpPost]
         public async Task<IActionResult> UpdateAlbum()
         {