Update main.py

main.py

@@ -610,163 +610,122 @@ HF_TOKENS_STR = os.environ.get("HF_TOKENS", "")
 HF_TOKENS =[k.strip() for k in HF_TOKENS_STR.split(",") if k.strip()]
 
 # ==============================================================================
-# 🟢 پارت 11: آپلودر قدرتمند و تابع ارسال فایل ضد خطا (نسخه نهایی ضد بمب اتم 🚀)
+# 🟢 پارت 11: آپلودر دوگانه هوشمند (آپلود در بله + بکاپ خودکار در روبیکا)
 # ==============================================================================
+BALE_BOT_TOKEN = os.environ.get("BALE_BOT_TOKEN", "").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 =[]
     
+    # ==========================================
+    # فاز 1: تلاش برای آپلود در بله (ساخت لینک)
+    # ==========================================
+    if BALE_BOT_TOKEN:
+        bale_chat_id = BALE_BOT_TOKEN.split(":")[0]
+        for attempt in range(3): # ۳ بار تلاش در سرور بله
+            try:
+                bale_url = f"https://tapi.bale.ai/bot{BALE_BOT_TOKEN}/sendDocument"
+                with open(abs_path, "rb") as f:
+                    form = aiohttp.FormData()
+                    form.add_field('chat_id', bale_chat_id)
+                    form.add_field('document', f, filename=os.path.basename(abs_path))
+                    
+                    async with aiohttp.ClientSession() as session:
+                        async with session.post(bale_url, data=form, timeout=120) as resp:
+                            if resp.status == 200:
+                                bale_data = await resp.json()
+                                if bale_data.get("ok"):
+                                    try:
+                                        file_id = bale_data['result']['document']['file_id']
+                                    except KeyError:
+                                        if 'audio' in bale_data['result']: file_id = bale_data['result']['audio']['file_id']
+                                        elif 'video' in bale_data['result']: file_id = bale_data['result']['video']['file_id']
+                                        elif 'voice' in bale_data['result']: file_id = bale_data['result']['voice']['file_id']
+                                        elif 'photo' in bale_data['result']: file_id = bale_data['result']['photo'][-1]['file_id']
+                                        else:
+                                            error_logs.append("فرمت در بله شناخته نشد.")
+                                            continue
+
+                                    download_url = f"https://tapi.bale.ai/file/bot{BALE_BOT_TOKEN}/{file_id}"
+                                    final_text = f"""{caption}\n\n━━━━━━━━━━━━━━━━━━━\n🌐 لینک دانلود فایل شما:\n\n{download_url}\n\n━━━━━━━━━━━━━━━━━━━\n⚠️ **راهنمای دانلود:**\nلطفاً لینک بالا را کپی کرده و در **مرورگر گوشی خود** باز کنید.\n*(مستقیماً کلیک نکنید)*"""
+                                    
+                                    send_res = await send_with_keyboard(client, chat_id, final_text, True)
+                                    if send_res: return True
+                                else:
+                                    error_logs.append(f"Bale API Err: {bale_data.get('description')}")
+                            else:
+                                error_logs.append(f"Bale HTTP Error: {resp.status}")
+                                if resp.status in[500, 502, 503]: await asyncio.sleep(2)
+            except Exception as e:
+                error_logs.append(f"Bale Err: {str(e)[:100]}")
+                await asyncio.sleep(2)
+
+    # ==========================================
+    # فاز 2: سیستم نجات! (آپلود مستقیم در روبیکا)
+    # (اگر بله قطع بود، فایل مستقیما تو روبیکا ارسال میشه)
+    # ==========================================
     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"
     
-    # روبیکا فرمت‌های خاصی را قبول می‌کند.
-    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):
+    fallback_caption = f"{caption}\n\n⚠️ (به دلیل اختلال سرورهای بله، فایل موقتاً به صورت مستقیم در روبیکا ارسال شد)"
+
+    for attempt in range(5):
         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)
-                    sent_success = True
-                except TypeError:
-                    await client.send_photo(chat_id, abs_path, caption=caption)
-                    sent_success = True
-                    
-            # تلاش برای ارسال ویس
+                try: await client.send_photo(chat_id, photo=abs_path, caption=fallback_caption); sent_success = True
+                except: await client.send_photo(chat_id, abs_path, caption=fallback_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)
-                    sent_success = True
-                except TypeError:
-                    await client.send_voice(chat_id, file=abs_path, caption=caption)
-                    sent_success = True
-                    
-            # تلاش برای ارسال موزیک
+                try: await client.send_voice(chat_id, abs_path, caption=fallback_caption); sent_success = True
+                except: await client.send_voice(chat_id, file=abs_path, caption=fallback_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)
-                    sent_success = True
-                except TypeError:
-                    await client.send_music(chat_id, music=abs_path, caption=caption)
-                    sent_success = True
-
-            # *** سیستم ضد بمب اتم فاز 1 ***
-            # اگر هیچکدام از متدهای بالا وجود نداشت یا به هر دلیلی ارسال نشد، حتما به عنوان فایل (سند) بفرست تا معطل نشود
+                try: await client.send_music(chat_id, abs_path, caption=fallback_caption); sent_success = True
+                except: await client.send_music(chat_id, music=abs_path, caption=fallback_caption); sent_success = True
+            
             if not sent_success:
                 if hasattr(client, "send_document"):
-                    try:
-                        await client.send_document(chat_id, document=abs_path, caption=caption)
-                        sent_success = True
-                    except TypeError:
-                        await client.send_document(chat_id, abs_path, caption=caption)
-                        sent_success = True
+                    try: await client.send_document(chat_id, document=abs_path, caption=fallback_caption); sent_success = True
+                    except: await client.send_document(chat_id, abs_path, caption=fallback_caption); sent_success = True
                 elif hasattr(client, "send_file"):
-                    try:
-                        await client.send_file(chat_id, file=abs_path)
-                    except TypeError:
-                        await client.send_file(chat_id, abs_path)
-                    if caption:
-                        await send_with_keyboard(client, chat_id, caption, True)
+                    try: await client.send_file(chat_id, file=abs_path)
+                    except: await client.send_file(chat_id, abs_path)
+                    if fallback_caption: await send_with_keyboard(client, chat_id, fallback_caption, True)
                     sent_success = True
-
+                    
             if sent_success:
                 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)
-            else: 
-                await asyncio.sleep(2)
+            error_logs.append(f"Rubpy Send Err: {str(e)[:100]}")
+            await asyncio.sleep(3)
 
-    # --- فاز دوم (سنگر آخر): آپلود دستی (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=30) as resp:
-                    if resp.status != 200:
-                        error_logs.append(f"Request HTTP {resp.status}")
-                        await asyncio.sleep(2)
-                        continue
-                        
-                    req_data = await resp.json()
-                    if req_data.get("status") == "OK":
-                        upload_url = req_data.get("data", {}).get("upload_url")
-                        if upload_url:
-                            with open(abs_path, "rb") as f:
-                                form = aiohttp.FormData()
-                                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)
-                                        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)
-                                        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)
-                                        continue
-
-                                    if up_data.get("status") == "OK" or up_data.get("status_det") == "OK":
-                                        if "data" in up_data and isinstance(up_data["data"], dict):
-                                            final_file_id = up_data["data"].get("file_id") or up_data["data"].get("id")
-                                        elif "file_id" in up_data: 
-                                            final_file_id = up_data.get("file_id")
-                                            
-                                    if final_file_id:
-                                        send_payload = {
-                                            "chat_id": str(chat_id),
-                                            "file_id": str(final_file_id),
-                                            "text": caption,
-                                            "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
-                                                
-                                            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" # دور زدن گیر دادن روبیکا
-                                        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)[:100]}")
-            await asyncio.sleep(2.5)
+    return "\n".join(error_logs[-5:])
+
+# ==============================================================================
+# 🟢 پارت 12: توابع تغییر صدا و لیست گویندگان
+# ==============================================================================
+# ==================================================================
+# لیست‌های اولیه ربات
+# ==================================================================
+WORKER_URLS =["https://opera8-ttspro.hf.space/generate"]
+
+SPEAKERS = {
+    "1": ("شهاب (مرد)", "Charon"), "2": ("آوا (زن)", "Zephyr"), "3": ("نوید (مرد)", "Achird"), 
+    "4": ("آرمان (مرد)", "Zubenelgenubi"), "5": ("مهسا (زن)", "Vindemiatrix"), "6": ("دانا (مرد)", "Rasalgethi"),
+    "7": ("سامان (مرد)", "Sadachbia"), "8": ("آرش (مرد)", "Sadaltager"), "9": ("شبنم (زن)", "Sulafat"),
+    "10": ("سحر (زن)", "Laomedeia"), "11": ("مریم (زن)", "Achernar"), "12": ("بهرام (مرد)", "Alnilam"),
+    "13": ("نیکان (مرد)", "Schedar"), "14": ("فرناز (زن)", "Gacrux"), "15": ("سارا (زن)", "Pulcherrima"),
+    "16": ("مانی (مرد)", "Umbriel"), "17": ("آرتین (مرد)", "Algieba"), "18": ("دلنواز (زن)", "Despina"),
+    "19": ("روژان (زن)", "Erinome"), "20": ("امید (مرد)", "Algenib"), "21": ("بردیا (مرد)", "Orus"),
+    "22": ("ترانه (زن)", "Aoede"), "23": ("نیکو (زن)", "Callirrhoe"), "24": ("هستی (زن)", "Autonoe"),
+    "25": ("کامیار (مرد)", "Enceladus"), "26": ("کیانوش (مرد)", "Iapetus"), "27": ("پویا (مرد)", "Puck"),
+    "28": ("مهتاب (زن)", "Kore"), "29": ("سام (مرد)", "Fenrir"), "30": ("لیدا (زن)", "Leda")
+}
 
