Upload 8 files

config.py

@@ -31,7 +31,7 @@ LINK_PATTERN_COMPILED = re.compile(
         r'com|net|org|edu|gov|mil|biz|info|mobi|name|'   # সাধারণ TLDs
         r'xyz|club|site|online|link|vip|pro|top|click|'  # স্প্যামারদের সস্তা TLDs
         r'shop|store|app|dev|me|tv|cc|ws|to|io|gg|bot|'  # টেক/গেমিং TLDs
-        r'tech|live|space|icu|cam|'
+        r'tech|live|space|icu|cam'
     r')\b'                                               # বাউন্ডারি
     r'|'                                                 # অথবা
     r'(?:(?:25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.){3}(?:25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)' # সরাসরি IP Address ব্লক (192.168.1.1)
@@ -76,6 +76,21 @@ DEFAULT_SPAM_PHRASES = [
     "get paid to chat", "make easy money", "instant cash", "𝐜𝐡𝐢𝐥𝐝 𝐩𝐨𝐫𝐧", "𝘀𝗲𝗹𝗹𝗲𝗿", "L0W PRlCE", "crypto payment"
 ]
 
+# --- Bio Check Settings ---
+# এই শব্দগুলো মেসেজে থাকলে বট প্রোফাইল চেক করবে
+BIO_TRIGGER_WORDS = [
+    # English
+    'bio', 'profile', 'link', 'see', 'look', 'check', 'visit', 'pinned', 'join',
+
+    # Bengali (বায়ো দেখার অনুরোধ)
+    'বায়ো', 'প্রোফাইল', 'লিংক', 'লিন্ক', 'দেখো', 'দেখুন', 'পিন', 'ইনবক্স', 'চেক', 'জয়েন', 'জয়েন',
+
+    # Hindi (प्रोफाइल देखने के लिए शब्द)
+    'dekho', 'deko', 'dekhiye', 'link', 'bio', 'profile', 'check',
+    'बायो', 'प्रोफाइल', 'लिंक', 'देखो', 'देखिये', 'चेक'
+]
+BIO_TRIGGER_REGEX = re.compile(r'\b(?:' + '|'.join(re.escape(word) for word in BIO_TRIGGER_WORDS) + r')\b', re.IGNORECASE)
+
 # --- Keywords to detect links in OCR text ---
 LINK_INDICATOR_KEYWORDS = ['t.me', 'tme', 'http', 'https', 'www', '.com', '.net', '.org', '.xyz', '.gg', '.io', '@']
 

credentials.py

@@ -1,10 +1,29 @@
-import os
-
-# Hugging Face Secrets থেকে ডাটা সংগ্রহ করা হচ্ছে
-BOT_TOKEN = os.getenv("BOT_TOKEN")
-BOT_OWNER_ID = os.getenv("BOT_OWNER_ID")
-REPORT_CHANNEL_ID = os.getenv("REPORT_CHANNEL_ID")
-DATABASE_URL = os.getenv("DATABASE_URL")
-OCR_API_URL = os.getenv("OCR_API_URL")
-REDIS_URL_1 = os.getenv("REDIS_URL_1")
-REDIS_URL_2 = os.getenv("REDIS_URL_2")
+# --- START OF FILE credentials.py (FINAL FIX) ---
+
+# আপনার টেলিগ্রাম বটের টোকেন
+BOT_TOKEN = "8736442113:AAGvSnV64n4Lg7aoJ3dWZ4UXBpKWaQ3cdSk"
+
+# আপনার টেলিগ্রাম ইউজার আইডি (বটের মালিক)
+BOT_OWNER_ID = "7273609587"
+
+# আপনার রিপোর্ট পাঠানোর চ্যানেলের আইডি
+REPORT_CHANNEL_ID = "-1003709977763"
+
+# আপনার supabase ডাটাবেসের লিঙ্ক
+DATABASE_URL = "postgresql://postgres.xlbhfttkepdkhprxupbg:yYrmVvtBD9WaQTK6@aws-1-us-east-2.pooler.supabase.com:6543/postgres"
+# আপনার OCR API-এর লিঙ্ক
+OCR_API_URL = "https://pmrony-my-easyocr-api.hf.space/ocr-from-image/"
+
+# --- FIX: আপনার Redis cloud amronyvai এর সঠিক URL ---
+# "redis-cli --tls -u" অংশটি বাদ দেওয়া হয়েছে
+REDIS_URL_1 = "redis://default:A5BhOdPYRxV73r9uoKvbEYhibjLWf1Fp@redis-18961.c264.ap-south-1-1.ec2.cloud.redislabs.com:18961"
+
+
+# --- FIX: আপনার  Redis cloud maronyvai এর সঠিক URL -- 
+REDIS_URL_2 = "redis://default:rDT4ZMYn6zbiv@p@redis-14733.c301.ap-south-1-1.ec2.cloud.redislabs.com:14733"
+
+# --- AI Features ---
+GEMINI_API_KEY = "AIzaSyCiBZVtFnFkyHWL_YH0lefRiMl50s4bGrE"
+REDIS_URL_AI = "rediss://default:AVNS_1HXzC8VrviAwOf2jIVc@valkey-2ee15c50-maronyvai-dff2.l.aivencloud.com:21982"
+
+# --- END OF FILE credentials.py ---

db.py

@@ -67,22 +67,26 @@ async def setup_database(pool):
                 warn_limit INTEGER DEFAULT 0,
                 warn_time_window INTEGER DEFAULT 10,
                 warn_action TEXT DEFAULT 'mute'
+                
             )""")
 
             # 🔥 FIX: Missing columns fix for group_settings (Auto-Warn Feature)
             # এটি পুরাতন ডাটাবেসে নতুন কলামগুলো যোগ করে দিবে যাতে /setwarn কাজ করে
+            # Line 74 থেকে শুরু হবে:
             for col, dtype in [
-                ("warn_limit", "INTEGER DEFAULT 0"),
-                ("warn_time_window", "INTEGER DEFAULT 10"),
-                ("warn_action", "TEXT DEFAULT 'mute'")
-            ]:
+            ("force_join_channel", "TEXT DEFAULT NULL"),
+            ("warn_limit", "INTEGER DEFAULT 0"),
+            ("warn_time_window", "INTEGER DEFAULT 10"),
+            ("warn_action", "TEXT DEFAULT 'mute'")
+        ]:
                 try: await conn.execute(f"ALTER TABLE group_settings ADD COLUMN {col} {dtype}")
                 except: pass
 
             # Filters & Notes
             await conn.execute("CREATE TABLE IF NOT EXISTS filters (chat_id BIGINT, keyword TEXT, reply_text TEXT, file_id TEXT, file_type TEXT, PRIMARY KEY (chat_id, keyword))")
             await conn.execute("CREATE TABLE IF NOT EXISTS notes (chat_id BIGINT, slug TEXT, content TEXT, file_id TEXT, file_type TEXT, PRIMARY KEY (chat_id, slug))")
-            await conn.execute("CREATE TABLE IF NOT EXISTS chats (chat_id BIGINT PRIMARY KEY, added_on TIMESTAMPTZ DEFAULT CURRENT_TIMESTAMP)")
+            try: await conn.execute("ALTER TABLE chats ADD COLUMN chat_title TEXT")
+            except: pass
 
             # VIP SYSTEM
             await conn.execute("""
