shpaq/Jackett-Jackett
1
0
Fork 0
mirror of https://github.com/Jackett/Jackett.git synced 2025-09-17 17:34:09 +02:00
Code Issues Packages Projects Releases Wiki Activity

RARBG API request throttling

Browse Source
This commit is contained in:
unknown
2015-08-22 15:21:29 -06:00
parent 28bc720ab3
commit 674be2843d
1 changed files with 16 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/Jackett/Indexers/Rarbg.cs
View File

@@ -107,7 +107,12 @@ namespace Jackett.Indexers
return IndexerConfigurationStatus.Completed; return IndexerConfigurationStatus.Completed;
} }
public async Task<IEnumerable<ReleaseInfo>> PerformQuery(TorznabQuery query) public Task<IEnumerable<ReleaseInfo>> PerformQuery(TorznabQuery query)
{
return PerformQuery(query, 0);
}
public async Task<IEnumerable<ReleaseInfo>> PerformQuery(TorznabQuery query, int attempts = 0)
{ {
await CheckToken(); await CheckToken();
var releases = new List<ReleaseInfo>(); var releases = new List<ReleaseInfo>();
@@ -120,6 +125,7 @@ namespace Jackett.Indexers
{ {
episodeSearchUrl += "&category=" + cats; episodeSearchUrl += "&category=" + cats;
} }
var response = await RequestStringWithCookiesAndRetry(episodeSearchUrl, string.Empty); var response = await RequestStringWithCookiesAndRetry(episodeSearchUrl, string.Empty);
try try
@@ -133,9 +139,17 @@ namespace Jackett.Indexers
} }
if (errorCode > 0) // too many requests per second if (errorCode > 0) // too many requests per second
{
if (attempts < 3)
{
await Task.Delay(TimeSpan.FromSeconds(2));
return await PerformQuery(query, ++attempts);
}
else
{ {
throw new Exception(jsonContent.Value<string>("error")); throw new Exception(jsonContent.Value<string>("error"));
} }
}
foreach (var item in jsonContent.Value<JArray>("torrent_results")) foreach (var item in jsonContent.Value<JArray>("torrent_results"))
{ {