离线功能

main.py

@@ -11,6 +11,7 @@ from telegram.ext import (
     CallbackQueryHandler,
     CallbackContext,
     ContextTypes,
+    filters,
 )
 import httpx
 
@@ -216,6 +217,23 @@ async def tg_emptytrash(update: Update, context):
         await update.message.reply_text(f"✅操作成功")
 
 
+# 消息处理
+async def handle_message(update: Update, context: ContextTypes.DEFAULT_TYPE):
+    text = update.message.text
+    if text.lower().startswith("magnet:"):
+        result = await THUNDERX_CLIENT.offline_download(text, "", "")
+        if result["task"]["id"] is not None:
+            await update.message.reply_text(f"✅操作成功")
+        else:
+            await update.message.reply_text(f"❌未成功创建任务，请稍后重试!!")
+    else:
+        await update.message.reply_text(f"收到不支持的消息:{text}")
+
+
+#################### 文件操作 #############################
+
+
+#################### 离线任务处理 ##########################
 # 确认操作的回调
 async def handle_task_confirmation(update: Update, context: CallbackContext):
     query = update.callback_query
@@ -414,6 +432,9 @@ async def init_client():
         TG_BOT_APPLICATION.add_handler(CommandHandler("quota", quota))
         TG_BOT_APPLICATION.add_handler(CommandHandler("emptytrash", tg_emptytrash))
         TG_BOT_APPLICATION.add_handler(CommandHandler("tasks", tg_show_task))
+        # Message 消息处理相关的命令！
+        TG_BOT_APPLICATION.add_handler(MessageHandler(filters.TEXT, handle_message))
+
         await TG_BOT_APPLICATION.initialize()