Update main.py

main.py

@@ -16,36 +16,52 @@ import concurrent.futures
 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
 
-# --- کد مدیریت برای ارتقای کاربران بدون نیاز به لاگین ---
-ADMIN_CODE = "3011"
+# --- تنظیمات آدرس سرورهای تغییر صدا ---
+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"}
+}
 
-# متغیر سراسری برای ذخیره آیدی خود ربات (جلوگیری از جواب دادن ربات به خودش)
+# --- کد مدیریت ---
+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,[])
-    # فقط زمان پیام‌های 3 ثانیه اخیر را نگه می‌داریم
-    times =[t for t in times if now - t < 3.0]
+    times = [t for t in times if now - t < 3.0]
     times.append(now)
     user_message_times[chat_id] = times
-    
-    # اگر یک کاربر به تنهایی در 3 ثانیه بیش از 4 پیام داد، پیامش نادیده گرفته شود
     if len(times) > 4:
         return True
     return False
 
-# --- سیستم دیتابیس حساب کاربری متصل به دیتاست هاگینگ فیس ---
+# --- سیستم دیتابیس حساب کاربری מתصل به دیتاست هاگینگ فیس ---
 DB_FILE = "users_db.json"
 DATASET_REPO = "opera8/Karbaran-rayegan-tedad"
 HF_TOKEN_DB = os.environ.get("HF_TOKEN")
@@ -72,7 +88,16 @@ def gregorian_to_jalali(gy, gm, gd):
 
 def load_db():
     print("در حال تلاش برای خواندن دیتابیس کاربران از دیتاست هاگینگ فیس...")
-    if HF_TOKEN_DB:
+    if not HF_TOKEN_DB:
+        if os.path.exists(DB_FILE):
+            try:
+                with open(DB_FILE, "r", encoding="utf-8") as f:
+                    return json.load(f)
+            except Exception:
+                pass
+        return {}
+        
+    while True:
         try:
             file_path = hf_hub_download(
                 repo_id=DATASET_REPO, 
@@ -84,15 +109,13 @@ def load_db():
                 print("✅ دیتابیس با موفقیت از دیتاست هاگینگ فیس لود شد.")
                 return json.load(f)
         except Exception as e:
-            print("⚠️ فایل دیتابیس در هاگینگ فیس یافت نشد یا خطایی رخ داد (ساخت دیتابیس جدید).")
-    
-    if os.path.exists(DB_FILE):
-        try:
-            with open(DB_FILE, "r", encoding="utf-8") as f:
-                return json.load(f)
-        except Exception:
-            pass
-    return {}
+            err_msg = str(e)
+            if "EntryNotFoundError" in err_msg or "404" in err_msg:
+                print("⚠️ فایل دیتابیس در هاگینگ فیس یافت نشد (ساخت دیتابیس جدید).")
+                return {}
+            
+            print(f"⚠️ قطعی در ارتباط با هاگینگ فیس! تلاش مجدد در 5 ثانیه... ({err_msg[:50]})")
+            time.sleep(5)
 
 db_needs_upload = False
 
@@ -101,21 +124,19 @@ def save_db(db_data):
     with db_lock:
         try:
             with open(DB_FILE, "w", encoding="utf-8") as f:
-                json.dump(db_data, f, ensure_ascii=False, indent=4)
-            db_needs_upload = True  # فقط تیک می‌زنیم که نیاز به آپلود دارد
+                json.dump(db_data, f, ensure_ascii=False, separators=(',', ':'))
+            db_needs_upload = True
         except Exception as e:
             print("خطا در ذخیره دیتابیس:", e)
 
-# یک تسک پس‌زمینه برای آپلود منظم و بدون فشار به سرور
 async def background_db_uploader():
     global db_needs_upload
     while True:
-        await asyncio.sleep(300) # هر ۵ دقیقه چک می‌کند
+        await asyncio.sleep(300)
         if db_needs_upload and HF_TOKEN_DB:
             db_needs_upload = False
             api = HfApi(token=HF_TOKEN_DB)
             try:
-                # استفاده از to_thread برای جلوگیری از قفل شدن ربات
                 await asyncio.to_thread(
                     api.upload_file,
                     path_or_fileobj=DB_FILE,
@@ -126,7 +147,7 @@ async def background_db_uploader():
                 print("✅ بکاپ دیتابیس در هاگینگ فیس ذخیره شد.")
             except Exception as e:
                 print("❌ خطا در آپلود دیتابیس به هاگینگ فیس:", str(e)[:100])
-                db_needs_upload = True # اگر خطا داد دفعه بعد دوباره تلاش کند
+                db_needs_upload = True
 
 user_credits_db = load_db()
 
@@ -135,7 +156,6 @@ def get_or_create_referral_code(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
@@ -166,6 +186,9 @@ def get_user_credits(chat_id):
             "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,
@@ -174,6 +197,11 @@ def get_user_credits(chat_id):
         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"):
@@ -196,13 +224,14 @@ def get_user_credits(chat_id):
             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
+    if not text: return text
     persian_digits = '۰۱۲۳۴۵۶۷۸۹'
     arabic_digits = '٠١٢٣٤٥٦٧٨٩'
     english_digits = '0123456789'
@@ -214,12 +243,12 @@ app = Flask(__name__)
 
 @app.route('/')
 def home():
-    return "ربات یکپارچه آلفا (نسخه پرو + مدیریت اشتراک نامحدود + دعوت دوستان + سیستم ضد باگ) روشن است! 🚀"
+    return "ربات یکپارچه آلفا (نسخه پرو + مدیریت اشتراک نامحدود + دعوت دوستان + سیستم تغییر صدا) روشن است! 🚀"
 
 def run_flask():
     app.run(host="0.0.0.0", port=7860, threaded=True)
 
-# --- توابع کمکی برای جلوگیری از بلاک شدن Event Loop ---
+# --- توابع کمکی ---
 def sync_save_image(image, file_name):
     rgb_im = image.convert('RGB')
     rgb_im.save(file_name, format="JPEG", quality=100)
@@ -259,6 +288,12 @@ MAIN_KEYPAD_DICT = {
                 {"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": "فایل صوتی به متن 📝"},
@@ -332,78 +367,54 @@ async def check_channel_membership(client, user_id):
                 elif hasattr(res, 'exist') and hasattr(res.exist, 'chat'):
                     CHANNEL_GUID = getattr(res.exist.chat, 'object_guid', None)
 
-        if not CHANNEL_GUID:
-            return True
+        if not CHANNEL_GUID: return True
 
-        payload = {
-            "channel_guid": CHANNEL_GUID,
-            "member_guid": user_id
-        }
+        payload = {"channel_guid": CHANNEL_GUID, "member_guid": user_id}
         res = await client._make_request("getChannelParticipant", payload)
         
-        if isinstance(res, dict):
-            if res.get("status") == "OK":
-                data = res.get("data", {})
-                if data and "participant" in data:
-                    return True
-        elif hasattr(res, 'status'):
-            if getattr(res, 'status') == "OK":
-                return True
-        
-        return False
-    except Exception:
+        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
-        }
+        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
-
+        try: return await client.send_message(chat_id, text)
+        except Exception: return None
 
 bot_token = os.environ.get("RUBIKA_AUTH", "").strip()
 
 # ==================================================================
-# 🔥 تابع دانلود کاملاً ضد بمب اتم (35 بار پافشاری و کنترل 502)
+# تابع دانلود ضد بمب اتم (پافشاری ۳۵ بار)
 # ==================================================================
 async def helper_download_file(client, msg_obj):
     errors =[]
     file_obj = None
     file_id = None
     
-    # 1. استخراج آبجکت و آیدی فایل با دقت بالا
     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']
+            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("خطا: هیچ فایلی در پیام یافت نشد.")
+    if not file_id: raise Exception("خطا: هیچ فایلی در پیام یافت نشد.")
 
     temp_name = f"temp_dl_{uuid.uuid4().hex}.tmp"
 
-    # روش 1: استفاده مستقیم از API قدرتمند روبیکا با پافشاری بسیار بالا (20 بار)
     for attempt in range(20):
         try:
             url_get_file = f"https://botapi.rubika.ir/v3/{bot_token}/getFile"
@@ -417,27 +428,22 @@ async def helper_download_file(client, msg_obj):
                         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:
-                                # اگر لینک داد، 3 بار هم برای خود لینک تلاش میکنیم تا اگر قطع شد جبران شود
                                 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}")
+                                                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]:
+                            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) # صبر بیشتر برای خطای 502
+                        await asyncio.sleep(3.5)
                         continue
                     else:
                         errors.append(f"GetFile HTTP {resp.status}")
