diff --git a/api/main.py b/api/main.py index 26b9ac5..a38bbf9 100644 --- a/api/main.py +++ b/api/main.py @@ -21,7 +21,7 @@ from fastapi.templating import Jinja2Templates from api.middleware import SecureLoggingMiddleware from db import database, crud, schemas from db.config import settings -from scrappers import tamil_blasters, tamilmv, prowlarr +from scrappers import tamil_blasters, tamilmv from streaming_providers.alldebrid.utils import get_direct_link_from_alldebrid from streaming_providers.debridlink.api import router as debridlink_router from streaming_providers.debridlink.utils import get_direct_link_from_debridlink @@ -77,7 +77,6 @@ async def init_server(): app.state.redis = redis.Redis( connection_pool=redis.ConnectionPool.from_url(settings.redis_url) ) - await prowlarr.init_indexers() @app.on_event("startup") diff --git a/api/task.py b/api/task.py index 867adc5..16aa611 100644 --- a/api/task.py +++ b/api/task.py @@ -2,7 +2,6 @@ import asyncio from db import database -from scrappers import prowlarr from scrappers.helpers import update_torrent_movie_streams_metadata # noqa: F401 from scrappers.prowlarr import parse_and_store_movie_stream_data # noqa: F401 from utils import torrent @@ -11,7 +10,6 @@ from utils import torrent async def async_setup(): # Your async initialization code here await torrent.init_best_trackers() - await prowlarr.init_indexers() await database.init() diff --git a/scrappers/prowlarr.py b/scrappers/prowlarr.py index 1005264..a45b9b5 100644 --- a/scrappers/prowlarr.py +++ b/scrappers/prowlarr.py @@ -1,5 +1,4 @@ import asyncio -import json import logging from datetime import datetime, timedelta @@ -577,26 +576,3 @@ async def parse_and_store_series_stream_data_actor( stream_data: list, ): await parse_and_store_series_stream_data(video_id, title, season, stream_data) - - -async def init_indexers(): - """Initialize indexers in prowlarr.""" - url = f"{settings.prowlarr_url}/api/v1/indexer" - headers = { - "accept": "application/json", - "X-Api-Key": settings.prowlarr_api_key, - } - with open("resources/json/prowlarr-indexers.json") as file: - indexers = json.load(file) - async with httpx.AsyncClient() as client: - response = await client.get(url, headers=headers) - response.raise_for_status() - data = response.json() - available_indexers = [indexer["name"] for indexer in data] - for indexer in indexers: - if indexer["name"] not in available_indexers: - response = await client.post(url, headers=headers, json=indexer) - response.raise_for_status() - logging.info(f"Added {indexer['name']} to prowlarr") - else: - logging.info(f"{indexer['name']} already exists in prowlarr")