|
|
|
@ -48,8 +48,9 @@ namespace Ombi.Schedule.Jobs.Plex
|
|
|
|
|
foreach (var server in s.Servers)
|
|
|
|
|
{
|
|
|
|
|
await Cache(server);
|
|
|
|
|
BackgroundJob.Enqueue(() => _availabilityChecker.Start());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
BackgroundJob.Enqueue(() => _availabilityChecker.Start());
|
|
|
|
|
}
|
|
|
|
|
catch (Exception e)
|
|
|
|
|
{
|
|
|
|
@ -127,6 +128,9 @@ namespace Ombi.Schedule.Jobs.Plex
|
|
|
|
|
private async Task ProcessEpsiodes(PlexContainer episodes)
|
|
|
|
|
{
|
|
|
|
|
var ep = new HashSet<PlexEpisode>();
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
foreach (var episode in episodes?.MediaContainer?.Metadata ?? new Metadata[]{})
|
|
|
|
|
{
|
|
|
|
@ -142,6 +146,25 @@ namespace Ombi.Schedule.Jobs.Plex
|
|
|
|
|
// continue;
|
|
|
|
|
//}
|
|
|
|
|
|
|
|
|
|
// Let's check if we have the parent
|
|
|
|
|
var seriesExists = await _repo.GetByKey(episode.grandparentRatingKey);
|
|
|
|
|
if (seriesExists == null)
|
|
|
|
|
{
|
|
|
|
|
// Ok let's try and match it to a title. TODO (This is experimental)
|
|
|
|
|
var seriesMatch = await _repo.GetAll().FirstOrDefaultAsync(x =>
|
|
|
|
|
x.Title.Equals(episode.grandparentTitle, StringComparison.CurrentCultureIgnoreCase));
|
|
|
|
|
if (seriesMatch == null)
|
|
|
|
|
{
|
|
|
|
|
_log.LogWarning(
|
|
|
|
|
"The episode title {0} we cannot find the parent series. The episode grandparentKey = {1}, grandparentTitle = {2}",
|
|
|
|
|
episode.title, episode.grandparentRatingKey, episode.grandparentTitle);
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// Set the rating key to the correct one
|
|
|
|
|
episode.grandparentRatingKey = seriesMatch.Key;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
ep.Add(new PlexEpisode
|
|
|
|
|
{
|
|
|
|
|
EpisodeNumber = episode.index,
|
|
|
|
@ -155,6 +178,12 @@ namespace Ombi.Schedule.Jobs.Plex
|
|
|
|
|
|
|
|
|
|
await _repo.AddRange(ep);
|
|
|
|
|
}
|
|
|
|
|
catch (Exception e)
|
|
|
|
|
{
|
|
|
|
|
Console.WriteLine(e);
|
|
|
|
|
throw;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private bool Validate(PlexServers settings)
|
|
|
|
|
{
|
|
|
|
|