-    return "\n".join(error_logs[-6:])
+user_states = {}
 
 # ==============================================================================
 # 🟢 پارت 12: توابع تغییر صدا و لیست گویندگان
@@ -801,20 +760,33 @@ async def process_standard_vc_job(client, chat_id, src_bytes, ref_bytes, job_typ
     proc_msg = 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')
+        job_id = None
+        total_chunks = 1
+        chunks =[]
         
-        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)
+        # ♻️ سیستم تلاش مجدد پنهان (دور زدن ارور 429)
+        for attempt in range(8):
+            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:
+                        data = await resp.json()
+                        job_id = data.get("job_id")
+                        total_chunks = data.get("total_chunks", 1)
+                        chunks = data.get("chunks",[])
+                        break
+                    elif resp.status == 429:
+                        await asyncio.sleep(4 + attempt * 2) # تاخیر تصاعدی تا سرور خلوت شود
+                    else:
+                        await asyncio.sleep(3)
+            except Exception as e:
+                await asyncio.sleep(3)
+                
+        if not job_id:
+            return await send_with_keyboard(client, chat_id, "❌ سرور پردازش صدا به دلیل ترافیک بالا پاسخگو نیست (خطای 429). لطفاً چند دقیقه دیگر امتحان کنید.", True)
 
         await send_with_keyboard(client, chat_id, "✅ فایل‌ها ارسال شد. در حال پردازش و تغییر صدا...\n(لطفا چند دقیقه صبور باشید)", False)
         
@@ -829,8 +801,10 @@ async def process_standard_vc_job(client, chat_id, src_bytes, ref_bytes, job_typ
                         if c_data.get("status") == "completed":
                             final_filename = c_data.get("filename")
                             break
-                        elif c_data.get("status") in ["failed", "error"]:
+                        elif c_data.get("status") in["failed", "error"]:
                             return await send_with_keyboard(client, chat_id, "❌ خطای سرور در حین پردازش صدا.", True)
+                    elif c_resp.status == 429:
+                        await asyncio.sleep(5)
             except Exception:
                 pass
                 
@@ -838,15 +812,24 @@ async def process_standard_vc_job(client, chat_id, src_bytes, ref_bytes, job_typ
             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)
+        await send_with_keyboard(client, chat_id, "📥 پردازش تمام شد! در حال آماده‌سازی لینک دانلود...", False)
+        
+        result_bytes = None
+        for attempt in range(5):
+            try:
+                async with session.get(download_url, timeout=43200) as d_resp:
+                    if d_resp.status == 200:
+                        result_bytes = await d_resp.read()
+                        break
+                    elif d_resp.status == 429:
+                        await asyncio.sleep(4 + attempt * 2)
+                    else:
+                        await asyncio.sleep(3)
+            except Exception:
+                await asyncio.sleep(3)
+
+        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)
@@ -864,7 +847,7 @@ async def process_standard_vc_job(client, chat_id, src_bytes, ref_bytes, job_typ
             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)
 
@@ -875,26 +858,37 @@ async def process_legacy_vc_job(client, chat_id, src_bytes, model_url, pitch, mo
     proc_msg = 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')
+        job_id = None
         
-        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)
+        # ♻️ سیستم تلاش مجدد پنهان (دور زدن ارور 429)
+        for attempt in range(8):
+            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:
+                        data = await resp.json()
+                        job_id = data.get("job_id")
+                        break
+                    elif resp.status == 429:
+                        await asyncio.sleep(4 + attempt * 2)
+                    else:
+                        await asyncio.sleep(3)
+            except Exception as e:
+                await asyncio.sleep(3)
+                
+        if not job_id:
+            return await send_with_keyboard(client, chat_id, "❌ سرور پردازش صدا به دلیل ترافیک بالا پاسخگو نیست (خطای 429). لطفاً چند دقیقه دیگر امتحان کنید.", True)
 
         await send_with_keyboard(client, chat_id, "✅ فایل ارسال شد. در حال پردازش و تغییر صدای شما...\n(لطفا چند دقیقه صبور باشید)", False)
         
@@ -910,6 +904,8 @@ async def process_legacy_vc_job(client, chat_id, src_bytes, model_url, pitch, mo
                             break
                         elif c_data.get("status") in["failed", "error", "not_found"]:
                             return await send_with_keyboard(client, chat_id, "❌ خطای سرور در حین پردازش.", True)
+                    elif c_resp.status == 429:
+                        await asyncio.sleep(5)
             except Exception:
                 pass
                 
@@ -917,15 +913,24 @@ async def process_legacy_vc_job(client, chat_id, src_bytes, model_url, pitch, mo
             return await send_with_keyboard(client, chat_id, "❌ پردازش بیش از حد طول کشید و متوقف شد.", True)
 
         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)
+        await send_with_keyboard(client, chat_id, "📥 پردازش تمام شد! در حال آماده‌سازی لینک دانلود...", False)
+        
+        result_bytes = None
+        for attempt in range(5):
+            try:
+                async with session.get(download_url, timeout=43200) as d_resp:
+                    if d_resp.status == 200:
+                        result_bytes = await d_resp.read()
+                        break
+                    elif d_resp.status == 429:
+                        await asyncio.sleep(4 + attempt * 2)
+                    else:
+                        await asyncio.sleep(3)
+            except Exception:
+                await asyncio.sleep(3)
+                
+        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)
@@ -939,11 +944,12 @@ async def process_legacy_vc_job(client, chat_id, src_bytes, model_url, pitch, mo
         await asyncio.sleep(4)
 
     if upload_result is True:
-        if not creds.get("is_premium"):
+        # اگر مدل باب اسفنجی نبود، از اعتبار کسر کن
+        if not creds.get("is_premium") and model_name != "باب اسفنجی":
             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)
 
@@ -1428,7 +1434,7 @@ async def process_tts(client, chat_id, user_text, speaker_id, speaker_name):
     except Exception: traceback.print_exc()
 
 # ==============================================================================
-# 🟢 پارت 17: سیستم ساخت پادکست
+# 🟢 پارت 17: سیستم ساخت پادکست (ضد قطعی و مقاوم در برابر 429)
 # ==============================================================================
 async def process_podcast(client, chat_id, prompt):
     str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
@@ -1446,11 +1452,23 @@ async def process_podcast(client, chat_id, prompt):
     payload_create = {"prompt": prompt, "available_speakers": available_speakers}
     
     async with aiohttp.ClientSession() as session:
-        try:
-            async with session.post(url_create, json=payload_create, timeout=60) as resp:
-                if resp.status != 202: return await send_with_keyboard(client, chat_id, f"❌ خطا در سرور پادکست: وضعیت {resp.status}", True)
-                task_id = (await resp.json()).get("task_id")
-        except Exception as e: return await send_with_keyboard(client, chat_id, f"❌ خطا در اتصال به سرور پادکست:\n{str(e)}", True)
+        task_id = None
+        # ♻️ تلاش مجدد برای جلوگیری از شکست در صورت شلوغی سرور
+        for attempt in range(8):
+            try:
+                async with session.post(url_create, json=payload_create, timeout=60) as resp:
+                    if resp.status == 202: 
+                        task_id = (await resp.json()).get("task_id")
+                        break
+                    elif resp.status == 429:
+                        await asyncio.sleep(4 + attempt * 2)
+                    else:
+                        await asyncio.sleep(3)
+            except Exception as e: 
+                await asyncio.sleep(3)
+        
+        if not task_id:
+            return await send_with_keyboard(client, chat_id, "❌ ترافیک سرور پادکست بالا است (خطای 429). لطفاً چند دقیقه دیگر امتحان کنید.", True)
 
         url_status = f"https://opera8-podgen.hf.space/api/podcast-status/{task_id}"
         script_data = None
@@ -1465,6 +1483,8 @@ async def process_podcast(client, chat_id, prompt):
                             break
                         elif status_data.get("status") == "failed":
                             return await send_with_keyboard(client, chat_id, "❌ متأسفانه هوش مصنوعی نتوانست برای این موضوع سناریو بنویسد.", True)
+                    elif resp.status == 429:
+                        await asyncio.sleep(5)
             except Exception: pass
             
         if not script_data: return await send_with_keyboard(client, chat_id, "❌ زمان انتظار برای نوشتن سناریو به پایان رسید.", True)
@@ -1485,16 +1505,21 @@ async def process_podcast(client, chat_id, prompt):
             payload_gen = {"text": turn["dialogue"], "speaker": turn["speaker_id"], "temperature": 0.9}
             chunk_audio_bytes = None
             
-            for attempt in range(10):
+            # ♻️ حلقه ضد قطعی برای ریکورد تک تک دیالوگ ها
+            for attempt in range(15):
                 try:
                     async with session.post(url_generate, json=payload_gen, timeout=120) as resp:
                         if resp.status == 200:
                             chunk_audio_bytes = await resp.read()
                             break
+                        elif resp.status == 429:
+                            await asyncio.sleep(4 + attempt * 2)
+                        else:
+                            await asyncio.sleep(2)
                 except Exception: await asyncio.sleep(2)
             
             if not chunk_audio_bytes: 
-                return await send_with_keyboard(client, chat_id, f"❌ خطا در تولید صدای بخش {index+1} از سرور. عملیات متوقف شد.", True)
+                return await send_with_keyboard(client, chat_id, f"❌ خطا در تولید صدای بخش {index+1} به دلیل شلوغی سرور. عملیات متوقف شد.", True)
                 
             try:
                 combined_audio = await asyncio.to_thread(sync_combine_audio, combined_audio, chunk_audio_bytes)
@@ -1848,36 +1873,838 @@ async def process_create_file(client, chat_id, topic):
         await send_with_keyboard(client, chat_id, "❌ متأسفانه پس از تلاش‌های مکرر، سرور قادر به ساخت و ارسال هیچ‌یک از فایل‌ها نبود و اعتباری از شما کسر نشد.", True)
 
 # ==============================================================================
-# 🔴 پارت 20: نسخه پاکسازی اضطراری (مخصوص تخلیه صف در دیتابیس جدید v3)
+# 🟢 پارت 20: بدنه اصلی ربات (Handler)، دستورات مدیریتی، حلقه اصلی و استارت
 # ==============================================================================
+# ==================================================================
+# حلقه و مدیریت اصلی ربات
+# ==================================================================
+
+# 🧹 سیستم پاکسازی هوشمند رم (Garbage Collector) مخصوص هزاران کاربر
+async def ram_garbage_collector():
+    """این تابع در پس‌زمینه می‌چرخد و فایل‌های رها شده در حافظه را پاک می‌کند تا رم سرور پر نشود"""
+    while True:
+        await asyncio.sleep(1800)  # هر ۳۰ دقیقه یکبار بررسی می‌��ند
+        now = time.time()
+        try:
+            for uid in list(user_states.keys()):
+                # اگر کاربر بیش از ۱ ساعت (۳۶۰۰ ثانیه) با ربات کار نکرده بود
+                if now - user_states[uid].get("last_time", 0) > 3600:
+                    # پاک کردن بایت‌های فایل‌های سنگین از رم سرور
+                    if user_states[uid].get("file_bytes") is not None:
+                        user_states[uid]["file_bytes"] = None
+                    if user_states[uid].get("ref_bytes") is not None:
+                        user_states[uid]["ref_bytes"] = None
+                    # خالی کردن تاریخچه چت برای آزادسازی رم (نگه داشتن ۵ پیام آخر)
+                    if len(user_states[uid].get("history",[])) > 5:
+                        user_states[uid]["history"] = user_states[uid]["history"][-5:]
+        except Exception as e:
+            pass
 
 if not bot_token:
-    print("خطا: توکن وارد نشده!")
+    print("خطا: توکن ربات روبیکا وارد نشده است!")
 else:
     bot = BotClient(bot_token)
 
     @bot.on_update(filters.private)
     async def main_handler(client, update):
+        global BOT_GUID
+        
         try:
-            # فقط استخراج آیدی پیام
+            if not BOT_GUID:
+                try:
+                    me_info = await client.get_me()
+                    if me_info and hasattr(me_info, 'user'):
+                        BOT_GUID = getattr(me_info.user, 'user_guid', None)
+                except Exception:
+                    pass
+
             msg_obj = getattr(update, "message", None) or getattr(update, "new_message", None)
+            
+            author_id = getattr(update, 'author_guid', None)
+            if not author_id and msg_obj:
+                author_id = msg_obj.get('author_object_guid') if isinstance(msg_obj, dict) else getattr(msg_obj, 'author_object_guid', None)
+            
+            if BOT_GUID and author_id == BOT_GUID:
+                return
+            
+            chat_id = getattr(update, 'object_guid', None) or getattr(update, 'author_guid', None) or getattr(update, "chat_id", None)
+            if not chat_id: return
+            
             msg_id = getattr(update, "message_id", None)
             if not msg_id and msg_obj:
                 msg_id = msg_obj.get("message_id") if isinstance(msg_obj, dict) else getattr(msg_obj, "message_id", None)
             
-            if not msg_id: return
-            str_msg_id = str(msg_id).strip()
-
-            # ثبت در دیتابیس v3 بدون فرستادن هیچ پاسخی
-            if not is_message_processed(str_msg_id):
+            str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
+            creds = get_user_credits(str_chat_id)
+
+            # ===================================================================
+            # 🛑 سیستم صد در صد قطعی ضد تکرار پیام با استفاده از دیتابیس ابری
+            # ===================================================================
+            if msg_id:
+                str_msg_id = str(msg_id).strip()
+                # 1. اگر پیام قبلاً در دیتابیس ثبت شده بود، ربات بی‌درنگ کار را متوقف می‌کند
+                if is_message_processed(str_msg_id):
+                    return
+                # 2. اگر پیام جدید بود، در همان لحظه در دیتابیس ذخیره می‌شود تا دیگر هرگز خوانده نشود
                 mark_message_processed(str_msg_id)