@@ -441,7 +445,7 @@ async def get_all_user_ids(pool):
             return [r['user_id'] for r in records]
     except: return []
     
-    # --- db.py এর একদম শেষে এই ফাংশনটি যোগ করুন ---
+    # --- db.py এর একদম শেষে এই ফাংশনগুলো থাকবে ---
 
 async def create_db_pool_with_retry(max_retries=5, delay=5):
     db_url = DATABASE_URL
@@ -467,7 +471,6 @@ async def track_chat_member(pool, chat_id, user_id):
     if not pool: return
     try:
         async with pool.acquire() as conn:
-            # টেবিলটি ইনশিওর করার জন্য ON CONFLICT ব্যবহার
             await conn.execute("""
                 INSERT INTO chat_members (chat_id, user_id, last_seen)
                 VALUES ($1, $2, CURRENT_TIMESTAMP)
@@ -477,4 +480,15 @@ async def track_chat_member(pool, chat_id, user_id):
     except Exception as e:
         logger.error(f"❌ Track Member DB Error: {e}")
 
+async def update_chat_title(pool, chat_id, title):
+    if not pool or not title: return
+    try:
+        async with pool.acquire() as conn:
+            await conn.execute("""
+                INSERT INTO chats (chat_id, chat_title) VALUES ($1, $2)
+                ON CONFLICT (chat_id) DO UPDATE SET chat_title = EXCLUDED.chat_title
+            """, chat_id, title)
+    except Exception as e:
+        pass
+
 # --- END OF FILE db.py ---

lang_bn.py

@@ -307,7 +307,22 @@ BN_LANGUAGE_DATA = {
     "welcome_set_error_pairs": "⚠️ বাটনের নাম এবং লিংক/লেখা জোড়ায় জোড়ায় হতে হবে।",
     "welcome_set_success": "✅ <b>ওয়েলকাম সেট করা হয়েছে!</b>\n\n📝 <b>টেক্সট:</b> {text}...\n🔘 <b>বাটন:</b> {count} টি\n⏱ <b>টাইমার:</b> {time}",
     "welcome_set_mode_replace": "আগের মেসেজ রিপ্লেস হবে",
-    "button_expired": "❌ বাটনটি আর কাজ করছে না বা মুছে ফেলা হয়েছে।"
+    "button_expired": "❌ বাটনটি আর কাজ করছে না বা মুছে ফেলা হয়েছে।",
+
+    # --- Force Join ---
+    "forcejoin_button_label": "📢 জয়েন ফোর্স",
+    "forcejoin_toggle_alert": "⚠️ এটি চালু করতে আপনার চ্যানেলের একটি মেসেজ এই বটের ইনবক্সে Forward করুন।",
+    "forcejoin_example_full_text": (
+        "<b>📢 ফোর্স সাবস্ক্রাইব</b>\n\n"
+        "গ্রুপে মেসেজ পাঠানোর পূর্বে সদস্যদের নির্ধারিত চ্যানেলে যুক্ত হওয়া বাধ্যতামূলক করতে এই ফিচারটি ব্যবহার করুন।\n\n"
+        "<b>⚙️ কনফিগারেশন:</b>\n"
+        "চ্যানেলটি সিঙ্ক করতে আপনার চ্যানেল থেকে যেকোনো একটি মেসেজ এখানে <b>Forward</b> করুন।\n\n"
+        "⚠️ <b>শর্ত:</b> বটকে অবশ্যই উক্ত চ্যানেলের <b>Admin</b> হতে হবে।"
+    ),
+    "forcejoin_no_group_selected": "⚠️ <b>গ্রুপ সিলেক্ট করা নেই!</b>\nআগে 'Manage My Groups' থেকে একটি গ্রুপ সিলেক্ট করুন, তারপর চ্যানেলের মেসেজ ফরোয়ার্ড করুন।",
+    "forcejoin_not_admin": "❌ <b>বট অ্যাডমিন নয়!</b>\nদয়া করে আমাকে <b>{title}</b> চ্যানেলে অ্যাডমিন বানিয়ে আবার ট্রাই করুন।",
+    "forcejoin_access_error": "❌ <b>এক্সেস এরর!</b>\nআমাকে ওই চ্যানেলে অ্যাডমিন করা আছে তো?",
+    "forcejoin_link_success": "✅ <b>সফলভাবে লিঙ্ক করা হয়েছে!</b>\n\n🏢 <b>গ্রুপ:</b> {g_title}\n📢 <b>চ্যানেল:</b> {c_title}\n🆔 <b>ID:</b> <code>{c_id}</code>\n\n<i>এখন থেকে এই চ্যানেলে জয়েন না থাকলে কেউ ওই গ্রুপে মেসেজ দিতে পারবে না।</i>",
 }
 
 # --- END OF FILE lang_bn.py ---

lang_en.py

@@ -310,6 +310,21 @@ EN_LANGUAGE_DATA = {
     "welcome_set_success": "✅ <b>Welcome Message Set!</b>\n\n📝 <b>Text:</b> {text}...\n🔘 <b>Buttons:</b> {count}\n⏱ <b>Timer:</b> {time}",
     "welcome_set_mode_replace": "Previous message will be replaced",
     "button_expired": "❌ This button is no longer working.",
+    
+    # --- Force Join ---
+    "forcejoin_button_label": "📢 Force Join",
+    "forcejoin_toggle_alert": "⚠️ To enable: Forward any message from your channel to this bot chat.",
+    "forcejoin_example_full_text": (
+        "<b>📢 Force Subscribe</b>\n\n"
+        "Use this feature to make channel subscription mandatory before members can message in the group.\n\n"
+        "<b>⚙️ Configuration:</b>\n"
+        "To sync your channel, simply <b>Forward</b> any message from that channel to this bot.\n\n"
+        "⚠️ <b>Note:</b> Bot must be an <b>Admin</b> in the selected channel."
+    ),
+    "forcejoin_no_group_selected": "⚠️ <b>No group selected!</b>\nPlease select a group from 'Manage My Groups' first, then forward the channel message.",
+    "forcejoin_not_admin": "❌ <b>Bot is not Admin!</b>\nPlease make me an Admin in <b>{title}</b> and try again.",
+    "forcejoin_access_error": "❌ <b>Access Error!</b>\nAm I an Admin in that channel?",
+    "forcejoin_link_success": "✅ <b>Successfully Linked!</b>\n\n🏢 <b>Group:</b> {g_title}\n📢 <b>Channel:</b> {c_title}\n🆔 <b>ID:</b> <code>{c_id}</code>\n\n<i>Now members must join this channel to chat in the group.</i>",
 }
 
 # --- END OF FILE lang_en.py ---

lang_hi.py

@@ -307,7 +307,21 @@ HI_LANGUAGE_DATA = {
     "welcome_set_error_pairs": "⚠️ बटन का नाम और लिंक जोड़े में होना चाहिए।",
     "welcome_set_success": "✅ <b>वेलकम सेट हो गया!</b>\n\n📝 <b>टेक्स्ट:</b> {text}...\n🔘 <b>बटन:</b> {count}\n⏱ <b>टाइमर:</b> {time}",
     "welcome_set_mode_replace": "पिछला संदेश बदला जाएगा",
-    "button_expired": "❌ यह बटन अब काम नहीं कर रहा है।"
+    "button_expired": "❌ यह बटन अब काम नहीं कर रहा है।",
+    # --- Force Join ---
+    "forcejoin_button_label": "📢 जॉइन फोर्स",
+    "forcejoin_toggle_alert": "⚠️ इसे चालू करने के लिए अपने चैनल का कोई भी मैसेज इस बॉट को Forward करें।",
+    "forcejoin_example_full_text": (
+        "<b>📢 फ़ोर्स सब्सक्राइब</b>\n\n"
+        "ग्रुप में मैसेज भेजने से पहले सदस्यों के लिए चैनल से जुड़ना अनिवार्य बनाने के लिए इस फीचर का उपयोग करें।\n\n"
+        "<b>⚙️ कॉन्फ़िगरेशन:</b>\n"
+        "चैनल को सिंक करने के लिए अपने चैनल से कोई भी मैसेज यहाँ <b>Forward</b> करें।\n\n"
+        "⚠️ <b>नोट:</b> बॉट का उक्त चैनल में <b>Admin</b> होना अनिवार्य है।"
+    ),
+    "forcejoin_no_group_selected": "⚠️ <b>ग्रुप चुना नहीं गया है!</b>\nपहले 'Manage My Groups' से एक ग्रुप चुनें, फिर चैनल मैसेज फॉरवर्ड करें।",
+    "forcejoin_not_admin": "❌ <b>बॉट एडमिन नहीं है!</b>\nकृपया मुझे <b>{title}</b> चैनल में एडमिन बनाएं और फिर से कोशिश करें।",
+    "forcejoin_access_error": "❌ <b>एक्सेस एरर!</b>\nक्या मुझे उस चैनल में एडमिन बनाया गया है?",
+    "forcejoin_link_success": "✅ <b>सफलतापूर्वक लिंक किया गया!</b>\n\n🏢 <b>ग्रुप:</b> {g_title}\n📢 <b>चैनल:</b> {c_title}\n🆔 <b>ID:</b> <code>{c_id}</code>\n\n<i>अब इस चैनल में शामिल हुए बिना कोई भी ग्रुप में मैसेज नहीं भेज पाएगा।</i>",
 }
 
 # --- END OF FILE lang_hi.py ---

main.py

@@ -1,125 +1,221 @@
+# --- START OF FILE main.py ---
 import logging
+import os
 import asyncio
 import threading
-import socket
-import http.server
-import socketserver
+import re
+from fastapi import FastAPI
+import uvicorn
+import redis.asyncio as redis
 from datetime import datetime, timedelta, timezone
+from concurrent.futures import ThreadPoolExecutor
 
-# ১. IPv4 Force Patch (Hugging Face-এর নেটওয়ার্ক ব্লকিং বাইপাস করার জন্য)
-old_getaddrinfo = socket.getaddrinfo
-def new_getaddrinfo(*args, **kwargs):
-    responses = old_getaddrinfo(*args, **kwargs)
-    return [r for r in responses if r[0] == socket.AF_INET]
-socket.getaddrinfo = new_getaddrinfo
+try:
+    import uvloop
+    asyncio.set_event_loop_policy(uvloop.EventLoopPolicy())
+except ImportError: pass
 
-# Telebot Async version ইম্পোর্ট
-from telebot.async_telebot import AsyncTeleBot
-from telebot import types
+from telegram import Update, InlineKeyboardButton, InlineKeyboardMarkup, ChatMember, ChatPermissions
+from telegram.ext import (
+    Application, CommandHandler, MessageHandler, ChatJoinRequestHandler,
+    filters, ChatMemberHandler, ContextTypes, CallbackQueryHandler
+)
 
-# আপনার প্রজেক্টের ফাইলগুলো থেকে ইম্পোর্ট
-from credentials import BOT_TOKEN, BOT_OWNER_ID, REPORT_CHANNEL_ID, REDIS_URL_1, REDIS_URL_2
+import credentials
 import config
-from config import logger, BOT_VERSION
+from config import logger, BOT_VERSION, TELEGRAM_API_CONCURRENCY_LIMIT
 from db import create_db_pool_with_retry, setup_database
-import db
-import redis.asyncio as redis
+import db 
+from bot_handlers.batch import BatchDeleter 
 from bot_handlers import utils
 
-# বট অবজেক্ট তৈরি
-bot = AsyncTeleBot(BOT_TOKEN.strip())
-
-# --- ২. Hugging Face Health Check Server (Port 7860) ---
-def run_web_server():
-    class HealthCheckHandler(http.server.SimpleHTTPRequestHandler):
-        def do_GET(self):
-            self.send_response(200); self.end_headers()
-            self.wfile.write(f"Telebot is Running! Version: {BOT_VERSION}".encode('utf-8'))
-        def log_message(self, *args): pass
-    try:
-        socketserver.TCPServer(("0.0.0.0", 7860), HealthCheckHandler).serve_forever()
-    except: pass
-
-# --- ৩. ব্যাকগ্রাউন্ড টাস্কসমূহ ---
-
-async def background_tasks_loop():
-    """বট স্টার্ট হওয়ার পর এই লুপগুলো ব্যাকগ্রাউন্ডে চলবে"""
-    # ডাটাবেস ও রেডিয়াস সেটআপ
-    bot.db_pool = await create_db_pool_with_retry()
-    await setup_database(bot.db_pool)
+app_web = FastAPI()
+@app_web.get("/")
+def read_root(): return {"status": "Bot is alive!", "version": BOT_VERSION}
+
+def run_web_server(): uvicorn.run(app_web, host="0.0.0.0", port=7860)
+
+async def global_error_handler(update: object, context: ContextTypes.DEFAULT_TYPE):
+    logger.error("Exception while handling an update:", exc_info=context.error)
+
+async def user_stats_flush_loop(app):
+    while True:
+        await asyncio.sleep(300)
+        await db.flush_user_stats_to_db(app)
+
+async def check_expired_trials_loop(app):
+    while True:
+        await asyncio.sleep(60) 
+        pool = app.bot_data.get('db_pool')
+        if not pool: continue
+        try:
+            async with pool.acquire() as conn:
+                now_utc = datetime.now(timezone.utc)
+                expired_vips = await conn.fetch("SELECT chat_id, user_id FROM vip_trials WHERE expiry_date < $1 AND is_safe = FALSE", now_utc)
+                for row in expired_vips:
+                    try: 
+                        await app.bot.ban_chat_member(row['chat_id'], row['user_id'])
+                        await app.bot.unban_chat_member(row['chat_id'], row['user_id'])
+                    except: pass
+                await conn.execute("DELETE FROM vip_trials WHERE expiry_date < $1", now_utc)
+        except Exception as e: logger.error(f"VIP Monitor Error: {e}")
+
+async def recovery_traffic_locks(app):
+    pool = app.bot_data.get('db_pool')
+    if not pool: return
+    group_ids = await db.get_all_group_ids(pool)
+    for chat_id in group_ids:
+        from bot_handlers.redis_manager import get_redis_client_for_chat
+        redis_client = get_redis_client_for_chat(app, chat_id)
+        if redis_client and (backup := await redis_client.get(f"backup_perms:{chat_id}")):
+            from bot_handlers.utils import restore_group_permissions
+            await restore_group_permissions(app, chat_id, backup)
+
+async def background_bio_task(app):
+    redis_client = app.bot_data.get('redis_clients')[0] if app.bot_data.get('redis_clients') else None
+    while True:
+        try:
+            data = await app.bot_data['bio_queue'].get()
+            chat_id, user_id, msg_id, settings, user_obj = data
+            await asyncio.sleep(0.2)
+            full_user = await app.bot.get_chat(user_id)
+            bio_text = getattr(full_user, 'bio', "") or ""
+            full_profile_text = f"{full_user.first_name} {getattr(full_user, 'last_name', '')} {bio_text}".strip()
+            is_bad = utils.has_link_in_text(full_profile_text) or getattr(full_user, 'personal_chat', None)
+            if redis_client: await redis_client.set(f"bio_status:{user_id}", "bad" if is_bad else "safe", ex=300)
+            if is_bad:
+                try: await app.bot.delete_message(chat_id, msg_id)
+                except: pass
+        except: pass
+        finally: app.bot_data['bio_queue'].task_done()
+
+async def handle_join_request(update: Update, context: ContextTypes.DEFAULT_TYPE):
+    req = update.chat_join_request
+    user, chat = req.from_user, req.chat
+    pool = context.bot_data.get('db_pool')
+    if user.username:
+        clients = context.bot_data.get('redis_clients')
+        if clients: await clients[0].set(f"join_cache:{user.username.lower()}", user.id, ex=2592000)
+    if pool:
+        try:
+            temp_expiry = datetime.now(timezone.utc) + timedelta(minutes=10)
+            async with pool.acquire() as conn:
+                await conn.execute("INSERT INTO vip_trials (chat_id, user_id, expiry_date, joined_at, is_safe) VALUES ($1, $2, $3, CURRENT_TIMESTAMP, TRUE) ON CONFLICT (chat_id, user_id) DO UPDATE SET expiry_date = EXCLUDED.expiry_date, is_safe = TRUE", chat.id, user.id, temp_expiry)
+        except: pass
+
+async def safe_start_command(update: Update, context: ContextTypes.DEFAULT_TYPE):
+    user = update.effective_user
+    if update.effective_chat.type != 'private': return
+    pool = context.bot_data.get('db_pool')
+    if pool: asyncio.create_task(pool.execute("INSERT INTO users (user_id, first_name, username, has_started_bot, last_active_on) VALUES ($1, $2, $3, TRUE, CURRENT_TIMESTAMP) ON CONFLICT (user_id) DO UPDATE SET has_started_bot = TRUE", user.id, user.first_name, user.username))
+    keyboard = InlineKeyboardMarkup([[InlineKeyboardButton("English 🇬🇧", callback_data='lang_en'), InlineKeyboardButton("বাংলা 🇧🇩", callback_data='lang_bn')], [InlineKeyboardButton("हिन्दी 🇮🇳", callback_data='lang_hi')]])
+    await update.message.reply_html(f"👋 <b>Hello {user.first_name}!</b>\n\nPlease choose language:", reply_markup=keyboard)
+
+async def w_bot_status(u, c): from bot_handlers.core import handle_bot_status_change; await handle_bot_status_change(u, c)
+async def w_member_status(u, c): from bot_handlers.core import handle_member_status_change; await handle_member_status_change(u, c)
+async def w_msg(u, c): from bot_handlers.core import handle_message; await handle_message(u, c)
+async def w_edit_msg(u, c): from bot_handlers.core import handle_edited_message; await handle_edited_message(u, c)
+async def w_callback(u, c): from bot_handlers import callbacks; await callbacks.w_callback(u, c)
+
+async def post_init(app: Application):
+    app.bot_data['db_pool'] = await create_db_pool_with_retry()
+    await setup_database(app.bot_data['db_pool'])
     
-    bot.redis_clients = []
-    for url in [REDIS_URL_1, REDIS_URL_2]:
+    app.bot_data['redis_clients'] = []
+    for url in [credentials.REDIS_URL_1, credentials.REDIS_URL_2]:
         if url:
             try:
-                r = redis.Redis.from_url(url, decode_responses=True)
-                await r.ping(); bot.redis_clients.append(r)
+                r = redis.Redis.from_url(url, decode_responses=True); await r.ping()
+                app.bot_data['redis_clients'].append(r)
             except: pass
+
+    # --- AI Redis Connection (From credentials.py) ---
+    if hasattr(credentials, 'REDIS_URL_AI') and credentials.REDIS_URL_AI:
+        try:
+            r_ai = redis.Redis.from_url(credentials.REDIS_URL_AI, decode_responses=True); await r_ai.ping()
+            app.bot_data['redis_ai'] = r_ai
+            logger.info("✅ Dedicated AI Redis Connected!")
+        except Exception as e: logger.error(f"❌ AI Redis Connection Failed: {e}"); app.bot_data['redis_ai'] = None
+
+    app.bot_data['api_semaphore'] = asyncio.Semaphore(TELEGRAM_API_CONCURRENCY_LIMIT)
+    app.bot_data['ocr_semaphore'] = asyncio.Semaphore(2)
+    app.bot_data['batch_deleter'] = BatchDeleter(app.bot)
+    app.bot_data['proc_pool'] = ThreadPoolExecutor(max_workers=4)
+    app.bot_data['BOT_OWNER_ID'] = int(credentials.BOT_OWNER_ID) if credentials.BOT_OWNER_ID else None
+    app.bot_data['REPORT_CHANNEL_ID'] = int(credentials.REPORT_CHANNEL_ID) if credentials.REPORT_CHANNEL_ID else None
+    app.bot_data['bio_queue'] = asyncio.Queue()
     
-    logger.info("✅ Database & Redis connected in background!")
-    
-    # এখানে আপনার অন্যান্য লুপ (Stats flush, Expired trial) গুলো asyncio.create_task দিয়ে চালু করতে পারেন
-    # উদাহরণ: asyncio.create_task(user_stats_flush_loop())
-
-# --- ৪. কমান্ড ও মেসেজ হ্যান্ডেলার্স ---
-
-@bot.message_handler(commands=['start'])
-async def start_cmd(message):
-    user = message.from_user
-    # ডাটাবেসে ইউজার সেভ করার লজিক (আপনার আগের কোড অনুযায়ী)
-    if hasattr(bot, 'db_pool'):
-        asyncio.create_task(bot.db_pool.execute(
-            "INSERT INTO users (user_id, first_name, has_started_bot) VALUES ($1, $2, TRUE) ON CONFLICT DO UPDATE SET has_started_bot = TRUE", 
-            user.id, user.first_name
-        ))
+    asyncio.create_task(background_bio_task(app))
+    asyncio.create_task(check_expired_trials_loop(app))
+    asyncio.create_task(user_stats_flush_loop(app))
+    asyncio.create_task(recovery_traffic_locks(app))
+
+async def post_stop(app: Application):
+    await db.flush_user_stats_to_db(app)
+    if p := app.bot_data.get('db_pool'): await p.close()
+    for r in app.bot_data.get('redis_clients', []): await r.close()
+    if r_ai := app.bot_data.get('redis_ai'): await r_ai.close()
+
+def main():
+    if not credentials.BOT_TOKEN: return
+    app = Application.builder().token(credentials.BOT_TOKEN).post_init(post_init).post_stop(post_stop).build()
+    app.add_error_handler(global_error_handler)
     
-    markup = types.InlineKeyboardMarkup()
-    markup.add(types.InlineKeyboardButton("English 🇬🇧", callback_data="lang_en"),
-               types.InlineKeyboardButton("বাংলা 🇧🇩", callback_data="lang_bn"))
-    await bot.reply_to(message, f"👋 Hello {user.first_name}!\nChoose Language:", reply_markup=markup)
-
-# জয়েন রিকোয়েস্ট হ্যান্ডেলার
-@bot.chat_join_request_handler()
-async def handle_join(request):
-    # আপনার জয়েন রিকোয়েস্ট লজিক এখানে লিখুন
-    await bot.approve_chat_join_request(request.chat.id, request.from_user.id)
-
-# অল মেসেজ হ্যান্ডেলার (আপনার ফিল্টার ও কোর লজিক ব্যবহারের জন্য)
-@bot.message_handler(func=lambda message: True, content_types=['text', 'photo', 'document', 'video'])
-async def handle_all_messages(message):
-    # আপনার bot_handlers.core.handle_message কল করুন
-    from bot_handlers.core import handle_message
-    # Telebot এবং python-telegram-bot এর অবজেক্ট আলাদা, তাই সরাসরি কাজ না করলে র‍্যাপার লাগবে
-    await handle_message(message, bot)
-
-# কলব্যাক কুয়েরি হ্যান্ডেলার
-@bot.callback_query_handler(func=lambda call: True)
-async def handle_callback(call):
-    from bot_handlers.callbacks import w_callback
-    await w_callback(call, bot)
-
-# --- ৫. মেইন রানার ---
-
-async def main():
-    if not BOT_TOKEN: return
+    from bot_handlers import admin_commands as ac, extra_commands as ec, owner_commands as oc, ai_commands as aic
+
+    app.add_handler(CommandHandler("start", safe_start_command))
+    app.add_handler(CommandHandler("ask", aic.ask_command))
+    app.add_handler(CommandHandler("summary", aic.summary_command))
+    app.add_handler(CommandHandler("grant", ac.vip_trial_command))
+    app.add_handler(CommandHandler("whois", ac.whois_command))
+    app.add_handler(CommandHandler("whisper", ac.whisper_command))
+    app.add_handler(CommandHandler("setwarn", ac.setwarn_command))
+    app.add_handler(CommandHandler("addword", ac.add_word_command))
+    app.add_handler(CommandHandler("delword", ac.del_word_command))
+    app.add_handler(CommandHandler("wordlist", ac.wordlist_command))
+    app.add_handler(CommandHandler("resetsettings", ac.reset_settings_command))
+    app.add_handler(CommandHandler("filter", ec.filter_command))
+    app.add_handler(CommandHandler("stop", ec.stop_filter_command))
+    app.add_handler(CommandHandler("save", ec.save_note_command))
+    app.add_handler(CommandHandler("setwelcome", ec.set_welcome_command))
+    app.add_handler(CommandHandler("welcomecard", ec.welcome_card_command))
+    app.add_handler(CommandHandler("shadow", ec.shadow_command))
+    app.add_handler(CommandHandler("clean_ghosts", ec.clean_ghosts_command))
+    app.add_handler(CommandHandler("linktomute", ec.linktomute_command))
+    app.add_handler(CommandHandler("spamscan", ec.spamscan_command))
+    app.add_handler(CommandHandler("antiduplicate", ec.antiduplicate_command))
+    app.add_handler(CommandHandler("blockforwards", ec.blockforwards_command))
+    app.add_handler(CommandHandler("blockbiolink", ec.blockbiolink_command))
+    app.add_handler(CommandHandler("ocrscan", ec.ocrscan_command))
+    app.add_handler(CommandHandler("traffic", ec.traffic_command))
+    app.add_handler(CommandHandler("manageadmins", ec.manageadmins_command))
+    app.add_handler(CommandHandler("allowusernames", ec.allowusernames_command))
+    app.add_handler(CommandHandler("maxlength", ec.maxlength_command))
+    app.add_handler(CommandHandler("autodelete", ec.autodelete_command))
+    app.add_handler(CommandHandler("sentiment", ec.sentiment_command))
+    app.add_handler(CommandHandler("ticket", ec.ticket_command))
+    app.add_handler(CommandHandler("trustscore", ec.trustscore_command))
+    app.add_handler(CommandHandler("fixdb", ec.fix_database_command))
+    app.add_handler(CommandHandler("bc", oc.broadcast_groups_command))
+    app.add_handler(CommandHandler("stats", oc.stats_command))
+    app.add_handler(CommandHandler("activity", oc.check_activity_command))
+    app.add_handler(CommandHandler("get_dead_groups", oc.get_dead_groups_command))
+    app.add_handler(CommandHandler("purge_dead_groups", oc.purge_dead_groups_command))
+    app.add_handler(CommandHandler("sban", oc.sban_command))
+    app.add_handler(CommandHandler("sdel", oc.sdel_command))
+    app.add_handler(CommandHandler("smute", oc.smute_command))
+    app.add_handler(CommandHandler("setforcejoin", ec.set_force_join_command))
     
-    # ওয়েব সার্ভার শুরু
+    app.add_handler(MessageHandler(filters.FORWARDED & filters.ChatType.PRIVATE, ec.handle_channel_forward))
+    app.add_handler(CallbackQueryHandler(w_callback))
+    app.add_handler(ChatJoinRequestHandler(handle_join_request))
+    app.add_handler(MessageHandler(filters.ALL & ~filters.COMMAND, w_msg))
+    app.add_handler(MessageHandler(filters.UpdateType.EDITED_MESSAGE, w_edit_msg))
+    app.add_handler(ChatMemberHandler(w_bot_status, ChatMemberHandler.MY_CHAT_MEMBER))
+    app.add_handler(ChatMemberHandler(w_member_status, ChatMemberHandler.CHAT_MEMBER))
+
     threading.Thread(target=run_web_server, daemon=True).start()
-    
-    # ব্যাকগ্রাউন্ড টাস্ক শুরু
-    asyncio.create_task(background_tasks_loop())
-    
-    logger.info("🚀 Telebot is starting in Async Mode...")
-    
-    # পোলিং শুরু (এটি অটোমেটিক রিস্টার্ট এবং টাইমআউট হ্যান্ডেল করে)
-    try:
-        await bot.polling(non_stop=True, interval=0, timeout=60)
-    except Exception as e:
-        logger.error(f"Polling Error: {e}")
-        await asyncio.sleep(5)
-
-if __name__ == '__main__':
-    try:
-        asyncio.run(main())
-    except KeyboardInterrupt:
-        pass
+    app.run_polling(allowed_updates=["message", "callback_query", "chat_member", "my_chat_member", "chat_join_request", "edited_message"])
+
+if __name__ == '__main__': main()
+# --- END OF FILE main.py ---

requirements.txt

@@ -1,10 +1,8 @@
-pyTelegramBotAPI
-aiohttp
-redis
-asyncio
-asyncpg
-fastapi
-uvicorn
+python-telegram-bot[webhooks]
 python-dotenv
-certifi
-orjson
+orjson
+httpx
+asyncpg
+redis
+Pillow
+uvloop