using System; using System.Collections.Generic; using System.Drawing; using System.Drawing.Imaging; using System.IO; using System.Linq; using System.Net.Http.Headers; using System.Text; using System.Text.RegularExpressions; using System.Threading.Tasks; using Manager.Interfaces.DTO; using Manager.Interfaces.Models; using Manager.Services; using ManagerService.Service.Services; using Microsoft.AspNetCore.Authorization; using Microsoft.AspNetCore.Mvc; using Microsoft.Extensions.Logging; using Newtonsoft.Json; using NSwag.Annotations; namespace ManagerService.Controllers { [Authorize] // TODO Add ROLES (Roles = "Admin") [ApiController, Route("api/[controller]")] [OpenApiTag("Resource", Description = "Resource management")] public class ResourceController : ControllerBase { private ResourceDatabaseService _resourceService; private SectionDatabaseService _sectionService; private ConfigurationDatabaseService _configurationService; private readonly ILogger _logger; public ResourceController(ILogger logger, ResourceDatabaseService resourceService, SectionDatabaseService sectionService, ConfigurationDatabaseService configurationService) { _logger = logger; _resourceService = resourceService; _sectionService = sectionService; _configurationService = configurationService; } /// /// Get a list of all resources (summary) /// /// id instance [ProducesResponseType(typeof(List), 200)] [ProducesResponseType(typeof(string), 500)] [HttpGet] public ObjectResult Get([FromQuery] string instanceId) { try { List resources = _resourceService.GetAll(instanceId); return new OkObjectResult(resources.Select(r => r.ToDTO(r.Type == ResourceType.ImageUrl))); } catch (Exception ex) { return new ObjectResult(ex.Message) { StatusCode = 500 }; } } /// /// Get a specific resource /// /// id resource [AllowAnonymous] [ProducesResponseType(typeof(ResourceDTO), 200)] [ProducesResponseType(typeof(string), 404)] [ProducesResponseType(typeof(string), 500)] [HttpGet("{id}/detail")] public ObjectResult GetDetail(string id) { try { Resource resource = _resourceService.GetById(id); if (resource == null) throw new KeyNotFoundException("This resource was not found"); return new OkObjectResult(resource.ToDTO(resource.Type == ResourceType.ImageUrl)); } catch (KeyNotFoundException ex) { return new NotFoundObjectResult(ex.Message) {}; } catch (Exception ex) { return new ObjectResult(ex.Message) { StatusCode = 500 }; } } /// /// Show a specific resource (as a picture or video stream) /// /// id resource [AllowAnonymous] [ProducesResponseType(typeof(FileResult), 200)] [ProducesResponseType(typeof(string), 404)] [ProducesResponseType(typeof(string), 500)] [HttpGet("{id}")] public ActionResult Show(string id) { try { Resource resource = _resourceService.GetById(id); if (resource == null) throw new KeyNotFoundException("This resource was not found"); var file = Convert.FromBase64String(resource.Data); if (resource.Type == ResourceType.Image) { return new FileContentResult(file, "image/png"); } if (resource.Type == ResourceType.Video) { return new FileContentResult(file, "application/octet-stream"); } return new FileContentResult(file, "image/png"); } catch (KeyNotFoundException ex) { return new NotFoundObjectResult(ex.Message) { }; } catch (Exception ex) { return new ObjectResult(ex.Message) { StatusCode = 500 }; } } /// /// Upload a specific resource (picture or video) /// [ProducesResponseType(typeof(string), 200)] [ProducesResponseType(typeof(string), 404)] [ProducesResponseType(typeof(string), 500)] [HttpPost("upload"), DisableRequestSizeLimit] public IActionResult Upload([FromForm] string label, [FromForm] string type, [FromForm] string instanceId) // Create but with local //[FromBody] ResourceDetailDTO uploadResource { try { if (label == null || type == null || instanceId == null) throw new ArgumentNullException("One of resource params is null"); List resources = new List(); foreach (var file in Request.Form.Files) { if (file.Length > 0) { var stringResult = ""; if (file.Length > 0) { using (var ms = new MemoryStream()) { file.CopyTo(ms); var fileBytes = ms.ToArray(); stringResult = Convert.ToBase64String(fileBytes); } } // Todo add some verification ? Resource resource = new Resource(); resource.Label = label; resource.Type = (ResourceType)Enum.Parse(typeof(ResourceType), type); resource.DateCreation = DateTime.Now; resource.Data = stringResult; resource.InstanceId = instanceId; Resource resourceCreated = _resourceService.Create(resource); resources.Add(resourceCreated); } } return Ok(resources.Select(r => r.ToDTO())); } catch (ArgumentNullException ex) { return new BadRequestObjectResult(ex.Message) { }; } catch (InvalidOperationException ex) { return new ConflictObjectResult(ex.Message) { }; } catch (Exception ex) { return new ObjectResult(ex.Message) { StatusCode = 500 }; } } /// /// Create a new resource /// /// New resource info [ProducesResponseType(typeof(ResourceDTO), 200)] [ProducesResponseType(typeof(string), 400)] [ProducesResponseType(typeof(string), 409)] [ProducesResponseType(typeof(string), 500)] [HttpPost] public ObjectResult Create([FromBody] ResourceDTO newResource) { try { if (newResource == null) throw new ArgumentNullException("Resource param is null"); // Todo add some verification ? Resource resource = new Resource(); resource.InstanceId = newResource.instanceId; resource.Label = newResource.label; resource.Type = newResource.type; resource.DateCreation = DateTime.Now; resource.Data = newResource.data; resource.InstanceId = newResource.instanceId; Resource resourceCreated = _resourceService.Create(resource); return new OkObjectResult(resourceCreated.ToDTO(resource.Type == ResourceType.ImageUrl)); } catch (ArgumentNullException ex) { return new BadRequestObjectResult(ex.Message) {}; } catch (InvalidOperationException ex) { return new ConflictObjectResult(ex.Message) {}; } catch (Exception ex) { return new ObjectResult(ex.Message) { StatusCode = 500 }; } } /// /// Update a resource /// /// Resource to update [ProducesResponseType(typeof(ResourceDTO), 200)] [ProducesResponseType(typeof(string), 400)] [ProducesResponseType(typeof(string), 404)] [ProducesResponseType(typeof(string), 500)] [HttpPut] public ObjectResult Update([FromBody] ResourceDTO updatedResource) { try { if (updatedResource == null) throw new ArgumentNullException("Resource param is null"); Resource resource = _resourceService.GetById(updatedResource.id); if (resource == null) throw new KeyNotFoundException("Resource does not exist"); // Todo add some verification ? resource.InstanceId = updatedResource.instanceId; resource.Label = updatedResource.label; resource.Type = updatedResource.type; resource.Data = updatedResource.data; Resource resourceModified = _resourceService.Update(updatedResource.id, resource); return new OkObjectResult(resourceModified.ToDTO()); } catch (ArgumentNullException ex) { return new BadRequestObjectResult(ex.Message) {}; } catch (KeyNotFoundException ex) { return new NotFoundObjectResult(ex.Message) {}; } catch (Exception ex) { return new ObjectResult(ex.Message) { StatusCode = 500 }; } } /// /// Delete a resource /// /// Id of resource to delete [ProducesResponseType(typeof(string), 202)] [ProducesResponseType(typeof(string), 400)] [ProducesResponseType(typeof(string), 404)] [ProducesResponseType(typeof(string), 500)] [HttpDelete("{id}")] public ObjectResult Delete(string id) { try { if (id == null) throw new ArgumentNullException("Resource param is null"); var ressource = _resourceService.GetById(id); if (ressource == null) throw new KeyNotFoundException("Resource does not exist"); foreach (var configuration in _configurationService.GetAll(ressource.InstanceId)) { if (configuration.ImageId == id) { configuration.ImageId = null; configuration.ImageSource = null; } } // Delete all resource occurence foreach (var section in _sectionService.GetAll(ressource.InstanceId)) { if (section.ImageId == id) { section.ImageId = null; section.ImageSource = null; } switch (section.Type) { case SectionType.Map: MapDTO mapDTO = JsonConvert.DeserializeObject(section.Data); mapDTO.iconResourceId = mapDTO.iconResourceId == id ? null : mapDTO.iconResourceId; foreach (var point in mapDTO.points) { foreach (var image in point.images) { image.imageSource = image.imageResourceId == id ? null : image.imageSource; image.imageResourceId = image.imageResourceId == id ? null : image.imageResourceId; } } section.Data = JsonConvert.SerializeObject(mapDTO); break; case SectionType.Slider: SliderDTO sliderDTO = JsonConvert.DeserializeObject(section.Data); List imagesToKeep = new List(); foreach (var image in sliderDTO.images) { if (image.resourceId != id) imagesToKeep.Add(image); } sliderDTO.images = imagesToKeep; section.Data = JsonConvert.SerializeObject(sliderDTO); break; case SectionType.Quizz: QuizzDTO quizzDTO = JsonConvert.DeserializeObject(section.Data); foreach (var question in quizzDTO.questions) { question.source = question.resourceId == id ? null : question.source; question.resourceId = question.resourceId == id ? null : question.resourceId; } if (quizzDTO.bad_level != null) { quizzDTO.bad_level.source = quizzDTO.bad_level.resourceId == id ? null : quizzDTO.bad_level.source; quizzDTO.bad_level.resourceId = quizzDTO.bad_level.resourceId == id ? null : quizzDTO.bad_level.resourceId; } if (quizzDTO.medium_level != null) { quizzDTO.medium_level.source = quizzDTO.medium_level.resourceId == id ? null : quizzDTO.medium_level.source; quizzDTO.medium_level.resourceId = quizzDTO.medium_level.resourceId == id ? null : quizzDTO.medium_level.resourceId; } if (quizzDTO.good_level != null) { quizzDTO.good_level.source = quizzDTO.good_level.resourceId == id ? null : quizzDTO.good_level.source; quizzDTO.good_level.resourceId = quizzDTO.good_level.resourceId == id ? null : quizzDTO.good_level.resourceId; } if (quizzDTO.great_level != null) { quizzDTO.great_level.source = quizzDTO.great_level.resourceId == id ? null : quizzDTO.great_level.source; quizzDTO.great_level.resourceId = quizzDTO.great_level.resourceId == id ? null : quizzDTO.great_level.resourceId; } section.Data = JsonConvert.SerializeObject(quizzDTO); break; case SectionType.Article: ArticleDTO articleDTO = JsonConvert.DeserializeObject(section.Data); List imagesArticleToKeep = new List(); foreach (var image in articleDTO.images) { if (image.resourceId != id) imagesArticleToKeep.Add(image); } articleDTO.images = imagesArticleToKeep; section.Data = JsonConvert.SerializeObject(articleDTO); break; } _sectionService.Update(section.Id, section); } _resourceService.Remove(id); return new ObjectResult("The resource has been deleted") { StatusCode = 202 }; } catch (ArgumentNullException ex) { return new BadRequestObjectResult(ex.Message) { }; } catch (KeyNotFoundException ex) { return new NotFoundObjectResult(ex.Message) { }; } catch (Exception ex) { return new ObjectResult(ex.Message) { StatusCode = 500 }; } } } }