How to add Multi Force Subscribe in any Repo

Broadcast

This feature helps you to broadcast your message to every user that exist in your database.

Follow the below step to add broadcast feature in any repository

1. Create a new file name "commands.py" and paste this code in that file.

from pyrogram import Client, filters
from pyrogram.types import Message, InlineKeyboardMarkup, InlineKeyboardButton
from pyrogram.errors import FloodWait, UserIsBlocked, PeerIdInvalid, InputUserDeactivated
import asyncio
import re
from config import ADMIN
from .db import tb
from collections import defaultdict

def parse_button_markup(text: str):
    lines = text.split("\n")
    buttons = []
    final_text_lines = []
    for line in lines:
        row = []
        parts = line.split("||")
        is_button_line = True
        for part in parts:
            match = re.fullmatch(r"\[(.+?)\]\((https?://[^\s]+)\)", part.strip())
            if match:
                row.append(InlineKeyboardButton(match[1], url=match[2]))
            else:
                is_button_line = False
                break
        if is_button_line and row:
            buttons.append(row)
        else:
            final_text_lines.append(line)
    return InlineKeyboardMarkup(buttons) if buttons else None, "\n".join(final_text_lines).strip()

@Client.on_message(filters.command("broadcast") & filters.private & filters.user(ADMIN))
async def broadcasting_func(client: Client, message: Message):
    if not message.reply_to_message:
        return await message.reply("Reply to a message to broadcast.")
    msg = await message.reply_text("📢 Starting broadcast...")
    to_copy_msg = message.reply_to_message
    users_list = await tb.get_all_users()
    total_before = len(users_list)
    completed_users = set()
    failed = 0
    raw_text = to_copy_msg.caption or to_copy_msg.text or ""
    reply_markup, cleaned_text = parse_button_markup(raw_text)

    for i, user in enumerate(users_list, start=1):
        user_id = user.get("user_id")
        if not user_id:
            if await tb.delete_user(user.get("_id")):
                failed += 1
            continue
        try:
            user_id = int(user_id)  # normalize to int
            if to_copy_msg.text:
                await client.send_message(user_id, cleaned_text, reply_markup=reply_markup)
            elif to_copy_msg.photo:
                await client.send_photo(user_id, to_copy_msg.photo.file_id, caption=cleaned_text, reply_markup=reply_markup)
            elif to_copy_msg.video:
                await client.send_video(user_id, to_copy_msg.video.file_id, caption=cleaned_text, reply_markup=reply_markup)
            elif to_copy_msg.document:
                await client.send_document(user_id, to_copy_msg.document.file_id, caption=cleaned_text, reply_markup=reply_markup)
            else:
                await to_copy_msg.copy(user_id)

            completed_users.add(user_id)

        except (UserIsBlocked, PeerIdInvalid, InputUserDeactivated):
            if await tb.delete_user(user_id):
                failed += 1
        except FloodWait as e:
            await asyncio.sleep(e.value)
            try:
                await to_copy_msg.copy(user_id)
                completed_users.add(user_id)
            except Exception:
                if await tb.delete_user(user_id):
                    failed += 1
        except Exception:
            if await tb.delete_user(user_id):
                failed += 1
        if i % 20 == 0 or i == total_before:
            try:
                await msg.edit(
                    f"😶‍🌫 Broadcasting...\n\n"
                    f"👥 Total Users: {total_before}\n"
                    f"✅ Successful: {len(completed_users)}\n"
                    f"❌ Failed/Removed: {failed}\n"
                    f"⚙️ Progress: {i}/{total_before}"
                )
            except Exception:
                pass

        await asyncio.sleep(0.05)

    all_users = await tb.get_all_users()
    users_by_id = defaultdict(list)
    for user in all_users:
        uid = user.get("user_id")
        if not uid:
            if await tb.delete_user(user.get("_id")):
                failed += 1
            continue
        users_by_id[uid].append(user)

    for uid, docs in users_by_id.items():
        if uid in completed_users:
            for duplicate in docs[1:]:
                if await tb.delete_user(duplicate.get("user_id")):
                    failed += 1
        else:
            for doc in docs:
                if await tb.delete_user(doc.get("user_id")):
                    failed += 1

    active_users = len(completed_users)

    await msg.edit(
        f"🎯 Broadcast Completed\n\n"
        f"👥 Total Users (Before): {total_before}\n"
        f"✅ Successful: {len(completed_users)}\n"
        f"❌ Failed/Removed: {failed}\n"
        f"📊 Active Users (Now): {active_users}",
        reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("🎭 Close", callback_data="close")]]),
    )

2. If you want to add "stats" command then pase this code in your "commands.py" file.

@Client.on_message(filters.command("stats") & filters.private & filters.user(ADMIN))
async def total_users(client: Client, message: Message):
    try:
        users = await tb.get_all_users()
        await message.reply_text(f"👥 **Total Users:** {len(users)}",reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton("🎭 𝖢𝗅𝗈𝗌𝖾", callback_data="close")]]))
    except Exception as e:
        r=await message.reply(f"❌ *Error:* `{str(e)}`")
        await asyncio.sleep(30)
        await r.delete()

Important

If you still face any issue then click on the below button

Watch Tutorial

Copying the post and using it without permission is strictly prohibited.

Go to Link