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

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

@@ -0,0 +1,1883 @@
+# ==============================================================================
+# 🟢 پارت 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()