jellyfin/MediaBrowser.Providers/TV/DummySeasonProvider.cs

210 lines
7.6 KiB
C#
Raw Normal View History

using System.Collections.Generic;
2015-01-14 04:20:30 +00:00
using System.Globalization;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using MediaBrowser.Controller.Configuration;
using MediaBrowser.Controller.Entities.TV;
using MediaBrowser.Controller.Library;
using MediaBrowser.Controller.Providers;
using MediaBrowser.Model.Entities;
2016-10-24 02:45:23 +00:00
using MediaBrowser.Model.Globalization;
using MediaBrowser.Model.IO;
using Microsoft.Extensions.Logging;
2015-01-14 04:20:30 +00:00
namespace MediaBrowser.Providers.TV
{
public class DummySeasonProvider
{
private readonly IServerConfigurationManager _config;
private readonly ILogger _logger;
private readonly ILocalizationManager _localization;
2015-01-17 18:15:09 +00:00
private readonly ILibraryManager _libraryManager;
2015-09-13 23:07:54 +00:00
private readonly IFileSystem _fileSystem;
2015-01-14 04:20:30 +00:00
private readonly CultureInfo _usCulture = new CultureInfo("en-US");
2015-09-13 23:07:54 +00:00
public DummySeasonProvider(IServerConfigurationManager config, ILogger logger, ILocalizationManager localization, ILibraryManager libraryManager, IFileSystem fileSystem)
2015-01-14 04:20:30 +00:00
{
_config = config;
_logger = logger;
_localization = localization;
2015-01-17 18:15:09 +00:00
_libraryManager = libraryManager;
2015-09-13 23:07:54 +00:00
_fileSystem = fileSystem;
2015-01-14 04:20:30 +00:00
}
2018-09-12 17:26:21 +00:00
public async Task<bool> Run(Series series, CancellationToken cancellationToken)
2015-01-14 04:20:30 +00:00
{
2018-09-12 17:26:21 +00:00
var seasonsRemoved = RemoveObsoleteSeasons(series);
2015-01-14 04:20:30 +00:00
var hasNewSeasons = await AddDummySeasonFolders(series, cancellationToken).ConfigureAwait(false);
if (hasNewSeasons)
{
//var directoryService = new DirectoryService(_fileSystem);
2015-01-14 04:20:30 +00:00
//await series.RefreshMetadata(new MetadataRefreshOptions(directoryService), cancellationToken).ConfigureAwait(false);
2017-06-23 16:04:45 +00:00
//await series.ValidateChildren(new SimpleProgress<double>(), cancellationToken, new MetadataRefreshOptions(directoryService))
2015-01-14 04:20:30 +00:00
// .ConfigureAwait(false);
}
2018-09-12 17:26:21 +00:00
return seasonsRemoved || hasNewSeasons;
2015-01-14 04:20:30 +00:00
}
private async Task<bool> AddDummySeasonFolders(Series series, CancellationToken cancellationToken)
{
2017-04-27 18:12:44 +00:00
var episodesInSeriesFolder = series.GetRecursiveChildren(i => i is Episode)
.Cast<Episode>()
2015-01-14 04:20:30 +00:00
.Where(i => !i.IsInSeasonFolder)
.ToList();
var hasChanges = false;
2018-09-12 17:26:21 +00:00
List<Season> seasons = null;
2015-01-14 04:20:30 +00:00
// Loop through the unique season numbers
foreach (var seasonNumber in episodesInSeriesFolder.Select(i => i.ParentIndexNumber ?? -1)
.Where(i => i >= 0)
.Distinct()
.ToList())
{
2018-09-12 17:26:21 +00:00
if (seasons == null)
{
seasons = series.Children.OfType<Season>().ToList();
}
var existingSeason = seasons
2017-01-14 03:48:25 +00:00
.FirstOrDefault(i => i.IndexNumber.HasValue && i.IndexNumber.Value == seasonNumber);
2015-01-14 04:20:30 +00:00
2017-01-14 03:48:25 +00:00
if (existingSeason == null)
2015-01-14 04:20:30 +00:00
{
2016-05-20 19:45:04 +00:00
await AddSeason(series, seasonNumber, false, cancellationToken).ConfigureAwait(false);
2015-01-14 04:20:30 +00:00
hasChanges = true;
2018-09-12 17:26:21 +00:00
seasons = null;
2015-01-14 04:20:30 +00:00
}
2017-01-14 03:48:25 +00:00
else if (existingSeason.IsVirtualItem)
{
existingSeason.IsVirtualItem = false;
2017-10-03 18:39:37 +00:00
existingSeason.UpdateToRepository(ItemUpdateType.MetadataEdit, cancellationToken);
2018-09-12 17:26:21 +00:00
seasons = null;
2017-01-14 03:48:25 +00:00
}
2015-01-14 04:20:30 +00:00
}
// Unknown season - create a dummy season to put these under
if (episodesInSeriesFolder.Any(i => !i.ParentIndexNumber.HasValue))
{
2018-09-12 17:26:21 +00:00
if (seasons == null)
{
seasons = series.Children.OfType<Season>().ToList();
}
var existingSeason = seasons
2017-01-14 03:48:25 +00:00
.FirstOrDefault(i => !i.IndexNumber.HasValue);
2015-01-14 04:20:30 +00:00
2017-01-14 03:48:25 +00:00
if (existingSeason == null)
2015-01-14 04:20:30 +00:00
{
2016-05-20 19:45:04 +00:00
await AddSeason(series, null, false, cancellationToken).ConfigureAwait(false);
2015-01-14 04:20:30 +00:00
hasChanges = true;
2018-09-12 17:26:21 +00:00
seasons = null;
2015-01-14 04:20:30 +00:00
}
2017-01-14 03:48:25 +00:00
else if (existingSeason.IsVirtualItem)
{
existingSeason.IsVirtualItem = false;
2017-10-03 18:39:37 +00:00
existingSeason.UpdateToRepository(ItemUpdateType.MetadataEdit, cancellationToken);
2018-09-12 17:26:21 +00:00
seasons = null;
2017-01-14 03:48:25 +00:00
}
2015-01-14 04:20:30 +00:00
}
return hasChanges;
}
/// <summary>
/// Adds the season.
/// </summary>
public async Task<Season> AddSeason(Series series,
int? seasonNumber,
2016-05-20 21:32:43 +00:00
bool isVirtualItem,
2015-01-14 04:20:30 +00:00
CancellationToken cancellationToken)
{
var seasonName = seasonNumber == 0 ?
_libraryManager.GetLibraryOptions(series).SeasonZeroDisplayName :
2015-01-14 04:20:30 +00:00
(seasonNumber.HasValue ? string.Format(_localization.GetLocalizedString("NameSeasonNumber"), seasonNumber.Value.ToString(_usCulture)) : _localization.GetLocalizedString("NameSeasonUnknown"));
_logger.LogInformation("Creating Season {0} entry for {1}", seasonName, series.Name);
2015-01-14 04:20:30 +00:00
var season = new Season
{
Name = seasonName,
IndexNumber = seasonNumber,
2016-05-20 19:45:04 +00:00
Id = _libraryManager.GetNewItemId((series.Id + (seasonNumber ?? -1).ToString(_usCulture) + seasonName), typeof(Season)),
2016-07-09 17:39:04 +00:00
IsVirtualItem = isVirtualItem,
2016-08-19 17:43:16 +00:00
SeriesId = series.Id,
2017-05-05 17:55:38 +00:00
SeriesName = series.Name
2015-01-14 04:20:30 +00:00
};
2015-07-09 05:52:25 +00:00
season.SetParent(series);
series.AddChild(season, cancellationToken);
2015-01-14 04:20:30 +00:00
await season.RefreshMetadata(new MetadataRefreshOptions(new DirectoryService(_logger, _fileSystem)), cancellationToken).ConfigureAwait(false);
2015-01-14 04:20:30 +00:00
return season;
}
2015-01-17 18:15:09 +00:00
2018-09-12 17:26:21 +00:00
private bool RemoveObsoleteSeasons(Series series)
2015-01-17 18:15:09 +00:00
{
var existingSeasons = series.Children.OfType<Season>().ToList();
var physicalSeasons = existingSeasons
.Where(i => i.LocationType != LocationType.Virtual)
.ToList();
var virtualSeasons = existingSeasons
.Where(i => i.LocationType == LocationType.Virtual)
.ToList();
var seasonsToRemove = virtualSeasons
.Where(i =>
{
if (i.IndexNumber.HasValue)
{
var seasonNumber = i.IndexNumber.Value;
// If there's a physical season with the same number, delete it
if (physicalSeasons.Any(p => p.IndexNumber.HasValue && (p.IndexNumber.Value == seasonNumber)))
{
return true;
}
2016-09-03 18:18:59 +00:00
}
2015-01-17 18:15:09 +00:00
2016-09-03 18:18:59 +00:00
// If there are no episodes with this season number, delete it
if (!i.GetEpisodes().Any())
{
return true;
2015-01-17 18:15:09 +00:00
}
2016-09-03 18:18:59 +00:00
return false;
2015-01-17 18:15:09 +00:00
})
.ToList();
var hasChanges = false;
foreach (var seasonToRemove in seasonsToRemove)
{
_logger.LogInformation("Removing virtual season {0} {1}", series.Name, seasonToRemove.IndexNumber);
2015-01-17 18:15:09 +00:00
2018-09-12 17:26:21 +00:00
_libraryManager.DeleteItem(seasonToRemove, new DeleteOptions
2016-02-12 04:54:00 +00:00
{
DeleteFileLocation = true
2018-09-12 17:26:21 +00:00
}, false);
2015-01-17 18:15:09 +00:00
hasChanges = true;
}
return hasChanges;
}
2015-01-14 04:20:30 +00:00
}
}