Update main.py

main.py

@@ -88,9 +88,9 @@ async def send_with_keyboard(client, chat_id, text, use_keyboard=True):
     return msg
 
 
-# --- 🚨 تابع هوشمند دانلود فایل (آپدیت و رفع باگ مسیر ذخیره) 🚨 ---
+# --- 🚨 تابع هوشمند دانلود فایل 🚨 ---
 async def helper_download_file(client, msg_obj):
-    errors = []
+    errors =[]
     
     file_id = None
     file_obj = None
@@ -102,22 +102,17 @@ async def helper_download_file(client, msg_obj):
             elif isinstance(val, dict) and 'file_id' in val: file_id = val['file_id']
             if file_id: break
 
-    # ساخت یک نام رندوم تا کتابخانه rubpy ارور NoneType برای نام فایل ندهد
     temp_name = f"temp_dl_{random.randint(1000, 999999)}.tmp"
 
     if hasattr(client, "download_file"):
-        
-        # تلاش ۱: ارسال مستقیم آبجکت پیام و نام فایل
         try:
             await client.download_file(msg_obj, temp_name)
             if os.path.exists(temp_name):
                 with open(temp_name, 'rb') as f: data = f.read()
                 os.remove(temp_name)
                 return data
-        except Exception as e:
-            errors.append(f"تلاش ۱ (msg_obj): {e}")
+        except Exception as e: errors.append(f"تلاش ۱: {e}")
 
-        # تلاش ۲: ارسال آبجکت فایل اختصاصی
         if file_obj:
             try:
                 await client.download_file(file_obj, temp_name)
@@ -125,10 +120,8 @@ async def helper_download_file(client, msg_obj):
                     with open(temp_name, 'rb') as f: data = f.read()
                     os.remove(temp_name)
                     return data
-            except Exception as e:
-                errors.append(f"تلاش ۲ (file_obj): {e}")
+            except Exception as e: errors.append(f"تلاش ۲: {e}")
 
-        # تلاش ۳: ارسال آیدی با آرگومان file_name
         if file_id:
             try:
                 await client.download_file(file_id, file_name=temp_name)
@@ -136,24 +129,70 @@ async def helper_download_file(client, msg_obj):
                     with open(temp_name, 'rb') as f: data = f.read()
                     os.remove(temp_name)
                     return data
-            except Exception as e:
-                errors.append(f"تلاش ۳ (file_id, file_name): {e}")
+            except Exception as e: errors.append(f"تلاش ۳: {e}")
 
-        # تلاش ۴: ارسال آیدی با آرگومان save_as
-        if file_id:
             try:
                 await client.download_file(file_id, save_as=temp_name)
                 if os.path.exists(temp_name):
                     with open(temp_name, 'rb') as f: data = f.read()
                     os.remove(temp_name)
                     return data
-            except Exception as e:
-                errors.append(f"تلاش ۴ (file_id, save_as): {e}")
+            except Exception as e: errors.append(f"تلاش ۴: {e}")
 
-    # در صورت شکست تمام حالت‌ها
     raise Exception("دانلود ناموفق. لاگ:\n" + "\n".join(errors))
 
 
