Update app.py

app.py

@@ -23,14 +23,12 @@ logger = logging.getLogger(__name__)
 
 # ===== تحميل النماذج =====
 try:
-    # 1. نموذج التعرف على الصوت (ASR)
     asr_pipeline = pipeline(
         "automatic-speech-recognition",
         model="jonatasgrosman/wav2vec2-large-xlsr-53-arabic",
         token=os.getenv("HF_TOKEN")
     )
 
-    # 2. نموذج توليف الصوت (TTS)
     tts_tokenizer = AutoTokenizer.from_pretrained(
         "facebook/mms-tts-ara",
         token=os.getenv("HF_TOKEN")
@@ -46,7 +44,6 @@ except Exception as e:
 
 # ===== دوال معالجة الصوت =====
 def enhance_audio(input_path: str, output_path: str) -> bool:
-    """تحسين جودة الملف الصوتي"""
     try:
         audio = AudioSegment.from_wav(input_path)
         audio = audio.low_pass_filter(3000)
@@ -60,7 +57,6 @@ def enhance_audio(input_path: str, output_path: str) -> bool:
         return False
 
 async def speech_to_text(audio_path: str) -> str:
-    """تحويل الصوت إلى نص"""
     try:
         audio, sr = librosa.load(audio_path, sr=16000)
         sf.write("temp.wav", audio, sr)
@@ -71,7 +67,6 @@ async def speech_to_text(audio_path: str) -> str:
         return ""
 
 async def generate_response(text: str) -> str:
-    """توليد رد الذكاء الاصطناعي"""
     try:
         chatbot = pipeline(
             "text-generation",
@@ -90,7 +85,6 @@ async def generate_response(text: str) -> str:
         return "حدث خطأ في توليد الرد."
 
 async def text_to_speech(text: str) -> None:
-    """تحويل النص إلى صوت"""
     try:
         inputs = tts_tokenizer(text, return_tensors="pt")
         with torch.no_grad():
@@ -103,16 +97,13 @@ async def text_to_speech(text: str) -> None:
 # ===== الدالة الرئيسية =====
 async def process_voice(update: Update, context):
     try:
-        # تحميل الصوت
         voice_file = await update.message.voice.get_file()
         await voice_file.download_to_drive("user_voice.ogg")
         
-        # معالجة الصوت
         user_text = await speech_to_text("user_voice.ogg")
         bot_response = await generate_response(user_text)
         await text_to_speech(bot_response)
         
-        # إرسال الرد
         if enhance_audio("bot_response.wav", "bot_response_enhanced.wav"):
             await update.message.reply_voice("bot_response_enhanced.wav")
         else:
@@ -122,11 +113,11 @@ async def process_voice(update: Update, context):
         logger.error(f"خطأ غير متوقع: {str(e)}")
         await update.message.reply_text("⚠️ عذرًا، حدث خطأ في المعالجة.")
 
-# ===== التشغيل الرئيسي =====
-async def main():
+# ===== التشغيل المعدل مع حل مشكلة الخيوط =====
+def run_bot():
     application = ApplicationBuilder().token(os.getenv("TELEGRAM_TOKEN")).build()
     application.add_handler(MessageHandler(filters.VOICE, process_voice))
-    await application.run_polling()
+    application.run_polling()
 
 if __name__ == "__main__":
-    asyncio.run(main())
+    run_bot()