fix update

akn/AllDownloaderBot/admins.py

@@ -0,0 +1,241 @@
+from pyrogram import *
+from pyrogram.types import *
+from akn.utils.database import db
+
+unmute_permissions = ChatPermissions(
+    can_send_messages=True,
+    can_send_media_messages=True,
+    can_send_polls=True,
+    can_change_info=False,
+    can_invite_users=True,
+    can_pin_messages=False,
+)
+
+async def extract_userid(message, text: str):
+    def is_int(text: str):
+        try:
+            int(text)
+        except ValueError:
+            return False
+        return True
+
+    text = text.strip()
+
+    if is_int(text):
+        return int(text)
+
+    entities = message.entities
+    app = message._client
+    if len(entities) < 2:
+        return (await app.get_users(text)).id
+    entity = entities[1]
+    if entity.type == "mention":
+        return (await app.get_users(text)).id
+    if entity.type == "text_mention":
+        return entity.user.id
+    return None
+
+
+async def extract_user_and_reason(message, sender_chat=False):
+    args = message.text.strip().split()
+    text = message.text
+    user = None
+    reason = None
+    if message.reply_to_message:
+        reply = message.reply_to_message
+        if not reply.from_user:
+            if (
+                reply.sender_chat
+                and reply.sender_chat != message.chat.id
+                and sender_chat
+            ):
+                id_ = reply.sender_chat.id
+            else:
+                return None, None
+        else:
+            id_ = reply.from_user.id
+
+        if len(args) < 2:
+            reason = None
+        else:
+            reason = text.split(None, 1)[1]
+        return id_, reason
+
+    if len(args) == 2:
+        user = text.split(None, 1)[1]
+        return await extract_userid(message, user), None
+
+    if len(args) > 2:
+        user, reason = text.split(None, 2)[1:]
+        return await extract_userid(message, user), reason
+
+    return user, reason
+
+
+async def extract_user(message):
+    return (await extract_user_and_reason(message))[0]
+
+
+@Client.on_message(
+    ~filters.scheduled
+    & filters.command(["ban", "dban"])
+    & ~filters.forwarded
+)
+async def arz_ban_user(client: Client, message: Message):
+    user_id, reason = await extract_user_and_reason(message, sender_chat=True)
+    bot = (await client.get_chat_member(message.chat.id, client.me.id)).privileges
+    if not bot.can_restrict_members:
+        return await message.edit_text("I don't have enough permissions")
+    if not user_id:
+        return await message.edit_text("I can't find that user.")
+    if user_id == client.me.id:
+        return await message.edit_text("I can't ban myself.")
+    if user_id == 1191668125:
+        return await message.edit_text("I can't ban my developer!")
+    try:
+        mention = (await client.get_users(user_id)).mention
+    except IndexError:
+        mention = (
+            message.reply_to_message.sender_chat.title
+            if message.reply_to_message
+            else "Anon"
+        )
+    msg = (
+        f"**Banned User:** <a href='tg://user?id={user_id}'>{mention}</a>\n"
+        f"**Banned By:** [{message.from_user.mention}](tg://user?id={message.from_user.id if message.from_user else 0})\n"
+    )
+    if message.command[0][0] == "d":
+        await message.reply_to_message.delete()
+    if reason:
+        msg += f"**Reason:** {reason}"
+    await message.chat.ban_member(user_id)
+    await message.reply_text(
+        msg,
+        reply_markup=InlineKeyboardMarkup(
+            [
+                [
+                    InlineKeyboardButton(
+                        "Unban", callback_data=f"arzunban_{user_id}"
+                    )
+                ]
+            ]
+        )
+    )
+
+@Client.on_message(
+    ~filters.scheduled
+    & filters.command(["unban"])
+    & ~filters.forwarded
+)
+async def arz_unban_user(client: Client, message: Message):
+    user_id, reason = await extract_user_and_reason(message, sender_chat=True)
+    if not user_id:
+        return await message.edit_text("I can't find that user.")
+    if user_id == client.me.id:
+        return await message.edit_text("I can't unban myself.")
+    if user_id == 1191668125:
+        return await message.edit_text("I can't unban my developer!")
+    try:
+        mention = (await client.get_users(user_id)).mention
+    except IndexError:
+        mention = (
+            message.reply_to_message.sender_chat.title
+            if message.reply_to_message
+            else "Anon"
+        )
+    msg = (
+        f"**Unbanned User:** <a href='tg://user?id={user_id}'>{mention}</a>\n"
+        f"**Unbanned By:** [{message.from_user.mention}](tg://user?id={message.from_user.id if message.from_user else 0})\n"
+    )
+    if reason:
+        msg += f"**Reason:** {reason}"
+    await message.chat.unban_member(user_id)
+    await message.reply_text(msg)
+
+@Client.on_message(
+    ~filters.scheduled
+    & filters.command(["banme"])
+    & ~filters.forwarded
+)
+async def arz_ban_me(client: Client, message: Message):
+    user_id = message.from_user.id
+    reason = None
+    if not user_id:
+        return await message.edit_text("I can't find that user.")
+    if user_id == client.me.id:
+        return await message.edit_text("I can't ban myself.")
+    if user_id == 1191668125:
+        return await message.edit_text("I can't ban my developer!")
+    try:
+        mention = (await client.get_users(user_id)).mention
+    except IndexError:
+        mention = (
+            message.reply_to_message.sender_chat.title
+            if message.reply_to_message
+            else "Anon"
+        )
+    msg = (
+        f"**Banned User:** <a href='tg://user?id={user_id}'>{mention}</a>\n"
+        f"**Banned By:** [{message.from_user.mention}](tg://user?id={message.from_user.id if message.from_user else 0})\n"
+    )
+    if reason:
+        msg += f"**Reason:** {reason}"
+    await message.chat.ban_member(user_id)
+    await message.reply_text(
+        msg,
+        reply_markup=InlineKeyboardMarkup(
+            [
+                [
+                    InlineKeyboardButton(
+                        "Unban", callback_data=f"arzunban_{user_id}"
+                    )
+                ]
+            ]
+        )
+    )
+
+@Client.on_message(
+    ~filters.scheduled
+    & filters.command(["mute", "dmute"])
+    & ~filters.forwarded
+)
+async def arz_mute(client: Client, message: Message):
+    user_id, reason = await extract_user_and_reason(message, sender_chat=True)
+    bot = (await client.get_chat_member(message.chat.id, client.me.id)).privileges
+    if not bot.can_restrict_members:
+        return await message.edit_text("I don't have enough permissions")
+    if not user_id:
+        return await message.edit_text("I can't find that user.")
+    if user_id == client.me.id:
+        return await message.edit_text("I can't mute myself.")
+    if user_id == 1191668125:
+        return await message.edit_text("I can't mute my developer!")
+    try:
+        mention = (await client.get_users(user_id)).mention
+    except IndexError:
+        mention = (
+            message.reply_to_message.sender_chat.title
+            if message.reply_to_message
+            else "Anon"
+        )
+    msg = (
+        f"**Muted User:** <a href='tg://user?id={user_id}'>{mention}</a>\n"
+        f"**Muted By:** [{message.from_user.mention}](tg://user?id={message.from_user.id if message.from_user else 0})\n"
+    )
+    if message.command[0][0] == "d":
+        await message.reply_to_message.delete()
+    if reason:
+        msg += f"**Reason:** {reason}"
+    await message.chat.restrict_member(user_id, ChatPermissions())
+    await message.reply_text(
+        msg,
+        reply_markup=InlineKeyboardMarkup(
+            [
+                [
+                    InlineKeyboardButton(
+                        "Unmute", callback_data=f"arzunmute_{user_id}"
+                    )
+                ]
+            ]
+        )
+    )

