From 174e81312769fd9dbd6ffe0b47ea64c282e4e5ef Mon Sep 17 00:00:00 2001 From: Viren070 Date: Wed, 26 Nov 2025 17:16:28 +0000 Subject: [PATCH] fix: filter out nzbs with failed status --- packages/core/src/builtins/utils/debrid.ts | 7 +++++++ packages/core/src/debrid/usenet-stream-base.ts | 4 ++-- 2 files changed, 9 insertions(+), 2 deletions(-) diff --git a/packages/core/src/builtins/utils/debrid.ts b/packages/core/src/builtins/utils/debrid.ts index 68a23090..286b1d77 100644 --- a/packages/core/src/builtins/utils/debrid.ts +++ b/packages/core/src/builtins/utils/debrid.ts @@ -426,6 +426,13 @@ async function processNZBsForDebridService( const nzbCheckResult = nzbCheckResults.find( (result) => result.hash === nzb.hash ); + if (nzbCheckResult?.status === 'failed') { + logger.debug(`Skipping NZB as its status is failed`, { + service: service.id, + nzb: nzb.title, + }); + continue; + } const parsedNzb = parsedTitlesMap.get(nzb.title ?? ''); if (metadata && parsedNzb) { if (isSeasonWrong(parsedNzb, metadata)) { diff --git a/packages/core/src/debrid/usenet-stream-base.ts b/packages/core/src/debrid/usenet-stream-base.ts index 4b28ee69..fa718c23 100644 --- a/packages/core/src/debrid/usenet-stream-base.ts +++ b/packages/core/src/debrid/usenet-stream-base.ts @@ -619,7 +619,7 @@ export abstract class UsenetStreamService implements DebridService { const history = await this.api.history(); const nzbs: DebridDownload[] = history.slots.map((slot, index) => ({ id: index, - status: 'cached' as const, + status: slot.status !== 'failed' ? 'cached' : 'failed', name: slot.name, })); this.serviceLogger.debug(`Listed NZBs from history`, { @@ -679,7 +679,7 @@ export abstract class UsenetStreamService implements DebridService { ); return { id: index, - status: 'cached', + status: libraryNzb?.status === 'failed' ? 'failed' : 'cached', library: !!libraryNzb, hash: h, name: n,