@@ -446,25 +452,20 @@ async def helper_download_file(client, msg_obj):
             errors.append(f"API Error: {str(e)[:50]}")
             await asyncio.sleep(2)
 
-    # روش 2: کتابخانه rubpy (بک‌آپ با 10 بار پافشاری)
     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 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
+                        if data and len(data) > 0: return data
             except Exception as e:
-                err_str = str(e)
-                errors.append(f"Rubpy Obj Error: {err_str[:50]}")
+                errors.append(f"Rubpy Obj Error: {str(e)[:50]}")
                 await asyncio.sleep(3)
 
-    # روش 3: متد قدیمی rubpy (بک‌آپ نهایی با 5 بار پافشاری)
     for attempt in range(5):
         try:
             if hasattr(client, "download_file"):
@@ -472,23 +473,33 @@ async def helper_download_file(client, msg_obj):
                 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
+                    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
 
+# ==================================================================
+# توکن‌ها و کلیدها
+# ==================================================================
 GEMINI_KEYS_STR1 = os.environ.get("GEMINI_API_KEYS1", "")
 GEMINI_KEYS_STR2 = os.environ.get("GEMINI_API_KEYS2", "")
 
 _raw_keys =[]
-if GEMINI_KEYS_STR1:
-    _raw_keys.extend(GEMINI_KEYS_STR1.split(","))
-if GEMINI_KEYS_STR2:
-    _raw_keys.extend(GEMINI_KEYS_STR2.split(","))
+if GEMINI_KEYS_STR1: _raw_keys.extend(GEMINI_KEYS_STR1.split(","))
+if GEMINI_KEYS_STR2: _raw_keys.extend(GEMINI_KEYS_STR2.split(","))
 
 GEMINI_KEYS = list(set([k.strip() for k in _raw_keys if k.strip()]))
 print(f"✅ تعداد {len(GEMINI_KEYS)} کلید جیمینای با موفقیت شناسایی شد.")
@@ -500,46 +511,34 @@ def get_next_gemini_keys(count=100):
     global current_gemini_key_index
     with gemini_key_lock:
         total_keys = len(GEMINI_KEYS)
-        if total_keys == 0:
-            return[]
-            
+        if total_keys == 0: return[]
         actual_count = min(count, total_keys)
         selected_keys =[]
-        
         for _ in range(actual_count):
             selected_keys.append(GEMINI_KEYS[current_gemini_key_index])
             current_gemini_key_index = (current_gemini_key_index + 1) % total_keys
