Update main.py

main.py

@@ -311,99 +311,16 @@ 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__)
 
-# آدرس وب‌هوک (اگر از Cloudflare Worker استفاده کردید، آدرس آن را اینجا بگذارید)
-WEBHOOK_URL = "https://opera8-sadarubikabot.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'])
+@app.route('/')
 def home():
-    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"})
+    return "ربات یکپارچه آلفا (نسخه پرو + مدیریت اشتراک نامحدود + دعوت دوستان + سیستم تغییر صدا) روشن است! 🚀"
 
 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)
 
 # --- توابع کمکی ---
@@ -420,15 +337,12 @@ 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: کیبوردها (دکمه���های شیشه‌ای / منوها)
 # ==============================================================================
@@ -700,19 +614,22 @@ 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"
         
-    # --- فاز اول (تلاش با متدهای روب‌پای تا 15 بار) ---
-    for attempt in range(15):
+    # --- فاز اول (فوق سریع): استفاده از متدهای اختصاصی rubpy ---
+    for attempt in range(10):
         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)
@@ -721,6 +638,7 @@ 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)
@@ -729,6 +647,7 @@ 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)
@@ -737,6 +656,8 @@ 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:
@@ -758,34 +679,28 @@ async def helper_upload_file(client, chat_id, file_name, file_type="Image", capt
                 return True
                     
         except Exception as e:
-            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: 
+            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)
+            else: 
+                await asyncio.sleep(2)
 
-    # --- فاز دوم (سنگر آخر: آپلود دستی تا 30 بار پافشاری شدید) ---
-    for attempt in range(30):
+    # --- فاز دوم (سنگر آخر): آپلود دستی (Raw HTTP) در صورت مسدودی کامل روب‌پای ---
+    for attempt in range(15):
         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=60) as resp:
+                async with session.post(url_request, json={"type": api_file_type}, timeout=30) as resp:
                     if resp.status != 200:
-                        await asyncio.sleep(5)
+                        error_logs.append(f"Request HTTP {resp.status}")
+                        await asyncio.sleep(2)
                         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:
@@ -794,24 +709,28 @@ 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:
-                                        await asyncio.sleep(5)
+                                        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)
                                         continue
                                         
                                     try: 
                                         up_data = await up_resp.json()
-                                    except Exception:
-                                        await asyncio.sleep(3)
+                                    except Exception as json_err:
+                                        error_logs.append(f"JSON Decode Error: {json_err}")
+                                        await asyncio.sleep(2)
                                         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"
-                                        await asyncio.sleep(2)
+                                        error_logs.append(f"Format Blocked! Downgrading type to File.")
+                                        await asyncio.sleep(1)
                                         continue
 
                                     if up_data.get("status") == "OK" or up_data.get("status_det") == "OK":
@@ -828,26 +747,34 @@ 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=60) as send_resp:
-                                            s_data = await send_resp.json()
-                                            if s_data.get("status") == "TOO_REQUESTS":
-                                                await asyncio.sleep(15)
+                                        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
-                                            if s_data.get("status") == "OK": 
-                                                return True
+                                                
+                                            s_data = await send_resp.json()
+                                            if s_data.get("status") == "OK": return True
+                                            else: error_logs.append(f"SendFile API Error: {s_data}")
                                     else:
                                         if up_data.get("status") == "INVALID_INPUT" and api_file_type in ["Voice", "Music"]:
-                                            api_file_type = "File"
+                                            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}")
         except Exception as e:
-            error_logs.append(f"Raw HTTP Error: {str(e)[:50]}")
-            await asyncio.sleep(5)
+            error_logs.append(f"Raw HTTP Error: {str(e)[:100]}")
+            await asyncio.sleep(2.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"), 
@@ -864,100 +791,80 @@ 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)
     
