Update app.py

app.py

@@ -74,7 +74,6 @@ def run_async(coro):
 bot = Client("file_unlocker_bot", api_id=API_ID, api_hash=API_HASH, bot_token=BOT_TOKEN)
 
 # ==================== ROBUST DB QUERY WITH AUTO-RETRY ====================
-# ডাটাবেজ কানেকশন ডিসকানেক্ট হলে যেন ক্র্যাশ না করে, সেজন্য 3-বার রিট্রাই করবে
 async def db_query(func, max_retries=3):
     last_error = None
     for attempt in range(max_retries):
@@ -85,7 +84,7 @@ async def db_query(func, max_retries=3):
             err_msg = str(e).lower()
             if "terminated" in err_msg or "disconnect" in err_msg or "timeout" in err_msg or "connection" in err_msg:
                 if attempt < max_retries - 1:
-                    await asyncio.sleep(1.5)  # একটু অপেক্ষা করে আবার ট্রাই করবে
+                    await asyncio.sleep(1.5)  
                     continue
             raise e
     raise last_error
@@ -394,6 +393,7 @@ async def start(client, message):
         await message.reply(welcome_text, parse_mode=enums.ParseMode.HTML, reply_markup=markup)
     except Exception as e: print(f"Start error: {e}")
 
+# ================= NEW: AUTO BROADCAST TO NEW GROUPS =================
 @bot.on_message(filters.new_chat_members)
 async def bot_added_to_group(client, message):
     me = client.me
@@ -404,18 +404,46 @@ async def bot_added_to_group(client, message):
     for member in message.new_chat_members:
         if member.id == me.id:
             try:
+                # 1. ডাটাবেজে গ্রুপ সেভ করা
                 await db_query(lambda: supabase.table('groups').upsert({
                     'group_id': message.chat.id,
                     'group_name': message.chat.title,
                     'added_by': message.from_user.id if message.from_user else None
                 }).execute())
                 
+                # 2. এডমিনকে নোটিফিকেশন দেওয়া
                 group_name = message.chat.title
                 admin_msg = f"✅ <b>Bot added to a new group!</b>\n\n📌 <b>Group Name:</b> {group_name}\n🆔 <b>ID:</b> <code>{message.chat.id}</code>"
                 for admin_id in ADMIN_IDS:
                     try: await client.send_message(chat_id=admin_id, text=admin_msg, parse_mode=enums.ParseMode.HTML)
                     except: pass
-            except: pass
+                
+                # 3. স্টোরেজ চ্যানেল থেকে সর্বশেষ ভিডিওটি নিয়ে এই গ্রুপে ব্রডকাস্ট করা
+                bot_link = f"https://t.me/{me.username}"
+                caption_text = f"🔥 <b>New Premium Viral Video Leaked!</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)]])
+
+                last_media_msg = None
+                async for msg in client.get_chat_history(STORAGE_CHANNEL_ID, limit=10):
+                    if msg.video or msg.photo or msg.animation or msg.document:
+                        last_media_msg = msg
+                        break
+                        
+                if last_media_msg:
+                    media_file_id = get_msg_file_id(last_media_msg)
+                    is_photo = bool(last_media_msg.photo)
+                    
+                    if media_file_id:
+                        # একটু অপেক্ষা করে মেসেজ পাঠানো (যাতে টেলিগ্রাম স্প্যাম না ভাবে)
+                        await asyncio.sleep(2)
+                        if is_photo:
+                            await client.send_photo(message.chat.id, media_file_id, caption=caption_text, parse_mode=enums.ParseMode.HTML, reply_markup=group_markup)
+                        else:
+                            await client.send_video(message.chat.id, media_file_id, caption=caption_text, parse_mode=enums.ParseMode.HTML, reply_markup=group_markup)
+                            
+            except Exception as e:
+                print(f"Error handling new group logic: {e}")
+# =====================================================================
 
 @bot.on_message(filters.command("sendto") & filters.private & filters.user(ADMIN_IDS))
 async def send_to_specific_group(client, message):