using Microsoft.EntityFrameworkCore; using WatchIt.Common.Model.Movies; using WatchIt.Database; using WatchIt.Database.Model.Media; using WatchIt.WebAPI.Services.Controllers.Common; using WatchIt.WebAPI.Services.Utility.User; namespace WatchIt.WebAPI.Services.Controllers.Movies; public class MoviesControllerService(DatabaseContext database, IUserService userService) : IMoviesControllerService { #region PUBLIC METHODS public async Task GetAll(MovieQueryParameters query) { IEnumerable data = await database.MediaMovies.Select(x => new MovieResponse(x)).ToListAsync(); data = query.PrepareData(data); return RequestResult.Ok(data); } public async Task Get(long id) { MediaMovie? item = await database.MediaMovies.FirstOrDefaultAsync(x => x.Id == id); if (item is null) { return RequestResult.NotFound(); } MovieResponse data = new MovieResponse(item); return RequestResult.Ok(data); } public async Task Post(MovieRequest data) { UserValidator validator = userService.GetValidator().MustBeAdmin(); if (!validator.IsValid) { return RequestResult.Forbidden(); } Media mediaItem = data.CreateMedia(); await database.Media.AddAsync(mediaItem); await database.SaveChangesAsync(); MediaMovie mediaMovieItem = data.CreateMediaMovie(mediaItem.Id); await database.MediaMovies.AddAsync(mediaMovieItem); await database.SaveChangesAsync(); return RequestResult.Created($"movies/{mediaItem.Id}", new MovieResponse(mediaMovieItem)); } public async Task Put(long id, MovieRequest data) { UserValidator validator = userService.GetValidator().MustBeAdmin(); if (!validator.IsValid) { return RequestResult.Forbidden(); } MediaMovie? item = await database.MediaMovies.FirstOrDefaultAsync(x => x.Id == id); if (item is null) { return RequestResult.NotFound(); } data.UpdateMediaMovie(item); data.UpdateMedia(item.Media); await database.SaveChangesAsync(); return RequestResult.Ok(); } public async Task Delete(long id) { UserValidator validator = userService.GetValidator().MustBeAdmin(); if (!validator.IsValid) { return RequestResult.Forbidden(); } MediaMovie? item = await database.MediaMovies.FirstOrDefaultAsync(x => x.Id == id); if (item is null) { return RequestResult.NotFound(); } database.MediaMovies.Attach(item); database.MediaMovies.Remove(item); database.MediaPosterImages.Attach(item.Media.MediaPosterImage!); database.MediaPosterImages.Remove(item.Media.MediaPosterImage!); database.MediaPhotoImages.AttachRange(item.Media.MediaPhotoImages); database.MediaPhotoImages.RemoveRange(item.Media.MediaPhotoImages); database.MediaGenres.AttachRange(item.Media.MediaGenres); database.MediaGenres.RemoveRange(item.Media.MediaGenres); database.MediaProductionCountries.AttachRange(item.Media.MediaProductionCountries); database.MediaProductionCountries.RemoveRange(item.Media.MediaProductionCountries); database.PersonActorRoles.AttachRange(item.Media.PersonActorRoles); database.PersonActorRoles.RemoveRange(item.Media.PersonActorRoles); database.PersonCreatorRoles.AttachRange(item.Media.PersonCreatorRoles); database.PersonCreatorRoles.RemoveRange(item.Media.PersonCreatorRoles); database.RatingsMedia.AttachRange(item.Media.RatingMedia); database.RatingsMedia.RemoveRange(item.Media.RatingMedia); database.ViewCountsMedia.AttachRange(item.Media.ViewCountsMedia); database.ViewCountsMedia.RemoveRange(item.Media.ViewCountsMedia); database.Media.Attach(item.Media); database.Media.Remove(item.Media); await database.SaveChangesAsync(); return RequestResult.Ok(); } #endregion }