Update app.py

app.py

@@ -14,7 +14,6 @@ from pyrogram.types import InlineKeyboardMarkup, InlineKeyboardButton, WebAppInf
 urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning)
 
 # ================= CONFIGURATION =================
-# শুধুমাত্র Hugging Face Secrets থেকে ভ্যালু নেওয়া হচ্ছে। এখানে কোনো টোকেন দেওয়া নেই।
 BOT_TOKEN = os.environ.get("BOT_TOKEN")
 API_ID = int(os.environ.get("API_ID", 0))         
 API_HASH = os.environ.get("API_HASH")     
@@ -366,31 +365,46 @@ async def handle_media_upload(client, message):
             is_large_video = True
             is_blur = False
 
-    status_msg = await message.reply("⏳ <b>Video is too large!</b> Skipping blur..." if is_large_video else "⏳ Downloading media...")
+    status_msg = await message.reply("⏳ <b>Video is too large!</b> Skipping blur..." if is_large_video else "⏳ Downloading media... 0%")
     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
     
+    # === Progress Bar Function ===
+    last_update_time = time.time()
+    async def download_progress(current, total):
+        nonlocal last_update_time
+        now = time.time()
+        if now - last_update_time >= 4.0: 
+            try:
+                percent = (current / total) * 100
+                await status_msg.edit_text(f"⏳ Downloading media... {percent:.1f}%")
+                last_update_time = now
+            except Exception:
+                pass
+    # =============================
+    
     try:
-        original_file = await message.download()
+        original_file = await message.download(progress=download_progress)
         final_file = original_file
         
+        # High Quality Video Output Settings (-crf 22, -preset fast, -c:a copy)
         if media_type == "video" and not is_large_video:
-            await status_msg.edit_text("⏳ Watermarking video... (Fast processing)")
+            await status_msg.edit_text("⏳ Watermarking video... (High Quality Processing)")
             watermarked_file = f"{original_file}_wm.mp4"
             cmd = [
                 "ffmpeg", "-y", "-i", original_file,
                 "-vf", "drawtext=text='@mxvdo':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", "ultrafast", "-threads", "2", "-crf", "28",
-                "-pix_fmt", "yuv420p", "-c:a", "aac", "-b:a", "128k", "-movflags", "+faststart", watermarked_file
+                "-c:v", "libx264", "-preset", "fast", "-threads", "2", "-crf", "22",
+                "-pix_fmt", "yuv420p", "-c:a", "copy", "-movflags", "+faststart", watermarked_file
             ]
             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...")
+            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}"
@@ -403,9 +417,12 @@ async def handle_media_upload(client, message):
             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", "ultrafast", "-threads", "2", "-pix_fmt", "yuv420p", blurred_file]
-            else: cmd_blur = ["ffmpeg", "-y", "-i", final_file] + ff_filter + ["-c:v", "libx264", "-preset", "ultrafast", "-threads", "2", "-crf", "28", "-pix_fmt", "yuv420p", "-c:a", "aac", "-b:a", "128k", "-movflags", "+faststart", blurred_file]
+            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()
@@ -563,7 +580,6 @@ async def manual_clean_channel(client, message):
     try:
         kicked, checked = 0, 0
         
-        # ডাটাবেজ থেকে সব ইউজারের আইডি নিয়ে আসা
         res_users = await db_query(lambda: supabase.table('referrals').select('user_id').execute())
         if not res_users.data:
             await message.reply("❌ No users found in database!")
@@ -573,7 +589,6 @@ async def manual_clean_channel(client, message):
         
         for user_id in set(user_ids):
             try:
-                # বট চেক করবে এই ইউজারটি চ্যানেলে জয়েন করা আছে কিনা
                 chat_member = await client.get_chat_member(PREMIUM_CHANNEL_ID, user_id)
                 
                 if chat_member.status in [enums.ChatMemberStatus.MEMBER, enums.ChatMemberStatus.RESTRICTED]:
@@ -598,7 +613,7 @@ async def manual_clean_channel(client, message):
                     if not is_valid:
                         try:
                             await client.ban_chat_member(PREMIUM_CHANNEL_ID, user_id)
-                            await client.unban_chat_member(PREMIUM_CHANNEL_ID, user_id) # Kick only
+                            await client.unban_chat_member(PREMIUM_CHANNEL_ID, user_id) 
                             kicked += 1
                         except Exception: pass
                         
@@ -652,7 +667,7 @@ async def auto_clean_channel_loop():
         except Exception as e:
             print(f"Auto clean error: {e}")
         
-        await asyncio.sleep(4 * 3600) # প্রতি ৪ ঘণ্টা পর পর রান হবে
+        await asyncio.sleep(4 * 3600) 
 
 @bot.on_message(filters.private & filters.user(ADMIN_IDS) & ~filters.command(["start", "stats", "users", "broadcast", "png", "addvideo", "blur", "clean"]))
 async def catch_admin_steps(client, message):