Function get_fsub

plugins/fsub.py:142–190

(bot: Client, message: Message)

async def get_fsub(bot: Client, message: Message) -> bool:
    user_id = message.from_user.id

    if user_id == Config.ADMIN:
        return True

    old_msg_id = await tb.get_fsub_msg(user_id)

    if old_msg_id:
        try:
            await bot.delete_messages(user_id, old_msg_id)
        except Exception:
            pass
        await tb.delete_fsub_msg_db(user_id)

    missing = []

    if Config.AUTH_CHANNELS:
        missing.extend(await is_subscribed(bot, user_id))

    if Config.AUTH_REQ_CHANNELS:
        missing.extend(await is_req_subscribed(bot, user_id))

    if not missing:
        return True

    bot_user = await bot.get_me()
    buttons = []

    for i in range(0, len(missing), 2):
        row = []
        for j in range(2):
            if i + j < len(missing):
                title, link = missing[i + j]
                row.append(InlineKeyboardButton(f"{i + j + 1}. {title}", url=link))
        buttons.append(row)

    buttons.append(
        [InlineKeyboardButton("🔄 𝖳𝗋𝗒 𝖠𝗀𝖺𝗂𝗇", url=f"https://telegram.me/{bot_user.username}?start=start")]
    )
    msg = await message.reply(
        f"<blockquote>**🔒 𝖠𝖼𝖼𝖾𝗌𝗌 𝖱𝖾𝗌𝗍𝗋𝗂𝖼𝗍𝖾𝖽!**</blockquote>\n\n"
        f"{message.from_user.mention}, 𝖳𝗈 𝖴𝗌𝖾 𝖳𝗁𝗂𝗌 𝖡𝗈𝗍, 𝖸𝗈𝗎 𝖭𝖾𝖾𝖽 𝖳𝗈 𝖩𝗈𝗂𝗇 𝖠𝖫𝖫 𝖱𝖾𝗊𝗎𝗂𝗋𝖾𝖽 𝖢𝗁𝖺𝗇𝗇𝖾𝗅𝗌.\n\n"
        f"𝖱𝖾𝗊𝗎𝗂𝗋𝖾𝖽 𝖢𝗁𝖺𝗇𝗇𝖾𝗅𝗌 ({len(missing)})\n\n"
        f"𝖠𝖿𝗍𝖾𝗋 𝖩𝗈𝗂𝗇𝗂𝗇𝗀, 𝖢𝗅𝗂𝖼𝗄 **“𝖳𝗋𝗒 𝖠𝗀𝖺𝗂𝗇”** 𝖡𝖾𝗅𝗈𝗐.",
        reply_markup=InlineKeyboardMarkup(buttons)
    )
    await tb.save_fsub_msg(user_id, msg.id)
    return False


@Client.on_message(filters.private & ~filters.user(Config.ADMIN) & ~filters.bot & ~filters.service & ~filters.me, group=-10)