Database migrations (#13)

* remove last use of dbcontextfactory * add initial migration
2021-02-12 12:50:04 +00:00
parent c2d8a54a47
commit db054ece24
31 changed files with 2869 additions and 104 deletions
@@ -0,0 +1,9 @@
+using System.Collections.Generic;
+using ErsatzTV.Core;
+using LanguageExt;
+
+namespace ErsatzTV.Application.MediaCollections.Commands
+{
+    public record AddItemsToSimpleMediaCollection
+        (int MediaCollectionId, List<int> ItemIds) : MediatR.IRequest<Either<BaseError, Unit>>;
+}
@@ -0,0 +1,79 @@
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading;
+using System.Threading.Tasks;
+using ErsatzTV.Core;
+using ErsatzTV.Core.Domain;
+using ErsatzTV.Core.Interfaces.Repositories;
+using LanguageExt;
+using static LanguageExt.Prelude;
+
+namespace ErsatzTV.Application.MediaCollections.Commands
+{
+    public class
+        AddItemsToSimpleMediaCollectionHandler : MediatR.IRequestHandler<AddItemsToSimpleMediaCollection,
+            Either<BaseError, Unit>>
+    {
+        private readonly IMediaCollectionRepository _mediaCollectionRepository;
+        private readonly IMediaItemRepository _mediaItemRepository;
+
+        public AddItemsToSimpleMediaCollectionHandler(
+            IMediaCollectionRepository mediaCollectionRepository,
+            IMediaItemRepository mediaItemRepository)
+        {
+            _mediaCollectionRepository = mediaCollectionRepository;
+            _mediaItemRepository = mediaItemRepository;
+        }
+
+        public Task<Either<BaseError, Unit>> Handle(
+            AddItemsToSimpleMediaCollection request,
+            CancellationToken cancellationToken) =>
+            Validate(request)
+                .MapT(ApplyAddItemsRequest)
+                .Bind(v => v.ToEitherAsync());
+
+        private async Task<Unit> ApplyAddItemsRequest(RequestParameters parameters)
+        {
+            foreach (MediaItem item in parameters.ItemsToAdd.Where(
+                item => parameters.Collection.Items.All(i => i.Id != item.Id)))
+            {
+                parameters.Collection.Items.Add(item);
+            }
+
+            await _mediaCollectionRepository.Update(parameters.Collection);
+
+            return Unit.Default;
+        }
+
+        private async Task<Validation<BaseError, RequestParameters>>
+            Validate(AddItemsToSimpleMediaCollection request) =>
+            (await SimpleMediaCollectionMustExist(request), await ValidateItems(request))
+            .Apply(
+                (simpleMediaCollectionToUpdate, itemsToAdd) =>
+                    new RequestParameters(simpleMediaCollectionToUpdate, itemsToAdd));
+
+        private Task<Validation<BaseError, SimpleMediaCollection>> SimpleMediaCollectionMustExist(
+            AddItemsToSimpleMediaCollection updateSimpleMediaCollection) =>
+            _mediaCollectionRepository.GetSimpleMediaCollection(updateSimpleMediaCollection.MediaCollectionId)
+                .Map(v => v.ToValidation<BaseError>("SimpleMediaCollection does not exist."));
+
+        private Task<Validation<BaseError, List<MediaItem>>> ValidateItems(
+            AddItemsToSimpleMediaCollection request) =>
+            LoadAllMediaItems(request)
+                .Map(v => v.ToValidation<BaseError>("MediaItem does not exist"));
+
+        private async Task<Option<List<MediaItem>>> LoadAllMediaItems(AddItemsToSimpleMediaCollection request)
+        {
+            var items = (await request.ItemIds.Map(async id => await _mediaItemRepository.Get(id)).Sequence())
+                .ToList();
+            if (items.Any(i => i.IsNone))
+            {
+                return None;
+            }
+
+            return items.Somes().ToList();
+        }
+
+        private record RequestParameters(SimpleMediaCollection Collection, List<MediaItem> ItemsToAdd);
+    }
+}
@@ -0,0 +1,11 @@
+using System;
+using System.Collections.Generic;
+using ErsatzTV.Application.MediaItems;
+using LanguageExt;
+using MediatR;
+
+namespace ErsatzTV.Application.MediaCollections.Queries
+{
+    public record GetSimpleMediaCollectionWithItemsById
+        (int Id) : IRequest<Option<Tuple<MediaCollectionViewModel, List<MediaItemSearchResultViewModel>>>>;
+}
@@ -0,0 +1,37 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading;
+using System.Threading.Tasks;
+using ErsatzTV.Application.MediaItems;
+using ErsatzTV.Core.Domain;
+using ErsatzTV.Core.Interfaces.Repositories;
+using LanguageExt;
+using MediatR;
+using static LanguageExt.Prelude;
+using static ErsatzTV.Application.MediaCollections.Mapper;
+using static ErsatzTV.Application.MediaItems.Mapper;
+
+namespace ErsatzTV.Application.MediaCollections.Queries
+{
+    public class GetSimpleMediaCollectionWithItemsByIdHandler : IRequestHandler<GetSimpleMediaCollectionWithItemsById,
+        Option<Tuple<MediaCollectionViewModel, List<MediaItemSearchResultViewModel>>>>
+    {
+        private readonly IMediaCollectionRepository _mediaCollectionRepository;
+
+        public GetSimpleMediaCollectionWithItemsByIdHandler(IMediaCollectionRepository mediaCollectionRepository) =>
+            _mediaCollectionRepository = mediaCollectionRepository;
+
+        public async Task<Option<Tuple<MediaCollectionViewModel, List<MediaItemSearchResultViewModel>>>> Handle(
+            GetSimpleMediaCollectionWithItemsById request,
+            CancellationToken cancellationToken)
+        {
+            Option<SimpleMediaCollection> maybeCollection =
+                await _mediaCollectionRepository.GetSimpleMediaCollectionWithItems(request.Id);
+
+            return maybeCollection.Match<Option<Tuple<MediaCollectionViewModel, List<MediaItemSearchResultViewModel>>>>(
+                c => Tuple(ProjectToViewModel(c), c.Items.Map(ProjectToSearchViewModel).ToList()),
+                None);
+        }
+    }
+}