Introduction

jackett_bot/
├── app.py              # Bot initialization and handler registration
├── config.py           # Environment-based configuration with validation
├── handlers/
│   └── commands.py     # Telegram command handlers and pagination logic
└── services/
    ├── auth.py         # Thread-safe authorization service
    ├── jackett.py      # Jackett API integration and XML parsing
    └── ptp.py          # PTP availability health check

from jackett_bot import JackettSearchBot

bot = JackettSearchBot.initialize("config.env")
bot.run()

@dataclass(frozen=True)
class BotConfig:
    token: str
    api_id: int
    api_hash: str
    jackett_api_key: str
    jackett_url: str
    default_max_results: int
    redact_after_seconds: int
    log_file_path: str
    console_log_level: int
    file_log_level: int
    authorized_chat_ids: list[int]
    owner_id: int

class JackettService:
    def build_search_url(self, query: str) -> str:
        if query.startswith("tt") and query[2:].isdigit():
            return (
                f"{self.jackett_url}/api/v2.0/indexers/all/results/torznab/api"
                f"?apikey={self.jackett_api_key}&imdbid={query}"
            )
        
        encoded_query = quote(query)
        return (
            f"{self.jackett_url}/api/v2.0/indexers/all/results/torznab/api"
            f"?apikey={self.jackett_api_key}&t=search&q={encoded_query}"
        )

class AuthorizationService:
    def __init__(self, bootstrap_ids: Iterable[int] | None = None):
        self._lock = threading.RLock()
        self._configured_ids: set[int] = set()
        self._temporary_ids: set[int] = set()

@dataclass(frozen=True)
class SearchResult:
    title: str
    age: str
    size: str

    def as_html(self) -> str:
        return (
            f"<b>Title:</b> <code>{self.title}</code>\n"
            f"<b>Age:</b> {self.age}\n"
            f"<b>Size:</b> {self.size}\n"
        )