Archive-Team
/
sonarr-repo-only
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Cleanup other provider status code

This commit is contained in:
Qstick 2023-08-12 20:49:24 -05:00
parent e354580172
commit c281a7818a
3 changed files with 16 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/NzbDrone.Core/Download/DownloadClientFactory.cs
View File

@ -56,11 +56,11 @@ namespace NzbDrone.Core.Download
private IEnumerable<IDownloadClient> FilterBlockedClients(IEnumerable<IDownloadClient> clients) private IEnumerable<IDownloadClient> FilterBlockedClients(IEnumerable<IDownloadClient> clients)
{ {
var blockedIndexers = _downloadClientStatusService.GetBlockedProviders().ToDictionary(v => v.ProviderId, v => v); var blockedClients = _downloadClientStatusService.GetBlockedProviders().ToDictionary(v => v.ProviderId, v => v);
foreach (var client in clients) foreach (var client in clients)
{ {
if (blockedIndexers.TryGetValue(client.Definition.Id, out var downloadClientStatus)) if (blockedClients.TryGetValue(client.Definition.Id, out var downloadClientStatus))
{ {
_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;

4
src/NzbDrone.Core/Housekeeping/Housekeepers/CleanupOrphanedDownloadClientStatus.cs
View File

@ -1,4 +1,4 @@
using Dapper; using Dapper;
using NzbDrone.Core.Datastore; using NzbDrone.Core.Datastore;
namespace NzbDrone.Core.Housekeeping.Housekeepers namespace NzbDrone.Core.Housekeeping.Housekeepers
@ -14,7 +14,7 @@ namespace NzbDrone.Core.Housekeeping.Housekeepers
public void Clean() public void Clean()
{ {
var mapper = _database.OpenConnection(); using var mapper = _database.OpenConnection();
mapper.Execute(@"DELETE FROM ""DownloadClientStatus"" mapper.Execute(@"DELETE FROM ""DownloadClientStatus""
WHERE ""Id"" IN ( WHERE ""Id"" IN (

12
src/NzbDrone.Core/Housekeeping/Housekeepers/FixFutureImportListStatusTimes.cs Normal file
View File

@ -0,0 +1,12 @@
using NzbDrone.Core.ImportLists;
namespace NzbDrone.Core.Housekeeping.Housekeepers
{
public class FixFutureImportListStatusTimes : FixFutureProviderStatusTimes<ImportListStatus>, IHousekeepingTask
{
public FixFutureImportListStatusTimes(IImportListStatusRepository importListStatusRepository)
: base(importListStatusRepository)
{
}
}
}