Update main.py

main.py

@@ -93,7 +93,7 @@ def gregorian_to_jalali(gy, gm, gd):
     return jy, jm, jd
 
 # ==============================================================================
-# 🟢 پارت 4: دیتابیس SQLite (نسخه نجات جراحی - پریدن از روی سکتورهای خراب)
+# 🟢 پارت 4: دیتابیس SQLite (نسخه جراحی + بازیابی هوشمند کاربران ویژه از JSON قدیمی)
 # ==============================================================================
 import os
 import sqlite3
@@ -101,9 +101,9 @@ import json
 import copy
 import threading
 
-# 🚀 انتقال به v6 برای انجام مجدد عملیات نجات (این بار به صورت خط‌به‌خط جراحی)
 DB_FILE = "/data/users_v6.db" 
 OLD_DB_V3 = "/data/users_v3.db"
+OLD_JSON_BAK = "Users_db.json.bak" # نام فایل بکاپ جیسون شما
 
 last_saved_state = {}
 recent_messages_dict = {}
@@ -126,9 +126,13 @@ def init_sqlite_db():
         conn.commit()
 
         if is_first_run:
-            print("🚨 عملیات نجات جراحی (دور زدن خرابی‌ها) از فایل v3 آغاز شد...")
+            print("🚨 عملیات نجات جراحی از فایل v3 آغاز شد...")
             surgical_salvage(OLD_DB_V3, conn)
         
+        # 🟢 بازگردانی کاربران دارای اشتراک از فایل جیسون قدیمی
+        # این تابع همیشه چک می‌کند تا اگر کاربر ویژه‌ای جا مانده بود یا اشتراکش در دیتابیس فعلی پریده بود، آن را برگرداند.
+        salvage_premium_from_json(OLD_JSON_BAK, conn)
+        
         conn.close()
     except Exception as e:
         print(f"❌ خطا در راه اندازی دیتابیس: {e}")
@@ -178,6 +182,59 @@ def surgical_salvage(old_file, new_conn):
     except Exception as e:
         print(f"⚠️ توقف استخراج: {e} | تعداد نجات‌یافته تا این لحظه: {extracted_count}")
 
+# 💎 تابع ارتقا یافته: بازیابی کاربران دارای اشتراک از فایل جیسون
+def salvage_premium_from_json(json_file, new_conn):
+    # بررسی وجود فایل در مسیر فعلی یا پوشه data
+    target_path = json_file
+    if not os.path.exists(target_path):
+        alt_path = f"/data/{json_file}"
+        if os.path.exists(alt_path):
+            target_path = alt_path
+        else:
+            return # اگر فایل بکاپ کلا وجود نداشت، بی‌صدا رد می‌شود
+
+    print(f"📦 در حال اسکن فایل بکاپ {target_path} جهت یافتن کاربران VIP جا مانده یا فاقد اشتراک...")
+    try:
+        with open(target_path, 'r', encoding='utf-8') as f:
+            old_json_data = json.load(f)
+            
+        restored_count = 0
+        cursor = new_conn.cursor()
+        
+        for chat_id, user_data in old_json_data.items():
+            # فقط کاربرانی که دیتای آنها به صورت دیکشنری است و اشتراک فعال دارند را انتخاب می‌کنیم
+            if isinstance(user_data, dict) and user_data.get("is_premium") == True:
+                user_data_str = json.dumps(user_data, ensure_ascii=False)
+                str_chat_id = str(chat_id)
+                try:
+                    # بررسی می‌کنیم آیا کاربر در دیتابیس فعلی (v6) وجود دارد یا خیر
+                    cursor.execute("SELECT user_data FROM users WHERE chat_id = ?", (str_chat_id,))
+                    existing_row = cursor.fetchone()
+                    
+                    if existing_row:
+                        # کاربر وجود دارد. بررسی می‌کنیم آیا اشتراکش فعال است؟
+                        existing_data = json.loads(existing_row[0])
+                        if not existing_data.get("is_premium"):
+                            # اگر در دیتابیس فعلی اشتراک نداشت، دیتای پولی جایگزین می‌شود
+                            cursor.execute("UPDATE users SET user_data = ? WHERE chat_id = ?", (user_data_str, str_chat_id))
+                            restored_count += 1
+                    else:
+                        # کاربر اصلا در دیتابیس وجود ندارد، او را اضافه می‌کنیم
+                        cursor.execute("INSERT INTO users (chat_id, user_data) VALUES (?, ?)", (str_chat_id, user_data_str))
+                        restored_count += 1
+                        
+                except Exception:
+                    continue
+                    
+        new_conn.commit()
+        if restored_count > 0:
+            print(f"💎 فوق‌العاده! اطلاعات {restored_count} کاربر دارای اشتراک (که غایب بودند یا در نسخه جدید اشتراک نداشتند) با موفقیت ریکاوری شد.")
+        else:
+            print("💎 ��ایل بکاپ بررسی شد؛ تمام کاربران VIP از قبل با اشتراک فعال در دیتابیس فعلی موجود هستند.")
+            
+    except Exception as e:
+        print(f"❌ خطا در پردازش فایل جیسون بکاپ: {e}")
+
 def load_db():
     global last_saved_state, recent_messages_dict
     init_sqlite_db()