+# --- 🚨 تابع هوشمند آپلود فایل (نسخه فوق‌پیشرفته + دیباگر) 🚨 ---
+async def helper_upload_file(client, chat_id, file_name, file_type="photo", caption=""):
+    abs_path = os.path.abspath(file_name) # پیدا کردن مسیر قطعی در سرور
+    error_logs =[]
+    
+    # 1. تلاش اول: ارسال پیام با پارامتر فایل
+    try:
+        await client.send_message(chat_id, text=caption, file=abs_path)
+        return True
+    except Exception as e:
+        error_logs.append(f"MsgFile: {e}")
+
+    # 2. تلاش دوم: استفاده مستقیم بدون نام پارامتر
+    try:
+        if file_type == "photo":
+            await client.send_photo(chat_id, abs_path, caption=caption)
+        else:
+            await client.send_voice(chat_id, abs_path)
+        return True
+    except Exception as e:
+        error_logs.append(f"DirectArg: {e}")
+
+    # 3. تلاش سوم: استفاده با نام پارامتر
+    try:
+        if file_type == "photo":
+            await client.send_photo(chat_id, photo=abs_path, caption=caption)
+        else:
+            await client.send_voice(chat_id, voice=abs_path)
+        return True
+    except Exception as e:
+        error_logs.append(f"Kwarg: {e}")
+
+    # 4. تلاش چهارم: ارسال به عنوان سند (Document)
+    try:
+        await client.send_document(chat_id, document=abs_path, caption=caption)
+        return True
+    except Exception as e:
+        error_logs.append(f"Doc: {e}")
+        
+    # 5. تلاش پنجم: تبدیل به بایت و ارسال مستقیم حافظه
+    try:
+        with open(abs_path, 'rb') as f:
+            await client.send_message(chat_id, text=caption, file=f)
+        return True
+    except Exception as e:
+        error_logs.append(f"ByteObj: {e}")
+
+    # در صورت شکست، لیست ارور��ا را خروجی می‌دهد
+    return "\n".join(error_logs)
+
+
 # --- لیست تمام سرورهای تولید صدای شما ---
 WORKER_URLS =[
     "https://hamed744-ttspro.hf.space/generate",
@@ -245,7 +284,7 @@ async def process_gemini(client, chat_id, prompt):
         await send_with_keyboard(client, chat_id, "❌ متأسفانه پاسخی دریافت نشد. لطفاً دوباره تلاش کنید.", False)
         return
 
-    history.append({"role": "model", "parts": [{"text": final_answer}]})
+    history.append({"role": "model", "parts":[{"text": final_answer}]})
     user_states[chat_id]["history"] = history
 
     try:
@@ -275,7 +314,7 @@ async def process_gemini(client, chat_id, prompt):
         await send_with_keyboard(client, chat_id, "❌ خطایی در ارسال پیام رخ داد.", False)
 
 
-# --- ۲. پردازش ساخت عکس (نسخه آپدیت شده و 100% تضمینی) ---
+# --- ۲. پردازش ساخت عکس ---
 async def process_image(client, chat_id, prompt):
     if not HF_TOKENS:
         await send_with_keyboard(client, chat_id, "❌ توکن‌های هاگینگ فیس تنظیم نشده‌اند.", False)
@@ -303,7 +342,7 @@ async def process_image(client, chat_id, prompt):
             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])
+                await client.delete_messages(chat_id,[msg_id])
     except Exception: pass
 
     if not generated_image:
@@ -318,50 +357,22 @@ async def process_image(client, chat_id, prompt):
         await asyncio.sleep(1)
         caption_text = "🎨 تصویر شما آماده شد!\n(مدل: Z-Image-Turbo)"
         
-        uploaded_directly = False
+        # استفاده از تابع هوشمند برای آپلود
+        upload_result = await helper_upload_file(client, chat_id, file_name, "photo", caption_text)
         
-        # 🚨 تست تمام حالت‌های آپلود عکس برای دور زدن باگ Rubpy
-        try:
-            await client.send_message(chat_id, file=file_name)
-            uploaded_directly = True
-        except Exception: pass
-
-        if not uploaded_directly:
-            try:
-                await client.send_photo(chat_id, photo=file_name)
-                uploaded_directly = True
-            except Exception: pass
-
-        if not uploaded_directly:
-            try:
-                await client.send_photo(chat_id, file_name)
-                uploaded_directly = True
-            except Exception: pass
-
-        if not uploaded_directly:
-            try:
-                await client.send_document(chat_id, document=file_name)
-                uploaded_directly = True
-            except Exception: pass
-
-        if not uploaded_directly:
-            try:
-                await client.send_document(chat_id, file=file_name)
-                uploaded_directly = True
-            except Exception: pass
-
-        if uploaded_directly:
-            await send_with_keyboard(client, chat_id, caption_text, True)
+        if upload_result is True:
+            await send_with_keyboard(client, chat_id, "✅ تصویر با موفقیت ارسال شد.", True)
         else:
-            await send_with_keyboard(client, chat_id, "❌ تصویر با موفقیت در سرور ساخته شد اما توابع روبیکا در ارسال آن شکست خوردند! (مشکل کتابخانه)", True)
-        
+            err_msg = str(upload_result)[:800]
+            await send_with_keyboard(client, chat_id, f"❌ تصویر در سرور ساخته شد، اما روبیکا در آپلود آن ارور داد.\n\n🔴 لاگ ارور برنامه‌نویس:\n`{err_msg}`", True)
+            
         if os.path.exists(file_name): os.remove(file_name)
             
     except Exception as e:
         await send_with_keyboard(client, chat_id, f"❌ خطایی در فرآیند ذخیره عکس رخ داد:\n{str(e)[:150]}", True)
 
 
