Update main.py

main.py

@@ -311,16 +311,99 @@ def to_english_digits(text):
     return str(text).translate(translation_table)
 
 # ==============================================================================
-# 🟢 پارت 6: تنظیمات وب‌سرور (Flask) و توابع کمکی فایل‌ها
+# 🟢 پارت 6: تنظیمات وب‌سرور (Flask)، دریافت وب‌هوک و توابع کمکی فایل‌ها
 # ==============================================================================
-# --- تنظیمات وب سرور ---
+import requests
+import asyncio
+from flask import Flask, request, jsonify
+
+# --- تنظیمات وب سرور و وب‌هوک ---
 app = Flask(__name__)
 
-@app.route('/')
+# آدرس وب‌هوک (اگر از Cloudflare Worker استفاده کردید، آدرس آن را اینجا بگذارید)
+WEBHOOK_URL = "https://opera8-rubikabot.hf.space/"
+
+def set_webhook_on_rubika():
+    bot_token = os.environ.get("RUBIKA_AUTH", "").strip()
+    if not bot_token: 
+        print("❌ توکن روبیکا یافت نشد!")
+        return
+    
+    url = f"https://botapi.rubika.ir/v3/{bot_token}/updateBotEndpoints"
+    
+    payload_update = {"url": WEBHOOK_URL, "type": "ReceiveUpdate"}
+    payload_inline = {"url": WEBHOOK_URL, "type": "ReceiveInlineMessage"}
+    
+    try:
+        r1 = requests.post(url, json=payload_update, timeout=15)
+        print("🟢 Webhook Setup (ReceiveUpdate):", r1.json())
+        
+        r2 = requests.post(url, json=payload_inline, timeout=15)
+        print("🟢 Webhook Setup (InlineMessage):", r2.json())
+    except Exception as e:
+        print("❌ Webhook Setup Failed:", e)
+
+class UpdateWrapper:
+    def __init__(self, d):
+        self._d = d
+        for k, v in d.items():
+            if isinstance(v, dict):
+                setattr(self, k, UpdateWrapper(v))
+            elif isinstance(v, list):
+                setattr(self, k, [UpdateWrapper(i) if isinstance(i, dict) else i for i in v])
+            else:
+                setattr(self, k, v)
+        
+        # 🟢 جادوی تطبیق متغیرهای وب‌هوک با استانداردهای ربات شما (رفع باگ خوانده نشدن پیام‌ها)
+        if hasattr(self, 'new_message'):
+            self.message = self.new_message
+            
+        if hasattr(self, 'message') and isinstance(self.message, UpdateWrapper):
+            if hasattr(self.message, 'sender_id') and not hasattr(self.message, 'author_object_guid'):
+                self.message.author_object_guid = self.message.sender_id
+                
+        if hasattr(self, 'chat_id') and not hasattr(self, 'object_guid'):
+            self.object_guid = self.chat_id
+            self.author_guid = self.chat_id
+    
+    def to_dict(self):
+        return self._d
+        
+    def get(self, key, default=None):
+        return getattr(self, key, default)
+
+@app.route('/', methods=['GET', 'POST'])
 def home():
-    return "ربات یکپارچه آلفا (نسخه پرو + مدیریت اشتراک نامحدود + دعوت دوستان + سیستم تغییر صدا) روشن است! 🚀"
+    if request.method == 'GET':
+        return "ربات یکپارچه آلفا (نسخه پرو + وب‌هوک روبیکا) روشن است! 🚀"
+    
+    if request.method == 'POST':
+        try:
+            data = request.json
+            if data:
+                inner_data = data
+                if "update" in data:
+                    inner_data = data["update"]
+                elif "inline_message" in data:
+                    inner_data = data["inline_message"]
+                    
+                wrapped_update = UpdateWrapper(inner_data)
+                
+                # تسک به سرعت به حلقه اصلی پاس داده می‌شود تا سرور منتظر نماند
+                if 'loop' in globals() and 'main_handler' in globals():
+                    asyncio.run_coroutine_threadsafe(main_handler(bot, wrapped_update), loop)
+                    
+        except Exception as e:
+            print("❌ Error in webhook processing:", e)
+            
+        # همیشه و در کسری از ثانیه 200 OK برمی‌گردانیم تا روبیکا ارتباط را قطع نکند
+        return jsonify({"status": "ok"})
 
 def run_flask():
+    set_webhook_on_rubika()
+    import logging
+    log = logging.getLogger('werkzeug')
+    log.setLevel(logging.ERROR)
     app.run(host="0.0.0.0", port=7860, threaded=True)
 
 # --- توابع کمکی ---
@@ -337,12 +420,17 @@ def sync_read_file(file_name):
         return f.read()
 
 def sync_combine_audio(current_audio, new_bytes):
