Update app.py

app.py

@@ -1097,6 +1097,7 @@ async def process_single_video(task, redis_client):
     print(f"▶️ [WM] Task Started for User: {owner_id}, Msg: {message_id}")
     
     clone_client = Client(f"clone_wm_{task_id}", bot_token=clone_token, api_id=API_ID, api_hash=API_HASH, in_memory=True)
+    thumb_path = f"thumb_{task_id}.jpg" # থাম্বনেইল এর ভেরিয়েবল
     
     try:
         await clone_client.start()
@@ -1106,13 +1107,13 @@ async def process_single_video(task, redis_client):
         if not msg or not (msg.video or msg.document):
             raise Exception("Video not found or deleted by user.")
             
-        status_msg = await clone_client.send_message(owner_id, "⏳ <b>Video processing started...</b>", parse_mode=enums.ParseMode.HTML)
+        status_msg = await clone_client.send_message(owner_id, "⏳ <b>ভিডিও প্রসেসিং শুরু হয়েছে...</b>", parse_mode=enums.ParseMode.HTML)
         print(f"▶️ [WM] Status Message Sent to User")
         
         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>Uploading original file to secure storage...</b>", parse_mode=enums.ParseMode.HTML)
+        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,
@@ -1122,9 +1123,9 @@ async def process_single_video(task, redis_client):
         raw_storage_id = raw_sent.id
         stream_link = f"{BACKEND_URL}/stream/{raw_storage_id}"
         download_link = f"{BACKEND_URL}/download/{raw_storage_id}"
-        print(f"▶️ [WM] Original Backup Uploaded to Storage")
+        print(f"▶️ [WM] Original video Uploaded to Storage")
         
-        await clone_client.edit_message_text(owner_id, status_msg.id, "⏳ <b>Applying Custom Watermark... (This may take a few minutes)</b>", parse_mode=enums.ParseMode.HTML)
+        await clone_client.edit_message_text(owner_id, status_msg.id, "⏳ <b>ওয়াটারমার্ক যুক্ত করা হচ্ছে... (কিছুক্ষণ সময় লাগতে পারে)</b>", parse_mode=enums.ParseMode.HTML)
         
         watermarked_path = f"wm_{task_id}.mp4"
         
@@ -1144,12 +1145,24 @@ async def process_single_video(task, redis_client):
             raise Exception("FFmpeg processing failed! The video format might be unsupported.")
             
         print(f"▶️ [WM] FFmpeg Processing Complete!")
-        await clone_client.edit_message_text(owner_id, status_msg.id, "⏳ <b>Uploading final video...</b>", parse_mode=enums.ParseMode.HTML)
+        
+        # ==========================================
+        # থাম্বনেইল জেনারেট করা হচ্ছে
+        # ==========================================
+        thumb_cmd = ["ffmpeg", "-y", "-i", watermarked_path, "-vframes", "1", thumb_path]
+        t_proc = await asyncio.create_subprocess_exec(*thumb_cmd, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE)
+        await t_proc.communicate()
+        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 bot.send_video(
             chat_id=STORAGE_CHANNEL_ID,
             video=watermarked_path,
-            caption=f"Watermarked Backup for Clone Owner {owner_id}"
+            caption=f"Watermarked Backup for Clone Owner {owner_id}",
+            thumb=thumb_path # থাম্বনেইল যুক্ত করা হলো
         )
         print(f"▶️ [WM] Watermarked Backup Uploaded to Storage")
         
@@ -1163,15 +1176,13 @@ async def process_single_video(task, redis_client):
             chat_id=owner_id,
             video=watermarked_path,
             caption=final_caption,
-            parse_mode=enums.ParseMode.HTML
+            parse_mode=enums.ParseMode.HTML,
+            thumb=thumb_path # থাম্বনেইল যুক্ত করা হলো
         )
         print(f"▶️ [WM] Final Video Sent to User Successfully!")
         
         await clone_client.delete_messages(owner_id, status_msg.id)
         
-        if os.path.exists(raw_video_path): os.remove(raw_video_path)
-        if os.path.exists(watermarked_path): os.remove(watermarked_path)
-        
     except Exception as e:
         print(f"❌ [WM] Process Error: {e}")
         try:
@@ -1180,6 +1191,11 @@ async def process_single_video(task, redis_client):
             print(f"❌ [WM] Failed to send error msg to user: {ex}")
         
     finally:
+        # ফাইলগুলো সার্ভার থেকে ডিলিট করে ক্লিন করা হচ্ছে
+        if os.path.exists(raw_video_path): os.remove(raw_video_path)
+        if os.path.exists(watermarked_path): os.remove(watermarked_path)
+        if thumb_path and os.path.exists(thumb_path): os.remove(thumb_path)
+        
         await clone_client.stop()
         await redis_client.delete(f"wm_processing:{owner_id}")
         processing_owners.discard(owner_id)