Update app.py

app.py

@@ -108,7 +108,7 @@ def get_file_stream(message_id):
                 await asyncio.to_thread(q.put, None)
                 return
             
-            # ডাটা রিড করে থ্রেড-সেফ কিউ-তে রাখা হচ্ছে (asyncio.to_thread ব্যবহারের ফলে মেইন লুপ কখনো ফ্রিজ হবে না)
+            # ডাটা রিড করে থ্রেড-সেফ কিউ-তে রাখা হচ্ছে
             async for chunk in bot.stream_media(media):
                 await asyncio.to_thread(q.put, chunk)
         except Exception as e:
@@ -124,7 +124,7 @@ def get_file_stream(message_id):
         try:
             while True:
                 try:
-                    # সর্বোচ্চ ১৫ সেকেন্ড অপেক্ষা করবে, ফলে থ্রেড কখনো অনন্তকাল হ্যাং হবে না
+                    # সর্বোচ্চ ১৫ সেকেন্ড অপেক্ষা করবে
                     chunk = q.get(timeout=15)
                 except queue.Empty:
                     break
@@ -132,7 +132,7 @@ def get_file_stream(message_id):
                     break
                 yield chunk
         except GeneratorExit:
-            # ইউজার যদি মাঝপথে ব্রাউজার ট্যাব কেটে দেয়, তবে কিউ খালি করে ব্যাকগ্রাউন্ড থ্রেড রিলিজ করা হবে
+            # ইউজার যদি মাঝপথে ব্রাউজার ট্যাব কেটে দেয়
             while not q.empty():
                 try: q.get_nowait()
                 except: break
@@ -420,7 +420,7 @@ async def send_to_specific_group(client, message):
     
     args = message.command
     if len(args) < 2:
-        return await message.reply("❌ <b>Group ID missing!</b>\n\nCorrect format:\n`/sendto -1001234567890`")
+        return await message.reply("❌ <b>Group ID missing!</b>\n\nCorrect format:\n`/sendto -1003973566529`")
         
     try:
         group_id = int(args[1])
@@ -616,7 +616,6 @@ def upload_file_sync(upload_url, file_path, api_key):
     except Exception as e:
         return {}
 
-# filters.document যুক্ত করা হলো যাতে ফাইল/ডকুমেন্ট হিসেবে ভিডিও পাঠালেও বট প্রসেস করতে পারে
 @bot.on_message((filters.video | filters.animation | filters.photo | filters.document) & filters.private & filters.user(ADMIN_IDS))
 async def handle_media_upload(client, message):
     global upload_mode
@@ -625,16 +624,13 @@ async def handle_media_upload(client, message):
         await process_broadcast(client, message)
         return
 
-    # ফাইলটি ভিডিও, জিআইএফ নাকি ফটো তা নিখুঁতভাবে চেক করা হচ্ছে
     is_video = message.video or (message.document and message.document.mime_type and "video" in message.document.mime_type)
     is_animation = message.animation or (message.document and message.document.mime_type and "gif" in message.document.mime_type)
     is_photo = message.photo or (message.document and message.document.mime_type and "image" in message.document.mime_type)
 
-    # যদি ভিডিও, ফটো বা অ্যানিমেশন না হয় তবে কাস্টম ফাইল স্কিপ করবে
     if not (is_video or is_animation or is_photo):
         return
 
-    # FORCE ANIMATIONS (GIFS) TO BE TREATED AS VIDEOS FOR BROADCAST STABILITY
     media_type = "video" if (is_video or is_animation) else "photo"
     has_blur_caption = message.caption and "/blur" in message.caption.lower()
     is_persistent_blur = bool(state.get("blur_percent"))
@@ -675,7 +671,6 @@ async def handle_media_upload(client, message):
 
     is_large_video = False
     if media_type == "video":
-        # Safe size checks for both Videos and Animations (GIFs/Documents)
         media = get_media_obj(message)
         duration = media.duration if media and hasattr(media, 'duration') and media.duration else 0
         file_size = media.file_size if media and hasattr(media, 'file_size') and media.file_size else 0
@@ -693,7 +688,6 @@ async def handle_media_upload(client, message):
     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()
     async def download_progress(current, total):
         nonlocal last_update_time
@@ -705,18 +699,15 @@ async def handle_media_upload(client, message):
                 last_update_time = now
             except Exception:
                 pass
-    # =============================
     
     try:
         original_file = await message.download(progress=download_progress)
         clean_upload_file = original_file 
         
-        # ১. ওয়াটারমার্ক (Watermark) করা - Balanced (Superfast + CRF 23)
         if media_type == "video" and not is_large_video:
             await status_msg.edit_text("⏳ Watermarking video... (HD + Superfast Processing)")
             watermarked_file = f"{original_file}_wm.mp4"
             
-            # জাইএফ ফাইলের ক্ষেত্রে অডিও ট্র্যাক বাদ দেওয়া হবে (-an) অন্যথায় কপি করা হবে
             has_audio = not (message.animation or (message.document and message.document.mime_type and "gif" in message.document.mime_type))
             audio_opts = ["-an"] if not has_audio else ["-c:a", "copy"]
             
