Update main.py

main.py

@@ -23,18 +23,19 @@ from pydub import AudioSegment
 # --- کد مدیریت برای ارتقای کاربران بدون نیاز به لاگین ---
 ADMIN_CODE = "3011"
 
-# متغیر سراسری برای ذخیره آیدی خود ربات
+# متغیر سراسری برای ذخیره آیدی خود ربات (جلوگیری از جواب دادن ربات به خودش)
 BOT_GUID = None
 
 # =======================================================
 # 🔥 سیستم کنترل سرعت و ضد رگبار (Burst Controller) 🔥
+# جلوگیری از هنگ کردن ربات هنگام دریافت پیام‌های تلنبار شده
 # =======================================================
 global_burst_count = 0
 global_burst_time = time.time()
 burst_lock = threading.Lock()
 
 def is_backlog_burst():
-    """اگر بیشتر از 5 پیام در 1 ثانیه بیاید، یعنی رگبار است و رد می‌شود"""
+    """اگر بیشتر از 5 پیام در 1 ثانیه بیاید، یعنی رگبار از سمت سرور است و رد می‌شود"""
     global global_burst_count, global_burst_time
     with burst_lock:
         now = time.time()
@@ -51,10 +52,10 @@ def is_backlog_burst():
 # --- سیستم دیتابیس حساب کاربری متصل به دیتاست هاگینگ فیس ---
 DB_FILE = "users_db.json"
 DATASET_REPO = "Opera8/Karbaran-rayegan-tedad"
-HF_TOKEN_DB = os.environ.get("HF_TOKEN")
+HF_TOKEN_DB = os.environ.get("HF_TOKEN") # توکنی که برای دیتاست تنظیم کرده‌اید
 db_lock = threading.Lock()
 
-# --- الگوریتم تبدیل تاریخ میلادی به شمسی ---
+# --- الگوریتم تبدیل تاریخ میلادی به شمسی (بدون نیاز به نصب کتابخانه) ---
 def gregorian_to_jalali(gy, gm, gd):
     g_d_m =[0, 31, 59, 90, 120, 151, 181, 212, 243, 273, 304, 334]
     gy2 = (gy + 1) if (gm > 2) else gy
@@ -78,6 +79,7 @@ def load_db():
     print("در حال تلاش برای خواندن دیتابیس کاربران از دیتاست هاگینگ فیس...")
     if HF_TOKEN_DB:
         try:
+            # دانلود دیتابیس از دیتاست خصوصی
             file_path = hf_hub_download(
                 repo_id=DATASET_REPO, 
                 filename=DB_FILE, 
@@ -88,8 +90,9 @@ def load_db():
                 print("✅ دیتابیس با موفقیت از دیتاست هاگینگ فیس لود شد.")
                 return json.load(f)
         except Exception as e:
-            print("⚠️ فایل دیتابیس در هاگینگ فیس یافت نشد یا خطایی رخ داد (ساخت دیتابیس جدید).")
+            print("⚠️ فایل دیتابیس در هاگینگ فیس یافت نشد یا خطایی رخ داد (ساخت دیتابیس جدید). جزئیات:", str(e)[:100])
     
+    # اگر از دیتاست لود نشد، از لوکال بخوان
     if os.path.exists(DB_FILE):
         try:
             with open(DB_FILE, "r", encoding="utf-8") as f:
@@ -99,6 +102,7 @@ def load_db():
     return {}
 
 def _upload_db_background():
+    """تابع کمکی برای آپلود دیتابیس بدون درگیر کردن سرعت ربات"""
     if HF_TOKEN_DB:
         api = HfApi(token=HF_TOKEN_DB)
         try:
@@ -108,13 +112,17 @@ def _upload_db_background():
                 repo_id=DATASET_REPO,
                 repo_type="dataset"
             )
-        except Exception: pass
+        except Exception as e:
+            print("❌ خطا در آپلود دیتابیس به هاگینگ فیس:", str(e)[:100])
 
 def save_db(db_data):
     with db_lock:
         try:
+            # ذخیره فایل به صورت لوکال
             with open(DB_FILE, "w", encoding="utf-8") as f:
                 json.dump(db_data, f, ensure_ascii=False, indent=4)
+            
+            # استارت کردن یک Thread جدید برای آپلود به دیتاست تا ربات منتظر نماند
             threading.Thread(target=_upload_db_background, daemon=True).start()
         except Exception as e:
             print("خطا در ذخیره دیتابیس:", e)
@@ -122,10 +130,12 @@ def save_db(db_data):
 user_credits_db = load_db()
 
 def get_user_credits(chat_id):
+    # اطمینان از پاک بودن استرینگ از علائم مزاحم
     str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
     today_str = datetime.date.today().isoformat()
     
     if str_chat_id not in user_credits_db:
+        # ساخت کاربر جدید با مقادیر اولیه
         user_credits_db[str_chat_id] = {
             "is_premium": False,
             "expire_date": None,
@@ -143,19 +153,23 @@ def get_user_credits(chat_id):
     user_data = user_credits_db[str_chat_id]
     is_premium = user_data.get("is_premium", False)
     
+    # 🛡 بررسی انقضای اشتراک ماهانه کاربران ویژه 🛡
     if is_premium and user_data.get("expire_date"):
         try:
             expire_date = datetime.datetime.fromisoformat(user_data["expire_date"])
             if datetime.datetime.now() > expire_date:
+                # اگر زمان اشتراک تمام شده باشد، دوباره رایگان می‌شود
                 user_data["is_premium"] = False
                 user_data["expire_date"] = None
                 is_premium = False
         except Exception:
             pass
 
+    # 🔄 سیستم شارژ روزانه (فقط و فقط برای نسخه رایگان) 🔄
     if not is_premium:
         if user_data.get("last_reset") != today_str:
             user_data["last_reset"] = today_str
+            # شارژ روزانه نسخه رایگان
             user_data["chat"] = 10
             user_data["image"] = 5
             user_data["edit_image"] = 1
@@ -167,8 +181,10 @@ def get_user_credits(chat_id):
             
     return user_data
 
+# --- تابع تبدیل اعداد فارسی/عربی به انگلیسی ---
 def to_english_digits(text):
-    if not text: return text
+    if not text:
+        return text
     persian_digits = '۰۱۲۳۴۵۶۷۸۹'
     arabic_digits = '٠١٢٣٤٥٦٧٨٩'
     english_digits = '0123456789'
@@ -180,13 +196,13 @@ app = Flask(__name__)
 
 @app.route('/')
 def home():
-    return "ربات آلفا پرو فعال است 🚀"
+    return "ربات یکپارچه آلفا (نسخه پرو + مدیریت اشتراک نامحدود + دیتاست + سیستم ضد باگ) روشن است! 🚀"
 
 def run_flask():
     app.run(host="0.0.0.0", port=7860)
 
 
-# --- کیبورد ---
+# --- ساختار کیبورد آپدیت شده ---
 MAIN_KEYPAD_DICT = {
     "rows": [
         {
@@ -232,6 +248,7 @@ MAIN_KEYPAD_DICT = {
     "resize_keyboard": True
 }
 
+# --- تابع ارسال منحصراً برای کیبورد پایین صفحه ---
 async def send_with_keyboard(client, chat_id, text, use_keyboard=True):
     try:
         if not use_keyboard:
@@ -250,6 +267,8 @@ async def send_with_keyboard(client, chat_id, text, use_keyboard=True):
         except Exception:
             return None
 
+
+# --- 🚨 تابع هوشمند دانلود فایل (با استفاده از UUID جهت جلوگیری از تداخل حریم خصوصی) 🚨 ---
 async def helper_download_file(client, msg_obj):
     errors =[]
     file_id = None
@@ -262,6 +281,7 @@ async def helper_download_file(client, msg_obj):
             elif isinstance(val, dict) and 'file_id' in val: file_id = val['file_id']
             if file_id: break
 
+    # 🛡 استفاده از UUID به جای اعداد تصادفی برای تضمین ۱۰۰ درصدی عدم تداخل نام فایل‌ها 🛡
     temp_name = f"temp_dl_{uuid.uuid4().hex}.tmp"
 
     if hasattr(client, "download_file"):
@@ -271,7 +291,7 @@ async def helper_download_file(client, msg_obj):
                 with open(temp_name, 'rb') as f: data = f.read()
                 os.remove(temp_name)
                 return data
-        except Exception as e: errors.append(f"Err1: {e}")
+        except Exception as e: errors.append(f"تلاش ۱: {e}")
 
         if file_obj:
             try:
@@ -280,7 +300,7 @@ async def helper_download_file(client, msg_obj):
                     with open(temp_name, 'rb') as f: data = f.read()
                     os.remove(temp_name)
                     return data
-            except Exception as e: errors.append(f"Err2: {e}")
+            except Exception as e: errors.append(f"تلاش ۲: {e}")
 
         if file_id:
             try:
@@ -289,7 +309,7 @@ async def helper_download_file(client, msg_obj):
                     with open(temp_name, 'rb') as f: data = f.read()
                     os.remove(temp_name)
                     return data
-            except Exception as e: errors.append(f"Err3: {e}")
+            except Exception as e: errors.append(f"تلاش ۳: {e}")
 
             try:
                 await client.download_file(file_id, save_as=temp_name)
@@ -297,41 +317,63 @@ async def helper_download_file(client, msg_obj):
                     with open(temp_name, 'rb') as f: data = f.read()
                     os.remove(temp_name)
                     return data
-            except Exception as e: errors.append(f"Err4: {e}")
+            except Exception as e: errors.append(f"تلاش ۴: {e}")
 
     raise Exception("دانلود ناموفق. لاگ:\n" + "\n".join(errors))
 
+
+# --- تنظیمات کلیدها ---
 GEMINI_KEYS_STR1 = os.environ.get("GEMINI_API_KEYS1", "")
 GEMINI_KEYS_STR2 = os.environ.get("GEMINI_API_KEYS2", "")
 
 _raw_keys =[]
-if GEMINI_KEYS_STR1: _raw_keys.extend(GEMINI_KEYS_STR1.split(","))
-if GEMINI_KEYS_STR2: _raw_keys.extend(GEMINI_KEYS_STR2.split(","))
+if GEMINI_KEYS_STR1:
+    _raw_keys.extend(GEMINI_KEYS_STR1.split(","))
+if GEMINI_KEYS_STR2:
+    _raw_keys.extend(GEMINI_KEYS_STR2.split(","))
+
+# حذف کلیدهای تکراری و خالی
 GEMINI_KEYS = list(set([k.strip() for k in _raw_keys if k.strip()]))
+print(f"✅ تعداد {len(GEMINI_KEYS)} کلید جیمینای با م��فقیت شناسایی شد.")
 
+# --- 🚀 سیستم چرخشی پیشرفته (Round-Robin) برای کلیدهای جیمینای ---
 current_gemini_key_index = 0
 gemini_key_lock = threading.Lock()
 
 def get_next_gemini_keys(count=100):
+    """
+    این تابع تضمین می‌کند که به ترتیب از کلیدها استفاده شود.
+    مثلاً درخواست اول کلیدهای ۱ تا ۱۰۰ را می‌گیرد.
+    درخواست دوم کلیدهای ۱۰۱ تا ۲۰۰ را می‌گیرد.
+    و وقتی به آخر لیست برسد، دوباره از اول شروع می‌کند.
+    """
     global current_gemini_key_index
     with gemini_key_lock:
         total_keys = len(GEMINI_KEYS)
-        if total_keys == 0: return[]
+        if total_keys == 0:
+            return[]
+            
         actual_count = min(count, total_keys)
         selected_keys =[]
+        
         for _ in range(actual_count):
             selected_keys.append(GEMINI_KEYS[current_gemini_key_index])
             current_gemini_key_index = (current_gemini_key_index + 1) % total_keys
+            
         return selected_keys
 
 HF_TOKENS_STR = os.environ.get("HF_TOKENS", "")
 HF_TOKENS =[k.strip() for k in HF_TOKENS_STR.split(",") if k.strip()]
+
 bot_token = os.environ.get("RUBIKA_AUTH", "").strip()
 
+
+# --- 🚨 تابع اختصاصی آپلود فایل به روبیکا 🚨 ---
 async def helper_upload_file(client, chat_id, file_name, file_type="Image", caption=""):
     abs_path = os.path.abspath(file_name)
     error_logs =[]
-    api_file_type = "Image" if file_type in["photo", "Image", "image"] else "Voice" if file_type in["voice", "Voice", "audio"] else "File"
+    
+    api_file_type = "Image" if file_type in ["photo", "Image", "image"] else "Voice" if file_type in["voice", "Voice", "audio"] else "File"
     
     try:
         url_request = f"https://botapi.rubika.ir/v3/{bot_token}/requestSendFile"
@@ -340,17 +382,21 @@ async def helper_upload_file(client, chat_id, file_name, file_type="Image", capt
         async with aiohttp.ClientSession() as session:
             async with session.post(url_request, json={"type": api_file_type}, timeout=20) as resp:
                 req_data = await resp.json()
+                
                 if req_data.get("status") == "OK":
                     data_dict = req_data.get("data", {})
                     upload_url = data_dict.get("upload_url")
                     file_id = data_dict.get("id") or data_dict.get("file_id")
+                    
                     if upload_url and file_id:
                         with open(abs_path, "rb") as f:
                             form = aiohttp.FormData()
                             form.add_field('file', f, filename=os.path.basename(abs_path))
                             headers = {"file-id": str(file_id)}
+                            
                             async with session.post(upload_url, data=form, headers=headers, timeout=60) as up_resp:
                                 up_data = await up_resp.json()
+                                
                                 if up_data.get("status") == "OK" or up_data.get("status_det") == "OK":
                                     send_payload = {
                                         "chat_id": chat_id,
@@ -361,22 +407,31 @@ async def helper_upload_file(client, chat_id, file_name, file_type="Image", capt
                                     }
                                     async with session.post(url_send, json=send_payload, timeout=20) 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}")
-                                else: error_logs.append(f"Upload API Error: {up_data}")
-                    else: error_logs.append(f"Missing Key in Response: {data_dict}")
-                else: error_logs.append(f"Request API Error: {req_data}")
-    except Exception as e: error_logs.append(f"Raw HTTP Error: {e}")
+                                        if s_data.get("status") == "OK":
+                                            return True
+                                        else:
+                                            error_logs.append(f"SendFile API Error: {s_data}")
+                                else:
+                                    error_logs.append(f"Upload API Error: {up_data}")
+                    else:
+                        error_logs.append(f"Missing Key in Response: {data_dict}")
+                else:
+                    error_logs.append(f"Request API Error: {req_data}")
+    except Exception as e:
+        error_logs.append(f"Raw HTTP Error: {e}")
 
     try:
         if hasattr(client, "send_file"):
             await client.send_file(chat_id, abs_path)
-            if caption: await send_with_keyboard(client, chat_id, caption, True)
+            if caption:
+                await send_with_keyboard(client, chat_id, caption, True)
             return True
-    except Exception as e: error_logs.append(f"Rubpy Send_file Error: {e}")
+    except Exception as e:
+        error_logs.append(f"Rubpy Send_file Error: {e}")
 
     return "\n".join(error_logs)
 
+
 WORKER_URLS =[
     "https://hamed744-ttspro.hf.space/generate",
     "https://hamed744-ttspro2.hf.space/generate",
@@ -406,30 +461,45 @@ user_states = {}
 processed_message_ids = set()
 user_last_request_time = {}
 
-# --- پردازش‌ها ---
+
+# --- ۱. پردازش چت متنی و چندرسانه‌ای ---
 async def process_gemini(client, chat_id, prompt, file_bytes=None, file_name=None):
     str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
     creds = get_user_credits(str_chat_id)
-    if creds["chat"] <= 0: return await send_with_keyboard(client, chat_id, "❌ اعتبار تمام شده است.", False)
-    if not GEMINI_KEYS: return await send_with_keyboard(client, chat_id, "❌ کلید تنظیم نیست.", False)
+    if creds["chat"] <= 0:
+        return await send_with_keyboard(client, chat_id, "❌ اعتبار پیام‌های چت شما تمام شده است. لطفاً از منوی اصلی وارد بخش «خرید اشتراک 💎» شوید.", False)
+
+    if not GEMINI_KEYS: return await send_with_keyboard(client, chat_id, "❌ کلیدهای API جیمینای تنظیم نشده‌اند.", False)
     
     proc_msg = await send_with_keyboard(client, chat_id, "🧠 در حال پردازش...", False)
-    history = user_states[chat_id].get("history",[])
+    history = user_states[chat_id].get("history", [])
     new_parts =[]
     
     if prompt: new_parts.append({"text": prompt})
-    elif file_bytes: new_parts.append({"text": "لطفاً این فایل را بررسی کن."})
+    elif file_bytes: new_parts.append({"text": "لطفاً این فایل را به دقت بررسی کن."})
         
     if file_bytes and file_name:
         base64_data = base64.b64encode(file_bytes).decode('utf-8')
         mime_type, _ = mimetypes.guess_type(file_name)
-        if not mime_type: mime_type = "image/jpeg"
+        if not mime_type:
+            if file_name.endswith(('.jpg', '.jpeg')): mime_type = "image/jpeg"
+            elif file_name.endswith('.png'): mime_type = "image/png"
+            elif file_name.endswith('.pdf'): mime_type = "application/pdf"
+            elif file_name.endswith('.mp4'): mime_type = "video/mp4"
+            elif file_name.endswith('.mp3'): mime_type = "audio/mp3"
+            elif file_name.endswith(('.ogg', '.oga')): mime_type = "audio/ogg"
+            elif file_name.endswith('.wav'): mime_type = "audio/wav"
+            else: mime_type = "image/jpeg"
         new_parts.append({"inlineData": {"mimeType": mime_type, "data": base64_data}})
 
     if history and history[-1]["role"] == "user": history[-1]["parts"].extend(new_parts)
     else: history.append({"role": "user", "parts": new_parts})
 
-    if len(history) > 40: history = history[-40:]
+    if len(history) > 40:
+        history = history[-40:]
+        if history[0]["role"] == "model": history = history[1:]
+
+    # دریافت ۱۰۰ کلید به صورت چرخشی
     keys_to_try = get_next_gemini_keys(100)
     final_answer = None
     
@@ -444,24 +514,27 @@ async def process_gemini(client, chat_id, prompt, file_bytes=None, file_name=Non
                         try:
                             final_answer = data["candidates"][0]["content"]["parts"][0]["text"]
                             break
-                        except Exception: continue 
+                        except (KeyError, IndexError): continue 
             except Exception: continue
     
     try:
         if proc_msg:
-            msg_id = getattr(proc_msg, 'message_id', None) or (proc_msg.get('message_update', {}).get('message_id') if isinstance(proc_msg, dict) else None)
+            msg_id = getattr(proc_msg, 'message_id', None)
+            if isinstance(proc_msg, dict): msg_id = proc_msg.get('message_update', {}).get('message_id') or proc_msg.get('message_id')
             if msg_id: await client.delete_messages(chat_id, [msg_id])
     except Exception: pass
 
     if not final_answer:
         if history and history[-1]["role"] == "user": history.pop()
-        return await send_with_keyboard(client, chat_id, "❌ سرور شلوغ است.", False)
+        await send_with_keyboard(client, chat_id, "❌ سرور شلوغ است فعلا بعدا امتحان کنید.", False)
+        return
 
+    # کسر اعتبار در دیتاست (اگر نامحدود نیست)
     if not creds.get("is_premium"):
         user_credits_db[str_chat_id]["chat"] -= 1
         save_db(user_credits_db)
 
-    history.append({"role": "model", "parts":[{"text": final_answer}]})
+    history.append({"role": "model", "parts": [{"text": final_answer}]})
     user_states[chat_id]["history"] = history
 
     try:
@@ -482,25 +555,32 @@ async def process_gemini(client, chat_id, prompt, file_bytes=None, file_name=Non
                 await send_with_keyboard(client, chat_id, chunk, False)
                 await asyncio.sleep(2.5) 
             except Exception: await asyncio.sleep(2.5)
+                
     except Exception:
-        await send_with_keyboard(client, chat_id, "❌ خطایی رخ داد.", False)
+        await send_with_keyboard(client, chat_id, "❌ خطایی در ارسال پیام رخ داد.", False)
 
+
+# --- ۲. پردازش ساخت عکس ---
 async def process_image(client, chat_id, prompt):
     str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
     creds = get_user_credits(str_chat_id)
-    if creds["image"] <= 0: return await send_with_keyboard(client, chat_id, "❌ اعتبار تمام شده.", False)
-    if not HF_TOKENS: return await send_with_keyboard(client, chat_id, "❌ توکن تنظیم نیست.", False)
+    if creds["image"] <= 0:
+        return await send_with_keyboard(client, chat_id, "❌ اعتبار ساخت عکس شما تمام شده است. لطفاً از منوی اصلی وارد بخش «خرید اشتراک 💎» شوید.", False)
+
+    if not HF_TOKENS: return await send_with_keyboard(client, chat_id, "❌ توکن‌های هاگینگ فیس تنظیم نشده‌اند.", False)
     
-    proc_msg = await send_with_keyboard(client, chat_id, "✨ پرامپت در حال بهینه‌سازی...", False)
+    proc_msg = await send_with_keyboard(client, chat_id, "✨ در حال ترجمه و بهینه‌سازی پرامپت شما توسط جیمینای...\n(تبدیل به پرامپت حرفه‌ای)", False)
     enhanced_prompt = prompt 
     if GEMINI_KEYS:
+        # دریافت ۱۰۰ کلید به صورت چرخشی
         keys_to_try_gemini = get_next_gemini_keys(100)
-        sys_p = f"You are an expert AI image prompt engineer. Translate to English and enhance with details. Return ONLY the English prompt.\nUser: {prompt}"
+        gemini_sys_prompt = f"You are an expert AI image generation prompt engineer. Translate the following user input to English, and enhance it with high-quality, highly detailed, 4k resolution, cinematic lighting, and visually striking descriptive keywords. Return ONLY the final English prompt string.\nUser input: {prompt}"
         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}}
                 try:
-                    async with session.post(url, json={"contents":[{"parts":[{"text": sys_p}]}]}, timeout=20) as response:
+                    async with session.post(url, json=payload, timeout=20) as response:
                         if response.status == 200:
                             data = await response.json()
                             enhanced_prompt = data["candidates"][0]["content"]["parts"][0]["text"].strip()
@@ -509,110 +589,164 @@ async def process_image(client, chat_id, prompt):
 
     try:
         if proc_msg:
-            msg_id = getattr(proc_msg, 'message_id', None) or (proc_msg.get('message_update', {}).get('message_id') if isinstance(proc_msg, dict) else None)
-            if msg_id: await client.delete_messages(chat_id, [msg_id])
+            msg_id = getattr(proc_msg, 'message_id', None)
+            if isinstance(proc_msg, dict): msg_id = proc_msg.get('message_update', {}).get('message_id') or proc_msg.get('message_id')
+            if msg_id: await client.delete_messages(chat_id,[msg_id])
     except Exception: pass
     
     short_preview = enhanced_prompt[:150] + "..." if len(enhanced_prompt) > 150 else enhanced_prompt
-    proc_msg = await send_with_keyboard(client, chat_id, f"🎨 در حال طراحی...\n`{short_preview}`", False)
+    proc_msg = await send_with_keyboard(client, chat_id, f"🎨 در حال طراحی عکس...\n\n📝 پرامپت ساخته شده:\n`{short_preview}`\n\n(ممکن است چند ثانیه زمان ببرد)", False)
 
     keys_to_try = HF_TOKENS.copy()
     random.shuffle(keys_to_try)
     generated_image = None
+    last_error_log = "هیچ اتصالی برقرار نشد."
     
     for token in keys_to_try:
         try:
             hf_client = AsyncInferenceClient(provider="fal-ai", api_key=token)
             generated_image = await hf_client.text_to_image(enhanced_prompt, model="Tongyi-MAI/Z-Image-Turbo")
             break 
-        except Exception: continue
+        except Exception as e:
+            last_error_log = str(e)
+            continue
             
     try:
         if proc_msg:
-            msg_id = getattr(proc_msg, 'message_id', None) or (proc_msg.get('message_update', {}).get('message_id') if isinstance(proc_msg, dict) else None)
-            if msg_id: await client.delete_messages(chat_id,[msg_id])
+            msg_id = getattr(proc_msg, 'message_id', None)
+            if isinstance(proc_msg, dict): msg_id = proc_msg.get('message_update', {}).get('message_id') or proc_msg.get('message_id')
+            if msg_id: await client.delete_messages(chat_id, [msg_id])
     except Exception: pass
 
-    if not generated_image: return await send_with_keyboard(client, chat_id, f"❌ عکس ساخته نشد.", True)
+    if not generated_image: return await send_with_keyboard(client, chat_id, f"❌ عکس ساخته نشد.\n\n⚠️ خطا:\n{last_error_log[:200]}", True)
 
+    # کسر اعتبار (ساخت عکس محدود است حتی برای پرو)
     user_credits_db[str_chat_id]["image"] -= 1
     save_db(user_credits_db)
 
     try:
         file_name = f"image_{uuid.uuid4().hex}.jpg"
-        generated_image.convert('RGB').save(file_name, format="JPEG", quality=100)
+        rgb_im = generated_image.convert('RGB')
+        rgb_im.save(file_name, format="JPEG", quality=100)
         await asyncio.sleep(1)
-        upload_result = await helper_upload_file(client, chat_id, file_name, "Image", f"🎨 عکس آماده شد!\n✨ ایده: {prompt}")
+        caption_text = f"🎨 تصویر شما با پرامپت هوشمند آماده شد!\n\n✨ ایده اولیه: {prompt}"
+        upload_result = await helper_upload_file(client, chat_id, file_name, "Image", caption_text)
+        if upload_result is not True: await send_with_keyboard(client, chat_id, f"❌ خطا در آپلود روبیکا:\n`{str(upload_result)[:800]}`", True)
         if os.path.exists(file_name): os.remove(file_name)
-    except Exception as e: await send_with_keyboard(client, chat_id, f"❌ خطا: {str(e)[:100]}", True)
+    except Exception as e: await send_with_keyboard(client, chat_id, f"❌ خطا در ذخیره عکس:\n{str(e)[:150]}", True)
 
+# --- تابع جدید برای ارسال متن به اسپیس مترجم ---
 async def translate_text_aloha(prompt_text):
     session_hash = ''.join(random.choices(string.ascii_lowercase + string.digits, k=11))
-    payload = {"data":[prompt_text, "انگلیسی (آمریکا) - جنی (زن)", 0, 0, 0], "fn_index": 1, "session_hash": session_hash}
+    join_url = "https://hamed744-translate-tts-aloha.hf.space/gradio_api/queue/join"
+    payload = {
+        "data":[prompt_text, "انگلیسی (آمریکا) - جنی (زن)", 0, 0, 0],
+        "fn_index": 1,
+        "session_hash": session_hash
+    }
+    
     try:
         async with aiohttp.ClientSession() as session:
-            await session.post("https://hamed744-translate-tts-aloha.hf.space/gradio_api/queue/join", json=payload, timeout=20)
-            async with session.get(f"https://hamed744-translate-tts-aloha.hf.space/gradio_api/queue/data?session_hash={session_hash}", timeout=60) as resp:
+            # پیوستن به صف ترجمه
+            async with session.post(join_url, json=payload, timeout=20) as resp:
+                if resp.status != 200:
+                    return prompt_text
+                    
+            # دریافت داده‌ها به صورت جریانی (Stream)
+            data_url = f"https://hamed744-translate-tts-aloha.hf.space/gradio_api/queue/data?session_hash={session_hash}"
+            async with session.get(data_url, timeout=60) as resp:
                 async for line_bytes in resp.content:
                     line = line_bytes.decode('utf-8').strip()
                     if line.startswith("data: "):
                         try:
                             json_data = json.loads(line[6:])
-                            if json_data.get("msg") == "process_completed" and json_data.get("success"):
-                                return json_data["output"]["data"][0]
-                        except Exception: pass
-    except Exception: pass
+                            if json_data.get("msg") == "process_completed":
+                                if json_data.get("success"):
+                                    return json_data["output"]["data"][0]
+                                break
+                        except Exception:
+                            pass
+    except Exception:
+        pass
+        
     return prompt_text
 
+# --- ۲.۵. پردازش ویرایش عکس با FLUX.2-dev ---
 async def process_image_edit(client, chat_id, image_bytes, prompt):
     str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
     creds = get_user_credits(str_chat_id)
-    if creds["edit_image"] <= 0: return await send_with_keyboard(client, chat_id, "❌ اعتبار تمام شده.", False)
-    if not HF_TOKENS: return await send_with_keyboard(client, chat_id, "❌ توکن تنظیم نیست.", False)
+    if creds["edit_image"] <= 0:
+        return await send_with_keyboard(client, chat_id, "❌ اعتبار ویرایش عکس شما تمام شده است. لطفاً از منوی اصلی وارد بخش «خرید اشتراک 💎» شوید.", False)
+
+    if not HF_TOKENS:
+        return await send_with_keyboard(client, chat_id, "❌ توکن‌های هاگینگ فیس تنظیم نشده‌اند.", False)
 
-    proc_msg = await send_with_keyboard(client, chat_id, "🪄 در حال ویرایش...", False)
-    translated_prompt = await translate_text_aloha(prompt) or prompt
+    proc_msg = await send_with_keyboard(client, chat_id, "🪄 در حال ترجمه دستور شما توسط اسپیس و اعمال جادوی FLUX.2...\n(این فرآیند ممکن است کمی طول بکشد)", False)
+    
+    # گرفتن ترجمه از اسپیس درخواستی
+    translated_prompt = await translate_text_aloha(prompt)
+    if not translated_prompt or translated_prompt.strip() == "":
+        translated_prompt = prompt
 
     keys_to_try = HF_TOKENS.copy()
     random.shuffle(keys_to_try)
     generated_image = None
+    last_error_log = "سرور پاسخ نداد."
     
     for token in keys_to_try:
         try:
             hf_client = AsyncInferenceClient(provider="fal-ai", api_key=token)
-            generated_image = await hf_client.image_to_image(image_bytes, prompt=translated_prompt, model="black-forest-labs/FLUX.2-dev")
+            generated_image = await hf_client.image_to_image(
+                image_bytes,
+                prompt=translated_prompt,
+                model="black-forest-labs/FLUX.2-dev"
+            )
             break 
-        except Exception: continue
+        except Exception as e:
+            last_error_log = str(e)
+            continue
             
     try:
         if proc_msg:
-            msg_id = getattr(proc_msg, 'message_id', None) or (proc_msg.get('message_update', {}).get('message_id') if isinstance(proc_msg, dict) else None)
-            if msg_id: await client.delete_messages(chat_id,[msg_id])
+            msg_id = getattr(proc_msg, 'message_id', None)
+            if isinstance(proc_msg, dict): msg_id = proc_msg.get('message_update', {}).get('message_id') or proc_msg.get('message_id')
+            if msg_id: await client.delete_messages(chat_id, [msg_id])
     except Exception: pass
 
-    if not generated_image: return await send_with_keyboard(client, chat_id, f"❌ ویرایش انجام نشد.", True)
+    if not generated_image:
+        return await send_with_keyboard(client, chat_id, f"❌ متأسفانه ویرایش عکس انجام نشد.\n\n⚠️ علت:\n{last_error_log[:200]}", True)
 
+    # کسر اعتبار (ویرایش عکس محدود است حتی برای پرو)
     user_credits_db[str_chat_id]["edit_image"] -= 1
     save_db(user_credits_db)
 
     try:
         file_name = f"edited_flux_{uuid.uuid4().hex}.jpg"
-        generated_image.convert('RGB').save(file_name, format="JPEG", quality=100)
+        rgb_im = generated_image.convert('RGB')
+        rgb_im.save(file_name, format="JPEG", quality=100)
         await asyncio.sleep(1)
-        upload_result = await helper_upload_file(client, chat_id, file_name, "Image", f"🪄 ویرایش انجام شد!\n🔤 دستور: {prompt}")
+        caption_text = f"🪄 ویرایش عکس با هوش مصنوعی Flux.2 انجام شد!\n\n✨ تغییرات خواسته شده: {prompt}\n🔤 متن ارسال شده به هوش: {translated_prompt}"
+        upload_result = await helper_upload_file(client, chat_id, file_name, "Image", caption_text)
+        if upload_result is not True:
+            await send_with_keyboard(client, chat_id, f"❌ عکس ساخته شد اما خطا در ارسال به روبیکا رخ داد:\n`{str(upload_result)[:800]}`", True)
         if os.path.exists(file_name): os.remove(file_name)
-    except Exception: pass
+    except Exception as e:
+        await send_with_keyboard(client, chat_id, f"❌ خطا در ذخیره عکس ویرایش شده:\n{str(e)[:150]}", True)
+
 
+# --- ۳. پردازش ساخت صدا ---
 async def process_tts(client, chat_id, user_text, speaker_id, speaker_name):
     str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
     creds = get_user_credits(str_chat_id)
-    if creds["tts"] <= 0: return await send_with_keyboard(client, chat_id, "❌ اعتبار تمام شده.", False)
+    if creds["tts"] <= 0:
+        return await send_with_keyboard(client, chat_id, "❌ اعتبار تبدیل متن به صدای شما تمام شده است. لطفاً از منوی اصلی وارد بخش «خرید اشتراک 💎» شوید.", False)
 
     try:
-        proc_msg = await send_with_keyboard(client, chat_id, f"⏳ در حال ساخت صدا...", False)
+        proc_msg = await send_with_keyboard(client, chat_id, f"⏳ در حال ساخت صدا با «{speaker_name}»...\n(لطفاً صبور باشید)", False)
         payload = {"text": user_text, "speaker": speaker_id, "temperature": 1.5, "prompt": "", "use_live_model": True}
         headers = {"User-Agent": "Mozilla/5.0", "Content-Type": "application/json"}
         audio_bytes = None
+        last_error = "پاسخی دریافت نشد"
         workers = WORKER_URLS.copy()
         random.shuffle(workers)
         
@@ -625,78 +759,104 @@ 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
-                except Exception: continue
+                            else: last_error = "فایل نامعتبر"
+                        else: last_error = f"ارور ({response.status})"
+                except Exception as e: last_error = f"خطا: {str(e)}"; continue
 
         try:
             if proc_msg:
-                msg_id = getattr(proc_msg, 'message_id', None) or (proc_msg.get('message_update', {}).get('message_id') if isinstance(proc_msg, dict) else None)
-                if msg_id: await client.delete_messages(chat_id,[msg_id])
+                msg_id = getattr(proc_msg, 'message_id', None)
+                if isinstance(proc_msg, dict): msg_id = proc_msg.get('message_update', {}).get('message_id') or proc_msg.get('message_id')
+                if msg_id: await client.delete_messages(chat_id, [msg_id])
         except Exception: pass
 
         if audio_bytes:
+            # کسر اعتبار در دیتاست (اگر نامحدود نیست)
             if not creds.get("is_premium"):
                 user_credits_db[str_chat_id]["tts"] -= 1
                 save_db(user_credits_db)
+            
             file_name = f"audio_{uuid.uuid4().hex}.mp3"
             with open(file_name, "wb") as f: f.write(audio_bytes)
             await asyncio.sleep(1)
-            await helper_upload_file(client, chat_id, file_name, "Voice", "✅ صدای شما آماده شد.")
+            upload_result = await helper_upload_file(client, chat_id, file_name, "Voice", "✅ صدای شما آماده شد.")
+            if upload_result is not True: await send_with_keyboard(client, chat_id, f"❌ ارور آپلود:\n`{str(upload_result)[:800]}`", True)
             if os.path.exists(file_name): os.remove(file_name)
-        else: await send_with_keyboard(client, chat_id, "❌ سرورها درگیر هستند.", True)
-    except Exception: pass
+        else: await send_with_keyboard(client, chat_id, f"❌ سرورها درگیر هستند.\nدلیل: {last_error}", True)
+    except Exception: traceback.print_exc()
 
+
+# --- ۳.۵. پردازش پادکست ---
 async def process_podcast(client, chat_id, prompt):
     str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
     creds = get_user_credits(str_chat_id)
-    if creds["podcast"] <= 0: return await send_with_keyboard(client, chat_id, "❌ اعتبار تمام شده.", False)
+    if creds["podcast"] <= 0:
+        return await send_with_keyboard(client, chat_id, "❌ اعتبار ساخت پادکست شما تمام شده است. لطفاً از منوی اصلی وارد بخش «خرید اشتراک 💎» شوید.", False)
+
+    proc_msg = await send_with_keyboard(client, chat_id, "📻 در حال بررسی موضوع و نگارش سناریوی پادکست توسط هوش مصنوعی...\n(لطفاً صبور باشید)", False)
+    available_speakers =[]
+    for num_key, (spk_name, spk_id) in SPEAKERS.items():
+        gender = "male" if "مرد" in spk_name else "female"
+        available_speakers.append({"id": spk_id, "name": spk_name.split(' (')[0], "gender": gender})
 
-    proc_msg = await send_with_keyboard(client, chat_id, "📻 در حال نگارش پادکست...", False)
-    available_speakers = [{"id": v[1], "name": v[0].split(' (')[0], "gender": "male" if "مرد" in v[0] else "female"} for k, v in SPEAKERS.items()]
+    url_create = "https://ezmarynoori-podgen.hf.space/api/create-full-podcast"
+    payload_create = {"prompt": prompt, "available_speakers": available_speakers}
     
     async with aiohttp.ClientSession() as session:
         try:
-            async with session.post("https://ezmarynoori-podgen.hf.space/api/create-full-podcast", json={"prompt": prompt, "available_speakers": available_speakers}, timeout=60) as resp:
-                if resp.status != 202: return await send_with_keyboard(client, chat_id, "❌ خطا در سرور.", True)
+            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: return await send_with_keyboard(client, chat_id, "❌ خطا در اتصال.", True)
+        except Exception as e: return await send_with_keyboard(client, chat_id, f"❌ خطا در اتصال به سرور پادکست:\n{str(e)}", True)
 
+        url_status = f"https://ezmarynoori-podgen.hf.space/api/podcast-status/{task_id}"
         script_data = None
         for _ in range(40):
             await asyncio.sleep(3)
             try:
-                async with session.get(f"https://ezmarynoori-podgen.hf.space/api/podcast-status/{task_id}") as resp:
+                async with session.get(url_status) as resp:
                     if resp.status == 200:
                         status_data = await resp.json()
                         if status_data.get("status") == "completed":
                             script_data = status_data.get("data", {}).get("script",[])
                             break
-                        elif status_data.get("status") == "failed": return await send_with_keyboard(client, chat_id, "❌ شکست در سناریو.", True)
+                        elif status_data.get("status") == "failed":
+                            return await send_with_keyboard(client, chat_id, "❌ متأسفانه هوش مصنوعی نتوانست برای این موضوع سناریو بنویسد.", True)
             except Exception: pass
             
-        if not script_data: return await send_with_keyboard(client, chat_id, "❌ زمان انتظار پایان یافت.", True)
+        if not script_data: return await send_with_keyboard(client, chat_id, "❌ زمان انتظار برای نوشتن سناریو به پایان رسید.", True)
 
         try:
             if proc_msg:
-                msg_id = getattr(proc_msg, 'message_id', None) or (proc_msg.get('message_update', {}).get('message_id') if isinstance(proc_msg, dict) else None)
-                if msg_id: await client.delete_messages(chat_id,[msg_id])
+                msg_id = getattr(proc_msg, 'message_id', None)
+                if isinstance(proc_msg, dict): msg_id = proc_msg.get('message_update', {}).get('message_id') or proc_msg.get('message_id')
+                if msg_id: await client.delete_messages(chat_id, [msg_id])
         except: pass
         
-        proc_msg = await send_with_keyboard(client, chat_id, "🎙 در حال میکس دیالوگ‌ها...", False)
+        proc_msg = await send_with_keyboard(client, chat_id, f"🎙 سناریو نوشته شد! در حال ریکورد و میکس دیالوگ‌های گویندگان (شامل {len(script_data)} نوبت صحبت)...\nاین مرحله زمان‌بر است...", False)
+
         combined_audio = AudioSegment.empty()
+        url_generate = "https://ezmarynoori-podgen.hf.space/api/generate"
         
-        for turn in script_data:
+        for index, turn in enumerate(script_data):
+            payload_gen = {"text": turn["dialogue"], "speaker": turn["speaker_id"], "temperature": 0.9}
             chunk_audio_bytes = None
-            for _ in range(3):
+            for attempt in range(3):
                 try:
-                    async with session.post("https://ezmarynoori-podgen.hf.space/api/generate", json={"text": turn["dialogue"], "speaker": turn["speaker_id"], "temperature": 0.9}, timeout=120) as resp:
+                    async with session.post(url_generate, json=payload_gen, timeout=120) as resp:
                         if resp.status == 200:
                             chunk_audio_bytes = await resp.read()
                             break
                 except Exception: await asyncio.sleep(2)
-            if not chunk_audio_bytes: return await send_with_keyboard(client, chat_id, "❌ خطا در تولید صدا.", True)
-            try: combined_audio += AudioSegment.from_file(io.BytesIO(chunk_audio_bytes))
-            except Exception: return await send_with_keyboard(client, chat_id, "❌ خطا در پردازش صدا.", True)
+            
+            if not chunk_audio_bytes: return await send_with_keyboard(client, chat_id, f"❌ خطا در تولید صدای بخش {index+1} از سرور. عملیات متوقف شد.", True)
+                
+            try:
+                audio_segment = AudioSegment.from_file(io.BytesIO(chunk_audio_bytes))
+                combined_audio += audio_segment
+            except Exception as e: return await send_with_keyboard(client, chat_id, f"❌ خطا در پردازش صدا (آیا pydub و ffmpeg نصب است؟):\n{str(e)}", True)
 
+        # کسر اعتبار در دیتاست (اگر نامحدود نیست)
         if not creds.get("is_premium"):
             user_credits_db[str_chat_id]["podcast"] -= 1
             save_db(user_credits_db)
@@ -706,32 +866,40 @@ async def process_podcast(client, chat_id, prompt):
         
         try:
             if proc_msg:
-                msg_id = getattr(proc_msg, 'message_id', None) or (proc_msg.get('message_update', {}).get('message_id') if isinstance(proc_msg, dict) else None)
-                if msg_id: await client.delete_messages(chat_id,[msg_id])
+                msg_id = getattr(proc_msg, 'message_id', None)
+                if isinstance(proc_msg, dict): msg_id = proc_msg.get('message_update', {}).get('message_id') or proc_msg.get('message_id')
+                if msg_id: await client.delete_messages(chat_id, [msg_id])
         except: pass
 
-        await helper_upload_file(client, chat_id, file_name, "Voice", f"🎧 پادکست ساخته شد!\n💡 موضوع: {prompt}")
+        caption = f"🎧 پادکست شما با موفقیت میکس و ساخته شد!\n\n💡 موضوع شما: {prompt}"
+        upload_result = await helper_upload_file(client, chat_id, file_name, "Voice", caption)
+        if upload_result is not True: await send_with_keyboard(client, chat_id, f"❌ پادکست ساخته شد اما روبیکا خطای آپلود داد.\n\n`{str(upload_result)[:800]}`", True)
         if os.path.exists(file_name): os.remove(file_name)
 
+
+# --- ۴. پردازش تبدیل فایل صوتی/تصویری به متن ---
 async def process_stt(client, chat_id, audio_bytes, file_name):
     str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
     creds = get_user_credits(str_chat_id)
-    if creds["stt"] <= 0: return await send_with_keyboard(client, chat_id, "❌ اعتبار تمام شده.", False)
-    if not GEMINI_KEYS: return await send_with_keyboard(client, chat_id, "❌ کلید تنظیم نشده.", False)
+    if creds["stt"] <= 0:
+        return await send_with_keyboard(client, chat_id, "❌ اعتبار تبدیل صدا به متن شما تمام شده است. لطفاً از منوی اصلی وارد بخش «خرید اشتراک 💎» شوید.", False)
+
+    if not GEMINI_KEYS: return await send_with_keyboard(client, chat_id, "❌ کلیدهای جیمینای تنظیم نشده‌اند.", False)
     
-    proc_msg = await send_with_keyboard(client, chat_id, "📝 در حال پیاده‌سازی متن...", False)
+    proc_msg = await send_with_keyboard(client, chat_id, "📝 در حال گوش دادن و پیاده‌سازی متن...", False)
     base64_data = base64.b64encode(audio_bytes).decode('utf-8')
     mime_type, _ = mimetypes.guess_type(file_name)
     if not mime_type: mime_type = "audio/ogg" 
     
+    # دریافت ۱۰۰ کلید به صورت چرخشی
     keys_to_try = get_next_gemini_keys(100)
     transcribed_text = None
-    prompt = "کلمه به کلمه به متن تبدیل کن. هیچ توضیح اضافه‌ای نده."
+    prompt = "لطفاً این فایل صوتی/تصویری را با دقت کامل گوش بده و صحبت‌های داخل آن را کلمه به کلمه به متن تبدیل کن. هیچ توضیح اضافه‌ای نده."
     
     async with aiohttp.ClientSession() as session:
         for key in keys_to_try:
             url = f"https://generativelanguage.googleapis.com/v1beta/models/gemini-2.5-flash:generateContent?key={key}"
-            payload = {"contents":[{"parts":[{"text": prompt}, {"inlineData": {"mimeType": mime_type, "data": base64_data}}]}], "generationConfig": {"temperature": 0.2}}
+            payload = {"contents": [{"parts":[{"text": prompt}, {"inlineData": {"mimeType": mime_type, "data": base64_data}}]}], "generationConfig": {"temperature": 0.2}}
             try:
                 async with session.post(url, json=payload, timeout=60) as response:
                     if response.status == 200:
@@ -742,28 +910,36 @@ async def process_stt(client, chat_id, audio_bytes, file_name):
 
     try:
         if proc_msg:
-            msg_id = getattr(proc_msg, 'message_id', None) or (proc_msg.get('message_update', {}).get('message_id') if isinstance(proc_msg, dict) else None)
+            msg_id = getattr(proc_msg, 'message_id', None)
+            if isinstance(proc_msg, dict): msg_id = proc_msg.get('message_update', {}).get('message_id') or proc_msg.get('message_id')
             if msg_id: await client.delete_messages(chat_id, [msg_id])
     except Exception: pass
 
     if transcribed_text:
+        # کسر اعتبار در دیتاست (اگر نامحدود نیست)
         if not creds.get("is_premium"):
             user_credits_db[str_chat_id]["stt"] -= 1
             save_db(user_credits_db)
         await send_with_keyboard(client, chat_id, f"📝 **متن استخراج شده:**\n\n{transcribed_text}", True)
-    else: await send_with_keyboard(client, chat_id, "❌ سرور شلوغ است.", True)
+    else: 
+        await send_with_keyboard(client, chat_id, "❌ سرور شلوغ است فعلا بعدا امتحان کنید.", True)
 
+
+# --- ۵. پردازش تحلیل فایل مستقل ---
 async def process_file_analysis(client, chat_id, file_bytes, file_name, prompt):
     str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
     creds = get_user_credits(str_chat_id)
-    if creds["file"] <= 0: return await send_with_keyboard(client, chat_id, "❌ اعتبار تمام شده.", False)
-    if not GEMINI_KEYS: return await send_with_keyboard(client, chat_id, "❌ کلید تنظیم نیست.", False)
+    if creds["file"] <= 0:
+        return await send_with_keyboard(client, chat_id, "❌ اعتبار تحلیل فایل شما تمام شده است. لطفاً از منوی اصلی وارد بخش «خرید اشتراک 💎» شوید.", False)
+
+    if not GEMINI_KEYS: return await send_with_keyboard(client, chat_id, "❌ کلید جیمینای تنظیم نیست.", False)
     
     proc_msg = await send_with_keyboard(client, chat_id, "👁️ در حال تحلیل فایل...", False)
     base64_data = base64.b64encode(file_bytes).decode('utf-8')
     mime_type, _ = mimetypes.guess_type(file_name)
     if not mime_type: mime_type = "image/jpeg"
     
+    # دریافت ۱۰۰ کلید به صورت چرخشی
     keys_to_try = get_next_gemini_keys(100)
     final_answer = None
     
@@ -781,16 +957,19 @@ async def process_file_analysis(client, chat_id, file_bytes, file_name, prompt):
 
     try:
         if proc_msg:
-            msg_id = getattr(proc_msg, 'message_id', None) or (proc_msg.get('message_update', {}).get('message_id') if isinstance(proc_msg, dict) else None)
-            if msg_id: await client.delete_messages(chat_id,[msg_id])
+            msg_id = getattr(proc_msg, 'message_id', None)
+            if isinstance(proc_msg, dict): msg_id = proc_msg.get('message_update', {}).get('message_id') or proc_msg.get('message_id')
+            if msg_id: await client.delete_messages(chat_id, [msg_id])
     except Exception: pass
 
     if final_answer: 
+        # کسر اعتبار در دیتاست (اگر نامحدود نیست)
         if not creds.get("is_premium"):
             user_credits_db[str_chat_id]["file"] -= 1
             save_db(user_credits_db)
         await send_with_keyboard(client, chat_id, f"💡 **نتیجه تحلیل:**\n\n{final_answer}", True)
-    else: await send_with_keyboard(client, chat_id, "❌ سرور شلوغ است.", True)
+    else: 
+        await send_with_keyboard(client, chat_id, "❌ سرور شلوغ است فعلا بعدا امتحان کنید.", True)
 
 
 # --- تنظیمات ربات روبیکا ---
@@ -803,85 +982,69 @@ else:
     async def main_handler(client, update):
         global BOT_GUID
         
-        # 🔥 دیوار دفاعی اول: فیلتر ضد رگبار 🔥
+        # 🔥 سیستم ضد رگبار و تخلیه صف (Backlog) سرور 🔥
+        # در صورت هجوم پیام‌های تلنبار شده سرور روبیکا، پیام‌ها رد می‌شوند
         if is_backlog_burst():
             return
             
-        current_time = time.time()
-        
         try:
-            # 1. استخراج آبجکت پیام
-            msg_obj = getattr(update, "message", None) or getattr(update, "new_message", None)
-            
-            # 2. فیلتر خود ربات
-            author_id = getattr(update, 'author_guid', None)
-            if not author_id and msg_obj:
-                author_id = getattr(msg_obj, 'author_object_guid', None)
-                if not author_id and isinstance(msg_obj, dict):
-                    author_id = msg_obj.get('author_object_guid') or msg_obj.get('author_guid')
-                    
+            # 🛡 دریافت آیدی یکتای ربات برای جلوگیری از لوپ 🛡
             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
+                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
-
-            # 3. استخراج امن زمان پیام برای فیلتر تکمیلی
-            msg_time = getattr(update, 'timestamp', None)
-            if not msg_time and msg_obj:
-                msg_time = getattr(msg_obj, 'timestamp', None)
-            if not msg_time and isinstance(update, dict):
-                msg_time = update.get('timestamp')
-                if not msg_time and 'message' in update and isinstance(update['message'], dict):
-                    msg_time = update['message'].get('timestamp')
-                    
-            if msg_time:
-                try:
-                    ts = float(msg_time)
-                    while ts > 3e9: ts /= 10.0 # نرمال‌سازی زمان به ثانیه
-                    if current_time - ts > 60.0: # اگر پیام مال بیشتر از ۶۰ ثانیه پیش بود، دور ریخته می‌شود
-                        return
-                except Exception: pass
-
-            # 4. استخراج چت آیدی
-            chat_id = getattr(update, 'object_guid', None) or getattr(update, 'chat_id', None)
-            if not chat_id and msg_obj:
-                chat_id = getattr(msg_obj, 'object_guid', None) or getattr(msg_obj, 'chat_id', None)
-            if not chat_id: chat_id = author_id
+            
+            # --- استخراج دقیق شناسه چت ---
+            chat_id = getattr(update, 'object_guid', None) or getattr(update, 'author_guid', None) or getattr(update, "chat_id", None)
             if not chat_id: return
             
-            # 5. سیستم ضد تداخل آیدی یکتا
+            # استخراج آیدی پیام
             msg_id = getattr(update, "message_id", None)
             if not msg_id and msg_obj:
-                msg_id = getattr(msg_obj, "message_id", None)
-            if msg_id:
-                unique_msg_key = f"{chat_id}_{msg_id}"
+                msg_id = msg_obj.get("message_id") if isinstance(msg_obj, dict) else getattr(msg_obj, "message_id", None)
+            
+            # 🛡 کلید ترکیبی ضد تداخل: آیدی چت + آیدی پیام 🛡
+            unique_msg_key = f"{chat_id}_{msg_id}" if msg_id else None
+            if unique_msg_key:
                 if unique_msg_key in processed_message_ids: return
                 processed_message_ids.add(unique_msg_key)
                 if len(processed_message_ids) > 5000: processed_message_ids.clear()
             
-            # 6. محدودکننده سرعت هر کاربر (1 ثانیه)
+            current_time = time.time()
+            
+            # 🛡 سیستم محدودکننده سرعت کاربر (Rate Limit) 🛡
             last_req_time = user_last_request_time.get(chat_id, 0)
             if current_time - last_req_time < 1.0:
                 return
             user_last_request_time[chat_id] = current_time
 
-            # 7. استخراج متن
-            user_text = getattr(update, "text", "") or (getattr(msg_obj, "text", "") if msg_obj else "")
+            # تشخیص محتوای متنی
+            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 user_text_str and user_text_str.startswith(("⏳", "❌", "✅", "🧠", "🎨", "🪄", "🎙", "📻", "📝", "👁️", "💡", "📥")):
                 return
 
             if chat_id not in user_states:
                 user_states[chat_id] = {"mode": None, "text": "", "history":[], "file_bytes": None, "file_name": None}
 
-            # 🛠 --- سیستم پنل مدیریت --- 🛠
+            # 🛠 --- سیستم پنل مدیریت (بدون نیاز به لاگین) --- 🛠
             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:
@@ -889,12 +1052,22 @@ else:
                     if target_id:
                         if target_id not in user_credits_db:
                             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
+                                "is_premium": False,
+                                "expire_date": None,
+                                "last_reset": "",
+                                "chat": 10,
+                                "image": 5,
+                                "edit_image": 1,
+                                "podcast": 2,
+                                "tts": 5,
+                                "file": 1,
+                                "stt": 5
                             }
+                        
                         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
@@ -902,44 +1075,83 @@ else:
                         user_credits_db[target_id]["tts"] = 999999
                         user_credits_db[target_id]["file"] = 999999
                         user_credits_db[target_id]["stt"] = 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, "🎉 حساب شما پرو شد.", True)
-                        except: pass
+                        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 and target_id in user_credits_db:
-                        user_credits_db[target_id]["is_premium"] = False
-                        user_credits_db[target_id]["expire_date"] = None
-                        save_db(user_credits_db)
-                        await send_with_keyboard(client, chat_id, f"✅ کاربر `{target_id}` رایگان شد.", False)
+                    if target_id:
+                        if target_id in user_credits_db:
+                            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 and target_id in user_credits_db:
-                        t_creds = user_credits_db[target_id]
-                        is_prem = t_creds.get("is_premium", False)
-                        if is_prem:
-                            days_left = 0
-                            if t_creds.get("expire_date"):
-                                diff = datetime.datetime.fromisoformat(t_creds["expire_date"]) - datetime.datetime.now()
-                                days_left = max(0, diff.days)
-                            status_text = f"🌟 پرو ({days_left} روز)"
-                        else: status_text = "🥉 رایگان"
-                        info_msg = f"شناسه: `{target_id}`\nوضعیت: {status_text}\nعکس: {t_creds.get('image',0)} | چت: {t_creds.get('chat',0)}"
-                        await send_with_keyboard(client, chat_id, info_msg, False)
+                    if target_id:
+                        if target_id in user_credits_db:
+                            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)
+                            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)
+
+                            info_msg = f"""🔍 **اطلاعات کاربر `{target_id}`:**
+
+🔹 **وضعیت:** {status_text}
+
+📊 **سهمیه:**
+- چت: {chat_rem}
+- تولید عکس: {image_rem}
+- ویرایش عکس: {edit_image_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"
+            
             if msg_obj:
                 for attr in['file', 'file_inline', 'photo', 'voice', 'audio', 'document', 'video']:
                     file_attr = getattr(msg_obj, attr, None)
@@ -947,6 +1159,7 @@ else:
                         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']:
@@ -959,77 +1172,150 @@ else:
             if user_text_str in["/start", "سلام", "لغو", "/cancel", "❌ لغو", "برگشت♻️"]:
                 user_states[chat_id]["mode"] = None
                 user_states[chat_id]["file_bytes"] = None
-                await send_with_keyboard(client, chat_id, "سلام! به ربات هوش مصنوعی آلفا خوش آمدید 🤖\n\nلطفاً از کیبورد پایین انتخاب کنید:", True)
+                await send_with_keyboard(client, chat_id, "سلام! به ربات هوش مصنوعی آلفا خوش آمدید 🤖\n\nلطفاً برای شروع، از کیبورد پایین یکی از بخش‌ها را انتخاب کنید:", True)
                 return
 
-            if user_text_str in["/account", "حساب کاربری 👤"]:
+            # --- حساب کاربری ---
+            if user_text_str in ["/account", "حساب کاربری 👤"]:
                 creds = get_user_credits(chat_id)
                 is_prem = creds.get("is_premium", False)
+                
                 if is_prem:
+                    expire_txt = "نامشخص"
                     days_left = 0
                     if creds.get("expire_date"):
-                        diff = datetime.datetime.fromisoformat(creds["expire_date"]) - datetime.datetime.now()
-                        days_left = max(0, diff.days)
-                    status_text = f"🌟 نسخه پرو (ویژه)\n⏳ **باقیمانده:** {days_left} روز"
-                else: status_text = "🥉 نسخه رایگان (آزمایشی)"
-
-                account_profile = f"""👤 **حساب کاربری**\n🔹 `{chat_id}`\n🔹 {status_text}\n\n📊 **سهمیه شما:**\n- چت: {"∞" if is_prem else creds['chat']}\n- عکس: {creds['image']}\n- ویرایش عکس: {creds['edit_image']}\n- پادکست: {"∞" if is_prem else creds['podcast']}\n- صدا: {"∞" if is_prem else creds['tts']}\n- تحلیل: {"∞" if is_prem else creds['file']}\n- صدا به متن: {"∞" if is_prem else creds['stt']}"""
+                        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']
+                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']
+
+                account_profile = f"""👤 **اطلاعات حساب کاربری شما**
+
+🔹 **شناسه یکتا:** `{chat_id}`
+🔹 **وضعیت اشتراک:** {status_text}{expire_info}
+
+📊 **سهمیه باقی‌مانده شما:**
+- 💬 چت هوشمند: {chat_rem}
+- 🎨 تولید تصویر: {image_rem} عدد
+- 🪄 ویرایش تصویر: {edit_image_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["/buy", "خرید اشتراک 💎"]:
-                buy_text = f"💎 **خرید اشتراک یک ماهه**\n💳 مبلغ 250 هزار تومان\n💳 کارت: `6219861411958035` کوهی\n\nپس از واریز، رسید و شناسه زیر را به پشتیبانی ارسال کنید:\nشناسه: `{chat_id}`\nپشتیبانی: @H_a_m_e_d100"
+            # --- دکمه خرید اشتراک ---
+            if user_text_str in ["/buy", "خرید اشتراک 💎"]:
+                buy_text = f"""💎 **خرید اشتراک ویژه آلفا پرو (یک ماهه)**
+
+با تهیه اشتراک ویژه، محدودیت‌ها را کنار بزنید و از نهایت قدرت هوش مصنوعی لذت ببرید! 🚀
+
+🎁 **بسته طلایی یک‌ماهه شامل:**
+🤖 چت با هوش مصنوعی بصورت نامحدود
+🗣 تبدیل متن به صدا بصورت نامحدود با ۳۰ گوینده
+🎙 ساخت پادکست بصورت نامحدود 
+
+🪄 ۱۰ ویرایش تصویر
+🎨 ۲۰ تولید تصویر 
+📁 تحلیل نامحدود فایل و سند
+📝 تبدیل فایل صوتی به متن نامحدود
+
+💳 **هزینه اشتراک یک ماهه:** 250 هزار تومان
+
+💳 **شماره کارت جهت واریز:**
+`6219861411958035`
+👤 **به نام:** کوهی
+
+✅ **نحوه فعال‌سازی:**
+پس از واریز مبلغ، لطفاً رسید پرداختی را به همراه **شناسه یکتای خود** (که در پایین آمده) به آیدی پشتیبانی زیر ارسال کنید تا اشتراک شما فعال گردد:
+
+🔑 **شناسه یکتای شما:** `{chat_id}`
+
+👨‍💻 **ارتباط با پشتیبانی:**
+🆔 @H_a_m_e_d100"""
                 await send_with_keyboard(client, chat_id, buy_text, True)
                 return
 
+            # --- دکمه انتقال اکانت ---
             if user_text_str in["/transfer", "انتقال اکانت از برنامه به ربات"]:
-                transfer_text = f"🔄 **انتقال اکانت**\nاگر در برنامه اشتراک دارید، نیازی به خرید مجدد نیست. شناسه ربات خود را به پشتیبانی بفرستید:\nشناسه: `{chat_id}`\nپشتیبانی: @H_a_m_e_d100"
+                transfer_text = f"""🔄 **انتقال اکانت از برنامه به ربات**
+
+کاربر گرامی، در صورتی که داخل برنامه «هوش مصنوعی آلفا» پیش‌تر اشتراک تهیه کرده‌اید، نیازی به خرید مجدد اشتراک داخل ربات نیست! 🎉
+
+کافیست **شناسه یکتای** ربات روبیکای خود را کپی کرده و برای پشتیبانی ما در برنامه هوش مصنوعی آلفا ارسال کنید تا اکانت اشتراکی شما به سرعت از برنامه به ربات روبیکا انتقال داده شود.
+
+🔑 **شناسه یکتای ربات شما:** `{chat_id}`
+
+👨‍💻 **دقت کنید شناسه ربات رو به پشتیبانی داخل خود برنامه هوش مصنوعی آلفا ارسال کنید:**
+🆔 @H_a_m_e_d100"""
                 await send_with_keyboard(client, chat_id, transfer_text, True)
                 return
 
             if user_text_str in["/chat", "💬 چت", "چت با هوش مصنوعی 🤖"]:
                 user_states[chat_id]["mode"] = "chat"
                 user_states[chat_id]["history"] =[]
-                await send_with_keyboard(client, chat_id, "💬 شما وارد بخش چت شدید. سوال خود را بپرسید:", True)
+                await send_with_keyboard(client, chat_id, "💬 شما وارد بخش **چت با هوش مصنوعی** شدید.\n\nهر سوالی دارید بفرستید تا جواب بدم:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
                 return
 
             if user_text_str in["/image", "🎨 عکس", "ساخت تصاویر🎨"]:
                 user_states[chat_id]["mode"] = "image_waiting_for_text"
-                await send_with_keyboard(client, chat_id, "🎨 شما وارد ساخت عکس شدید. متن خود را بفرستید:", True)
+                await send_with_keyboard(client, chat_id, "🎨 شما وارد بخش **ساخت عکس پیشرفته** شدید.\n\nمتن خود را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
                 return
 
-            if user_text_str in["/edit_image", "ویرایش تصاویر 🪄"]:
+            if user_text_str in ["/edit_image", "ویرایش تصاویر 🪄"]:
                 user_states[chat_id]["mode"] = "image_edit_waiting_for_image"
                 user_states[chat_id]["file_bytes"] = None
-                await send_with_keyboard(client, chat_id, "🪄 لطفاً عکسی که می‌خواهید ویرایش کنید را بفرستید:", True)
+                await send_with_keyboard(client, chat_id, "🪄 به بخش **ویرایش عکس (Flux.2)** خوش آمدید.\n\nلطفاً ابتدا عکسی که می‌خواهید ویرایش کنید را بفرستید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
                 return
 
-            if user_text_str in["/tts", "🎙️ صدا", "تبدیل متن به صدا🗣️"]:
+            if user_text_str in ["/tts", "🎙️ صدا", "تبدیل متن به صدا🗣️"]:
                 user_states[chat_id]["mode"] = "tts_waiting_for_text"
-                await send_with_keyboard(client, chat_id, "🎙️ لطفاً متن خود را برای تبدیل به صدا بفرستید:", True)
+                await send_with_keyboard(client, chat_id, "🎙️ شما وارد بخش **تبدیل متن به صدا** شدید.\n\nلطفاً متنی که می‌خواهید به صدا تبدیل شود را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
                 return
             
             if user_text_str in["/podcast", "📻 پادکست", "ساخت پادکست 🎙️"]:
                 user_states[chat_id]["mode"] = "podcast_waiting_for_topic"
-                await send_with_keyboard(client, chat_id, "📻 لطفاً موضوع پادکست را بفرستید:", True)
+                await send_with_keyboard(client, chat_id, "📻 شما وارد بخش **ساخت پادکست** شدید.\n\nلطفاً موضوع پادکست خود را بفرستید.\nمثال: درباره تاریخچه پیدایش قهوه با ۳ گوینده یک پادکست جذاب بساز\n\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
                 return
 
-            if user_text_str in ["/file", "تحلیل فایل 📁"]:
+            if user_text_str in["/file", "تحلیل فایل 📁"]:
                 user_states[chat_id]["mode"] = "file_waiting_for_file"
                 user_states[chat_id]["file_bytes"] = None
-                await send_with_keyboard(client, chat_id, "📁 لطفاً فایل خود را بفرستید:", True)
+                await send_with_keyboard(client, chat_id, "📁 شما وارد بخش **تحلیل فایل اختصاصی** شدید.\n\nلطفاً فایل خود را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
                 return
 
             if user_text_str in["/stt", "فایل صوتی به متن 📝"]:
                 user_states[chat_id]["mode"] = "stt_waiting_for_audio"
-                await send_with_keyboard(client, chat_id, "📝 لطفاً فایل صوتی را بفرستید:", True)
+                await send_with_keyboard(client, chat_id, "📝 شما وارد بخش **تبدیل صدا به متن** شدید.\n\nلطفاً فایل خود (ویس، آهنگ، ویدیو و...) را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
                 return
 
             current_mode = user_states[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)
+                elif user_text_str: await send_with_keyboard(client, chat_id, "⚠️ لطفاً ابتدا از کیبورد پایین، بخش مورد نظرتان را انتخاب کنید:", True)
                 return
 
             elif current_mode == "chat":
@@ -1038,7 +1324,7 @@ else:
                     try:
                         file_bytes = await helper_download_file(client, msg_obj)
                         asyncio.create_task(process_gemini(client, chat_id, user_text_str, file_bytes=file_bytes, file_name=file_name))
-                    except Exception as dl_err: await send_with_keyboard(client, chat_id, "❌ خطا در دریافت.", 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
 
@@ -1047,14 +1333,14 @@ else:
                 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)
+                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[chat_id]["file_bytes"] = file_bytes
                     user_states[chat_id]["mode"] = "image_edit_waiting_for_prompt"
-                    await send_with_keyboard(client, chat_id, "✅ عکس دریافت شد. حالا دستور خود را تایپ کنید.", False)
-                except Exception: await send_with_keyboard(client, chat_id, "❌ خطا در دانلود.", False)
+                    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":
@@ -1063,51 +1349,66 @@ else:
                     user_states[chat_id]["mode"] = None 
                     user_states[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)
+                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, "⚠️ متن خیلی طولانی است.", False)
+                    if len(user_text_str) > 2500: return await send_with_keyboard(client, chat_id, "⚠️ لطفاً متنی کوتاه‌تر از 2500 کاراکتر بفرستید.", False)
                     user_states[chat_id]["text"] = user_text_str
                     user_states[chat_id]["mode"] = "tts_waiting_for_speaker"
-                    await send_with_keyboard(client, chat_id, "✅ ذخیره شد.\nلطفاً شماره گوینده (1 تا 30) را بفرستید.", False)
+                    
+                    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[chat_id]["text"]
                     user_states[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)
+                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)
+                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)
+                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: await send_with_keyboard(client, chat_id, "❌ خطا در دانلود.", 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_file":
-                if not is_file: return await send_with_keyboard(client, chat_id, "⚠️ لطفاً یک فایل ارسال کنید.", False)
-                await send_with_keyboard(client, chat_id, "📥 در حال دانلود...", False)
+                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[chat_id]["file_bytes"] = file_bytes
                     user_states[chat_id]["file_name"] = file_name 
                     user_states[chat_id]["mode"] = "file_waiting_for_prompt"
-                    await send_with_keyboard(client, chat_id, "✅ فایل دریافت شد. حالا بپرسید چگونه تحلیل شود؟", False)
-                except Exception: await send_with_keyboard(client, chat_id, "❌ خطا در دانلود.", False)
+                    await send_with_keyboard(client, chat_id, "✅ فایل با موفقیت دریافت شد.\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":
@@ -1116,7 +1417,7 @@ else:
                     saved_name = user_states[chat_id].get("file_name", "file.jpeg")
                     user_states[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)
+                else: await send_with_keyboard(client, chat_id, "⚠️ لطفاً درخواست خود را متنی بنویسید.", False)
                 return
 
         except Exception: traceback.print_exc()
@@ -1124,5 +1425,5 @@ else:
 if __name__ == "__main__":
     threading.Thread(target=run_flask, daemon=True).start()
     if bot_token:
-        print("🚀 ربات آلفا پرو به همراه دیواره ضد-رگبار (Burst Controller) روشن شد...")
+        print("ربات آلفا پرو با سیستم اشتراک نامحدود + سپر امنیتی Burst Controller روشن شد...")
         bot.run()