mirror of https://github.com/ErsatzTV/ErsatzTV.git
20 changed files with 425 additions and 1 deletions
@ -0,0 +1,5 @@ |
|||||||
|
using ErsatzTV.Core; |
||||||
|
|
||||||
|
namespace ErsatzTV.Application.MediaCollections; |
||||||
|
|
||||||
|
public record AddEpisodeToPlaylist(int PlaylistId, int EpisodeId) : IRequest<Either<BaseError, Unit>>; |
||||||
@ -0,0 +1,59 @@ |
|||||||
|
using ErsatzTV.Core; |
||||||
|
using ErsatzTV.Core.Domain; |
||||||
|
using ErsatzTV.Infrastructure.Data; |
||||||
|
using ErsatzTV.Infrastructure.Extensions; |
||||||
|
using Microsoft.EntityFrameworkCore; |
||||||
|
|
||||||
|
namespace ErsatzTV.Application.MediaCollections; |
||||||
|
|
||||||
|
public class AddEpisodeToPlaylistHandler(IDbContextFactory<TvContext> dbContextFactory) |
||||||
|
: IRequestHandler<AddEpisodeToPlaylist, Either<BaseError, Unit>> |
||||||
|
{ |
||||||
|
public async Task<Either<BaseError, Unit>> Handle( |
||||||
|
AddEpisodeToPlaylist request, |
||||||
|
CancellationToken cancellationToken) |
||||||
|
{ |
||||||
|
await using TvContext dbContext = await dbContextFactory.CreateDbContextAsync(cancellationToken); |
||||||
|
Validation<BaseError, Parameters> validation = await Validate(dbContext, request); |
||||||
|
return await validation.Apply(parameters => ApplyAddEpisodeRequest(dbContext, parameters)); |
||||||
|
} |
||||||
|
|
||||||
|
private static async Task<Unit> ApplyAddEpisodeRequest(TvContext dbContext, Parameters parameters) |
||||||
|
{ |
||||||
|
var playlistItem = new PlaylistItem |
||||||
|
{ |
||||||
|
Index = parameters.Playlist.Items.Max(i => i.Index) + 1, |
||||||
|
CollectionType = ProgramScheduleItemCollectionType.Episode, |
||||||
|
MediaItemId = parameters.Episode.Id, |
||||||
|
PlaybackOrder = PlaybackOrder.Shuffle, |
||||||
|
IncludeInProgramGuide = true |
||||||
|
}; |
||||||
|
|
||||||
|
parameters.Playlist.Items.Add(playlistItem); |
||||||
|
await dbContext.SaveChangesAsync(); |
||||||
|
return Unit.Default; |
||||||
|
} |
||||||
|
|
||||||
|
private static async Task<Validation<BaseError, Parameters>> Validate( |
||||||
|
TvContext dbContext, |
||||||
|
AddEpisodeToPlaylist request) => |
||||||
|
(await PlaylistMustExist(dbContext, request), await ValidateEpisode(dbContext, request)) |
||||||
|
.Apply((collection, episode) => new Parameters(collection, episode)); |
||||||
|
|
||||||
|
private static Task<Validation<BaseError, Playlist>> PlaylistMustExist( |
||||||
|
TvContext dbContext, |
||||||
|
AddEpisodeToPlaylist request) => |
||||||
|
dbContext.Playlists |
||||||
|
.Include(c => c.Items) |
||||||
|
.SelectOneAsync(c => c.Id, c => c.Id == request.PlaylistId) |
||||||
|
.Map(o => o.ToValidation<BaseError>("Playlist does not exist.")); |
||||||
|
|
||||||
|
private static Task<Validation<BaseError, Episode>> ValidateEpisode( |
||||||
|
TvContext dbContext, |
||||||
|
AddEpisodeToPlaylist request) => |
||||||
|
dbContext.Episodes |
||||||
|
.SelectOneAsync(m => m.Id, e => e.Id == request.EpisodeId) |
||||||
|
.Map(o => o.ToValidation<BaseError>("Episode does not exist")); |
||||||
|
|
||||||
|
private sealed record Parameters(Playlist Playlist, Episode Episode); |
||||||
|
} |
||||||
@ -0,0 +1,5 @@ |
|||||||
|
using ErsatzTV.Core; |
||||||
|
|
||||||
|
namespace ErsatzTV.Application.MediaCollections; |
||||||
|
|
||||||
|
public record AddSeasonToPlaylist(int PlaylistId, int SeasonId) : IRequest<Either<BaseError, Unit>>; |
||||||
@ -0,0 +1,59 @@ |
|||||||
|
using ErsatzTV.Core; |
||||||
|
using ErsatzTV.Core.Domain; |
||||||
|
using ErsatzTV.Infrastructure.Data; |
||||||
|
using ErsatzTV.Infrastructure.Extensions; |
||||||
|
using Microsoft.EntityFrameworkCore; |
||||||
|
|
||||||
|
namespace ErsatzTV.Application.MediaCollections; |
||||||
|
|
||||||
|
public class AddSeasonToPlaylistHandler(IDbContextFactory<TvContext> dbContextFactory) |
||||||
|
: IRequestHandler<AddSeasonToPlaylist, Either<BaseError, Unit>> |
||||||
|
{ |
||||||
|
public async Task<Either<BaseError, Unit>> Handle( |
||||||
|
AddSeasonToPlaylist request, |
||||||
|
CancellationToken cancellationToken) |
||||||
|
{ |
||||||
|
await using TvContext dbContext = await dbContextFactory.CreateDbContextAsync(cancellationToken); |
||||||
|
Validation<BaseError, Parameters> validation = await Validate(dbContext, request); |
||||||
|
return await validation.Apply(parameters => ApplyAddSeasonRequest(dbContext, parameters)); |
||||||
|
} |
||||||
|
|
||||||
|
private static async Task<Unit> ApplyAddSeasonRequest(TvContext dbContext, Parameters parameters) |
||||||
|
{ |
||||||
|
var playlistItem = new PlaylistItem |
||||||
|
{ |
||||||
|
Index = parameters.Playlist.Items.Max(i => i.Index) + 1, |
||||||
|
CollectionType = ProgramScheduleItemCollectionType.TelevisionSeason, |
||||||
|
MediaItemId = parameters.Season.Id, |
||||||
|
PlaybackOrder = PlaybackOrder.Shuffle, |
||||||
|
IncludeInProgramGuide = true |
||||||
|
}; |
||||||
|
|
||||||
|
parameters.Playlist.Items.Add(playlistItem); |
||||||
|
await dbContext.SaveChangesAsync(); |
||||||
|
return Unit.Default; |
||||||
|
} |
||||||
|
|
||||||
|
private static async Task<Validation<BaseError, Parameters>> Validate( |
||||||
|
TvContext dbContext, |
||||||
|
AddSeasonToPlaylist request) => |
||||||
|
(await PlaylistMustExist(dbContext, request), await ValidateSeason(dbContext, request)) |
||||||
|
.Apply((collection, episode) => new Parameters(collection, episode)); |
||||||
|
|
||||||
|
private static Task<Validation<BaseError, Playlist>> PlaylistMustExist( |
||||||
|
TvContext dbContext, |
||||||
|
AddSeasonToPlaylist request) => |
||||||
|
dbContext.Playlists |
||||||
|
.Include(c => c.Items) |
||||||
|
.SelectOneAsync(c => c.Id, c => c.Id == request.PlaylistId) |
||||||
|
.Map(o => o.ToValidation<BaseError>("Playlist does not exist.")); |
||||||
|
|
||||||
|
private static Task<Validation<BaseError, Season>> ValidateSeason( |
||||||
|
TvContext dbContext, |
||||||
|
AddSeasonToPlaylist request) => |
||||||
|
dbContext.Seasons |
||||||
|
.SelectOneAsync(m => m.Id, e => e.Id == request.SeasonId) |
||||||
|
.Map(o => o.ToValidation<BaseError>("Season does not exist")); |
||||||
|
|
||||||
|
private sealed record Parameters(Playlist Playlist, Season Season); |
||||||
|
} |
||||||
@ -0,0 +1,5 @@ |
|||||||
|
using ErsatzTV.Core; |
||||||
|
|
||||||
|
namespace ErsatzTV.Application.MediaCollections; |
||||||
|
|
||||||
|
public record AddShowToPlaylist(int PlaylistId, int ShowId) : IRequest<Either<BaseError, Unit>>; |
||||||
@ -0,0 +1,59 @@ |
|||||||
|
using ErsatzTV.Core; |
||||||
|
using ErsatzTV.Core.Domain; |
||||||
|
using ErsatzTV.Infrastructure.Data; |
||||||
|
using ErsatzTV.Infrastructure.Extensions; |
||||||
|
using Microsoft.EntityFrameworkCore; |
||||||
|
|
||||||
|
namespace ErsatzTV.Application.MediaCollections; |
||||||
|
|
||||||
|
public class AddShowToPlaylistHandler(IDbContextFactory<TvContext> dbContextFactory) |
||||||
|
: IRequestHandler<AddShowToPlaylist, Either<BaseError, Unit>> |
||||||
|
{ |
||||||
|
public async Task<Either<BaseError, Unit>> Handle( |
||||||
|
AddShowToPlaylist request, |
||||||
|
CancellationToken cancellationToken) |
||||||
|
{ |
||||||
|
await using TvContext dbContext = await dbContextFactory.CreateDbContextAsync(cancellationToken); |
||||||
|
Validation<BaseError, Parameters> validation = await Validate(dbContext, request); |
||||||
|
return await validation.Apply(parameters => ApplyAddShowRequest(dbContext, parameters)); |
||||||
|
} |
||||||
|
|
||||||
|
private static async Task<Unit> ApplyAddShowRequest(TvContext dbContext, Parameters parameters) |
||||||
|
{ |
||||||
|
var playlistItem = new PlaylistItem |
||||||
|
{ |
||||||
|
Index = parameters.Playlist.Items.Max(i => i.Index) + 1, |
||||||
|
CollectionType = ProgramScheduleItemCollectionType.TelevisionShow, |
||||||
|
MediaItemId = parameters.Show.Id, |
||||||
|
PlaybackOrder = PlaybackOrder.Shuffle, |
||||||
|
IncludeInProgramGuide = true |
||||||
|
}; |
||||||
|
|
||||||
|
parameters.Playlist.Items.Add(playlistItem); |
||||||
|
await dbContext.SaveChangesAsync(); |
||||||
|
return Unit.Default; |
||||||
|
} |
||||||
|
|
||||||
|
private static async Task<Validation<BaseError, Parameters>> Validate( |
||||||
|
TvContext dbContext, |
||||||
|
AddShowToPlaylist request) => |
||||||
|
(await PlaylistMustExist(dbContext, request), await ValidateShow(dbContext, request)) |
||||||
|
.Apply((collection, episode) => new Parameters(collection, episode)); |
||||||
|
|
||||||
|
private static Task<Validation<BaseError, Playlist>> PlaylistMustExist( |
||||||
|
TvContext dbContext, |
||||||
|
AddShowToPlaylist request) => |
||||||
|
dbContext.Playlists |
||||||
|
.Include(c => c.Items) |
||||||
|
.SelectOneAsync(c => c.Id, c => c.Id == request.PlaylistId) |
||||||
|
.Map(o => o.ToValidation<BaseError>("Playlist does not exist.")); |
||||||
|
|
||||||
|
private static Task<Validation<BaseError, Show>> ValidateShow( |
||||||
|
TvContext dbContext, |
||||||
|
AddShowToPlaylist request) => |
||||||
|
dbContext.Shows |
||||||
|
.SelectOneAsync(m => m.Id, e => e.Id == request.ShowId) |
||||||
|
.Map(o => o.ToValidation<BaseError>("Show does not exist")); |
||||||
|
|
||||||
|
private sealed record Parameters(Playlist Playlist, Show Show); |
||||||
|
} |
||||||
Loading…
Reference in new issue