@@ -213,7 +270,7 @@ def background_save_worker(changed_data):
 
 def save_db(db_data):
     global last_saved_state
-    changed =[]
+    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)))
@@ -761,12 +818,12 @@ SPEAKERS = {
 user_states = {}
 
 # ==============================================================================
-# 🟢 پارت 12: توابع تغییر صدا و لیست گویندگان
+# 🟢 پارت 12: لیست گویندگان و توابع تغییر صدا
 # ==============================================================================
 # ==================================================================
 # لیست‌های اولیه ربات
 # ==================================================================
-WORKER_URLS =["https://opera8-ttspro.hf.space/generate"]
+# (آدرس کارگرها طبق درخواست حذف شد و پردازش به اسپیس پادکست منتقل گردید)
 
 SPEAKERS = {
     "1": ("شهاب (مرد)", "Charon"), "2": ("آوا (زن)", "Zephyr"), "3": ("نوید (مرد)", "Achird"), 
@@ -795,7 +852,7 @@ async def process_standard_vc_job(client, chat_id, src_bytes, ref_bytes, job_typ
     async with aiohttp.ClientSession() as session:
         job_id = None
         total_chunks = 1
-        chunks =[]
+        chunks = []
         
         # ♻️ سیستم تلاش مجدد پنهان (دور زدن ارور 429)
         for attempt in range(8):
@@ -809,7 +866,7 @@ async def process_standard_vc_job(client, chat_id, src_bytes, ref_bytes, job_typ
                         data = await resp.json()
                         job_id = data.get("job_id")
                         total_chunks = data.get("total_chunks", 1)
-                        chunks = data.get("chunks",[])
+                        chunks = data.get("chunks", [])
                         break
                     elif resp.status == 429:
                         await asyncio.sleep(4 + attempt * 2) # تاخیر تصاعدی تا سرور خلوت شود
@@ -834,7 +891,7 @@ async def process_standard_vc_job(client, chat_id, src_bytes, ref_bytes, job_typ
                         if c_data.get("status") == "completed":
                             final_filename = c_data.get("filename")
                             break
-                        elif c_data.get("status") in["failed", "error"]:
+                        elif c_data.get("status") in ["failed", "error"]:
                             return await send_with_keyboard(client, chat_id, "❌ خطای سرور در حین پردازش صدا.", True)
                     elif c_resp.status == 429:
                         await asyncio.sleep(5)
@@ -935,7 +992,7 @@ async def process_legacy_vc_job(client, chat_id, src_bytes, model_url, pitch, mo
                         if c_data.get("status") == "completed":
                             final_filename = c_data.get("filename")
                             break
-                        elif c_data.get("status") in["failed", "error", "not_found"]:
+                        elif c_data.get("status") in ["failed", "error", "not_found"]:
                             return await send_with_keyboard(client, chat_id, "❌ خطای سرور در حین پردازش.", True)
                     elif c_resp.status == 429:
                         await asyncio.sleep(5)
@@ -1127,7 +1184,7 @@ async def process_gemini(client, chat_id, prompt, file_bytes=None, file_name=Non
         # 🟢 تزریق شخصیت و دستورالعمل جدید به مدل
         system_rules = """تو یک دستیار با مزه از برنامه هوش مصنوعی آلفا هستی😊 و توسط هوش مصنوعی آلفا توسعه داده شدی.
 اینگونه می‌تونی خودت رو معرفی کنی، من یه هوش مصنوعیِ ساخته‌شده توسط تیم‌ تخصصی آلفا ام، و بر پایه مدل GPT-5.4 کار می‌کنم. یعنی یه نوع نرم‌افزار خیلی هوشمند که با کمک میلیون‌ها داده و آموزش‌های پیشرفته ساخته شده، تا بتونه بهت کمک کنه، سوالاتت رو جواب بده، یا حتی یه شوخی خنده‌دار برات بگه وقتی حال و هوات گرفته‌ست!
-در واقع، من نتیجه سال‌ها تحقیقات و تلاش‌های مهندس‌ها و پژوهشگرها هستم، تا جایی که می‌تونم بهترین کمک رو بهت بکنم. این دستورات های تو هستند و بصورت رندوم متفاوت جواب بده و از شکلک های مناسب و جواب های جذاب استفاده کن. اگر در یک مکالمه اول سلام کردی در پیام های بعدی سلام نیاز نیست ."""
+در واقع، من نتیجه سال‌ها تحقیقات و تلاش‌های مهندس‌ها و پژوهشگرها هستم، تا جایی که می‌تونم بهترین کمک رو بهت بکنم. این دستورات های تو هستند و بصورت رندوم متفاوت جواب بده و از شکلک های مناسب و جواب های جذاب استفاده کن. اگر در یک مکالمه اول سلام کردی در پیام های بعدی سلام نیاز نیست.."""
 
         # 🟢 استخراج تاریخچه و تبدیل آن به متنی پیوسته جهت تزریق مستقیم به حافظه مدل (تضمین ۱۰۰٪ یادآوری)
         text_history = ""
@@ -1525,7 +1582,7 @@ async def process_image_edit(client, chat_id, image_bytes, prompt):
         await send_with_keyboard(client, chat_id, f"❌ خطا در ذخیره عکس ویرایش شده:\n{str(e)[:150]}", True)
 
 # ==============================================================================
-# 🟢 پارت 16: ساخت صدا از روی متن (تبدیل متن به صدا - TTS)
+# 🟢 پارت 16: ساخت صدا از روی متن (تبدیل متن به صدا - متصل به اسپیس پادکست)
 # ==============================================================================
 async def process_tts(client, chat_id, user_text, speaker_id, speaker_name):
     str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
@@ -1535,48 +1592,57 @@ async def process_tts(client, chat_id, user_text, speaker_id, speaker_name):
 
     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}
+        
+        # اتصال مستقیم به اسپیس ساخت پادکست جهت تولید صدا
+        tts_url = "https://opera8-podgen.hf.space/api/generate"
+        payload = {
+            "text": user_text, 
+            "speaker": speaker_id, 
+            "temperature": 0.9, 
+            "is_custom": False
+        }
         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)
+        async with aiohttp.ClientSession(headers=headers, timeout=aiohttp.ClientTimeout(total=300)) as session:
+            for attempt in range(6):
+                try:
+                    async with session.post(tts_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 = "فایل نامعتبر"
+                        elif response.status == 429:
+                            await asyncio.sleep(4 + attempt * 2)
+                        else:
+                            last_error = f"ارور ({response.status})"
+                            await asyncio.sleep(2)
+                except Exception as e: 
+                    last_error = f"خطا: {str(e)}"
+                    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])
+                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)
+            # ذخیره با فرمت wav (چون سرور فایل wav برمی‌گرداند)
+            file_name_audio = f"audio_{uuid.uuid4().hex}.wav"
+            await asyncio.to_thread(sync_write_file, file_name_audio, 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):")
+                res = await helper_upload_file(client, chat_id, file_name_audio, "Music", "✅ صدای شما با موفقیت آماده شد:")
                 if res is True:
                     upload_result_file = True
                     break
@@ -1591,13 +1657,15 @@ async def process_tts(client, chat_id, user_text, speaker_id, speaker_name):
             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)
+            if os.path.exists(file_name_audio): 
+                os.remove(file_name_audio)
         else: 
             await send_with_keyboard(client, chat_id, f"❌ سرورها درگیر هستند.\nدلیل: {last_error}", True)
-    except Exception: traceback.print_exc()
+    except Exception: 
+        traceback.print_exc()
 
 # ==============================================================================
-# 🟢 پارت 17: سیستم ساخت پادکست (ضد قطعی و مقاوم در برابر 429)
+# 🟢 پارت 17: سیستم ساخت پادکست (ضد قطعی، بدون 429 و متصل به API هوشمند)
 # ==============================================================================
 async def process_podcast(client, chat_id, prompt):
     str_chat_id = str(chat_id).replace("`", "").replace("'", "").replace('"', "").strip()
@@ -1605,19 +1673,22 @@ async def process_podcast(client, chat_id, prompt):
     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 =[]
+    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"
+    # استفاده از API جدید که تمام کارها را صفر تا صد سمت اسپیس انجام می‌دهد
+    url_create = "https://opera8-podgen.hf.space/api/auto-podcast"
     payload_create = {"prompt": prompt, "available_speakers": available_speakers}
     
     async with aiohttp.ClientSession() as session:
         task_id = None
-        # ♻️ تلاش مجدد برای جلوگیری از شکست در صورت شلوغی سرور
-        for attempt in range(8):
+        
+        # 1. ارسال درخواست اولیه به اسپیس
+        for attempt in range(5):
             try:
                 async with session.post(url_create, json=payload_create, timeout=60) as resp:
                     if resp.status == 202: 
@@ -1631,75 +1702,78 @@ async def process_podcast(client, chat_id, prompt):
                 await asyncio.sleep(3)
         
         if not task_id:
-            return await send_with_keyboard(client, chat_id, "❌ ترافیک سرور پادکست بالا است (خطای 429). لطفاً چند دقیقه دیگر امتحان کنید.", True)
+            return await send_with_keyboard(client, chat_id, "❌ ارتباط با سرور پادکست در حال حاضر برقرار نشد. لطفاً چند دقیقه دیگر امتحان کنید.", True)
 
-        url_status = f"https://opera8-podgen.hf.space/api/podcast-status/{task_id}"
-        script_data = None
+        # 2. بررسی وضعیت پردازش در پس‌زمینه سرور اسپیس
+        url_status = f"https://opera8-podgen.hf.space/api/auto-podcast-status/{task_id}"
+        final_filename = None
+        last_progress_message = ""
+        
+        # ربات تا 1500 ثانیه (25 دقیقه) منتظر اتمام ساخت پادکست می‌ماند
         for _ in range(500):
-            await asyncio.sleep(3)
+            await asyncio.sleep(4)
             try:
-                async with session.get(url_status) as resp:
+                async with session.get(url_status, timeout=20) 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",[])
+                        current_status = status_data.get("status")
+                        progress_msg = status_data.get("progress", "")
+                        
+                        if current_status == "completed":
+                            final_filename = status_data.get("filename")
                             break
-                        elif status_data.get("status") == "failed":
-                            return await send_with_keyboard(client, chat_id, "❌ متأسفانه هوش مصنوعی نتوانست برای این موضوع سناریو بنویسد.", True)
+                            
+                        elif current_status == "failed":
+                            error_detail = status_data.get("error", "نامشخص")
+                            return await send_with_keyboard(client, chat_id, f"❌ سرور در ساخت پادکست با خطا مواجه شد.\nدلیل: {error_detail}", True)
+                            
                     elif resp.status == 429:
                         await asyncio.sleep(5)
-            except Exception: pass
+            except Exception: 
+                pass
             
-        if not script_data: return await send_with_keyboard(client, chat_id, "❌ زمان انتظار برای نوشتن سناریو به پایان رسید.", True)
+        if not final_filename: 
+            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])
+                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)
+        proc_msg = await send_with_keyboard(client, chat_id, "📥 پادکست ساخته شد! در حال دانلود فایل نهایی از سرور و آماده‌سازی جهت ارسال...", False)
 
-        combined_audio = AudioSegment.empty()
-        url_generate = "https://opera8-podgen.hf.space/api/generate"
+        # 3. دانلود مستقیم فایل MP3 ترکیب شده از اسپیس
+        download_url = f"https://opera8-podgen.hf.space/api/download-podcast/{final_filename}"
+        audio_bytes = None
         
-        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(15):
-                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
-                        elif resp.status == 429:
-                            await asyncio.sleep(4 + attempt * 2)
-                        else:
-                            await asyncio.sleep(2)
-                except Exception: await asyncio.sleep(2)
-            
-            if not chunk_audio_bytes: 
-                return await send_with_keyboard(client, chat_id, f"❌ خطا در تولید صدای بخش {index+1} به دلیل شلوغی سرور. عملیات متوقف شد.", True)
-                
+        for attempt in range(5):
             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)
+                async with session.get(download_url, timeout=300) as resp:
+                    if resp.status == 200:
+                        audio_bytes = await resp.read()
+                        break
+                    else:
+                        await asyncio.sleep(4)
+            except Exception: 
+                await asyncio.sleep(4)
+                
+        if not audio_bytes:
+            return await send_with_keyboard(client, chat_id, "❌ فایل پادکست آماده شد اما ربات نتوانست آن را از سرور دانلود کند.", True)
 
+        # 4. ذخیره محلی موقت و ارسال به روبیکا
         file_name_mp3 = f"final_podcast_{uuid.uuid4().hex}.mp3"
-        await asyncio.to_thread(sync_export_audio, combined_audio, file_name_mp3)
+        await asyncio.to_thread(sync_write_file, file_name_mp3, audio_bytes)
         
         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])
+                if msg_id: await client.delete_messages(chat_id, [msg_id])
         except: pass
 
-        caption_file = f"🎧 فایل پادکست شما با فرمت MP3:\n\n💡 موضوع شما: {prompt}"
+        caption_file = f"🎧 فایل پادکست شما آماده است:\n\n💡 موضوع شما: {prompt}"
         
         upload_result_file = False
         error_log_pod = ""
@@ -1717,9 +1791,10 @@ async def process_podcast(client, chat_id, prompt):
                 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)
+            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)
+        if os.path.exists(file_name_mp3): 
+            os.remove(file_name_mp3)
 
 # ==============================================================================
 # 🟢 پارت 18: استخراج متن از صدا (STT) و تحلیل انواع فایل با هوش مصنوعی