`🚀 V1.5.0 Release`

### New Features & Improvements:

📂 **Flexible Quality Storage:** Supports storing multiple files of the same quality when replace mode is disabled.

### Fixes:

🐛 **Quality Deletion Fix:** Deleting a quality now removes only the selected file instead of all files with the same quality.
📖 **Documentation Fix:** Corrected and clarified `REPLACE_MODE` explanation in README.

### ⚙️ Configuration:

```env
REPLACE_MODE=true # Replace old files of same quality (false = allow duplicates)
```

Backend/__init__.py

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

Backend/config.py

@@ -21,6 +21,7 @@ class Telegram:
     UPSTREAM_BRANCH = getenv("UPSTREAM_BRANCH", "")
 
     OWNER_ID = int(getenv("OWNER_ID", "5422223708"))
+    REPLACE_MODE = getenv("REPLACE_MODE", "true").lower() == "true"
 
     ADMIN_USERNAME = getenv("ADMIN_USERNAME", "fyvio")
     ADMIN_PASSWORD = getenv("ADMIN_PASSWORD", "fyvio")

Backend/fastapi/main.py

@@ -4,7 +4,6 @@ from fastapi.middleware.cors import CORSMiddleware
 from fastapi.staticfiles import StaticFiles
 from starlette.middleware.sessions import SessionMiddleware
 from Backend import __version__
-
 from Backend.fastapi.security.credentials import require_auth
 from Backend.fastapi.routes.stream_routes import router as stream_router
 from Backend.fastapi.routes.stremio_routes import router as stremio_router
