Delete main (پاکسازی).py

main (پاکسازی).py

@@ -1,1883 +0,0 @@
-# ==============================================================================
-# 🟢 پارت 1: وارد کردن کتابخانه‌ها و ماژول‌ها (Imports)
-# ==============================================================================
-import os
-import time
-import threading
-import random
-import aiohttp
-import traceback
-import asyncio
-import base64
-import mimetypes
-import io
-import json
-import datetime
-import string
-import uuid
-import concurrent.futures
-import sqlite3     # 🟢 اضافه شده برای دیتابیس فوق‌سریع 
-import copy        # 🟢 اضافه شده برای سیستم تشخیص تغییرات دیتابیس
-from flask import Flask
-from rubpy.bot import BotClient, filters  
-
-from huggingface_hub import AsyncInferenceClient, HfApi, hf_hub_download
-from PIL import Image
-from pydub import AudioSegment
-
-# ==============================================================================
-# 🟢 پارت 2: تنظیمات سرورها، مدل‌های تغییر صدا و کلون صدا
-# ==============================================================================
-# --- تنظیمات آدرس سرورهای تغییر صدا ---
-VC_BASE_URL = "https://sada8888-sada.hf.space"
-LEGACY_BASE_URL = "https://ezmarynoori-rvc.hf.space"
-
-LEGACY_MODELS = {
-    "1": {"name": "شادمهر", "url": "https://huggingface.co/amirmatrix/shadmehr/resolve/main/added_IVF722_Flat_nprobe_1_shadmehr_v2.zip?download=true", "gender": "male"},
-    "2": {"name": "معین", "url": "https://huggingface.co/datasets/Hamed744/Ezmary/resolve/main/Moein.zip?download=true", "gender": "male"},
-    "3": {"name": "بیلی آیلیش", "url": "https://huggingface.co/datasets/Hamed744/Ezmary/resolve/main/Billie.zip?download=true", "gender": "female"},
-    "4": {"name": "محسن چاوشی", "url": "https://huggingface.co/datasets/Hamed744/Ezmary/resolve/main/chavoshi250.zip?download=true", "gender": "male"},
-    "5": {"name": "سیاوش قمیشی", "url": "https://huggingface.co/datasets/Hamed744/Ezmary/resolve/main/Ghomayshi250.zip?download=true", "gender": "male"},
-    "6": {"name": "یاس", "url": "https://huggingface.co/datasets/Hamed744/Ezmary/resolve/main/Yas300.zip?download=true", "gender": "male"},
-    "7": {"name": "عادل فردوسی‌پور", "url": "https://huggingface.co/datasets/Hamed744/Ezmary/resolve/main/Adel.zip?download=true", "gender": "male"},
-    "8": {"name": "باب اسفنجی", "url": "https://huggingface.co/datasets/Hamed744/Ezmary/resolve/main/Bab_Asfanj300.zip?download=true", "gender": "male"}
-}
-
-STANDARD_MODELS = {
-    "9": {"name": "علی سورنا", "ref": "https://huggingface.co/datasets/Hamed744/mp3/resolve/main/%D9%85%D8%AF%D9%84%20%D8%B5%D8%AF%D8%A7%DB%8C%20%D8%B3%D9%88%D8%B1%D9%86%D8%A7.mp3?download=true"},
-    "10": {"name": "رونالدو", "ref": "https://huggingface.co/datasets/Hamed744/mp3/resolve/main/%D8%B1%D9%88%D9%86%D8%A7%D9%84%D8%AF%D9%88.wav?download=true"},
-    "11": {"name": "مسی", "ref": "https://huggingface.co/datasets/Hamed744/mp3/resolve/main/%D8%B5%D8%AF%D8%A7%DB%8C-%D9%85%D8%B3%DB%8C.mp3?download=true"},
-    "12": {"name": "مریم", "ref": "https://huggingface.co/datasets/Hamed744/mp3/resolve/main/%D8%B5%D8%AF%D8%A7%DB%8C%20%D8%AE%D8%A7%D9%86%D9%85.wav?download=true"}
-}
-
-# ==============================================================================
-# 🟢 پارت 3: متغیرهای ادمین، سیستم ضد اسپم و توابع تبدیل تاریخ
-# ==============================================================================
-# --- کد مدیریت ---
-ADMIN_CODE = "3011"
-BOT_GUID = None
-
-# =======================================================
-# سیستم ضد اسپم کاربر-محور
-# =======================================================
-user_message_times = {}
-
-def is_user_spamming(chat_id):
-    now = time.time()
-    times = user_message_times.get(chat_id,[])
-    times =[t for t in times if now - t < 3.0]
-    times.append(now)
-    user_message_times[chat_id] = times
-    if len(times) > 4:
-        return True
-    return False
-
-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
-    days = 355666 + (365 * gy) + ((gy2 + 3) // 4) - ((gy2 + 99) // 100) + ((gy2 + 399) // 400) + gd + g_d_m[gm - 1]
-    jy = -1595 + (33 * (days // 12053))
-    days %= 12053
-    jy += 4 * (days // 1461)
-    days %= 1461
-    if days > 365:
-        jy += (days - 1) // 365
-        days = (days - 1) % 365
-    if days < 186:
-        jm = 1 + (days // 31)
-        jd = 1 + (days % 31)
-    else:
-        jm = 7 + ((days - 186) // 30)
-        jd = 1 + ((days - 186) % 30)
-    return jy, jm, jd
-
-# ==============================================================================
-# 🟢 پارت 4: دیتابیس SQLite (نسخه نجات همه‌جانبه: اعتبارها + پیام‌های قدیمی)
-# ==============================================================================
-import os
-import sqlite3
-import json
-import copy
-
-# استفاده از نام جدید v3 برای شروع کاملاً پاک و بدون قفل
-DB_FILE = "/data/users_v3.db" 
-CORRUPT_FILE = "/data/users_db.db" # فایل ۱۱.۷ مگابایتی شما
-BACKUP_JSON = "/data/users_db.json.bak" # فایل ۴.۷ مگابایتی اعتبارها
-
-last_saved_state = {}
-
-def init_sqlite_db():
-    try:
-        os.makedirs(os.path.dirname(DB_FILE), exist_ok=True)
-        
-        # اگر فایل v3 وجود ندارد، یعنی بار اول است و باید نجات را شروع کنیم
-        is_first_run = not os.path.exists(DB_FILE)
-
-        conn = sqlite3.connect(DB_FILE, timeout=60.0)
-        cursor = conn.cursor()
-        cursor.execute('PRAGMA journal_mode=DELETE;') # امن‌ترین حالت برای شبکه
-        cursor.execute('CREATE TABLE IF NOT EXISTS users (chat_id TEXT PRIMARY KEY, user_data TEXT)')
-        cursor.execute('CREATE TABLE IF NOT EXISTS processed_messages (message_id TEXT PRIMARY KEY)')
-        conn.commit()
-        conn.close()
-
-        if is_first_run:
-            print("🚨 عملیات نجات آغاز شد...")
-            # ۱. بازیابی اعتبارها از JSON (۱۰۰ درصد مطمئن)
-            restore_users_from_json()
-            # ۲. نجات شناسه‌های پیام از فایل ۱۱.۷ مگابایتی (تا جایی که راه بدهد)
-            salvage_messages_from_corrupt_db()
-
-    except Exception as e:
-        print(f"❌ خطا در راه اندازی دیتابیس: {e}")
-
-def restore_users_from_json():
-    if os.path.exists(BACKUP_JSON):
-        print("📥 در حال بازیابی اعتبار کاربران از فایل پشتیبان...")
-        try:
-            with open(BACKUP_JSON, "r", encoding="utf-8") as f:
-                data = json.load(f)
-            if data:
-                conn = sqlite3.connect(DB_FILE, timeout=60.0)
-                for cid, udata in data.items():
-                    conn.execute("INSERT OR REPLACE INTO users VALUES (?, ?)", (str(cid), json.dumps(udata)))
-                conn.commit()
-                conn.close()
-                print(f"✅ اعتبار {len(data)} کاربر با موفقیت بازیابی شد.")
-        except Exception as e:
-            print(f"❌ خطا در بازیابی اعتبارها: {e}")
-
-def salvage_messages_from_corrupt_db():
-    if os.path.exists(CORRUPT_FILE):
-        print(f"🔍 در حال تلاش برای نجات شناسه‌های پیام از فایل {CORRUPT_FILE} ...")
-        try:
-            # وصل کردن فایل خراب به دیتابیس جدید
-            conn = sqlite3.connect(DB_FILE, timeout=60.0)
-            conn.execute(f"ATTACH DATABASE '{CORRUPT_FILE}' AS old_db")
-            
-            # کپی کردن شناسه‌ها (با استفاده از INSERT OR IGNORE که اگر خراب بود رد شود)
-            # این دستور تلاش می‌کند حتی اگر فایل Malformed باشد، ردیف‌های سالم را بردارد
-            conn.execute("INSERT OR IGNORE INTO processed_messages SELECT message_id FROM old_db.processed_messages")
-            
-            conn.commit()
-            conn.close()
-            print("✅ شناسه‌های پیام قدیمی با موفقیت نجات یافتند و به دیتابیس جدید منتقل شدند.")
-        except Exception as e:
-            print(f"⚠️ هشدار: برخی پیام‌ها به دلیل خرابی شدید فایل اصلی قابل نجات نبودند، اما نگران نباشید، ربات دوباره آن‌ها را شناسایی می‌کند. ارور: {e}")
-
-def load_db():
-    global last_saved_state
-    init_sqlite_db()
-    db_dict = {}
-    try:
-        conn = sqlite3.connect(DB_FILE, timeout=60.0)
-        cursor = conn.cursor()
-        cursor.execute("SELECT chat_id, user_data FROM users")
-        for row in cursor.fetchall():
-            db_dict[row[0]] = json.loads(row[1])
-        conn.close()
-        last_saved_state = copy.deepcopy(db_dict)
-        print(f"🚀 دیتابیس نهایی آماده شد. تعداد کاربران: {len(db_dict)}")
-        return db_dict
-    except Exception as e:
-        print(f"⚠️ ارور در لود نهایی: {e}")
-        return {}
-
-def save_db(db_data):
-    global last_saved_state
-    try:
-        changed = []
-        for cid, data in db_data.items():
-            if cid not in last_saved_state or last_saved_state[cid] != data:
-                changed.append((str(cid), json.dumps(data, ensure_ascii=False)))
-        if not changed: return
-        conn = sqlite3.connect(DB_FILE, timeout=60.0)
-        conn.execute('PRAGMA journal_mode=DELETE;')
-        conn.executemany("INSERT OR REPLACE INTO users (chat_id, user_data) VALUES (?, ?)", changed)
-        conn.commit()
-        conn.close()
-        for cid, _ in changed:
-            last_saved_state[cid] = copy.deepcopy(db_data[cid])
-    except Exception as e:
-        print(f"❌ خطا در ذخیره: {e}")
-
-def is_message_processed(message_id):
-    try:
-        conn = sqlite3.connect(DB_FILE, timeout=30.0)
-        res = conn.execute("SELECT 1 FROM processed_messages WHERE message_id = ?", (str(message_id),)).fetchone()
-        conn.close()
-        return res is not None
-    except: return False
-
-def mark_message_processed(message_id):
-    try:
-        conn = sqlite3.connect(DB_FILE, timeout=30.0)
-        conn.execute("INSERT OR IGNORE INTO processed_messages VALUES (?)", (str(message_id),))
-        conn.commit()
-        conn.close()
-    except: pass
-
-user_credits_db = load_db()
-
-
-# ==============================================================================
-# 🟢 پارت 5: توابع کد معرف، مدیریت سهمیه حساب کاربری و تبدیل اعداد
-# ==============================================================================
-def get_or_create_referral_code(chat_id):
-    user_data = user_credits_db[chat_id]
-    if not user_data.get("referral_code"):
-        while True:
-            new_code = ''.join(random.choices(string.digits, k=8))
-            exists = any(isinstance(u, dict) and u.get("referral_code") == new_code for u in user_credits_db.values())
-            if not exists:
-                user_data["referral_code"] = new_code
-                save_db(user_credits_db)
-                break
-    return user_data["referral_code"]
-
-def find_user_by_referral_code(code):
-    code = code.strip()
-    for uid, data in user_credits_db.items():
-        if isinstance(data, dict) and data.get("referral_code", "") == code:
-            return uid
-    return None
-
-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 or not isinstance(user_credits_db[str_chat_id], dict):
-        user_credits_db[str_chat_id] = {
-            "is_premium": False,
-            "expire_date": None,
-            "last_reset": "",
-            "chat": 10,
-            "image": 5,
-            "edit_image": 1,
-            "podcast": 2,
-            "tts": 5,
-            "file": 1,
-            "stt": 5,
-            "voice_conv": 3,
-            "voice_clone": 1,
-            "last_msg_id": 0,
-            "has_joined": False,
-            "invited_count": 0,
-            "used_referral": False,
-            "referral_code": ""
-        }
-        save_db(user_credits_db)
-        
-    user_data = user_credits_db[str_chat_id]
-    
-    if "voice_conv" not in user_data: user_data["voice_conv"] = 3
-    if "voice_clone" not in user_data: user_data["voice_clone"] = 1
-    if "last_msg_id" not in user_data: user_data["last_msg_id"] = 0
-
-    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
-            user_data["podcast"] = 2
-            user_data["tts"] = 5
-            user_data["file"] = 1
-            user_data["stt"] = 5
-            user_data["voice_conv"] = 3
-            user_data["voice_clone"] = 1
-            save_db(user_credits_db)
-            
-    return user_data
-
-def to_english_digits(text):
-    if not text: return text
-    persian_digits = '۰۱۲۳۴۵۶۷۸۹'
-    arabic_digits = '٠١٢٣٤٥٦٧٨٩'
-    english_digits = '0123456789'
-    translation_table = str.maketrans(persian_digits + arabic_digits, english_digits * 2)
-    return str(text).translate(translation_table)
-
-# ==============================================================================
-# 🟢 پارت 6: تنظیمات وب‌سرور (Flask) و توابع کمکی فایل‌ها
-# ==============================================================================
-# --- تنظیمات وب سرور ---
-app = Flask(__name__)
-
-@app.route('/')
-def home():
-    return "ربات یکپارچه آلفا (نسخه پرو + مدیریت اشتراک نامحدود + دعوت دوستان + سیستم تغییر صدا) روشن است! 🚀"
-
-def run_flask():
-    app.run(host="0.0.0.0", port=7860, threaded=True)
-
-# --- توابع کمکی ---
-def sync_save_image(image, file_name):
-    rgb_im = image.convert('RGB')
-    rgb_im.save(file_name, format="JPEG", quality=100)
-
-def sync_write_file(file_name, data):
-    with open(file_name, "wb") as f:
-        f.write(data)
-
-def sync_read_file(file_name):
-    with open(file_name, 'rb') as f:
-        return f.read()
-
-def sync_combine_audio(current_audio, new_bytes):
-    audio_segment = AudioSegment.from_file(io.BytesIO(new_bytes))
-    return current_audio + audio_segment
-
-def sync_export_audio(audio_obj, file_name):
-    audio_obj.export(file_name, format="mp3")
-
-# ==============================================================================
-# 🟢 پارت 7: کیبوردها (دکمه‌های شیشه‌ای / منوها)
-# ==============================================================================
-# --- ساختار کیبورد ---
-MAIN_KEYPAD_DICT = {
-    "rows":[
-        {
-            "buttons":[
-                {"id": "chat_btn", "type": "Simple", "button_text": "چت با هوش مصنوعی 🤖"}
-            ]
-        },
-        {
-            "buttons":[
-                {"id": "img_btn", "type": "Simple", "button_text": "ساخت تصاویر🎨"},
-                {"id": "edit_img_btn", "type": "Simple", "button_text": "ویرایش تصاویر 🪄"}
-            ]
-        },
-        {
-            "buttons":[
-                {"id": "podcast_btn", "type": "Simple", "button_text": "ساخت پادکست 🎙️"},
-                {"id": "tts_btn", "type": "Simple", "button_text": "تبدیل متن به صدا🗣️"}
-            ]
-        },
-        {
-            "buttons":[
-                {"id": "vc_btn", "type": "Simple", "button_text": "تغییر صدا 🎙️"},
-                {"id": "clone_btn", "type": "Simple", "button_text": "کلون کردن صدا 👤"}
-            ]
-        },
-        {
-            "buttons":[
-                {"id": "stt_btn", "type": "Simple", "button_text": "فایل صوتی به متن 📝"},
-                {"id": "file_btn", "type": "Simple", "button_text": "تحلیل فایل 📁"}
-            ]
-        },
-        {
-            "buttons":[
-                {"id": "create_file_btn", "type": "Simple", "button_text": "ساخت فایل 📄"}
-            ]
-        },
-        {
-            "buttons":[
-                {"id": "account_btn", "type": "Simple", "button_text": "حساب کاربری 👤"},
-                {"id": "buy_btn", "type": "Simple", "button_text": "خرید اشتراک 💎"}
-            ]
-        },
-        {
-            "buttons":[
-                {"id": "invite_btn", "type": "Simple", "button_text": "دعوت دوستان 🎁"},
-                {"id": "referral_btn", "type": "Simple", "button_text": "ثبت کد هدیه 🎫"}
-            ]
-        },
-        {
-            "buttons":[
-                {"id": "transfer_btn", "type": "Simple", "button_text": "انتقال اکانت از برنامه به ربات"}
-            ]
-        },
-        {
-            "buttons":[
-                {"id": "cancel_btn", "type": "Simple", "button_text": "برگشت♻️"}
-            ]
-        }
-    ],
-    "resize_keyboard": True
-}
-
-CHANNEL_USERNAME = "aialpha"
-CHANNEL_GUID = None
-
-JOIN_KEYPAD_DICT = {
-    "rows":[
-        {
-            "buttons":[
-                {"id": "check_join_btn", "type": "Simple", "button_text": "✅ عضو شدم"}
-            ]
-        }
-    ],
-    "resize_keyboard": True
-}
-
-# ==============================================================================
-# 🟢 پارت 8: تابع بررسی عضویت کانال، ارسال کیبورد و توکن روبیکا
-# ==============================================================================
-async def check_channel_membership(client, user_id):
-    global CHANNEL_GUID
-    if str(user_id) == str(BOT_GUID): return True
-    
-    try:
-        if not CHANNEL_GUID:
-            res = await client.get_object_by_username(CHANNEL_USERNAME)
-            if isinstance(res, dict):
-                if 'channel' in res and 'channel_guid' in res['channel']:
-                    CHANNEL_GUID = res['channel']['channel_guid']
-                elif 'data' in res and 'channel' in res['data']:
-                    CHANNEL_GUID = res['data']['channel']['channel_guid']
-                elif 'exist' in res and 'chat' in res['exist']:
-                    CHANNEL_GUID = res['exist']['chat']['object_guid']
-            else:
-                if hasattr(res, 'channel'):
-                    CHANNEL_GUID = getattr(res.channel, 'channel_guid', None)
-                elif hasattr(res, 'data') and hasattr(res.data, 'channel'):
-                    CHANNEL_GUID = getattr(res.data.channel, 'channel_guid', None)
-                elif hasattr(res, 'exist') and hasattr(res.exist, 'chat'):
-                    CHANNEL_GUID = getattr(res.exist.chat, 'object_guid', None)
-
-        if not CHANNEL_GUID: return True
-
-        payload = {"channel_guid": CHANNEL_GUID, "member_guid": user_id}
-        res = await client._make_request("getChannelParticipant", payload)
-        
-        if isinstance(res, dict) and res.get("status") == "OK":
-            data = res.get("data", {})
-            if data and "participant" in data: return True
-        elif hasattr(res, 'status') and getattr(res, 'status') == "OK":
-            return True
-        return False
-    except Exception: return False
-
-async def send_with_keyboard(client, chat_id, text, use_keyboard=True):
-    try:
-        if not use_keyboard: return await client.send_message(chat_id, text)
-        payload = {"chat_id": chat_id, "text": text, "chat_keypad_type": "New", "chat_keypad": MAIN_KEYPAD_DICT}
-        return await client._make_request("sendMessage", payload)
-    except Exception:
-        try: return await client.send_message(chat_id, text)
-        except Exception: return None
-
-bot_token = os.environ.get("RUBIKA_AUTH", "").strip()
-
-# ==============================================================================
-# 🟢 پارت 9: دانلودر قدرتمند و تابع ضد قطعی روبیکا
-# ==============================================================================
-# ==================================================================
-# تابع دانلود ضد بمب اتم (پافشاری ۳۵ بار)
-# ==================================================================
-async def helper_download_file(client, msg_obj):
-    errors =[]
-    file_obj = None
-    file_id = None
-    
-    for attr in['file', 'file_inline', 'photo', 'voice', 'audio', 'document', 'video']:
-        val = getattr(msg_obj, attr, None)
-        if val:
-            file_obj = val
-            if hasattr(val, 'file_id'): file_id = val.file_id
-            elif isinstance(val, dict) and 'file_id' in val: file_id = val['file_id']
-            break
-            
-    if not file_obj and hasattr(msg_obj, "file_id"):
-        file_id = msg_obj.file_id
-        file_obj = msg_obj
-
-    if not file_id: raise Exception("خطا: هیچ فایلی در پیام یافت نشد.")
-
-    temp_name = f"temp_dl_{uuid.uuid4().hex}.tmp"
-
-    for attempt in range(20):
-        try:
-            url_get_file = f"https://botapi.rubika.ir/v3/{bot_token}/getFile"
-            payload = {"file_id": str(file_id)}
-            headers = {"User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64)"}
-            
-            async with aiohttp.ClientSession() as session:
-                async with session.post(url_get_file, json=payload, headers=headers, timeout=30) as resp:
-                    if resp.status == 200:
-                        res_data = await resp.json()
-                        if res_data.get("status") == "OK" or res_data.get("status_det") == "OK":
-                            download_url = res_data.get("data", {}).get("download_url") or res_data.get("data", {}).get("file_url")
-                            if download_url:
-                                for dl_attempt in range(3):
-                                    try:
-                                        async with session.get(download_url, headers=headers, timeout=60) as dl_resp:
-                                            if dl_resp.status == 200:
-                                                data = await dl_resp.read()
-                                                if data and len(data) > 0: return data
-                                            else: errors.append(f"DL HTTP {dl_resp.status}")
-                                            await asyncio.sleep(2)
-                                    except Exception as dl_err:
-                                        errors.append(f"DL Error: {str(dl_err)[:30]}")
-                                        await asyncio.sleep(2)
-                            else: errors.append("No download URL in response.")
-                        else: errors.append(f"API Not OK: {res_data.get('status')}")
-                    elif resp.status in [502, 503, 500]:
-                        errors.append(f"GetFile HTTP {resp.status}")
-                        await asyncio.sleep(3.5)
-                        continue
-                    else:
-                        errors.append(f"GetFile HTTP {resp.status}")
-                        await asyncio.sleep(2)
-        except Exception as e:
-            errors.append(f"API Error: {str(e)[:50]}")
-            await asyncio.sleep(2)
-
-    if file_obj:
-        for attempt in range(10):
-            try:
-                if hasattr(client, "download"):
-                    result = await client.download(file_obj, save_as=temp_name)
-                    if isinstance(result, bytes) and len(result) > 0: return result
-                    if os.path.exists(temp_name):
-                        data = await asyncio.to_thread(sync_read_file, temp_name)
-                        os.remove(temp_name)
-                        if data and len(data) > 0: return data
-            except Exception as e:
-                errors.append(f"Rubpy Obj Error: {str(e)[:50]}")
-                await asyncio.sleep(3)
-
-    for attempt in range(5):
-        try:
-            if hasattr(client, "download_file"):
-                await client.download_file(file_id, file_name=temp_name)
-                if os.path.exists(temp_name):
-                    data = await asyncio.to_thread(sync_read_file, temp_name)
-                    os.remove(temp_name)
-                    if data and len(data) > 0: return data
-        except Exception as e:
-            errors.append(f"Rubpy FileId Error: {str(e)[:50]}")
-            await asyncio.sleep(3)
-            
-    raise Exception(f"سرورهای دانلود روبیکا پس از ۳۵ بار تلاش پاسخ ندادند!\nلاگ خطاها: {str(errors[-5:])}")
-
-async def helper_download_url_to_bytes(url):
-    async with aiohttp.ClientSession() as session:
-        for _ in range(3):
-            try:
-                async with session.get(url, timeout=30) as resp:
-                    if resp.status == 200:
-                        return await resp.read()
-            except Exception:
-                await asyncio.sleep(2)
-    return None
-
-# ==============================================================================
-# 🟢 پارت 10: سیستم چرخش کلیدهای جیمینای و تنظیم توکن‌های هاگینگ فیس
-# ==============================================================================
-# ==================================================================
-# توکن‌ها و کلیدها
-# ==================================================================
-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(","))
-
-GEMINI_KEYS = list(set([k.strip() for k in _raw_keys if k.strip()]))
-print(f"✅ تعداد {len(GEMINI_KEYS)} کلید جیمینای با موفقیت شناسایی شد.")
-
-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[]
-        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()]
-
-# ==============================================================================
-# 🟢 پارت 11: آپلودر قدرتمند و تابع ارسال فایل ضد خطا (نسخه نهایی ضد بمب اتم 🚀)
-# ==============================================================================
-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_type
-    
-    # روبیکا فرمت‌های خاصی را قبول می‌کند.
-    if api_file_type == "Voice" and not abs_path.lower().endswith('.ogg'): 
-        api_file_type = "Music"
-    if api_file_type == "File" and abs_path.lower().endswith('.mp3'): 
-        api_file_type = "Music"
-        
-    # --- فاز اول (فوق سریع): استفاده از متدهای اختصاصی rubpy ---
-    for attempt in range(10):
-        try:
-            sent_success = False
-            
-            # تلاش برای ارسال عکس
-            if api_file_type == "Image" and hasattr(client, "send_photo"):
-                try:
-                    await client.send_photo(chat_id, photo=abs_path, caption=caption)
-                    sent_success = True
-                except TypeError:
-                    await client.send_photo(chat_id, abs_path, caption=caption)
-                    sent_success = True
-                    
-            # تلاش برای ارسال ویس
-            elif api_file_type == "Voice" and hasattr(client, "send_voice"):
-                try:
-                    await client.send_voice(chat_id, abs_path, caption=caption)
-                    sent_success = True
-                except TypeError:
-                    await client.send_voice(chat_id, file=abs_path, caption=caption)
-                    sent_success = True
-                    
-            # تلاش برای ارسال موزیک
-            elif api_file_type == "Music" and hasattr(client, "send_music"):
-                try:
-                    await client.send_music(chat_id, abs_path, caption=caption)
-                    sent_success = True
-                except TypeError:
-                    await client.send_music(chat_id, music=abs_path, caption=caption)
-                    sent_success = True
-
-            # *** سیستم ضد بمب اتم فاز 1 ***
-            # اگر هیچکدام از متدهای بالا وجود نداشت یا به هر دلیلی ارسال نشد، حتما به عنوان فایل (سند) بفرست تا معطل نشود
-            if not sent_success:
-                if hasattr(client, "send_document"):
-                    try:
-                        await client.send_document(chat_id, document=abs_path, caption=caption)
-                        sent_success = True
-                    except TypeError:
-                        await client.send_document(chat_id, abs_path, caption=caption)
-                        sent_success = True
-                elif hasattr(client, "send_file"):
-                    try:
-                        await client.send_file(chat_id, file=abs_path)
-                    except TypeError:
-                        await client.send_file(chat_id, abs_path)
-                    if caption:
-                        await send_with_keyboard(client, chat_id, caption, True)
-                    sent_success = True
-
-            if sent_success:
-                return True
-                    
-        except Exception as e:
-            err_msg = str(e)[:150]
-            error_logs.append(f"Rubpy Send Error: {err_msg}")
-            
-            if "502" in err_msg or "timeout" in err_msg.lower() or "time" in err_msg.lower(): 
-                await asyncio.sleep(4)
-            else: 
-                await asyncio.sleep(2)
-
-    # --- فاز دوم (سنگر آخر): آپلود دستی (Raw HTTP) در صورت مسدودی کامل روب‌پای ---
-    for attempt in range(15):
-        try:
-            url_request = f"https://botapi.rubika.ir/v3/{bot_token}/requestSendFile"
-            url_send = f"https://botapi.rubika.ir/v3/{bot_token}/sendFile"
-            
-            async with aiohttp.ClientSession() as session:
-                async with session.post(url_request, json={"type": api_file_type}, timeout=30) as resp:
-                    if resp.status != 200:
-                        error_logs.append(f"Request HTTP {resp.status}")
-                        await asyncio.sleep(2)
-                        continue
-                        
-                    req_data = await resp.json()
-                    if req_data.get("status") == "OK":
-                        upload_url = req_data.get("data", {}).get("upload_url")
-                        if upload_url:
-                            with open(abs_path, "rb") as f:
-                                form = aiohttp.FormData()
-                                form.add_field('file', f, filename=os.path.basename(abs_path))
-                                async with session.post(upload_url, data=form, timeout=300) as up_resp:
-                                    if up_resp.status != 200:
-                                        error_logs.append(f"Upload HTTP {up_resp.status}")
-                                        if up_resp.status in[502, 503, 500]: 
-                                            await asyncio.sleep(3) 
-                                        else: 
-                                            await asyncio.sleep(1.5)
-                                        continue
-                                        
-                                    try: 
-                                        up_data = await up_resp.json()
-                                    except Exception as json_err:
-                                        error_logs.append(f"JSON Decode Error: {json_err}")
-                                        await asyncio.sleep(2)
-                                        continue
-                                    
-                                    final_file_id = None
-                                    
-                                    # *** سیستم ضد بمب اتم فاز 2 ***
-                                    # دور زدن ارور روبیکا: اگر روبیکا به فرمت فایل گیر داد، سریعاً نوع را به File تغییر بده تا بدون بررسی فرمت آپلود کند!
-                                    if up_data.get("status") == "INVALID_INPUT" and "format" in str(up_data).lower():
-                                        api_file_type = "File"
-                                        error_logs.append(f"Format Blocked! Downgrading type to File.")
-                                        await asyncio.sleep(1)
-                                        continue
-
-                                    if up_data.get("status") == "OK" or up_data.get("status_det") == "OK":
-                                        if "data" in up_data and isinstance(up_data["data"], dict):
-                                            final_file_id = up_data["data"].get("file_id") or up_data["data"].get("id")
-                                        elif "file_id" in up_data: 
-                                            final_file_id = up_data.get("file_id")
-                                            
-                                    if final_file_id:
-                                        send_payload = {
-                                            "chat_id": str(chat_id),
-                                            "file_id": str(final_file_id),
-                                            "text": caption,
-                                            "chat_keypad_type": "New",
-                                            "chat_keypad": MAIN_KEYPAD_DICT
-                                        }
-                                        async with session.post(url_send, json=send_payload, timeout=30) as send_resp:
-                                            if send_resp.status != 200:
-                                                error_logs.append(f"Send HTTP {send_resp.status}")
-                                                await asyncio.sleep(2)
-                                                continue
-                                                
-                                            s_data = await send_resp.json()
-                                            if s_data.get("status") == "OK": return True
-                                            else: error_logs.append(f"SendFile API Error: {s_data}")
-                                    else:
-                                        if up_data.get("status") == "INVALID_INPUT" and api_file_type in ["Voice", "Music"]:
-                                            api_file_type = "File" # دور زدن گیر دادن روبیکا
-                                        error_logs.append(f"Upload API Error: {up_data}")
-                        else: error_logs.append(f"Missing upload_url in Response: {req_data}")
-                    else: error_logs.append(f"Request API Error: {req_data}")
-        except Exception as e:
-            error_logs.append(f"Raw HTTP Error: {str(e)[:100]}")
-            await asyncio.sleep(2.5)
-
-    return "\n".join(error_logs[-6:])
-
-# ==============================================================================
-# 🟢 پارت 12: توابع تغییر صدا و لیست گویندگان
-# ==============================================================================
-# ==================================================================
-# لیست‌های اولیه ربات
-# ==================================================================
-WORKER_URLS =["https://opera8-ttspro.hf.space/generate"]
-
-SPEAKERS = {
-    "1": ("شهاب (مرد)", "Charon"), "2": ("آوا (زن)", "Zephyr"), "3": ("نوید (مرد)", "Achird"), 
-    "4": ("آرمان (مرد)", "Zubenelgenubi"), "5": ("مهسا (زن)", "Vindemiatrix"), "6": ("دانا (مرد)", "Rasalgethi"),
-    "7": ("سامان (مرد)", "Sadachbia"), "8": ("آرش (مرد)", "Sadaltager"), "9": ("شبنم (زن)", "Sulafat"),
-    "10": ("سحر (زن)", "Laomedeia"), "11": ("مریم (زن)", "Achernar"), "12": ("بهرام (مرد)", "Alnilam"),
-    "13": ("نیکان (مرد)", "Schedar"), "14": ("فرناز (زن)", "Gacrux"), "15": ("سارا (زن)", "Pulcherrima"),
-    "16": ("مانی (مرد)", "Umbriel"), "17": ("آرتین (مرد)", "Algieba"), "18": ("دلنواز (زن)", "Despina"),
-    "19": ("روژان (زن)", "Erinome"), "20": ("امید (مرد)", "Algenib"), "21": ("بردیا (مرد)", "Orus"),
-    "22": ("ترانه (زن)", "Aoede"), "23": ("نیکو (زن)", "Callirrhoe"), "24": ("هستی (زن)", "Autonoe"),
-    "25": ("کامیار (مرد)", "Enceladus"), "26": ("کیانوش (مرد)", "Iapetus"), "27": ("پویا (مرد)", "Puck"),
-    "28": ("مهتاب (زن)", "Kore"), "29": ("سام (مرد)", "Fenrir"), "30": ("لیدا (زن)", "Leda")
-}
-
-user_states = {}
-
-# ==================================================================
-# توابع تغییر صدا و کلون کردن
-# ==================================================================
-async def process_standard_vc_job(client, chat_id, src_bytes, ref_bytes, job_type_name, credit_type):
-    str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
-    creds = get_user_credits(str_chat_id)
-    
-    proc_msg = await send_with_keyboard(client, chat_id, f"⏳ در حال آماده‌سازی فایل‌ها...\n(مدل: {job_type_name})", False)
-    
-    async with aiohttp.ClientSession() as session:
-        form = aiohttp.FormData()
-        form.add_field('source_audio', src_bytes, filename='src.wav', content_type='audio/wav')
-        form.add_field('ref_audio', ref_bytes, filename='ref.wav', content_type='audio/wav')
-        
-        try:
-            async with session.post(f"{VC_BASE_URL}/upload", data=form, timeout=43200) as resp:
-                if resp.status != 200:
-                    return await send_with_keyboard(client, chat_id, f"❌ خطا در ارسال فایل‌ها (کد {resp.status})", True)
-                data = await resp.json()
-                job_id = data.get("job_id")
-                total_chunks = data.get("total_chunks", 1)
-                chunks = data.get("chunks",[])
-        except Exception as e:
-            return await send_with_keyboard(client, chat_id, f"❌ خطا در اتصال به سرور:\n{str(e)[:100]}", True)
-
-        await send_with_keyboard(client, chat_id, "✅ فایل‌ها ارسال شد. در حال پردازش و تغییر صدا...\n(لطفا چند دقیقه صبور باشید)", False)
-        
-        final_filename = None
-        for _ in range(10000):
-            await asyncio.sleep(4)
-            payload_check = {"job_id": job_id, "total_chunks": total_chunks, "chunks": chunks}
-            try:
-                async with session.post(f"{VC_BASE_URL}/check_status", json=payload_check, timeout=20) as c_resp:
-                    if c_resp.status == 200:
-                        c_data = await c_resp.json()
-                        if c_data.get("status") == "completed":
-                            final_filename = c_data.get("filename")
-                            break
-                        elif c_data.get("status") in ["failed", "error"]:
-                            return await send_with_keyboard(client, chat_id, "❌ خطای سرور در حین پردازش صدا.", True)
-            except Exception:
-                pass
-                
-        if not final_filename:
-            return await send_with_keyboard(client, chat_id, "❌ پردازش بیش از حد طول کشید و متوقف شد.", True)
-
-        download_url = f"{VC_BASE_URL}/download/{final_filename}"
-        await send_with_keyboard(client, chat_id, "📥 پردازش تمام شد! در حال دانلود نتیجه...", False)
-        try:
-            async with session.get(download_url, timeout=43200) as d_resp:
-                if d_resp.status == 200:
-                    result_bytes = await d_resp.read()
-                else:
-                    return await send_with_keyboard(client, chat_id, "❌ خطا در دریافت فایل نهایی از سرور.", True)
-        except Exception:
-            return await send_with_keyboard(client, chat_id, "❌ خطا در اتصال هنگام دانلود خروجی.", True)
-
-    file_name_mp3 = f"vc_standard_{uuid.uuid4().hex[:6]}.mp3"
-    await asyncio.to_thread(sync_write_file, file_name_mp3, result_bytes)
-    
-    upload_result = False
-    for up_att in range(3):
-        res = await helper_upload_file(client, chat_id, file_name_mp3, "Music", f"🎙️ {job_type_name} شما آماده است!")
-        if res is True:
-            upload_result = True
-            break
-        await asyncio.sleep(4)
-
-    if upload_result is True:
-        if not creds.get("is_premium"):
-            user_credits_db[str_chat_id][credit_type] -= 1
-            save_db(user_credits_db)
-    else:
-        await send_with_keyboard(client, chat_id, "❌ فایل پردازش شد اما امکان ارسال در روبیکا فراهم نشد.", True)
-        
-    if os.path.exists(file_name_mp3): os.remove(file_name_mp3)
-
-async def process_legacy_vc_job(client, chat_id, src_bytes, model_url, pitch, model_name):
-    str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
-    creds = get_user_credits(str_chat_id)
-    
-    proc_msg = await send_with_keyboard(client, chat_id, f"⏳ در حال آماده‌سازی فایل‌ها...\n(مدل: {model_name})", False)
-    
-    async with aiohttp.ClientSession() as session:
-        form = aiohttp.FormData()
-        form.add_field('audio_file', src_bytes, filename='input.wav', content_type='audio/wav')
-        form.add_field('model_url', model_url)
-        form.add_field('pitch', str(pitch))
-        form.add_field('algo', 'rmvpe+')
-        form.add_field('index_inf', '0.75')
-        form.add_field('res_filter', '3')
-        form.add_field('env_ratio', '0.25')
-        form.add_field('protect', '0.33')
-        form.add_field('denoise', 'false')
-        form.add_field('reverb', 'false')
-        
-        try:
-            async with session.post(f"{LEGACY_BASE_URL}/upload", data=form, timeout=43200) as resp:
-                if resp.status != 200:
-                    return await send_with_keyboard(client, chat_id, f"❌ خطا در ارسال فایل‌ها (کد {resp.status})", True)
-                data = await resp.json()
-                job_id = data.get("job_id")
-        except Exception as e:
-            return await send_with_keyboard(client, chat_id, f"❌ خطا در اتصال به سرور:\n{str(e)[:100]}", True)
-
-        await send_with_keyboard(client, chat_id, "✅ فایل ارسال شد. در حال پردازش و تغییر صدای شما...\n(لطفا چند دقیقه صبور باشید)", False)
-        
-        final_filename = None
-        for _ in range(10000):
-            await asyncio.sleep(5)
-            try:
-                async with session.get(f"{LEGACY_BASE_URL}/status/{job_id}", timeout=20) as c_resp:
-                    if c_resp.status == 200:
-                        c_data = await c_resp.json()
-                        if c_data.get("status") == "completed":
-                            final_filename = c_data.get("filename")
-                            break
-                        elif c_data.get("status") in["failed", "error", "not_found"]:
-                            return await send_with_keyboard(client, chat_id, "❌ خطای سرور در حین پردازش.", True)
-            except Exception:
-                pass
-                
-        if not final_filename:
-            return await send_with_keyboard(client, chat_id, "❌ پردازش بیش از حد طول کشید و متوقف شد.", True)
-
-        download_url = f"{LEGACY_BASE_URL}/download/{final_filename}"
-        await send_with_keyboard(client, chat_id, "📥 پردازش تمام شد! در حال دانلود نتیجه...", False)
-        try:
-            async with session.get(download_url, timeout=43200) as d_resp:
-                if d_resp.status == 200:
-                    result_bytes = await d_resp.read()
-                else:
-                    return await send_with_keyboard(client, chat_id, "❌ خطا در دریافت فایل نهایی از سرور.", True)
-        except Exception:
-            return await send_with_keyboard(client, chat_id, "❌ خطا در اتصال هنگام دانلود خروجی.", True)
-
-    file_name_mp3 = f"vc_legacy_{uuid.uuid4().hex[:6]}.mp3"
-    await asyncio.to_thread(sync_write_file, file_name_mp3, result_bytes)
-    
-    upload_result = False
-    for up_att in range(3):
-        res = await helper_upload_file(client, chat_id, file_name_mp3, "Music", f"🎙️ صدای خروجی با مدل {model_name} آماده است!")
-        if res is True:
-            upload_result = True
-            break
-        await asyncio.sleep(4)
-
-    if upload_result is True:
-        if not creds.get("is_premium"):
-            user_credits_db[str_chat_id]["voice_conv"] -= 1
-            save_db(user_credits_db)
-    else:
-        await send_with_keyboard(client, chat_id, "❌ فایل پردازش شد اما امکان ارسال در روبیکا فراهم نشد.", True)
-        
-    if os.path.exists(file_name_mp3): os.remove(file_name_mp3)
-
-# ==============================================================================
-# 🟢 پارت 13: پردازش هوش مصنوعی متنی و تصویری جیمینای و هاگینگ‌فیس
-# ==============================================================================
-# ==================================================================
-# سایر توابع پردازشی
-# ==================================================================
-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, "❌ کلیدهای API جیمینای تنظیم نشده‌اند.", False)
-    
-    proc_msg = await send_with_keyboard(client, chat_id, "🧠 در حال پردازش...", False)
-    history = user_states[chat_id].get("history",[])
-    new_parts =[]
-    
-    is_image = True
-    has_non_image_file = False
-    
-    if prompt: new_parts.append({"text": prompt})
-    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:
-            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"
-            
-        is_image = mime_type.startswith('image/')
-        if not is_image:
-            has_non_image_file = True
-            
-        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 history[0]["role"] == "model": history = history[1:]
-
-    final_answer = None
-    for attempt in range(3):
-        keys_to_try = get_next_gemini_keys(100)
-        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": history, "generationConfig": {"temperature": 0.7, "maxOutputTokens": 8192}}
-                try:
-                    async with session.post(url, json=payload, timeout=60) as response:
-                        if response.status == 200:
-                            data = await response.json()
-                            try:
-                                final_answer = data["candidates"][0]["content"]["parts"][0]["text"]
-                                break
-                            except (KeyError, IndexError): continue 
-                except Exception: continue
-        if final_answer: break
-        await asyncio.sleep(2)
-
-    if not final_answer:
-        if has_non_image_file:
-            if history and history[-1]["role"] == "user": history.pop()
-            try:
-                if proc_msg:
-                    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
-            await send_with_keyboard(client, chat_id, "❌ متأسفانه سرور اصلی در حال حاضر شلوغ است و در این شرایط **فعلاً تنها امکان تحلیل تصاویر** توسط سرور جایگزین در دسترس است.", False)
-            return
-            
-        if HF_TOKENS:
-            hf_messages =[]
-            for msg in history:
-                role = "assistant" if msg["role"] == "model" else "user"
-                content_parts =[]
-                for part in msg["parts"]:
-                    if "text" in part:
-                        content_parts.append({"type": "text", "text": part["text"]})
-                    elif "inlineData" in part:
-                        mime_t = part["inlineData"]["mimeType"]
-                        b64_d = part["inlineData"]["data"]
-                        if mime_t.startswith('image/'):
-                            content_parts.append({
-                                "type": "image_url",
-                                "image_url": {"url": f"data:{mime_t};base64,{b64_d}"}
-                            })
-                if content_parts:
-                    hf_messages.append({"role": role, "content": content_parts})
-
-            for attempt in range(3):
-                keys_to_try_hf = HF_TOKENS.copy()
-                random.shuffle(keys_to_try_hf)
-                async with aiohttp.ClientSession() as session:
-                    for hf_key in keys_to_try_hf:
-                        url = "https://router.huggingface.co/v1/chat/completions"
-                        headers = {"Authorization": f"Bearer {hf_key}", "Content-Type": "application/json"}
-                        payload = {
-                            "model": "google/gemma-4-31B-it:novita",
-                            "messages": hf_messages,
-                            "max_tokens": 4096
-                        }
-                        try:
-                            async with session.post(url, headers=headers, json=payload, timeout=60) as response:
-                                if response.status == 200:
-                                    data = await response.json()
-                                    final_answer = data["choices"][0]["message"]["content"]
-                                    break
-                        except Exception:
-                            continue
-                if final_answer: break
-                await asyncio.sleep(2)
-
-    try:
-        if proc_msg:
-            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()
-        await send_with_keyboard(client, chat_id, "❌ تمامی سرورها شلوغ هستند. لطفاً بعداً امتحان کنید.", False)
-        return
-
-    history.append({"role": "model", "parts":[{"text": final_answer}]})
-    user_states[chat_id]["history"] = history
-
-    try:
-        max_len = 1000 
-        chunks =[]
-        temp_text = final_answer
-        while len(temp_text) > max_len:
-            split_idx = temp_text.rfind('\n', 0, max_len)
-            if split_idx == -1: split_idx = temp_text.rfind(' ', 0, max_len)
-            if split_idx == -1: split_idx = max_len
-            chunks.append(temp_text[:split_idx])
-            temp_text = temp_text[split_idx:].strip()
-        if temp_text: chunks.append(temp_text)
-        
-        success_sent = False
-        for idx, chunk in enumerate(chunks):
-            if idx != len(chunks) - 1: chunk += "\n\n⏳ *(ادامه در پیام بعدی)...* 👇"
-            try:
-                res = await send_with_keyboard(client, chat_id, chunk, False)
-                if res: success_sent = True
-                await asyncio.sleep(2.5) 
-            except Exception: await asyncio.sleep(2.5)
-            
-        if success_sent and not creds.get("is_premium"):
-            user_credits_db[str_chat_id]["chat"] -= 1
-            save_db(user_credits_db)
-                
-    except Exception:
-        await send_with_keyboard(client, chat_id, "❌ خطایی در ارسال پیام رخ داد.", False)
-
-# ==============================================================================
-# 🟢 پارت 14: ساخت عکس با هوش مصنوعی
-# ==============================================================================
-async def process_image(client, chat_id, prompt, size_choice="1"):
-    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)
-    
-    proc_msg = await send_with_keyboard(client, chat_id, "✨ در حال ترجمه و بهینه‌سازی پرامپت شما...\n(تبدیل به پرامپت حرفه‌ای)", False)
-    enhanced_prompt = 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}"
-    
-    if GEMINI_KEYS:
-        keys_to_try_gemini = get_next_gemini_keys(100)
-        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=payload, timeout=20) as response:
-                        if response.status == 200:
-                            data = await response.json()
-                            enhanced_prompt = data["candidates"][0]["content"]["parts"][0]["text"].strip()
-                            break
-                except Exception: continue
-
-    if enhanced_prompt == prompt and HF_TOKENS:
-        keys_to_try_hf = HF_TOKENS.copy()
-        random.shuffle(keys_to_try_hf)
-        async with aiohttp.ClientSession() as session:
-            for hf_key in keys_to_try_hf:
-                url = "https://router.huggingface.co/v1/chat/completions"
-                headers = {"Authorization": f"Bearer {hf_key}", "Content-Type": "application/json"}
-                payload = {
-                    "model": "google/gemma-4-31B-it:novita",
-                    "messages":[{"role": "user", "content":[{"type": "text", "text": gemini_sys_prompt}]}],
-                    "max_tokens": 1024
-                }
-                try:
-                    async with session.post(url, headers=headers, json=payload, timeout=20) as response:
-                        if response.status == 200:
-                            data = await response.json()
-                            enhanced_prompt = data["choices"][0]["message"]["content"].strip()
-                            break
-                except Exception:
-                    continue
-
-    try:
-        if proc_msg:
-            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
-    
-    w, h = 1024, 1024
-    size_name = "مربع (1:1) ⬛"
-    if size_choice == "2":
-        w, h = 768, 1344
-        size_name = "عمودی (9:16) 📱"
-    elif size_choice == "3":
-        w, h = 1344, 768
-        size_name = "افقی (16:9) 🖥️"
-    elif size_choice == "4":
-        w, h = 1024, 768
-        size_name = "استاندارد (4:3) 📸"
-
-    short_preview = enhanced_prompt[:150] + "..." if len(enhanced_prompt) > 150 else enhanced_prompt
-    proc_msg = await send_with_keyboard(client, chat_id, f"🎨 در حال طراحی عکس...\n\n📏 **ابعاد:** {size_name}\n📝 **پرامپت ساخته شده:**\n`{short_preview}`\n\n(ممکن است چند ثانیه زمان ببرد)", False)
-
-    generated_image = None
-    last_error_log = "هیچ اتصالی برقرار نشد."
-    
-    for attempt in range(5):
-        keys_to_try = HF_TOKENS.copy()
-        random.shuffle(keys_to_try)
-        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",
-                    width=w,
-                    height=h
-                )
-                break 
-            except Exception as e:
-                last_error_log = str(e)
-                continue
-        if generated_image: break
-        await asyncio.sleep(2)
-            
-    try:
-        if proc_msg:
-            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"❌ عکس ساخته نشد.\n\n⚠️ خطا:\n{last_error_log[:200]}", True)
-
-    try:
-        file_name = f"image_{uuid.uuid4().hex}.jpg"
-        await asyncio.to_thread(sync_save_image, generated_image, file_name)
-        await asyncio.sleep(1)
-        caption_text = f"🎨 تصویر شما با پرامپت هوشمند آماده شد!\n\n📏 ابعاد تصویر: {size_name}\n✨ ایده اولیه: {prompt}"
-        
-        upload_result = False
-        error_log_img = ""
-        for up_att in range(3):
-            res = await helper_upload_file(client, chat_id, file_name, "Image", caption_text)
-            if res is True:
-                upload_result = True
-                break
-            else:
-                error_log_img = res
-                await asyncio.sleep(4)
-        
-        if upload_result is True:
-            if not creds.get("is_premium"):
-                user_credits_db[str_chat_id]["image"] -= 1
-                save_db(user_credits_db)
-        else:
-            await send_with_keyboard(client, chat_id, f"❌ عکس ساخته شد اما آپلود در روبیکا با خطا مواجه شد:\n`{str(error_log_img)[:800]}`", True)
-            
-        if os.path.exists(file_name): os.remove(file_name)
-    except Exception as e: 
-        await send_with_keyboard(client, chat_id, f"❌ خطا در ذخیره و ارسال عکس:\n{str(e)[:150]}", True)
-
-# ==============================================================================
-# 🟢 پارت 15: توابع ترجمه و ویرایش عکس با هوش مصنوعی (Flux.2)
-# ==============================================================================
-async def translate_text_aloha(prompt_text):
-    session_hash = ''.join(random.choices(string.ascii_lowercase + string.digits, k=11))
-    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:
-            async with session.post(join_url, json=payload, timeout=20) as resp:
-                if resp.status != 200:
-                    return prompt_text
-                    
-            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":
-                                if json_data.get("success"):
-                                    return json_data["output"]["data"][0]
-                                break
-                        except Exception:
-                            pass
-    except Exception:
-        pass
-        
-    return prompt_text
-
-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)
-
-    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
-
-    generated_image = None
-    last_error_log = "سرور پاسخ نداد."
-    
-    for attempt in range(5):
-        keys_to_try = HF_TOKENS.copy()
-        random.shuffle(keys_to_try)
-        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"
-                )
-                break 
-            except Exception as e:
-                last_error_log = str(e)
-                continue
-        if generated_image: break
-        await asyncio.sleep(2)
-            
-    try:
-        if proc_msg:
-            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"❌ متأسفانه ویرایش عکس انجام نشد.\n\n⚠️ علت:\n{last_error_log[:200]}", True)
-
-    try:
-        file_name = f"edited_flux_{uuid.uuid4().hex}.jpg"
-        await asyncio.to_thread(sync_save_image, generated_image, file_name)
-        await asyncio.sleep(1)
-        caption_text = f"🪄 ویرایش عکس با هوش مصنوعی Flux.2 انجام شد!\n\n✨ تغییرات خواسته شده: {prompt}\n🔤 متن ارسال شده به هوش: {translated_prompt}"
-        
-        upload_result = False
-        error_log_edit = ""
-        for up_att in range(3):
-            res = await helper_upload_file(client, chat_id, file_name, "Image", caption_text)
-            if res is True:
-                upload_result = True
-                break
-            else:
-                error_log_edit = res
-                await asyncio.sleep(4)
-        
-        if upload_result is True:
-            if not creds.get("is_premium"):
-                user_credits_db[str_chat_id]["edit_image"] -= 1
-                save_db(user_credits_db)
-        else:
-            await send_with_keyboard(client, chat_id, f"❌ عکس ساخته شد اما خطا در ارسال به روبیکا رخ داد:\n`{str(error_log_edit)[:800]}`", True)
-            
-        if os.path.exists(file_name): os.remove(file_name)
-    except Exception as e:
-        await send_with_keyboard(client, chat_id, f"❌ خطا در ذخیره عکس ویرایش شده:\n{str(e)[:150]}", True)
-
-# ==============================================================================
-# 🟢 پارت 16: ساخت صدا از روی متن (تبدیل متن به صدا - TTS)
-# ==============================================================================
-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)
-
-    try:
-        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 = "پاسخی دریافت نشد"
-        
-        for attempt in range(10):
-            workers = WORKER_URLS.copy()
-            random.shuffle(workers)
-            async with aiohttp.ClientSession(headers=headers, timeout=aiohttp.ClientTimeout(total=600)) as session:
-                for worker_url in workers[:3]:
-                    try:
-                        async with session.post(worker_url, json=payload) as response:
-                            if response.status == 200:
-                                content_type = response.headers.get('Content-Type', '')
-                                if 'audio' in content_type or response.content_length > 1000:
-                                    audio_bytes = await response.read()
-                                    break
-                                else: last_error = "فایل نامعتبر"
-                            else: last_error = f"ارور ({response.status})"
-                    except Exception as e: 
-                        last_error = f"خطا: {str(e)}"
-                        continue
-            if audio_bytes: break
-            await asyncio.sleep(2)
-
-        try:
-            if proc_msg:
-                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:
-            file_name_mp3 = f"audio_{uuid.uuid4().hex}.mp3"
-            await asyncio.to_thread(sync_write_file, file_name_mp3, audio_bytes)
-            await asyncio.sleep(1)
-            
-            upload_result_file = False
-            error_log_tts = ""
-            for up_att in range(3):
-                res = await helper_upload_file(client, chat_id, file_name_mp3, "Music", "✅ صدای شما با موفقیت آماده شد (فایل MP3):")
-                if res is True:
-                    upload_result_file = True
-                    break
-                else:
-                    error_log_tts = res
-                    await asyncio.sleep(4)
-            
-            if upload_result_file is True: 
-                if not creds.get("is_premium"):
-                    user_credits_db[str_chat_id]["tts"] -= 1
-                    save_db(user_credits_db)
-            else:
-                await send_with_keyboard(client, chat_id, f"❌ فایل صدا ساخته شد اما سرور روبیکا اجازه آپلود نداد:\n`{str(error_log_tts)[:800]}`", True)
-                
-            if os.path.exists(file_name_mp3): os.remove(file_name_mp3)
-        else: 
-            await send_with_keyboard(client, chat_id, f"❌ سرورها درگیر هستند.\nدلیل: {last_error}", True)
-    except Exception: traceback.print_exc()
-
-# ==============================================================================
-# 🟢 پارت 17: سیستم ساخت پادکست
-# ==============================================================================
-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)
-
-    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})
-
-    url_create = "https://opera8-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(url_create, json=payload_create, timeout=60) as resp:
-                if resp.status != 202: return await send_with_keyboard(client, chat_id, f"❌ خطا در سرور پادکست: وضعیت {resp.status}", True)
-                task_id = (await resp.json()).get("task_id")
-        except Exception as e: return await send_with_keyboard(client, chat_id, f"❌ خطا در اتصال به سرور پادکست:\n{str(e)}", True)
-
-        url_status = f"https://opera8-podgen.hf.space/api/podcast-status/{task_id}"
-        script_data = None
-        for _ in range(500):
-            await asyncio.sleep(3)
-            try:
-                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)
-            except Exception: pass
-            
-        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)
-                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, f"🎙 سناریو نوشته شد! در حال ریکورد و م��کس دیالوگ‌های گویندگان (شامل {len(script_data)} نوبت صحبت)...\nاین مرحله زمان‌بر است...", False)
-
-        combined_audio = AudioSegment.empty()
-        url_generate = "https://opera8-podgen.hf.space/api/generate"
-        
-        for index, turn in enumerate(script_data):
-            payload_gen = {"text": turn["dialogue"], "speaker": turn["speaker_id"], "temperature": 0.9}
-            chunk_audio_bytes = None
-            
-            for attempt in range(10):
-                try:
-                    async with session.post(url_generate, json=payload_gen, timeout=120) as resp:
-                        if resp.status == 200:
-                            chunk_audio_bytes = await resp.read()
-                            break
-                except Exception: await asyncio.sleep(2)
-            
-            if not chunk_audio_bytes: 
-                return await send_with_keyboard(client, chat_id, f"❌ خطا در تولید صدای بخش {index+1} از سرور. عملیات متوقف شد.", True)
-                
-            try:
-                combined_audio = await asyncio.to_thread(sync_combine_audio, combined_audio, chunk_audio_bytes)
-            except Exception as e: 
-                return await send_with_keyboard(client, chat_id, f"❌ خطا در پردازش صدا:\n{str(e)}", True)
-
-        file_name_mp3 = f"final_podcast_{uuid.uuid4().hex}.mp3"
-        await asyncio.to_thread(sync_export_audio, combined_audio, file_name_mp3)
-        
-        try:
-            if proc_msg:
-                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
-
-        caption_file = f"🎧 فایل پادکست شما با فرمت MP3:\n\n💡 موضوع شما: {prompt}"
-        
-        upload_result_file = False
-        error_log_pod = ""
-        for up_att in range(3):
-            res = await helper_upload_file(client, chat_id, file_name_mp3, "Music", caption_file)
-            if res is True:
-                upload_result_file = True
-                break
-            else:
-                error_log_pod = res
-                await asyncio.sleep(5)
-        
-        if upload_result_file is True: 
-            if not creds.get("is_premium"):
-                user_credits_db[str_chat_id]["podcast"] -= 1
-                save_db(user_credits_db)
-        else:
-            await send_with_keyboard(client, chat_id, f"❌ پادکست ساخته شد اما روبیکا پس از ده‌ها تلاش خطای آپلود داد.\n\n`{str(error_log_pod)[:800]}`", True)
-            
-        if os.path.exists(file_name_mp3): os.remove(file_name_mp3)
-
-# ==============================================================================
-# 🟢 پارت 18: استخراج متن از صدا (STT) و تحلیل انواع فایل با هوش مصنوعی
-# ==============================================================================
-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)
-    
-    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" 
-    
-    prompt = "لطفاً این فایل صوتی/تصویری را با دقت کامل گوش بده و صحبت‌های داخل آن را کلمه به کلمه به متن تبدیل کن. هیچ توضیح اضافه‌ای نده."
-    
-    transcribed_text = None
-    for attempt in range(5):
-        keys_to_try = get_next_gemini_keys(100)
-        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}}
-                try:
-                    async with session.post(url, json=payload, timeout=60) as response:
-                        if response.status == 200:
-                            data = await response.json()
-                            transcribed_text = data["candidates"][0]["content"]["parts"][0]["text"]
-                            break
-                except Exception: continue
-        if transcribed_text: break
-        await asyncio.sleep(2)
-
-    try:
-        if proc_msg:
-            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:
-        sent = await send_with_keyboard(client, chat_id, f"📝 **متن استخراج شده:**\n\n{transcribed_text}", True)
-        if sent and not creds.get("is_premium"):
-            user_credits_db[str_chat_id]["stt"] -= 1
-            save_db(user_credits_db)
-    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)
-    
-    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: 
-        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"
-        
-    is_image = mime_type.startswith('image/')
-    
-    final_answer = None
-    for attempt in range(5):
-        keys_to_try = get_next_gemini_keys(100)
-        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.6}}
-                try:
-                    async with session.post(url, json=payload, timeout=45) as response:
-                        if response.status == 200:
-                            data = await response.json()
-                            final_answer = data["candidates"][0]["content"]["parts"][0]["text"]
-                            break
-                except Exception: continue
-        if final_answer: break
-        await asyncio.sleep(2)
-
-    if not final_answer:
-        if is_image and HF_TOKENS:
-            for attempt in range(5):
-                keys_to_try_hf = HF_TOKENS.copy()
-                random.shuffle(keys_to_try_hf)
-                
-                hf_messages =[
-                    {
-                        "role": "user",
-                        "content":[
-                            {"type": "text", "text": prompt},
-                            {
-                                "type": "image_url",
-                                "image_url": {"url": f"data:{mime_type};base64,{base64_data}"}
-                            }
-                        ]
-                    }
-                ]
-                
-                async with aiohttp.ClientSession() as session:
-                    for hf_key in keys_to_try_hf:
-                        url = "https://router.huggingface.co/v1/chat/completions"
-                        headers = {"Authorization": f"Bearer {hf_key}", "Content-Type": "application/json"}
-                        payload = {
-                            "model": "google/gemma-4-31B-it:novita",
-                            "messages": hf_messages,
-                            "max_tokens": 4096
-                        }
-                        try:
-                            async with session.post(url, headers=headers, json=payload, timeout=60) as response:
-                                if response.status == 200:
-                                    data = await response.json()
-                                    final_answer = data["choices"][0]["message"]["content"]
-                                    break
-                        except Exception:
-                            continue
-                if final_answer: break
-                await asyncio.sleep(2)
-
-    try:
-        if proc_msg:
-            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: 
-        sent = await send_with_keyboard(client, chat_id, f"💡 **نتیجه تحلیل:**\n\n{final_answer}", True)
-        if sent and not creds.get("is_premium"):
-            user_credits_db[str_chat_id]["file"] -= 1
-            save_db(user_credits_db)
-    else: 
-        if not is_image:
-            await send_with_keyboard(client, chat_id, "❌ متأسفانه سرور اصلی در حال حاضر شلوغ است و در این شرایط **فعلاً تنها امکان تحلیل تصاویر** توسط سرور جایگزین در دسترس است.", True)
-        else:
-            await send_with_keyboard(client, chat_id, "❌ تمامی سرورها شلوغ هستند. لطفاً بعداً امتحان کنید.", True)
-
-# ==============================================================================
-# 🟢 پارت 19: ساخت مقاله و خروجی فایل متنی (Word/PDF)
-# ==============================================================================
-async def process_create_file(client, chat_id, topic):
-    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)
-    
-    proc_msg = await send_with_keyboard(client, chat_id, "✍️ در حال تحقیق و نگارش مقاله جامع و حرفه‌ای...\n(این عملیات با توجه به طولانی بودن متن ممکن است کمی طول بکشد)", False)
-
-    ai_prompt = f"یک مقاله بسیار جامع، کاملا حرفه‌ای، بسیار طولانی و با جزئیات کامل درباره موضوع زیر به زبان فارسی بنویس. فقط متن مقاله را بده و هیچ توضیح اضافه‌ای نده:\n\nموضوع: {topic}"
-    
-    article_text = None
-    for attempt in range(5):
-        keys_to_try = get_next_gemini_keys(100)
-        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": ai_prompt}]}], "generationConfig": {"temperature": 0.7, "maxOutputTokens": 8192}}
-                try:
-                    async with session.post(url, json=payload, timeout=60) as response:
-                        if response.status == 200:
-                            data = await response.json()
-                            article_text = data["candidates"][0]["content"]["parts"][0]["text"]
-                            break
-                except Exception: continue
-        if article_text: break
-        await asyncio.sleep(2)
-
-    if not article_text and HF_TOKENS:
-        for attempt in range(5):
-            keys_to_try_hf = HF_TOKENS.copy()
-            random.shuffle(keys_to_try_hf)
-            async with aiohttp.ClientSession() as session:
-                for hf_key in keys_to_try_hf:
-                    url = "https://router.huggingface.co/v1/chat/completions"
-                    headers = {"Authorization": f"Bearer {hf_key}", "Content-Type": "application/json"}
-                    payload = {
-                        "model": "google/gemma-4-31B-it:novita",
-                        "messages":[{"role": "user", "content":[{"type": "text", "text": ai_prompt}]}],
-                        "max_tokens": 4096
-                    }
-                    try:
-                        async with session.post(url, headers=headers, json=payload, timeout=60) as response:
-                            if response.status == 200:
-                                data = await response.json()
-                                article_text = data["choices"][0]["message"]["content"]
-                                break
-                    except Exception: continue
-            if article_text: break
-            await asyncio.sleep(2)
-
-    if not article_text:
-        return await send_with_keyboard(client, chat_id, "❌ سرور تولید متن شلوغ است، لطفاً بعداً تلاش کنید.", True)
-
-    try:
-        if proc_msg:
-            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
-
-    proc_msg = await send_with_keyboard(client, chat_id, "📄 مقاله با موفقیت نوشته شد! در حال ارتباط با سرور و تبدیل به فایل‌های PDF و Word...\n(لطفا صبور باشید)", False)
-
-    converter_url = "https://opera8-texttopdf.hf.space/"
-    uid = uuid.uuid4().hex
-
-    pdf_success = False
-    for attempt in range(30):
-        try:
-            pdf_bytes = None
-            async with aiohttp.ClientSession() as session:
-                form_data = aiohttp.FormData()
-                form_data.add_field('content', article_text)
-                form_data.add_field('format', 'pdf')
-                async with session.post(converter_url, data=form_data, timeout=90) as resp:
-                    if resp.status == 200:
-                        data_bytes = await resp.read()
-                        if data_bytes and len(data_bytes) > 100:
-                            pdf_bytes = data_bytes
-            
-            if pdf_bytes:
-                filename = f"Article_{uid}.pdf"
-                await asyncio.to_thread(sync_write_file, filename, pdf_bytes)
-                
-                res_upload = False
-                for _ in range(3):
-                    r = await helper_upload_file(client, chat_id, filename, "File", f"📄 فایل PDF مقاله شما:\n\n💡 موضوع: {topic}")
-                    if r is True:
-                        res_upload = True
-                        break
-                    await asyncio.sleep(4)
-
-                if os.path.exists(filename): 
-                    os.remove(filename)
-                
-                if res_upload is True:
-                    pdf_success = True
-                    break 
-        except Exception as e:
-            print(f"PDF error (attempt {attempt+1}):", e)
-        
-        await asyncio.sleep(4)
-
-    await asyncio.sleep(3.5)
-
-    docx_success = False
-    for attempt in range(30): 
-        try:
-            docx_bytes = None
-            async with aiohttp.ClientSession() as session:
-                form_data = aiohttp.FormData()
-                form_data.add_field('content', article_text)
-                form_data.add_field('format', 'docx')
-                async with session.post(converter_url, data=form_data, timeout=90) as resp:
-                    if resp.status == 200:
-                        data_bytes = await resp.read()
-                        if data_bytes and len(data_bytes) > 100:
-                            docx_bytes = data_bytes
-            
-            if docx_bytes:
-                filename = f"Article_{uid}.docx"
-                await asyncio.to_thread(sync_write_file, filename, docx_bytes)
-                
-                res_upload = False
-                for _ in range(3):
-                    r = await helper_upload_file(client, chat_id, filename, "File", f"📝 فایل Word (DOCX) مقاله شما:\n\n💡 موضوع: {topic}")
-                    if r is True:
-                        res_upload = True
-                        break
-                    await asyncio.sleep(4)
-
-                if os.path.exists(filename): 
-                    os.remove(filename)
-                
-                if res_upload is True:
-                    docx_success = True
-                    break 
-        except Exception as e:
-            print(f"DOCX error (attempt {attempt+1}):", e)
-        
-        await asyncio.sleep(4)
-
-    try:
-        if proc_msg:
-            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 pdf_success and docx_success:
-        if not creds.get("is_premium"):
-            user_credits_db[str_chat_id]["chat"] -= 1
-            save_db(user_credits_db)
-        await send_with_keyboard(client, chat_id, "✅ مقاله شما با موفقیت به صورت هر دو فایل (PDF و Word) تحویل داده شد!", True)
-    elif pdf_success or docx_success:
-        if not creds.get("is_premium"):
-            user_credits_db[str_chat_id]["chat"] -= 1
-            save_db(user_credits_db)
-        await send_with_keyboard(client, chat_id, "⚠️ یکی از فایل‌ها با موفقیت ارسال شد اما دیگری پس از تلاش‌های مکرر سرور با خطا مواجه شد.", True)
-    else:
-        await send_with_keyboard(client, chat_id, "❌ متأسفانه پس از تلاش‌های مکرر، سرور قادر به ساخت و ارسال هیچ‌یک از فایل‌ها نبود و اعتباری از شما کسر نشد.", True)
-
-# ==============================================================================
-# 🔴 پا��ت 20: نسخه پاکسازی اضطراری (مخصوص تخلیه صف در دیتابیس جدید v3)
-# ==============================================================================
-
-if not bot_token:
-    print("خطا: توکن وارد نشده!")
-else:
-    bot = BotClient(bot_token)
-
-    @bot.on_update(filters.private)
-    async def main_handler(client, update):
-        try:
-            # فقط استخراج آیدی پیام
-            msg_obj = getattr(update, "message", None) or getattr(update, "new_message", None)
-            msg_id = getattr(update, "message_id", None)
-            if not msg_id and msg_obj:
-                msg_id = msg_obj.get("message_id") if isinstance(msg_obj, dict) else getattr(msg_obj, "message_id", None)
-            
-            if not msg_id: return
-            str_msg_id = str(msg_id).strip()
-
-            # ثبت در دیتابیس v3 بدون فرستادن هیچ پاسخی
-            if not is_message_processed(str_msg_id):
-                mark_message_processed(str_msg_id)
-                print(f"🗑️ [V3-CLEARING] پیام {str_msg_id} ثبت شد.")
-            
-        except Exception:
-            pass
-
-if __name__ == "__main__":
-    threading.Thread(target=run_flask, daemon=True).start()
-    if bot_token:
-        print("⚠️ وضعیت: در حال تخلیه صف پیام‌ها در دیتابیس v3... لطفاً تا توقف لاگ‌ها صبر کنید.")
-        bot.run()