Update app.py

app.py

@@ -1118,25 +1118,15 @@ async def process_single_video(task, redis_client):
         raw_video_path = await clone_client.download_media(msg)
         print(f"▶️ [WM] Original Video Downloaded: {raw_video_path}")
         
-        await clone_client.edit_message_text(owner_id, status_msg.id, "⏳ <b>অরিজিনাল ভিডিও স্টোরেজে আপলোড হচ্ছে...</b>", parse_mode=enums.ParseMode.HTML)
-        
-        raw_sent = await bot.send_video(
-            chat_id=STORAGE_CHANNEL_ID,
-            video=raw_video_path,
-            caption=f"Original Backup for Clone Owner {owner_id}"
-        )
-        raw_storage_id = raw_sent.id
-        stream_link = f"{BACKEND_URL}/stream/{raw_storage_id}"
-        download_link = f"{BACKEND_URL}/download/{raw_storage_id}"
-        
-        await clone_client.edit_message_text(owner_id, status_msg.id, "⏳ <b>ওয়াটারমার্ক যুক্ত করা হচ্ছে... (কিছুক্ষণ সময় লাগতে পারে)</b>", parse_mode=enums.ParseMode.HTML)
+        await clone_client.edit_message_text(owner_id, status_msg.id, "⏳ <b>ওয়াটারমার্ক যুক্ত করা হচ্ছে... (High Speed CPU Mode)</b>", parse_mode=enums.ParseMode.HTML)
         
         watermarked_path = f"wm_{task_id}.mp4"
         
+        # Hugging Face এ দ্রুত প্রসেস করার জন্য ultrafast, threads 4 এবং crf 26 ব্যবহার করা হলো
         cmd = [
             "ffmpeg", "-y", "-i", raw_video_path,
             "-vf", f"drawtext=text='{wm_text}':x=W-tw-20:y=H-th-20:fontsize=22:fontcolor=white@0.7:shadowcolor=black@0.8:shadowx=2:shadowy=2:enable='gte(t,5)'",
-            "-c:v", "libx264", "-preset", "superfast", "-crf", "23",
+            "-c:v", "libx264", "-preset", "ultrafast", "-crf", "26", "-threads", "4",
             "-c:a", "copy", "-movflags", "+faststart", watermarked_path
         ]
         
@@ -1154,15 +1144,28 @@ async def process_single_video(task, redis_client):
         if not os.path.exists(thumb_path) or os.path.getsize(thumb_path) == 0:
             thumb_path = None
         
-        await clone_client.edit_message_text(owner_id, status_msg.id, "⏳ <b>ফাইনাল ভিডিও আপলোড হচ্ছে...</b>", parse_mode=enums.ParseMode.HTML)
+        await clone_client.edit_message_text(owner_id, status_msg.id, "⏳ <b>ফাইনাল ভিডিও স্টোরেজে আপলোড হচ্ছে...</b>", parse_mode=enums.ParseMode.HTML)
         
-        await bot.send_video(
+        # Background এ অরিজিনাল ভিডিও স্টোরেজে পাঠানো হচ্ছে, যাতে ইউজারকে ওয়েট করতে না হয়
+        async def backup_raw_video():
+            try:
+                await bot.send_video(chat_id=STORAGE_CHANNEL_ID, video=raw_video_path, caption=f"Original Backup for Clone Owner {owner_id}")
+            except Exception: pass
+        asyncio.create_task(backup_raw_video())
+        
+        # ওয়াটারমার্ক করা ভিডিওটি আপলোড হচ্ছে (সঠিক Stream Link বানানোর জন্য)
+        wm_sent = await bot.send_video(
             chat_id=STORAGE_CHANNEL_ID,
             video=watermarked_path,
             caption=f"Watermarked Backup for Clone Owner {owner_id}",
             thumb=thumb_path
         )
         
+        # FIX: এখন লিংকগুলো অরিজিনালের বদলে ওয়াটারমার্ক ভিডিও পয়েন্ট করবে
+        wm_storage_id = wm_sent.id
+        stream_link = f"{BACKEND_URL}/stream/{wm_storage_id}"
+        download_link = f"{BACKEND_URL}/download/{wm_storage_id}"
+        
         final_caption = (
             f"✅ <b>Watermark Successfully Added!</b>\n\n"
             f"🎬 <b>Stream/Watch Online Link:</b>\n<code>{stream_link}</code>\n\n"