@@ -37,7 +36,7 @@ app.add_middleware(
 try:
     app.mount("/static", StaticFiles(directory="Backend/fastapi/static"), name="static")
 except Exception:
-    pass 
+    pass
 
 # --- Include existing API routers ---
 app.include_router(stream_router)
@@ -83,9 +82,9 @@ async def edit_media(request: Request, tmdb_id: int, db_index: int, media_type:
 
 @app.get("/api/media/list")
 async def list_media(
-    media_type: str = Query("movie", regex="^(movie|tv)$"), 
-    page: int = Query(1, ge=1), 
-    page_size: int = Query(24, ge=1, le=100), 
+    media_type: str = Query("movie", regex="^(movie|tv)$"),
+    page: int = Query(1, ge=1),
+    page_size: int = Query(24, ge=1, le=100),
     search: str = Query("", max_length=100),
     _: bool = Depends(require_auth)
 ):
@@ -100,12 +99,12 @@ async def update_media(request: Request, tmdb_id: int, db_index: int, media_type
     return await update_media_api(request, tmdb_id, db_index, media_type)
 
 @app.delete("/api/media/delete-quality")
-async def delete_movie_quality(tmdb_id: int, db_index: int, quality: str, _: bool = Depends(require_auth)):
-    return await delete_movie_quality_api(tmdb_id, db_index, quality)
+async def delete_movie_quality(tmdb_id: int, db_index: int, id: str, _: bool = Depends(require_auth)):
+    return await delete_movie_quality_api(tmdb_id, db_index, id)
 
 @app.delete("/api/media/delete-tv-quality")
-async def delete_tv_quality(tmdb_id: int, db_index: int, season: int, episode: int, quality: str, _: bool = Depends(require_auth)):
-    return await delete_tv_quality_api(tmdb_id, db_index, season, episode, quality)
+async def delete_tv_quality(tmdb_id: int, db_index: int, season: int, episode: int, id: str, _: bool = Depends(require_auth)):
+    return await delete_tv_quality_api(tmdb_id, db_index, season, episode, id)
 
 @app.delete("/api/media/delete-tv-episode")
 async def delete_tv_episode(tmdb_id: int, db_index: int, season: int, episode: int, _: bool = Depends(require_auth)):
@@ -115,7 +114,6 @@ async def delete_tv_episode(tmdb_id: int, db_index: int, season: int, episode: i
 async def delete_tv_season(tmdb_id: int, db_index: int, season: int, _: bool = Depends(require_auth)):
     return await delete_tv_season_api(tmdb_id, db_index, season)
 
-
 @app.get("/api/system/workloads")
 async def get_workloads(_: bool = Depends(require_auth)):
     try:
@@ -131,7 +129,6 @@ async def get_workloads(_: bool = Depends(require_auth)):
     except Exception as e:
         return {"loads": {}}
 
-
 @app.exception_handler(401)
 async def auth_exception_handler(request: Request, exc):
-    return RedirectResponse(url="/login", status_code=302)
+    return RedirectResponse(url="/login", status_code=302)

Backend/fastapi/routes/api_routes.py

@@ -119,9 +119,9 @@ async def get_media_details_api(
     except Exception as e:
         raise HTTPException(status_code=500, detail=str(e))
 
-async def delete_movie_quality_api(tmdb_id: int, db_index: int, quality: str):
+async def delete_movie_quality_api(tmdb_id: int, db_index: int, id: str):
     try:
-        result = await db.delete_movie_quality(tmdb_id, db_index, quality)
+        result = await db.delete_movie_quality(tmdb_id, db_index, id)
         if result:
             return {"message": "Quality deleted successfully"}
         else:
@@ -130,12 +130,12 @@ async def delete_movie_quality_api(tmdb_id: int, db_index: int, quality: str):
         raise HTTPException(status_code=500, detail=str(e))
 
 async def delete_tv_quality_api(
-    tmdb_id: int, db_index: int, season: int, episode: int, quality: str
+    tmdb_id: int, db_index: int, season: int, episode: int, id: str
 ):
     try:
-        result = await db.delete_tv_quality(tmdb_id, db_index, season, episode, quality)
+        result = await db.delete_tv_quality(tmdb_id, db_index, season, episode, id)
         if result:
-            return {"message": "Quality deleted successfully"}
+            return {"message": "deleted successfully"}
         else:
             raise HTTPException(status_code=404, detail="Quality not found")
     except Exception as e:

Backend/fastapi/templates/media_edit.html

@@ -1,6 +1,6 @@
 {% extends "base.html" %}
 
-{% block title %}Edit {{ media_type|title }} - Telegram Stremio{% endblock %}
+{% block title %}Edit {{ media_type|title }} - Fyvio Backend{% endblock %}
 
 {% block content %}
 <div class="max-w-7xl mx-auto px-4 sm:px-6 lg:px-8 py-4 sm:py-8">
@@ -220,7 +220,7 @@
                     </div>
                     <p class="text-sm text-gray-500 mt-2 sm:mt-1 break-all">{{ quality.name }}</p>
                 </div>
-                <button onclick="deleteQuality('{{ quality.quality }}')" 
+                <button onclick="deleteQuality('{{ quality.id }}')" 
                         class="self-start sm:self-center text-red-600 hover:text-red-800 hover:bg-red-50 px-3 py-1 rounded transition-colors text-sm">
                     Delete
                 </button>
@@ -277,7 +277,7 @@
                                                 <span class="text-xs text-gray-500">{{ quality.size }}</span>
                                                 <span class="text-xs text-gray-400 break-all">{{ quality.name }}</span>
                                             </div>
-                                            <button onclick="deleteTVQuality({{ season.season_number }}, {{ episode.episode_number }}, '{{ quality.quality }}')" 
+                                            <button onclick="deleteTVQuality({{ season.season_number }}, {{ episode.episode_number }}, '{{ quality.id }}')" 
                                                     class="self-start sm:self-center text-red-600 hover:text-red-800 hover:bg-red-50 px-2 py-1 rounded transition-colors text-xs">
                                                 Delete
                                             </button>
@@ -383,47 +383,47 @@ async function updateMedia(event) {
     }
 }
 
-// Delete quality from movie
-async function deleteQuality(quality) {
-    if (!confirm(`Are you sure you want to delete the ${quality} quality?`)) return;
+// Delete name from movie
+async function deleteQuality(id) {
+    if (!confirm(`Are you sure you want to delete the ${id} ?`)) return;
     
     try {
-        const response = await fetch(`/api/media/delete-quality?tmdb_id=${tmdbId}&db_index=${dbIndex}&quality=${encodeURIComponent(quality)}`, {
+        const response = await fetch(`/api/media/delete-quality?tmdb_id=${tmdbId}&db_index=${dbIndex}&id=${encodeURIComponent(id)}`, {
             method: 'DELETE'
         });
         
         if (response.ok) {
-            showSuccessMessage(`${quality} quality deleted successfully`);
+            showSuccessMessage(`${id} deleted successfully`);
             setTimeout(() => location.reload(), 1000);
         } else {
             const error = await response.json();
-            showErrorMessage(`Error deleting quality: ${error.detail || 'Unknown error'}`);
+            showErrorMessage(`Error deleting : ${error.detail || 'Unknown error'}`);
         }
     } catch (error) {
-        console.error('Error deleting quality:', error);
-        showErrorMessage('Error deleting quality. Please try again.');
+        console.error('Error deleting :', error);
+        showErrorMessage('Error deleting . Please try again.');
     }
 }
 
 // Delete TV quality
-async function deleteTVQuality(season, episode, quality) {
-    if (!confirm(`Are you sure you want to delete the ${quality} quality from Season ${season} Episode ${episode}?`)) return;
+async function deleteTVQuality(season, episode, id) {
+    if (!confirm(`Are you sure you want to delete the ${id} from Season ${season} Episode ${episode}?`)) return;
     
     try {
-        const response = await fetch(`/api/media/delete-tv-quality?tmdb_id=${tmdbId}&db_index=${dbIndex}&season=${season}&episode=${episode}&quality=${encodeURIComponent(quality)}`, {
+        const response = await fetch(`/api/media/delete-tv-quality?tmdb_id=${tmdbId}&db_index=${dbIndex}&season=${season}&episode=${episode}&id=${encodeURIComponent(id)}`, {
             method: 'DELETE'
         });
         
         if (response.ok) {
-            showSuccessMessage(`${quality} quality deleted successfully`);
+            showSuccessMessage(`${id} deleted successfully`);
             setTimeout(() => location.reload(), 1000);
         } else {
             const error = await response.json();
-            showErrorMessage(`Error deleting quality: ${error.detail || 'Unknown error'}`);
+            showErrorMessage(`Error deleting : ${error.detail || 'Unknown error'}`);
         }
     } catch (error) {
-        console.error('Error deleting quality:', error);
-        showErrorMessage('Error deleting quality. Please try again.');
+        console.error('Error deleting :', error);
+        showErrorMessage('Error deleting. Please try again.');
     }
 }
 

Backend/helper/database.py

@@ -249,34 +249,38 @@ class Database:
         tmdb_id = movie_dict["tmdb_id"]
         title = movie_dict["title"]
         release_year = movie_dict["release_year"]
+
         quality_to_update = movie_dict["telegram"][0]
         target_quality = quality_to_update["quality"]
+
         current_db_key = f"storage_{self.current_db_index}"
+        total_storage_dbs = len(self.dbs) - 1
 
-        total_storage_dbs = len(self.dbs) - 1  
+        existing_movie = None
         existing_db_key = None
         existing_db_index = None
-        existing_movie = None
 
-        
         for db_index in range(1, total_storage_dbs + 1):
             db_key = f"storage_{db_index}"
             movie = None
+
             if imdb_id:
                 movie = await self.dbs[db_key]["movie"].find_one({"imdb_id": imdb_id})
             if not movie and tmdb_id:
                 movie = await self.dbs[db_key]["movie"].find_one({"tmdb_id": tmdb_id})
             if not movie and title and release_year:
                 movie = await self.dbs[db_key]["movie"].find_one({
-                    "title": title, 
+                    "title": title,
                     "release_year": release_year
                 })
+
             if movie:
+                existing_movie = movie
                 existing_db_key = db_key
                 existing_db_index = db_index
-                existing_movie = movie
                 break
 
+        # ---------------- INSERT NEW MOVIE ----------------
         if not existing_movie:
             try:
                 movie_dict["db_index"] = self.current_db_index
@@ -288,24 +292,34 @@ class Database:
                     return await self._handle_storage_error(self.update_movie, movie_data, total_storage_dbs=total_storage_dbs)
                 return None
 
+        # ---------------- UPDATE MOVIE ----------------
         movie_id = existing_movie["_id"]
         existing_qualities = existing_movie.get("telegram", [])
-        matching_quality = next((q for q in existing_qualities if q["quality"] == target_quality), None)
-        if matching_quality:
-            
-            try:
-                old_id = matching_quality.get("id")
-                if old_id:
-                    decoded_data = await decode_string(old_id)
-                    chat_id = int(f"-100{decoded_data['chat_id']}")
-                    msg_id = int(decoded_data['msg_id'])
-                    create_task(delete_message(chat_id, msg_id))
-            except Exception as e:
-                LOGGER.error(f"Failed to queue old quality file for deletion: {e}")
 
-            matching_quality.update(quality_to_update)
+        if Telegram.REPLACE_MODE:
+            # delete all same-quality entries
+            to_delete = [q for q in existing_qualities if q.get("quality") == target_quality]
+
+            for q in to_delete:
+                try:
+                    old_id = q.get("id")
+                    if old_id:
+                        decoded = await decode_string(old_id)
+                        chat_id = int(f"-100{decoded['chat_id']}")
+                        msg_id = int(decoded['msg_id'])
+                        create_task(delete_message(chat_id, msg_id))
+                except Exception as e:
+                    LOGGER.error(f"Failed to delete old quality: {e}")
+
+            existing_qualities = [
+                q for q in existing_qualities if q.get("quality") != target_quality
+            ]
+            existing_qualities.append(quality_to_update)
+
         else:
+            # allow duplicate qualities
             existing_qualities.append(quality_to_update)
+
         existing_movie["telegram"] = existing_qualities
         existing_movie["updated_on"] = datetime.utcnow()
 
@@ -332,21 +346,23 @@ class Database:
         except ValidationError as e:
             LOGGER.error(f"Validation error: {e}")
             return None
-        
+
         imdb_id = tv_show_dict.get("imdb_id")
         tmdb_id = tv_show_dict.get("tmdb_id")
         title = tv_show_dict["title"]
         release_year = tv_show_dict["release_year"]
+
         current_db_key = f"storage_{self.current_db_index}"
         total_storage_dbs = len(self.dbs) - 1
 
+        existing_tv = None
         existing_db_key = None
         existing_db_index = None
-        existing_tv = None
 
         for db_index in range(1, total_storage_dbs + 1):
             db_key = f"storage_{db_index}"
             tv = None
+
             if imdb_id:
                 tv = await self.dbs[db_key]["tv"].find_one({"imdb_id": imdb_id})
             if not tv and tmdb_id:
@@ -356,12 +372,14 @@ class Database:
                     "title": title,
                     "release_year": release_year
                 })
+
             if tv:
+                existing_tv = tv
                 existing_db_key = db_key
                 existing_db_index = db_index
-                existing_tv = tv
                 break
 
+        # ---------------- INSERT NEW TV ----------------
         if not existing_tv:
             try:
                 tv_show_dict["db_index"] = self.current_db_index
@@ -373,46 +391,65 @@ class Database:
                     return await self._handle_storage_error(self.update_tv_show, tv_show_data, total_storage_dbs=total_storage_dbs)
                 return None
 
+        # ---------------- UPDATE TV ----------------
         tv_id = existing_tv["_id"]
+
         for season in tv_show_dict["seasons"]:
             existing_season = next(
-                (s for s in existing_tv["seasons"] if s["season_number"] == season["season_number"]), None
+                (s for s in existing_tv["seasons"]
+                if s["season_number"] == season["season_number"]),
+                None
             )
-            if existing_season:
-                for episode in season["episodes"]:
-                    existing_episode = next(
-                        (e for e in existing_season["episodes"] if e["episode_number"] == episode["episode_number"]), None
-                    )
-                    if existing_episode:
-                        existing_episode.setdefault("telegram", [])
-                        for quality in episode["telegram"]:
-                            existing_quality = next(
-                                (q for q in existing_episode["telegram"]
-                                if q.get("quality") == quality.get("quality")),
-                                None
-                            )
-                            if existing_quality:
-                                try:
-                                    old_id = existing_quality.get("id")
 
-                                    if old_id:
-                                        decoded_data = await decode_string(old_id)
+            if not existing_season:
+                existing_tv["seasons"].append(season)
+                continue
+
+            for episode in season["episodes"]:
+                existing_episode = next(
+                    (e for e in existing_season["episodes"]
+                    if e["episode_number"] == episode["episode_number"]),
+                    None
+                )
+
+                if not existing_episode:
+                    existing_season["episodes"].append(episode)
+                    continue
+
+                existing_episode.setdefault("telegram", [])
+
+                for quality in episode["telegram"]:
+                    target_quality = quality.get("quality")
+
+                    if Telegram.REPLACE_MODE:
+                        to_delete = [
+                            q for q in existing_episode["telegram"]
+                            if q.get("quality") == target_quality
+                        ]
+
+                        for q in to_delete:
+                            try:
+                                old_id = q.get("id")
+                                if old_id:
+                                    decoded = await decode_string(old_id)
+                                    chat_id = int(f"-100{decoded['chat_id']}")
+                                    msg_id = int(decoded['msg_id'])
+                                    create_task(delete_message(chat_id, msg_id))
+                            except Exception as e:
+                                LOGGER.error(f"Failed to delete old quality: {e}")
+
+                        existing_episode["telegram"] = [
+                            q for q in existing_episode["telegram"]
+                            if q.get("quality") != target_quality
+                        ]
+                        existing_episode["telegram"].append(quality)
 
-                                        chat_id = int(f"-100{decoded_data['chat_id']}")
-                                        msg_id = int(decoded_data['msg_id'])
-                                        create_task(delete_message(chat_id, msg_id))
-                                        
-                                except Exception as e:
-                                    LOGGER.error(f"Failed to queue old quality file for deletion: {e}")
-                                existing_quality.update(quality)
-                            else:
-                                existing_episode["telegram"].append(quality)
                     else:
-                        existing_season["episodes"].append(episode)
-            else:
-                existing_tv["seasons"].append(season)
+                        existing_episode["telegram"].append(quality)
+
         existing_tv["updated_on"] = datetime.utcnow()
 
+        # ---------------- MOVE DB IF NEEDED ----------------
         if existing_db_index != self.current_db_index:
             try:
                 if await self._move_document("tv", existing_tv, existing_db_index):
@@ -714,7 +751,7 @@ class Database:
         LOGGER.info(f"No document found with tmdb_id {tmdb_id}.")
         return False
 
-    async def delete_movie_quality(self, tmdb_id: int, db_index: int, quality: str) -> bool:
+    async def delete_movie_quality(self, tmdb_id: int, db_index: int, id: str) -> bool:
         db_key = f"storage_{db_index}"
         movie = await self.dbs[db_key]["movie"].find_one({"tmdb_id": tmdb_id})
         
@@ -722,7 +759,7 @@ class Database:
             return False
 
         for q in movie["telegram"]:
-            if q.get("quality") == quality:
+            if q.get("id") == id:
                 try:
                     old_id = q.get("id")
                     if old_id:
@@ -735,7 +772,7 @@ class Database:
                 break
         
         original_len = len(movie["telegram"])
-        movie["telegram"] = [q for q in movie["telegram"] if q.get("quality") != quality]
+        movie["telegram"] = [q for q in movie["telegram"] if q.get("id") != id]
         
         if len(movie["telegram"]) == original_len:
             return False
@@ -812,7 +849,7 @@ class Database:
         result = await self.dbs[db_key]["tv"].replace_one({"tmdb_id": tmdb_id}, tv)
         return result.modified_count > 0
 
-    async def delete_tv_quality(self, tmdb_id: int, db_index: int, season_number: int, episode_number: int, quality: str) -> bool:
+    async def delete_tv_quality(self, tmdb_id: int, db_index: int, season_number: int, episode_number: int, id: str) -> bool:
         db_key = f"storage_{db_index}"
         tv = await self.dbs[db_key]["tv"].find_one({"tmdb_id": tmdb_id})
         
@@ -825,7 +862,7 @@ class Database:
                 for episode in season["episodes"]:
                     if episode.get("episode_number") == episode_number and "telegram" in episode:
                         for q in episode["telegram"]:
-                            if q.get("quality") == quality:
+                            if q.get("id") == id:
                                 try:
                                     old_id = q.get("id")
                                     if old_id:
@@ -838,7 +875,7 @@ class Database:
                                 break
                         
                         original_len = len(episode["telegram"])
-                        episode["telegram"] = [q for q in episode["telegram"] if q.get("quality") != quality]
+                        episode["telegram"] = [q for q in episode["telegram"] if q.get("id") != id]
                         found = original_len > len(episode["telegram"])
                         break
         

README.md

@@ -217,6 +217,7 @@ All environment variables for this project are defined in the `config.env` file.
 | **`BOT_TOKEN`** | The main bot’s **access token** from [@BotFather](https://t.me/BotFather). Handles user requests and media fetching. |
 | **`HELPER_BOT_TOKEN`** | **Secondary bot token** used to assist the main bot with tasks like deleting, editing, or managing. |
 | **`OWNER_ID`** | Your **Telegram user ID**. This ID has full administrative access. |
+| **`REPLACE_MODE`** | When `true`, new files replace existing files of the same quality. When `false`, multiple files of the same quality are allowed. |
 
 ### 🗄️ Storage
 

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "Telegram-Stremio"
-version = "1.4.4"
+version = "1.5.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"

uv.lock

@@ -901,7 +901,7 @@ wheels = [
 
 [[package]]
 name = "telegram-stremio"
-version = "1.4.3"
+version = "1.4.4"
 source = { virtual = "." }
 dependencies = [
     { name = "aiofiles" },