Update bot.py

bot.py

@@ -5,6 +5,8 @@ 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())
@@ -19,29 +21,32 @@ logger = logging.getLogger(__name__)
 # --- إعدادات أساسية ---
 config = Config()
 config.device = "cpu"
-config.is_half = False # الدقة الكاملة أفضل للمعالج العادي
+config.is_half = False
 
 # --- تحميل النموذج الخاص بك عند بدء التشغيل ---
 HUB_REPO_ID = "Hashim-dotcom/Hashim.ai.rvc"
 MODEL_FILE = "model.pth"
 WEIGHTS_DIR = "assets/weights"
 
-logger.info("تجهيز مجلد النماذج...")
-os.makedirs(WEIGHTS_DIR, exist_ok=True)
-
-logger.info(f"جاري تحميل نموذجك الخاص '{MODEL_FILE}' من Hugging Face Hub...")
+pipeline = None
 try:
-    model_path_on_disk = hf_hub_download(repo_id=HUB_REPO_ID, filename=MODEL_FILE)
+    logger.info("تجهيز مجلد النماذج...")
+    os.makedirs(WEIGHTS_DIR, exist_ok=True)
+    
+    logger.info(f"جاري تحميل نموذجك الخاص '{MODEL_FILE}' من Hugging Face Hub...")
+    model_path_on_disk = hf_hub_download(repo_id=HUB_REPO_ID, filename=MODEL_FILE, cache_dir="/tmp/.cache/huggingface")
+    
     # نسخ النموذج إلى المجلد الذي يتوقعه RVC
-    os.rename(model_path_on_disk, os.path.join(WEIGHTS_DIR, MODEL_FILE))
+    final_model_path = os.path.join(WEIGHTS_DIR, MODEL_FILE)
+    os.rename(model_path_on_disk, final_model_path)
     logger.info("تم تحميل النموذج بنجاح!")
     
-    # الآن نقوم بإنشاء وتشغيل المحرك بالنموذج الخاص بك
+    # === هذا هو السطر الذي تم إصلاحه ===
     pipeline = Pipeline(config)
+    # ==================================
     
 except Exception as e:
     logger.error(f"حدث خطأ فادح أثناء تحميل النموذج: {e}")
-    pipeline = None
 
 # --- دوال البوت ---
 async def start(update, context):
@@ -54,6 +59,7 @@ async def handle_audio(update, context):
 
     await update.message.reply_text("تم استلام صوتك، جاري المعالجة...")
     
+    # ... (بقية كود معالجة الصوت يبقى كما هو)
     try:
         if update.message.voice:
             file_id = update.message.voice.file_id
@@ -66,11 +72,10 @@ async def handle_audio(update, context):
         input_path = f"{file_id}_input"
         await audio_file.download_to_drive(input_path)
         
-        # --- عملية التحويل ---
         output_audio = pipeline.infer(
             model_name=MODEL_FILE,
             input_audio_path=input_path,
-            f0_up_key=0 # تغيير حدة الصوت (0 = بدون تغيير)
+            f0_up_key=0
         )
         output_path = f"{file_id}_output.wav"
         import soundfile as sf
@@ -82,24 +87,45 @@ 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)
 
-def main():
+
+async def main():
     TOKEN = os.getenv("TELEGRAM_TOKEN")
     if not TOKEN:
-        logger.critical("خطأ: لم يتم العثور على TELEGRAM_TOKEN في الأسرار.")
+        logger.critical("خطأ: لم يتم العثور على TELEGRAM_TOKEN.")
         return
 
-    application = Application.builder().token(TOKEN).build()
+    # === هذا هو الإصلاح الثاني لمشكلة الشبكة ===
+    from telegram.ext import AIORateLimiter
+    from telegram.request import HTTPXRequest
+    
+    request = HTTPXRequest(http_version="1.1") # استخدام إصدار HTTP أقدم وأكثر توافقاً
+    
+    application = (
+        Application.builder()
+        .token(TOKEN)
+        .request(request)
+        .rate_limiter(AIORateLimiter())
+        .build()
+    )
+    # =========================================
+
     application.add_handler(CommandHandler("start", start))
     application.add_handler(MessageHandler(filters.VOICE | filters.AUDIO, handle_audio))
     
     logger.info("البوت قيد التشغيل...")
-    application.run_polling()
+    # نشغل البوت بطريقة لا تمنع البرنامج من الإقلاع بشكل كامل
+    await application.initialize()
+    await application.start()
+    await application.updater.start_polling()
+    # حلقة لا نهائية لإبقاء البرنامج يعمل
+    while True:
+        await asyncio.sleep(3600)
+
 
 if __name__ == "__main__":
-    main()
+    asyncio.run(main())