fix(renamer): resolve multiple rows error for multi-subscription seasons

When multiple bangumi subscriptions share the same save_path (e.g., split-cour
anime with S01E1-12 and S01E13-24), the renamer's match_by_save_path() query
returned multiple rows causing "Multiple rows were found" errors.

Changes:
- Add qb_hash field to Torrent model for direct hash-to-bangumi linking
- Add database migration v6 for qb_hash column with index
- Add tags parameter to add_torrents() in all downloader clients
- Tag new torrents with ab:{bangumi_id} for offset lookup during rename
- Implement multi-tier lookup in renamer: qb_hash -> tags -> torrent_name -> save_path
- Fix auth tests by mocking DEV_AUTH_BYPASS for proper 401 testing

The renamer now reliably finds the correct bangumi and its offsets even when
multiple subscriptions download to the same directory.

Generated with [Claude Code](https://claude.ai/code)
via [Happy](https://happy.engineering)

Co-Authored-By: Claude <noreply@anthropic.com>
Co-Authored-By: Happy <yesreply@happy.engineering>

Author: 3 people

backend/src/module/database/bangumi.py

@@ -38,7 +38,9 @@ def _is_duplicate(self, data: Bangumi) -> bool:
 
     def add(self, data: Bangumi) -> bool:
         if self._is_duplicate(data):
-            logger.debug(f"[Database] Skipping duplicate: {data.official_title} ({data.group_name})")
+            logger.debug(
+                f"[Database] Skipping duplicate: {data.official_title} ({data.group_name})"
+            )
             return False
         self.session.add(data)
         self.session.commit()
@@ -58,10 +60,7 @@ def add_all(self, datas: list[Bangumi]) -> int:
                 existing.add((data.title_raw, data.group_name))
 
         # Filter out duplicates
-        to_add = [
-            d for d in datas
-            if (d.title_raw, d.group_name) not in existing
-        ]
+        to_add = [d for d in datas if (d.title_raw, d.group_name) not in existing]
 
         # Also deduplicate within the batch itself
         seen = set()
@@ -73,17 +72,23 @@ def add_all(self, datas: list[Bangumi]) -> int:
                 unique_to_add.append(d)
 
         if not unique_to_add:
-            logger.debug(f"[Database] All {len(datas)} bangumi already exist, skipping.")
+            logger.debug(
+                f"[Database] All {len(datas)} bangumi already exist, skipping."
+            )
             return 0
 
         self.session.add_all(unique_to_add)
         self.session.commit()
         _invalidate_bangumi_cache()
         skipped = len(datas) - len(unique_to_add)
         if skipped > 0:
-            logger.debug(f"[Database] Insert {len(unique_to_add)} bangumi, skipped {skipped} duplicates.")
+            logger.debug(
+                f"[Database] Insert {len(unique_to_add)} bangumi, skipped {skipped} duplicates."
+            )
         else:
-            logger.debug(f"[Database] Insert {len(unique_to_add)} bangumi into database.")
+            logger.debug(
+                f"[Database] Insert {len(unique_to_add)} bangumi into database."
+            )
         return len(unique_to_add)
 
     def update(self, data: Bangumi | BangumiUpdate, _id: int = None) -> bool:
@@ -152,7 +157,10 @@ def delete_all(self):
     def search_all(self) -> list[Bangumi]:
         global _bangumi_cache, _bangumi_cache_time
         now = time.time()
-        if _bangumi_cache is not None and (now - _bangumi_cache_time) < _BANGUMI_CACHE_TTL:
+        if (
+            _bangumi_cache is not None
+            and (now - _bangumi_cache_time) < _BANGUMI_CACHE_TTL
+        ):
             return _bangumi_cache
         statement = select(Bangumi)
         result = self.session.execute(statement)
@@ -199,7 +207,10 @@ def match_list(self, torrent_list: list, rss_link: str) -> list:
             matched = False
             for title_raw, match_data in title_index.items():
                 if title_raw in torrent.name:
-                    if rss_link not in match_data.rss_link and title_raw not in rss_updated:
+                    if (
+                        rss_link not in match_data.rss_link
+                        and title_raw not in rss_updated
+                    ):
                         match_data.rss_link += f",{rss_link}"
                         match_data.added = False
                         rss_updated.add(title_raw)
@@ -211,7 +222,9 @@ def match_list(self, torrent_list: list, rss_link: str) -> list:
         if rss_updated:
             self.session.commit()
             _invalidate_bangumi_cache()
-            logger.debug(f"[Database] Batch updated rss_link for {len(rss_updated)} bangumi.")
+            logger.debug(
+                f"[Database] Batch updated rss_link for {len(rss_updated)} bangumi."
+            )
         return unmatched
 
     def match_torrent(self, torrent_name: str) -> Optional[Bangumi]:
@@ -290,10 +303,17 @@ def unarchive_one(self, _id: int) -> bool:
         return True
 
     def match_by_save_path(self, save_path: str) -> Optional[Bangumi]:
-        """Find bangumi by save_path to get offset."""
-        statement = select(Bangumi).where(Bangumi.save_path == save_path)
+        """Find bangumi by save_path to get offset.
+
+        Note: When multiple subscriptions share the same save_path (e.g., different RSS
+        sources for the same anime), this returns the first match. Use match_torrent()
+        for more accurate matching when torrent_name is available.
+        """
+        statement = select(Bangumi).where(
+            and_(Bangumi.save_path == save_path, Bangumi.deleted == false())
+        )
         result = self.session.execute(statement)
-        return result.scalar_one_or_none()
+        return result.scalars().first()
 
     def get_needs_review(self) -> list[Bangumi]:
         """Get all bangumi that need review for offset mismatch."""

backend/src/module/database/combine.py

@@ -23,7 +23,7 @@
 TABLE_MODELS: list[type[SQLModel]] = [Bangumi, RSSItem, Torrent, User, Passkey]
 
 # Increment this when adding new migrations to MIGRATIONS list.
-CURRENT_SCHEMA_VERSION = 5
+CURRENT_SCHEMA_VERSION = 6
 
 # Each migration is a tuple of (version, description, list of SQL statements).
 # Migrations are applied in order. A migration at index i brings the schema
@@ -80,6 +80,14 @@
             "ALTER TABLE bangumi ADD COLUMN needs_review_reason TEXT DEFAULT NULL",
         ],
     ),
