Update main.py

main.py

@@ -88,11 +88,10 @@ async def download_youtube_rapidapi(url, chat_id, message_id, client):
         }
 
         async with aiohttp.ClientSession(headers=headers) as session:
-            # مرحله 1: شروع دانلود
+            # مرحله 1: شروع دانلود (مسیر اصلاح شد: downloadVideo)
             payload = {"url": url, "format": "mp4", "quality": 720}
-            async with session.post(f"{API_BASE}/v1/download", json=payload) as resp:
+            async with session.post(f"{API_BASE}/downloadVideo", json=payload) as resp:
                 
-                # 🟢 بخش نمایش دقیق لاگ سرور
                 if resp.status != 200:
                     server_log = await resp.text()
                     error_message = (
@@ -112,14 +111,21 @@ async def download_youtube_rapidapi(url, chat_id, message_id, client):
                 if not job_id:
                     raise Exception(f"سرور شناسه Job ID را برنگرداند. پاسخ سرور:\n{start_data}")
                 
+                # خواندن داینامیک مسیر وضعیت از پاسخی که خود سرور برمی‌گرداند
+                status_path = start_data.get("statusUrl", f"/status/{job_id}")
+                if status_path.startswith("/"):
+                    status_url = API_BASE + status_path
+                else:
+                    status_url = f"{API_BASE}/{status_path}"
+                
                 if status_msg_id:
                     try: await client.edit_message_text(chat_id, status_msg_id, "⏳ ویدیو در سرور رپید در حال پردازش است (در حال بررسی وضعیت...)")
                     except: pass
 
-                # مرحله 2: بررسی وضعیت پردازش (Polling) هر 3 ثانیه
+                # مرحله 2: بررسی وضعیت پردازش
                 while True:
                     await asyncio.sleep(3)
-                    async with session.get(f"{API_BASE}/v1/status/{job_id}", headers=headers) as status_resp:
+                    async with session.get(status_url) as status_resp:
                         if status_resp.status != 200:
                             status_log = await status_resp.text()
                             raise Exception(f"خطا در بررسی وضعیت (کد {status_resp.status}).\nلاگ:\n{status_log}")
@@ -141,7 +147,7 @@ async def download_youtube_rapidapi(url, chat_id, message_id, client):
                 try: await client.edit_message_text(chat_id, status_msg_id, "📥 پردازش موفق! در حال دانلود ویدیو از سرور واسط...")
                 except: pass
 
-            # مرحله 3: دانلود فایل نهایی در سرور خودمان
+            # مرحله 3: دانلود فایل نهایی (آدرس دانلود هم نیاز به توکن دارد که توسط سشن ارسال می‌شود)
             temp_dir = "/app/downloads"
             os.makedirs(temp_dir, exist_ok=True)
             filename = f"youtube_{uuid.uuid4().hex[:6]}.mp4"
@@ -158,10 +164,9 @@ async def download_youtube_rapidapi(url, chat_id, message_id, client):
             return file_path, filename, status_msg_id
 
     except Exception as e:
-        # نمایش خطای کامل در ربات
         error_msg = f"❌ خطای یوتیوب:\n{str(e)}"
         if status_msg_id:
-            try: await client.edit_message_text(chat_id, status_msg_id, error_msg[:1000]) # محدودیت متن روبیکا
+            try: await client.edit_message_text(chat_id, status_msg_id, error_msg[:1000])
             except: pass
         return None, None, status_msg_id