V-3.0.0

* custom catalog support

Backend/__init__.py

@@ -11,4 +11,4 @@ StartTime = time()
 USE_DEFAULT_ID: str = None
 db = Database()  
 
-__version__ = "2.2.0"
+__version__ = "3.0.0"

Backend/fastapi/main.py

@@ -3,6 +3,7 @@ from fastapi.responses import HTMLResponse, RedirectResponse
 from fastapi.middleware.cors import CORSMiddleware
 from fastapi.staticfiles import StaticFiles
 from starlette.middleware.sessions import SessionMiddleware
+from fastapi.templating import Jinja2Templates
 from Backend import __version__
 from Backend.fastapi.security.credentials import require_auth
 from Backend.fastapi.routes.stream_routes import router as stream_router, decay_client_failures
@@ -10,7 +11,8 @@ from Backend.fastapi.routes.stremio_routes import router as stremio_router
 from Backend.fastapi.routes.template_routes import (
     login_page, login_post, logout, set_theme, dashboard_page,
     media_management_page, edit_media_page, public_status_page, stremio_guide_page,
-    admin_dashboard_page, admin_subscriptions_page, admin_access_page
+    admin_dashboard_page, admin_subscriptions_page, admin_access_page,
+    custom_catalogs_page
 )
 from Backend.fastapi.routes.api_routes import (
     list_media_api, delete_media_api, update_media_api,
@@ -24,9 +26,14 @@ from Backend.fastapi.routes.api_routes import (
     update_subscription_plan_api, delete_subscription_plan_api,
     get_all_subscribers_api, manage_subscriber_api,
     get_all_tokens_api, assign_plan_api, link_token_user_api,
-    search_media_rescan_api, apply_media_rescan_api
+    search_media_rescan_api, apply_media_rescan_api,
+    list_custom_catalogs_api, create_custom_catalog_api, update_custom_catalog_api,
+    delete_custom_catalog_api, get_custom_catalog_items_api, search_catalog_media_api,
+    add_custom_catalog_item_api, remove_custom_catalog_item_api
 )
 
+templates = Jinja2Templates(directory="Backend/fastapi/templates")
+
 app = FastAPI(
     title="Telegram Stremio Media Server",
     description="A powerful, self-hosted Telegram Stremio Media Server built with FastAPI, MongoDB, and PyroFork seamlessly integrated with Stremio for automated media streaming and discovery.",
@@ -95,6 +102,11 @@ async def admin_dashboard(request: Request, _: bool = Depends(require_auth)):
 async def media_management(request: Request, media_type: str = "movie", _: bool = Depends(require_auth)):
     return await media_management_page(request, media_type, _)
 
+
+@app.get("/catalogs", response_class=HTMLResponse)
+async def custom_catalogs(request: Request, _: bool = Depends(require_auth)):
+    return await custom_catalogs_page(request, _)
+
 @app.get("/media/edit", response_class=HTMLResponse)
 async def edit_media(request: Request, tmdb_id: int, db_index: int, media_type: str, _: bool = Depends(require_auth)):
     return await edit_media_page(request, tmdb_id, db_index, media_type, _)
@@ -281,6 +293,63 @@ async def apply_media_rescan(
 ):
     return await apply_media_rescan_api(request, tmdb_id, db_index, media_type)
 
+
+# --- Custom Catalog Management ---
+@app.get("/api/custom-catalogs")
+async def list_custom_catalogs(
+    tmdb_id: int | None = None,
+    db_index: int | None = None,
+    media_type: str | None = None,
+    _: bool = Depends(require_auth)
+):
+    return await list_custom_catalogs_api(tmdb_id, db_index, media_type)
+
+@app.post("/api/custom-catalogs")
+async def create_custom_catalog(payload: dict, _: bool = Depends(require_auth)):
+    return await create_custom_catalog_api(payload)
+
+@app.put("/api/custom-catalogs/{catalog_id}")
+async def update_custom_catalog(catalog_id: str, payload: dict, _: bool = Depends(require_auth)):
+    return await update_custom_catalog_api(catalog_id, payload)
+
+@app.delete("/api/custom-catalogs/{catalog_id}")
+async def delete_custom_catalog(catalog_id: str, _: bool = Depends(require_auth)):
+    return await delete_custom_catalog_api(catalog_id)
+
+@app.get("/api/custom-catalogs/search-media")
+async def search_catalog_media(
+    query: str,
+    media_type: str = Query("movie", regex="^(movie|tv)$"),
+    page: int = Query(1, ge=1),
+    page_size: int = Query(12, ge=1, le=50),
+    _: bool = Depends(require_auth)
+):
+    return await search_catalog_media_api(query, media_type, page, page_size)
+
+@app.get("/api/custom-catalogs/{catalog_id}/items")
+async def get_custom_catalog_items(
+    catalog_id: str,
+    media_type: str | None = Query(None, regex="^(movie|tv)$"),
+    page: int = Query(1, ge=1),
+    page_size: int = Query(24, ge=1, le=100),
+    _: bool = Depends(require_auth)
+):
+    return await get_custom_catalog_items_api(catalog_id, media_type, page, page_size)
+
+@app.post("/api/custom-catalogs/{catalog_id}/items")
+async def add_custom_catalog_item(catalog_id: str, payload: dict, _: bool = Depends(require_auth)):
+    return await add_custom_catalog_item_api(catalog_id, payload)
+
+@app.delete("/api/custom-catalogs/{catalog_id}/items")
+async def remove_custom_catalog_item(
+    catalog_id: str,
+    tmdb_id: int,
+    db_index: int,
+    media_type: str = Query("movie", regex="^(movie|tv)$"),
+    _: bool = Depends(require_auth)
+):
+    return await remove_custom_catalog_item_api(catalog_id, tmdb_id, db_index, media_type)
+
 @app.exception_handler(401)
 async def auth_exception_handler(request: Request, exc):
     return RedirectResponse(url="/login", status_code=302)

Backend/fastapi/routes/api_routes.py

@@ -790,3 +790,137 @@ async def apply_media_rescan_api(request: Request, tmdb_id: int, db_index: int,
         "media_type": media_type,
         "data": updated_doc,
 }
+
+
+# --- Custom Catalog APIs ---
+
+def _normalize_media_type(media_type: str) -> str:
+    return "tv" if media_type in ["tv", "series"] else "movie"
+
+
+async def list_custom_catalogs_api(
+    tmdb_id: int | None = None,
+    db_index: int | None = None,
+    media_type: str | None = None,
+):
+    try:
+        catalogs = await db.get_custom_catalogs()
+        if tmdb_id is not None and db_index is not None and media_type:
+            normalized_type = _normalize_media_type(media_type)
+            for catalog in catalogs:
+                catalog["contains_current"] = any(
+                    int(item.get("tmdb_id", -1)) == int(tmdb_id)
+                    and int(item.get("db_index", -1)) == int(db_index)
+                    and item.get("media_type") == normalized_type
+                    for item in catalog.get("items", []) or []
+                )
+        return {"catalogs": catalogs}
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=str(e))
+
+
+async def create_custom_catalog_api(payload: dict):
+    name = (payload.get("name") or "").strip()
+    visible = bool(payload.get("visible", True))
+    if not name:
+        raise HTTPException(status_code=400, detail="Catalog name is required.")
+
+    catalog_id = await db.create_custom_catalog(name=name, visible=visible)
+    if not catalog_id:
+        raise HTTPException(status_code=500, detail="Failed to create catalog.")
+
+    catalog = await db.get_custom_catalog(catalog_id)
+    return {"message": "Catalog created successfully.", "catalog": catalog}
+
+
+async def update_custom_catalog_api(catalog_id: str, payload: dict):
+    name = payload.get("name")
+    visible = payload.get("visible") if "visible" in payload else None
+    result = await db.update_custom_catalog(catalog_id, name=name, visible=visible)
+    if not result:
+        catalog = await db.get_custom_catalog(catalog_id)
+        if not catalog:
+            raise HTTPException(status_code=404, detail="Catalog not found.")
+    return {"message": "Catalog updated successfully.", "catalog": await db.get_custom_catalog(catalog_id)}
+
+
+async def delete_custom_catalog_api(catalog_id: str):
+    result = await db.delete_custom_catalog(catalog_id)
+    if not result:
+        raise HTTPException(status_code=404, detail="Catalog not found.")
+    return {"message": "Catalog deleted successfully."}
+
+
+async def get_custom_catalog_items_api(
+    catalog_id: str,
+    media_type: str | None = None,
+    page: int = 1,
+    page_size: int = 24,
+):
+    try:
+        data = await db.get_custom_catalog_items(catalog_id, media_type, page, page_size)
+        if not data.get("catalog"):
+            raise HTTPException(status_code=404, detail="Catalog not found.")
+        return data
+    except HTTPException:
+        raise
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=str(e))
+
+
+async def search_catalog_media_api(
+    query: str,
+    media_type: str = "movie",
+    page: int = 1,
+    page_size: int = 12,
+):
+    query = (query or "").strip()
+    if not query:
+        return {"results": [], "total_count": 0}
+
+    try:
+        result = await db.search_documents(query, page, page_size)
+        normalized_type = _normalize_media_type(media_type)
+        filtered = [item for item in result.get("results", []) if item.get("media_type") == normalized_type]
+        return {"results": filtered, "total_count": len(filtered)}
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=str(e))
+
+
+async def add_custom_catalog_item_api(catalog_id: str, payload: dict):
+    tmdb_id = payload.get("tmdb_id")
+    db_index = payload.get("db_index")
+    media_type = _normalize_media_type(payload.get("media_type", "movie"))
+
+    if not tmdb_id or not db_index:
+        raise HTTPException(status_code=400, detail="tmdb_id and db_index are required.")
+
+    media = await db.get_document(media_type, int(tmdb_id), int(db_index))
+    if not media:
+        raise HTTPException(status_code=404, detail="Media not found.")
+
+    catalog = await db.get_custom_catalog(catalog_id)
+    if not catalog:
+        raise HTTPException(status_code=404, detail="Catalog not found.")
+
+    added = await db.add_item_to_custom_catalog(catalog_id, int(tmdb_id), int(db_index), media_type)
+    message = "Added to catalog." if added else "Already exists in this catalog."
+    return {"message": message, "added": added}
+
+
+async def remove_custom_catalog_item_api(
+    catalog_id: str,
+    tmdb_id: int,
+    db_index: int,
+    media_type: str,
+):
+    catalog = await db.get_custom_catalog(catalog_id)
+    if not catalog:
+        raise HTTPException(status_code=404, detail="Catalog not found.")
+
+    removed = await db.remove_item_from_custom_catalog(
+        catalog_id, int(tmdb_id), int(db_index), _normalize_media_type(media_type)
+    )
+    if not removed:
+        return {"message": "Item was not in this catalog.", "removed": False}
+    return {"message": "Removed from catalog.", "removed": True}

