"""jokepool710/Torrent-_Trackers collector.

Independent daily public-tracker list (MIT, (c) J0KEP00L). Only the aggregate
`trackers_all.txt` feed is consumed; the per-protocol files it also publishes
are subsets of that aggregate.
"""

from __future__ import annotations

import httpx
from sqlalchemy.ext.asyncio import AsyncSession

from app.collectors.base import ImportStats, import_source_feeds
from app.config import Settings

SOURCE_NAME = "jokepool710"


class Jokepool710Collector:
    name = SOURCE_NAME

    async def import_once(
        self, session: AsyncSession, client: httpx.AsyncClient, settings: Settings
    ) -> ImportStats:
        return await import_source_feeds(
            session,
            client,
            source_name=SOURCE_NAME,
            primary_url=settings.jokepool710_all_url,
        )