Update bot.py

bot.py

@@ -5,10 +5,9 @@ from telegram.ext import Application, CommandHandler, MessageHandler, filters
 import torch
 import logging
 from huggingface_hub import hf_hub_download
-from urllib3.util import Retry
 import asyncio
 
-# إضافة مسار المشروع إلى مسارات بايثون للوصول للمكتبات المحلية
+# إضافة مسار المشروع إلى مسارات بايثون
 sys.path.append(os.getcwd())
 
 from infer.modules.vc.pipeline import Pipeline
@@ -23,7 +22,7 @@ config = Config()
 config.device = "cpu"
 config.is_half = False
 
-# --- تحميل النموذج الخاص بك عند بدء التشغيل ---
+# --- تحميل النموذج ---
 HUB_REPO_ID = "Hashim-dotcom/Hashim.ai.rvc"
 MODEL_FILE = "model.pth"
 WEIGHTS_DIR = "assets/weights"
@@ -33,10 +32,9 @@ try:
     logger.info("تجهيز مجلد النماذج...")
     os.makedirs(WEIGHTS_DIR, exist_ok=True)
     
-    logger.info(f"جاري تحميل نموذجك الخاص '{MODEL_FILE}' من Hugging Face Hub...")
+    logger.info(f"جاري تحميل نموذجك الخاص '{MODEL_FILE}'...")
     model_path_on_disk = hf_hub_download(repo_id=HUB_REPO_ID, filename=MODEL_FILE, cache_dir="/tmp/.cache/huggingface")
     
-    # نسخ النموذج إلى المجلد الذي يتوقعه RVC
     final_model_path = os.path.join(WEIGHTS_DIR, MODEL_FILE)
     os.rename(model_path_on_disk, final_model_path)
     logger.info("تم تحميل النموذج بنجاح!")
@@ -59,14 +57,12 @@ async def handle_audio(update, context):
 
     await update.message.reply_text("تم استلام صوتك، جاري المعالجة...")
     
-    # ... (بقية كود معالجة الصوت يبقى كما هو)
     try:
         if update.message.voice:
             file_id = update.message.voice.file_id
         elif update.message.audio:
             file_id = update.message.audio.file_id
-        else:
-            return
+        else: return
 
         audio_file = await context.bot.get_file(file_id)
         input_path = f"{file_id}_input"
@@ -87,11 +83,9 @@ async def handle_audio(update, context):
         logger.error(f"حدث خطأ أثناء المعالجة: {e}")
         await update.message.reply_text(f"عذراً، حدث خطأ: {str(e)}")
     finally:
-        if 'input_path' in locals() and os.path.exists(input_path):
-            os.remove(input_path)
-        if 'output_path' in locals() and os.path.exists(output_path):
-            os.remove(output_path)
-
+        # تنظيف الملفات
+        if 'input_path' in locals() and os.path.exists(input_path): os.remove(input_path)
+        if 'output_path' in locals() and os.path.exists(output_path): os.remove(output_path)
 
 async def main():
     TOKEN = os.getenv("TELEGRAM_TOKEN")
@@ -99,11 +93,10 @@ async def main():
         logger.critical("خطأ: لم يتم العثور على TELEGRAM_TOKEN.")
         return
 
-    # === هذا هو الإصلاح الثاني لمشكلة الشبكة ===
     from telegram.ext import AIORateLimiter
     from telegram.request import HTTPXRequest
     
-    request = HTTPXRequest(http_version="1.1") # استخدام إصدار HTTP أقدم وأكثر توافقاً
+    request = HTTPXRequest(http_version="1.1")
     
     application = (
         Application.builder()
@@ -112,20 +105,15 @@ async def main():
         .rate_limiter(AIORateLimiter())
         .build()
     )
-    # =========================================
 
     application.add_handler(CommandHandler("start", start))
     application.add_handler(MessageHandler(filters.VOICE | filters.AUDIO, handle_audio))
     
     logger.info("البوت قيد التشغيل...")
-    # نشغل البوت بطريقة لا تمنع البرنامج من الإقلاع بشكل كامل
     await application.initialize()
-    await application.start()
     await application.updater.start_polling()
-    # حلقة لا نهائية لإبقاء البرنامج يعمل
-    while True:
-        await asyncio.sleep(3600)
-
+    await application.start()
+    while True: await asyncio.sleep(3600)
 
 if __name__ == "__main__":
     asyncio.run(main())