mirror of
https://github.com/jellyfin/jellyfin.git
synced 2024-09-07 11:57:55 +02:00
151 lines
5.6 KiB
C#
151 lines
5.6 KiB
C#
using System;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
using MediaBrowser.Controller.Library;
|
|
using Microsoft.Extensions.Caching.Memory;
|
|
using TvDbSharper;
|
|
using TvDbSharper.Dto;
|
|
|
|
namespace MediaBrowser.Providers.TV
|
|
{
|
|
// TODO add to DI once Bond's PR is merged
|
|
public sealed class TvDbClientManager
|
|
{
|
|
private static volatile TvDbClientManager instance;
|
|
// TODO add to DI once Bond's PR is merged
|
|
private readonly SemaphoreSlim _cacheWriteLock = new SemaphoreSlim(1, 1);
|
|
private static MemoryCache _cache;
|
|
private static readonly object syncRoot = new object();
|
|
private static TvDbClient tvDbClient;
|
|
private static DateTime tokenCreatedAt;
|
|
|
|
private TvDbClientManager()
|
|
{
|
|
tvDbClient = new TvDbClient();
|
|
tvDbClient.Authentication.AuthenticateAsync(TVUtils.TvdbApiKey);
|
|
tokenCreatedAt = DateTime.Now;
|
|
}
|
|
|
|
public static TvDbClientManager Instance
|
|
{
|
|
get
|
|
{
|
|
if (instance != null)
|
|
{
|
|
return instance;
|
|
}
|
|
|
|
lock (syncRoot)
|
|
{
|
|
if (instance == null)
|
|
{
|
|
instance = new TvDbClientManager();
|
|
_cache = new MemoryCache(new MemoryCacheOptions());
|
|
}
|
|
}
|
|
|
|
return instance;
|
|
}
|
|
}
|
|
|
|
public TvDbClient TvDbClient
|
|
{
|
|
get
|
|
{
|
|
// Refresh if necessary
|
|
if (tokenCreatedAt > DateTime.Now.Subtract(TimeSpan.FromHours(20)))
|
|
{
|
|
try
|
|
{
|
|
tvDbClient.Authentication.RefreshTokenAsync();
|
|
}
|
|
catch
|
|
{
|
|
tvDbClient.Authentication.AuthenticateAsync(TVUtils.TvdbApiKey);
|
|
}
|
|
|
|
tokenCreatedAt = DateTime.Now;
|
|
}
|
|
// Default to English
|
|
tvDbClient.AcceptedLanguage = "en";
|
|
return tvDbClient;
|
|
}
|
|
}
|
|
|
|
public Task<TvDbResponse<SeriesSearchResult[]>> GetSeriesByNameAsync(string name, CancellationToken cancellationToken)
|
|
{
|
|
return TryGetValue("series" + name,() => TvDbClient.Search.SearchSeriesByNameAsync(name, cancellationToken));
|
|
}
|
|
|
|
public Task<TvDbResponse<Series>> GetSeriesByIdAsync(int tvdbId, CancellationToken cancellationToken)
|
|
{
|
|
return TryGetValue("series" + tvdbId,() => TvDbClient.Series.GetAsync(tvdbId, cancellationToken));
|
|
}
|
|
|
|
public Task<TvDbResponse<EpisodeRecord>> GetEpisodesAsync(int episodeTvdbId, CancellationToken cancellationToken)
|
|
{
|
|
return TryGetValue("episode" + episodeTvdbId,() => TvDbClient.Episodes.GetAsync(episodeTvdbId, cancellationToken));
|
|
}
|
|
|
|
public Task<TvDbResponse<SeriesSearchResult[]>> GetSeriesByImdbIdAsync(string imdbId, CancellationToken cancellationToken)
|
|
{
|
|
return TryGetValue("series" + imdbId,() => TvDbClient.Search.SearchSeriesByImdbIdAsync(imdbId, cancellationToken));
|
|
}
|
|
|
|
public Task<TvDbResponse<SeriesSearchResult[]>> GetSeriesByZap2ItIdAsync(string zap2ItId, CancellationToken cancellationToken)
|
|
{
|
|
return TryGetValue("series" + zap2ItId,() => TvDbClient.Search.SearchSeriesByZap2ItIdAsync(zap2ItId, cancellationToken));
|
|
}
|
|
public Task<TvDbResponse<Actor[]>> GetActorsAsync(int tvdbId, CancellationToken cancellationToken)
|
|
{
|
|
return TryGetValue("actors" + tvdbId,() => TvDbClient.Series.GetActorsAsync(tvdbId, cancellationToken));
|
|
}
|
|
|
|
public Task<TvDbResponse<Image[]>> GetImagesAsync(int tvdbId, ImagesQuery imageQuery, CancellationToken cancellationToken)
|
|
{
|
|
return TryGetValue("images" + tvdbId,() => TvDbClient.Series.GetImagesAsync(tvdbId, imageQuery, cancellationToken));
|
|
}
|
|
|
|
public Task<TvDbResponse<Language[]>> GetLanguagesAsync(CancellationToken cancellationToken)
|
|
{
|
|
return TryGetValue("languages",() => TvDbClient.Languages.GetAllAsync(cancellationToken));
|
|
}
|
|
|
|
public Task<TvDbResponse<EpisodesSummary>> GetSeriesEpisodeSummaryAsync(int tvdbId, CancellationToken cancellationToken)
|
|
{
|
|
return TryGetValue("seriesepisodesummary" + tvdbId,
|
|
() => TvDbClient.Series.GetEpisodesSummaryAsync(tvdbId, cancellationToken));
|
|
}
|
|
|
|
public Task<TvDbResponse<EpisodeRecord[]>> GetEpisodesPageAsync(int tvdbId, EpisodeQuery episodeQuery, CancellationToken cancellationToken)
|
|
{
|
|
return TryGetValue("episodespage" + tvdbId + episodeQuery.AiredSeason,
|
|
() => TvDbClient.Series.GetEpisodesAsync(tvdbId, 1, episodeQuery, cancellationToken));
|
|
}
|
|
|
|
private async Task<T> TryGetValue<T>(object key, Func<Task<T>> resultFactory)
|
|
{
|
|
if (_cache.TryGetValue(key, out T cachedValue))
|
|
{
|
|
return cachedValue;
|
|
}
|
|
|
|
await _cacheWriteLock.WaitAsync().ConfigureAwait(false);
|
|
try
|
|
{
|
|
if (_cache.TryGetValue(key, out cachedValue))
|
|
{
|
|
return cachedValue;
|
|
}
|
|
|
|
var result = await resultFactory.Invoke();
|
|
_cache.Set(key, result, TimeSpan.FromHours(1));
|
|
return result;
|
|
}
|
|
finally
|
|
{
|
|
_cacheWriteLock.Release();
|
|
}
|
|
}
|
|
}
|
|
}
|