check torrent add status

src/bot/plugins/commands.py

@@ -3,6 +3,7 @@
 import psutil
 
 from .. import custom_filters
+from ...db_management import write_support
 from ...utils import convert_size
 from ...configs import Configs
 from .common import send_menu
@@ -18,6 +19,7 @@ async def access_denied_message(client: Client, message: Message) -> None:
 @Client.on_message(filters.command("start") & custom_filters.check_user_filter)
 async def start_command(client: Client, message: Message) -> None:
     """Start the bot."""
+    write_support("None", message.chat.id)
     await send_menu(client, message.id, message.chat.id)
 
 

src/bot/plugins/on_message.py

@@ -24,11 +24,15 @@ async def on_text(client: Client, message: Message) -> None:
             category = db_management.read_support(message.from_user.id).split("#")[1]
 
             repository = ClientRepo.get_client_manager(Configs.config.client.type)
-            repository.add_magnet(
+            response = repository.add_magnet(
                 magnet_link=magnet_link,
                 category=category
             )
 
+            if not response:
+                await message.reply_text("Unable to add magnet link")
+                return
+
             await send_menu(client, message.id, message.from_user.id)
             db_management.write_support("None", message.from_user.id)
 
@@ -43,7 +47,11 @@ async def on_text(client: Client, message: Message) -> None:
                 await message.download(name)
 
                 repository = ClientRepo.get_client_manager(Configs.config.client.type)
-                repository.add_torrent(file_name=name, category=category)
+                response = repository.add_torrent(file_name=name, category=category)
+
+                if not response:
+                    await message.reply_text("Unable to add magnet link")
+                    return
 
             await send_menu(client, message.id, message.from_user.id)
             db_management.write_support("None", message.from_user.id)

src/client_manager/client_manager.py

@@ -5,13 +5,13 @@
 
 class ClientManager(ABC):
     @classmethod
-    def add_magnet(cls, magnet_link: Union[str, List[str]], category: str = None) -> None:
-        """Add one or multiple magnet links with or without a category"""
+    def add_magnet(cls, magnet_link: Union[str, List[str]], category: str = None) -> bool:
+        """Add one or multiple magnet links with or without a category, return true if successful"""
         raise NotImplementedError
 
     @classmethod
-    def add_torrent(cls, file_name: str, category: str = None) -> None:
-        """Add one torrent file with or without a category"""
+    def add_torrent(cls, file_name: str, category: str = None) -> bool:
+        """Add one torrent file with or without a category, return true if successful"""
         raise NotImplementedError
 
     @classmethod

src/client_manager/qbittorrent_manager.py

@@ -11,23 +11,26 @@
 
 class QbittorrentManager(ClientManager):
     @classmethod
-    def add_magnet(cls, magnet_link: Union[str, List[str]], category: str = None) -> None:
+    def add_magnet(cls, magnet_link: Union[str, List[str]], category: str = None) -> bool:
         if category == "None":
             category = None
 
         with qbittorrentapi.Client(**Configs.config.client.connection_string) as qbt_client:
             logger.debug(f"Adding magnet with category {category}")
-            qbt_client.torrents_add(urls=magnet_link, category=category)
+            result = qbt_client.torrents_add(urls=magnet_link, category=category)
+
+        return result == "Ok."
 
     @classmethod
-    def add_torrent(cls, file_name: str, category: str = None) -> None:
+    def add_torrent(cls, file_name: str, category: str = None) -> bool:
         if category == "None":
             category = None
 
         try:
             with qbittorrentapi.Client(**Configs.config.client.connection_string) as qbt_client:
                 logger.debug(f"Adding torrent with category {category}")
-                qbt_client.torrents_add(torrent_files=file_name, category=category)
+                result = qbt_client.torrents_add(torrent_files=file_name, category=category)
+            return result == "Ok."
 
         except qbittorrentapi.exceptions.UnsupportedMediaType415Error:
             pass