Update app.py

app.py

@@ -1094,12 +1094,18 @@ async def process_single_video(task, redis_client):
     wm_text = task['watermark_text']
     task_id = f"{owner_id}_{message_id}"
     
-    print(f"▶️ [WM] Task Started for User: {owner_id}, Msg: {message_id}")
+    # ==============================
+    # FIX: আগে ভেরিয়েবল ডিফাইন করা হলো যাতে finally ব্লকে এরর না আসে
+    raw_video_path = None
+    watermarked_path = None
+    thumb_path = f"thumb_{task_id}.jpg"
+    clone_client = None
+    # ==============================
     
-    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" # থাম্বনেইল এর ভেরিয়েবল
+    print(f"▶️ [WM] Task Started for User: {owner_id}, Msg: {message_id}")
     
     try:
+        clone_client = Client(f"clone_wm_{task_id}", bot_token=clone_token, api_id=API_ID, api_hash=API_HASH, in_memory=True)
         await clone_client.start()
         print(f"▶️ [WM] Clone Client Started Successfully")
         
@@ -1108,7 +1114,6 @@ async def process_single_video(task, redis_client):
             raise Exception("Video not found or deleted by user.")
             
         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}")
@@ -1123,7 +1128,6 @@ 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 video Uploaded to Storage")
         
         await clone_client.edit_message_text(owner_id, status_msg.id, "⏳ <b>ওয়াটারমার্ক যুক্ত করা হচ্ছে... (কিছুক্ষণ সময় লাগতে পারে)</b>", parse_mode=enums.ParseMode.HTML)
         
@@ -1136,25 +1140,19 @@ async def process_single_video(task, redis_client):
             "-c:a", "copy", "-movflags", "+faststart", watermarked_path
         ]
         
-        print(f"▶️ [WM] Starting FFmpeg processing...")
         process = await asyncio.create_subprocess_exec(*cmd, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE)
         stdout, stderr = await process.communicate()
         
         if process.returncode != 0 or not os.path.exists(watermarked_path) or os.path.getsize(watermarked_path) == 0:
-            print(f"❌ [WM] FFmpeg Error: {stderr.decode()}")
             raise Exception("FFmpeg processing failed! The video format might be unsupported.")
             
         print(f"▶️ [WM] FFmpeg Processing Complete!")
         
-        # ==========================================
-        # থাম্বনেইল জেনারেট করা হচ্ছে
-        # ==========================================
         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)
         
@@ -1162,9 +1160,8 @@ async def process_single_video(task, redis_client):
             chat_id=STORAGE_CHANNEL_ID,
             video=watermarked_path,
             caption=f"Watermarked Backup for Clone Owner {owner_id}",
-            thumb=thumb_path # থাম্বনেইল যুক্ত করা হলো
+            thumb=thumb_path
         )
-        print(f"▶️ [WM] Watermarked Backup Uploaded to Storage")
         
         final_caption = (
             f"✅ <b>Watermark Successfully Added!</b>\n\n"
@@ -1177,26 +1174,28 @@ async def process_single_video(task, redis_client):
             video=watermarked_path,
             caption=final_caption,
             parse_mode=enums.ParseMode.HTML,
-            thumb=thumb_path # থাম্বনেইল যুক্ত করা হলো
+            thumb=thumb_path
         )
-        print(f"▶️ [WM] Final Video Sent to User Successfully!")
         
         await clone_client.delete_messages(owner_id, status_msg.id)
         
     except Exception as e:
         print(f"❌ [WM] Process Error: {e}")
         try:
-            await clone_client.send_message(owner_id, f"❌ <b>Error processing video:</b> {e}", parse_mode=enums.ParseMode.HTML)
+            if clone_client and clone_client.is_connected:
+                await clone_client.send_message(owner_id, f"❌ <b>Error processing video:</b> {e}", parse_mode=enums.ParseMode.HTML)
         except Exception as ex: 
             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 raw_video_path and os.path.exists(raw_video_path): os.remove(raw_video_path)
+        if watermarked_path and 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()
+        if clone_client and clone_client.is_connected:
+            await clone_client.stop()
+            
         await redis_client.delete(f"wm_processing:{owner_id}")
         processing_owners.discard(owner_id) 
         print(f"▶️ [WM] Task Cleaned Up and Client Stopped")