-            
         return selected_keys
 
 HF_TOKENS_STR = os.environ.get("HF_TOKENS", "")
 HF_TOKENS =[k.strip() for k in HF_TOKENS_STR.split(",") if k.strip()]
 
-
 # ==================================================================
-# 🔥 تابع آپلود فایل فوق قدرتمند و ضدضربه (75 بار مقاومت در برابر 502)
+# تابع آپلود فایل (قدرتمند و ضدضربه) با حفظ قابلیت ارسال عکس 
 # ==================================================================
 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
-    
-    # روبیکا با ارسال فایل‌های ogg غیر ویس و فایل‌های mp3 به عنوان File مشکل دارد و 502 میدهد.
-    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"
+    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"
         
-    # روش اول: استفاده مستقیم از API روبیکا با 15 بار پافشاری قدرتمند
     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:
-                # 1. درخواست لینک آپلود
                 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}")
@@ -547,39 +546,29 @@ async def helper_upload_file(client, chat_id, file_name, file_type="Image", capt
                         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))
-                                
-                                # 2. آپلود فایل در سرور (با تایم‌اوت 300 ثانیه مخصوص فایل‌های حجیم مثل پادکست)
                                 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)
+                                        await asyncio.sleep(3) if up_resp.status in[502, 503, 500] else asyncio.sleep(1.5)
                                         continue
                                         
-                                    try:
-                                        up_data = await up_resp.json()
+                                    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
                                     
-                                    # 3. دریافت آیدی و ارسال نهایی پیام
                                     final_file_id = None
                                     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")
+                                        elif "file_id" in up_data: final_file_id = up_data.get("file_id")
                                             
                                     if final_file_id:
                                         send_payload = {
@@ -596,48 +585,53 @@ async def helper_upload_file(client, chat_id, file_name, file_type="Image", capt
                                                 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}")
+                                            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 == "Voice":
                                             api_file_type = "Music"
                                         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}")
+                        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)
 
-    # روش دوم: بک‌آپ قدرتمند با کتابخانه rubpy با 10 بار پافشاری 
+    # روش دوم: استفاده از متدهای اختصاصی rubpy برای ارسال عکس/فایل (جلوگیری از ارسال عکس به صورت داکیومنت)
     for attempt in range(10):
         try:
-            if hasattr(client, "send_file"):
+            if api_file_type == "Image" and hasattr(client, "send_photo"):
+                await client.send_photo(chat_id, photo=abs_path, caption=caption)
+                return True
+            elif api_file_type in ["Voice", "Music"]:
+                if hasattr(client, "send_voice"):
+                    await client.send_voice(chat_id, voice=abs_path, caption=caption)
+                    return True
+                elif hasattr(client, "send_music"):
+                    await client.send_music(chat_id, music=abs_path, caption=caption)
+                    return True
+            
+            # در صورتی که هیچ‌کدام از شروط بالا برقرار نبود به عنوان فایل ارسال شود
+            if hasattr(client, "send_document"): 
+                await client.send_document(chat_id, document=abs_path, caption=caption)
+                return True
+            elif hasattr(client, "send_file"):
                 await client.send_file(chat_id, abs_path)
                 if caption:
                     await send_with_keyboard(client, chat_id, caption, True)
                 return True
-            elif hasattr(client, "send_document"): 
-                await client.send_document(chat_id, abs_path, caption=caption)
-                return True
         except Exception as e:
             err_msg = str(e)[:100]
             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)
-                continue
-            else:
-                await asyncio.sleep(2)
+            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)
 
     return "\n".join(error_logs[-6:])
 
-
-WORKER_URLS =[
-    "https://opera8-ttspro.hf.space/generate",
-]
+# ==================================================================
+# لیست‌های اولیه ربات
+# ==================================================================
+WORKER_URLS =["https://opera8-ttspro.hf.space/generate"]
 
 SPEAKERS = {
     "1": ("شهاب (مرد)", "Charon"), "2": ("آوا (زن)", "Zephyr"), "3": ("نوید (مرد)", "Achird"), 
@@ -653,10 +647,166 @@ SPEAKERS = {
 }
 
 user_states = {}
-processed_messages_list = user_credits_db.get("system_processed_messages",[])
-processed_message_ids = set(processed_messages_list)
 
+# ==================================================================
+# توابع تغییر صدا و کلون کردن
+# ==================================================================
+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)
 
+# ==================================================================
+# سایر توابع پردازشی
+# ==================================================================
 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)
@@ -701,7 +851,6 @@ async def process_gemini(client, chat_id, prompt, file_bytes=None, file_name=Non
         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)
@@ -811,7 +960,6 @@ async def process_gemini(client, chat_id, prompt, file_bytes=None, file_name=Non
                 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)
@@ -819,7 +967,6 @@ async def process_gemini(client, chat_id, prompt, file_bytes=None, file_name=Non
     except Exception:
         await send_with_keyboard(client, chat_id, "❌ خطایی در ارسال پیام رخ داد.", False)
 
-
 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)
@@ -889,7 +1036,6 @@ async def process_image(client, chat_id, prompt, size_choice="1"):
     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 = "هیچ اتصالی برقرار نشد."
     
@@ -928,7 +1074,6 @@ async def process_image(client, chat_id, prompt, size_choice="1"):
         await asyncio.sleep(1)
         caption_text = f"🎨 تصویر شما با پرامپت هوشمند آماده شد!\n\n📏 ابعاد تصویر: {size_name}\n✨ ایده اولیه: {prompt}"
         
-        # آپلود قدرتمند با 3 بار تلاش مجدد بیرونی 
         upload_result = False
         error_log_img = ""
         for up_att in range(3):