Backend/fastapi/routes/stremio_routes.py

@@ -159,6 +159,33 @@ async def get_manifest(token: str, token_data: dict = Depends(verify_token)):
             }
         ]
 
+        # Add visible custom catalogs to the Stremio home screen.
+        # Each custom catalog is exposed once for movies and once for series because
+        # Stremio catalogs are type-specific. Hidden catalogs remain manageable in the
+        # web panel, but are not included in the manifest.
+        try:
+            custom_catalogs = await db.get_custom_catalogs(visible_only=True)
+            for catalog in custom_catalogs:
+                catalog_id = str(catalog.get("_id"))
+                catalog_name = catalog.get("name") or "Custom Catalog"
+                catalogs.append({
+                    "type": "movie",
+                    "id": f"custom_{catalog_id}",
+                    "name": catalog_name,
+                    "extra": [{"name": "skip"}],
+                    "extraSupported": ["skip"],
+                })
+                catalogs.append({
+                    "type": "series",
+                    "id": f"custom_{catalog_id}",
+                    "name": catalog_name,
+                    "extra": [{"name": "skip"}],
+                    "extraSupported": ["skip"],
+                })
+        except Exception:
+            pass
+
+
     # Build dynamic name/description/version with subscription info
     addon_name = ADDON_NAME
     addon_desc = "Streams movies and series from your Telegram."