-# --- ۳. پردازش ساخت صدا (نسخه آپدیت شده و 100% تضمینی) ---
+# --- ۳. پردازش ساخت صدا ---
 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)
@@ -405,48 +416,16 @@ async def process_tts(client, chat_id, user_text, speaker_id, speaker_name):
             file_name = f"audio_{random.randint(1000, 999999)}.wav"
             with open(file_name, "wb") as f: f.write(audio_bytes)
             
-            uploaded_directly = False
+            await asyncio.sleep(1)
             
-            # 🚨 تست تمام حالت‌های آپلود ویس برای دور زدن باگ Rubpy
-            try:
-                await client.send_message(chat_id, file=file_name)
-                uploaded_directly = True
-            except Exception: pass
-
-            if not uploaded_directly:
-                try:
-                    await client.send_voice(chat_id, voice=file_name)
-                    uploaded_directly = True
-                except Exception: pass
-
-            if not uploaded_directly:
-                try:
-                    await client.send_voice(chat_id, file_name)
-                    uploaded_directly = True
-                except Exception: pass
-
-            if not uploaded_directly:
-                try:
-                    await client.send_audio(chat_id, audio=file_name)
-                    uploaded_directly = True
-                except Exception: pass
-
-            if not uploaded_directly:
-                try:
-                    await client.send_document(chat_id, document=file_name)
-                    uploaded_directly = True
-                except Exception: pass
-                
-            if not uploaded_directly:
-                try:
-                    await client.send_document(chat_id, file=file_name)
-                    uploaded_directly = True
-                except Exception: pass
-
-            if uploaded_directly:
-                await send_with_keyboard(client, chat_id, "✅ پردازش صدا انجام شد.", True)
+            # استفاده از تابع هوشمند برای آپلود
+            upload_result = await helper_upload_file(client, chat_id, file_name, "voice", "")
+            
+            if upload_result is True:
+                await send_with_keyboard(client, chat_id, "✅ صدای شما با موفقیت ارسال شد.", True)
             else:
-                await send_with_keyboard(client, chat_id, f"❌ صدا در سرور ساخته شد اما متدهای کتابخانه روبیکا برای آپلود ویس ناموفق بودند!", True)
+                err_msg = str(upload_result)[:800]
+                await send_with_keyboard(client, chat_id, f"❌ صدا ساخته شد، اما روبیکا در آپلود آن ارور داد.\n\n🔴 لاگ ارور برنامه‌نویس:\n`{err_msg}`", True)
                 
             if os.path.exists(file_name): os.remove(file_name)
         else:
@@ -482,7 +461,7 @@ async def process_stt(client, chat_id, audio_bytes):
         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 transcribed_text:
@@ -519,7 +498,7 @@ async def process_file_analysis(client, chat_id, file_bytes, file_name, prompt):
         for key in keys_to_try:
             url = f"https://generativelanguage.googleapis.com/v1beta/models/gemini-2.5-flash:generateContent?key={key}"
             payload = {
-                "contents": [{"parts":[{"text": prompt}, {"inlineData": {"mimeType": mime_type, "data": base64_data}}]}],
+                "contents":[{"parts":[{"text": prompt}, {"inlineData": {"mimeType": mime_type, "data": base64_data}}]}],
                 "generationConfig": {"temperature": 0.6, "maxOutputTokens": 8192}
             }
             try:
@@ -592,7 +571,7 @@ else:
                 await send_with_keyboard(client, chat_id, "سلام! به ربات هوشمند آلفا خوش آمدید 🤖\n\nلطفاً برای شروع، از کیبورد پایین یکی از بخش‌ها را انتخاب کنید:", True)
                 return
 
-            if user_text_str in ["/chat", "💬 چت", "چت با هوش مصنوعی 🤖"]:
+            if user_text_str in["/chat", "💬 چت", "چت با هوش مصنوعی 🤖"]:
                 user_states[chat_id] = {"mode": "chat", "text": "", "history":[]}
                 await send_with_keyboard(client, chat_id, "💬 شما وارد بخش **چت با هوش مصنوعی** شدید.\n(حالا ربات سابقه گفتگو را به یاد می‌آورد)\n\nهر سوالی دارید بفرستید تا جواب بدم:\n\n(برای خروج دکمه «برگشت♻️» را بزنید)", True)
                 return