Release v1.8.0 (#104)

Author: TimilsinaBimal

.gitignore

@@ -48,3 +48,9 @@ logs/
 *.ipynb
 .vercel
 migration.py
+
+
+.cursor
+.github
+.pytest_cache
+.ruff_cache

app/api/endpoints/catalogs.py

@@ -15,6 +15,12 @@ async def get_catalog(response: Response, type: str, id: str, token: str, extra:
 
     This endpoint delegates all logic to CatalogService facade.
     """
+    if type not in ("movie", "series"):
+        raise HTTPException(status_code=400, detail="Invalid content type. Must be 'movie' or 'series'.")
+
+    if len(token) > 30:  # normal stremio tokens are 24 length. But we are using this just to be safe.
+        raise HTTPException(status_code=400, detail="Invalid token.")
+
     try:
         # Delegate to catalog service facade
         recommendations, headers = await catalog_service.get_catalog(token, type, id)

app/api/endpoints/tokens.py

@@ -1,4 +1,5 @@
 from datetime import datetime, timezone
+from typing import Literal
 
 from fastapi import APIRouter, HTTPException, Request
 from loguru import logger
@@ -23,6 +24,11 @@ class TokenRequest(BaseModel):
     poster_rating: PosterRatingConfig | None = Field(default=None, description="Poster rating provider configuration")
     excluded_movie_genres: list[str] = Field(default_factory=list, description="List of movie genre IDs to exclude")
     excluded_series_genres: list[str] = Field(default_factory=list, description="List of series genre IDs to exclude")
+    popularity: Literal["mainstream", "balanced", "gems", "all"] = Field(
+        default="balanced", description="Popularity for TMDB API"
+    )
+    year_min: int = Field(default=2010, description="Minimum release year for TMDB API")
+    year_max: int = Field(default=2025, description="Maximum release year for TMDB API")
 
 
 class TokenResponse(BaseModel):
@@ -85,6 +91,9 @@ async def create_token(payload: TokenRequest, request: Request) -> TokenResponse
         poster_rating=poster_rating,
         excluded_movie_genres=payload.excluded_movie_genres,
         excluded_series_genres=payload.excluded_series_genres,
+        year_min=payload.year_min,
+        year_max=payload.year_max,
+        popularity=payload.popularity,
     )
 
     # 4. Prepare payload to store

app/core/app.py

@@ -30,6 +30,13 @@ async def lifespan(app: FastAPI):
     """
     Manage application lifespan events (startup/shutdown).
     """
+    # Startup checks
+    if settings.TOKEN_SALT == "change-me" and settings.APP_ENV == "production":
+        logger.warning(
+            "Security Warning: TOKEN_SALT is set to default 'change-me' in production environment! "
+            "Please set the TOKEN_SALT environment variable."
+        )
+
     yield
     try:
         await redis_service.close()

app/core/config.py

@@ -31,14 +31,15 @@ class Settings(BaseSettings):
     TOKEN_TTL_SECONDS: int = 0  # 0 = never expire
     ANNOUNCEMENT_HTML: str = ""
     AUTO_UPDATE_CATALOGS: bool = True
-    CATALOG_REFRESH_INTERVAL_SECONDS: int = 43200  # 12 hours
+    CATALOG_REFRESH_INTERVAL_SECONDS: int = 86400  # 24 hours
     APP_ENV: Literal["development", "production", "vercel"] = "production"
     HOST_NAME: str = "https://1ccea4301587-watchly.baby-beamup.club"
 
     RECOMMENDATION_SOURCE_ITEMS_LIMIT: int = 10
     LIBRARY_ITEMS_LIMIT: int = 20
 
     CATALOG_CACHE_TTL: int = 43200  # 12 hours
+    CATALOG_STALE_TTL: int = 604800  # 7 days (soft expiration fallback)
 
     # AI
     DEFAULT_GEMINI_MODEL: str = "gemma-3-27b-it"

app/core/constants.py

@@ -2,6 +2,8 @@
 DEFAULT_MIN_ITEMS: int = 8
 DEFAULT_CATALOG_LIMIT: int = 20
 
+MAX_CATALOG_ITEMS: int = 100
+
 DEFAULT_CONCURRENCY_LIMIT: int = 30
 
 DEFAULT_MINIMUM_RATING_FOR_THEME_BASED_MOVIE: float = 7.2
@@ -16,3 +18,27 @@
 
 
 DISCOVER_ONLY_EXTRA: list[dict] = [{"name": "genre", "isRequired": True, "options": ["All"], "optionsLimit": 1}]
+
+
+DISCOVERY_SETTINGS: dict = {
+    "mainstream": {
+        "popularity.gte": 30,
+        "vote_average.gte": 6.2,
+        "vote_count.gte": 500,
+    },
+    "balanced": {
+        "popularity.lte": 30,
+        "vote_average.gte": 6.7,
+        "vote_count.gte": 250,
+    },
+    "gems": {
+        "popularity.lte": 15,
+        "vote_average.gte": 7.2,
+        "vote_count.gte": 100,
+    },
+    "all": {
+        "popularity.gte": 0,
+        "vote_average.gte": 5.0,
+        "vote_count.gte": 100,
+    },
+}

app/core/settings.py

@@ -30,6 +30,11 @@ class UserSettings(BaseModel):
     poster_rating: PosterRatingConfig | None = Field(default=None, description="Poster rating provider configuration")
     excluded_movie_genres: list[str] = Field(default_factory=list)
     excluded_series_genres: list[str] = Field(default_factory=list)
+    year_min: int = Field(default=1970, description="Minimum release year")
+    year_max: int = Field(default=2026, description="Maximum release year")
+    popularity: Literal["mainstream", "balanced", "gems", "all"] = Field(
+        default="balanced", description="Popularity preference"
+    )
 
 
 # Catalog descriptions for frontend

app/core/version.py

@@ -1 +1 @@
-__version__ = "1.7.0"
+__version__ = "1.7.1-rc.1"

app/models/taste_profile.py

@@ -23,10 +23,21 @@ class TasteProfile(BaseModel):
     country_scores: dict[str, float] = Field(default_factory=dict, description="Country code → accumulated score")
     director_scores: dict[int, float] = Field(default_factory=dict, description="Director ID → accumulated score")
     cast_scores: dict[int, float] = Field(default_factory=dict, description="Actor ID → accumulated score")
+    runtime_bucket_scores: dict[str, float] = Field(
+        default_factory=dict,
+        description="Runtime bucket (short/medium/long) → accumulated score",
+    )
 
     # Metadata
+    average_episodes: float | None = Field(
+        default=None, description="Weighted average episodes per series (series only)"
+    )
     last_updated: datetime = Field(default_factory=lambda: datetime.now(timezone.utc))
     content_type: str | None = Field(default=None, description="movie or series")
+    processed_items: set[str] = Field(
+        default_factory=set,
+        description="Set of processed item IDs to prevent double counting",
+    )
 
     class Config:
         """Pydantic configuration."""
@@ -91,4 +102,5 @@ def normalize_dict(scores: dict[Any, float]) -> dict[Any, float]:
             "directors": normalize_dict(self.director_scores),
             "cast": normalize_dict(self.cast_scores),
             "creators": normalize_dict({**self.director_scores, **self.cast_scores}),
+            "runtime_buckets": normalize_dict(self.runtime_bucket_scores),
         }

app/services/catalog.py

@@ -134,6 +134,7 @@ async def _generate_for_type(media_type: str, genres: list[int]):
                 library_items, media_type, None, None
             )
             if not profile:
+                logger.warning(f"Failed to build profile for {media_type}")
                 return media_type, []
 
             try: