Update main.py

main.py

@@ -1958,12 +1958,13 @@ async def process_create_file(client, chat_id, topic):
 
 # ==============================================================================
 # 🟢 پارت 20: بدنه اصلی ربات (Handler)، دستورات مدیریتی، حلقه اصلی و استارت
-# ⚠️ (نسخه موقت جاروبرقی: فقط پیام‌ها را می‌خواند و تیک می‌زند تا صف خالی شود) ⚠️
 # ==============================================================================
 # ==================================================================
 # حلقه و مدیریت اصلی ربات
 # ==================================================================
 
+BOT_START_TIME = time.time()  # ⏳ زمان دقیق روشن شدن ربات ثبت می‌شود
+
 # 🧹 سیستم پاکسازی هوشمند رم (Garbage Collector) مخصوص هزاران کاربر
 async def ram_garbage_collector():
     """این تابع در پس‌زمینه می‌چرخد و فایل‌های رها شده در حافظه را پاک می‌کند تا رم سرور پر نشود"""
@@ -2027,20 +2028,793 @@ else:
             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)
             
+            str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
+            creds = get_user_credits(str_chat_id)
+
             # ===================================================================
-            # 🛑 سیستم صد در صد قطعی ضد تکرار پیام با استفاده از دیتابیس ابری
+            # 🛑 سیستم صد در صد قطعی ضد تکرار پیام و فیلتر پیام‌های قدیمی (Timestamp)
             # ===================================================================
             if msg_id:
                 str_msg_id = str(msg_id).strip()
                 if is_message_processed(str_msg_id):
                     return
-                # شناسه پیام در دیتابیس ثبت می‌شود تا دیگر هرگز خوانده نشود
+                
+                # ⏳ تشخیص پیام‌های قدیمی (مربوط به قبل از ری‌استارت ربات)
+                is_old = False
+                try:
+                    for attr in['timestamp', 'time', 'date', 'message_date']:
+                        val = getattr(msg_obj, attr, None)
+                        if not val and isinstance(msg_obj, dict):
+                            val = msg_obj.get(attr)
+                        if val:
+                            val_int = int(val)
+                            # روبیکا معمولا زمان را ۱۳ رقمی (میلی‌ثانیه) می‌دهد، تبدیل به ثانیه:
+                            if val_int > 10000000000:
+                                val_int = val_int / 1000
+                            
+                            # اگر پیام بیشتر از 60 ثانیه قبل از روشن شدن ربات فرستاده شده باشد، قدیمی است
+                            if val_int < BOT_START_TIME - 60:
+                                is_old = True
+                            break
+                except Exception:
+                    pass
+
+                # پیام چه قدیمی باشد چه جدید، در دیتابیس ثبت می‌شود که دیگر خوانده نشود
                 mark_message_processed(str_msg_id)
-                print(f"✅ پیام قدیمی با شناسه {str_msg_id} تیک خورد و دور انداخته شد.")
+
+                if is_old:
+                    # پیام تلنبار شده و قدیمی است، کاملا بی‌سروصدا دور ریخته می‌شود (بدون جواب دادن)
+                    return
             # ===================================================================
+
+            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": 0,
+                                "edit_image": 0,
+                                "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"] = 10
+                        user_credits_db[target_id]["edit_image"] = 5
+                        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"] = "" 
+                            user_credits_db[target_id]["image"] = 0
+                            user_credits_db[target_id]["edit_image"] = 0
+                            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"
             
-            # ⛔️ توقف در همین نقطه! هیچ پردازشی انجام نمی‌شود و هیچ پیامی ارسال نمی‌گردد.
-            return
+            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"""💎 **خرید اشتراک ویژه آلفا پرو (یک ماهه)**
+
+با تهیه اشتراک ویژه، محدودیت‌ها را کنار بزنید و از نهایت قدرت هوش مصنوعی لذت ببرید! 🚀
+
+━━━━━━━━━━━━━━━━━━━
+🎁 **بسته طلایی یک‌ماهه شامل:**
+🤖 چت با هوش مصنوعی: نامحدود ∞
+🎙️ تغییر صدا و کلون کردن صدا: نامحدود ∞
+🗣 تبدیل متن به صدا (۳۰ گوینده): نامحدود ∞
+🎙 ساخت پادکست: نامحدود ∞
+📁 تحلیل فایل و سند: نامحدود ∞
+📝 تبدیل فایل صوتی به متن: نامحدود ∞
+🪄 ویرایش تصویر: 5 عدد
+🎨 تولید تصویر: 10 عدد
+━━━━━━━━━━━━━━━━━━━
+
+💳 **هزینه اشتراک یک ماهه:** 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", "ویرایش تصاویر 🪄"]:
+                if not creds.get("is_premium", False):
+                    msg = """کاربر گرامی،
+
+ضمن تشکر از توجه شما، به اطلاع می‌رساند که قابلیت ویرایش تصاویر در حال حاضر به صورت رایگان در دسترس نمی‌باشد. این سرویس به دلیل نیاز به منابع پردازشی بالا، جزو خدمات ویژه و نیازمند تهیه اشتراک است.
+
+با این حال، شما می‌توانید از تست رایگان و امکانات سایر بخش‌های پلتفرم ما بهره‌مند شوید.
+
+ما همواره در تلاش برای افزایش منابع و اضافه کردن خدمات رایگان بیشتر به کاربران عزیز هستیم.
+
+در حال حاضر، می‌توانید از سایر بخش‌های رایگان موجود استفاده کنید و یا برای دسترسی کامل و نامحدود به تمامی قابلیت‌ها (از جمله ویرایش تصاویر)، اشتراک تهیه نمایید.
+
+از صبوری و همراهی شما سپاسگزاریم."""
+                    await send_with_keyboard(client, chat_id, msg, False)
+                    return
+                
+                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"] = 10
+                        inviter_data["edit_image"] = 5
+                        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()
 
@@ -2054,5 +2828,5 @@ if __name__ == "__main__":
         
         loop.create_task(ram_garbage_collector())
         
-        print("🚀 ربات در حالت موقت (جاروبرقی پیام‌های قدیمی) روشن شد. منتظر بمانید تا صف پیام‌ها خالی شود...")
+        print("🚀 ربات آلفا پرو (نسخه صنعتی + دیتابیس هوشمند + فیلتر زمان قطعی + 256 تونل همزمان) روشن شد...")
         bot.run()