@@ -940,7 +1085,6 @@ async def process_image(client, chat_id, prompt, size_choice="1"):
                 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
@@ -952,7 +1096,6 @@ async def process_image(client, chat_id, prompt, size_choice="1"):
     except Exception as e: 
         await send_with_keyboard(client, chat_id, f"❌ خطا در ذخیره و ارسال عکس:\n{str(e)[:150]}", True)
 
-
 async def translate_text_aloha(prompt_text):
     session_hash = ''.join(random.choices(string.ascii_lowercase + string.digits, k=11))
     join_url = "https://hamed744-translate-tts-aloha.hf.space/gradio_api/queue/join"
@@ -986,7 +1129,6 @@ async def translate_text_aloha(prompt_text):
         
     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)
@@ -1002,7 +1144,6 @@ async def process_image_edit(client, chat_id, image_bytes, prompt):
     if not translated_prompt or translated_prompt.strip() == "":
         translated_prompt = prompt
 
-    # --- سیستم پافشاری برای ویرایش عکس ---
     generated_image = None
     last_error_log = "سرور پاسخ نداد."
     
@@ -1051,7 +1192,6 @@ async def process_image_edit(client, chat_id, image_bytes, prompt):
                 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
@@ -1063,7 +1203,6 @@ async def process_image_edit(client, chat_id, image_bytes, prompt):
     except Exception as e:
         await send_with_keyboard(client, chat_id, f"❌ خطا در ذخیره عکس ویرایش شده:\n{str(e)[:150]}", True)
 
-
 async def process_tts(client, chat_id, user_text, speaker_id, speaker_name):
     str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
     creds = get_user_credits(str_chat_id)
@@ -1075,7 +1214,6 @@ async def process_tts(client, chat_id, user_text, speaker_id, speaker_name):
         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 = "پاسخی دریافت نشد"
         
@@ -1111,11 +1249,9 @@ async def process_tts(client, chat_id, user_text, speaker_id, speaker_name):
             await asyncio.to_thread(sync_write_file, file_name_mp3, audio_bytes)
             await asyncio.sleep(1)
             
-            # ارسال با فرمت Music و مقاومت ۳ برابری
             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
@@ -1124,7 +1260,6 @@ async def process_tts(client, chat_id, user_text, speaker_id, speaker_name):
                     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
@@ -1137,7 +1272,6 @@ async def process_tts(client, chat_id, user_text, speaker_id, speaker_name):
             await send_with_keyboard(client, chat_id, f"❌ سرورها درگیر هستند.\nدلیل: {last_error}", True)
     except Exception: traceback.print_exc()
 
-
 async def process_podcast(client, chat_id, prompt):
     str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
     creds = get_user_credits(str_chat_id)
@@ -1193,7 +1327,6 @@ async def process_podcast(client, chat_id, prompt):
             payload_gen = {"text": turn["dialogue"], "speaker": turn["speaker_id"], "temperature": 0.9}
             chunk_audio_bytes = None
             
-            # --- پافشاری قدرتمندتر برای دریافت هر بخش پادکست ---
             for attempt in range(10):
                 try:
                     async with session.post(url_generate, json=payload_gen, timeout=120) as resp:
@@ -1208,7 +1341,7 @@ async def process_podcast(client, chat_id, prompt):
             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"❌ خطا در پردازش صدا (آیا pydub و ffmpeg نصب است؟):\n{str(e)}", True)
+                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)
@@ -1222,12 +1355,9 @@ async def process_podcast(client, chat_id, prompt):
 
         caption_file = f"🎧 فایل پادکست شما با فرمت MP3:\n\n💡 موضوع شما: {prompt}"
         
-        # ⚠️ آپلود بسیار قدرتمند پادکست (ارسال با هویت Music برای جلوگیری از 502) 
-        # همراه با 3 مرحله تکرار خارجی، که خود شامل 15 + 10 بار تکرار داخلی است!
         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
@@ -1236,7 +1366,6 @@ async def process_podcast(client, chat_id, prompt):
                 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
@@ -1246,7 +1375,6 @@ async def process_podcast(client, chat_id, prompt):
             
         if os.path.exists(file_name_mp3): os.remove(file_name_mp3)
 
-
 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)
@@ -1262,7 +1390,6 @@ async def process_stt(client, chat_id, audio_bytes, file_name):
     
     prompt = "لطفاً این فایل صوتی/تصویری را با دقت کامل گوش بده و صحبت‌های داخل آن را کلمه به کلمه به متن تبدیل کن. هیچ توضیح اضافه‌ای نده."
     
-    # --- سیستم پافشاری برای تبدیل صدا به متن ---
     transcribed_text = None
     for attempt in range(5):
         keys_to_try = get_next_gemini_keys(100)
@@ -1289,14 +1416,12 @@ async def process_stt(client, chat_id, audio_bytes, file_name):
 
     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)
@@ -1320,7 +1445,6 @@ async def process_file_analysis(client, chat_id, file_bytes, file_name, prompt):
         
     is_image = mime_type.startswith('image/')
     
-    # --- سیستم پافشاری برای تحلیل فایل ---
     final_answer = None
     for attempt in range(5):
         keys_to_try = get_next_gemini_keys(100)
@@ -1386,7 +1510,6 @@ async def process_file_analysis(client, chat_id, file_bytes, file_name, prompt):
 
     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)
@@ -1396,7 +1519,6 @@ async def process_file_analysis(client, chat_id, file_bytes, file_name, prompt):
         else:
             await send_with_keyboard(client, chat_id, "❌ تمامی سرورها شلوغ هستند. لطفاً بعداً امتحان کنید.", True)
 
