Update app.py

app.py

@@ -369,7 +369,8 @@ async def handle_media_upload(client, message):
     bot_me = client.me if client.me else await client.get_me()
     bot_link = f"https://t.me/{bot_me.username}"
     
-    original_file, watermarked_file, blurred_file, final_file, embed_link = None, None, None, None, None
+    original_file, watermarked_file, blurred_file = None, None, None
+    clean_upload_file, telegram_file, embed_link = None, None, None
     
     # === Progress Bar Function ===
     last_update_time = time.time()
@@ -387,9 +388,9 @@ async def handle_media_upload(client, message):
     
     try:
         original_file = await message.download(progress=download_progress)
-        final_file = original_file
+        clean_upload_file = original_file # ডিফল্টভাবে অরিজিনাল ফাইলই ক্লিন ফাইল
         
-        # High Quality Video Output Settings (-crf 22, -preset fast, -c:a copy)
+        # ১. ওয়াটারমার্ক (Watermark) করা - HD Quality
         if media_type == "video" and not is_large_video:
             await status_msg.edit_text("⏳ Watermarking video... (High Quality Processing)")
             watermarked_file = f"{original_file}_wm.mp4"
@@ -401,42 +402,19 @@ async def handle_media_upload(client, message):
             ]
             process = await asyncio.create_subprocess_exec(*cmd, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE)
             await process.communicate()
-            if process.returncode == 0 and os.path.exists(watermarked_file): final_file = watermarked_file
-            
-        if is_blur and not is_large_video:
-            await status_msg.edit_text(f"⏳ Applying {blur_percent}% blur... (High Quality Processing)")
-            radius = max(2, min(20, int((blur_percent / 100.0) * 30)))
-            ext = "jpg" if media_type == "photo" else "mp4"
-            blurred_file = f"{original_file}_blurred.{ext}"
-            
-            if clear_percent > 0:
-                clear_ratio = clear_percent / 100.0
-                ff_filter = ["-filter_complex", f"[0:v]split[v1][v2];[v2]boxblur={radius}:1[blurred];[v1]crop=iw:ih*{clear_ratio}:0:0[top];[blurred][top]overlay=0:0[vout]", "-map", "[vout]"]
-                if media_type == "video":
-                    ff_filter.extend(["-map", "0:a?"])
-            else:
-                ff_filter = ["-vf", f"boxblur={radius}:1"]
-            
-            if media_type == "photo": 
-                cmd_blur = ["ffmpeg", "-y", "-i", final_file] + ff_filter + [blurred_file]
-            elif media_type == "animation": 
-                cmd_blur = ["ffmpeg", "-y", "-i", final_file] + ff_filter + ["-c:v", "libx264", "-preset", "fast", "-threads", "2", "-pix_fmt", "yuv420p", blurred_file]
-            else: 
-                cmd_blur = ["ffmpeg", "-y", "-i", final_file] + ff_filter + ["-c:v", "libx264", "-preset", "fast", "-threads", "2", "-crf", "22", "-pix_fmt", "yuv420p", "-c:a", "copy", "-movflags", "+faststart", blurred_file]
-            
-            process_blur = await asyncio.create_subprocess_exec(*cmd_blur, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE)
-            await process_blur.communicate()
-            if process_blur.returncode == 0 and os.path.exists(blurred_file): final_file = blurred_file
+            if process.returncode == 0 and os.path.exists(watermarked_file): 
+                clean_upload_file = watermarked_file
 
+        # ২. byse.sx সার্ভারে HD / Clean ভিডিও আপলোড করা
         if media_type == "video":
-            await status_msg.edit_text("⏳ Uploading video to byse.sx server...")
+            await status_msg.edit_text("⏳ Uploading Clean HD video to byse.sx server...")
             api_endpoint = "https://api.byse.sx/upload/server"
             loop = asyncio.get_event_loop()
             response = await loop.run_in_executor(None, lambda: requests.get(api_endpoint, params={'key': BYSE_API_KEY}, timeout=30))
             result = response.json()
             
             if result.get('status') == 200:
-                upload_res = await loop.run_in_executor(None, upload_file_sync, result.get('result'), final_file, BYSE_API_KEY)
+                upload_res = await loop.run_in_executor(None, upload_file_sync, result.get('result'), clean_upload_file, BYSE_API_KEY)
                 if upload_res.get('status') == 200 and 'files' in upload_res and len(upload_res['files']) > 0:
                     file_status = upload_res['files'][0].get('status', '')
                     if "not allowed" in str(file_status).lower():
@@ -455,6 +433,34 @@ async def handle_media_upload(client, message):
             await status_msg.delete()
             return  
 