-                print(f"🗑️ [V3-CLEARING] پیام {str_msg_id} ثبت شد.")
+            # ===================================================================
+
+            user_text = getattr(update, "text", "") or getattr(msg_obj, "text", "")
+            user_text_str = str(user_text).strip() if user_text else ""
+            user_text_lower = user_text_str.lower()
+
+            if is_user_spamming(str_chat_id):
+                return
+
+            # ===================================================================
+            # 🟢 ثبت آخرین زمان فعالیت کاربر برای سیستم پاکسازی رم
+            # ===================================================================
+            if str_chat_id not in user_states:
+                user_states[str_chat_id] = {"mode": None, "text": "", "history":[], "file_bytes": None, "file_name": None, "last_time": time.time()}
+            else:
+                user_states[str_chat_id]["last_time"] = time.time()  # آپدیت زمان فعالیت
+
+            if user_text_lower.startswith(f"{ADMIN_CODE} pro=") or user_text_lower.startswith(f"{ADMIN_CODE}pro="):
+                parts = user_text_str.split("=", 1)
+                if len(parts) >= 2:
+                    target_id = parts[1].replace("`", "").replace("'", "").replace('"', "").strip()
+                    if target_id:
+                        if target_id not in user_credits_db or not isinstance(user_credits_db[target_id], dict):
+                            user_credits_db[target_id] = {
+                                "is_premium": False,
+                                "expire_date": None,
+                                "last_reset": "",
+                                "chat": 10,
+                                "image": 5,
+                                "edit_image": 1,
+                                "podcast": 2,
+                                "tts": 5,
+                                "file": 1,
+                                "stt": 5,
+                                "voice_conv": 3,
+                                "voice_clone": 1,
+                                "last_msg_id": 0,
+                                "has_joined": True,
+                                "invited_count": 0,
+                                "used_referral": False,
+                                "referral_code": ""
+                            }
+                        
+                        user_credits_db[target_id]["is_premium"] = True
+                        expire_time = datetime.datetime.now() + datetime.timedelta(days=30)
+                        user_credits_db[target_id]["expire_date"] = expire_time.isoformat()
+                        
+                        user_credits_db[target_id]["chat"] = 999999
+                        user_credits_db[target_id]["image"] = 20
+                        user_credits_db[target_id]["edit_image"] = 10
+                        user_credits_db[target_id]["podcast"] = 999999
+                        user_credits_db[target_id]["tts"] = 999999
+                        user_credits_db[target_id]["file"] = 999999
+                        user_credits_db[target_id]["stt"] = 999999
+                        user_credits_db[target_id]["voice_conv"] = 999999
+                        user_credits_db[target_id]["voice_clone"] = 999999
+                        
+                        save_db(user_credits_db)
+                        await send_with_keyboard(client, chat_id, f"✅ حساب کاربر `{target_id}` به مدت ۳۰ روز شارژ شد و به پرو ارتقا یافت.", False)
+                        try:
+                            await send_with_keyboard(client, target_id, "🎉 **کاربر گرامی، تبریک!**\n\nحساب شما با موفقیت توسط پشتیبانی به **🌟 نسخه پرو (ویژه)** ارتقا یافت.\nهم‌اکنون بسته‌های نامحدود و طلایی یک‌ماهه شما فعال گردید.\n\nجهت مشاهده جزئیات روی دکمه «حساب کاربری 👤» کلیک کنید.", True)
+                        except Exception: pass
+                return
+                
+            if user_text_lower.startswith(f"{ADMIN_CODE} free=") or user_text_lower.startswith(f"{ADMIN_CODE}free="):
+                parts = user_text_str.split("=", 1)
+                if len(parts) >= 2:
+                    target_id = parts[1].replace("`", "").replace("'", "").replace('"', "").strip()
+                    if target_id:
+                        if target_id in user_credits_db and isinstance(user_credits_db[target_id], dict):
+                            user_credits_db[target_id]["is_premium"] = False
+                            user_credits_db[target_id]["expire_date"] = None
+                            user_credits_db[target_id]["last_reset"] = "" 
+                            save_db(user_credits_db)
+                        await send_with_keyboard(client, chat_id, f"✅ اشتراک کاربر `{target_id}` لغو شد و به رایگان تبدیل گشت.", False)
+                        try:
+                            await send_with_keyboard(client, target_id, "⚠️ کاربر گرامی، اشتراک ویژه شما به پایان رسید و حساب شما به نسخه رایگان (آزمایشی) تغییر یافت.", True)
+                        except Exception: pass
+                return
+
+            if user_text_lower.startswith(f"{ADMIN_CODE} =") or user_text_lower.startswith(f"{ADMIN_CODE}="):
+                parts = user_text_str.split("=", 1)
+                if len(parts) >= 2:
+                    target_id = parts[1].replace("`", "").replace("'", "").replace('"', "").strip()
+                    if target_id:
+                        if target_id in user_credits_db and isinstance(user_credits_db[target_id], dict):
+                            t_creds = user_credits_db[target_id]
+                            is_prem = t_creds.get("is_premium", False)
+                            
+                            if is_prem:
+                                expire_txt = "نامشخص"
+                                days_left = 0
+                                if t_creds.get("expire_date"):
+                                    exp_d = datetime.datetime.fromisoformat(t_creds["expire_date"])
+                                    now = datetime.datetime.now()
+                                    diff = exp_d - now
+                                    days_left = diff.days if diff.days >= 0 else 0
+                                    
+                                    jy, jm, jd = gregorian_to_jalali(exp_d.year, exp_d.month, exp_d.day)
+                                    expire_txt = f"{jy:04d}/{jm:02d}/{jd:02d}"
+                                status_text = f"🌟 نسخه پرو (ویژه)\n📅 انقضا: {expire_txt}\n⏳ باقیمانده: {days_left} روز"
+                            else:
+                                status_text = "🥉 نسخه رایگان (آزمایشی)\n⏳ وضعیت: سهمیه روزانه محدود"
+
+                            chat_rem = "نامحدود ∞" if is_prem else t_creds.get('chat', 0)
+                            vc_rem = "نامحدود ∞" if is_prem else t_creds.get('voice_conv', 0)
+                            clone_rem = "نامحدود ∞" if is_prem else t_creds.get('voice_clone', 0)
+                            podcast_rem = "نامحدود ∞" if is_prem else t_creds.get('podcast', 0)
+                            tts_rem = "نامحدود ∞" if is_prem else t_creds.get('tts', 0)
+                            file_rem = "نامحدود ∞" if is_prem else t_creds.get('file', 0)
+                            stt_rem = "نامحدود ∞" if is_prem else t_creds.get('stt', 0)
+                            image_rem = t_creds.get('image', 0)
+                            edit_image_rem = t_creds.get('edit_image', 0)
+                            invs = t_creds.get('invited_count', 0)
+                            joined_status = "بله ✅" if t_creds.get('has_joined') else "خیر ❌"
+
+                            info_msg = f"""🔍 **اطلاعات اختصاصی کاربر:**
+👤 شناسه: `{target_id}`
+عضو کانال: {joined_status}
+
+🔹 **وضعیت اشتراک:**
+{status_text}
+🎁 **تعداد افراد دعوت شده:** {invs} نفر
+
+📊 **سهمیه باقی‌مانده فعلی:**
+💬 چت: {chat_rem}
+🎨 تولید عکس: {image_rem}
+🪄 ویرایش عکس: {edit_image_rem}
+🎙️ تغییر صدا: {vc_rem}
+👤 کلون کردن صدا: {clone_rem}
+🎙 پادکست: {podcast_rem}
+🗣 متن به صدا: {tts_rem}
+📁 تحلیل فایل: {file_rem}
+📝 صدا به متن: {stt_rem}"""
+                            await send_with_keyboard(client, chat_id, info_msg, False)
+                        else:
+                            await send_with_keyboard(client, chat_id, f"❌ کاربری با شناسه `{target_id}` در دیتابیس ربات یافت نشد.", False)
+                return
+
+            is_file = False
+            file_name = f"unknown_file_{uuid.uuid4().hex[:6]}.jpg"
             