-
 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)
@@ -1410,7 +1532,6 @@ async def process_create_file(client, chat_id, topic):
 
     ai_prompt = f"یک مقاله بسیار جامع، کاملا حرفه‌ای، بسیار طولانی و با جزئیات کامل درباره موضوع زیر به زبان فارسی بنویس. فقط متن مقاله را بده و هیچ توضیح اضافه‌ای نده:\n\nموضوع: {topic}"
     
-    # --- سیستم پافشاری برای تولید متن مقاله ---
     article_text = None
     for attempt in range(5):
         keys_to_try = get_next_gemini_keys(100)
@@ -1466,11 +1587,8 @@ async def process_create_file(client, chat_id, topic):
     converter_url = "https://opera8-texttopdf.hf.space/"
     uid = uuid.uuid4().hex
 
-    # =======================================================================
-    # ---- 1. پردازش و ارسال فایل PDF (دونه دونه و با پافشاری شدید) ----
-    # =======================================================================
     pdf_success = False
-    for attempt in range(30):  # تا 30 بار تلاش (تقریبا ول کن نیست)
+    for attempt in range(30):
         try:
             pdf_bytes = None
             async with aiohttp.ClientSession() as session:
@@ -1500,22 +1618,16 @@ async def process_create_file(client, chat_id, topic):
                 
                 if res_upload is True:
                     pdf_success = True
-                    break  # با موفقیت ساخته و ارسال شد -> خروج از حلقه
+                    break 
         except Exception as e:
             print(f"PDF error (attempt {attempt+1}):", e)
         
-        await asyncio.sleep(4)  # در صورت خطا 4 ثانیه مکث و تلاش مجدد
+        await asyncio.sleep(4)
 
-    # =======================================================================
-    # استراحت بین دو فایل برای هضم شدن فایل قبلی توسط سیستم روبیکا
-    # =======================================================================
     await asyncio.sleep(3.5)
 
-    # =======================================================================
-    # ---- 2. پردازش و ارسال فایل Word (دونه دونه و با پافشاری شدید) ----
-    # =======================================================================
     docx_success = False
-    for attempt in range(30):  # تا 30 بار تلاش 
+    for attempt in range(30): 
         try:
             docx_bytes = None
             async with aiohttp.ClientSession() as session:
@@ -1545,11 +1657,11 @@ async def process_create_file(client, chat_id, topic):
                 
                 if res_upload is True:
                     docx_success = True
-                    break  # با موفقیت ساخته و ارسال شد -> خروج از حلقه
+                    break 
         except Exception as e:
             print(f"DOCX error (attempt {attempt+1}):", e)
         
-        await asyncio.sleep(4)  # در صورت خطا 4 ثانیه مکث و تلاش مجدد
+        await asyncio.sleep(4)
 
     try:
         if proc_msg:
@@ -1558,7 +1670,6 @@ async def process_create_file(client, chat_id, topic):
             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
@@ -1572,7 +1683,9 @@ async def process_create_file(client, chat_id, topic):
     else:
         await send_with_keyboard(client, chat_id, "❌ متأسفانه پس از تلاش‌های مکرر، سرور قادر به ساخت و ارسال هیچ‌یک از فایل‌ها نبود و اعتباری از شما کسر نشد.", True)
 
-
+# ==================================================================
+# حلقه و مدیریت اصلی ربات
+# ==================================================================
 if not bot_token:
     print("خطا: توکن ربات روبیکا وارد نشده است!")
 else:
@@ -1580,7 +1693,7 @@ else:
 
     @bot.on_update(filters.private)
     async def main_handler(client, update):
-        global BOT_GUID, processed_messages_list, processed_message_ids
+        global BOT_GUID
         
         try:
             if not BOT_GUID:
@@ -1607,36 +1720,33 @@ else:
             if not msg_id and msg_obj:
                 msg_id = msg_obj.get("message_id") if isinstance(msg_obj, dict) else getattr(msg_obj, "message_id", None)
             
-            unique_msg_key = f"{chat_id}_{msg_id}" if msg_id else None
-            if unique_msg_key:
-                if unique_msg_key in processed_message_ids: return
-                
-                processed_message_ids.add(unique_msg_key)
-                processed_messages_list.append(unique_msg_key)
-                
-                if len(processed_messages_list) > 5000:
-                    processed_messages_list = processed_messages_list[-5000:]
-                    processed_message_ids.clear()
-                    processed_message_ids.update(processed_messages_list)
+            str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
+            creds = get_user_credits(str_chat_id)
+
+            # --- سیستم فوق بهینه پیگیری پیام (Offset Tracking) ---
+            if msg_id:
+                try:
+                    current_msg_int = int(msg_id)
+                    last_msg_int = creds.get("last_msg_id", 0)
                     
-                user_credits_db["system_processed_messages"] = processed_messages_list
-                save_db(user_credits_db)
+                    if current_msg_int <= last_msg_int:
+                        return
+                    
+                    user_credits_db[str_chat_id]["last_msg_id"] = current_msg_int
+                    save_db(user_credits_db)
+                except Exception:
+                    pass
 
             user_text = getattr(update, "text", "") or getattr(msg_obj, "text", "")
             user_text_str = str(user_text).strip() if user_text else ""
             user_text_lower = user_text_str.lower()
 
-            str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
-
-            # بررسی اسپم فقط برای همین کاربر
             if is_user_spamming(str_chat_id):
                 return
 
             if str_chat_id not in user_states:
                 user_states[str_chat_id] = {"mode": None, "text": "", "history":[], "file_bytes": None, "file_name": None}
 
