mirror of
https://github.com/Prowlarr/Prowlarr
synced 2026-05-08 12:43:19 +02:00
Check for disabled till value in filtering blocked providers
This commit is contained in:
parent
222dfb1821
commit
8e69415d64
5 changed files with 5 additions and 5 deletions
|
|
@ -53,7 +53,7 @@ private IEnumerable<IApplication> FilterBlockedApplications(IEnumerable<IApplica
|
||||||
|
|
||||||
foreach (var application in applications)
|
foreach (var application in applications)
|
||||||
{
|
{
|
||||||
if (blockedApplications.TryGetValue(application.Definition.Id, out var blockedApplicationStatus))
|
if (blockedApplications.TryGetValue(application.Definition.Id, out var blockedApplicationStatus) && blockedApplicationStatus.DisabledTill.HasValue)
|
||||||
{
|
{
|
||||||
_logger.Debug("Temporarily ignoring application {0} till {1} due to recent failures.", application.Definition.Name, blockedApplicationStatus.DisabledTill.Value.ToLocalTime());
|
_logger.Debug("Temporarily ignoring application {0} till {1} due to recent failures.", application.Definition.Name, blockedApplicationStatus.DisabledTill.Value.ToLocalTime());
|
||||||
continue;
|
continue;
|
||||||
|
|
|
||||||
|
|
@ -61,7 +61,7 @@ private IEnumerable<IDownloadClient> FilterBlockedClients(IEnumerable<IDownloadC
|
||||||
|
|
||||||
foreach (var client in clients)
|
foreach (var client in clients)
|
||||||
{
|
{
|
||||||
if (blockedClients.TryGetValue(client.Definition.Id, out var downloadClientStatus))
|
if (blockedClients.TryGetValue(client.Definition.Id, out var downloadClientStatus) && downloadClientStatus.DisabledTill.HasValue)
|
||||||
{
|
{
|
||||||
_logger.Debug("Temporarily ignoring download client {0} till {1} due to recent failures.", client.Definition.Name, downloadClientStatus.DisabledTill.Value.ToLocalTime());
|
_logger.Debug("Temporarily ignoring download client {0} till {1} due to recent failures.", client.Definition.Name, downloadClientStatus.DisabledTill.Value.ToLocalTime());
|
||||||
continue;
|
continue;
|
||||||
|
|
|
||||||
|
|
@ -242,7 +242,7 @@ private IEnumerable<IIndexer> FilterBlockedIndexers(IEnumerable<IIndexer> indexe
|
||||||
|
|
||||||
foreach (var indexer in indexers)
|
foreach (var indexer in indexers)
|
||||||
{
|
{
|
||||||
if (blockedIndexers.TryGetValue(indexer.Definition.Id, out var blockedIndexerStatus))
|
if (blockedIndexers.TryGetValue(indexer.Definition.Id, out var blockedIndexerStatus) && blockedIndexerStatus.DisabledTill.HasValue)
|
||||||
{
|
{
|
||||||
_logger.Debug("Temporarily ignoring indexer {0} till {1} due to recent failures.", indexer.Definition.Name, blockedIndexerStatus.DisabledTill.Value.ToLocalTime());
|
_logger.Debug("Temporarily ignoring indexer {0} till {1} due to recent failures.", indexer.Definition.Name, blockedIndexerStatus.DisabledTill.Value.ToLocalTime());
|
||||||
continue;
|
continue;
|
||||||
|
|
|
||||||
|
|
@ -79,7 +79,7 @@ private IEnumerable<INotification> FilterBlockedNotifications(IEnumerable<INotif
|
||||||
|
|
||||||
foreach (var notification in notifications)
|
foreach (var notification in notifications)
|
||||||
{
|
{
|
||||||
if (blockedNotifications.TryGetValue(notification.Definition.Id, out var notificationStatus))
|
if (blockedNotifications.TryGetValue(notification.Definition.Id, out var notificationStatus) && notificationStatus.DisabledTill.HasValue)
|
||||||
{
|
{
|
||||||
_logger.Debug("Temporarily ignoring notification {0} till {1} due to recent failures.", notification.Definition.Name, notificationStatus.DisabledTill.Value.ToLocalTime());
|
_logger.Debug("Temporarily ignoring notification {0} till {1} due to recent failures.", notification.Definition.Name, notificationStatus.DisabledTill.Value.ToLocalTime());
|
||||||
continue;
|
continue;
|
||||||
|
|
|
||||||
|
|
@ -341,7 +341,7 @@ private ProviderStatusBase GetBlockedIndexerStatus(IIndexer indexer)
|
||||||
{
|
{
|
||||||
var blockedIndexers = _indexerStatusService.GetBlockedProviders().ToDictionary(v => v.ProviderId, v => v);
|
var blockedIndexers = _indexerStatusService.GetBlockedProviders().ToDictionary(v => v.ProviderId, v => v);
|
||||||
|
|
||||||
return blockedIndexers.TryGetValue(indexer.Definition.Id, out var blockedIndexerStatus) ? blockedIndexerStatus : null;
|
return blockedIndexers.GetValueOrDefault(indexer.Definition.Id);
|
||||||
}
|
}
|
||||||
|
|
||||||
private void AddRetryAfterHeader(int retryAfterSeconds)
|
private void AddRetryAfterHeader(int retryAfterSeconds)
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue