server/AyaNova/Controllers/ImportController.cs

@@ -0,0 +1,160 @@
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.Http;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.AspNetCore.Routing;
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.Extensions.Logging;
+using AyaNova.Models;
+using AyaNova.Api.ControllerHelpers;
+using AyaNova.Biz;
+using AyaNova.Util;
+using Newtonsoft.Json;
+using Newtonsoft.Json.Linq;
+using System.IO;
+using System.IO.Compression;
+using ChoETL;
+
+namespace AyaNova.Api.Controllers
+{
+    [ApiController]
+    [ApiVersion("8.0")]
+    [Route("api/v{version:apiVersion}/import")]
+    [Produces("application/json")]
+    [Authorize]
+    public class ImportController : ControllerBase
+    {
+        private readonly AyContext ct;
+        private readonly ILogger<ImportController> log;
+        private readonly ApiServerState serverState;
+
+        /// <summary>
+        /// ctor
+        /// </summary>
+        /// <param name="dbcontext"></param>
+        /// <param name="logger"></param>
+        /// <param name="apiServerState"></param>  
+        public ImportController(AyContext dbcontext, ILogger<ImportController> logger, ApiServerState apiServerState)
+        {
+            ct = dbcontext;
+            log = logger;
+            serverState = apiServerState;
+        }
+
+
+
+
+
+        /// <summary>
+        /// Upload Translation export file
+        /// Max 15mb total
+        /// </summary>
+        /// <returns>Accepted</returns>
+        [Authorize]
+        [HttpPost("upload")]
+        [DisableFormValueModelBinding]
+        [RequestSizeLimit(15000000)]//currently export file is 200kb * 50 maximum at a time = 15mb  https://github.com/aspnet/Announcements/issues/267
+        public async Task<IActionResult> UploadAsync()
+        {
+            //Adapted from the example found here: https://docs.microsoft.com/en-us/aspnet/core/mvc/models/file-uploads#uploading-large-files-with-streaming
+
+            if (!serverState.IsOpen)
+                return StatusCode(503, new ApiErrorResponse(serverState.ApiErrorCode, null, serverState.Reason));
+
+
+            // AyaTypeId attachToObject = null;
+            ApiUploadProcessor.ApiUploadedFilesResult uploadFormData = null;
+            try
+            {
+                if (!MultipartRequestHelper.IsMultipartContentType(Request.ContentType))
+                    return BadRequest(new ApiErrorResponse(ApiErrorCode.INVALID_OPERATION, null, $"Expected a multipart request, but got {Request.ContentType}"));
+
+                //Save uploads to disk under temporary file names until we decide how to handle them
+                uploadFormData = await ApiUploadProcessor.ProcessUploadAsync(HttpContext);
+
+                bool badRequest = false;
+                string UploadObjectType = string.Empty;
+                string UploadObjectId = string.Empty;
+                string errorMessage = string.Empty;
+                string Notes = string.Empty;
+                List<UploadFileData> FileData = new List<UploadFileData>();
+
+                if (
+                !uploadFormData.FormFieldData.ContainsKey("FileData"))//only filedata is required
+                {
+                    badRequest = true;
+                    errorMessage = "Missing required FormFieldData value: FileData";
+                }
+                if (!badRequest)
+                {
+                    if (uploadFormData.FormFieldData.ContainsKey("ObjectType"))
+                        UploadObjectType = uploadFormData.FormFieldData["ObjectType"].ToString();
+                    if (uploadFormData.FormFieldData.ContainsKey("ObjectId"))
+                        UploadObjectId = uploadFormData.FormFieldData["ObjectId"].ToString();
+                    if (uploadFormData.FormFieldData.ContainsKey("Notes"))
+                        Notes = uploadFormData.FormFieldData["Notes"].ToString();
+                    //fileData in JSON stringify format which contains the actual last modified dates etc
+                    //"[{\"name\":\"Client.csv\",\"lastModified\":1582822079618},{\"name\":\"wmi4fu06nrs41.jpg\",\"lastModified\":1586900220990}]"
+                    FileData = Newtonsoft.Json.JsonConvert.DeserializeObject<List<UploadFileData>>(uploadFormData.FormFieldData["FileData"].ToString());
+
+                }
+
+
+                //  long UserId = UserIdFromContext.Id(HttpContext.Items);
+                //Instantiate the business object handler
+                TranslationBiz biz = TranslationBiz.GetBiz(ct, HttpContext);
+
+
+                //We have our files now can parse and insert into db
+                if (uploadFormData.UploadedFiles.Count > 0)
+                {
+                    //deserialize each file and import
+                    foreach (UploadedFileInfo a in uploadFormData.UploadedFiles)
+                    {
+                        JObject o = JObject.Parse(System.IO.File.ReadAllText(a.InitialUploadedPathName));
+                        if (!await biz.ImportAsync(o))
+                        {
+                            //delete all the files temporarily uploaded and return bad request
+                            ApiUploadProcessor.DeleteTempUploadFile(uploadFormData);
+                            return BadRequest(new ApiErrorResponse(biz.Errors));
+                        }
+                    }
+                }
+            }
+            catch (System.IO.InvalidDataException ex)
+            {
+                return BadRequest(new ApiErrorResponse(ApiErrorCode.INVALID_OPERATION, null, ex.Message));
+            }
+            finally
+            {
+                //delete all the files temporarily uploaded and return bad request
+
+                ApiUploadProcessor.DeleteTempUploadFile(uploadFormData);
+            }
+
+            //Return the list of attachment ids and filenames
+            return Accepted();
+        }
+
+
+        // private static void DeleteTempUploadFile(ApiUploadProcessor.ApiUploadedFilesResult uploadFormData)
+        // {
+        //     if (uploadFormData.UploadedFiles.Count > 0)
+        //     {
+        //         foreach (UploadedFileInfo a in uploadFormData.UploadedFiles)
+        //         {
+        //             System.IO.File.Delete(a.InitialUploadedPathName);
+        //         }
+        //     }
+        // }
+
+
+
+        //-----------------------------------------
+
+
+
+
+
+    }//eoc
+}//eons