-            creds = get_user_credits(str_chat_id)
-
             if user_text_lower.startswith(f"{ADMIN_CODE} pro=") or user_text_lower.startswith(f"{ADMIN_CODE}pro="):
                 parts = user_text_str.split("=", 1)
                 if len(parts) >= 2:
@@ -1654,6 +1764,9 @@ else:
                                 "tts": 5,
                                 "file": 1,
                                 "stt": 5,
+                                "voice_conv": 3,
+                                "voice_clone": 1,
+                                "last_msg_id": 0,
                                 "has_joined": True,
                                 "invited_count": 0,
                                 "used_referral": False,
@@ -1671,6 +1784,8 @@ else:
                         user_credits_db[target_id]["tts"] = 999999
                         user_credits_db[target_id]["file"] = 999999
                         user_credits_db[target_id]["stt"] = 999999
+                        user_credits_db[target_id]["voice_conv"] = 999999
+                        user_credits_db[target_id]["voice_clone"] = 999999
                         
                         save_db(user_credits_db)
                         await send_with_keyboard(client, chat_id, f"✅ حساب کاربر `{target_id}` به مدت ۳۰ روز شارژ شد و به پرو ارتقا یافت.", False)
@@ -1720,6 +1835,8 @@ else:
                                 status_text = "🥉 نسخه رایگان (آزمایشی)\n⏳ وضعیت: سهمیه روزانه محدود"
 
                             chat_rem = "نامحدود ∞" if is_prem else t_creds.get('chat', 0)
+                            vc_rem = "نامحدود ∞" if is_prem else t_creds.get('voice_conv', 0)
+                            clone_rem = "نامحدود ∞" if is_prem else t_creds.get('voice_clone', 0)
                             podcast_rem = "نامحدود ∞" if is_prem else t_creds.get('podcast', 0)
                             tts_rem = "نامحدود ∞" if is_prem else t_creds.get('tts', 0)
                             file_rem = "نامحدود ∞" if is_prem else t_creds.get('file', 0)
@@ -1741,6 +1858,8 @@ else:
 💬 چت: {chat_rem}
 🎨 تولید عکس: {image_rem}
 🪄 ویرایش عکس: {edit_image_rem}
+🎙️ تغییر صدا: {vc_rem}
+👤 کلون کردن صدا: {clone_rem}
 🎙 پادکست: {podcast_rem}
 🗣 متن به صدا: {tts_rem}
 📁 تحلیل فایل: {file_rem}
@@ -1825,6 +1944,8 @@ else:
                     daily_note = "*نکته: سهمیه شما هر روز ساعت ۰۰:۰۰ بامداد به صورت خودکار مجدداً شارژ می‌گردد.*"
 
                 chat_rem = "نامحدود ∞" if is_prem else creds['chat']
+                vc_rem = "نامحدود ∞" if is_prem else creds.get('voice_conv', 0)
+                clone_rem = "نامحدود ∞" if is_prem else creds.get('voice_clone', 0)
                 podcast_rem = "نامحدود ∞" if is_prem else creds['podcast']
                 tts_rem = "نامحدود ∞" if is_prem else creds['tts']
                 file_rem = "نامحدود ∞" if is_prem else creds['file']
@@ -1845,6 +1966,8 @@ else:
 - 💬 چت هوشمند: {chat_rem}
 - 🎨 تولید تصویر: {image_rem} عدد
 - 🪄 ویرایش تصویر: {edit_image_rem} عدد
+- 🎙️ تغییر صدا: {vc_rem}
+- 👤 کلون کردن صدا: {clone_rem}
 - 🎙 ساخت پادکست: {podcast_rem}
 - 🗣 تبدیل متن به صدا: {tts_rem}
 - 📁 تحلیل فایل و سند: {file_rem}
@@ -1854,9 +1977,6 @@ else:
                 await send_with_keyboard(client, chat_id, account_profile, True)
                 return
 
-            # ===============================================
-            # 🎁 سیستم جدید دعوت دوستان (دو سر سود) 🎁
-            # ===============================================
             if user_text_str in["/invite", "دعوت دوستان 🎁"]:
                 invites = creds.get("invited_count", 0)
                 remains = 10 - (invites % 10)
@@ -1884,6 +2004,7 @@ else:
 ✨ با این ربات می‌تونی کارهای زیر رو به راحتی انجام بدی:
 💬 چت با پیشرفته‌ترین هوش مصنوعی
 🎨 ساخت و ویرایش حرفه‌ای عکس
+🎙️ تغییر صدا و کلون کردن صدا 
 🎙 ساخت پادکست اختصاصی
 🗣 تبدیل متن به صدا (30 گوینده مختلف)
 📝 تبدیل صدا و ویدیو به متن
@@ -1913,6 +2034,7 @@ else:
 
 🎁 **بسته طلایی یک‌ماهه شامل:**
 🤖 چت با هوش مصنوعی بصورت نامحدود
+🎙️ تغییر صدا و کلون کردن صدای نامحدود
 🗣 تبدیل متن به صدا بصورت نامحدود با ۳۰ گوینده
 🎙 ساخت پادکست بصورت نامحدود 
 