+    from pydub import AudioSegment
+    import io
     audio_segment = AudioSegment.from_file(io.BytesIO(new_bytes))
     return current_audio + audio_segment
 
 def sync_export_audio(audio_obj, file_name):
     audio_obj.export(file_name, format="mp3")
 
+
+
+
 # ==============================================================================
 # 🟢 پارت 7: کیبوردها (دکمه���های شیشه‌ای / منوها)
 # ==============================================================================
@@ -614,22 +702,19 @@ HF_TOKENS =[k.strip() for k in HF_TOKENS_STR.split(",") if k.strip()]
 # ==============================================================================
 async def helper_upload_file(client, chat_id, file_name, file_type="Image", caption=""):
     abs_path = os.path.abspath(file_name)
-    error_logs = []
+    error_logs =[]
     
-    api_file_type = "Image" if file_type in["photo", "Image", "image"] else "Voice" if file_type in ["voice", "Voice", "audio"] else file_type
+    api_file_type = "Image" if file_type in ["photo", "Image", "image"] else "Voice" if file_type in ["voice", "Voice", "audio"] else file_type
     
-    # روبیکا فرمت‌های خاصی را قبول می‌کند.
     if api_file_type == "Voice" and not abs_path.lower().endswith('.ogg'): 
         api_file_type = "Music"
     if api_file_type == "File" and abs_path.lower().endswith('.mp3'): 
         api_file_type = "Music"
         
-    # --- فاز اول (فوق سریع): استفاده از متدهای اختصاصی rubpy ---
-    for attempt in range(10):
+    # --- فاز اول (تلاش با متدهای روب‌پای تا 15 بار) ---
+    for attempt in range(15):
         try:
             sent_success = False
-            
-            # تلاش برای ارسال عکس
             if api_file_type == "Image" and hasattr(client, "send_photo"):
                 try:
                     await client.send_photo(chat_id, photo=abs_path, caption=caption)