@@ -730,18 +721,14 @@ 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) and os.path.getsize(watermarked_file) > 0: 
                 clean_upload_file = watermarked_file
 
-        # ২. আপনার নিজের টেলিগ্রাম স্টোরেজ চ্যানেলে ফাইল আপলোড (ভিডিও বা ফটো)
-        # এখানে থাম্বনেইল, সঠিক ডিউরেশন এবং সাইজ জেনারেট করে পোস্ট করা হবে যাতে সাদা ০:০০ শো না করে
         storage_msg_id = None
         if media_type in ["video", "photo"]:
             if upload_mode == "telegram":
                 await status_msg.edit_text("⏳ Uploading Clean HD video to your storage channel...")
                 
-                # স্টোরেজ চ্যানেলেও অরিজিনাল থাম্বনেইল, ডিউরেশন এবং সাইজ জেনারেট করে পাঠানো হচ্ছে যাতে সাদা ০:০০ শো না করে
                 thumb_path_storage = f"{original_file}_storage_thumb.jpg"
                 proc = await asyncio.create_subprocess_exec("ffmpeg", "-y", "-i", clean_upload_file, "-vframes", "1", thumb_path_storage, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE)
                 await proc.communicate()
@@ -764,12 +751,10 @@ async def handle_media_upload(client, message):
                 )
                 storage_msg_id = sent_to_channel.id
                 
-                # আপনার নিজস্ব ডোমেইন বা সার্ভারের স্ট্রিমিং ও ডিরেক্ট ডাউনলোড লিংক জেনারেট
                 stream_link = f"{BACKEND_URL}/stream/{storage_msg_id}"
                 download_link = f"{BACKEND_URL}/download/{storage_msg_id}"
                 embed_link = stream_link
             else:
-                # Byse.sx আপলোড মোড
                 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()
@@ -799,7 +784,6 @@ 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...")
@@ -815,7 +799,6 @@ async def handle_media_upload(client, message):
             else:
                 ff_filter = ["-vf", f"boxblur={radius}:1"]
             
-            # জাইএফ ফাইলের ক্ষেত্রে অডিও ট্র্যাক বাদ দেওয়া হবে (-an) অন্যথায় কপি করা হবে
             has_audio = not (message.animation or (message.document and message.document.mime_type and "gif" in message.document.mime_type))
             audio_opts_blur = ["-an"] if not has_audio else []
             
@@ -827,7 +810,6 @@ async def handle_media_upload(client, message):
             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) and os.path.getsize(blurred_file) > 0: 
                 telegram_file = blurred_file
 
@@ -839,7 +821,6 @@ async def handle_media_upload(client, message):
         
         group_markup = InlineKeyboardMarkup([[InlineKeyboardButton("🎬 Watch Full Video Here 🔞", url=bot_link)]])
         
-        # অ্যাডমিন চ্যাটে সাকসেস মেসেজ ও লিংক পাঠানো হচ্ছে
         admin_cap = (
             f"✅ <b>Upload and Processing Complete!</b>\n\n"
             f"🎬 <b>Stream/Watch Online Link:</b>\n<code>{stream_link}</code>\n\n"
@@ -856,7 +837,6 @@ async def handle_media_upload(client, message):
         if media_type == "photo":
             sent_to_admin = await client.send_photo(message.chat.id, telegram_file, caption=admin_cap, parse_mode=enums.ParseMode.HTML)
         else:
-            # Safe dimensions extraction for Videos and Animations
             media = get_media_obj(message)
             vid_duration = media.duration if media and hasattr(media, 'duration') and media.duration else 0
             vid_width = media.width if media and hasattr(media, 'width') and media.width else 0
@@ -873,10 +853,9 @@ async def handle_media_upload(client, message):
                 thumb=thumb_path
             )
             
-        # ক্র্যাশ-ফ্রি উপায়ে file_id রিড করার জন্য ইউনিভার্সাল এক্সট্রাক্টর
         tg_file_id = get_msg_file_id(sent_to_admin)
         if not tg_file_id:
-            tg_file_id = get_msg_file_id(message) # Fallback to original
+            tg_file_id = get_msg_file_id(message)
             
         await status_msg.delete()
         
@@ -907,7 +886,7 @@ async def handle_media_upload(client, message):
     except Exception as e: await message.reply(f"⚠️ Error occurred: {str(e)}")
     finally:
         for f in [original_file, watermarked_file, blurred_file, f"{original_file}_thumb.jpg" if original_file else None, f"{original_file}_storage_thumb.jpg" if original_file else None]:
-            if f && os.path.exists(f):
+            if f and os.path.exists(f):
                 try: os.remove(f)
                 except: pass
 
@@ -1047,7 +1026,7 @@ async def catch_admin_steps(client, message):
     elif state.get("step") == "broadcast":
         await process_broadcast(client, message)
 
-def run_flask(): app.run(host="0.0.0.0", port=int(os.environ.get("PORT", 7860)), threaded=True) # Multithreading explicitly enabled
+def run_flask(): app.run(host="0.0.0.0", port=int(os.environ.get("PORT", 7860)), threaded=True) 
 
 async def main():
     await bot.start()