Add more Lidarr checks for failed imports (#48)

This commit is contained in:
Marius Nechifor
2025-01-28 19:10:07 +02:00
committed by GitHub
parent 0f63a2d271
commit c813215f3e
2 changed files with 7 additions and 3 deletions
@@ -66,7 +66,7 @@ public abstract class ArrClient
return queueResponse; return queueResponse;
} }
public virtual bool ShouldRemoveFromQueue(QueueRecord record, bool isPrivateDownload) public virtual bool ShouldRemoveFromQueue(InstanceType instanceType, QueueRecord record, bool isPrivateDownload)
{ {
if (_queueCleanerConfig.ImportFailedIgnorePrivate && isPrivateDownload) if (_queueCleanerConfig.ImportFailedIgnorePrivate && isPrivateDownload)
{ {
@@ -83,8 +83,12 @@ public abstract class ArrClient
.Equals("importPending", StringComparison.InvariantCultureIgnoreCase); .Equals("importPending", StringComparison.InvariantCultureIgnoreCase);
bool isImportFailed() => record.TrackedDownloadState bool isImportFailed() => record.TrackedDownloadState
.Equals("importFailed", StringComparison.InvariantCultureIgnoreCase); .Equals("importFailed", StringComparison.InvariantCultureIgnoreCase);
bool isFailedLidarr() => instanceType is InstanceType.Lidarr &&
(record.Status.Equals("failed", StringComparison.InvariantCultureIgnoreCase) ||
record.Status.Equals("completed", StringComparison.InvariantCultureIgnoreCase)) &&
hasWarn();
if (hasWarn() && (isImportBlocked() || isImportPending() || isImportFailed())) if (hasWarn() && (isImportBlocked() || isImportPending() || isImportFailed()) || isFailedLidarr())
{ {
if (HasIgnoredPatterns(record)) if (HasIgnoredPatterns(record))
{ {
@@ -75,7 +75,7 @@ public sealed class QueueCleaner : GenericHandler
} }
// failed import check // failed import check
bool shouldRemoveFromArr = arrClient.ShouldRemoveFromQueue(record, stalledCheckResult.IsPrivate); bool shouldRemoveFromArr = arrClient.ShouldRemoveFromQueue(instanceType, record, stalledCheckResult.IsPrivate);
if (!shouldRemoveFromArr && !stalledCheckResult.ShouldRemove) if (!shouldRemoveFromArr && !stalledCheckResult.ShouldRemove)
{ {