@@ -638,7 +723,6 @@ async def helper_upload_file(client, chat_id, file_name, file_type="Image", capt
                     await client.send_photo(chat_id, abs_path, caption=caption)
                     sent_success = True
                     
-            # تلاش برای ارسال ویس
             elif api_file_type == "Voice" and hasattr(client, "send_voice"):
                 try:
                     await client.send_voice(chat_id, abs_path, caption=caption)
@@ -647,7 +731,6 @@ async def helper_upload_file(client, chat_id, file_name, file_type="Image", capt
                     await client.send_voice(chat_id, file=abs_path, caption=caption)
                     sent_success = True
                     
-            # تلاش برای ارسال موزیک
             elif api_file_type == "Music" and hasattr(client, "send_music"):
                 try:
                     await client.send_music(chat_id, abs_path, caption=caption)
@@ -656,8 +739,6 @@ async def helper_upload_file(client, chat_id, file_name, file_type="Image", capt
                     await client.send_music(chat_id, music=abs_path, caption=caption)
                     sent_success = True
 
-            # *** سیستم ضد بمب اتم فاز 1 ***
-            # اگر هیچکدام از متدهای بالا وجود نداشت یا به هر دلیلی ارسال نشد، حتما به عنوان فایل (سند) بفرست تا معطل نشود
             if not sent_success:
                 if hasattr(client, "send_document"):
                     try:
@@ -679,28 +760,34 @@ async def helper_upload_file(client, chat_id, file_name, file_type="Image", capt
                 return True
                     
         except Exception as e:
-            err_msg = str(e)[:150]
-            error_logs.append(f"Rubpy Send Error: {err_msg}")
-            
-            if "502" in err_msg or "timeout" in err_msg.lower() or "time" in err_msg.lower(): 
-                await asyncio.sleep(4)
+            err_msg = str(e)
+            error_logs.append(f"Rubpy Error: {err_msg[:50]}")
+            # سیستم ضد اسپم روبیکا: اگر ارور محدودیت درخواست داد، ۱۵ ثانیه صبر کن!
+            if "TOO_REQUESTS" in err_msg or "429" in err_msg or "502" in err_msg or "timeout" in err_msg.lower(): 
+                await asyncio.sleep(15)
             else: 
-                await asyncio.sleep(2)
+                await asyncio.sleep(4)
 
-    # --- فاز دوم (سنگر آخر): آپلود دستی (Raw HTTP) در صورت مسدودی کامل روب‌پای ---
-    for attempt in range(15):
+    # --- فاز دوم (سنگر آخر: آپلود دستی تا 30 بار پافشاری شدید) ---
+    for attempt in range(30):
         try:
             url_request = f"https://botapi.rubika.ir/v3/{bot_token}/requestSendFile"
             url_send = f"https://botapi.rubika.ir/v3/{bot_token}/sendFile"
             
             async with aiohttp.ClientSession() as session:
-                async with session.post(url_request, json={"type": api_file_type}, timeout=30) as resp:
+                async with session.post(url_request, json={"type": api_file_type}, timeout=60) as resp:
                     if resp.status != 200:
-                        error_logs.append(f"Request HTTP {resp.status}")
-                        await asyncio.sleep(2)
+                        await asyncio.sleep(5)
                         continue
                         
                     req_data = await resp.json()
+                    
+                    # 🛑 هندل کردن دقیق ارور رباتیک TOO_REQUESTS
+                    if req_data.get("status") == "TOO_REQUESTS":
+                        error_logs.append("Hit TOO_REQUESTS on requestSendFile. Sleeping 15s...")
+                        await asyncio.sleep(15)
+                        continue
+
                     if req_data.get("status") == "OK":
                         upload_url = req_data.get("data", {}).get("upload_url")
                         if upload_url:
@@ -709,28 +796,24 @@ async def helper_upload_file(client, chat_id, file_name, file_type="Image", capt
                                 form.add_field('file', f, filename=os.path.basename(abs_path))
                                 async with session.post(upload_url, data=form, timeout=300) as up_resp:
                                     if up_resp.status != 200:
-                                        error_logs.append(f"Upload HTTP {up_resp.status}")
-                                        if up_resp.status in[502, 503, 500]: 
-                                            await asyncio.sleep(3) 
-                                        else: 
-                                            await asyncio.sleep(1.5)
+                                        await asyncio.sleep(5)
                                         continue
                                         
                                     try: 
                                         up_data = await up_resp.json()
-                                    except Exception as json_err:
-                                        error_logs.append(f"JSON Decode Error: {json_err}")
-                                        await asyncio.sleep(2)
+                                    except Exception:
+                                        await asyncio.sleep(3)
                                         continue
                                     
+                                    if up_data.get("status") == "TOO_REQUESTS":
+                                        await asyncio.sleep(15)
+                                        continue
+
                                     final_file_id = None
                                     
-                                    # *** سیستم ضد بمب اتم فاز 2 ***
-                                    # دور زدن ارور روبیکا: اگر روبیکا به فرمت فایل گیر داد، سریعاً نوع را به File تغییر بده تا بدون بررسی فرمت آپلود کند!
                                     if up_data.get("status") == "INVALID_INPUT" and "format" in str(up_data).lower():
                                         api_file_type = "File"
-                                        error_logs.append(f"Format Blocked! Downgrading type to File.")
-                                        await asyncio.sleep(1)
+                                        await asyncio.sleep(2)
                                         continue
 
                                     if up_data.get("status") == "OK" or up_data.get("status_det") == "OK":
@@ -747,34 +830,26 @@ async def helper_upload_file(client, chat_id, file_name, file_type="Image", capt
                                             "chat_keypad_type": "New",
                                             "chat_keypad": MAIN_KEYPAD_DICT
                                         }
-                                        async with session.post(url_send, json=send_payload, timeout=30) as send_resp:
-                                            if send_resp.status != 200:
-                                                error_logs.append(f"Send HTTP {send_resp.status}")
-                                                await asyncio.sleep(2)
-                                                continue
-                                                
+                                        async with session.post(url_send, json=send_payload, timeout=60) as send_resp:
                                             s_data = await send_resp.json()
-                                            if s_data.get("status") == "OK": return True
-                                            else: error_logs.append(f"SendFile API Error: {s_data}")
+                                            if s_data.get("status") == "TOO_REQUESTS":
+                                                await asyncio.sleep(15)
+                                                continue
+                                            if s_data.get("status") == "OK": 
+                                                return True
                                     else:
                                         if up_data.get("status") == "INVALID_INPUT" and api_file_type in ["Voice", "Music"]:
-                                            api_file_type = "File" # دور زدن گیر دادن روبیکا
-                                        error_logs.append(f"Upload API Error: {up_data}")
-                        else: error_logs.append(f"Missing upload_url in Response: {req_data}")
-                    else: error_logs.append(f"Request API Error: {req_data}")
+                                            api_file_type = "File"
         except Exception as e:
-            error_logs.append(f"Raw HTTP Error: {str(e)[:100]}")
-            await asyncio.sleep(2.5)
+            error_logs.append(f"Raw HTTP Error: {str(e)[:50]}")
+            await asyncio.sleep(5)
 
     return "\n".join(error_logs[-6:])
 
 # ==============================================================================
 # 🟢 پارت 12: توابع تغییر صدا و لیست گویندگان
 # ==============================================================================
-# ==================================================================
-# لیست‌های اولیه ربات
-# ==================================================================
-WORKER_URLS =["https://opera8-ttspro.hf.space/generate"]
+WORKER_URLS = ["https://opera8-ttspro.hf.space/generate"]
 
 SPEAKERS = {
     "1": ("شهاب (مرد)", "Charon"), "2": ("آوا (زن)", "Zephyr"), "3": ("نوید (مرد)", "Achird"), 
@@ -791,80 +866,100 @@ SPEAKERS = {
 
 user_states = {}
 
-# ==================================================================
-# توابع تغییر صدا و کلون کردن
-# ==================================================================
 async def process_standard_vc_job(client, chat_id, src_bytes, ref_bytes, job_type_name, credit_type):
     str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
     creds = get_user_credits(str_chat_id)
     
-    proc_msg = await send_with_keyboard(client, chat_id, f"⏳ در حال آماده‌سازی فایل‌ها...\n(مدل: {job_type_name})", False)
+    await send_with_keyboard(client, chat_id, f"⏳ در حال آماده‌سازی فایل‌ها...\n(مدل: {job_type_name})", False)
     
-    async with aiohttp.ClientSession() as session:
-        form = aiohttp.FormData()
-        form.add_field('source_audio', src_bytes, filename='src.wav', content_type='audio/wav')
-        form.add_field('ref_audio', ref_bytes, filename='ref.wav', content_type='audio/wav')
-        
-        try:
-            async with session.post(f"{VC_BASE_URL}/upload", data=form, timeout=43200) as resp:
-                if resp.status != 200:
-                    return await send_with_keyboard(client, chat_id, f"❌ خطا در ارسال فایل‌ها (کد {resp.status})", True)
-                data = await resp.json()
-                job_id = data.get("job_id")
-                total_chunks = data.get("total_chunks", 1)
-                chunks = data.get("chunks",[])
-        except Exception as e:
-            return await send_with_keyboard(client, chat_id, f"❌ خطا در اتصال به سرور:\n{str(e)[:100]}", True)
+    job_id = None
+    total_chunks = 1
+    chunks =[]
+    
+    # 🛑 پافشاری ۳۰ بار برای آپلود به سرور تغییر صدا (ضد ارور 429)
+    for attempt in range(30):
+        async with aiohttp.ClientSession() as session:
+            # فرم باید در هر تلاش از نو ساخته شود
+            form = aiohttp.FormData()
+            form.add_field('source_audio', src_bytes, filename='src.wav', content_type='audio/wav')
+            form.add_field('ref_audio', ref_bytes, filename='ref.wav', content_type='audio/wav')
+            try:
+                async with session.post(f"{VC_BASE_URL}/upload", data=form, timeout=120) as resp:
+                    if resp.status == 429: # شلوغی سرور اسپیس
+                        await asyncio.sleep(15)
+                        continue
+                    if resp.status == 200:
+                        data = await resp.json()
+                        job_id = data.get("job_id")
+                        total_chunks = data.get("total_chunks", 1)
+                        chunks = data.get("chunks",[])
+                        break
+                    else:
+                        await asyncio.sleep(5)
+            except Exception:
+                await asyncio.sleep(5)
 
-        await send_with_keyboard(client, chat_id, "✅ فایل‌ها ارسال شد. در حال پردازش و تغییر صدا...\n(لطفا چند دقیقه صبور باشید)", False)
-        
-        final_filename = None
-        for _ in range(10000):
-            await asyncio.sleep(4)
+    if not job_id:
+        return await send_with_keyboard(client, chat_id, "❌ پردازش ناموفق بود. ترافیک ربات بسیار بالاست، لطفا چند دقیقه دیگر مجدداً تلاش کنید.", True)
+
+    await send_with_keyboard(client, chat_id, "✅ فایل‌ها ارسال شد. در حال پردازش و تغییر صدا...\n(لطفا چند دقیقه صبور باشید)", False)
+    
+    final_filename = None
+    async with aiohttp.ClientSession() as session:
+        for _ in range(1000): # حل��ه بی‌نهایت چک کردن استتوس
+            await asyncio.sleep(5)
             payload_check = {"job_id": job_id, "total_chunks": total_chunks, "chunks": chunks}
             try:
-                async with session.post(f"{VC_BASE_URL}/check_status", json=payload_check, timeout=20) as c_resp:
+                async with session.post(f"{VC_BASE_URL}/check_status", json=payload_check, timeout=30) as c_resp:
                     if c_resp.status == 200:
                         c_data = await c_resp.json()
                         if c_data.get("status") == "completed":
                             final_filename = c_data.get("filename")
                             break
                         elif c_data.get("status") in ["failed", "error"]:
-                            return await send_with_keyboard(client, chat_id, "❌ خطای سرور در حین پردازش صدا.", True)
+                            return await send_with_keyboard(client, chat_id, "❌ خطای داخلی سرور در حین ساخت صدا رخ داد.", True)
             except Exception:
                 pass
                 
         if not final_filename:
-            return await send_with_keyboard(client, chat_id, "❌ پردازش بیش از حد طول کشید و متوقف شد.", True)
+            return await send_with_keyboard(client, chat_id, "❌ پردازش بیش از حد طول کشید.", True)
 
         download_url = f"{VC_BASE_URL}/download/{final_filename}"
         await send_with_keyboard(client, chat_id, "📥 پردازش تمام شد! در حال دانلود نتیجه...", False)
-        try:
-            async with session.get(download_url, timeout=43200) as d_resp:
-                if d_resp.status == 200:
-                    result_bytes = await d_resp.read()
-                else:
-                    return await send_with_keyboard(client, chat_id, "❌ خطا در دریافت فایل نهایی از سرور.", True)
-        except Exception:
-            return await send_with_keyboard(client, chat_id, "❌ خطا در اتصال هنگام دانلود خروجی.", True)
+        
+        result_bytes = None
+        for attempt in range(30):
+            try:
+                async with session.get(download_url, timeout=120) as d_resp:
+                    if d_resp.status == 200:
+                        result_bytes = await d_resp.read()
+                        break
+                    elif d_resp.status == 429:
+                        await asyncio.sleep(10)
+            except Exception:
+                await asyncio.sleep(5)
+
+    if not result_bytes:
+         return await send_with_keyboard(client, chat_id, "❌ خطا در دریافت فایل نهایی از سرور.", True)
 
     file_name_mp3 = f"vc_standard_{uuid.uuid4().hex[:6]}.mp3"
     await asyncio.to_thread(sync_write_file, file_name_mp3, result_bytes)
     
     upload_result = False
-    for up_att in range(3):
+    # پافشاری بسیار بالا برای آپلود نهایی به روبیکا
+    for up_att in range(15):
         res = await helper_upload_file(client, chat_id, file_name_mp3, "Music", f"🎙️ {job_type_name} شما آماده است!")
         if res is True:
             upload_result = True
             break
-        await asyncio.sleep(4)
+        await asyncio.sleep(5)
 
     if upload_result is True:
         if not creds.get("is_premium"):
             user_credits_db[str_chat_id][credit_type] -= 1
             save_db(user_credits_db)
     else:
-        await send_with_keyboard(client, chat_id, "❌ فایل پردازش شد اما امکان ارسال در روبیکا فراهم نشد.", True)
+        await send_with_keyboard(client, chat_id, "❌ فایل با موفقیت پردازش شد اما ارسال آن به دلیل شلوغی سرور روبیکا با مشکل مواجه شد.", True)
         
     if os.path.exists(file_name_mp3): os.remove(file_name_mp3)
 
@@ -872,37 +967,48 @@ async def process_legacy_vc_job(client, chat_id, src_bytes, model_url, pitch, mo
     str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
     creds = get_user_credits(str_chat_id)
     
-    proc_msg = await send_with_keyboard(client, chat_id, f"⏳ در حال آماده‌سازی فایل‌ها...\n(مدل: {model_name})", False)
+    await send_with_keyboard(client, chat_id, f"⏳ در حال آماده‌سازی فایل‌ها...\n(مدل: {model_name})", False)
     
-    async with aiohttp.ClientSession() as session:
-        form = aiohttp.FormData()
-        form.add_field('audio_file', src_bytes, filename='input.wav', content_type='audio/wav')
-        form.add_field('model_url', model_url)
-        form.add_field('pitch', str(pitch))
-        form.add_field('algo', 'rmvpe+')
-        form.add_field('index_inf', '0.75')
-        form.add_field('res_filter', '3')
-        form.add_field('env_ratio', '0.25')
-        form.add_field('protect', '0.33')
-        form.add_field('denoise', 'false')
-        form.add_field('reverb', 'false')
-        
-        try:
-            async with session.post(f"{LEGACY_BASE_URL}/upload", data=form, timeout=43200) as resp:
-                if resp.status != 200:
-                    return await send_with_keyboard(client, chat_id, f"❌ خطا در ارسال فایل‌ها (کد {resp.status})", True)
-                data = await resp.json()
-                job_id = data.get("job_id")
-        except Exception as e:
-            return await send_with_keyboard(client, chat_id, f"❌ خطا در اتصال به سرور:\n{str(e)[:100]}", True)
+    job_id = None
+    # 🛑 پافشاری ۳۰ بار
+    for attempt in range(30):
+        async with aiohttp.ClientSession() as session:
+            form = aiohttp.FormData()
+            form.add_field('audio_file', src_bytes, filename='input.wav', content_type='audio/wav')
+            form.add_field('model_url', model_url)
+            form.add_field('pitch', str(pitch))
+            form.add_field('algo', 'rmvpe+')
+            form.add_field('index_inf', '0.75')
+            form.add_field('res_filter', '3')
+            form.add_field('env_ratio', '0.25')
+            form.add_field('protect', '0.33')
+            form.add_field('denoise', 'false')
+            form.add_field('reverb', 'false')
+            try:
+                async with session.post(f"{LEGACY_BASE_URL}/upload", data=form, timeout=120) as resp:
+                    if resp.status == 429:
+                        await asyncio.sleep(15)
+                        continue
+                    if resp.status == 200:
+                        data = await resp.json()
+                        job_id = data.get("job_id")
+                        break
+                    else:
+                        await asyncio.sleep(5)
+            except Exception:
+                await asyncio.sleep(5)
 
-        await send_with_keyboard(client, chat_id, "✅ فایل ارسال شد. در حال پردازش و تغییر صدای شما...\n(لطفا چند دقیقه صبور باشید)", False)
-        
-        final_filename = None
-        for _ in range(10000):
+    if not job_id:
+        return await send_with_keyboard(client, chat_id, "❌ ترافیک سرور بسیار بالاست. لطفا چند دقیقه دیگر امتحان کنید.", True)
+
+    await send_with_keyboard(client, chat_id, "✅ فایل ارسال شد. در حال پردازش و تغییر صدای شما...\n(لطفا چند دقیقه صبور باشید)", False)
+    
+    final_filename = None
+    async with aiohttp.ClientSession() as session:
+        for _ in range(1000):
             await asyncio.sleep(5)
             try:
-                async with session.get(f"{LEGACY_BASE_URL}/status/{job_id}", timeout=20) as c_resp:
+                async with session.get(f"{LEGACY_BASE_URL}/status/{job_id}", timeout=30) as c_resp:
                     if c_resp.status == 200:
                         c_data = await c_resp.json()
                         if c_data.get("status") == "completed":
@@ -918,32 +1024,39 @@ async def process_legacy_vc_job(client, chat_id, src_bytes, model_url, pitch, mo
 
         download_url = f"{LEGACY_BASE_URL}/download/{final_filename}"
         await send_with_keyboard(client, chat_id, "📥 پردازش تمام شد! در حال دانلود نتیجه...", False)
-        try:
-            async with session.get(download_url, timeout=43200) as d_resp:
-                if d_resp.status == 200:
-                    result_bytes = await d_resp.read()
-                else:
-                    return await send_with_keyboard(client, chat_id, "❌ خطا در دریافت فایل نهایی از سرور.", True)
-        except Exception:
-            return await send_with_keyboard(client, chat_id, "❌ خطا در اتصال هنگام دانلود خروجی.", True)
+        
+        result_bytes = None
+        for attempt in range(30):
+            try:
+                async with session.get(download_url, timeout=120) as d_resp:
+                    if d_resp.status == 200:
+                        result_bytes = await d_resp.read()
+                        break
+                    elif d_resp.status == 429:
+                        await asyncio.sleep(10)
+            except Exception:
+                await asyncio.sleep(5)
+
+    if not result_bytes:
+        return await send_with_keyboard(client, chat_id, "❌ خطا در دریافت فایل نهایی از سرور.", True)
 
     file_name_mp3 = f"vc_legacy_{uuid.uuid4().hex[:6]}.mp3"
     await asyncio.to_thread(sync_write_file, file_name_mp3, result_bytes)
     
     upload_result = False
-    for up_att in range(3):
+    for up_att in range(15):
         res = await helper_upload_file(client, chat_id, file_name_mp3, "Music", f"🎙️ صدای خروجی با مدل {model_name} آماده است!")
         if res is True:
             upload_result = True
             break
-        await asyncio.sleep(4)
+        await asyncio.sleep(5)
 
     if upload_result is True:
         if not creds.get("is_premium"):
             user_credits_db[str_chat_id]["voice_conv"] -= 1
             save_db(user_credits_db)
     else:
-        await send_with_keyboard(client, chat_id, "❌ فایل پردازش شد اما امکان ارسال در روبیکا فراهم نشد.", True)
+        await send_with_keyboard(client, chat_id, "❌ فایل پردازش شد اما ترافیک روبیکا اجازه آپلود نداد.", True)
         
     if os.path.exists(file_name_mp3): os.remove(file_name_mp3)
 
@@ -1133,7 +1246,7 @@ async def process_image(client, chat_id, prompt, size_choice="1"):
         async with aiohttp.ClientSession() as session:
             for key in keys_to_try_gemini:
                 url = f"https://generativelanguage.googleapis.com/v1beta/models/gemini-2.5-flash:generateContent?key={key}"
-                payload = {"contents": [{"parts":[{"text": gemini_sys_prompt}]}], "generationConfig": {"temperature": 0.7}}
+                payload = {"contents":[{"parts":[{"text": gemini_sys_prompt}]}], "generationConfig": {"temperature": 0.7}}
                 try:
                     async with session.post(url, json=payload, timeout=20) as response:
                         if response.status == 200:
@@ -1186,9 +1299,9 @@ async def process_image(client, chat_id, prompt, size_choice="1"):
     proc_msg = await send_with_keyboard(client, chat_id, f"🎨 در حال طراحی عکس...\n\n📏 **ابعاد:** {size_name}\n📝 **پرامپت ساخته شده:**\n`{short_preview}`\n\n(ممکن است چند ثانیه زمان ببرد)", False)
 
     generated_image = None
-    last_error_log = "هیچ اتصالی برقرار نشد."
     
-    for attempt in range(5):
+    # پافشاری ۳۰ بار روی ساخت عکس
+    for attempt in range(30):
         keys_to_try = HF_TOKENS.copy()
         random.shuffle(keys_to_try)
         for token in keys_to_try:
@@ -1202,10 +1315,12 @@ async def process_image(client, chat_id, prompt, size_choice="1"):
                 )
                 break 
             except Exception as e:
-                last_error_log = str(e)
+                err_str = str(e).lower()
+                if "429" in err_str or "too many" in err_str:
+                    await asyncio.sleep(10)
                 continue
         if generated_image: break
-        await asyncio.sleep(2)
+        await asyncio.sleep(5)
             
     try:
         if proc_msg:
@@ -1215,7 +1330,7 @@ async def process_image(client, chat_id, prompt, size_choice="1"):
     except Exception: pass
 
     if not generated_image: 
-        return await send_with_keyboard(client, chat_id, f"❌ عکس ساخته نشد.\n\n⚠️ خطا:\n{last_error_log[:200]}", True)
+        return await send_with_keyboard(client, chat_id, f"❌ سرورهای ساخت عکس به شدت شلوغ هستند. لطفاً مجدداً امتحان کنید.", True)
 
     try:
         file_name = f"image_{uuid.uuid4().hex}.jpg"
@@ -1224,26 +1339,25 @@ async def process_image(client, chat_id, prompt, size_choice="1"):
         caption_text = f"🎨 تصویر شما با پرامپت هوشمند آماده شد!\n\n📏 ابعاد تصویر: {size_name}\n✨ ایده اولیه: {prompt}"
         
         upload_result = False
-        error_log_img = ""
-        for up_att in range(3):
+        # پافشاری ۱۵ بار روی ارسال عکس به روبیکا
+        for up_att in range(15):
             res = await helper_upload_file(client, chat_id, file_name, "Image", caption_text)
             if res is True:
                 upload_result = True
                 break
             else:
-                error_log_img = res
-                await asyncio.sleep(4)
+                await asyncio.sleep(5)
         
         if upload_result is True:
             if not creds.get("is_premium"):
                 user_credits_db[str_chat_id]["image"] -= 1
                 save_db(user_credits_db)
         else:
-            await send_with_keyboard(client, chat_id, f"❌ عکس ساخته شد اما آپلود در روبیکا با خطا مواجه شد:\n`{str(error_log_img)[:800]}`", True)
+            await send_with_keyboard(client, chat_id, f"❌ عکس با موفقیت ساخته شد اما روبیکا به دلیل ترافیک بالا اجازه ارسال نداد.", True)
             
         if os.path.exists(file_name): os.remove(file_name)
     except Exception as e: 
-        await send_with_keyboard(client, chat_id, f"❌ خطا در ذخیره و ارسال عکس:\n{str(e)[:150]}", True)
+        pass
 
 # ==============================================================================
 # 🟢 پارت 15: توابع ترجمه و ویرایش عکس با هوش مصنوعی (Flux.2)
@@ -1370,9 +1484,9 @@ async def process_tts(client, chat_id, user_text, speaker_id, speaker_name):
         headers = {"User-Agent": "Mozilla/5.0", "Content-Type": "application/json"}
         
         audio_bytes = None
-        last_error = "پاسخی دریافت نشد"
         
-        for attempt in range(10):
+        # پافشاری بسیار بالا (۳۰ بار) برای سرورهای تولید صدا
+        for attempt in range(30):
             workers = WORKER_URLS.copy()
             random.shuffle(workers)
             async with aiohttp.ClientSession(headers=headers, timeout=aiohttp.ClientTimeout(total=600)) as session:
@@ -1384,13 +1498,12 @@ async def process_tts(client, chat_id, user_text, speaker_id, speaker_name):
                                 if 'audio' in content_type or response.content_length > 1000:
                                     audio_bytes = await response.read()
                                     break
-                                else: last_error = "فایل نامعتبر"
-                            else: last_error = f"ارور ({response.status})"
-                    except Exception as e: 
-                        last_error = f"خطا: {str(e)}"
+                            elif response.status == 429: # مسدودیت موقت
+                                await asyncio.sleep(10)
+                    except Exception: 
                         continue
             if audio_bytes: break
-            await asyncio.sleep(2)
+            await asyncio.sleep(5)
 
         try:
             if proc_msg:
@@ -1405,26 +1518,25 @@ async def process_tts(client, chat_id, user_text, speaker_id, speaker_name):
             await asyncio.sleep(1)
             
             upload_result_file = False
-            error_log_tts = ""
-            for up_att in range(3):
+            # پافشاری بالا روی ارسال فایل در روبیکا
+            for up_att in range(15):
                 res = await helper_upload_file(client, chat_id, file_name_mp3, "Music", "✅ صدای شما با موفقیت آماده شد (فایل MP3):")
                 if res is True:
                     upload_result_file = True
                     break
                 else:
-                    error_log_tts = res
-                    await asyncio.sleep(4)
+                    await asyncio.sleep(5)
             
             if upload_result_file is True: 
                 if not creds.get("is_premium"):
                     user_credits_db[str_chat_id]["tts"] -= 1
                     save_db(user_credits_db)
             else:
-                await send_with_keyboard(client, chat_id, f"❌ فایل صدا ساخته شد اما سرور روبیکا اجازه آپلود نداد:\n`{str(error_log_tts)[:800]}`", True)
+                await send_with_keyboard(client, chat_id, f"❌ صدای شما ساخته شد اما شلوغی سرور روبیکا مانع ارسال آن شد.", True)
                 
             if os.path.exists(file_name_mp3): os.remove(file_name_mp3)
         else: 
-            await send_with_keyboard(client, chat_id, f"❌ سرورها درگیر هستند.\nدلیل: {last_error}", True)
+            await send_with_keyboard(client, chat_id, f"❌ سرورها درگیر هستند. لطفا دقایقی دیگر مجددا امتحان کنید.", True)
     except Exception: traceback.print_exc()
 
 # ==============================================================================
@@ -1880,7 +1992,7 @@ if not bot_token:
 else:
     bot = BotClient(bot_token)
 
-    @bot.on_update(filters.private)
+    # دکوریتور @bot.on_update حذف شد چون با وب‌هوک خودمان مستقیم این تابع را صدا می‌زنیم
     async def main_handler(client, update):
         global BOT_GUID
         
@@ -2645,16 +2757,22 @@ else:
         except Exception: traceback.print_exc()
 
 if __name__ == "__main__":
+    loop = asyncio.get_event_loop()
+    
+    # 🟢 تونل‌های پرسرعت: ارتقا از 32 کارگر به 256 کارگر برای پاسخگویی همزمان به هزاران نفر
+    loop.set_default_executor(concurrent.futures.ThreadPoolExecutor(max_workers=256))
+    
+    # 🟢 روشن کردن سیستم پاکسازی هوشمند رم در پس‌زمینه
+    loop.create_task(ram_garbage_collector())
+    
+    # استارت کردن وب‌سرور فلسک در یک Thread جداگانه (که وب‌هوک را تنظیم و پیام‌ها را دریافت می‌کند)
+    import threading
     threading.Thread(target=run_flask, daemon=True).start()
     
     if bot_token:
-        loop = asyncio.get_event_loop()
-        
-        # 🟢 تونل‌های پرسرعت: ارتقا از 32 کارگر به 256 کارگر برای پاسخگویی همزمان به هزاران نفر
-        loop.set_default_executor(concurrent.futures.ThreadPoolExecutor(max_workers=256))
-        
-        # 🟢 روشن کردن سیستم پاکسازی هوشمند رم در پس‌زمینه
-        loop.create_task(ram_garbage_collector())
-        
-        print("🚀 ربات آلفا پرو (نسخه صنعتی + دیتابیس هوشمند + پاکسازی رم + 256 تونل همزمان) روشن شد...")
-        bot.run()
+        print("�� ربات آلفا پرو (نسخه صنعتی + وب‌هوک + دیتابیس هوشمند + پاکسازی رم + 256 تونل همزمان) روشن شد...")
+        # جایگزینی bot.run() با روشن نگه داشتن حلقه بی‌نهایت
+        try:
+            loop.run_forever()
+        except KeyboardInterrupt:
+            pass