"""Episode comments functionality."""
from config.api import DEFAULT_LIMIT
from config.endpoints import TRAKT_ENDPOINTS
from models.types import CommentResponse
from utils.api.errors import handle_api_errors
from ..base import BaseClient
class EpisodeCommentsClient(BaseClient):
"""Client for episode comments operations."""
@handle_api_errors
async def get_episode_comments(
self,
show_id: str,
season: int,
episode: int,
limit: int = DEFAULT_LIMIT,
page: int = 1,
sort: str = "newest",
) -> list[CommentResponse]:
"""Get comments for an episode.
Args:
show_id: The Trakt show ID
season: Season number
episode: Episode number
limit: Maximum number of comments to return
page: Page number for pagination
sort: Sort order for comments
Returns:
List of episode comments data
"""
endpoint = (
TRAKT_ENDPOINTS["comments_episode"]
.replace(":id", show_id)
.replace(":season", str(season))
.replace(":episode", str(episode))
.replace(":sort", sort)
)
return await self._make_typed_list_request(
endpoint,
response_type=CommentResponse,
params={"limit": limit, "page": page},
)