-        except Exception:
-            pass
+            if msg_obj:
+                for attr in['file', 'file_inline', 'photo', 'voice', 'audio', 'document', 'video']:
+                    file_attr = getattr(msg_obj, attr, None)
+                    if file_attr:
+                        is_file = True
+                        file_name = getattr(file_attr, 'file_name', file_name)
+                        break
+                
+                if not is_file and hasattr(msg_obj, 'to_dict'):
+                    msg_dict = msg_obj.to_dict()
+                    for attr in['file', 'file_inline', 'photo', 'voice', 'audio', 'document', 'video']:
+                        if attr in msg_dict:
+                            is_file = True
+                            file_attr = msg_dict.get(attr, {})
+                            file_name = file_attr.get('file_name', file_name) if isinstance(file_attr, dict) else file_name
+                            break
+
+            if user_text_str == "✅ عضو شدم":
+                if not creds.get("has_joined", False):
+                    user_credits_db[str_chat_id]["has_joined"] = True
+                    save_db(user_credits_db)
+                    await send_with_keyboard(client, chat_id, "🎉 **عضویت شما با موفقیت تایید شد! خیلی خوش آمدید.**\n\nحالا می‌توانید از تمامی امکانات ربات استفاده کنید.\nلطفاً یکی از گزینه‌های منو را انتخاب کنید:", True)
+                    return
+                else:
+                    await send_with_keyboard(client, chat_id, "✅ شما قبلاً عضو شده‌اید! لطفا از منوی اصلی استفاده کنید.", True)
+                    return
+
+            if not creds.get("has_joined", False):
+                join_msg = "👋 **سلام کاربر گرامی!**\n\nجهت استفاده از خدمات ربات هوش مصنوعی آلفا و مطلع شدن از آخرین آپدیت‌ها، لطفا ابتدا در کانال رسمی ما عضو شوید:\n\n📢 **آیدی کانال:** @aialpha\n\n👇 پس از عضویت در کانال، بر روی دکمه **«✅ عضو شدم»** کلیک کنید تا ربات برای شما فعال شود."
+                try:
+                    payload = {"chat_id": chat_id, "text": join_msg, "chat_keypad_type": "New", "chat_keypad": JOIN_KEYPAD_DICT}
+                    await client._make_request("sendMessage", payload)
+                except Exception:
+                    await client.send_message(chat_id, join_msg)
+                return
+
+            if user_text_lower.startswith("/start"):
+                user_states[str_chat_id]["mode"] = None
+                user_states[str_chat_id]["file_bytes"] = None
+                await send_with_keyboard(client, chat_id, "سلام! به ربات هوش مصنوعی آلفا خوش آمدید 🤖\n\nلطفاً برای شروع، از کیبورد پایین یکی از بخش‌ها را انتخاب کنید:", True)
+                return
+
+            if user_text_str in["سلام", "لغو", "/cancel", "❌ لغو", "برگشت♻️"]:
+                user_states[str_chat_id]["mode"] = None
+                user_states[str_chat_id]["file_bytes"] = None
+                await send_with_keyboard(client, chat_id, "سلام! به ربات هوش مصنوعی آلفا خوش آمدید 🤖\n\nلطفاً برای شروع، از کیبورد پایین یکی از بخش‌ها را انتخاب کنید:", True)
+                return
+
+            if user_text_str in["/account", "حساب کاربری 👤"]:
+                is_prem = creds.get("is_premium", False)
+                
+                if is_prem:
+                    expire_txt = "نامشخص"
+                    days_left = 0
+                    if creds.get("expire_date"):
+                        exp_d = datetime.datetime.fromisoformat(creds["expire_date"])
+                        now = datetime.datetime.now()
+                        diff = exp_d - now
+                        days_left = diff.days if diff.days >= 0 else 0
+                        
+                        jy, jm, jd = gregorian_to_jalali(exp_d.year, exp_d.month, exp_d.day)
+                        expire_txt = f"{jy:04d}/{jm:02d}/{jd:02d} (ساعت {exp_d.hour:02d}:{exp_d.minute:02d})"
+                        
+                    status_text = "🌟 نسخه پرو (ویژه)"
+                    expire_info = f"\n📅 **تاریخ انقضا:** {expire_txt}\n⏳ **زمان باقیمانده:** {days_left} روز"
+                    daily_note = "*نکته: سهمیه پردازشی شما مختص همین دوره یک‌ماهه می‌باشد.*"
+                else:
+                    status_text = "🥉 نسخه رایگان (آزمایشی)"
+                    expire_info = ""
+                    daily_note = "*نکته: سهمیه شما هر روز ساعت ۰۰:۰۰ بامداد به صورت خودکار مجدداً شارژ می‌گردد.*"
+
+                chat_rem = "نامحدود ∞" if is_prem else creds['chat']
+                vc_rem = "نامحدود ∞" if is_prem else creds.get('voice_conv', 0)
+                clone_rem = "نامحدود ∞" if is_prem else creds.get('voice_clone', 0)
+                podcast_rem = "نامحدود ∞" if is_prem else creds['podcast']
+                tts_rem = "نامحدود ∞" if is_prem else creds['tts']
+                file_rem = "نامحدود ∞" if is_prem else creds['file']
+                stt_rem = "نامحدود ∞" if is_prem else creds['stt']
+                image_rem = creds['image']
+                edit_image_rem = creds['edit_image']
+                invited_count = creds.get('invited_count', 0)
+                my_code = get_or_create_referral_code(str_chat_id)
+
+                account_profile = f"""👤 **اطلاعات حساب کاربری شما**
+
+🔹 **شناسه یکتا:** `{chat_id}`
+🎫 **کد هدیه شما:** `{my_code}`
+🔹 **وضعیت اشتراک:** {status_text}{expire_info}
+🎁 **تعداد افراد دعوت شده:** {invited_count} نفر
+
+📊 **سهمیه باقی‌مانده شما:**
+- 💬 چت هوشمند: {chat_rem}
+- 🎨 تولید تصویر: {image_rem} عدد
+- 🪄 ویرایش تصویر: {edit_image_rem} عدد
+- 🎙️ تغییر صدا: {vc_rem}
+- 👤 کلون کردن صدا: {clone_rem}
+- 🎙 ساخت پادکست: {podcast_rem}
+- 🗣 تبدیل متن به صدا: {tts_rem}
+- 📁 تحلیل فایل و سند: {file_rem}
+- 📝 تبدیل صدا به متن: {stt_rem}
+
+{daily_note}"""
+                await send_with_keyboard(client, chat_id, account_profile, True)
+                return
+
+            if user_text_str in["/invite", "دعوت دوستان 🎁"]:
+                invites = creds.get("invited_count", 0)
+                remains = 10 - (invites % 10)
+                my_code = get_or_create_referral_code(str_chat_id)
+                
+                invite_text = f"""🎁 **سیستم دعوت دوستان (دو سر سود)**
+
+با دعوت دوستان خود به ربات آلفا، هم شما و هم دوستتان هدیه می‌گیرید!
+به دوست خود بگویید پس از ورود به ربات، دکمه **«ثبت کد هدیه 🎫»** را بزند و کد زیر را وارد کند.
+✨ **سود دوست شما:** در همان لحظه 10 تبدیل رایگان متن به صدا دریافت می‌کند.
+✨ **سود شما:** به آمار دعوت‌هایتان اضافه می‌شود و به ازای هر **10 نفر**، **3 روز اشتراک پرو نامحدود** می‌گیرید.
+
+📊 **آمار شما:**
+- تعداد دعوت‌های موفق: {invites} نفر
+- دعوت‌های باقی‌مانده تا جایزه بعدی: {remains} نفر
+
+کد هدیه اختصاصی شما:
+`{my_code}`
+
+(متن زیر را کپی کرده و برای دوستانتان بفرستید 👇)"""
+                await send_with_keyboard(client, chat_id, invite_text, True)
+                
+                forward_text = f"""🤖 **ربات هوش مصنوعی آلفا پرو**
+
+✨ با این ربات می‌تونی کارهای زیر رو به راحتی انجام بدی:
+💬 چت با پیشرفته‌ترین هوش مصنوعی
+🎨 ساخت و ویرایش حرفه‌ای عکس
+🎙️ تغییر صدا و کلون کردن صدا 
+🎙 ساخت پادکست اختصاصی
+🗣 تبدیل متن به صدا (30 گوینده مختلف)
+📝 تبدیل صدا و ویدیو به متن
+📁 تحلیل فایل‌ها و ساخت مقاله
+
+👇 اول وارد ربات زیر شو:
+@aialphabot
+
+سپس دکمه **«ثبت کد هدیه 🎫»** را بزن و کد 8 رقمی زیر رو وارد کن تا همون اول **10 تا تبدیل صدا هدیه بگیری**:
+`{my_code}`"""
+                await send_with_keyboard(client, chat_id, forward_text, False)
+                return
+
+            if user_text_str in["/referral", "ثبت کد هدیه 🎫"]:
+                if creds.get("used_referral", False):
+                    await send_with_keyboard(client, chat_id, "❌ شما قبلاً کد هدیه یک نفر را ثبت کرده‌اید و فقط یک‌بار مجاز به استفاده از این امکان هستید.", True)
+                    return
+                user_states[str_chat_id]["mode"] = "waiting_for_referral_code"
+                msg = "🎫 **ثبت کد هدیه**\n\nکد هدیه 8 رقمی (اعداد) که از دوست خود دریافت کرده‌اید را اینجا وارد کنید تا در همان لحظه **10 سهمیه تبدیل رایگان متن به صدا** هدیه بگیرید!\n\n(برای انصراف دکمه «برگشت♻️» را بزنید)"
+                await send_with_keyboard(client, chat_id, msg, True)
+                return
+
+            if user_text_str in["/buy", "خرید اشتراک 💎"]:
+                buy_text = f"""💎 **خرید اشتراک ویژه آلفا پرو (یک ماهه)**
+
+با تهیه اشتراک ویژه، محدودیت‌ها را کنار بزنید و از نهایت قدرت هوش مصنوعی لذت ببرید! 🚀
+
+━━━━━━━━━━━━━━━━━━━
+🎁 **بسته طلایی یک‌ماهه شامل:**
+🤖 چت با هوش مصنوعی: نامحدود ∞
+🎙️ تغییر صدا و کلون کردن صدا: نامحدود ∞
+🗣 تبدیل متن به صدا (۳۰ گوینده): نامحدود ∞
+🎙 ساخت پادکست: نامحدود ∞
+📁 تحلیل فایل و سند: نامحدود ∞
+📝 تبدیل فایل صوتی به متن: نامحدود ∞
+🪄 ویرایش تصویر: ۱۰ عدد
+🎨 تولید تصویر: ۲۰ عدد
+━━━━━━━━━━━━━━━━━━━
+
+💳 **هزینه اشتراک یک ماهه:** 250 هزار تومان
+
+💳 **شماره کارت جهت واریز:**
+➖➖➖➖➖➖➖➖
+`6219861411958035`
+➖➖➖➖➖➖➖➖
+👤 **به نام:** کوهی
+
+✅ **نحوه فعال‌سازی:**
+پس از واریز مبلغ، لطفاً رسید پرداختی را به همراه **شناسه یکتای خود** (که در پایین آمده) به آیدی پشتیبانی زیر ارسال کنید تا اشتراک شما فعال گردد:
+
+🔑 **شناسه یکتای شما:**
+`{chat_id}`
+
+👨‍💻 **ارتباط با پشتیبانی:**
+🆔 @aialpha_admin"""
+                await send_with_keyboard(client, chat_id, buy_text, True)
+                return
+
+            if user_text_str in["/transfer", "انتقال اکانت از برنامه به ربات"]:
+                transfer_text = f"""🔄 **انتقال اکانت از برنامه به ربات**
+
+کاربر گرامی، در صورتی که داخل برنامه «هوش مصنوعی آلفا» پیش‌تر اشتراک تهیه کرده‌اید، نیازی به خرید مجدد اشتراک داخل ربات نیست! 🎉
+
+کافیست **شناسه یکتای** ربات روبیکای خود را کپی کرده و برای پشتیبانی ما در برنامه هوش مصنوعی ��لفا ارسال کنید تا اکانت اشتراکی شما به سرعت از برنامه به ربات روبیکا انتقال داده شود.
+
+🔑 **شناسه یکتای ربات شما:**
+`{chat_id}`
+
+👨‍💻 **دقت کنید شناسه ربات رو به پشتیبانی داخل خود برنامه هوش مصنوعی آلفا ارسال کنید.**"""
+                await send_with_keyboard(client, chat_id, transfer_text, True)
+                return
+
+            if user_text_str in["/chat", "💬 چت", "چت با هوش مصنوعی 🤖"]:
+                user_states[str_chat_id]["mode"] = "chat"
+                user_states[str_chat_id]["history"] =[]
+                await send_with_keyboard(client, chat_id, "💬 شما وارد بخش **چت با هوش مصنوعی** شدید.\n\nهر سوالی دارید بفرستید تا جواب بدم:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                return
+
+            if user_text_str in["/image", "🎨 عکس", "ساخت تصاویر🎨"]:
+                user_states[str_chat_id]["mode"] = "image_waiting_for_text"
+                await send_with_keyboard(client, chat_id, "🎨 شما وارد بخش **ساخت عکس پیشرفته** شدید.\n\nمتن (ایده) خود را به صورت کامل ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                return
+
+            if user_text_str in["/edit_image", "ویرایش تصاویر 🪄"]:
+                user_states[str_chat_id]["mode"] = "image_edit_waiting_for_image"
+                user_states[str_chat_id]["file_bytes"] = None
+                await send_with_keyboard(client, chat_id, "🪄 به بخش **ویرایش عکس (Flux.2)** خوش آمدید.\n\nلطفاً ابتدا عکسی که می‌خواهید ویرایش کنید را بفرستید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                return
+
+            if user_text_str in["/tts", "🎙️ صدا", "تبدیل متن به صدا🗣️"]:
+                user_states[str_chat_id]["mode"] = "tts_waiting_for_text"
+                await send_with_keyboard(client, chat_id, "🎙️ شما وارد بخش **تبدیل متن به صدا** شدید.\n\nلطفاً متنی که می‌خواهید به صدا تبدیل شود را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                return
+            
+            if user_text_str in["/podcast", "📻 پادکست", "ساخت پادکست 🎙️"]:
+                user_states[str_chat_id]["mode"] = "podcast_waiting_for_topic"
+                await send_with_keyboard(client, chat_id, "📻 شما وارد بخش **ساخت پادکست** شدید.\n\nلطفاً موضوع پادکست خود را بفرستید.\nمثال: درباره تاریخچه پیدایش قهوه با ۳ گوینده یک پادکست جذاب بساز . همچنین این قسمت متصل به مدل زبانی است و درخواست هارو قبل از ساخت درک میکنه. میتوانید مقاله کامل یک سایت بفرستید با تبلیغات یا هرچی، هوش مصنوعی متن مقاله رو استخراج و پادکست براتون میسازه . در توضیحات امکان مشخص کردن تعداد گوینده به همراه اسم شون نیز از سمت شما امکان پذیر است.\n\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                return
+
+            # ===============================================
+            # بخش‌های تغییر صدا و کلون کردن صدا
+            # ===============================================
+            if user_text_str in["/vc", "تغییر صدا 🎙️"]:
+                user_states[str_chat_id]["mode"] = "vc_waiting_for_voice"
+                user_states[str_chat_id]["file_bytes"] = None
+                await send_with_keyboard(client, chat_id, "🎙️ شما وارد بخش **تغییر صدا** شدید.\n\nلطفاً صدای خود (ویس) را بفرستید تا آن را به صدای شخصیت‌های معروف تبدیل کنم:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                return
+
+            if user_text_str in["/clone", "کلون کردن صدا 👤"]:
+                user_states[str_chat_id]["mode"] = "clone_waiting_for_src"
+                user_states[str_chat_id]["file_bytes"] = None
+                user_states[str_chat_id]["ref_bytes"] = None
+                clone_text = """👤 **شما وارد بخش کلون کردن صدای اختصاصی شدید.**
+
+✨ **این بخش چه کاری انجام می‌دهد؟**
+با این ویژگی بی‌نظیر، شما می‌توانید صدای خود (یا هر فرد دیگری) را دقیقاً شبیه‌سازی کنید! کافیست یک نمونه از صدای خودتان صحبت کنید و یک نمونه از صدای شخص مورد نظر (الگو) را به هوش مصنوعی بدهید. ربات لحن و کلمات شما را گرفته و دقیقاً با جنس صدای شخص الگو بازسازی می‌کند.
+
+📌 **راهنمای استفاده:**
+شما در این مرحله به **2 فایل صوتی** نیاز دارید:
+1️⃣ **صدای ورودی (شما):** صدایی که می‌خواهید متن و لحن آن خوانده شود.
+2️⃣ **صدای الگو (هدف):** صدایی که می‌خواهید خروجی نهایی شبیه به آن شود (بدون نویز و موزیک پس‌زمینه، بین ۳ تا ۱۰ ثانیه بهترین نتیجه را می‌دهد).
+
+👇 **مرحله اول:**
+لطفاً ابتدا **صدای خودتان (ورودی)** را به صورت ویس یا فایل صوتی ارسال کنید:
+
+*(برای خروج دکمه «برگشت♻️» را بزنید)*"""
+                await send_with_keyboard(client, chat_id, clone_text, True)
+                return
+            # ===============================================
+
+            if user_text_str in["/file", "تحلیل فایل 📁"]:
+                user_states[str_chat_id]["mode"] = "file_waiting_for_file"
+                user_states[str_chat_id]["file_bytes"] = None
+                await send_with_keyboard(client, chat_id, "📁 شما وارد بخش **تحلیل فایل اختصاصی** شدید.\n\nلطفاً فایل خود را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                return
+
+            if user_text_str in["/stt", "فایل صوتی به متن 📝"]:
+                user_states[str_chat_id]["mode"] = "stt_waiting_for_audio"
+                await send_with_keyboard(client, chat_id, "📝 شما وارد بخش **تبدیل صدا به متن** شدید.\n\nلطفاً فایل خود (ویس، آهنگ، ویدیو و...) را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                return
+
+            if user_text_str in["/create_file", "ساخت فایل 📄"]:
+                user_states[str_chat_id]["mode"] = "create_file_waiting_for_topic"
+                await send_with_keyboard(client, chat_id, "📄 شما وارد بخش **ساخت فایل** شدید.\n\nلطفاً موضوع مقاله‌ای که می‌خواهید را کامل بفرستید.\nمثال: نحوه مدیریت زمان\n\nهوش مصنوعی یک مقاله کامل و طولانی نوشته و در نهایت فایل PDF و Word آن را به شما تحویل می‌دهد.\n\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                return
+
+            current_mode = user_states[str_chat_id].get("mode")
+
+            if current_mode is None:
+                if is_file: pass 
+                elif user_text_str: await send_with_keyboard(client, chat_id, "⚠️ لطفاً ابتدا از کیبورد پایین، بخش مورد نظرتان را انتخاب کنید:", True)
+                return
+
+            elif current_mode == "waiting_for_referral_code":
+                if user_text_str:
+                    normalized_code = to_english_digits(user_text_str).strip()
+                    
+                    if not normalized_code.isdigit() or len(normalized_code) != 8:
+                        await send_with_keyboard(client, chat_id, "❌ کد وارد شده نامعتبر است. لطفاً یک کد 8 رقمی صحیح بفرستید.", False)
+                        return
+                    
+                    inviter_id = find_user_by_referral_code(normalized_code)
+                    
+                    if not inviter_id:
+                        await send_with_keyboard(client, chat_id, "❌ کد هدیه یافت نشد. لطفاً کد را با دقت بررسی کنید.", False)
+                        return
+                        
+                    if str(inviter_id) == str(str_chat_id):
+                        await send_with_keyboard(client, chat_id, "❌ شما نمی‌توانید کد خودتان را ثبت کنید!", False)
+                        return
+                    
+                    user_states[str_chat_id]["mode"] = None
+                    
+                    user_credits_db[str_chat_id]["used_referral"] = True
+                    user_credits_db[str_chat_id]["tts"] = user_credits_db[str_chat_id].get("tts", 0) + 10
+                    
+                    user_credits_db[inviter_id]["invited_count"] = user_credits_db[inviter_id].get("invited_count", 0) + 1
+                    current_invites = user_credits_db[inviter_id]["invited_count"]
+                    
+                    if current_invites > 0 and current_invites % 10 == 0:
+                        inviter_data = user_credits_db[inviter_id]
+                        inviter_data["is_premium"] = True
+                        now = datetime.datetime.now()
+                        if inviter_data.get("expire_date"):
+                            try:
+                                current_exp = datetime.datetime.fromisoformat(inviter_data["expire_date"])
+                                if current_exp > now:
+                                    new_exp = current_exp + datetime.timedelta(days=3)
+                                else:
+                                    new_exp = now + datetime.timedelta(days=3)
+                            except:
+                                new_exp = now + datetime.timedelta(days=3)
+                        else:
+                            new_exp = now + datetime.timedelta(days=3)
+                            
+                        inviter_data["expire_date"] = new_exp.isoformat()
+                        inviter_data["chat"] = 999999
+                        inviter_data["image"] = 20
+                        inviter_data["edit_image"] = 10
+                        inviter_data["podcast"] = 999999
+                        inviter_data["tts"] = 999999
+                        inviter_data["file"] = 999999
+                        inviter_data["stt"] = 999999
+                        
+                        save_db(user_credits_db)
+                        try:
+                            msg_text = f"🎉 **تبریک ویژه!**\nیک دوست کد هدیه شما را ثبت کرد.\nتعداد کل دعوت‌های شما: {current_invites} نفر\n\n🎁 **هدیه شما:** ۳ روز اشتراک پرو نامحدود به حساب شما افزوده شد!"
+                            asyncio.create_task(send_with_keyboard(client, inviter_id, msg_text, True))
+                        except: pass
+                    else:
+                        save_db(user_credits_db)
+                        remains = 10 - (current_invites % 10)
+                        try:
+                            msg_text = f"🎉 **تبریک!**\nیک دوست کد هدیه شما را ثبت کرد.\nتعداد کل دعوت‌های شما: {current_invites} نفر\n\n⏳ با دعوت {remains} نفر دیگر، ۳ روز اشتراک رایگان دریافت می‌کنید!"
+                            asyncio.create_task(send_with_keyboard(client, inviter_id, msg_text, True))
+                        except: pass
+
+                    await send_with_keyboard(client, chat_id, "✅ کد هدیه با موفقیت ثبت شد!\n🎁 **10 سهمیه تبدیل رایگان متن به صدا** به حساب شما اضافه گردید.", True)
+                return
+
+            elif current_mode == "chat":
+                if is_file:
+                    await send_with_keyboard(client, chat_id, "📥 در حال دانلود فایل...", False)
+                    try:
+                        file_bytes = await helper_download_file(client, msg_obj)
+                        user_states[str_chat_id]["file_bytes"] = file_bytes
+                        user_states[str_chat_id]["file_name"] = file_name
+                        user_states[str_chat_id]["mode"] = "chat_waiting_for_prompt"
+                        await send_with_keyboard(client, chat_id, "✅ فایل با موفقیت دریافت شد.\n\nحالا لطفاً متنی بفرستید و بگویید **چه کاری با این فایل انجام دهم؟**\n(مثلاً: این تصویر را توصیف کن، یا متن این سند را خلاصه کن)", False)
+                    except Exception as dl_err: 
+                        await send_with_keyboard(client, chat_id, f"❌ خطا در دریافت فایل!\n{str(dl_err)}", False)
+                elif user_text_str: 
+                    asyncio.create_task(process_gemini(client, chat_id, user_text_str))
+                return
+
+            elif current_mode == "chat_waiting_for_prompt":
+                if user_text_str:
+                    saved_bytes = user_states[str_chat_id].get("file_bytes")
+                    saved_name = user_states[str_chat_id].get("file_name", "file.jpeg")
+                    user_states[str_chat_id]["mode"] = "chat"
+                    user_states[str_chat_id]["file_bytes"] = None
+                    asyncio.create_task(process_gemini(client, chat_id, user_text_str, file_bytes=saved_bytes, file_name=saved_name))
+                else: 
+                    await send_with_keyboard(client, chat_id, "⚠️ لطفاً درخواست خود را متنی بنویسید.", False)
+                return
+
+            elif current_mode == "image_waiting_for_text":
+                if user_text_str:
+                    user_states[str_chat_id]["text"] = user_text_str
+                    user_states[str_chat_id]["mode"] = "image_waiting_for_size"
+                    
+                    size_menu = """🖼 **لطفاً ابعاد تصویر خود را انتخاب کنید:**
+
+1️⃣ `1:1` (مربع) - مناسب پروفایل ⬛
+2️⃣ `9:16` (عمودی) - مناسب استوری و پس‌زمینه گوشی 📱
+3️⃣ `16:9` (افقی) - مناسب دسکتاپ و ویدیو 🖥️
+4️⃣ `4:3` (استاندارد) - مناسب چاپ و پست 📸
+
+(لطفاً فقط عدد 1 تا 4 را بفرستید)"""
+                    await send_with_keyboard(client, chat_id, size_menu, False)
+                else:
+                    await send_with_keyboard(client, chat_id, "⚠️ لطفاً ایده عکس خود را به صورت متنی بفرستید.", False)
+                return
+
+            elif current_mode == "image_waiting_for_size":
+                normalized_choice = to_english_digits(user_text_str).strip()
+                if normalized_choice in["1", "2", "3", "4"]:
+                    saved_text = user_states[str_chat_id].get("text", "")
+                    user_states[str_chat_id]["mode"] = None
+                    asyncio.create_task(process_image(client, chat_id, saved_text, normalized_choice))
+                else:
+                    await send_with_keyboard(client, chat_id, "❌ عدد وارد شده نامعتبر است! لطفاً فقط یکی از اعداد 1 تا 4 را بفرستید.", False)
+                return
+
+            elif current_mode == "image_edit_waiting_for_image":
+                if not is_file: return await send_with_keyboard(client, chat_id, "⚠️ لطفاً ابتدا یک عکس ارسال کنید.", False)
+                await send_with_keyboard(client, chat_id, "📥 در حال دانلود عکس...", False)
+                try:
+                    file_bytes = await helper_download_file(client, msg_obj)
+                    user_states[str_chat_id]["file_bytes"] = file_bytes
+                    user_states[str_chat_id]["mode"] = "image_edit_waiting_for_prompt"
+                    await send_with_keyboard(client, chat_id, "✅ عکس با موفقیت دریافت شد.\n\nحالا دستور خود را به صورت متنی تایپ کنید.\nمثال: یک کلاه قرمز روی سر این گربه بگذار.", False)
+                except Exception as dl_err: await send_with_keyboard(client, chat_id, f"❌ خطا در دریافت عکس!\n{str(dl_err)}", False)
+                return
+
+            elif current_mode == "image_edit_waiting_for_prompt":
+                if user_text_str:
+                    saved_bytes = user_states[str_chat_id].get("file_bytes")
+                    user_states[str_chat_id]["mode"] = None 
+                    user_states[str_chat_id]["file_bytes"] = None
+                    asyncio.create_task(process_image_edit(client, chat_id, saved_bytes, user_text_str))
+                else: await send_with_keyboard(client, chat_id, "⚠️ لطفاً درخواست خود را متنی بنویسید.", False)
+                return
+
+            elif current_mode == "tts_waiting_for_text":
+                if user_text_str:
+                    if len(user_text_str) > 2500: return await send_with_keyboard(client, chat_id, "⚠️ لطفاً متنی کوتاه‌تر از 2500 کاراکتر بفرستید.", False)
+                    user_states[str_chat_id]["text"] = user_text_str
+                    user_states[str_chat_id]["mode"] = "tts_waiting_for_speaker"
+                    
+                    speakers_menu = """✅ متن شما ذخیره شد.
+لطفاً **شماره** گوینده مورد نظر خود را بفرستید:
+1. شهاب | 2. آوا | 3. نوید
+4. آرمان | 5. مهسا | 6. دانا
+7. سامان | 8. آرش | 9. شبنم
+10. سحر | 11. مریم | 12. بهرام
+13. نیکان| 14. فرناز | 15. سارا
+16. مانی | 17. آرتین | 18. دلنواز
+19. روژان | 20. امید | 21. بردیا
+22. ترانه | 23. نیکو | 24. هستی
+25. کامیار| 26. کیانوش| 27. پویا
+28. مهتاب | 29. سام | 30. لیدا"""
+                    await send_with_keyboard(client, chat_id, speakers_menu, False)
+                return
+
+            elif current_mode == "tts_waiting_for_speaker":
+                normalized_text = to_english_digits(user_text_str)
+                
+                if normalized_text.isdigit() and normalized_text in SPEAKERS:
+                    spk_name, spk_id = SPEAKERS[normalized_text]
+                    txt = user_states[str_chat_id]["text"]
+                    user_states[str_chat_id]["mode"] = "tts_waiting_for_text"
+                    asyncio.create_task(process_tts(client, chat_id, txt, spk_id, spk_name))
+                else: 
+                    await send_with_keyboard(client, chat_id, "❌ شماره نامعتبر است! لطفاً فقط یک عدد بین 1 تا 30 بفرستید.", False)
+                return
+
+            elif current_mode == "podcast_waiting_for_topic":
+                if user_text_str: asyncio.create_task(process_podcast(client, chat_id, user_text_str))
+                else: await send_with_keyboard(client, chat_id, "⚠️ لطفاً موضوع پادکست خود را به صورت متنی بفرستید.", False)
+                return
+
+            elif current_mode == "stt_waiting_for_audio":
+                if not is_file: return await send_with_keyboard(client, chat_id, "⚠️ لطفاً یک فایل ارسال کنید.", False)
+                await send_with_keyboard(client, chat_id, "📥 در حال دانلود فایل...", False)
+                try:
+                    audio_bytes = await helper_download_file(client, msg_obj)
+                    asyncio.create_task(process_stt(client, chat_id, audio_bytes, file_name))
+                except Exception as dl_err: await send_with_keyboard(client, chat_id, f"❌ خطا در دانلود فایل!\n{str(dl_err)}", False)
+                return
+
+            elif current_mode == "file_waiting_for_file":
+                if not is_file: return await send_with_keyboard(client, chat_id, "⚠️ لطفاً ابتدا یک فایل ارسال کنید.", False)
+                await send_with_keyboard(client, chat_id, "📥 در حال دریافت فایل...", False)
+                try:
+                    file_bytes = await helper_download_file(client, msg_obj)
+                    user_states[str_chat_id]["file_bytes"] = file_bytes
+                    user_states[str_chat_id]["file_name"] = file_name 
+                    user_states[str_chat_id]["mode"] = "file_waiting_for_prompt"
+                    await send_with_keyboard(client, chat_id, "✅ فایل با موفقیت دریافت شد.\n\nحالا لطفاً متنی بگویید **چگونه تحلیل شود؟**\n(می‌توانید سوال خاصی بپرسید یا فقط بخواهید فایل را توضیح دهد)", False)
+                except Exception as dl_err: await send_with_keyboard(client, chat_id, f"❌ خطا در دریافت فایل!\n{str(dl_err)}", False)
+                return
+
+            elif current_mode == "file_waiting_for_prompt":
+                if user_text_str:
+                    saved_bytes = user_states[str_chat_id].get("file_bytes")
+                    saved_name = user_states[str_chat_id].get("file_name", "file.jpeg")
+                    user_states[str_chat_id]["mode"] = "file_waiting_for_file" 
+                    asyncio.create_task(process_file_analysis(client, chat_id, saved_bytes, saved_name, user_text_str))
+                else: await send_with_keyboard(client, chat_id, "⚠️ لطفاً درخواست خود را متنی بنویسید.", False)
+                return
+
+            elif current_mode == "create_file_waiting_for_topic":
+                if user_text_str:
+                    asyncio.create_task(process_create_file(client, chat_id, user_text_str))
+                else: 
+                    await send_with_keyboard(client, chat_id, "⚠️ لطفاً موضوع مقاله خود را به صورت متنی بفرستید.", False)
+                return
+
+            # ===============================================
+            # بخش‌های تغییر صدا و کلون صدا
+            # ===============================================
+            elif current_mode == "vc_waiting_for_voice":
+                if not is_file: return await send_with_keyboard(client, chat_id, "⚠️ لطفاً یک فایل صوتی یا ویس ارسال کنید.", False)
+                await send_with_keyboard(client, chat_id, "📥 در حال دانلود فایل صوتی شما...", False)
+                try:
+                    file_bytes = await helper_download_file(client, msg_obj)
+                    user_states[str_chat_id]["file_bytes"] = file_bytes
+                    user_states[str_chat_id]["mode"] = "vc_waiting_for_model"
+                    
+                    model_menu = "✅ صدای شما دریافت شد.\n\nلطفا **شماره** مدلی که می‌خواهید صدایتان به آن تبدیل شود را ارسال کنید:\n\n"
+                    for k, v in LEGACY_MODELS.items():
+                        if k == "8":
+                            model_menu += f"{k}. {v['name']} (نامحدود رایگان)\n"
+                        else:
+                            model_menu += f"{k}. {v['name']}\n"
+                    model_menu += "➖➖➖➖➖➖➖➖\n"
+                    for k, v in STANDARD_MODELS.items(): model_menu += f"{k}. {v['name']}\n"
+                    
+                    await send_with_keyboard(client, chat_id, model_menu, False)
+                except Exception as dl_err: 
+                    await send_with_keyboard(client, chat_id, f"❌ خطا در دریافت فایل!\n{str(dl_err)}", False)
+                return
+
+            elif current_mode == "vc_waiting_for_model":
+                choice = to_english_digits(user_text_str).strip()
+                
+                if choice in STANDARD_MODELS:
+                    if creds["voice_conv"] <= 0: return await send_with_keyboard(client, chat_id, "❌ سهمیه تغییر صدای شما تمام شده است. لطفاً از منوی اصلی وارد بخش «خرید اشتراک 💎» شوید.", False)
+                    user_states[str_chat_id]["mode"] = None
+                    model = STANDARD_MODELS[choice]
+                    src_bytes = user_states[str_chat_id]["file_bytes"]
+                    await send_with_keyboard(client, chat_id, "📥 در حال آماده‌سازی فایل‌ها...", False)
+                    ref_bytes = await helper_download_url_to_bytes(model["ref"])
+                    if not ref_bytes: return await send_with_keyboard(client, chat_id, "❌ خطا در دسترسی به فایل صدای مدل.", False)
+                    
+                    asyncio.create_task(process_standard_vc_job(client, chat_id, src_bytes, ref_bytes, model["name"], "voice_conv"))
+                
+                elif choice in LEGACY_MODELS:
+                    # اگر شماره مدل ۸ نبود و اعتبار هم صفر بود، ارور بده
+                    if choice != "8" and creds["voice_conv"] <= 0: 
+                        return await send_with_keyboard(client, chat_id, "❌ سهمیه تغییر صدای شما تمام شده است. لطفاً از منوی اصلی وارد بخش «خرید اشتراک 💎» شوید.", False)
+                    
+                    user_states[str_chat_id]["selected_model"] = choice
+                    user_states[str_chat_id]["mode"] = "vc_waiting_for_gender"
+                    
+                    gender_msg = f"✅ مدل {LEGACY_MODELS[choice]['name']} انتخاب شد.\n\nبرای تنظیم دقیق فرکانس‌ها به ما بگویید صدایی که خودتان فرستادید صدای یک **مرد** است یا **زن**؟\n\n1. مرد 👨\n2. زن 👩"
+                    await send_with_keyboard(client, chat_id, gender_msg, False)
+                else:
+                    await send_with_keyboard(client, chat_id, "❌ شماره وارد شده صحیح نیست. لطفاً فقط عدد مدل را بفرستید.", False)
+                return
+
+            elif current_mode == "vc_waiting_for_gender":
+                choice = to_english_digits(user_text_str).strip()
+                if choice not in["1", "2"]:
+                    return await send_with_keyboard(client, chat_id, "❌ لطفاً عدد 1 (مرد) یا 2 (زن) را ارسال کنید.", False)
+                
+                user_gender = "male" if choice == "1" else "female"
+                model_key = user_states[str_chat_id]["selected_model"]
+                model = LEGACY_MODELS[model_key]
+                target_gender = model["gender"]
+                
+                pitch = 0
+                if target_gender == "female" and user_gender == "male": pitch = 12
+                elif target_gender == "male" and user_gender == "female": pitch = -12
+                
+                user_states[str_chat_id]["mode"] = None
+                src_bytes = user_states[str_chat_id]["file_bytes"]
+                asyncio.create_task(process_legacy_vc_job(client, chat_id, src_bytes, model["url"], pitch, model["name"]))
+                return
+
+            elif current_mode == "clone_waiting_for_src":
+                if not is_file: return await send_with_keyboard(client, chat_id, "⚠️ لطفاً فایل صوتی صدای خودتان را بفرستید.", False)
+                await send_with_keyboard(client, chat_id, "📥 در حال دانلود صدای شما...", False)
+                try:
+                    file_bytes = await helper_download_file(client, msg_obj)
+                    user_states[str_chat_id]["file_bytes"] = file_bytes
+                    user_states[str_chat_id]["mode"] = "clone_waiting_for_ref"
+                    await send_with_keyboard(client, chat_id, "✅ صدای شما دریافت شد.\n\nحالا **فایل الگو (صدای شخصی که می‌خواهید شبیه‌سازی کنید)** را ارسال کنید.\n(پیشنهاد: فایل بدون نویز و موسیقی، بین ۳ تا ۱۰ ثانیه)", False)
+                except Exception as dl_err: 
+                    await send_with_keyboard(client, chat_id, f"❌ خطا در دریافت فایل!\n{str(dl_err)}", False)
+                return
+
+            elif current_mode == "clone_waiting_for_ref":
+                if not is_file: return await send_with_keyboard(client, chat_id, "⚠️ لطفاً فایل صوتی الگوی هدف را بفرستید.", False)
+                await send_with_keyboard(client, chat_id, "📥 در حال دانلود صدای الگو...", False)
+                try:
+                    ref_bytes = await helper_download_file(client, msg_obj)
+                    
+                    if creds["voice_clone"] <= 0: 
+                        return await send_with_keyboard(client, chat_id, "❌ سهمیه کلون کردن صدای شما تمام شده است. نیازمند تهیه اشتراک هستید.", False)
+                    
+                    user_states[str_chat_id]["mode"] = None
+                    src_bytes = user_states[str_chat_id]["file_bytes"]
+                    
+                    asyncio.create_task(process_standard_vc_job(client, chat_id, src_bytes, ref_bytes, "صدای اختصاصی (کلون شده)", "voice_clone"))
+                except Exception as dl_err: 
+                    await send_with_keyboard(client, chat_id, f"❌ خطا در دریافت فایل!\n{str(dl_err)}", False)
+                return
+
+        except Exception: traceback.print_exc()
 
 if __name__ == "__main__":
     threading.Thread(target=run_flask, daemon=True).start()
+    
     if bot_token:
-        print("⚠️ وضعیت: در حال تخلیه صف پیام‌ها در دیتابیس v3... لطفاً تا توقف لاگ‌ها صبر کنید.")
+        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()