pimhwang
/
ErsatzTV
mirror of https://github.com/ErsatzTV/ErsatzTV.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity
Browse Source

remove old television tables from database

pull/31/head
Jason Dove 6 years ago
parent
15d22c4641
commit
d879bd6b02
8 changed files with 1967 additions and 747 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 3
      ErsatzTV.Application/MediaCards/Queries/GetCollectionCards.cs
  2. 6
      ErsatzTV.Application/MediaCards/Queries/GetCollectionCardsHandler.cs
  3. 4
      ErsatzTV.Core/Domain/PlayoutProgramScheduleAnchor.cs
  4. 11
      ErsatzTV.Core/Interfaces/Repositories/ICollectionRepository.cs
  5. 6
      ErsatzTV.Core/Scheduling/PlayoutBuilder.cs
  6. 1361
      ErsatzTV.Infrastructure/Migrations/20210226183532_Remove_OldTelevisionEntities.Designer.cs
  7. 489
      ErsatzTV.Infrastructure/Migrations/20210226183532_Remove_OldTelevisionEntities.cs
  8. 834
      ErsatzTV.Infrastructure/Migrations/TvContextModelSnapshot.cs

3
ErsatzTV.Application/MediaCards/Queries/GetCollectionCards.cs
Unescape View File

@ -4,6 +4,5 @@ using MediatR;
namespace ErsatzTV.Application.MediaCards.Queries namespace ErsatzTV.Application.MediaCards.Queries
{ {
public record GetCollectionCards public record GetCollectionCards(int Id) : IRequest<Either<BaseError, CollectionCardResultsViewModel>>;
(int Id) : IRequest<Either<BaseError, CollectionCardResultsViewModel>>;
} }

6
ErsatzTV.Application/MediaCards/Queries/GetCollectionCardsHandler.cs
Unescape View File

@ -11,15 +11,15 @@ namespace ErsatzTV.Application.MediaCards.Queries
public class GetCollectionCardsHandler : IRequestHandler<GetCollectionCards, public class GetCollectionCardsHandler : IRequestHandler<GetCollectionCards,
Either<BaseError, CollectionCardResultsViewModel>> Either<BaseError, CollectionCardResultsViewModel>>
{ {
private readonly ICollectionRepository _collectionRepository; private readonly IMediaCollectionRepository _collectionRepository;
public GetCollectionCardsHandler(ICollectionRepository collectionRepository) => public GetCollectionCardsHandler(IMediaCollectionRepository collectionRepository) =>
_collectionRepository = collectionRepository; _collectionRepository = collectionRepository;
public async Task<Either<BaseError, CollectionCardResultsViewModel>> Handle( public async Task<Either<BaseError, CollectionCardResultsViewModel>> Handle(
GetCollectionCards request, GetCollectionCards request,
CancellationToken cancellationToken) => CancellationToken cancellationToken) =>
(await _collectionRepository.GetWithItemsUntracked(request.Id)) (await _collectionRepository.GetCollectionWithItemsUntracked(request.Id))
.ToEither(BaseError.New("Unable to load collection")) .ToEither(BaseError.New("Unable to load collection"))
.Map(ProjectToViewModel); .Map(ProjectToViewModel);
} }

4
ErsatzTV.Core/Domain/PlayoutProgramScheduleAnchor.cs
Unescape View File

@ -7,12 +7,8 @@
public Playout Playout { get; set; } public Playout Playout { get; set; }
public int ProgramScheduleId { get; set; } public int ProgramScheduleId { get; set; }
public ProgramSchedule ProgramSchedule { get; set; } public ProgramSchedule ProgramSchedule { get; set; }
public ProgramScheduleItemCollectionType CollectionType { get; set; } public ProgramScheduleItemCollectionType CollectionType { get; set; }
// TODO: remove this
public int CollectionId { get; set; }
// TODO: rename this // TODO: rename this
public int? NewCollectionId { get; set; } public int? NewCollectionId { get; set; }
public Collection Collection { get; set; } public Collection Collection { get; set; }

