From 489ed9bdbe79aef571cbccb3b3742c4f9162c04e Mon Sep 17 00:00:00 2001 From: g0ldyy <153996346+g0ldyy@users.noreply.github.com> Date: Sun, 28 Dec 2025 17:05:12 +0100 Subject: [PATCH] feat: conditionally apply digital release filter based on settings and remove redundant internal filter check --- comet/api/endpoints/stream.py | 31 ++++++++++++++++--------------- comet/metadata/filter.py | 3 --- 2 files changed, 16 insertions(+), 18 deletions(-) diff --git a/comet/api/endpoints/stream.py b/comet/api/endpoints/stream.py index 948e549..d22b5e7 100644 --- a/comet/api/endpoints/stream.py +++ b/comet/api/endpoints/stream.py @@ -171,24 +171,25 @@ async def stream( async with aiohttp.ClientSession(connector=connector) as session: metadata_scraper = MetadataScraper(session) - # Digital Release Filter id, season, episode = parse_media_id(media_type, media_id) - is_released = await release_filter.check_is_released( - session, media_type, media_id, season, episode - ) + # Digital Release Filter + if settings.DIGITAL_RELEASE_FILTER: + is_released = await release_filter.check_is_released( + session, media_type, media_id, season, episode + ) - if not is_released: - logger.log("FILTER", f"🚫 {media_id} is not released yet. Skipping.") - return { - "streams": [ - { - "name": "[🚫] Comet", - "description": "Content not digitally released yet.", - "url": "https://comet.fast", - } - ] - } + if not is_released: + logger.log("FILTER", f"🚫 {media_id} is not released yet. Skipping.") + return { + "streams": [ + { + "name": "[🚫] Comet", + "description": "Content not digitally released yet.", + "url": "https://comet.fast", + } + ] + } # Check if metadata is already cached cached_metadata = await metadata_scraper.get_cached( diff --git a/comet/metadata/filter.py b/comet/metadata/filter.py index e5402fe..5c1be70 100644 --- a/comet/metadata/filter.py +++ b/comet/metadata/filter.py @@ -15,9 +15,6 @@ class DigitalReleaseFilter: season: int = None, episode: int = None, ): - if not settings.DIGITAL_RELEASE_FILTER: - return True - try: cached_date = await database.fetch_val( """