github/Ombi
1
0
Fork 0
mirror of https://github.com/Ombi-app/Ombi.git synced 2025-07-08 06:00:50 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions

additional cacher error handling + don't bother checking the requests when we don't get data back from plex

Browse source
This commit is contained in:
Drewster727 2016-04-21 09:00:06 -05:00
parent 076a75b82f
commit ba06e8630f
4 changed files with 60 additions and 24 deletions
Download patch file Download diff file Expand all files Collapse all files

13
PlexRequests.Services/Jobs/CouchPotatoCacher.cs
View file

@ -62,10 +62,17 @@ namespace PlexRequests.Services.Jobs
if (settings.Enabled) if (settings.Enabled)
{ {
Log.Trace("Getting all movies from CouchPotato"); Log.Trace("Getting all movies from CouchPotato");
var movies = CpApi.GetMovies(settings.FullUri, settings.ApiKey, new[] { "active" }); try
if (movies != null)
{ {
Cache.Set(CacheKeys.CouchPotatoQueued, movies, CacheKeys.TimeFrameMinutes.SchedulerCaching); var movies = CpApi.GetMovies(settings.FullUri, settings.ApiKey, new[] { "active" });
if (movies != null)
{
Cache.Set(CacheKeys.CouchPotatoQueued, movies, CacheKeys.TimeFrameMinutes.SchedulerCaching);
}
}
catch (System.Exception ex)
{
Log.Error(ex, "Failed caching queued items from CouchPotato");
} }
} }
} }

41
PlexRequests.Services/Jobs/PlexAvailabilityChecker.cs
View file

@ -75,6 +75,13 @@ namespace PlexRequests.Services.Jobs
} }
var libraries = CachedLibraries(authSettings, plexSettings, true); //force setting the cache (10 min intervals via scheduler) var libraries = CachedLibraries(authSettings, plexSettings, true); //force setting the cache (10 min intervals via scheduler)
if (libraries == null || !libraries.Any())
{
Log.Info("Did not find any libraries in Plex.");
return;
}
var movies = GetPlexMovies().ToArray(); var movies = GetPlexMovies().ToArray();
var shows = GetPlexTvShows().ToArray(); var shows = GetPlexTvShows().ToArray();
var albums = GetPlexAlbums().ToArray(); var albums = GetPlexAlbums().ToArray();
@ -248,25 +255,33 @@ namespace PlexRequests.Services.Jobs
return results; // don't error out here, just let it go! return results; // don't error out here, just let it go!
} }
if (setCache) try
{ {
Log.Trace("Plex Lib API Call"); if (setCache)
results = GetLibraries(authSettings, plexSettings);
Log.Trace("Plex Lib Cache Set Call");
if (results != null)
{ {
Cache.Set(CacheKeys.PlexLibaries, results, CacheKeys.TimeFrameMinutes.SchedulerCaching); Log.Trace("Plex Lib API Call");
results = GetLibraries(authSettings, plexSettings);
Log.Trace("Plex Lib Cache Set Call");
if (results != null)
{
Cache.Set(CacheKeys.PlexLibaries, results, CacheKeys.TimeFrameMinutes.SchedulerCaching);
}
}
else
{
Log.Trace("Plex Lib GetSet Call");
results = Cache.GetOrSet(CacheKeys.PlexLibaries, () => {
Log.Trace("Plex Lib API Call (inside getset)");
return GetLibraries(authSettings, plexSettings);
}, CacheKeys.TimeFrameMinutes.SchedulerCaching);
} }
} }
else catch (Exception ex)
{ {
Log.Trace("Plex Lib GetSet Call"); Log.Error(ex, "Failed to obtain Plex libraries");
results = Cache.GetOrSet(CacheKeys.PlexLibaries, () => {
Log.Trace("Plex Lib API Call (inside getset)");
return GetLibraries(authSettings, plexSettings);
}, CacheKeys.TimeFrameMinutes.SchedulerCaching);
} }
return results; return results;
} }

13
PlexRequests.Services/Jobs/SickRageCacher.cs
View file

@ -62,10 +62,17 @@ namespace PlexRequests.Services.Jobs
if (settings.Enabled) if (settings.Enabled)
{ {
Log.Trace("Getting all shows from SickRage"); Log.Trace("Getting all shows from SickRage");
var shows = SrApi.GetShows(settings.ApiKey, settings.FullUri); try
if (shows != null)
{ {
Cache.Set(CacheKeys.SickRageQueued, shows.Result, CacheKeys.TimeFrameMinutes.SchedulerCaching); var shows = SrApi.GetShows(settings.ApiKey, settings.FullUri);
if (shows != null)
{
Cache.Set(CacheKeys.SickRageQueued, shows.Result, CacheKeys.TimeFrameMinutes.SchedulerCaching);
}
}
catch (System.Exception ex)
{
Log.Error(ex, "Failed caching queued items from SickRage");
} }
} }
} }

13
PlexRequests.Services/Jobs/SonarrCacher.cs
View file

@ -63,10 +63,17 @@ namespace PlexRequests.Services.Jobs
if (settings.Enabled) if (settings.Enabled)
{ {
Log.Trace("Getting all tv series from Sonarr"); Log.Trace("Getting all tv series from Sonarr");
var series = SonarrApi.GetSeries(settings.ApiKey, settings.FullUri); try
if (series != null)
{ {
Cache.Set(CacheKeys.SonarrQueued, series, CacheKeys.TimeFrameMinutes.SchedulerCaching); var series = SonarrApi.GetSeries(settings.ApiKey, settings.FullUri);
if (series != null)
{
Cache.Set(CacheKeys.SonarrQueued, series, CacheKeys.TimeFrameMinutes.SchedulerCaching);
}
}
catch (System.Exception ex)
{
Log.Error(ex, "Failed caching queued items from Sonarr");
} }
} }
} }