11
ErsatzTV.Core/Interfaces/Repositories/ICollectionRepository.cs
Unescape View File

@ -1,11 +0,0 @@
using System.Threading.Tasks;
using ErsatzTV.Core.Domain;
using LanguageExt;
namespace ErsatzTV.Core.Interfaces.Repositories
{
public interface ICollectionRepository
{
public Task<Option<Collection>> GetWithItemsUntracked(int collectionId);
}
}

6
ErsatzTV.Core/Scheduling/PlayoutBuilder.cs
Unescape View File

@ -325,7 +325,7 @@ namespace ErsatzTV.Core.Scheduling
{ {
Option<PlayoutProgramScheduleAnchor> maybeExisting = playout.ProgramScheduleAnchors Option<PlayoutProgramScheduleAnchor> maybeExisting = playout.ProgramScheduleAnchors
.FirstOrDefault( .FirstOrDefault(
a => a.CollectionType == collectionKey.CollectionType && a.CollectionId == collectionKey.Id); a => a.CollectionType == collectionKey.CollectionType && a.NewCollectionId == collectionKey.Id);
var maybeEnumeratorState = collectionEnumerators.GroupBy(e => e.Key, e => e.Value.State) var maybeEnumeratorState = collectionEnumerators.GroupBy(e => e.Key, e => e.Value.State)
.ToDictionary(mcs => mcs.Key, mcs => mcs.Head()); .ToDictionary(mcs => mcs.Key, mcs => mcs.Head());
@ -343,7 +343,7 @@ namespace ErsatzTV.Core.Scheduling
ProgramSchedule = playout.ProgramSchedule, ProgramSchedule = playout.ProgramSchedule,
ProgramScheduleId = playout.ProgramScheduleId, ProgramScheduleId = playout.ProgramScheduleId,
CollectionType = collectionKey.CollectionType, CollectionType = collectionKey.CollectionType,
CollectionId = collectionKey.Id, NewCollectionId = collectionKey.Id,
EnumeratorState = maybeEnumeratorState[collectionKey] EnumeratorState = maybeEnumeratorState[collectionKey]
}); });
@ -362,7 +362,7 @@ namespace ErsatzTV.Core.Scheduling
.FirstOrDefault( .FirstOrDefault(
a => a.ProgramScheduleId == playout.ProgramScheduleId && a.CollectionType == a => a.ProgramScheduleId == playout.ProgramScheduleId && a.CollectionType ==
collectionKey.CollectionType collectionKey.CollectionType
&& a.CollectionId == collectionKey.Id); && a.NewCollectionId == collectionKey.Id);
CollectionEnumeratorState state = maybeAnchor.Match( CollectionEnumeratorState state = maybeAnchor.Match(
anchor => anchor.EnumeratorState, anchor => anchor.EnumeratorState,

1361
ErsatzTV.Infrastructure/Migrations/20210226183532_Remove_OldTelevisionEntities.Designer.cs generated
View File

File diff suppressed because it is too large Load Diff

489
ErsatzTV.Infrastructure/Migrations/20210226183532_Remove_OldTelevisionEntities.cs
Unescape View File

@ -0,0 +1,489 @@
using System;
using Microsoft.EntityFrameworkCore.Migrations;
namespace ErsatzTV.Infrastructure.Migrations
{
public partial class Remove_OldTelevisionEntities : Migration
{
protected override void Up(MigrationBuilder migrationBuilder)
{
migrationBuilder.Sql(
@"UPDATE ProgramScheduleItem SET
MediaCollectionId = null,
TelevisionSeasonId = null,
TelevisionShowId = null");
migrationBuilder.DropForeignKey(
"FK_ProgramScheduleItem_MediaCollection_MediaCollectionId",
"ProgramScheduleItem");
migrationBuilder.DropForeignKey(
"FK_ProgramScheduleItem_TelevisionSeason_TelevisionSeasonId",
"ProgramScheduleItem");
migrationBuilder.DropForeignKey(
"FK_ProgramScheduleItem_TelevisionShow_TelevisionShowId",
"ProgramScheduleItem");
migrationBuilder.DropTable(
"SimpleMediaCollectionEpisode");
migrationBuilder.DropTable(
"SimpleMediaCollectionMovie");
migrationBuilder.DropTable(
"SimpleMediaCollectionSeason");
migrationBuilder.DropTable(
"SimpleMediaCollectionShow");
migrationBuilder.DropTable(
"TelevisionEpisodeMetadata");
migrationBuilder.DropTable(
"TelevisionShowMetadata");
migrationBuilder.DropTable(
"TelevisionShowSource");
migrationBuilder.DropTable(
"SimpleMediaCollection");
migrationBuilder.DropTable(
"TelevisionEpisode");
migrationBuilder.DropTable(
"MediaCollection");
migrationBuilder.DropTable(
"TelevisionSeason");
migrationBuilder.DropTable(
"TelevisionShow");
migrationBuilder.DropIndex(
"IX_ProgramScheduleItem_MediaCollectionId",
"ProgramScheduleItem");
migrationBuilder.DropIndex(
"IX_ProgramScheduleItem_TelevisionSeasonId",
"ProgramScheduleItem");
migrationBuilder.DropIndex(
"IX_ProgramScheduleItem_TelevisionShowId",
"ProgramScheduleItem");
migrationBuilder.DropColumn(
"MediaCollectionId",
"ProgramScheduleItem");
migrationBuilder.DropColumn(
"TelevisionSeasonId",
"ProgramScheduleItem");
migrationBuilder.DropColumn(
"TelevisionShowId",
"ProgramScheduleItem");
migrationBuilder.DropColumn(
"CollectionId",
"PlayoutProgramScheduleAnchor");
}
protected override void Down(MigrationBuilder migrationBuilder)
{
migrationBuilder.AddColumn<int>(
"MediaCollectionId",
"ProgramScheduleItem",
"INTEGER",
nullable: true);
migrationBuilder.AddColumn<int>(
"TelevisionSeasonId",
"ProgramScheduleItem",
"INTEGER",
nullable: true);
migrationBuilder.AddColumn<int>(
"TelevisionShowId",
"ProgramScheduleItem",
"INTEGER",
nullable: true);
migrationBuilder.AddColumn<int>(
"CollectionId",
"PlayoutProgramScheduleAnchor",
"INTEGER",
nullable: false,
defaultValue: 0);
migrationBuilder.CreateTable(
"MediaCollection",
table => new
{
Id = table.Column<int>("INTEGER", nullable: false)
.Annotation("Sqlite:Autoincrement", true),
Name = table.Column<string>("TEXT", nullable: true)
},
constraints: table => { table.PrimaryKey("PK_MediaCollection", x => x.Id); });
migrationBuilder.CreateTable(
"TelevisionShow",
table => new
{
Id = table.Column<int>("INTEGER", nullable: false)
.Annotation("Sqlite:Autoincrement", true),
Poster = table.Column<string>("TEXT", nullable: true),
PosterLastWriteTime = table.Column<DateTime>("TEXT", nullable: true)
},
constraints: table => { table.PrimaryKey("PK_TelevisionShow", x => x.Id); });
migrationBuilder.CreateTable(
"SimpleMediaCollection",
table => new
{
Id = table.Column<int>("INTEGER", nullable: false)
.Annotation("Sqlite:Autoincrement", true)
},
constraints: table =>
{
table.PrimaryKey("PK_SimpleMediaCollection", x => x.Id);
table.ForeignKey(
"FK_SimpleMediaCollection_MediaCollection_Id",
x => x.Id,
"MediaCollection",
"Id",
onDelete: ReferentialAction.Cascade);
});
migrationBuilder.CreateTable(
"TelevisionSeason",
table => new
{
Id = table.Column<int>("INTEGER", nullable: false)
.Annotation("Sqlite:Autoincrement", true),
Number = table.Column<int>("INTEGER", nullable: false),
Path = table.Column<string>("TEXT", nullable: true),
Poster = table.Column<string>("TEXT", nullable: true),
PosterLastWriteTime = table.Column<DateTime>("TEXT", nullable: true),
TelevisionShowId = table.Column<int>("INTEGER", nullable: false)
},
constraints: table =>
{
table.PrimaryKey("PK_TelevisionSeason", x => x.Id);
table.ForeignKey(
"FK_TelevisionSeason_TelevisionShow_TelevisionShowId",
x => x.TelevisionShowId,
"TelevisionShow",
"Id",
onDelete: ReferentialAction.Cascade);
});
migrationBuilder.CreateTable(
"TelevisionShowMetadata",
table => new
{
Id = table.Column<int>("INTEGER", nullable: false)
.Annotation("Sqlite:Autoincrement", true),
LastWriteTime = table.Column<DateTime>("TEXT", nullable: true),
Plot = table.Column<string>("TEXT", nullable: true),
SortTitle = table.Column<string>("TEXT", nullable: true),
Source = table.Column<int>("INTEGER", nullable: false),
TelevisionShowId = table.Column<int>("INTEGER", nullable: false),
Title = table.Column<string>("TEXT", nullable: true),
Year = table.Column<int>("INTEGER", nullable: true)
},
constraints: table =>
{
table.PrimaryKey("PK_TelevisionShowMetadata", x => x.Id);
table.ForeignKey(
"FK_TelevisionShowMetadata_TelevisionShow_TelevisionShowId",
x => x.TelevisionShowId,
"TelevisionShow",
"Id",
onDelete: ReferentialAction.Cascade);
});
migrationBuilder.CreateTable(
"TelevisionShowSource",
table => new
{
Id = table.Column<int>("INTEGER", nullable: false)
.Annotation("Sqlite:Autoincrement", true),
Discriminator = table.Column<string>("TEXT", nullable: false),
TelevisionShowId = table.Column<int>("INTEGER", nullable: false),
MediaSourceId = table.Column<int>("INTEGER", nullable: true),
Path = table.Column<string>("TEXT", nullable: true)
},
constraints: table =>
{
table.PrimaryKey("PK_TelevisionShowSource", x => x.Id);
table.ForeignKey(
"FK_TelevisionShowSource_LocalMediaSource_MediaSourceId",
x => x.MediaSourceId,
"LocalMediaSource",
"Id",
onDelete: ReferentialAction.Cascade);
table.ForeignKey(
"FK_TelevisionShowSource_TelevisionShow_TelevisionShowId",
x => x.TelevisionShowId,
"TelevisionShow",
"Id",
onDelete: ReferentialAction.Cascade);
});
migrationBuilder.CreateTable(
"SimpleMediaCollectionMovie",
table => new
{
MoviesId = table.Column<int>("INTEGER", nullable: false),
SimpleMediaCollectionsId = table.Column<int>("INTEGER", nullable: false)
},
constraints: table =>
{
table.PrimaryKey(
"PK_SimpleMediaCollectionMovie",
x => new { x.MoviesId, x.SimpleMediaCollectionsId });
table.ForeignKey(
"FK_SimpleMediaCollectionMovie_Movie_MoviesId",
x => x.MoviesId,
"Movie",
"Id",
onDelete: ReferentialAction.Cascade);
table.ForeignKey(
"FK_SimpleMediaCollectionMovie_SimpleMediaCollection_SimpleMediaCollectionsId",
x => x.SimpleMediaCollectionsId,
"SimpleMediaCollection",
"Id",
onDelete: ReferentialAction.Cascade);
});
migrationBuilder.CreateTable(
"SimpleMediaCollectionShow",
table => new
{
SimpleMediaCollectionsId = table.Column<int>("INTEGER", nullable: false),
TelevisionShowsId = table.Column<int>("INTEGER", nullable: false)
},
constraints: table =>
{
table.PrimaryKey(
"PK_SimpleMediaCollectionShow",
x => new { x.SimpleMediaCollectionsId, x.TelevisionShowsId });
table.ForeignKey(
"FK_SimpleMediaCollectionShow_SimpleMediaCollection_SimpleMediaCollectionsId",
x => x.SimpleMediaCollectionsId,
"SimpleMediaCollection",
"Id",
onDelete: ReferentialAction.Cascade);
table.ForeignKey(
"FK_SimpleMediaCollectionShow_TelevisionShow_TelevisionShowsId",
x => x.TelevisionShowsId,
"TelevisionShow",
"Id",
onDelete: ReferentialAction.Cascade);
});
migrationBuilder.CreateTable(
"SimpleMediaCollectionSeason",
table => new
{
SimpleMediaCollectionsId = table.Column<int>("INTEGER", nullable: false),
TelevisionSeasonsId = table.Column<int>("INTEGER", nullable: false)
},
constraints: table =>
{
table.PrimaryKey(
"PK_SimpleMediaCollectionSeason",
x => new { x.SimpleMediaCollectionsId, x.TelevisionSeasonsId });
table.ForeignKey(
"FK_SimpleMediaCollectionSeason_SimpleMediaCollection_SimpleMediaCollectionsId",
x => x.SimpleMediaCollectionsId,
"SimpleMediaCollection",
"Id",
onDelete: ReferentialAction.Cascade);
table.ForeignKey(
"FK_SimpleMediaCollectionSeason_TelevisionSeason_TelevisionSeasonsId",
x => x.TelevisionSeasonsId,
"TelevisionSeason",
"Id",
onDelete: ReferentialAction.Cascade);
});
migrationBuilder.CreateTable(
"TelevisionEpisode",
table => new
{
Id = table.Column<int>("INTEGER", nullable: false)
.Annotation("Sqlite:Autoincrement", true),
SeasonId = table.Column<int>("INTEGER", nullable: false)
},
constraints: table =>
{
table.PrimaryKey("PK_TelevisionEpisode", x => x.Id);
table.ForeignKey(
"FK_TelevisionEpisode_MediaItem_Id",
x => x.Id,
"MediaItem",
"Id",
onDelete: ReferentialAction.Cascade);
table.ForeignKey(
"FK_TelevisionEpisode_TelevisionSeason_SeasonId",
x => x.SeasonId,
"TelevisionSeason",
"Id",
onDelete: ReferentialAction.Cascade);
});
migrationBuilder.CreateTable(
"SimpleMediaCollectionEpisode",
table => new
{
SimpleMediaCollectionsId = table.Column<int>("INTEGER", nullable: false),
TelevisionEpisodesId = table.Column<int>("INTEGER", nullable: false)
},
constraints: table =>
{
table.PrimaryKey(
"PK_SimpleMediaCollectionEpisode",
x => new { x.SimpleMediaCollectionsId, x.TelevisionEpisodesId });
table.ForeignKey(
"FK_SimpleMediaCollectionEpisode_SimpleMediaCollection_SimpleMediaCollectionsId",
x => x.SimpleMediaCollectionsId,
"SimpleMediaCollection",
"Id",
onDelete: ReferentialAction.Cascade);
table.ForeignKey(
"FK_SimpleMediaCollectionEpisode_TelevisionEpisode_TelevisionEpisodesId",
x => x.TelevisionEpisodesId,
"TelevisionEpisode",
"Id",
onDelete: ReferentialAction.Cascade);
});
migrationBuilder.CreateTable(
"TelevisionEpisodeMetadata",
table => new
{
Id = table.Column<int>("INTEGER", nullable: false)
.Annotation("Sqlite:Autoincrement", true),
Aired = table.Column<DateTime>("TEXT", nullable: true),
Episode = table.Column<int>("INTEGER", nullable: false),
LastWriteTime = table.Column<DateTime>("TEXT", nullable: true),
Plot = table.Column<string>("TEXT", nullable: true),
Season = table.Column<int>("INTEGER", nullable: false),
SortTitle = table.Column<string>("TEXT", nullable: true),
Source = table.Column<int>("INTEGER", nullable: false),
TelevisionEpisodeId = table.Column<int>("INTEGER", nullable: false),
Title = table.Column<string>("TEXT", nullable: true)
},
constraints: table =>
{
table.PrimaryKey("PK_TelevisionEpisodeMetadata", x => x.Id);
table.ForeignKey(
"FK_TelevisionEpisodeMetadata_TelevisionEpisode_TelevisionEpisodeId",
x => x.TelevisionEpisodeId,
"TelevisionEpisode",
"Id",
onDelete: ReferentialAction.Cascade);
});
migrationBuilder.CreateIndex(
"IX_ProgramScheduleItem_MediaCollectionId",
"ProgramScheduleItem",
"MediaCollectionId");
migrationBuilder.CreateIndex(
"IX_ProgramScheduleItem_TelevisionSeasonId",
"ProgramScheduleItem",
"TelevisionSeasonId");
migrationBuilder.CreateIndex(
"IX_ProgramScheduleItem_TelevisionShowId",
"ProgramScheduleItem",
"TelevisionShowId");
migrationBuilder.CreateIndex(
"IX_MediaCollection_Name",
"MediaCollection",
"Name",
unique: true);
migrationBuilder.CreateIndex(
"IX_SimpleMediaCollectionEpisode_TelevisionEpisodesId",
"SimpleMediaCollectionEpisode",
"TelevisionEpisodesId");
migrationBuilder.CreateIndex(
"IX_SimpleMediaCollectionMovie_SimpleMediaCollectionsId",
"SimpleMediaCollectionMovie",
"SimpleMediaCollectionsId");
migrationBuilder.CreateIndex(
"IX_SimpleMediaCollectionSeason_TelevisionSeasonsId",
"SimpleMediaCollectionSeason",
"TelevisionSeasonsId");
migrationBuilder.CreateIndex(
"IX_SimpleMediaCollectionShow_TelevisionShowsId",
"SimpleMediaCollectionShow",
"TelevisionShowsId");
migrationBuilder.CreateIndex(
"IX_TelevisionEpisode_SeasonId",
"TelevisionEpisode",
"SeasonId");
migrationBuilder.CreateIndex(
"IX_TelevisionEpisodeMetadata_TelevisionEpisodeId",
"TelevisionEpisodeMetadata",
"TelevisionEpisodeId",
unique: true);
migrationBuilder.CreateIndex(
"IX_TelevisionSeason_TelevisionShowId",
"TelevisionSeason",
"TelevisionShowId");
migrationBuilder.CreateIndex(
"IX_TelevisionShowMetadata_TelevisionShowId",
"TelevisionShowMetadata",
"TelevisionShowId",
unique: true);
migrationBuilder.CreateIndex(
"IX_TelevisionShowSource_MediaSourceId",
"TelevisionShowSource",
"MediaSourceId");
migrationBuilder.CreateIndex(
"IX_TelevisionShowSource_TelevisionShowId",
"TelevisionShowSource",
"TelevisionShowId");
migrationBuilder.AddForeignKey(
"FK_ProgramScheduleItem_MediaCollection_MediaCollectionId",
"ProgramScheduleItem",
"MediaCollectionId",
"MediaCollection",
principalColumn: "Id",
onDelete: ReferentialAction.Restrict);
migrationBuilder.AddForeignKey(
"FK_ProgramScheduleItem_TelevisionSeason_TelevisionSeasonId",
"ProgramScheduleItem",
"TelevisionSeasonId",
"TelevisionSeason",
principalColumn: "Id",
onDelete: ReferentialAction.Restrict);
migrationBuilder.AddForeignKey(
"FK_ProgramScheduleItem_TelevisionShow_TelevisionShowId",
"ProgramScheduleItem",
"TelevisionShowId",
"TelevisionShow",
principalColumn: "Id",
onDelete: ReferentialAction.Restrict);
}
}
}

834
ErsatzTV.Infrastructure/Migrations/TvContextModelSnapshot.cs
View File

File diff suppressed because it is too large Load Diff
Write Preview
Loading…
Cancel
Save