-    await send_with_keyboard(client, chat_id, f"⏳ در حال آماده‌سازی فایل‌ها...\n(مدل: {job_type_name})", False)
-    
-    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)
-
-    if not job_id:
-        return await send_with_keyboard(client, chat_id, "❌ پردازش ناموفق بود. ترافیک ربات بسیار بالاست، لطفا چند دقیقه دیگر مجدداً تلاش کنید.", True)
-
-    await send_with_keyboard(client, chat_id, "✅ فایل‌ها ارسال شد. در حال پردازش و تغییر صدا...\n(لطفا چند دقیقه صبور باشید)", False)
+    proc_msg = await send_with_keyboard(client, chat_id, f"⏳ در حال آماده‌سازی فایل‌ها...\n(مدل: {job_type_name})", False)
     
-    final_filename = None
     async with aiohttp.ClientSession() as session:
-        for _ in range(1000): # حلقه بی‌نهایت چک کردن استتوس
-            await asyncio.sleep(5)
+        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)
+
+        await send_with_keyboard(client, chat_id, "✅ فایل‌ها ارسال شد. در حال پردازش و تغییر صدا...\n(لطفا چند دقیقه صبور باشید)", False)
+        
+        final_filename = None
+        for _ in range(10000):
+            await asyncio.sleep(4)
             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=30) as c_resp:
+                async with session.post(f"{VC_BASE_URL}/check_status", json=payload_check, timeout=20) 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)
-        
-        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)
+        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)
 
     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(15):
+    for up_att in range(3):
         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(5)
+        await asyncio.sleep(4)
 
     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)
 
@@ -965,48 +872,37 @@ 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)
     
-    await send_with_keyboard(client, chat_id, f"⏳ در حال آماده‌سازی فایل‌ها...\n(مدل: {model_name})", False)
-    
-    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)
-
-    if not job_id:
-        return await send_with_keyboard(client, chat_id, "❌ ترافیک سرور بسیار بالاست. لطفا چند دقیقه دیگر امتحان کنید.", True)
-
-    await send_with_keyboard(client, chat_id, "✅ فایل ارسال شد. در حال پردازش و تغییر صدای شما...\n(لطفا چند دقیقه صبور باشید)", False)
+    proc_msg = await send_with_keyboard(client, chat_id, f"⏳ در حال آماده‌سازی فایل‌ها...\n(مدل: {model_name})", False)
     
-    final_filename = None
     async with aiohttp.ClientSession() as session:
-        for _ in range(1000):
+        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)
+
+        await send_with_keyboard(client, chat_id, "✅ فایل ارسال شد. در حال پردازش و تغییر صدای شما...\n(لطفا چند دقیقه صبور باشید)", False)
+        
+        final_filename = None
+        for _ in range(10000):
             await asyncio.sleep(5)
             try:
-                async with session.get(f"{LEGACY_BASE_URL}/status/{job_id}", timeout=30) as c_resp:
+                async with session.get(f"{LEGACY_BASE_URL}/status/{job_id}", timeout=20) as c_resp:
                     if c_resp.status == 200:
                         c_data = await c_resp.json()
                         if c_data.get("status") == "completed":
@@ -1022,39 +918,32 @@ 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)
-        
-        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)
+        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)
 
     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(15):
+    for up_att in range(3):
         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(5)
+        await asyncio.sleep(4)
 
     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)
 
@@ -1244,7 +1133,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:
@@ -1297,9 +1186,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(30):
+    for attempt in range(5):
         keys_to_try = HF_TOKENS.copy()
         random.shuffle(keys_to_try)
         for token in keys_to_try:
@@ -1313,12 +1202,10 @@ async def process_image(client, chat_id, prompt, size_choice="1"):
                 )
                 break 
             except Exception as e:
-                err_str = str(e).lower()
-                if "429" in err_str or "too many" in err_str:
-                    await asyncio.sleep(10)
+                last_error_log = str(e)
                 continue
         if generated_image: break
-        await asyncio.sleep(5)
+        await asyncio.sleep(2)
             
     try:
         if proc_msg:
@@ -1328,7 +1215,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"❌ سرورهای ساخت عکس به شدت شلوغ هستند. لطفاً مجدداً امتحان کنید.", True)
+        return await send_with_keyboard(client, chat_id, f"❌ عکس ساخته نشد.\n\n⚠️ خطا:\n{last_error_log[:200]}", True)
 
     try:
         file_name = f"image_{uuid.uuid4().hex}.jpg"
@@ -1337,25 +1224,26 @@ async def process_image(client, chat_id, prompt, size_choice="1"):
         caption_text = f"🎨 تصویر شما با پرامپت هوشمند آماده شد!\n\n📏 ابعاد تصویر: {size_name}\n✨ ایده اولیه: {prompt}"
         
         upload_result = False
-        # پافشاری ۱۵ بار روی ارسال عکس به روبیکا
-        for up_att in range(15):
+        error_log_img = ""
+        for up_att in range(3):
             res = await helper_upload_file(client, chat_id, file_name, "Image", caption_text)
             if res is True:
                 upload_result = True
                 break
             else:
-                await asyncio.sleep(5)
+                error_log_img = res
+                await asyncio.sleep(4)
         
         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"❌ عکس با موفقیت ساخته شد اما روبیکا به دلیل ترافیک بالا اجازه ارسال نداد.", True)
+            await send_with_keyboard(client, chat_id, f"❌ عکس ساخته شد اما آپلود در روبیکا با خطا مواجه شد:\n`{str(error_log_img)[:800]}`", True)
             
         if os.path.exists(file_name): os.remove(file_name)
     except Exception as e: 
-        pass
+        await send_with_keyboard(client, chat_id, f"❌ خطا در ذخیره و ارسال عکس:\n{str(e)[:150]}", True)
 
 # ==============================================================================
 # 🟢 پارت 15: توابع ترجمه و ویرایش عکس با هوش مصنوعی (Flux.2)
@@ -1482,9 +1370,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(30):
+        for attempt in range(10):
             workers = WORKER_URLS.copy()
             random.shuffle(workers)
             async with aiohttp.ClientSession(headers=headers, timeout=aiohttp.ClientTimeout(total=600)) as session:
@@ -1496,12 +1384,13 @@ 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
-                            elif response.status == 429: # مسدودیت موقت
-                                await asyncio.sleep(10)
-                    except Exception: 
+                                else: last_error = "فایل نامعتبر"
+                            else: last_error = f"ارور ({response.status})"
+                    except Exception as e: 
+                        last_error = f"خطا: {str(e)}"
                         continue
             if audio_bytes: break
-            await asyncio.sleep(5)
+            await asyncio.sleep(2)
 
         try:
             if proc_msg:
@@ -1516,25 +1405,26 @@ async def process_tts(client, chat_id, user_text, speaker_id, speaker_name):
             await asyncio.sleep(1)
             
             upload_result_file = False
-            # پافشاری بالا روی ارسال فایل در روبیکا
-            for up_att in range(15):
+            error_log_tts = ""
+            for up_att in range(3):
                 res = await helper_upload_file(client, chat_id, file_name_mp3, "Music", "✅ صدای شما با موفقیت آماده شد (فایل MP3):")
                 if res is True:
                     upload_result_file = True
                     break
                 else:
-                    await asyncio.sleep(5)
+                    error_log_tts = res
+                    await asyncio.sleep(4)
             
             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"❌ صدای شما ساخته شد اما شلوغی سرور روبیکا مانع ارسال آن شد.", True)
+                await send_with_keyboard(client, chat_id, f"❌ فایل صدا ساخته شد اما سرور روبیکا اجازه آپلود نداد:\n`{str(error_log_tts)[:800]}`", True)
                 
             if os.path.exists(file_name_mp3): os.remove(file_name_mp3)
         else: 
-            await send_with_keyboard(client, chat_id, f"❌ سرورها درگیر هستند. لطفا دقایقی دیگر مجددا امتحان کنید.", True)
+            await send_with_keyboard(client, chat_id, f"❌ سرورها درگیر هستند.\nدلیل: {last_error}", True)
     except Exception: traceback.print_exc()
 
 # ==============================================================================