+    (
+        6,
+        "add qb_hash column to torrent for downloader tracking",
+        [
+            "ALTER TABLE torrent ADD COLUMN qb_hash TEXT",
+            "CREATE INDEX IF NOT EXISTS ix_torrent_qb_hash ON torrent(qb_hash)",
+        ],
+    ),
 ]
 
 
@@ -163,6 +171,10 @@ def run_migrations(self):
                 columns = [col["name"] for col in inspector.get_columns("bangumi")]
                 if "episode_offset" in columns:
                     needs_run = False
+            if "torrent" in tables and version == 6:
+                columns = [col["name"] for col in inspector.get_columns("torrent")]
+                if "qb_hash" in columns:
+                    needs_run = False
             if needs_run:
                 with self.engine.connect() as conn:
                     for stmt in statements:

backend/src/module/database/torrent.py

@@ -59,3 +59,28 @@ def check_new(self, torrents_list: list[Torrent]) -> list[Torrent]:
         result = self.session.execute(statement)
         existing_urls = set(result.scalars().all())
         return [t for t in torrents_list if t.url not in existing_urls]
+
+    def search_by_qb_hash(self, qb_hash: str) -> Torrent | None:
+        """Find torrent by qBittorrent hash."""
+        result = self.session.execute(
+            select(Torrent).where(Torrent.qb_hash == qb_hash)
+        )
+        return result.scalar_one_or_none()
+
+    def search_by_url(self, url: str) -> Torrent | None:
+        """Find torrent by URL."""
+        result = self.session.execute(
+            select(Torrent).where(Torrent.url == url)
+        )
+        return result.scalar_one_or_none()
+
+    def update_qb_hash(self, torrent_id: int, qb_hash: str) -> bool:
+        """Update the qb_hash for a torrent."""
+        torrent = self.search(torrent_id)
+        if torrent:
+            torrent.qb_hash = qb_hash
+            self.session.add(torrent)
+            self.session.commit()
+            logger.debug(f"Updated qb_hash for torrent {torrent_id}: {qb_hash}")
+            return True
+        return False

backend/src/module/downloader/client/aria2_downloader.py

@@ -57,7 +57,7 @@ async def logout(self):
     async def torrents_files(self, torrent_hash: str):
         return []
 
-    async def add_torrents(self, torrent_urls, torrent_files, save_path, category):
+    async def add_torrents(self, torrent_urls, torrent_files, save_path, category, tags=None):
         import base64
         options = {"dir": save_path}
         if torrent_urls: