Update main.py

main.py

@@ -2,6 +2,7 @@ import os
 import threading
 import random
 import aiohttp
+import traceback
 from flask import Flask
 from rubpy.bot import BotClient, filters
 
@@ -33,26 +34,39 @@ if not bot_token:
 else:
     bot = BotClient(bot_token)
 
-    @bot.on_update(filters.private & filters.text)
-    async def handle_messages(client, message):
-        user_text = message.text
-        
-        # پاسخ به دستور استارت
-        if user_text == "/start" or user_text == "سلام":
-            welcome_text = "سلام! 🎙️\nمن ربات هوش مصنوعی تبدیل متن به صدا هستم.\n\nهر متنی که دوست داری رو برام بفرست تا با کیفیت استودیویی برات بخونمش!"
-            await message.reply(welcome_text)
-            return
+    # استفاده از فیلتر private برای دریافت پیام‌های پی‌وی
+    @bot.on_update(filters.private)
+    async def handle_messages(client, update):
+        try:
+            # 1. استخراج امن متن پیام (ضد خطا برای نسخه‌های مختلف rubpy)
+            user_text = ""
+            if hasattr(update, "text") and update.text:
+                user_text = update.text
+            elif hasattr(update, "message") and hasattr(update.message, "text") and update.message.text:
+                user_text = update.message.text
+            elif hasattr(update, "new_message") and hasattr(update.new_message, "text") and update.new_message.text:
+                user_text = update.new_message.text
+            
+            if not user_text:
+                return
 
-        # محدودیت طول متن برای سرعت بهتر (مثل محدودیت کدهای خودتان)
-        if len(user_text) > 500:
-            await message.reply("⚠️ کاربر گرامی، لطفاً متنی کوتاه‌تر از ۵۰۰ کاراکتر بفرستید.")
-            return
+            print(f"پیام جدید دریافت شد: {user_text}")
 
-        # ارسال پیام انتظار
-        wait_msg = await message.reply("⏳ در حال ساخت صدا...\n(ممکن است چند ثانیه طول بکشد)")
+            # 2. پاسخ به دستور استارت
+            if user_text == "/start" or user_text == "سلام":
+                welcome_text = "سلام! 🎙️\nمن ربات هوش مصنوعی تبدیل متن به صدا هستم.\n\nهر متنی که دوست داری رو برام بفرست تا با کیفیت استودیویی برات بخونمش!"
+                await update.reply(welcome_text)
+                return
 
-        try:
-            # انتخاب تصادفی یکی از سرورهای شما برای جلوگیری از فشار روی یک سرور
+            # محدودیت طول متن
+            if len(user_text) > 500:
+                await update.reply("⚠️ کاربر گرامی، لطفاً متنی کوتاه‌تر از ۵۰۰ کاراکتر بفرستید.")
+                return
+
+            # پیام در حال پردازش
+            await update.reply("⏳ در حال ساخت صدا...\n(ممکن است چند ثانیه طول بکشد)")
+
+            # 3. انتخاب تصادفی یکی از سرورهای هوش مصنوعی
             worker_url = random.choice(WORKER_URLS)
             
             # تنظیمات ویس (در اینجا گوینده 'Charon' یا همان 'شهاب' تنظیم شده است)
@@ -62,29 +76,42 @@ else:
                 "use_live_model": True
             }
 
-            # ارسال درخواست به سرور صدای شما به صورت غیرمسدودکننده (Async)
+            # 4. اتصال به سرور شما و دریافت صدا
             async with aiohttp.ClientSession() as session:
                 async with session.post(worker_url, json=payload, timeout=120) as response:
                     if response.status == 200:
                         audio_bytes = await response.read()
                         
-                        # ذخیره موقت فایل صوتی (برای هر پیام یک اسم اختصاصی می‌سازیم که تداخل پیدا نکنند)
-                        file_name = f"audio_{message.message_id}.wav"
+                        # نام فایل رندوم برای جلوگیری از تداخل
+                        file_name = f"audio_{random.randint(1000, 999999)}.wav"
                         with open(file_name, "wb") as f:
                             f.write(audio_bytes)
                         
-                        # ارسال فایل صوتی به صورت Voice در روبیکا
-                        await message.reply_voice(file_name)
+                        # 5. ارسال فایل صوتی ساخته شده
+                        try:
+                            # روش اول: استخراج آیدی کاربر و ارسال ویس
+                            chat_id = getattr(update, "chat_id", None) or getattr(update, "object_guid", None) or getattr(update, "author_guid", None)
+                            await client.send_voice(chat_id, file_name)
+                        except Exception as e_send:
+                            print(f"Send Voice Error: {e_send}")
+                            try:
+                                # روش جایگزین در صورتی که روش اول جواب نداد
+                                await update.reply(file=file_name)
+                            except Exception as e_reply:
+                                print(f"Reply File Error: {e_reply}")
+                                await update.reply("✅ فایل با موفقیت ساخته شد اما ربات اجازه ارسال ویس را ندارد.")
                         
-                        # پاک کردن فایل از روی سرور برای خالی ماندن فضا
-                        os.remove(file_name)
+                        # پاک کردن فایل از روی سرور پس از ارسال
+                        if os.path.exists(file_name):
+                            os.remove(file_name)
                         
                     else:
-                        await message.reply("❌ متاسفانه سرور هوش مصنوعی در حال حاضر شلوغ است. لطفاً چند دقیقه دیگر تلاش کنید.")
+                        await update.reply("❌ متاسفانه سرور هوش مصنوعی در حال حاضر شلوغ است. لطفاً چند دقیقه دیگر تلاش کنید.")
 
         except Exception as e:
-            print(f"Error: {e}")
-            await message.reply("❌ خطایی در ارتباط با سرور رخ داد. لطفاً دوباره تلاش کنید.")
+            # چاپ کامل خطا در لاگ‌های هاگینگ فیس
+            print(f"یک خطای کلی در ربات رخ داد: {e}")
+            traceback.print_exc()
 
 if __name__ == "__main__":
     threading.Thread(target=run_flask, daemon=True).start()