+        # ৩. টেলিগ্রামে পাঠানোর জন্য ভিডিও ব্লার করা (যদি ব্লার অন থাকে)
+        telegram_file = clean_upload_file
+        if is_blur and not is_large_video:
+            await status_msg.edit_text(f"⏳ Applying {blur_percent}% blur for Telegram broadcast...")
+            radius = max(2, min(20, int((blur_percent / 100.0) * 30)))
+            ext = "jpg" if media_type == "photo" else "mp4"
+            blurred_file = f"{original_file}_blurred.{ext}"
+            
+            if clear_percent > 0:
+                clear_ratio = clear_percent / 100.0
+                ff_filter = ["-filter_complex", f"[0:v]split[v1][v2];[v2]boxblur={radius}:1[blurred];[v1]crop=iw:ih*{clear_ratio}:0:0[top];[blurred][top]overlay=0:0[vout]", "-map", "[vout]"]
+                if media_type == "video":
+                    ff_filter.extend(["-map", "0:a?"])
+            else:
+                ff_filter = ["-vf", f"boxblur={radius}:1"]
+            
+            if media_type == "photo": 
+                cmd_blur = ["ffmpeg", "-y", "-i", clean_upload_file] + ff_filter + [blurred_file]
+            elif media_type == "animation": 
+                cmd_blur = ["ffmpeg", "-y", "-i", clean_upload_file] + ff_filter + ["-c:v", "libx264", "-preset", "fast", "-threads", "2", "-pix_fmt", "yuv420p", blurred_file]
+            else: 
+                cmd_blur = ["ffmpeg", "-y", "-i", clean_upload_file] + ff_filter + ["-c:v", "libx264", "-preset", "fast", "-threads", "2", "-crf", "22", "-pix_fmt", "yuv420p", "-c:a", "copy", "-movflags", "+faststart", blurred_file]
+            
+            process_blur = await asyncio.create_subprocess_exec(*cmd_blur, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE)
+            await process_blur.communicate()
+            if process_blur.returncode == 0 and os.path.exists(blurred_file): 
+                telegram_file = blurred_file
+
         await status_msg.edit_text("⏳ Preparing to broadcast to groups...")
         if media_type == "video":
             caption_text = f"🔥 <b>New Premium Viral Video Leaked!</b> 🔞\n\n🎬 <b>Watch HD Video Here:</b>\n👉 <b><a href='{embed_link if is_blur else bot_link}'>▶️ Click Here to Watch</a></b>\n\n👇 <i>Click the button below to open Bot!</i>"
@@ -462,20 +468,20 @@ async def handle_media_upload(client, message):
             caption_text = f"{clean_caption}\n\n👇 <i>Click the button below to open Bot!</i>" if clean_caption else f"🔥 <b>New Premium Viral Content!</b> 🔞\n\n🎬 <b>Watch HD Video Here:</b>\n👉 <b><a href='{bot_link}'>▶️ Click Here to Watch</a></b>\n\n👇 <i>Click the button below to open Bot!</i>"
         
         group_markup = InlineKeyboardMarkup([[InlineKeyboardButton("🎬 Watch Full Video Here 🔞", url=bot_link)]])
-        admin_cap = f"✅ <b>Success!</b> Media is broadcasting...\n\n🔗 <b>Embed Link:</b>\n<code>{embed_link or 'N/A'}</code>"
+        admin_cap = f"✅ <b>Success!</b> Media is broadcasting...\n\n🔗 <b>Embed Link (Clean HD):</b>\n<code>{embed_link or 'N/A'}</code>"
         
         thumb_path = None
         if media_type == "video":
             thumb_path = f"{original_file}_thumb.jpg"
-            proc = await asyncio.create_subprocess_exec("ffmpeg", "-y", "-i", final_file, "-vframes", "1", thumb_path, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE)
+            proc = await asyncio.create_subprocess_exec("ffmpeg", "-y", "-i", telegram_file, "-vframes", "1", thumb_path, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE)
             await proc.communicate()
             if not os.path.exists(thumb_path): thumb_path = None
 
         if media_type == "photo":
-            sent_to_admin = await client.send_photo(message.chat.id, final_file, caption=admin_cap, parse_mode=enums.ParseMode.HTML)
+            sent_to_admin = await client.send_photo(message.chat.id, telegram_file, caption=admin_cap, parse_mode=enums.ParseMode.HTML)
             tg_file_id = sent_to_admin.photo.file_id
         elif media_type == "animation":
-            sent_to_admin = await client.send_animation(message.chat.id, final_file, caption=admin_cap, parse_mode=enums.ParseMode.HTML)
+            sent_to_admin = await client.send_animation(message.chat.id, telegram_file, caption=admin_cap, parse_mode=enums.ParseMode.HTML)
             tg_file_id = sent_to_admin.animation.file_id
         else:
             vid_duration = message.video.duration if message.video and message.video.duration else 0
@@ -484,7 +490,7 @@ async def handle_media_upload(client, message):
             
             sent_to_admin = await client.send_video(
                 message.chat.id, 
-                final_file, 
+                telegram_file, 
                 caption=admin_cap, 
                 parse_mode=enums.ParseMode.HTML, 
                 duration=vid_duration,