feat: add translation service to translate catalog names to user language (#23)

Author: TimilsinaBimal

Dockerfile

@@ -21,9 +21,7 @@ COPY requirements.txt .
 # Install Python dependencies
 RUN pip install --no-cache-dir -r requirements.txt
 
-# Copy application code (including static files)
 COPY app/ ./app/
-COPY static/ ./static/
 COPY main.py .
 COPY pyproject.toml .
 

app/api/endpoints/manifest.py

@@ -7,6 +7,7 @@
 from app.core.version import __version__
 from app.services.catalog import DynamicCatalogService
 from app.services.stremio_service import StremioService
+from app.services.translation import translation_service
 from app.utils import resolve_user_credentials
 
 router = APIRouter()
@@ -45,7 +46,7 @@ def get_base_manifest(user_settings: UserSettings | None = None):
         "version": __version__,
         "name": settings.ADDON_NAME,
         "description": "Movie and series recommendations based on your Stremio library",
-        "logo": "https://raw.githubusercontent.com/TimilsinaBimal/Watchly/refs/heads/main/static/logo.png",
+        "logo": "https://raw.githubusercontent.com/TimilsinaBimal/Watchly/refs/heads/main/app/static/logo.png",
         "resources": [{"name": "catalog", "types": ["movie", "series"], "idPrefixes": ["tt"]}],
         "types": ["movie", "series"],
         "idPrefixes": ["tt"],
@@ -106,6 +107,11 @@ async def _manifest_handler(response: Response, token: str | None, settings_str:
 
     base_manifest = get_base_manifest(user_settings)
 
+    if user_settings and user_settings.language:
+        for cat in base_manifest.get("catalogs", []):
+            if cat.get("name"):
+                cat["name"] = await translation_service.translate(cat["name"], user_settings.language)
+
     if token:
         # We pass settings_str to fetch_catalogs so it can cache different versions
         # We COPY the lists to avoid modifying cached objects or base_manifest defaults

app/core/app.py

@@ -74,10 +74,10 @@ async def lifespan(app: FastAPI):
 # Static directory is at project root (3 levels up from app/core/app.py)
 # app/core/app.py -> app/core -> app -> root
 project_root = Path(__file__).resolve().parent.parent.parent
-static_dir = project_root / "static"
+static_dir = project_root / "app/static"
 
 if static_dir.exists():
-    app.mount("/static", StaticFiles(directory=str(static_dir)), name="static")
+    app.mount("/app/static", StaticFiles(directory=str(static_dir)), name="static")
 
 
 # Serve index.html at /configure and /{token}/configure

app/services/catalog.py

@@ -3,6 +3,7 @@
 from app.services.scoring import ScoringService
 from app.services.stremio_service import StremioService
 from app.services.tmdb_service import TMDBService
+from app.services.translation import translation_service
 from app.services.user_profile import UserProfileService
 
 
@@ -34,9 +35,6 @@ def build_catalog_entry(self, item, label, config_id):
             catalog_id = item_id
 
         name = item.get("name")
-        # # Truncate long names for cleaner UI
-        # if len(name) > 25:
-        #     name = name[:25] + "..."
 
         return {
             "type": self.normalize_type(item.get("type")),
@@ -49,6 +47,8 @@ async def get_theme_based_catalogs(
         self, library_items: list[dict], user_settings: UserSettings | None = None
     ) -> list[dict]:
         catalogs = []
+        lang = user_settings.language if user_settings else "en-US"
+
         # 1. Build User Profile
         # Combine loved and watched
         all_items = library_items.get("loved", []) + library_items.get("watched", [])
@@ -82,7 +82,8 @@ async def get_theme_based_catalogs(
         movie_rows = await self.row_generator.generate_rows(movie_profile, "movie")
 
         for row in movie_rows:
-            catalogs.append({"type": "movie", "id": row.id, "name": row.title, "extra": []})
+            translated_title = await translation_service.translate(row.title, lang)
+            catalogs.append({"type": "movie", "id": row.id, "name": translated_title, "extra": []})
 
         # Generate for Series
         series_profile = await self.user_profile_service.build_user_profile(
@@ -91,7 +92,8 @@ async def get_theme_based_catalogs(
         series_rows = await self.row_generator.generate_rows(series_profile, "series")
 
         for row in series_rows:
-            catalogs.append({"type": "series", "id": row.id, "name": row.title, "extra": []})
+            translated_title = await translation_service.translate(row.title, lang)
+            catalogs.append({"type": "series", "id": row.id, "name": translated_title, "extra": []})
 
         return catalogs
 
@@ -101,6 +103,7 @@ async def get_dynamic_catalogs(
         """
         Generate all dynamic catalog rows.
         """
+        lang = user_settings.language if user_settings else "en-US"
 
         include_item_based_rows = bool(
             next((c for c in user_settings.catalogs if c.id == "watchly.item" and c.enabled), True)
@@ -116,15 +119,19 @@ async def get_dynamic_catalogs(
         # 3. Add Item-Based Rows
         if include_item_based_rows:
             # For Movies
-            self._add_item_based_rows(catalogs, library_items, "movie")
+            await self._add_item_based_rows(catalogs, library_items, "movie", lang)
             # For Series
-            self._add_item_based_rows(catalogs, library_items, "series")
+            await self._add_item_based_rows(catalogs, library_items, "series", lang)
 
         return catalogs
 
-    def _add_item_based_rows(self, catalogs: list, library_items: dict, content_type: str):
+    async def _add_item_based_rows(self, catalogs: list, library_items: dict, content_type: str, language: str):
         """Helper to add 'Because you watched' and 'More like' rows."""
 
+        # Translate labels
+        label_more_like = await translation_service.translate("More like", language)
+        label_bc_watched = await translation_service.translate("Because you watched", language)
+
         # Helper to parse date
         def get_date(item):
             import datetime
@@ -152,13 +159,9 @@ def get_date(item):
 
         last_loved = loved[0] if loved else None
         if last_loved:
-            catalogs.append(self.build_catalog_entry(last_loved, "More like", "watchly.item"))
+            catalogs.append(self.build_catalog_entry(last_loved, label_more_like, "watchly.item"))
 
         # 2. Because you watched <Watched Item>
-        # Filter only watched items (exclude loved if possible or treat as separate pool)
-        # Actually, watched_items in StremioService include everything with progress or watched flag
-        # We want 'Because you watched' to reflect recent activity.
-
         watched = [i for i in library_items.get("watched", []) if i.get("type") == content_type]
         watched.sort(key=get_date, reverse=True)
 
@@ -170,8 +173,5 @@ def get_date(item):
             last_watched = item
             break
 
-        # If no distinct last watched found (e.g. only watched 1 item and it was loved),
-        # we can skip or pick the next best.
-
         if last_watched:
-            catalogs.append(self.build_catalog_entry(last_watched, "Because you watched", "watchly.item"))
+            catalogs.append(self.build_catalog_entry(last_watched, label_bc_watched, "watchly.item"))

app/services/translation.py

@@ -0,0 +1,31 @@
+import asyncio
+
+from async_lru import alru_cache
+from deep_translator import GoogleTranslator
+from loguru import logger
+
+
+class TranslationService:
+    @alru_cache(maxsize=1000, ttl=7 * 24 * 60 * 60)
+    async def translate(self, text: str, target_lang: str | None) -> str:
+        if not text or not target_lang:
+            return text
+
+        # Normalize lang (e.g. en-US -> en)
+        lang = target_lang.split("-")[0].lower()
+        if lang == "en":
+            return text
+
+        try:
+            loop = asyncio.get_running_loop()
+
+            translated = await loop.run_in_executor(
+                None, lambda: GoogleTranslator(source="auto", target=lang).translate(text)
+            )
+            return translated if translated else text
+        except Exception as e:
+            logger.warning(f"Translation failed for '{text}' to '{lang}': {e}")
+            return text
+
+
+translation_service = TranslationService()