From 1f29c4ca1ba074f35760ce7549098b68e6b7d778 Mon Sep 17 00:00:00 2001 From: g0ldyy <153996346+g0ldyy@users.noreply.github.com> Date: Wed, 7 Jan 2026 01:23:33 +0100 Subject: [PATCH] feat: fix a few useless things --- comet/metadata/kitsu.py | 16 ++++++++-------- comet/metadata/manager.py | 2 +- comet/services/anime.py | 7 +++++-- comet/utils/network_manager.py | 2 +- 4 files changed, 15 insertions(+), 12 deletions(-) diff --git a/comet/metadata/kitsu.py b/comet/metadata/kitsu.py index 2264ebb..4aef0f5 100644 --- a/comet/metadata/kitsu.py +++ b/comet/metadata/kitsu.py @@ -27,15 +27,15 @@ async def get_kitsu_metadata(session: aiohttp.ClientSession, id: str): if end_date and len(end_date) >= 4: year_end = int(end_date[:4]) - if year is None: - created_at = attributes.get("createdAt") - if created_at and len(created_at) >= 4: - year = int(created_at[:4]) + # if year is None: + # created_at = attributes.get("createdAt") + # if created_at and len(created_at) >= 4: + # year = int(created_at[:4]) - if year_end is None: - updated_at = attributes.get("updatedAt") - if updated_at and len(updated_at) >= 4: - year_end = int(updated_at[:4]) + # if year_end is None: + # updated_at = attributes.get("updatedAt") + # if updated_at and len(updated_at) >= 4: + # year_end = int(updated_at[:4]) return title, year, year_end except Exception as e: diff --git a/comet/metadata/manager.py b/comet/metadata/manager.py index beb9a6f..187b3d7 100644 --- a/comet/metadata/manager.py +++ b/comet/metadata/manager.py @@ -183,7 +183,7 @@ class MetadataScraper: aliases = await anime_mapper.get_aliases(full_media_id) logger.log( "SCRAPER", - f"📜 Found {len(aliases['ez'])} Anime title aliases for {media_id}", + f"📜 Found {len(aliases.get('ez', []))} Anime title aliases for {media_id}", ) if aliases: return aliases diff --git a/comet/services/anime.py b/comet/services/anime.py index 4f7a43a..2e63369 100644 --- a/comet/services/anime.py +++ b/comet/services/anime.py @@ -42,6 +42,7 @@ class AnimeMapper: def __init__(self): self.loaded = False self._refresh_lock = asyncio.Lock() + self._refresh_task = None self.anime_imdb_ids = set() self._aod_url = "https://github.com/manami-project/anime-offline-database/releases/latest/download/anime-offline-database-minified.json" @@ -56,7 +57,9 @@ class AnimeMapper: await self._load_provider_ids() if await self._is_cache_stale(): - asyncio.create_task(self._refresh_from_remote(background=True)) + self._refresh_task = asyncio.create_task( + self._refresh_from_remote(background=True) + ) self.loaded = True logger.log( @@ -371,7 +374,7 @@ class AnimeMapper: except Exception as exc: logger.error(f"Failed to persist anime mapping cache: {exc}") - + return 0, 0 anime_mapper = AnimeMapper() diff --git a/comet/utils/network_manager.py b/comet/utils/network_manager.py index 094172c..b80960d 100644 --- a/comet/utils/network_manager.py +++ b/comet/utils/network_manager.py @@ -266,7 +266,7 @@ class AsyncClientWrapper: if not self._curl_session: self._curl_session = CurlSession( headers=self.headers, - impersonate=self.impersonate or "chrome", + impersonate=self.impersonate, timeout=self.timeout, ) return self._curl_session