feat: delete associated torrents when removing a bangumi

Author: KotaHv

backend/src/module/database/torrent.py

@@ -63,3 +63,11 @@ def get_bangumi_id(self, torrent_hash: str) -> Optional[int]:
             .where(and_(Torrent.hash == torrent_hash, Torrent.bangumi_id.isnot(None)))
             .order_by(desc(Torrent.id))
         ).first()
+
+    def delete_by_bangumi_id(self, bangumi_id: int):
+        statement = select(Torrent).where(Torrent.bangumi_id == bangumi_id)
+        torrents = self.session.exec(statement).all()
+        for torrent in torrents:
+            logger.debug(f"[Database] Delete torrent name: {torrent.name}.")
+            self.session.delete(torrent)
+        self.session.commit()

backend/src/module/manager/torrent.py

@@ -42,6 +42,7 @@ def delete_rule(self, _id: int | str, file: bool = False):
             with DownloadClient() as client:
                 self.rss.delete(data.official_title)
                 self.bangumi.delete_one(int(_id))
+                self.torrent.delete_by_bangumi_id(int(_id))
                 if file:
                     torrent_message = self.delete_torrents(data, client)
                 logger.info(f"[Manager] Delete rule for {data.official_title}")