Phase 15: Admin Panel added with stats, broadcast and db export

database.py

@@ -88,5 +88,35 @@ class Database:
             result = cursor.fetchone()
             return result[0] if result else 'retro'
 
+    def get_stats(self):
+        """Bot statistikasini qaytaradi (jami userlar va amallar)."""
+        with self.get_connection() as conn:
+            cursor = conn.cursor()
+            cursor.execute('SELECT COUNT(*) FROM users')
+            total_users = cursor.fetchone()[0]
+            
+            cursor.execute('SELECT COUNT(*) FROM history')
+            total_processed = cursor.fetchone()[0]
+            
+            # Oxirgi 24 soatdagi faollik
+            cursor.execute('''
+                SELECT COUNT(*) FROM history 
+                WHERE processed_at > datetime("now", "-1 day")
+            ''')
+            daily_active = cursor.fetchone()[0]
+            
+            return {
+                "total_users": total_users,
+                "total_processed": total_processed,
+                "daily_active": daily_active
+            }
+
+    def get_all_users(self):
+        """Xabar tarqatish uchun barcha user ID-larini qaytaradi."""
+        with self.get_connection() as conn:
+            cursor = conn.cursor()
+            cursor.execute('SELECT user_id FROM users')
+            return [row[0] for row in cursor.fetchall()]
+
 # Global DB instance
 db = Database()

main.py

@@ -55,11 +55,13 @@ from filters import (
     process_video_trim, process_video_face_fix, process_video_auto_enhance,
     process_video_fps_boost, apply_nudenet_filter, process_video_nnsfw,
     process_video_subtitle,
-    apply_glitch_filter, apply_mirror_filter, apply_watermark, apply_bg_remove,
-    apply_style_transfer, apply_quality_boost,
-    process_video_glitch, process_video_mirror, process_video_watermark,
     process_video_subtitle_translate
 )
+
+# Admin sozlamalari
+ADMIN_ID = int(os.environ.get("ADMIN_ID", 6309900880))
+BROADCAST_MODE = {} # {admin_id: True}
+
 from database import db
 from concurrent.futures import ThreadPoolExecutor
 from apscheduler.schedulers.asyncio import AsyncIOScheduler
@@ -266,6 +268,34 @@ async def handle_photo(update: Update, context: ContextTypes.DEFAULT_TYPE):
         logger.error(f"Error in handle_photo: {e}")
         await update.message.reply_text("❌ Xatolik yuz berdi.")
 
+async def handle_text(update: Update, context: ContextTypes.DEFAULT_TYPE):
+    """Matn xabarlarini qabul qilish."""
+    # Agar admin xabar tarqatish rejimida bo'lsa
+    if update.effective_user.id == ADMIN_ID and BROADCAST_MODE.get(ADMIN_ID):
+        BROADCAST_MODE[ADMIN_ID] = False
+        text_to_send = update.message.text
+        users = db.get_all_users()
+        count = 0
+        status_msg = await update.message.reply_text(f"🚀 Xabar tarqatish boshlandi (0/{len(users)})...")
+        
+        for u_id in users:
+            try:
+                await context.bot.send_message(u_id, text_to_send)
+                count += 1
+                if count % 10 == 0:
+                    await status_msg.edit_text(f"🚀 Xabar tarqatish davom etmoqda ({count}/{len(users)})...")
+            except:
+                pass
+        
+        await status_msg.edit_text(f"✅ Xabar tarqatish yakunlandi. {count} ta foydalanuvchiga yuborildi.")
+        return
+
+    # Check for text (if they send prompt for style transfer or other features)
+    text = update.message.text
+    # Add any other text handling logic here if needed
+    await update.message.reply_text("Kechirasiz, men faqat rasm va videolarni qayta ishlay olaman. Iltimos, rasm yoki video yuboring.")
+
+
 async def handle_video(update: Update, context: ContextTypes.DEFAULT_TYPE):
     """Videolarni qabul qilish."""
     try:
@@ -376,11 +406,60 @@ async def navigation_handler(update: Update, context: ContextTypes.DEFAULT_TYPE)
         keyboard = [[InlineKeyboardButton("🔙 Orqaga", callback_data="nav|main")]]
         await query.edit_message_text(text, reply_markup=InlineKeyboardMarkup(keyboard), parse_mode=constants.ParseMode.MARKDOWN)
 
