Update main.py

main.py

@@ -614,22 +614,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 +635,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 +643,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 +651,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 +672,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 +708,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 +742,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 +778,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 +879,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 +936,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 +1158,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 +1211,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 +1227,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 +1242,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 +1251,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 +1396,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 +1410,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 +1430,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()
 
 # ==============================================================================