Add SaveEpisodes controller

EstusShots.Server/Controllers/EpisodeController.cs

@@ -1,42 +0,0 @@
-using System;
-using System.Threading.Tasks;
-using AutoMapper;
-using EstusShots.Server.Models;
-using EstusShots.Server.Services;
-using Microsoft.AspNetCore.Mvc;
-using Microsoft.Extensions.Logging;
-
-namespace EstusShots.Server.Controllers
-{
-    [ApiController]
-    [Route("/api/[controller]")]
-    public class EpisodeController : ControllerBase
-    {
-        private readonly EstusShotsContext _context;
-        private readonly IMapper _mapper;
-        private readonly ILogger _logger;
-
-        public EpisodeController(EstusShotsContext context, IMapper mapper, ILogger<EpisodeController> logger)
-        {
-            _context = context;
-            _mapper = mapper;
-            _logger = logger;
-        }
-        
-        [HttpPost]
-        public async Task<ActionResult<Shared.Dto.Episode>> CreateSeason(Shared.Dto.Episode episodeDto)
-        {
-            var episode = _mapper.Map<Episode>(episodeDto);
-            _context.Episodes.Add(episode);
-            try
-            {
-                await _context.SaveChangesAsync();
-            }
-            catch (Exception e)
-            {
-                _logger.LogError(e, "Error while saving object");
-            }
-            return CreatedAtAction("", new {id = episode.EpisodeId}, episode);
-        }
-    }
-}

EstusShots.Server/Controllers/EpisodesController.cs

@@ -49,5 +49,19 @@ namespace EstusShots.Server.Controllers
                 return new ApiResponse<GetEpisodeResponse>(new OperationResult(e));
             }
         }
+
+        public async Task<ApiResponse<SaveEpisodeResponse>> SaveEpisode(SaveEpisodeParameter parameter)
+        {
+            try
+            {
+                _logger.LogInformation($"Request received from client '{Request.HttpContext.Connection.RemoteIpAddress}'");
+                return await _episodesService.SaveEpisode(parameter);
+            }
+            catch (Exception e)
+            {
+                _logger.LogError(e, "Exception Occured");
+                return new ApiResponse<SaveEpisodeResponse>(new OperationResult(e));
+            }
+        }
     }
 }

EstusShots.Server/Services/EpisodesService.cs

@@ -1,7 +1,9 @@
+using System;
 using System.Collections.Generic;
 using System.Linq;
 using System.Threading.Tasks;
 using AutoMapper;
+using EstusShots.Server.Models;
 using EstusShots.Shared.Interfaces;
 using EstusShots.Shared.Models;
 using EstusShots.Shared.Models.Parameters;
@@ -45,5 +47,29 @@ namespace EstusShots.Server.Services
             var dto = _mapper.Map<Dto.Episode>(episode);
             return new ApiResponse<GetEpisodeResponse>(new GetEpisodeResponse(dto));
         }
+
+        public async Task<ApiResponse<SaveEpisodeResponse>> SaveEpisode(SaveEpisodeParameter parameter)
+        {
+            var episode = _mapper.Map<Episode>(parameter.Episode);
+            if (episode.EpisodeId == Guid.Empty)
+            {
+                _context.Episodes.Add(episode);
+                try
+                {
+                    var count = await _context.SaveChangesAsync();
+                    _logger.LogInformation($"Updated {count} rows");
+                }
+                catch (Exception e)
+                {
+                    _logger.LogError(e, "Error while saving object");
+                    return new ApiResponse<SaveEpisodeResponse>(new OperationResult(e));
+                }
+                return new ApiResponse<SaveEpisodeResponse>(new SaveEpisodeResponse(episode.EpisodeId));
+            }
+            else
+            {
+                throw new NotImplementedException();
+            }
+        }
     }
 }