-async def button_handler(update: Update, context: ContextTypes.DEFAULT_TYPE):
-    """Filtr tugmalari."""
+async def admin_panel(update: Update, context: ContextTypes.DEFAULT_TYPE):
+    """Faqat admin ko'ra oladigan boshqaruv paneli."""
+    if update.effective_user.id != ADMIN_ID:
+        return
+
+    keyboard = [
+        [
+            InlineKeyboardButton("📊 Statistika", callback_data="admin_stats"),
+            InlineKeyboardButton("📂 Bazani yuklab olish", callback_data="admin_db")
+        ],
+        [
+            InlineKeyboardButton("📢 Xabar tarqatish", callback_data="admin_broadcast")
+        ]
+    ]
+    reply_markup = InlineKeyboardMarkup(keyboard)
+    await update.message.reply_text("👑 **Admin Panel**\n\nBotni boshqarish uchun kerakli bo'limni tanlang:", 
+                                   reply_markup=reply_markup, parse_mode=constants.ParseMode.MARKDOWN)
+
+async def handle_callback(update: Update, context: ContextTypes.DEFAULT_TYPE):
     query = update.callback_query
     await query.answer()
+
+    if query.data.startswith("admin_"):
+        if update.effective_user.id != ADMIN_ID:
+            return
+        
+        if query.data == "admin_stats":
+            stats = db.get_stats()
+            text = (f"📊 **Bot Statistikasi**\n\n"
+                    f"👥 Jami foydalanuvchilar: {stats['total_users']}\n"
+                    f"🔄 Jami tahrirlangan media: {stats['total_processed']}\n"
+                    f"📈 Oxirgi 24 soatdagi faollik: {stats['daily_active']}")
+            await query.edit_message_text(text, parse_mode=constants.ParseMode.MARKDOWN, 
+                                         reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("⬅️ Orqaga", callback_data="admin_back")]]))
+        
+        elif query.data == "admin_db":
+            await query.message.reply_document(document=open(db.db_path, 'rb'), caption="📂 Bot ma'lumotlar bazasi zaxira nusxasi.")
+        
+        elif query.data == "admin_broadcast":
+            BROADCAST_MODE[ADMIN_ID] = True
+            await query.edit_message_text("📝 **Xabar tarqatish rejimi**\n\nBarcha foydalanuvchilarga yubormoqchi bo'lgan matningizni kiriting:",
+                                         reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("❌ Bekor qilish", callback_data="admin_back")]]))
+        
+        elif query.data == "admin_back":
+            BROADCAST_MODE[ADMIN_ID] = False
+            keyboard = [
+                [InlineKeyboardButton("📊 Statistika", callback_data="admin_stats"),
+                 InlineKeyboardButton("📂 Bazani yuklab olish", callback_data="admin_db")],
+                [InlineKeyboardButton("📢 Xabar tarqatish", callback_data="admin_broadcast")]
+            ]
+            await query.edit_message_text("👑 **Admin Panel**", reply_markup=InlineKeyboardMarkup(keyboard), parse_mode=constants.ParseMode.MARKDOWN)
+        return
     
+    # [Avvalgi button_handler mantiqi davom etadi...]
     try:
         data = query.data.split("|")
         action, m_type, short_id = data[0], data[1], data[2]
@@ -604,11 +683,13 @@ if __name__ == '__main__':
         app = ApplicationBuilder().token(TOKEN).request(request).post_init(post_init).build()
         
         app.add_handler(CommandHandler("start", start))
+        app.add_handler(CommandHandler("admin", admin_panel))
         app.add_handler(CallbackQueryHandler(navigation_handler, pattern=r"^nav\|"))
         app.add_handler(CallbackQueryHandler(settings_callback_handler, pattern=r"^set\|"))
-        app.add_handler(CallbackQueryHandler(button_handler))
+        app.add_handler(CallbackQueryHandler(handle_callback)) # This now handles all callbacks, including admin and regular buttons
         app.add_handler(MessageHandler(filters.PHOTO, handle_photo))
         app.add_handler(MessageHandler(filters.VIDEO | filters.ANIMATION | filters.Document.ALL, handle_video))
+        app.add_handler(MessageHandler(filters.TEXT & ~filters.COMMAND, handle_text)) # Handle general text messages
         
         logger.info("Bot polling rejimi ishga tushmoqda...")
         app.run_polling()