akn/AllDownloaderBot/helpers/azrcallback.py

@@ -1,5 +1,14 @@
 from pyrogram import filters, Client
-from pyrogram.types import InlineKeyboardMarkup, InlineKeyboardButton
+from pyrogram.types import *
+
+unmute_permissions = ChatPermissions(
+    can_send_messages=True,
+    can_send_media_messages=True,
+    can_send_polls=True,
+    can_change_info=False,
+    can_invite_users=True,
+    can_pin_messages=False,
+)
 
 help_texts = {
     "ban": "**Ban Commands:**\n"
@@ -36,10 +45,40 @@ help_texts = {
             "/demote - Demote user\n"
             "/undemote - Undemote user\n"
             "/demoteme - Demote yourself\n"
-            "/demoteall - Demote all admins"
+            "/demoteall - Demote all admins",
+
+    "downloader": "**Downloader Commands:**\n"
+            "/igdl - Instgram Downloader\n"
+            "/ytv - Youtube Downloader\n"
+            "/yta - Youtube Audio Downloader\n"
+            "/ytva - Youtube Video Audio Downloader\n"
+            "/fbdl - Facebook Downloader\n"
+            "/ttdl - Tiktok Downloader\n"
+            "/twtdl - Twitter Downloader\n"
+            "alldl - All Downloader\n"
 }
 
-@Client.on_callback_query(filters.regex("^rhelp_(ban|mute|promote|demote|clean|lock)$"))
+@Client.on_message(filters.regex("^arzunban_(\d+)"))
+async def arzunban_callback(client, callback):
+    user_id = int(callback.data.split("_")[1])
+    chat_id = callback.chat.id
+    try:
+        await client.unban_chat_member(chat_id, user_id)
+        await callback.answer("User unbanned successfully!")
+    except Exception as e:
+        await callback.answer(f"Failed to unban user: {e}")
+
+@Client.on_message(filters.regex("^arzunmute_(\d+)"))
+async def arzunmute_callback(client, callback):
+    user_id = int(callback.data.split("_")[1])
+    chat_id = callback.chat.id
+    try:
+        await client.restrict_chat_member(chat_id, user_id, permissions=unmute_permissions)
+        await callback.answer("User unmuted successfully!")
+    except Exception as e:
+        await callback.answer(f"Failed to unmute user: {e}")
+
+@Client.on_callback_query(filters.regex("^rhelp_(ban|mute|promote|demote|clean|lock|downloader$"))
 async def rxhelp_callback(client, callback):
     category = callback.data.split("_")[1]
     keyboard = InlineKeyboardMarkup([
@@ -51,7 +90,6 @@ async def rxhelp_callback(client, callback):
         reply_markup=keyboard
     )
 
-
 @Client.on_callback_query(filters.regex("^rhelps_back"))
 async def rhelp_back(client, callback):
     keyboard = InlineKeyboardMarkup([
@@ -66,9 +104,14 @@ async def rhelp_back(client, callback):
         [
             InlineKeyboardButton("🧹 Clean", callback_data="rhelp_clean"),
             InlineKeyboardButton("🔒 Lock", callback_data="rhelp_lock")
+        ],
+        [
+            InlineKeyboardButton("📥 Downloader", callback_data="rhelp_downloader"),
+        ],
+        [
+            InlineKeyboardButton("❌ Close", callback_data="cclose"),
         ]
     ])
-    
     await callback.edit_message_text(
         "**Admin Help Menu**\nChoose a category:",
         reply_markup=keyboard

akn/AllDownloaderBot/main.py

@@ -55,6 +55,17 @@ COMMAND = """
 - `/ytlink` – Search for YouTube videos.  
 """
 
+GROUP_TEXTS = """
+Hi {name} iam a modular group management bot with some fun extras.
+
+Resfresh Ping: {ping}
+
+i can do Azrea Bot of things, and help u manage your group effortlessly!
+
+All Command can be accessed by using: `/`
+**Click on help to learn more!**
+"""
+
 @Client.on_callback_query(filters.regex("^cclose"))
 async def cb_cclose(client, query):
     await query.message.delete()
@@ -106,6 +117,38 @@ async def cb_author_command(client, query):
         reply_markup=keyboard_back
     )
 
+@Client.on_callback_query(filters.regex("^zvhelp"))
+async def varzhelp_callbackz(c, callback):
+    start = time.time()
+    await c.get_me()
+    end = time.time()
+    latency = (end - start) * 1000
+    keyboard = InlineKeyboardMarkup([
+        [
+            InlineKeyboardButton("🚫 Ban", callback_data="rhelp_ban"),
+            InlineKeyboardButton("🔇 Mute", callback_data="rhelp_mute")
+        ],
+        [
+            InlineKeyboardButton("👑 Promote", callback_data="rhelp_promote"),
+            InlineKeyboardButton("🛡️ Demote", callback_data="rhelp_demote")
+        ],
+        [
+            InlineKeyboardButton("🧹 Clean", callback_data="rhelp_clean"),
+            InlineKeyboardButton("🔒 Lock", callback_data="rhelp_lock")
+        ],
+        [
+            InlineKeyboardButton("📥 Downloader", callback_data="rhelp_downloader"),
+        ],
+        [
+            InlineKeyboardButton("⏪ Back", callback_data="zvback"),
+            InlineKeyboardButton("❌ Close", callback_data="cclose"),
+        ]
+    ])
+    await callback.edit_message_text(
+        GROUP_TEXTS.format(name=callback.from_user.mention, ping=latency),
+        reply_markup=keyboard
+    )
+
 @Client.on_message(
     ~filters.scheduled
     & filters.command(["start"])
@@ -115,6 +158,10 @@ async def cb_author_command(client, query):
 async def startbot(c, m):
     if await db.get_alldlbot_is_blacklist_user(c.me.id, m.from_user.id):
         return
+    start = time.time()
+    await c.get_me()
+    end = time.time()
+    latency = (end - start) * 1000
     buttons = [
         [
             InlineKeyboardButton(
@@ -130,6 +177,10 @@ async def startbot(c, m):
             InlineKeyboardButton(
                 text="Author Commands",
                 callback_data='author_cmd'
+            ),
+            InlineKeyboardButton(
+                text="Help",
+                callback_data='zvhelp'
             )
         ]
     ]
@@ -144,6 +195,10 @@ async def startbot(c, m):
             InlineKeyboardButton(
                 text="Author Commands",
                 callback_data='author_cmd'
+            ),
+            InlineKeyboardButton(
+                text="Help",
+                callback_data='zvhelp'
             )
         ]
     ]
@@ -155,11 +210,11 @@ async def startbot(c, m):
         if is_pic and catbox_link:
             return await m.reply_photo(
                 photo=catbox_link,
-                caption=COMMAND,
+                caption=GROUP_TEXTS.format(name=m.from_user.mention, ping=latency),
                 reply_markup=reply_markup
             )
         return await m.reply_text(
-            text=COMMAND,
+            text=GROUP_TEXTS.format(name=m.from_user.mention, ping=latency),
             disable_web_page_preview=True,
             reply_markup=reply_markup
         )