lgladsden/jellyfin-server
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

limit rotten tomatoes requests

Browse Source
This commit is contained in:
Luke Pulverenti 2013-05-06 09:21:11 -04:00
parent 716151c9e4
commit 72414c0410
1 changed files with 23 additions and 68 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

81
MediaBrowser.Controller/Providers/Movies/RottenTomatoesMovieProvider.cs
View File

@ -34,7 +34,7 @@ namespace MediaBrowser.Controller.Providers.Movies
/// <summary> /// <summary>
/// The _rotten tomatoes resource pool /// The _rotten tomatoes resource pool
/// </summary> /// </summary>
private readonly SemaphoreSlim _rottenTomatoesResourcePool = new SemaphoreSlim(2, 2); private readonly SemaphoreSlim _rottenTomatoesResourcePool = new SemaphoreSlim(1, 1);
/// <summary> /// <summary>
/// Gets the json serializer. /// Gets the json serializer.
@ -105,7 +105,7 @@ namespace MediaBrowser.Controller.Providers.Movies
/// <returns><c>true</c> if XXXX, <c>false</c> otherwise</returns> /// <returns><c>true</c> if XXXX, <c>false</c> otherwise</returns>
public override bool Supports(BaseItem item) public override bool Supports(BaseItem item)
{ {
return item is Movie; return item is Movie || item is Trailer;
} }
/// <summary> /// <summary>
@ -155,73 +155,29 @@ namespace MediaBrowser.Controller.Providers.Movies
/// <param name="force">if set to <c>true</c> [force].</param> /// <param name="force">if set to <c>true</c> [force].</param>
/// <param name="cancellationToken">The cancellation token.</param> /// <param name="cancellationToken">The cancellation token.</param>
/// <returns>Task{System.Boolean}.</returns> /// <returns>Task{System.Boolean}.</returns>
public override Task<bool> FetchAsync(BaseItem item, bool force, CancellationToken cancellationToken) public override async Task<bool> FetchAsync(BaseItem item, bool force, CancellationToken cancellationToken)
{ {
BaseProviderInfo data; BaseProviderInfo data;
// See whether there's an IMDB Id available if (!item.ProviderData.TryGetValue(Id, out data))
string imdbId = null;
if (item.ProviderData.TryGetValue(Id, out data))
{ {
imdbId = item.GetProviderId(MetadataProviders.Imdb); data = new BaseProviderInfo();
item.ProviderData[Id] = data;
}
var imdbId = item.GetProviderId(MetadataProviders.Imdb);
if (string.IsNullOrEmpty(imdbId))
{
data.Data = GetComparisonData(imdbId);
data.LastRefreshStatus = ProviderRefreshStatus.Success;
return true;
} }
RTMovieSearchResult hit = null; RTMovieSearchResult hit = null;
if (string.IsNullOrEmpty(imdbId))
{
// No IMDB Id, search RT for an ID
var page = 1;
using (var stream = HttpClient.Get(MovieSearchUrl(item.Name, page), _rottenTomatoesResourcePool, cancellationToken).Result)
{
var result = JsonSerializer.DeserializeFromStream<RTSearchResults>(stream);
if (result.total == 1)
{
// With only one result we'll have to assume that this is the movie we're searching for
hit = result.movies[0];
}
else if (result.total > 1)
{
// If there are more results than one
// Step 1: Loop through all current results, see if there's an exact match (not case sensitive) somewhere, if so, accept that as the searched item, else go to step 2
// Step 2: Retrieve the next page and go to step 1 if there are results, else, stop checking
while (hit == null)
{
foreach (var searchHit in result.movies)
{
if (string.Equals(searchHit.title, item.Name, StringComparison.InvariantCultureIgnoreCase))
{
hit = searchHit;
break;
}
}
if (hit == null)
{
using (var newPageStream = HttpClient.Get(MovieSearchUrl(item.Name, page++), _rottenTomatoesResourcePool, cancellationToken).Result)
{
result = JsonSerializer.DeserializeFromStream<RTSearchResults>(newPageStream);
if (result.total == 0)
{
// No results found on RottenTomatoes
break;
}
}
}
// while end
}
}
}
// if null end
}
else
{
// Have IMDB Id // Have IMDB Id
using (var stream = HttpClient.Get(MovieImdbUrl(imdbId), _rottenTomatoesResourcePool, cancellationToken).Result) using (var stream = await HttpClient.Get(MovieImdbUrl(imdbId), _rottenTomatoesResourcePool, cancellationToken).ConfigureAwait(false))
{ {
var result = JsonSerializer.DeserializeFromStream<RTMovieSearchResult>(stream); var result = JsonSerializer.DeserializeFromStream<RTMovieSearchResult>(stream);
@ -231,7 +187,6 @@ namespace MediaBrowser.Controller.Providers.Movies
hit = result; hit = result;
} }
} }
}
// If we found any results, that's great! // If we found any results, that's great!
if (hit != null) if (hit != null)
@ -239,7 +194,7 @@ namespace MediaBrowser.Controller.Providers.Movies
item.CriticRatingSummary = hit.critics_consensus; item.CriticRatingSummary = hit.critics_consensus;
item.CriticRating = float.Parse(hit.ratings.critics_score); item.CriticRating = float.Parse(hit.ratings.critics_score);
using (var stream = HttpClient.Get(MovieReviewsUrl(hit.id), _rottenTomatoesResourcePool, cancellationToken).Result) using (var stream = await HttpClient.Get(MovieReviewsUrl(hit.id), _rottenTomatoesResourcePool, cancellationToken).ConfigureAwait(false))
{ {
var result = JsonSerializer.DeserializeFromStream<RTReviewList>(stream); var result = JsonSerializer.DeserializeFromStream<RTReviewList>(stream);
@ -282,7 +237,7 @@ namespace MediaBrowser.Controller.Providers.Movies
SetLastRefreshed(item, DateTime.UtcNow); SetLastRefreshed(item, DateTime.UtcNow);
return Task.FromResult(true); return true;
} }
// Utility functions to get the URL of the API calls // Utility functions to get the URL of the API calls