@@ -1978,6 +2100,23 @@ else:
                 await send_with_keyboard(client, chat_id, "📻 شما وارد بخش **ساخت پادکست** شدید.\n\nلطفاً موضوع پادکست خود را بفرستید.\nمثال: درباره تاریخچه پیدایش قهوه با ۳ گوینده یک پادکست جذاب بساز . همچنین این قسمت متصل به مدل زبانی است و درخواست هارو قبل از ساخت درک میکنه. میتوانید مقاله کامل یک سایت بفرستید با تبلیغات یا هرچی، هوش مصنوعی متن مقاله رو استخراج و پادکست براتون میسازه . در توضیحات امکان مشخص کردن تعداد گوینده به همراه اسم شون نیز از سمت شما امکان پذیر است.\n\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
                 return
 
+            # ===============================================
+            # بخش‌های جدید: تغییر صدا و کلون کردن صدا
+            # ===============================================
+            if user_text_str in["/vc", "تغییر صدا 🎙️"]:
+                user_states[str_chat_id]["mode"] = "vc_waiting_for_voice"
+                user_states[str_chat_id]["file_bytes"] = None
+                await send_with_keyboard(client, chat_id, "🎙️ شما وارد بخش **تغییر صدا** شدید.\n\nلطفاً صدای خود (ویس) را بفرستید تا آن را به صدای شخصیت‌های معروف تبدیل کنم:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                return
+
+            if user_text_str in["/clone", "کلون کردن صدا 👤"]:
+                user_states[str_chat_id]["mode"] = "clone_waiting_for_src"
+                user_states[str_chat_id]["file_bytes"] = None
+                user_states[str_chat_id]["ref_bytes"] = None
+                await send_with_keyboard(client, chat_id, "👤 شما وارد بخش **کلون کردن صدای اختصاصی** شدید.\n\nدر این بخش شما به 2 فایل صوتی نیاز دارید:\n1️⃣ صدای خودتان (ورودی)\n2️⃣ صدای شخص هدف (الگو)\n\nابتدا **صدای خودتان (ورودی)** را ارسال کنید:\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
+                return
+            # ===============================================
+
             if user_text_str in["/file", "تحلیل فایل 📁"]:
                 user_states[str_chat_id]["mode"] = "file_waiting_for_file"
                 user_states[str_chat_id]["file_bytes"] = None
@@ -2001,9 +2140,6 @@ else:
                 elif user_text_str: await send_with_keyboard(client, chat_id, "⚠️ لطفاً ابتدا از کیبورد پایین، بخش مورد نظرتان را انتخاب کنید:", True)
                 return
 
-            # ===============================================
-            # بخش دریافت کد هدیه 8 رقمی از کاربر
-            # ===============================================
             elif current_mode == "waiting_for_referral_code":
                 if user_text_str:
                     normalized_code = to_english_digits(user_text_str).strip()
@@ -2071,9 +2207,6 @@ else:
                     await send_with_keyboard(client, chat_id, "✅ کد هدیه با موفقیت ثبت شد!\n🎁 **10 سهمیه تبدیل رایگان متن به صدا** به حساب شما اضافه گردید.", True)
                 return
 
-            # ===============================================
-            # آپدیت جدید: در چت ابتدا فایل را می‌گیرد و می‌پرسد چه کار کند
-            # ===============================================
             elif current_mode == "chat":
                 if is_file:
                     await send_with_keyboard(client, chat_id, "📥 در حال دانلود فایل...", False)
@@ -2100,9 +2233,6 @@ else:
                     await send_with_keyboard(client, chat_id, "⚠️ لطفاً درخواست خود را متنی بنویسید.", False)
                 return
 
-            # ===============================================
-            # دریافت سایز قبل از ساخت عکس
-            # ===============================================
             elif current_mode == "image_waiting_for_text":
                 if user_text_str:
                     user_states[str_chat_id]["text"] = user_text_str
@@ -2226,6 +2356,100 @@ else:
                     await send_with_keyboard(client, chat_id, "⚠️ لطفاً موضوع مقاله خود را به صورت متنی بفرستید.", False)
                 return
 
+            # ===============================================
+            # بخش‌های تغییر صدا و کلون صدا
+            # ===============================================
+            elif current_mode == "vc_waiting_for_voice":
+                if not is_file: return await send_with_keyboard(client, chat_id, "⚠️ لطفاً یک فایل صوتی یا ویس ارسال کنید.", False)
+                await send_with_keyboard(client, chat_id, "📥 در حال دانلود فایل صوتی شما...", False)
+                try:
+                    file_bytes = await helper_download_file(client, msg_obj)
+                    user_states[str_chat_id]["file_bytes"] = file_bytes
+                    user_states[str_chat_id]["mode"] = "vc_waiting_for_model"
+                    
+                    model_menu = "✅ صدای شما دریافت شد.\n\nلطفا **شماره** مدلی که می‌خواهید صدایتان به آن تبدیل شود را ارسال کنید:\n\n"
+                    for k, v in LEGACY_MODELS.items(): model_menu += f"{k}. {v['name']}\n"
+                    model_menu += "➖➖➖➖➖➖➖➖\n"
+                    for k, v in STANDARD_MODELS.items(): model_menu += f"{k}. {v['name']}\n"
+                    
+                    await send_with_keyboard(client, chat_id, model_menu, False)
+                except Exception as dl_err: 
+                    await send_with_keyboard(client, chat_id, f"❌ خطا در دریافت فایل!\n{str(dl_err)}", False)
+                return
+
+            elif current_mode == "vc_waiting_for_model":
+                choice = to_english_digits(user_text_str).strip()
+                
+                if choice in STANDARD_MODELS:
+                    if creds["voice_conv"] <= 0: return await send_with_keyboard(client, chat_id, "❌ سهمیه تغییر صدای شما تمام شده است. لطفاً از منوی اصلی وارد بخش «خرید اشتراک 💎» شوید.", False)
+                    user_states[str_chat_id]["mode"] = None
+                    model = STANDARD_MODELS[choice]
+                    src_bytes = user_states[str_chat_id]["file_bytes"]
+                    await send_with_keyboard(client, chat_id, "📥 در حال آماده‌سازی فایل‌ها...", False)
+                    ref_bytes = await helper_download_url_to_bytes(model["ref"])
+                    if not ref_bytes: return await send_with_keyboard(client, chat_id, "❌ خطا در دسترسی به فایل صدای مدل.", False)
+                    
+                    asyncio.create_task(process_standard_vc_job(client, chat_id, src_bytes, ref_bytes, model["name"], "voice_conv"))
+                
+                elif choice in LEGACY_MODELS:
+                    if creds["voice_conv"] <= 0: return await send_with_keyboard(client, chat_id, "❌ سهمیه تغییر صدای شما تمام شده است. لطفاً از منوی اصلی وارد بخش «خرید اشتراک 💎» شوید.", False)
+                    user_states[str_chat_id]["selected_model"] = choice
+                    user_states[str_chat_id]["mode"] = "vc_waiting_for_gender"
+                    
+                    gender_msg = f"✅ مدل {LEGACY_MODELS[choice]['name']} انتخاب شد.\n\nبرای تنظیم دقیق فرکانس‌ها به ما بگویید صدایی که خودتان فرستادید صدای یک **مرد** است یا **زن**؟\n\n1. مرد 👨\n2. زن 👩"
+                    await send_with_keyboard(client, chat_id, gender_msg, False)
+                else:
+                    await send_with_keyboard(client, chat_id, "❌ شماره وارد شده صحیح نیست. لطفاً فقط عدد مدل را بفرستید.", False)
+                return
+
+            elif current_mode == "vc_waiting_for_gender":
+                choice = to_english_digits(user_text_str).strip()
+                if choice not in ["1", "2"]:
+                    return await send_with_keyboard(client, chat_id, "❌ لطفاً عدد 1 (مرد) یا 2 (زن) را ارسال کنید.", False)
+                
+                user_gender = "male" if choice == "1" else "female"
+                model_key = user_states[str_chat_id]["selected_model"]
+                model = LEGACY_MODELS[model_key]
+                target_gender = model["gender"]
+                
+                pitch = 0
+                if target_gender == "female" and user_gender == "male": pitch = 12
+                elif target_gender == "male" and user_gender == "female": pitch = -12
+                
+                user_states[str_chat_id]["mode"] = None
+                src_bytes = user_states[str_chat_id]["file_bytes"]
+                asyncio.create_task(process_legacy_vc_job(client, chat_id, src_bytes, model["url"], pitch, model["name"]))
+                return
+
+            elif current_mode == "clone_waiting_for_src":
+                if not is_file: return await send_with_keyboard(client, chat_id, "⚠️ لطفاً فایل صوتی صدای خودتان را بفرستید.", False)
+                await send_with_keyboard(client, chat_id, "📥 در حال دانلود صدای شما...", False)
+                try:
+                    file_bytes = await helper_download_file(client, msg_obj)
+                    user_states[str_chat_id]["file_bytes"] = file_bytes
+                    user_states[str_chat_id]["mode"] = "clone_waiting_for_ref"
+                    await send_with_keyboard(client, chat_id, "✅ صدای شما دریافت شد.\n\nحالا **فایل الگو (صدای شخصی که می‌خواهید شبیه‌سازی کنید)** را ارسال کنید.\n(پیشنهاد: فایل بدون نویز و موسیقی، بین ۳ تا ۱۰ ثانیه)", False)
+                except Exception as dl_err: 
+                    await send_with_keyboard(client, chat_id, f"❌ خطا در دریافت فایل!\n{str(dl_err)}", False)
+                return
+
+            elif current_mode == "clone_waiting_for_ref":
+                if not is_file: return await send_with_keyboard(client, chat_id, "⚠️ لطفاً فایل صوتی الگوی هدف را بفرستید.", False)
+                await send_with_keyboard(client, chat_id, "📥 در حال دانلود صدای الگو...", False)
+                try:
+                    ref_bytes = await helper_download_file(client, msg_obj)
+                    
+                    if creds["voice_clone"] <= 0: 
+                        return await send_with_keyboard(client, chat_id, "❌ سهمیه کلون کردن صدای شما تمام شده است. نیازمند تهیه اشتراک هستید.", False)
+                    
+                    user_states[str_chat_id]["mode"] = None
+                    src_bytes = user_states[str_chat_id]["file_bytes"]
+                    
+                    asyncio.create_task(process_standard_vc_job(client, chat_id, src_bytes, ref_bytes, "صدای اختصاصی (کلون شده)", "voice_clone"))
+                except Exception as dl_err: 
+                    await send_with_keyboard(client, chat_id, f"❌ خطا در دریافت فایل!\n{str(dl_err)}", False)
+                return
+
         except Exception: traceback.print_exc()
 
 if __name__ == "__main__":
@@ -2235,8 +2459,7 @@ if __name__ == "__main__":
         loop = asyncio.get_event_loop()
         loop.set_default_executor(concurrent.futures.ThreadPoolExecutor(max_workers=32))
         
-        # روشن کردن سیستم آپلود دیتابیس هوشمند
         loop.create_task(background_db_uploader())
         
-        print("ربات آلفا پرو با سیستم اشتراک نامحدود + سپر امنیتی + دانلود پیشرفته فایل + 32 Worker پس‌زمینه روشن شد...")
+        print("ربات آلفا پرو با سیستم اشتراک نامحدود + دانلود پیشرفته + آپدیت دیتابیس (جلوگیری از ریست) + تغییر و کلون صدا روشن شد...")
         bot.run()