@@ -406,7 +433,21 @@ async def get_catalog(token: str, media_type: str, id: str, extra: Optional[str]
     page = (stremio_skip // PAGE_SIZE) + 1
 
     try:
-        if search_query:
+        if id.startswith("custom_"):
+            catalog_id = id.removeprefix("custom_")
+            catalog = await db.get_custom_catalog(catalog_id)
+            if not catalog or not catalog.get("visible", True):
+                return {"metas": []}
+
+            db_media_type = "tv" if media_type == "series" else "movie"
+            data = await db.get_custom_catalog_items(
+                catalog_id=catalog_id,
+                media_type=db_media_type,
+                page=page,
+                page_size=PAGE_SIZE,
+            )
+            items = data.get("items", [])
+        elif search_query:
             search_results = await db.search_documents(query=search_query, page=page, page_size=PAGE_SIZE)
             all_items = search_results.get("results", [])
             db_media_type = "tv" if media_type == "series" else "movie"

Backend/fastapi/templates/base.html

@@ -197,6 +197,7 @@ tailwind.config = {
         <div id="active-pill" class="pointer-events-none"></div>
         <a href="/" class="nav-link">Home</a>
         <a href="/media/manage" class="nav-link">Media</a>
+        <a href="/catalogs" class="nav-link">Catalogs</a>
         <a href="/admin/dashboard" class="nav-link">Admin</a>
         <a href="/admin/subscriptions" class="nav-link">Subs</a>
         <a href="/admin/access" class="nav-link">Access</a>
@@ -249,6 +250,7 @@ tailwind.config = {
         <div class="glass-panel mx-2 rounded-3xl p-4 flex flex-col gap-2">
             <a href="/" class="px-4 py-3 rounded-xl hover:bg-primary hover:text-background transition flex items-center gap-3 font-semibold"><i class="fa-solid fa-house"></i> Home</a>
             <a href="/media/manage" class="px-4 py-3 rounded-xl hover:bg-primary hover:text-background transition flex items-center gap-3 font-semibold"><i class="fa-solid fa-clapperboard"></i> Media</a>
+            <a href="/catalogs" class="px-4 py-3 rounded-xl hover:bg-primary hover:text-background transition flex items-center gap-3 font-semibold"><i class="fa-solid fa-layer-group"></i> Catalogs</a>
             <a href="/admin/dashboard" class="px-4 py-3 rounded-xl hover:bg-primary hover:text-background transition flex items-center gap-3 font-semibold"><i class="fa-solid fa-chart-line"></i> Admin</a>
             <a href="/admin/subscriptions" class="px-4 py-3 rounded-xl hover:bg-primary hover:text-background transition flex items-center gap-3 font-semibold"><i class="fa-solid fa-credit-card"></i> Subs</a>
             <a href="/admin/access" class="px-4 py-3 rounded-xl hover:bg-primary hover:text-background transition flex items-center gap-3 font-semibold"><i class="fa-solid fa-shield"></i> Access</a>

Backend/fastapi/templates/custom_catalogs.html

@@ -0,0 +1,627 @@
+{% extends "base.html" %}
+
+{% block title %}Custom Catalogs - Telegram Stremio{% endblock %}
+
+{% block content %}
+<style>
+  .catalog-page {
+    --soft-bg: color-mix(in srgb, var(--bg) 78%, transparent);
+    --card-bg: color-mix(in srgb, var(--card) 58%, transparent);
+    --card-bg-strong: color-mix(in srgb, var(--card) 82%, transparent);
+    --line: color-mix(in srgb, var(--border) 90%, transparent);
+    --primary-soft: color-mix(in srgb, var(--primary) 15%, transparent);
+    --accent-soft: color-mix(in srgb, var(--accent) 14%, transparent);
+  }
+
+  .glass-card {
+    position: relative;
+    overflow: hidden;
+    background: var(--card-bg);
+    border: 1px solid var(--line);
+    backdrop-filter: blur(22px);
+    box-shadow: 0 18px 50px rgba(0, 0, 0, 0.18);
+  }
+
+  .glass-card::before {
+    content: "";
+    position: absolute;
+    inset: 0;
+    pointer-events: none;
+    background:
+      radial-gradient(circle at 12% 0%, var(--primary-soft), transparent 36%),
+      radial-gradient(circle at 95% 10%, var(--accent-soft), transparent 34%);
+    opacity: .9;
+  }
+
+  .glass-card > * { position: relative; z-index: 1; }
+
+  .hero-card {
+    min-height: 15rem;
+    display: grid;
+    place-items: stretch;
+  }
+
+  .hero-orb {
+    width: 4.25rem;
+    height: 4.25rem;
+    border-radius: 9999px;
+    background: linear-gradient(135deg, var(--primary), var(--accent));
+    box-shadow: 0 0 45px color-mix(in srgb, var(--primary) 45%, transparent);
+    display: grid;
+    place-items: center;
+    color: var(--bg);
+  }
+
+  .section-title {
+    color: var(--text);
+    font-weight: 900;
+    letter-spacing: -0.035em;
+  }
+
+  .muted { color: var(--text-sec); }
+
+  .field-label {
+    display: block;
+    font-size: 0.875rem;
+    font-weight: 800;
+    margin-bottom: 0.55rem;
+    color: var(--text);
+  }
+
+  .field-input,
+  .field-select {
+    width: 100%;
+    border-radius: 1rem;
+    border: 1px solid var(--line);
+    background: color-mix(in srgb, var(--bg) 84%, var(--card) 16%);
+    color: var(--text);
+    padding: 0.9rem 1rem;
+    outline: none;
+    transition: all .2s ease;
+    box-shadow: inset 0 1px 0 color-mix(in srgb, var(--text) 5%, transparent);
+  }
+
+  .field-input::placeholder { color: color-mix(in srgb, var(--text-sec) 82%, transparent); }
+
+  .field-input:focus,
+  .field-select:focus {
+    border-color: var(--primary);
+    box-shadow: 0 0 0 4px color-mix(in srgb, var(--primary) 18%, transparent);
+  }
+
+  .btn-ui {
+    display: inline-flex;
+    align-items: center;
+    justify-content: center;
+    gap: .55rem;
+    border-radius: 1rem;
+    padding: .85rem 1.15rem;
+    font-weight: 900;
+    transition: all .2s ease;
+    border: 1px solid transparent;
+    white-space: nowrap;
+  }
+
+  .btn-ui:hover { transform: translateY(-1px); }
+  .btn-ui:active { transform: translateY(0) scale(.99); }
+
+  .btn-primary {
+    background: linear-gradient(135deg, var(--primary), var(--accent));
+    color: var(--bg);
+    box-shadow: 0 14px 28px color-mix(in srgb, var(--primary) 24%, transparent);
+  }
+
+  .btn-ghost {
+    background: color-mix(in srgb, var(--bg) 70%, transparent);
+    color: var(--text);
+    border-color: var(--line);
+  }
+
+  .btn-danger {
+    background: color-mix(in srgb, rgb(239 68 68) 16%, var(--card));
+    color: rgb(248 113 113);
+    border-color: color-mix(in srgb, rgb(239 68 68) 32%, var(--border));
+  }
+
+  .pill {
+    display: inline-flex;
+    align-items: center;
+    gap: .45rem;
+    padding: .42rem .85rem;
+    border-radius: 9999px;
+    font-size: .78rem;
+    font-weight: 900;
+    border: 1px solid var(--line);
+    background: color-mix(in srgb, var(--bg) 66%, transparent);
+    color: var(--text);
+  }
+
+  .stat-card,
+  .catalog-card,
+  .media-card,
+  .empty-state {
+    background: color-mix(in srgb, var(--bg) 72%, var(--card) 28%);
+    border: 1px solid var(--line);
+    border-radius: 1.45rem;
+    transition: transform .2s ease, border-color .2s ease, box-shadow .2s ease, background .2s ease;
+  }
+
+  .catalog-card:hover,
+  .media-card:hover {
+    transform: translateY(-2px);
+    border-color: color-mix(in srgb, var(--primary) 42%, var(--border));
+    box-shadow: 0 16px 34px rgba(0,0,0,.16);
+  }
+
+  .catalog-card.active {
+    border-color: var(--primary);
+    background:
+      linear-gradient(135deg, color-mix(in srgb, var(--primary) 13%, transparent), transparent),
+      color-mix(in srgb, var(--bg) 70%, var(--card) 30%);
+    box-shadow: 0 0 0 4px color-mix(in srgb, var(--primary) 14%, transparent);
+  }
+
+  .poster {
+    width: 4.25rem;
+    height: 6.35rem;
+    object-fit: cover;
+    border-radius: 1rem;
+    border: 1px solid color-mix(in srgb, var(--text) 12%, transparent);
+    background: color-mix(in srgb, var(--bg) 80%, transparent);
+    flex-shrink: 0;
+  }
+
+  .switch {
+    width: 3.1rem;
+    height: 1.7rem;
+    border-radius: 999px;
+    background: color-mix(in srgb, var(--border) 80%, transparent);
+    position: relative;
+    cursor: pointer;
+    transition: .2s ease;
+    border: 1px solid var(--line);
+  }
+
+  .switch::after {
+    content: "";
+    width: 1.25rem;
+    height: 1.25rem;
+    border-radius: 999px;
+    background: var(--text);
+    position: absolute;
+    left: .18rem;
+    top: .17rem;
+    transition: .2s ease;
+    box-shadow: 0 4px 12px rgba(0,0,0,.24);
+  }
+
+  .switch-input:checked + .switch {
+    background: linear-gradient(135deg, var(--primary), var(--accent));
+  }
+
+  .switch-input:checked + .switch::after {
+    left: 1.55rem;
+    background: var(--bg);
+  }
+
+  .mini-tab {
+    border-radius: 999px;
+    padding: .48rem .9rem;
+    border: 1px solid var(--line);
+    color: var(--text-sec);
+    background: color-mix(in srgb, var(--bg) 56%, transparent);
+    font-weight: 900;
+    font-size: .8rem;
+  }
+
+  .mini-tab.active {
+    color: var(--bg);
+    border-color: transparent;
+    background: linear-gradient(135deg, var(--primary), var(--accent));
+  }
+
+  .skeleton {
+    min-height: 5.5rem;
+    border-radius: 1.45rem;
+    background: linear-gradient(90deg,
+      color-mix(in srgb, var(--bg) 72%, var(--card) 28%),
+      color-mix(in srgb, var(--primary) 9%, var(--card)),
+      color-mix(in srgb, var(--bg) 72%, var(--card) 28%));
+    background-size: 220% 100%;
+    animation: shimmer 1.2s infinite linear;
+    border: 1px solid var(--line);
+  }
+
+  @keyframes shimmer {
+    to { background-position: -220% 0; }
+  }
+
+  @media (max-width: 640px) {
+    .hero-card { min-height: 13rem; }
+    .btn-ui { width: 100%; }
+  }
+</style>
+
+<div class="catalog-page max-w-7xl mx-auto px-4 sm:px-6 lg:px-8 py-5 sm:py-8 space-y-6">
+  <div class="glass-card hero-card rounded-3xl p-5 sm:p-7 lg:p-8">
+    <div class="flex flex-col lg:flex-row lg:items-center lg:justify-between gap-6">
+      <div class="flex flex-col sm:flex-row sm:items-center gap-5">
+        <div class="hero-orb text-3xl">🎞️</div>
+        <div>
+          <div class="flex flex-wrap items-center gap-2 mb-3">
+            <span class="pill">Custom Stremio sections</span>
+            <span class="pill">No Stremio search/filter</span>
+          </div>
+          <h1 class="section-title text-3xl sm:text-4xl lg:text-5xl">Custom Catalogs</h1>
+          <p class="muted mt-3 max-w-2xl text-sm sm:text-base leading-7">
+            Build dynamic curated rows like Bollywood, Anime, Kids, 4K, Watch Later, or hidden private lists from your existing Telegram media.
+          </p>
+        </div>
+      </div>
+
+      <div class="grid grid-cols-3 gap-3 min-w-full sm:min-w-[26rem] lg:min-w-[30rem]">
+        <div class="stat-card p-4 text-center">
+          <p id="stat-total" class="section-title text-2xl">0</p>
+          <p class="muted text-xs font-bold mt-1">Catalogs</p>
+        </div>
+        <div class="stat-card p-4 text-center">
+          <p id="stat-visible" class="section-title text-2xl">0</p>
+          <p class="muted text-xs font-bold mt-1">Visible</p>
+        </div>
+        <div class="stat-card p-4 text-center">
+          <p id="stat-items" class="section-title text-2xl">0</p>
+          <p class="muted text-xs font-bold mt-1">Titles</p>
+        </div>
+      </div>
+    </div>
+  </div>
+
+  <div class="grid grid-cols-1 xl:grid-cols-[0.88fr_1.12fr] gap-6">
+    <div class="space-y-6">
+      <div class="glass-card rounded-3xl p-5 sm:p-6">
+        <div class="flex items-start justify-between gap-3 mb-5">
+          <div>
+            <h2 class="section-title text-2xl">Create Catalog</h2>
+            <p class="muted text-sm mt-1">Visible catalogs appear in Stremio manifest. Hidden catalogs stay only in web panel.</p>
+          </div>
+          <span class="pill">New</span>
+        </div>
+
+        <form onsubmit="createCatalog(event)" class="space-y-4">
+          <div>
+            <label class="field-label">Catalog Name</label>
+            <input id="catalog-name" class="field-input" placeholder="Example: Bollywood Hits" required>
+          </div>
+
+          <label class="catalog-card p-4 flex items-center justify-between gap-4 cursor-pointer select-none">
+            <div>
+              <p class="font-black">Show in Stremio</p>
+              <p class="muted text-xs mt-1">Turn off to keep this catalog private in web panel.</p>
+            </div>
+            <input id="catalog-visible" type="checkbox" checked class="switch-input hidden">
+            <span class="switch"></span>
+          </label>
+
+          <button class="btn-ui btn-primary w-full" type="submit">➕ Create Catalog</button>
+        </form>
+      </div>
+
+      <div class="glass-card rounded-3xl p-5 sm:p-6">
+        <div class="flex items-center justify-between gap-3 mb-5">
+          <div>
+            <h2 class="section-title text-2xl">Your Catalogs</h2>
+            <p class="muted text-sm mt-1">Select one to manage titles.</p>
+          </div>
+          <button onclick="loadCatalogs()" class="btn-ui btn-ghost px-3 py-2 text-sm">↻</button>
+        </div>
+        <div id="catalog-list" class="space-y-3">
+          <div class="skeleton"></div>
+          <div class="skeleton"></div>
+        </div>
+      </div>
+    </div>
+
+    <div class="glass-card rounded-3xl p-5 sm:p-6">
+      <div class="flex flex-col md:flex-row md:items-start md:justify-between gap-3 mb-5">
+        <div>
+          <div class="flex flex-wrap gap-2 mb-3">
+            <span id="selected-visibility-pill" class="pill hidden"></span>
+            <span id="selected-count-pill" class="pill hidden"></span>
+          </div>
+          <h2 id="selected-title" class="section-title text-2xl">Select a catalog</h2>
+          <p id="selected-subtitle" class="muted text-sm mt-1">Choose a catalog from the left side to add or remove titles.</p>
+        </div>
+        <button id="delete-catalog-btn" onclick="deleteSelectedCatalog()" class="btn-ui btn-danger hidden md:w-auto">Delete Catalog</button>
+      </div>
+
+      <div id="catalog-empty-guide" class="empty-state p-6 sm:p-8 text-center">
+        <div class="text-4xl mb-3">📚</div>
+        <h3 class="section-title text-xl">No catalog selected</h3>
+        <p class="muted mt-2 text-sm leading-6">Create a catalog or select an existing one. Then search from your existing media library and add titles instantly.</p>
+      </div>
+
+      <div id="catalog-workspace" class="hidden space-y-6">
+        <div class="catalog-card p-4 sm:p-5">
+          <div class="flex flex-col sm:flex-row sm:items-end gap-3">
+            <div class="flex-1">
+              <label class="field-label">Search existing media</label>
+              <input id="search-query" class="field-input" placeholder="Search title to add..." onkeydown="if(event.key === 'Enter') searchMedia()">
+            </div>
+            <div class="sm:w-44">
+              <label class="field-label">Type</label>
+              <select id="search-media-type" class="field-select">
+                <option value="movie">Movie</option>
+                <option value="tv">Series</option>
+              </select>
+            </div>
+            <button onclick="searchMedia()" class="btn-ui btn-primary sm:w-auto">🔎 Search</button>
+          </div>
+        </div>
+
+        <div id="search-results-wrap" class="hidden">
+          <div class="flex items-center justify-between gap-3 mb-3">
+            <h3 class="section-title text-lg">Search Results</h3>
+            <button onclick="clearSearchResults()" class="mini-tab">Clear</button>
+          </div>
+          <div id="search-results" class="grid grid-cols-1 lg:grid-cols-2 gap-3"></div>
+        </div>
+
+        <div class="border-t pt-5" style="border-color: var(--line);">
+          <div class="flex flex-col sm:flex-row sm:items-center sm:justify-between gap-3 mb-3">
+            <div>
+              <h3 class="section-title text-lg">Titles in this catalog</h3>
+              <p class="muted text-xs mt-1">These are shown in Stremio when the catalog is visible.</p>
+            </div>
+            <button onclick="loadCatalogItems()" class="btn-ui btn-ghost px-3 py-2 text-sm sm:w-auto">Refresh</button>
+          </div>
+          <div id="catalog-items" class="grid grid-cols-1 lg:grid-cols-2 gap-3"></div>
+        </div>
+      </div>
+    </div>
+  </div>
+</div>
+
+<script>
+let catalogs = [];
+let selectedCatalogId = null;
+
+function posterOrFallback(item) {
+  return item.poster || 'https://via.placeholder.com/120x180/111827/94a3b8?text=No+Poster';
+}
+
+function escapeHtml(value) {
+  const div = document.createElement('div');
+  div.textContent = value == null ? '' : String(value);
+  return div.innerHTML;
+}
+
+function getSelectedCatalog() {
+  return catalogs.find(c => c._id === selectedCatalogId);
+}
+
+function updateStats() {
+  const total = catalogs.length;
+  const visible = catalogs.filter(c => c.visible).length;
+  const items = catalogs.reduce((sum, c) => sum + ((c.items || []).length), 0);
+  document.getElementById('stat-total').textContent = total;
+  document.getElementById('stat-visible').textContent = visible;
+  document.getElementById('stat-items').textContent = items;
+}
+
+function mediaCard(item, actionHtml) {
+  const mediaType = item.media_type === 'tv' ? 'Series' : 'Movie';
+  const genres = Array.isArray(item.genres) ? item.genres.slice(0, 2).join(' · ') : '';
+  return `<div class="media-card p-3 flex gap-3">
+    <img src="${escapeHtml(posterOrFallback(item))}" class="poster" onerror="this.src='https://via.placeholder.com/120x180/111827/94a3b8?text=No+Poster'" alt="Poster">
+    <div class="min-w-0 flex-1">
+      <div class="flex items-start justify-between gap-2">
+        <div class="min-w-0">
+          <h4 class="font-black truncate" title="${escapeHtml(item.title)}">${escapeHtml(item.title)}</h4>
+          <p class="muted text-xs mt-1">${mediaType} · ${escapeHtml(item.release_year || 'Unknown')} · TMDb ${escapeHtml(item.tmdb_id || '')}</p>
+        </div>
+        <span class="pill text-[0.68rem] py-1 px-2">${escapeHtml(mediaType)}</span>
+      </div>
+      ${genres ? `<p class="muted text-xs mt-2 truncate">${escapeHtml(genres)}</p>` : ''}
+      <div class="mt-3">${actionHtml}</div>
+    </div>
+  </div>`;
+}
+
+function emptyState(icon, title, message) {
+  return `<div class="empty-state p-6 text-center col-span-full">
+    <div class="text-3xl mb-2">${icon}</div>
+    <h4 class="section-title text-lg">${escapeHtml(title)}</h4>
+    <p class="muted text-sm mt-1">${escapeHtml(message)}</p>
+  </div>`;
+}
+
+async function loadCatalogs() {
+  const box = document.getElementById('catalog-list');
+  box.innerHTML = '<div class="skeleton"></div><div class="skeleton"></div>';
+  try {
+    const res = await fetch('/api/custom-catalogs');
+    const data = await res.json().catch(() => ({}));
+    if (!res.ok) throw new Error(data.detail || 'Failed to load catalogs');
+    catalogs = data.catalogs || [];
+    if (selectedCatalogId && !catalogs.some(c => c._id === selectedCatalogId)) selectedCatalogId = null;
+    updateStats();
+    renderCatalogs();
+    updateSelectedHeader();
+  } catch (error) {
+    box.innerHTML = emptyState('⚠️', 'Unable to load catalogs', error.message || 'Please refresh and try again.');
+    showToast(error.message || 'Unable to load catalogs', 'error', 'Error');
+  }
+}
+
+function renderCatalogs() {
+  const box = document.getElementById('catalog-list');
+  if (!catalogs.length) {
+    box.innerHTML = emptyState('✨', 'No custom catalog yet', 'Create your first curated Stremio section above.');
+    return;
+  }
+  box.innerHTML = catalogs.map(c => {
+    const isActive = c._id === selectedCatalogId;
+    const count = (c.items || []).length;
+    return `<div class="catalog-card p-4 ${isActive ? 'active' : ''}">
+      <div class="flex items-start justify-between gap-3">
+        <button class="text-left min-w-0 flex-1" onclick="selectCatalog('${c._id}')">
+          <div class="flex items-center gap-2 min-w-0">
+            <span class="text-xl">${c.visible ? '🌐' : '🔒'}</span>
+            <h3 class="font-black truncate">${escapeHtml(c.name)}</h3>
+          </div>
+          <p class="muted text-xs mt-2">${count} title${count === 1 ? '' : 's'} · ${c.visible ? 'Visible in Stremio' : 'Hidden from Stremio'}</p>
+        </button>
+        <label class="flex items-center gap-2 shrink-0" title="Toggle Stremio visibility">
+          <input type="checkbox" ${c.visible ? 'checked' : ''} onchange="toggleVisibility('${c._id}', this.checked)" class="switch-input hidden">
+          <span class="switch"></span>
+        </label>
+      </div>
+    </div>`;
+  }).join('');
+}
+
+function updateSelectedHeader() {
+  const catalog = getSelectedCatalog();
+  const workspace = document.getElementById('catalog-workspace');
+  const guide = document.getElementById('catalog-empty-guide');
+  const deleteBtn = document.getElementById('delete-catalog-btn');
+  const visibilityPill = document.getElementById('selected-visibility-pill');
+  const countPill = document.getElementById('selected-count-pill');
+
+  if (!catalog) {
+    workspace.classList.add('hidden');
+    guide.classList.remove('hidden');
+    deleteBtn.classList.add('hidden');
+    visibilityPill.classList.add('hidden');
+    countPill.classList.add('hidden');
+    document.getElementById('selected-title').textContent = 'Select a catalog';
+    document.getElementById('selected-subtitle').textContent = 'Choose a catalog from the left side to add or remove titles.';
+    return;
+  }
+
+  workspace.classList.remove('hidden');
+  guide.classList.add('hidden');
+  deleteBtn.classList.remove('hidden');
+  visibilityPill.classList.remove('hidden');
+  countPill.classList.remove('hidden');
+  visibilityPill.textContent = catalog.visible ? '🌐 Visible in Stremio' : '🔒 Hidden from Stremio';
+  countPill.textContent = `${(catalog.items || []).length} title${(catalog.items || []).length === 1 ? '' : 's'}`;
+  document.getElementById('selected-title').textContent = catalog.name || 'Selected Catalog';
+  document.getElementById('selected-subtitle').textContent = catalog.visible
+    ? 'This catalog appears on the Stremio catalog screen.'
+    : 'This catalog is private in the web panel and hidden from Stremio.';
+}
+
+async function createCatalog(event) {
+  event.preventDefault();
+  const name = document.getElementById('catalog-name').value.trim();
+  const visible = document.getElementById('catalog-visible').checked;
+  if (!name) return showToast('Catalog name is required', 'error', 'Error');
+  const res = await fetch('/api/custom-catalogs', {
+    method: 'POST', headers: {'Content-Type': 'application/json'}, body: JSON.stringify({name, visible})
+  });
+  const data = await res.json().catch(() => ({}));
+  if (!res.ok) return showToast(data.detail || 'Failed to create catalog', 'error', 'Error');
+  document.getElementById('catalog-name').value = '';
+  showToast('Catalog created', 'success', 'Success');
+  await loadCatalogs();
+}
+
+async function toggleVisibility(id, visible) {
+  const catalog = catalogs.find(c => c._id === id);
+  const res = await fetch(`/api/custom-catalogs/${id}`, {
+    method: 'PUT', headers: {'Content-Type': 'application/json'}, body: JSON.stringify({name: catalog?.name, visible})
+  });
+  const data = await res.json().catch(() => ({}));
+  if (!res.ok) showToast(data.detail || 'Failed to update visibility', 'error', 'Error');
+  await loadCatalogs();
+}
+
+async function selectCatalog(id) {
+  selectedCatalogId = id;
+  renderCatalogs();
+  updateSelectedHeader();
+  await loadCatalogItems();
+}
+
+async function searchMedia() {
+  if (!selectedCatalogId) return showToast('Select a catalog first.', 'error', 'Error');
+  const q = document.getElementById('search-query').value.trim();
+  const mediaType = document.getElementById('search-media-type').value;
+  if (!q) return showToast('Type a title to search.', 'error', 'Error');
+  const wrap = document.getElementById('search-results-wrap');
+  const box = document.getElementById('search-results');
+  wrap.classList.remove('hidden');
+  box.innerHTML = '<div class="skeleton"></div><div class="skeleton"></div>';
+  try {
+    const res = await fetch(`/api/custom-catalogs/search-media?query=${encodeURIComponent(q)}&media_type=${mediaType}`);
+    const data = await res.json().catch(() => ({}));
+    if (!res.ok) throw new Error(data.detail || 'Search failed');
+    const results = data.results || [];
+    box.innerHTML = results.length
+      ? results.map(item => mediaCard(item, `<button class="btn-ui btn-primary px-3 py-2 text-sm" onclick="addItem(${item.tmdb_id}, ${item.db_index}, '${item.media_type}')">Add</button>`)).join('')
+      : emptyState('🔍', 'No title found', 'Try a shorter title or change movie/series type.');
+  } catch (error) {
+    box.innerHTML = emptyState('⚠️', 'Search failed', error.message || 'Please try again.');
+  }
+}
+
+function clearSearchResults() {
+  document.getElementById('search-results-wrap').classList.add('hidden');
+  document.getElementById('search-results').innerHTML = '';
+}
+
+async function addItem(tmdbId, dbIndex, mediaType) {
+  const res = await fetch(`/api/custom-catalogs/${selectedCatalogId}/items`, {
+    method: 'POST', headers: {'Content-Type': 'application/json'}, body: JSON.stringify({tmdb_id: tmdbId, db_index: dbIndex, media_type: mediaType})
+  });
+  const data = await res.json().catch(() => ({}));
+  if (!res.ok) return showToast(data.detail || 'Failed to add title', 'error', 'Error');
+  showToast(data.message || 'Added', 'success', 'Success');
+  await loadCatalogs();
+  await loadCatalogItems();
+}
+
+async function loadCatalogItems() {
+  if (!selectedCatalogId) return;
+  const box = document.getElementById('catalog-items');
+  box.innerHTML = '<div class="skeleton"></div><div class="skeleton"></div>';
+  try {
+    const res = await fetch(`/api/custom-catalogs/${selectedCatalogId}/items?page_size=100`);
+    const data = await res.json().catch(() => ({}));
+    if (!res.ok) throw new Error(data.detail || 'Failed to load catalog items');
+    const items = data.items || [];
+    box.innerHTML = items.length
+      ? items.map(item => mediaCard(item, `<button class="btn-ui btn-danger px-3 py-2 text-sm" onclick="removeItem(${item.tmdb_id}, ${item.db_index}, '${item.media_type}')">Remove</button>`)).join('')
+      : emptyState('➕', 'No titles added yet', 'Use search above to add media to this catalog.');
+  } catch (error) {
+    box.innerHTML = emptyState('⚠️', 'Unable to load titles', error.message || 'Please try again.');
+  }
+}
+
+async function removeItem(tmdbId, dbIndex, mediaType) {
+  const url = `/api/custom-catalogs/${selectedCatalogId}/items?tmdb_id=${tmdbId}&db_index=${dbIndex}&media_type=${mediaType}`;
+  const res = await fetch(url, { method: 'DELETE' });
+  const data = await res.json().catch(() => ({}));
+  if (!res.ok) return showToast(data.detail || 'Failed to remove title', 'error', 'Error');
+  showToast(data.message || 'Removed', 'success', 'Success');
+  await loadCatalogs();
+  await loadCatalogItems();
+}
+
+async function deleteSelectedCatalog() {
+  if (!selectedCatalogId) return;
+  if (!confirm('Delete this custom catalog? Titles will not be deleted from your media library.')) return;
+  const res = await fetch(`/api/custom-catalogs/${selectedCatalogId}`, { method: 'DELETE' });
+  const data = await res.json().catch(() => ({}));
+  if (!res.ok) return showToast(data.detail || 'Failed to delete catalog', 'error', 'Error');
+  selectedCatalogId = null;
+  clearSearchResults();
+  updateSelectedHeader();
+  showToast('Catalog deleted', 'success', 'Success');
+  await loadCatalogs();
+}
+
+document.addEventListener('DOMContentLoaded', loadCatalogs);
+</script>
+{% endblock %}

Backend/fastapi/templates/media_edit.html

@@ -366,6 +366,32 @@
     </div>
     {% endif %}
 
+
+    {% if media_details %}
+    <div class="glass-card rounded-3xl p-5 sm:p-6 lg:p-8 mb-6 sm:mb-8">
+        <div class="flex flex-col lg:flex-row lg:items-end lg:justify-between gap-3 mb-5 sm:mb-6">
+            <div>
+                <h3 class="section-title text-xl sm:text-2xl">Custom Catalog</h3>
+                <p class="muted mt-1 text-sm sm:text-base">Add this title directly into any custom Stremio catalog.</p>
+            </div>
+            <a href="/catalogs" class="btn-ui btn-ghost">Manage Catalogs</a>
+        </div>
+
+        <div class="grid grid-cols-1 lg:grid-cols-[1fr_auto_auto] gap-3">
+            <select id="custom-catalog-select" class="field-input">
+                <option value="">Loading catalogs...</option>
+            </select>
+            <button type="button" onclick="addCurrentMediaToCatalog()" class="btn-ui btn-primary">
+                ➕ Add to Catalog
+            </button>
+            <button type="button" onclick="removeCurrentMediaFromCatalog()" class="btn-ui btn-danger">
+                Remove
+            </button>
+        </div>
+        <p id="custom-catalog-status" class="muted text-sm mt-3">Only visible catalogs appear in Stremio. Hidden catalogs remain manageable in web panel.</p>
+    </div>
+    {% endif %}
+
     <div class="glass-card rounded-3xl p-5 sm:p-6 lg:p-8 mb-6 sm:mb-8">
         <div class="flex items-center justify-between gap-3 mb-5 sm:mb-6">
             <h3 class="section-title text-xl sm:text-2xl">Edit Details</h3>
@@ -977,7 +1003,144 @@
         return sessionStorage.getItem('api_token') || localStorage.getItem('api_token') || null;
     }
 
+
+    const CURRENT_TMDB_ID = Number("{{ tmdb_id }}");
+    const CURRENT_DB_INDEX = Number("{{ db_index }}");
+    const CURRENT_MEDIA_TYPE = "{{ media_type }}";
+
+    function setCatalogStatus(message, type = 'info') {
+        const status = document.getElementById('custom-catalog-status');
+        if (!status) return;
+        status.textContent = message;
+        status.classList.remove('text-emerald-300', 'text-rose-300', 'text-amber-300');
+        if (type === 'success') status.classList.add('text-emerald-300');
+        if (type === 'error') status.classList.add('text-rose-300');
+        if (type === 'warn') status.classList.add('text-amber-300');
+    }
+
+    async function loadMediaCatalogDropdown(selectedCatalogId = '') {
+        const select = document.getElementById('custom-catalog-select');
+        if (!select) return;
+
+        select.disabled = true;
+        select.innerHTML = '<option value="">Loading catalogs...</option>';
+        setCatalogStatus('Loading custom catalogs...');
+
+        try {
+            const params = new URLSearchParams({
+                tmdb_id: String(CURRENT_TMDB_ID),
+                db_index: String(CURRENT_DB_INDEX),
+                media_type: CURRENT_MEDIA_TYPE
+            });
+            const res = await fetch(`/api/custom-catalogs?${params.toString()}`);
+            const data = await res.json().catch(() => ({}));
+
+            if (!res.ok) {
+                throw new Error(data.detail || 'Failed to load catalogs');
+            }
+
+            const catalogs = data.catalogs || [];
+            if (!catalogs.length) {
+                select.innerHTML = '<option value="">No custom catalog found</option>';
+                setCatalogStatus('Create a catalog first from Manage Catalogs.', 'warn');
+                return;
+            }
+
+            select.innerHTML = catalogs.map(catalog => {
+                const visibility = catalog.visible ? 'Visible' : 'Hidden';
+                const added = catalog.contains_current ? ' · Added' : '';
+                return `<option value="${escapeHtml(catalog._id)}" data-visible="${catalog.visible ? '1' : '0'}" data-added="${catalog.contains_current ? '1' : '0'}">${escapeHtml(catalog.name)} (${visibility}${added})</option>`;
+            }).join('');
+
+            if (selectedCatalogId && catalogs.some(c => c._id === selectedCatalogId)) {
+                select.value = selectedCatalogId;
+            }
+
+            select.disabled = false;
+            updateCatalogDropdownStatus();
+        } catch (error) {
+            select.innerHTML = '<option value="">Failed to load catalogs</option>';
+            setCatalogStatus(error.message || 'Failed to load custom catalogs.', 'error');
+            showToast(error.message || 'Failed to load custom catalogs', 'error', 'Error');
+        }
+    }
+
+    function updateCatalogDropdownStatus() {
+        const select = document.getElementById('custom-catalog-select');
+        if (!select || !select.value) return;
+
+        const option = select.options[select.selectedIndex];
+        const isVisible = option?.dataset.visible === '1';
+        const isAdded = option?.dataset.added === '1';
+
+        if (isAdded) {
+            setCatalogStatus(`This title is already added to ${option.textContent.replace(' · Added', '')}.`, 'success');
+        } else if (!isVisible) {
+            setCatalogStatus('This catalog is hidden from Stremio main catalog screen, but you can still manage it here.', 'warn');
+        } else {
+            setCatalogStatus('This visible catalog will appear in Stremio main catalog screen.', 'info');
+        }
+    }
+
+    async function addCurrentMediaToCatalog() {
+        const select = document.getElementById('custom-catalog-select');
+        const catalogId = select?.value;
+        if (!catalogId) {
+            showToast('Please select a catalog first.', 'error', 'Error');
+            return;
+        }
+
+        try {
+            const res = await fetch(`/api/custom-catalogs/${catalogId}/items`, {
+                method: 'POST',
+                headers: {'Content-Type': 'application/json'},
+                body: JSON.stringify({
+                    tmdb_id: CURRENT_TMDB_ID,
+                    db_index: CURRENT_DB_INDEX,
+                    media_type: CURRENT_MEDIA_TYPE
+                })
+            });
+            const data = await res.json().catch(() => ({}));
+            if (!res.ok) throw new Error(data.detail || 'Failed to add title to catalog');
+
+            showToast(data.message || 'Added to catalog.', 'success', 'Success');
+            await loadMediaCatalogDropdown(catalogId);
+        } catch (error) {
+            showToast(error.message || 'Failed to add title to catalog', 'error', 'Error');
+            setCatalogStatus(error.message || 'Failed to add title to catalog.', 'error');
+        }
+    }
+
+    async function removeCurrentMediaFromCatalog() {
+        const select = document.getElementById('custom-catalog-select');
+        const catalogId = select?.value;
+        if (!catalogId) {
+            showToast('Please select a catalog first.', 'error', 'Error');
+            return;
+        }
+
+        try {
+            const params = new URLSearchParams({
+                tmdb_id: String(CURRENT_TMDB_ID),
+                db_index: String(CURRENT_DB_INDEX),
+                media_type: CURRENT_MEDIA_TYPE
+            });
+            const res = await fetch(`/api/custom-catalogs/${catalogId}/items?${params.toString()}`, {method: 'DELETE'});
+            const data = await res.json().catch(() => ({}));
+            if (!res.ok) throw new Error(data.detail || 'Failed to remove title from catalog');
+
+            showToast(data.message || 'Removed from catalog.', data.removed === false ? 'info' : 'success', 'Done');
+            await loadMediaCatalogDropdown(catalogId);
+        } catch (error) {
+            showToast(error.message || 'Failed to remove title from catalog', 'error', 'Error');
+            setCatalogStatus(error.message || 'Failed to remove title from catalog.', 'error');
+        }
+    }
+
     document.addEventListener('DOMContentLoaded', () => {
+        const select = document.getElementById('custom-catalog-select');
+        if (select) select.addEventListener('change', updateCatalogDropdownStatus);
+        loadMediaCatalogDropdown();
         document.querySelectorAll('.season-content').forEach((content, index) => {
             if (index > 0) {
                 content.classList.add('season-collapsed');

Backend/helper/database.py

@@ -290,6 +290,177 @@ class Database:
         }
 
 
+
+
+    # -------------------------------
+    # Custom Catalog Management
+    # -------------------------------
+    async def create_custom_catalog(self, name: str, visible: bool = True) -> Optional[str]:
+        name = (name or "").strip()
+        if not name:
+            return None
+
+        now = datetime.utcnow()
+        result = await self.dbs["tracking"]["custom_catalogs"].insert_one({
+            "name": name,
+            "visible": bool(visible),
+            "items": [],
+            "created_at": now,
+            "updated_at": now,
+        })
+        return str(result.inserted_id)
+
+    async def get_custom_catalogs(self, visible_only: bool = False) -> List[dict]:
+        query = {"visible": True} if visible_only else {}
+        cursor = self.dbs["tracking"]["custom_catalogs"].find(query).sort("updated_at", DESCENDING)
+        catalogs = await cursor.to_list(None)
+        return [convert_objectid_to_str(catalog) for catalog in catalogs]
+
+    async def get_custom_catalog(self, catalog_id: str) -> Optional[dict]:
+        try:
+            catalog = await self.dbs["tracking"]["custom_catalogs"].find_one({"_id": ObjectId(catalog_id)})
+            return convert_objectid_to_str(catalog) if catalog else None
+        except Exception:
+            return None
+
+    async def update_custom_catalog(self, catalog_id: str, name: Optional[str] = None, visible: Optional[bool] = None) -> bool:
+        update_data = {"updated_at": datetime.utcnow()}
+        if name is not None:
+            clean_name = name.strip()
+            if clean_name:
+                update_data["name"] = clean_name
+        if visible is not None:
+            update_data["visible"] = bool(visible)
+
+        try:
+            result = await self.dbs["tracking"]["custom_catalogs"].update_one(
+                {"_id": ObjectId(catalog_id)},
+                {"$set": update_data}
+            )
+            return result.modified_count > 0
+        except Exception:
+            return False
+
+    async def delete_custom_catalog(self, catalog_id: str) -> bool:
+        try:
+            result = await self.dbs["tracking"]["custom_catalogs"].delete_one({"_id": ObjectId(catalog_id)})
+            return result.deleted_count > 0
+        except Exception:
+            return False
+
+    async def add_item_to_custom_catalog(
+        self, catalog_id: str, tmdb_id: int, db_index: int, media_type: str
+    ) -> bool:
+        media_type = "tv" if media_type in ["tv", "series"] else "movie"
+        item = {
+            "tmdb_id": int(tmdb_id),
+            "db_index": int(db_index),
+            "media_type": media_type,
+            "added_at": datetime.utcnow(),
+        }
+        try:
+            result = await self.dbs["tracking"]["custom_catalogs"].update_one(
+                {
+                    "_id": ObjectId(catalog_id),
+                    "items": {
+                        "$not": {
+                            "$elemMatch": {
+                                "tmdb_id": int(tmdb_id),
+                                "db_index": int(db_index),
+                                "media_type": media_type,
+                            }
+                        }
+                    },
+                },
+                {
+                    "$push": {"items": {"$each": [item], "$position": 0}},
+                    "$set": {"updated_at": datetime.utcnow()},
+                }
+            )
+            return result.modified_count > 0
+        except Exception:
+            return False
+
+    async def remove_item_from_custom_catalog(
+        self, catalog_id: str, tmdb_id: int, db_index: int, media_type: str
+    ) -> bool:
+        media_type = "tv" if media_type in ["tv", "series"] else "movie"
+        try:
+            result = await self.dbs["tracking"]["custom_catalogs"].update_one(
+                {"_id": ObjectId(catalog_id)},
+                {
+                    "$pull": {
+                        "items": {
+                            "tmdb_id": int(tmdb_id),
+                            "db_index": int(db_index),
+                            "media_type": media_type,
+                        }
+                    },
+                    "$set": {"updated_at": datetime.utcnow()},
+                }
+            )
+            return result.modified_count > 0
+        except Exception:
+            return False
+
+    async def custom_catalog_contains_item(
+        self, catalog_id: str, tmdb_id: int, db_index: int, media_type: str
+    ) -> bool:
+        media_type = "tv" if media_type in ["tv", "series"] else "movie"
+        try:
+            catalog = await self.dbs["tracking"]["custom_catalogs"].find_one({
+                "_id": ObjectId(catalog_id),
+                "items": {
+                    "$elemMatch": {
+                        "tmdb_id": int(tmdb_id),
+                        "db_index": int(db_index),
+                        "media_type": media_type,
+                    }
+                }
+            })
+            return bool(catalog)
+        except Exception:
+            return False
+
+    async def get_custom_catalog_items(
+        self, catalog_id: str, media_type: Optional[str] = None, page: int = 1, page_size: int = 24
+    ) -> dict:
+        catalog = await self.get_custom_catalog(catalog_id)
+        if not catalog:
+            return {"catalog": None, "items": [], "total_count": 0, "current_page": page, "total_pages": 0}
+
+        db_media_type = None
+        if media_type:
+            db_media_type = "tv" if media_type in ["tv", "series"] else "movie"
+
+        raw_items = catalog.get("items", []) or []
+        if db_media_type:
+            raw_items = [item for item in raw_items if item.get("media_type") == db_media_type]
+
+        total_count = len(raw_items)
+        skip = (page - 1) * page_size
+        selected_items = raw_items[skip:skip + page_size]
+
+        hydrated_items = []
+        for item in selected_items:
+            doc = await self.get_document(
+                item.get("media_type", "movie"),
+                int(item.get("tmdb_id")),
+                int(item.get("db_index", 1))
+            )
+            if doc:
+                hydrated_items.append(doc)
+
+        total_pages = (total_count + page_size - 1) // page_size if total_count else 0
+        return {
+            "catalog": catalog,
+            "items": hydrated_items,
+            "total_count": total_count,
+            "current_page": page,
+            "total_pages": total_pages,
+        }
+
+
     # -------------------------------
     # Helper Methods for Repeated Logic
     # -------------------------------

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "Telegram-Stremio"
-version = "2.2.0"
+version = "3.0.0"
 description = "A powerful, self-hosted Telegram Stremio Media Server built with FastAPI, MongoDB, and PyroFork seamlessly integrated with Stremio for automated media streaming and discovery."
 readme = "README.md"
 requires-python = ">=3.11"