Add files via upload

plugins/__init__.py

@@ -0,0 +1,189 @@
+# Ultroid - UserBot
+# Copyright (C) 2021-2023 TeamUltroid
+#
+# This file is a part of < https://github.com/TeamUltroid/Ultroid/ >
+# PLease read the GNU Affero General Public License in
+# <https://www.github.com/TeamUltroid/Ultroid/blob/main/LICENSE/>.
+
+import asyncio
+import os
+import time
+import datetime
+from random import choice
+#from ApiNyaEr.teks import ISLAMIC as QUOTES
+import requests
+from telethon import Button, events
+from telethon.tl import functions, types  # pylint:ignore
+#from assistant.start import _start, _settings
+from xteam import *
+from xteam._misc._assistant import asst_cmd, callback, in_pattern
+from xteam._misc._decorators import ultroid_cmd
+from xteam._misc._wrappers import eod, eor
+from xteam.dB import DEVLIST, ULTROID_IMAGES, ALIVE_TEXT, ALIVE_NAME, QUOTES
+from xteam.fns.helper import *
+from xteam.fns.misc import *
+from xteam.fns.tools import *
+from xteam.startup._database import _BaseDatabase as Database
+from xteam.version import __version__, ultroid_version
+from strings import get_help, get_string
+from xteam._misc._supporter import CMD_HNDLR
+from xteam.dB import stickers
+
+
+udB: Database
+
+Redis = udB.get_key
+con = TgConverter
+quotly = Quotly()
+OWNER_NAME = ultroid_bot.full_name
+OWNER_ID = ultroid_bot.uid
+OWNER_USERNAME = ultroid_bot.username
+BOT_NAME = asst.full_name
+BOT_USERNAME = asst.username
+
+ultroid_bot: UltroidClient
+asst: UltroidClient
+
+LOG_CHANNEL = udB.get_key("LOG_CHANNEL")
+StartTime = time.time()
+
+def inline_pic():
+    INLINE_PIC = udB.get_key("INLINE_PIC")
+    if INLINE_PIC is None:
+        INLINE_PIC = choice(ULTROID_IMAGES)
+    elif INLINE_PIC == False:
+        INLINE_PIC = None
+    return INLINE_PIC
+
+def ping_pic():
+    PING_PIC = udB.get_key("PING_PIC")
+    if PING_PIC is None:
+        PING_PIC = choice(ULTROID_IMAGES)
+    elif PING_PIC == False:
+        PING_PIC = None
+    return PING_PIC
+
+def get_readable_time(seconds: int) -> str:
+    count = 0
+    readable_time = ""
+    time_list = []
+    time_suffix_list = ["s", "m", "h", "days"]
+
+    while count < 4:
+        count += 1
+        remainder, result = divmod(seconds, 60) if count < 3 else divmod(seconds, 24)
+        if seconds == 0 and remainder == 0:
+            break
+        time_list.append(int(result))
+        seconds = int(remainder)
+
+    for x in range(len(time_list)):
+        time_list[x] = str(time_list[x]) + time_suffix_list[x]
+    if len(time_list) == 4:
+        readable_time += f"{time_list.pop()}, "
+
+    time_list.reverse()
+    readable_time += ":".join(time_list)
+
+    return readable_time
+
+
+Telegraph = telegraph_client()
+
+List = []
+Dict = {}
+InlinePlugin = {}
+N = 0
+cmd = ultroid_cmd
+STUFF = {}
+
+# Chats, which needs to be ignore for some cases
+# Considerably, there can be many
+# Feel Free to Add Any other...
+
+NOSPAM_CHAT = [
+    -1001361294038,  # UltroidSupportChat
+    -1001387666944,  # PyrogramChat
+    -1001109500936,  # TelethonChat
+    -1001050982793,  # Python
+    -1001256902287,  # DurovsChat
+    -1001473548283,  # SharingUserbot
+    -1001599474353,
+    -1001692751821,
+    -1001473548283,
+    -1001459812644,
+    -1001433238829,
+    -1001476936696,
+    -1001327032795,
+    -1001294181499,
+    -1001419516987,
+    -1001209432070,
+    -1001296934585,
+    -1001481357570,
+    -1001459701099,
+    -1001109837870,
+    -1001485393652,
+    -1001354786862,
+    -1001109500936,
+    -1001387666944,
+    -1001390552926,
+    -1001752592753,
+    -1001777428244,
+    -1001771438298,
+    -1001287188817,
+    -1001812143750,
+    -1001883961446,
+    -1001753840975,
+    -1001896051491,
+    -1001578091827,
+    -1001284445583,
+    -1001927904459,
+    -1001675396283,
+    -1001825363971,
+    -1001537280879,
+    -1001302879778,
+    -1001797285258,
+    -1001864253073,
+    -1001876092598,
+    -1001608847572,
+    -1001451642443,
+    -1001538826310,
+    -1001608701614,
+    -1001861414061,
+    -1001406767793,
+    -1001306409796,
+    -1002136866494,
+    -1002234906165,
+    -1001557462351,
+    -1001185324811,
+    -1002341392113,
+    -1002385138723,
+]
+
+KANGING_STR = [
+    "Using Witchery to kang this sticker...",
+    "Plagiarising hehe...",
+    "Inviting this sticker over to my pack...",
+    "Kanging this sticker...",
+    "Hey that's a nice sticker!\nMind if I kang?!..",
+    "Hehe me stel ur stiker...",
+    "Ay look over there (☉｡☉)!→\nWhile I kang this...",
+    "Roses are red violets are blue, kanging this sticker so my pack looks cool",
+    "Imprisoning this sticker...",
+    "Mr.Steal-Your-Sticker is stealing this sticker... ",
+]
+
+ATRA_COL = [
+    "DarkCyan",
+    "DeepSkyBlue",
+    "DarkTurquoise",
+    "Cyan",
+    "LightSkyBlue",
+    "Turquoise",
+    "MediumVioletRed",
+    "Aquamarine",
+    "Lightcyan",
+    "Azure",
+    "Moccasin",
+    "PowderBlue",
+]

plugins/_chatactions.py

@@ -0,0 +1,253 @@
+# Ultroid - UserBot
+# Copyright (C) 2021-2023 TeamUltroid
+#
+# This file is a part of < https://github.com/TeamUltroid/Ultroid/ >
+# PLease read the GNU Affero General Public License in
+# <https://www.github.com/TeamUltroid/Ultroid/blob/main/LICENSE/>.
+
+import asyncio
+
+from telethon import events
+from telethon.errors.rpcerrorlist import UserNotParticipantError
+from telethon.tl.functions.channels import GetParticipantRequest
+from telethon.utils import get_display_name
+
+from xteam.dB import stickers
+from xteam.dB.echo_db import check_echo
+from xteam.dB.forcesub_db import get_forcesetting
+from xteam.dB.gban_mute_db import is_gbanned
+from xteam.dB.greetings_db import get_goodbye, get_welcome, must_thank
+from xteam.dB.nsfw_db import is_profan
+from xteam.fns.helper import inline_mention
+from xteam.fns.tools import async_searcher, create_tl_btn, get_chatbot_reply
+
+try:
+    from ProfanityDetector import detector
+except ImportError:
+    detector = None
+from . import LOG_CHANNEL, LOGS, asst, get_string, types, udB, ultroid_bot
+from ._inline import something
+
+
+@ultroid_bot.on(events.ChatAction())
+async def Function(event):
+    try:
+        await DummyHandler(event)
+    except Exception as er:
+        LOGS.exception(er)
+
+
+async def DummyHandler(ult):
+    # clean chat actions
+    key = udB.get_key("CLEANCHAT") or []
+    if ult.chat_id in key:
+        try:
+            await ult.delete()
+        except BaseException:
+            pass
+
+    # thank members
+    if must_thank(ult.chat_id):
+        chat_count = (await ult.client.get_participants(ult.chat_id, limit=0)).total
+        if chat_count % 100 == 0:
+            stik_id = chat_count / 100 - 1
+            sticker = stickers[stik_id]
+            await ult.respond(file=sticker)
+    # force subscribe
+    if (
+        udB.get_key("FORCESUB")
+        and ((ult.user_joined or ult.user_added))
+        and get_forcesetting(ult.chat_id)
+    ):
+        user = await ult.get_user()
+        if not user.bot:
+            joinchat = get_forcesetting(ult.chat_id)
+            try:
+                await ultroid_bot(GetParticipantRequest(int(joinchat), user.id))
+            except UserNotParticipantError:
+                await ultroid_bot.edit_permissions(
+                    ult.chat_id, user.id, send_messages=False
+                )
+                res = await ultroid_bot.inline_query(
+                    asst.me.username, f"fsub {user.id}_{joinchat}"
+                )
+                await res[0].click(ult.chat_id, reply_to=ult.action_message.id)
+
+    if ult.user_joined or ult.added_by:
+        user = await ult.get_user()
+        chat = await ult.get_chat()
+        # gbans and @UltroidBans checks
+        if udB.get_key("ULTROID_BANS"):
+            try:
+                is_banned = await async_searcher(
+                    "https://bans.ultroid.tech/api/status",
+                    json={"userId": user.id},
+                    post=True,
+                    re_json=True,
+                )
+                if is_banned["is_banned"]:
+                    await ult.client.edit_permissions(
+                        chat.id,
+                        user.id,
+                        view_messages=False,
+                    )
+                    await ult.respond(
+                        f'**@UltroidBans:** Banned user detected and banned!\n`{str(is_banned)}`.\nBan reason: {is_banned["reason"]}',
+                    )
+
+            except BaseException:
+                pass
+        reason = is_gbanned(user.id)
+        if reason and chat.admin_rights:
+            try:
+                await ult.client.edit_permissions(
+                    chat.id,
+                    user.id,
+                    view_messages=False,
+                )
+                gban_watch = get_string("can_1").format(inline_mention(user), reason)
+                await ult.reply(gban_watch)
+            except Exception as er:
+                LOGS.exception(er)
+
+        # greetings
+        elif get_welcome(ult.chat_id):
+            user = await ult.get_user()
+            chat = await ult.get_chat()
+            title = chat.title or "this chat"
+            count = (
+                chat.participants_count
+                or (await ult.client.get_participants(chat, limit=0)).total
+            )
+            mention = inline_mention(user)
+            name = user.first_name
+            fullname = get_display_name(user)
+            uu = user.username
+            username = f"@{uu}" if uu else mention
+            wel = get_welcome(ult.chat_id)
+            msgg = wel["welcome"]
+            med = wel["media"] or None
+            userid = user.id
+            msg = None
+            if msgg:
+                msg = msgg.format(
+                    mention=mention,
+                    group=title,
+                    count=count,
+                    name=name,
+                    fullname=fullname,
+                    username=username,
+                    userid=userid,
+                )
+            if wel.get("button"):
+                btn = create_tl_btn(wel["button"])
+                await something(ult, msg, med, btn)
+            elif msg:
+                send = await ult.reply(
+                    msg,
+                    file=med,
+                )
+                await asyncio.sleep(150)
+                await send.delete()
+            else:
+                await ult.reply(file=med)
+    elif (ult.user_left or ult.user_kicked) and get_goodbye(ult.chat_id):
+        user = await ult.get_user()
+        chat = await ult.get_chat()
+        title = chat.title or "this chat"
+        count = (
+            chat.participants_count
+            or (await ult.client.get_participants(chat, limit=0)).total
+        )
+        mention = inline_mention(user)
+        name = user.first_name
+        fullname = get_display_name(user)
+        uu = user.username
+        username = f"@{uu}" if uu else mention
+        wel = get_goodbye(ult.chat_id)
+        msgg = wel["goodbye"]
+        med = wel["media"]
+        userid = user.id
+        msg = None
+        if msgg:
+            msg = msgg.format(
+                mention=mention,
+                group=title,
+                count=count,
+                name=name,
+                fullname=fullname,
+                username=username,
+                userid=userid,
+            )
+        if wel.get("button"):
+            btn = create_tl_btn(wel["button"])
+            await something(ult, msg, med, btn)
+        elif msg:
+            send = await ult.reply(
+                msg,
+                file=med,
+            )
+            await asyncio.sleep(150)
+            await send.delete()
+        else:
+            await ult.reply(file=med)
+
+
+@ultroid_bot.on(events.NewMessage(incoming=True))
+async def chatBot_replies(e):
+    sender = await e.get_sender()
+    if not isinstance(sender, types.User) or sender.bot:
+        return
+    if check_echo(e.chat_id, e.sender_id):
+        try:
+            await e.respond(e.message)
+        except Exception as er:
+            LOGS.exception(er)
+    key = udB.get_key("CHATBOT_USERS") or {}
+    if e.text and key.get(e.chat_id) and sender.id in key[e.chat_id]:
+        msg = await get_chatbot_reply(e.message.message)
+        if msg:
+            sleep = udB.get_key("CHATBOT_SLEEP") or 1.5
+            await asyncio.sleep(sleep)
+            await e.reply(msg)
+    chat = await e.get_chat()
+    if e.is_group and sender.username:
+        await uname_stuff(e.sender_id, sender.username, sender.first_name)
+    elif e.is_private and chat.username:
+        await uname_stuff(e.sender_id, chat.username, chat.first_name)
+    if detector and is_profan(e.chat_id) and e.text:
+        x, y = detector(e.text)
+        if y:
+            await e.delete()
+
+
+@ultroid_bot.on(events.Raw(types.UpdateUserName))
+async def uname_change(e):
+    await uname_stuff(e.user_id, e.usernames[0] if e.usernames else None, e.first_name)
+
+
+async def uname_stuff(id, uname, name):
+    if udB.get_key("USERNAME_LOG"):
+        old_ = udB.get_key("USERNAME_DB") or {}
+        old = old_.get(id)
+        # Ignore Name Logs
+        if old and old == uname:
+            return
+        if old and uname:
+            await asst.send_message(
+                LOG_CHANNEL,
+                get_string("can_2").format(old, uname),
+            )
+        elif old:
+            await asst.send_message(
+                LOG_CHANNEL,
+                get_string("can_3").format(f"[{name}](tg://user?id={id})", old),
+            )
+        elif uname:
+            await asst.send_message(
+                LOG_CHANNEL,
+                get_string("can_4").format(f"[{name}](tg://user?id={id})", uname),
+            )
+
+        old_[id] = uname
+        udB.set_key("USERNAME_DB", old_)

plugins/_help.py

@@ -0,0 +1,125 @@
+# Ultroid - UserBot
+# Copyright (C) 2021-2023 TeamUltroid
+#
+# This file is a part of < https://github.com/TeamUltroid/Ultroid/ >
+# PLease read the GNU Affero General Public License in
+# <https://www.github.com/TeamUltroid/Ultroid/blob/main/LICENSE/>.
+
+import base64
+import inspect
+from datetime import datetime
+from html import unescape
+from random import choice
+from re import compile as re_compile
+
+from bs4 import BeautifulSoup as bs
+from telethon import Button
+from telethon.tl.alltlobjects import LAYER, tlobjects
+from telethon.tl.types import DocumentAttributeAudio as Audio
+from telethon.tl.types import InputWebDocument as wb
+
+from telethon.errors.rpcerrorlist import (
+    BotInlineDisabledError,
+    BotMethodInvalidError,
+    BotResponseTimeoutError,
+)
+from telethon.tl.custom import Button
+from assistant import *
+from xteam.dB._core import HELP, LIST
+from xteam.fns.tools import cmd_regex_replace
+
+from . import HNDLR, LOGS, OWNER_NAME, asst, get_string, inline_pic, udB, ultroid_cmd, call_back, callback, def_logs, eor, get_string, heroku_logs, in_pattern
+
+_main_help_menu = [
+    [
+        Button.url("18+",url=f"https://t.me/+5WS60Gdkpt84YWM1"),
+        Button.inline("ᴍᴏᴅᴜʟᴇꜱ", data="uh_Official_"),
+    ],
+    [Button.inline("ᴄʟᴏꜱᴇ", data="close")],
+]
+
+@ultroid_cmd(pattern="help( (.*)|$)")
+async def _help(ult):
+    plug = ult.pattern_match.group(1).strip()
+    chat = await ult.get_chat()
+    if plug:
+        try:
+            if plug in HELP["Official"]:
+                output = f"**Plugin** - `{plug}`\n"
+                for i in HELP["Official"][plug]:
+                    output += i
+                output += "\n© @xteam_cloner"
+                await ult.eor(output)
+            elif HELP.get("Addons") and plug in HELP["Addons"]:
+                output = f"**Plugin** - `{plug}`\n"
+                for i in HELP["Addons"][plug]:
+                    output += i
+                output += "\n© @xteam_cloner"
+                await ult.eor(output)
+            elif HELP.get("VCBot") and plug in HELP["VCBot"]:
+                output = f"**Plugin** - `{plug}`\n"
+                for i in HELP["VCBot"][plug]:
+                    output += i
+                output += "\n© @xteam_cloner"
+                await ult.eor(output)
+            else:
+                try:
+                    x = get_string("help_11").format(plug)
+                    for d in LIST[plug]:
+                        x += HNDLR + d
+                        x += "\n"
+                    x += "\n© @xteam_cloner"
+                    await ult.eor(x)
+                except BaseException:
+                    file = None
+                    compare_strings = []
+                    for file_name in LIST:
+                        compare_strings.append(file_name)
+                        value = LIST[file_name]
+                        for j in value:
+                            j = cmd_regex_replace(j)
+                            compare_strings.append(j)
+                            if j.strip() == plug:
+                                file = file_name
+                                break
+                    if not file:
+                        # the entered command/plugin name is not found
+                        text = f"`{plug}` is not a valid plugin!"
+                        best_match = None
+                        for _ in compare_strings:
+                            if plug in _ and not _.startswith("_"):
+                                best_match = _
+                                break
+                        if best_match:
+                            text += f"\nDid you mean `{best_match}`?"
+                        return await ult.eor(text)
+                    output = f"**Command** `{plug}` **found in plugin** - `{file}`\n"
+                    if file in HELP["Official"]:
+                        for i in HELP["Official"][file]:
+                            output += i
+                    elif HELP.get("Addons") and file in HELP["Addons"]:
+                        for i in HELP["Addons"][file]:
+                            output += i
+                    elif HELP.get("VCBot") and file in HELP["VCBot"]:
+                        for i in HELP["VCBot"][file]:
+                            output += i
+                    output += "\n© @xteam_cloner"
+                    await ult.eor(output)
+        except BaseException as er:
+            LOGS.exception(er)
+            await ult.eor("Error 🤔 occurred.")
+    else:
+        try:
+            results = await ult.client.inline_query(asst.me.username, "ultd")
+        except BotMethodInvalidError:
+            return await ult.reply(
+                "Inline mode is disabled. Please enable it in bot settings or contact support.",
+            )
+        except BotResponseTimeoutError:
+            return await ult.eor(
+                "The bot did not respond in time. Please try again later.",
+            )
+        except BotInlineDisabledError:
+            return await ult.eor("The bot's inline mode is currently disabled.")
+        await results[0].click(chat.id, reply_to=ult.reply_to_msg_id, hide_via=True)
+        await ult.delete()

plugins/_inline.py

@@ -0,0 +1,447 @@
+# Ultroid - UserBot
+# Copyright (C) 2021-2023 TeamUltroid
+#
+# This file is a part of < https://github.com/TeamUltroid/Ultroid/ >
+# PLease read the GNU Affero General Public License in
+# <https://www.github.com/TeamUltroid/Ultroid/blob/main/LICENSE/>.
+
+import re
+import time
+from datetime import datetime
+from os import remove
+import resources
+from git import Repo
+from telethon import Button
+from telethon.tl.types import InputWebDocument, Message
+from telethon.utils import resolve_bot_file_id
+
+from xteam._misc._assistant import callback, in_pattern
+from xteam.dB._core import HELP, LIST
+from xteam.fns.helper import gen_chlog, time_formatter, updater
+from xteam.fns.misc import split_list
+
+from . import (
+    HNDLR,
+    LOGS,
+    OWNER_NAME,
+    InlinePlugin,
+    asst,
+    get_string,
+    inline_pic,
+    split_list,
+    start_time,
+    udB,
+)
+from ._help import _main_help_menu
+
+# ================================================#
+
+helps = get_string("inline_1")
+
+add_ons = udB.get_key("ADDONS")
+
+zhelps = get_string("inline_3") if add_ons is False else get_string("inline_2")
+PLUGINS = HELP.get("Official", [])
+ADDONS = HELP.get("Addons", [])
+upage = 0
+# ============================================#
+
+# --------------------BUTTONS--------------------#
+
+SUP_BUTTONS = [
+    [
+        Button.url("• Repo •", url="https://github.com/xteam-cloner/Userbotx"),
+    ],
+]
+
+# --------------------BUTTONS--------------------#
+
+
+@in_pattern("repo",owner=False)
+async def inline_alive(o):
+    TLINK = inline_pic() or "https://telegra.ph/file/cad7038fe82e47f79c609.jpg"
+    MSG = "**What are you looking for?**"
+    WEB0 = InputWebDocument(
+        "https://telegra.ph/file/cad7038fe82e47f79c609.jpg", 0, "image/jpg", []
+    )
+    RES = [
+        await o.builder.article(
+            type="photo",
+            text=MSG,
+            include_media=True,
+            buttons=SUP_BUTTONS,
+            title="Userbot",
+            description="Userbot",
+            url=TLINK,
+            thumb=WEB0,
+            content=InputWebDocument(TLINK, 0, "image/jpg", []),
+        )
+    ]
+    await o.answer(
+        RES,
+        private=True,
+        cache_time=300,
+        switch_pm="xteam-userbot",
+        switch_pm_param="start",
+    )
+
+
+@in_pattern("ultd", owner=True)
+async def inline_handler(event):
+    z = []
+    for x in LIST.values():
+        z.extend(x)
+    text = get_string("inline_4").format(
+        OWNER_NAME,
+        len(HELP.get("Official", [])),
+        len(HELP.get("Addons", [])),
+        len(z),
+    )
+    if inline_pic():
+        result = await event.builder.photo(
+            file=inline_pic(),
+            link_preview=False,
+            text=text,
+            buttons=page_num,
+        )
+    else:
+        result = await event.builder.article(
+            title="Ultroid Help Menu", text=text, buttons=_main_help_menu
+        )
+    await event.answer([result], private=True, cache_time=300, gallery=True)
+
+
+@in_pattern("pasta", owner=True)
+async def _(event):
+    ok = event.text.split("-")[1]
+    link = f"https://spaceb.in/{ok}"
+    raw = f"https://spaceb.in/api/v1/documents/{ok}/raw"
+    result = await event.builder.article(
+        title="Paste",
+        text="Pasted to Spacebin 🌌",
+        buttons=[
+            [
+                Button.url("SpaceBin", url=link),
+                Button.url("Raw", url=raw),
+            ],
+        ],
+    )
+    await event.answer([result])
+
+
+@callback("ownr", owner=True)
+async def setting(event):
+    z = []
+    for x in LIST.values():
+        z.extend(x)
+    await event.edit(
+        get_string("inline_4").format(
+            OWNER_NAME,
+            len(HELP.get("Official", [])),
+            len(HELP.get("Addons", [])),
+            len(z),
+        ),
+        file=inline_pic(),
+        link_preview=False,
+        buttons=[
+            [
+                Button.inline("•Pɪɴɢ•", data="pkng"),
+                Button.inline("•Uᴘᴛɪᴍᴇ•", data="upp"),
+            ],
+            [
+                Button.inline("•Stats•", data="alive"),
+                Button.inline("•Uᴘᴅᴀᴛᴇ•", data="doupdate"),
+            ],
+            [Button.inline("« Bᴀᴄᴋ", data="open")],
+        ],
+    )
+
+
+_strings = {"Official": helps, "Addons": zhelps, "VCBot": get_string("inline_6")}
+
+
+@callback(re.compile("uh_(.*)"), owner=True)
+async def help_func(ult):
+    key, count = ult.data_match.group(1).decode("utf-8").split("_")
+    if key == "VCBot" and HELP.get("VCBot") is None:
+        return await ult.answer(get_string("help_12"), alert=True)
+    elif key == "Addons" and HELP.get("Addons") is None:
+        return await ult.answer(get_string("help_13").format(HNDLR), alert=True)
+    if "|" in count:
+        _, count = count.split("|")
+    count = int(count) if count else 0
+    text = _strings.get(key, "").format(OWNER_NAME, len(HELP.get(key)))
+    await ult.edit(text, buttons=page_num(count, key), link_preview=False)
+
+
+@callback(re.compile("uplugin_(.*)"), owner=True)
+async def uptd_plugin(event):
+    key, file = event.data_match.group(1).decode("utf-8").split("_")
+    index = None
+    if "|" in file:
+        file, index = file.split("|")
+    key_ = HELP.get(key, [])
+    hel_p = f"Plugin Name - `{file}`\n"
+    help_ = ""
+    try:
+        for i in key_[file]:
+            help_ += i
+    except BaseException:
+        if file in LIST:
+            help_ = get_string("help_11").format(file)
+            for d in LIST[file]:
+                help_ += HNDLR + d
+                help_ += "\n"
+    if not help_:
+        help_ = f"{file} has no Detailed Help!"
+    help_ += "\n© @xteam_cloner"
+    buttons = []
+    if inline_pic():
+        data = f"sndplug_{key}_{file}"
+        if index is not None:
+            data += f"|{index}"
+        buttons.append(
+            [
+                Button.inline(
+                    "« Sᴇɴᴅ Pʟᴜɢɪɴ »",
+                    data=data,
+                )
+            ]
+        )
+    data = f"uh_{key}_"
+    if index is not None:
+        data += f"|{index}"
+    buttons.append(
+        [
+            Button.inline("<<", data=data),
+        ]
+    )
+    try:
+        await event.edit(help_, buttons=buttons)
+    except Exception as er:
+        LOGS.exception(er)
+        help = f"Do `{HNDLR}help {key}` to get list of commands."
+        await event.edit(help, buttons=buttons)
+
+
+@callback(data="doupdate", owner=True)
+async def _(event):
+    if not await updater():
+        return await event.answer(get_string("inline_9"), cache_time=0, alert=True)
+    if not inline_pic():
+        return await event.answer(f"Do '{HNDLR}update' to update..")
+    repo = Repo.init()
+    changelog, tl_chnglog = await gen_chlog(
+        repo, f"HEAD..upstream/{repo.active_branch}"
+    )
+    changelog_str = changelog + "\n\n" + get_string("inline_8")
+    if len(changelog_str) > 1024:
+        await event.edit(get_string("upd_4"))
+        with open("ultroid_updates.txt", "w+") as file:
+            file.write(tl_chnglog)
+        await event.edit(
+            get_string("upd_5"),
+            file="ultroid_updates.txt",
+            buttons=[
+                [Button.inline("• Uᴘᴅᴀᴛᴇ Nᴏᴡ •", data="updatenow")],
+                [Button.inline("<<", data="ownr")],
+            ],
+        )
+        remove("ultroid_updates.txt")
+    else:
+        await event.edit(
+            changelog_str,
+            buttons=[
+                [Button.inline("Update Now", data="updatenow")],
+                [Button.inline("<<", data="ownr")],
+            ],
+            parse_mode="html",
+        )
+
+
+@callback(data="pkng", owner=True)
+async def _(event):
+    start = datetime.now()
+    end = datetime.now()
+    ms = (end - start).microseconds
+    pin = f"🌋Pɪɴɢ = {ms} microseconds"
+    await event.answer(pin, cache_time=0, alert=True)
+
+
+@callback(data="upp", owner=True)
+async def _(event):
+    uptime = time_formatter((time.time() - start_time) * 1000)
+    pin = f"🙋Uᴘᴛɪᴍᴇ = {uptime}"
+    await event.answer(pin, cache_time=0, alert=True)
+
+
+@callback(data="inlone", owner=True)
+async def _(e):
+    _InButtons = [
+        Button.switch_inline(_, query=InlinePlugin[_], same_peer=True)
+        for _ in list(InlinePlugin.keys())
+    ]
+    InButtons = split_list(_InButtons, 2)
+
+    button = InButtons.copy()
+    button.append(
+        [
+            Button.inline("<<", data="open"),
+        ],
+    )
+    await e.edit(buttons=button, link_preview=False)
+
+
+@callback(data="open", owner=True)
+async def opner(event):
+    z = []
+    for x in LIST.values():
+        z.extend(x)
+    await event.edit(
+        get_string("inline_4").format(
+            OWNER_NAME,
+            len(HELP.get("Official", [])),
+            len(HELP.get("Addons", [])),
+            len(z),
+        ),
+        buttons=_main_help_menu,
+        link_preview=False,
+    )
+
+
+@callback(data="close", owner=True)
+async def on_plug_in_callback_query_handler(event):
+    await event.delete()
+
+
+def page_num(index, key):
+    rows = udB.get_key("HELP_ROWS") or 5
+    cols = udB.get_key("HELP_COLUMNS") or 2
+    loaded = HELP.get(key, [])
+    emoji = udB.get_key("EMOJI_IN_HELP") or "🫧"
+    List = [
+        Button.inline(f"{emoji} {x} {emoji}", data=f"uplugin_{key}_{x}|{index}")
+        for x in sorted(loaded)
+    ]
+    all_ = split_list(List, cols)
+    fl_ = split_list(all_, rows)
+    try:
+        new_ = fl_[index]
+    except IndexError:
+        new_ = fl_[0] if fl_ else []
+        index = 0
+    if index == 0 and len(fl_) == 1:
+        new_.append([Button.inline("×", data="open")])
+    else:
+        new_.append(
+            [
+                Button.inline(
+                    "<",
+                    data=f"uh_{key}_{index-1}",
+                ),
+                Button.inline("×", data="open"),
+                Button.inline(
+                    ">",
+                    data=f"uh_{key}_{index+1}",
+                ),
+            ]
+        )
+    return new_
+
+
+# --------------------------------------------------------------------------------- #
+
+
+STUFF = {}
+
+
+@in_pattern("stf(.*)", owner=True)
+async def ibuild(e):
+    n = e.pattern_match.group(1).strip()
+    builder = e.builder
+    if not (n and n.isdigit()):
+        return
+    ok = STUFF.get(int(n))
+    txt = ok.get("msg")
+    pic = ok.get("media")
+    btn = ok.get("button")
+    if not (pic or txt):
+        txt = "Hey!"
+    if pic:
+        try:
+            include_media = True
+            mime_type, _pic = None, None
+            cont, results = None, None
+            try:
+                ext = str(pic).split(".")[-1].lower()
+            except BaseException:
+                ext = None
+            if ext in ["img", "jpg", "png"]:
+                _type = "photo"
+                mime_type = "image/jpg"
+            elif ext in ["mp4", "mkv", "gif"]:
+                mime_type = "video/mp4"
+                _type = "gif"
+            else:
+                try:
+                    if "telethon.tl.types" in str(type(pic)):
+                        _pic = pic
+                    else:
+                        _pic = resolve_bot_file_id(pic)
+                except BaseException:
+                    pass
+                if _pic:
+                    results = [
+                        await builder.document(
+                            _pic,
+                            title="Ultroid Op",
+                            text=txt,
+                            description="@TeamUltroid",
+                            buttons=btn,
+                            link_preview=False,
+                        )
+                    ]
+                else:
+                    _type = "article"
+                    include_media = False
+            if not results:
+                if include_media:
+                    cont = InputWebDocument(pic, 0, mime_type, [])
+                results = [
+                    await builder.article(
+                        title="Ultroid Op",
+                        type=_type,
+                        text=txt,
+                        description="@TeamUltroid",
+                        include_media=include_media,
+                        buttons=btn,
+                        thumb=cont,
+                        content=cont,
+                        link_preview=False,
+                    )
+                ]
+            return await e.answer(results)
+        except Exception as er:
+            LOGS.exception(er)
+    result = [
+        await builder.article("Ultroid Op", text=txt, link_preview=False, buttons=btn)
+    ]
+    await e.answer(result)
+
+
+async def something(e, msg, media, button, reply=True, chat=None):
+    if e.client._bot:
+        return await e.reply(msg, file=media, buttons=button)
+    num = len(STUFF) + 1
+    STUFF.update({num: {"msg": msg, "media": media, "button": button}})
+    try:
+        res = await e.client.inline_query(asst.me.username, f"stf{num}")
+        return await res[0].click(
+            chat or e.chat_id,
+            reply_to=bool(isinstance(e, Message) and reply),
+            hide_via=True,
+            silent=True,
+        )
+
+    except Exception as er:
+        LOGS.exception(er)

plugins/_sendplugin.py

@@ -0,0 +1,92 @@
+# < Source - t.me/testingpluginnn >
+# < https://github.com/TeamUltroid/Ultroid >
+
+"""
+✘ **Send any Installed Plugin to the Chat!**
+
+>> Use : `{i}cd <plugin_name>`
+"""
+
+import os
+
+from . import *
+async def get_paste(data: str, extension: str = "txt"):
+    ssl_context = ssl.create_default_context(cafile=certifi.where())
+    json = {"content": data, "extension": extension}
+    key = await async_searcher(
+        url="https://spaceb.in/api/",
+        json=json,
+        ssl=ssl_context,
+        post=True,
+        re_json=True,
+    )
+    try:
+        return True, key["payload"]["id"]
+    except KeyError:
+        if "the length must be between 2 and 400000." in key["error"]:
+            return await get_paste(data[-400000:], extension=extension)
+        return False, key["error"]
+    except Exception as e:
+        LOGS.info(e)
+        return None, str(e)
+
+
+def send(fn):
+    lst = ["plugins", "addons"]
+    if not fn.endswith(".py"):
+        fn += ".py"
+    for i in lst:
+        path = os.path.join(i, fn)
+        if os.path.exists(path):
+            return path
+    else:
+        return
+
+
+def alt_send(fn):
+    import re
+    for k, v in LIST.items():
+        for fx in v:
+            if re.findall(fn, fx):
+                return send(k)
+    else:
+        return
+
+
+async def pastee(path):
+    with open(path, "r") as f:
+        data = f.read()
+    err, linky = await get_paste(data)
+    if err:
+        return f"<b>>> <a href='https://spaceb.in/{linky}'>Pasted Here!</a></b> \n"
+    else:
+        LOGS.error(linky)
+        return ""
+
+
+@ultroid_cmd(pattern="cd ?(.*)")
+async def semd_plugin(ult):
+    repo = "https://github.com/xteam-clone r/Userbotx"
+    args = ult.pattern_match.group(1)
+    if not args:
+        return await ult.eod("`Give a modules name too`")
+
+    eris = await ult.eor("`...`")
+    path = send(args)
+    if not path:
+        path = alt_send(args)
+    if not path:
+        return await eris.edit(f"No modules were found for: `{args}`")
+
+    paste = await pastee(path)
+    caption = f"<b>>> </b><code>{path}</code> \n{paste} \n" \
+        f"© <a href='{repo}'>Userbot</a>"
+    try:
+        await ult.client.send_file(
+            ult.chat_id, path,
+            caption=caption, parse_mode="html",
+            silent=True, reply_to=ult.reply_to_msg_id,
+        )
+        await eris.delete()
+    except Exception as fx:
+        return await eris.edit(str(fx))

plugins/_ultroid.py

@@ -0,0 +1,66 @@
+# Ultroid - UserBot
+# Copyright (C) 2021-2023 TeamUltroid
+#
+# This file is a part of < https://github.com/TeamUltroid/Ultroid/ >
+# PLease read the GNU Affero General Public License in
+# <https://www.github.com/TeamUltroid/Ultroid/blob/main/LICENSE/>.
+
+from telethon.errors import (
+    BotMethodInvalidError,
+    ChatSendInlineForbiddenError,
+    ChatSendMediaForbiddenError,
+)
+
+from . import LOG_CHANNEL, LOGS, Button, asst, eor, get_string, ultroid_cmd
+
+REPOMSG = """
+• **USERBOT** •\n
+• Repo - [Click Here](https://github.com/xteam-cloner/Userbot)
+• Addons - [Click Here](https://github.com/xteam-cloner/Userbot)
+• Support - @xteam_cloner
+"""
+
+RP_BUTTONS = [
+    [
+        Button.url(get_string("bot_3"), "https://github.com/xteam-cloner/Userbot"),
+        Button.url("Addons", "https://github.com/xteam-cloner/Userbot"),
+    ],
+    [Button.url("Support Group", "t.me/xteam_cloner")],
+]
+
+ULTSTRING = """🎇 **Thanks for Deploying Userbot!**
+
+• Here, are the Some Basic stuff from, where you can Know, about its Usage."""
+
+
+@ultroid_cmd(
+    pattern="repo$",
+    manager=True,
+)
+async def repify(e):
+    try:
+        q = await e.client.inline_query(asst.me.username, "")
+        await q[0].click(e.chat_id)
+        return await e.delete()
+    except (
+        ChatSendInlineForbiddenError,
+        ChatSendMediaForbiddenError,
+        BotMethodInvalidError,
+    ):
+        pass
+    except Exception as er:
+        LOGS.info(f"Error while repo command : {str(er)}")
+    await e.eor(REPOMSG)
+
+
+@ultroid_cmd(pattern="userbot$")
+async def useUltroid(rs):
+    button = Button.inline("Start >>", "initft_2")
+    msg = await asst.send_message(
+        LOG_CHANNEL,
+        ULTSTRING,
+        file="https://telegra.ph/file/8d7b534e34e13316a7dd2.jpg",
+        buttons=button,
+    )
+    if not (rs.chat_id == LOG_CHANNEL and rs.client._bot):
+        await eor(rs, f"**[Click Here]({msg.message_link})**")

plugins/_userlogs.py

@@ -0,0 +1,297 @@
+# Ultroid - UserBot
+# Copyright (C) 2021-2023 TeamUltroid
+#
+# This file is a part of < https://github.com/TeamUltroid/Ultroid/ >
+# PLease read the GNU Affero General Public License in
+# <https://www.github.com/TeamUltroid/Ultroid/blob/main/LICENSE/>.
+
+import os
+import re
+
+from telethon.errors.rpcerrorlist import (
+    ChannelPrivateError,
+    ChatWriteForbiddenError,
+    MediaCaptionTooLongError,
+    MediaEmptyError,
+    MessageTooLongError,
+    PeerIdInvalidError,
+    UserNotParticipantError,
+)
+from telethon.tl.types import MessageEntityMention, MessageEntityMentionName, User
+from telethon.utils import get_display_name
+
+from xteam.dB.botchat_db import tag_add, who_tag
+
+from . import (
+    LOG_CHANNEL,
+    LOGS,
+    Button,
+    asst,
+    callback,
+    events,
+    get_string,
+    inline_mention,
+    udB,
+    ultroid_bot,
+)
+
+CACHE_SPAM = {}
+TAG_EDITS = {}
+
+
+@ultroid_bot.on(
+    events.NewMessage(
+        incoming=True,
+        func=lambda e: (e.mentioned),
+    ),
+)
+async def all_messages_catcher(e):
+    x = await e.get_sender()
+    if isinstance(x, User) and (x.bot or x.verified):
+        return
+    if not udB.get_key("TAG_LOG"):
+        return
+    NEEDTOLOG = udB.get_key("TAG_LOG")
+    buttons = await parse_buttons(e)
+    try:
+        sent = await asst.send_message(NEEDTOLOG, e.message, buttons=buttons)
+        if TAG_EDITS.get(e.chat_id):
+            TAG_EDITS[e.chat_id].update({e.id: {"id": sent.id, "msg": e}})
+        else:
+            TAG_EDITS.update({e.chat_id: {e.id: {"id": sent.id, "msg": e}}})
+        tag_add(sent.id, e.chat_id, e.id)
+    except MediaEmptyError as er:
+        LOGS.debug(f"handling {er}.")
+        try:
+            msg = await asst.get_messages(e.chat_id, ids=e.id)
+            sent = await asst.send_message(NEEDTOLOG, msg, buttons=buttons)
+            if TAG_EDITS.get(e.chat_id):
+                TAG_EDITS[e.chat_id].update({e.id: {"id": sent.id, "msg": e}})
+            else:
+                TAG_EDITS.update({e.chat_id: {e.id: {"id": sent.id, "msg": e}}})
+            tag_add(sent.id, e.chat_id, e.id)
+        except Exception as me:
+            if not isinstance(me, (PeerIdInvalidError, ValueError)):
+                LOGS.exception(me)
+            if e.photo or e.sticker or e.gif:
+                try:
+                    media = await e.download_media()
+                    sent = await asst.send_message(
+                        NEEDTOLOG, e.message.text, file=media, buttons=buttons
+                    )
+                    if TAG_EDITS.get(e.chat_id):
+                        TAG_EDITS[e.chat_id].update({e.id: {"id": sent.id, "msg": e}})
+                    else:
+                        TAG_EDITS.update({e.chat_id: {e.id: {"id": sent.id, "msg": e}}})
+                    return os.remove(media)
+                except Exception as er:
+                    LOGS.exception(er)
+            await asst.send_message(NEEDTOLOG, get_string("com_4"), buttons=buttons)
+    except (PeerIdInvalidError, ValueError) as er:
+        LOGS.exception(er)
+        try:
+            CACHE_SPAM[NEEDTOLOG]
+        except KeyError:
+            await asst.send_message(
+                udB.get_key("LOG_CHANNEL"), get_string("userlogs_1")
+            )
+            CACHE_SPAM.update({NEEDTOLOG: True})
+    except ChatWriteForbiddenError:
+        try:
+            await asst.get_permissions(NEEDTOLOG, "me")
+            MSG = get_string("userlogs_4")
+        except UserNotParticipantError:
+            MSG = get_string("userlogs_2")
+        try:
+            CACHE_SPAM[NEEDTOLOG]
+        except KeyError:
+            await asst.send_message(LOG_CHANNEL, MSG)
+            CACHE_SPAM.update({NEEDTOLOG: True})
+    except Exception as er:
+        LOGS.exception(er)
+
+
+if udB.get_key("TAG_LOG"):
+
+    @ultroid_bot.on(events.MessageEdited(func=lambda x: not x.out))
+    async def upd_edits(event):
+        x = event.sender
+        if isinstance(x, User) and (x.bot or x.verified):
+            return
+        if event.chat_id not in TAG_EDITS:
+            if event.sender_id == udB.get_key("TAG_LOG"):
+                return
+            if event.is_private:
+                return
+            if entities := event.get_entities_text():
+                is_self = False
+                username = event.client.me.username
+                if username:
+                    username = username.lower()
+                for ent, text in entities:
+                    if isinstance(ent, MessageEntityMention):
+                        is_self = text[1:].lower() == username
+                    elif isinstance(ent, MessageEntityMentionName):
+                        is_self = ent.user_id == event.client.me.id
+                if is_self:
+                    text = f"**#Edited & #Mentioned**\n\n{event.text}"
+                    try:
+                        sent = await asst.send_message(
+                            udB.get_key("TAG_LOG"),
+                            text,
+                            buttons=await parse_buttons(event),
+                        )
+                    except Exception as er:
+                        return LOGS.exception(er)
+                    if TAG_EDITS.get(event.chat_id):
+                        TAG_EDITS[event.chat_id].update({event.id: {"id": sent.id}})
+                    else:
+                        TAG_EDITS.update({event.chat_id: {event.id: {"id": sent.id}}})
+            return
+        d_ = TAG_EDITS[event.chat_id]
+        if not d_.get(event.id):
+            return
+        d_ = d_[event.id]
+        if d_["msg"].text == event.text:
+            return
+        msg = None
+        if d_.get("count"):
+            d_["count"] += 1
+        else:
+            msg = True
+            d_.update({"count": 1})
+        if d_["count"] > 10:
+            return  # some limit to take edits
+        try:
+            MSG = await asst.get_messages(udB.get_key("TAG_LOG"), ids=d_["id"])
+        except Exception as er:
+            return LOGS.exception(er)
+        TEXT = MSG.text
+        if msg:
+            TEXT += "\n\n🖋 **Later Edited to !**"
+        strf = event.edit_date.strftime("%H:%M:%S")
+        if "\n" not in event.text:
+            TEXT += f"\n• `{strf}` : {event.text}"
+        else:
+            TEXT += f"\n• `{strf}` :\n-> {event.text}"
+        if d_["count"] == 10:
+            TEXT += "\n\n• __Only the first 10 Edits are shown.__"
+        try:
+            msg = await MSG.edit(TEXT, buttons=await parse_buttons(event))
+            d_["msg"] = msg
+        except (MessageTooLongError, MediaCaptionTooLongError):
+            del TAG_EDITS[event.chat_id][event.id]
+        except Exception as er:
+            LOGS.exception(er)
+
+    @ultroid_bot.on(
+        events.NewMessage(
+            outgoing=True,
+            chats=[udB.get_key("TAG_LOG")],
+            func=lambda e: e.reply_to,
+        )
+    )
+    async def idk(e):
+        id = e.reply_to_msg_id
+        chat, msg = who_tag(id)
+        if chat and msg:
+            try:
+                await ultroid_bot.send_message(chat, e.message, reply_to=msg)
+            except BaseException as er:
+                LOGS.exception(er)
+
+
+# log for assistant/user joins/add
+
+
+async def when_added_or_joined(event):
+    user = await event.get_user()
+    chat = await event.get_chat()
+    if not (user and user.is_self):
+        return
+    if getattr(chat, "username", None):
+        chat = f"[{chat.title}](https://t.me/{chat.username}/{event.action_message.id})"
+    else:
+        chat = f"[{chat.title}](https://t.me/c/{chat.id}/{event.action_message.id})"
+    key = "bot" if event.client._bot else "user"
+    buttons = Button.inline(
+        get_string("userlogs_3"), data=f"leave_ch_{event.chat_id}|{key}"
+    )
+    if event.user_added:
+        tmp = event.added_by
+        text = f"#ADD_LOG\n\n{inline_mention(tmp)} just added {inline_mention(user)} to {chat}."
+    elif event.from_request:
+        text = f"#APPROVAL_LOG\n\n{inline_mention(user)} just got Chat Join Approval to {chat}."
+    else:
+        text = f"#JOIN_LOG\n\n{inline_mention(user)} just joined {chat}."
+    await asst.send_message(udB.get_key("LOG_CHANNEL"), text, buttons=buttons)
+
+
+asst.add_event_handler(
+    when_added_or_joined, events.ChatAction(func=lambda x: x.user_added)
+)
+ultroid_bot.add_event_handler(
+    when_added_or_joined,
+    events.ChatAction(func=lambda x: x.user_added or x.user_joined),
+)
+_client = {"bot": asst, "user": ultroid_bot}
+
+
+@callback(
+    re.compile(
+        "leave_ch_(.*)",
+    ),
+    from_users=[ultroid_bot.uid],
+)
+async def leave_ch_at(event):
+    cht = event.data_match.group(1).decode("UTF-8")
+    ch_id, client = cht.split("|")
+    try:
+        client = _client[client]
+    except KeyError:
+        return
+    try:
+        name = (await client.get_entity(int(ch_id))).title
+        await client.delete_dialog(int(ch_id))
+    except UserNotParticipantError:
+        pass
+    except ChannelPrivateError:
+        return await event.edit(
+            "`[CANT_ACCESS_CHAT]` `Maybe already left or got banned.`"
+        )
+    except Exception as er:
+        LOGS.exception(er)
+        return await event.answer(str(er))
+    await event.edit(get_string("userlogs_5").format(name))
+
+
+@callback("do_nothing")
+async def _(event):
+    await event.answer()
+
+
+async def parse_buttons(event):
+    y, x = event.chat, event.sender
+    where_n, who_n = get_display_name(y), get_display_name(x)
+    where_l = event.message_link
+    buttons = [[Button.url(where_n, where_l)]]
+    if isinstance(x, User) and x.username:
+        try:
+            buttons.append(
+                [Button.mention(who_n, await asst.get_input_entity(x.username))]
+            )
+        except Exception as er:
+            LOGS.exception(er)
+            buttons.append([Button.url(who_n, f"t.me/{x.username}")])
+    elif getattr(x, "username"):
+        buttons.append([Button.url(who_n, f"t.me/{x.username}")])
+    else:
+        buttons.append([Button.url(who_n, where_l)])
+    replied = await event.get_reply_message()
+    if replied and replied.out:
+        button = Button.url("Replied to", replied.message_link)
+        if len(who_n) > 7:
+            buttons.append([button])
+        else:
+            buttons[-1].append(button)
+    return buttons

plugins/_wspr.py

@@ -0,0 +1,204 @@
+# Ultroid - UserBot
+# Copyright (C) 2021-2023 TeamUltroid
+#
+# This file is a part of < https://github.com/TeamUltroid/Ultroid/ >
+# PLease read the GNU Affero General Public License in
+# <https://www.github.com/TeamUltroid/Ultroid/blob/main/LICENSE/>.
+
+import re
+
+from telethon import Button
+from telethon.errors.rpcerrorlist import (
+    BotInlineDisabledError,
+    BotResponseTimeoutError,
+    MessageNotModifiedError,
+)
+from telethon.tl import types
+from telethon.tl.functions.users import GetFullUserRequest as gu
+
+from . import (
+    HNDLR,
+    LOGS,
+    asst,
+    callback,
+    get_string,
+    in_pattern,
+    inline_mention,
+    ultroid_bot,
+    ultroid_cmd,
+)
+
+buddhhu = {}
+
+
+@ultroid_cmd(
+    pattern="wspr( (.*)|$)",
+)
+async def _(e):
+    if e.reply_to_msg_id:
+        okk = await e.get_reply_message()
+        put = f"@{okk.sender.username}" if okk.sender.username else okk.sender_id
+    else:
+        put = e.pattern_match.group(1).strip()
+    if put:
+        try:
+            results = await e.client.inline_query(asst.me.username, f"msg {put}")
+        except BotResponseTimeoutError:
+            return await e.eor(
+                get_string("help_2").format(HNDLR),
+            )
+        except BotInlineDisabledError:
+            return await e.eor(get_string("help_3"))
+        await results[0].click(e.chat_id, reply_to=e.reply_to_msg_id, hide_via=True)
+        return await e.delete()
+    await e.eor(get_string("wspr_3"))
+
+
+@in_pattern("wspr", owner=True)
+async def _(e):
+    iuser = e.query.user_id
+    zzz = e.text.split(maxsplit=2)
+    try:
+        query = zzz[1]
+        if query.isdigit():
+            query = int(query)
+        logi = await ultroid_bot.get_entity(query)
+        if not isinstance(logi, types.User):
+            raise ValueError("Invalid Username.")
+    except IndexError:
+        sur = await e.builder.article(
+            title="Give Username",
+            description="You Didn't Type Username or id.",
+            text="You Didn't Type Username or id.",
+        )
+        return await e.answer([sur])
+    except ValueError as er:
+        LOGS.exception(er)
+        sur = await e.builder.article(
+            title="User Not Found",
+            description="Make sure username or id is correct.",
+            text="Make sure username or id is correct.",
+        )
+        return await e.answer([sur])
+    try:
+        desc = zzz[2]
+    except IndexError:
+        sur = await e.builder.article(
+            title="Type ur msg", text="You Didn't Type Your Msg"
+        )
+        return await e.answer([sur])
+    button = [
+        [
+            Button.inline("Secret Msg", data=f"dd_{e.id}"),
+            Button.inline("Delete Msg", data=f"del_{e.id}"),
+        ],
+        [
+            Button.switch_inline(
+                "New", query=f"wspr {logi.username or logi.id}", same_peer=True
+            )
+        ],
+    ]
+    us = logi.username or logi.first_name
+    sur = await e.builder.article(
+        title=logi.first_name,
+        description=desc,
+        text=get_string("wspr_1").format(us),
+        buttons=button,
+    )
+    buddhhu.update({e.id: [logi.id, iuser, desc]})
+    await e.answer([sur])
+
+
+@in_pattern("msg", owner=True)
+async def _(e):
+    zzz = e.text.split(maxsplit=1)
+    desc = "Touch me"
+    try:
+        query = zzz[1]
+        if query.isdigit():
+            query = int(query)
+        logi = await ultroid_bot(gu(id=query))
+        user = logi.users[0]
+        mention = inline_mention(user)
+        x = user.status
+        if isinstance(x, types.UserStatusOnline):
+            status = "Online"
+        elif isinstance(x, types.UserStatusOffline):
+            status = "Offline"
+        elif isinstance(x, types.UserStatusRecently):
+            status = "Last Seen Recently"
+        elif isinstance(x, types.UserStatusLastMonth):
+            status = "Last seen months ago"
+        elif isinstance(x, types.UserStatusLastWeek):
+            status = "Last seen weeks ago"
+        else:
+            status = "Can't Tell"
+        text = f"**Name:**    `{user.first_name}`\n"
+        text += f"**Id:**    `{user.id}`\n"
+        if user.username:
+            text += f"**Username:**    `{user.username}`\n"
+            url = f"https://t.me/{user.username}"
+        else:
+            text += f"**Mention:**    `{mention}`\n"
+            url = f"tg://user?id={user.id}"
+        text += f"**Status:**    `{status}`\n"
+        text += f"**About:**    `{logi.full_user.about}`"
+        button = [
+            Button.url("Private", url=url),
+            Button.switch_inline(
+                "Secret msg",
+                query=f"wspr {query} Hello 👋",
+                same_peer=True,
+            ),
+        ]
+        sur = e.builder.article(
+            title=user.first_name,
+            description=desc,
+            text=text,
+            buttons=button,
+        )
+    except IndexError:
+        sur = e.builder.article(
+            title="Give Username",
+            description="You Didn't Type Username or id.",
+            text="You Didn't Type Username or id.",
+        )
+    except BaseException as er:
+        LOGS.exception(er)
+        name = get_string("wspr_4").format(query)
+        sur = e.builder.article(
+            title=name,
+            text=name,
+        )
+
+    await e.answer([sur])
+
+
+@callback(
+    re.compile(
+        "dd_(.*)",
+    ),
+)
+async def _(e):
+    ids = int(e.pattern_match.group(1).strip().decode("UTF-8"))
+    if buddhhu.get(ids):
+        if e.sender_id in buddhhu[ids]:
+            await e.answer(buddhhu[ids][-1], alert=True)
+        else:
+            await e.answer("Not For You", alert=True)
+    else:
+        await e.answer(get_string("wspr_2"), alert=True)
+
+
+@callback(re.compile("del_(.*)"))
+async def _(e):
+    ids = int(e.pattern_match.group(1).strip().decode("UTF-8"))
+    if buddhhu.get(ids):
+        if e.sender_id in buddhhu[ids]:
+            buddhhu.pop(ids)
+            try:
+                await e.edit(get_string("wspr_2"))
+            except MessageNotModifiedError:
+                pass
+        else:
+            await e.answer(get_string("wspr_5"), alert=True)

plugins/absen.py

@@ -0,0 +1,107 @@
+# Ayiin - Userbot
+# Copyright (C) 2022-2023 @AyiinXd
+#
+# This file is a part of < https://github.com/AyiinXd/Ayiin-Userbot >
+# PLease read the GNU Affero General Public License in
+# <https://www.github.com/AyiinXd/Ayiin-Userbot/blob/main/LICENSE/>.
+#
+# FROM Ayiin-Userbot <https://github.com/AyiinXd/Ayiin-Userbot>
+# t.me/AyiinXdSupport & t.me/AyiinSupport
+
+# ========================×========================
+#            Jangan Hapus Credit Ngentod
+# ========================×========================
+
+import time
+from datetime import datetime
+from secrets import choice 
+from xteam.dB import devs
+from telethon.tl.types import User
+from xteam._misc import sudoers
+from . import ultroid_cmd as ayiinCmd 
+from . import (
+    ATRA_COL,
+    LOGS,
+    OWNER_NAME,
+    ULTROID_IMAGES,
+    Button,
+    Carbon,
+    Telegraph,
+    Var,
+    allcmds,
+    asst,
+    bash,
+    call_back,
+    callback,
+    def_logs,
+    eor,
+    get_string,
+    heroku_logs,
+    in_pattern,
+    inline_pic,
+    restart,
+    shutdown,
+    start_time,
+    time_formatter,
+    udB,
+    ultroid_version,
+    updater,
+)
+
+absen = [
+    "**𝙃𝙖𝙙𝙞𝙧 𝙙𝙤𝙣𝙜 𝙏𝙤𝙙** 😁",
+    "**𝙃𝙖𝙙𝙞𝙧 𝙆𝙖𝙠𝙖 𝙂𝙖𝙣𝙩𝙚𝙣𝙜** 😉",
+    "**𝙂𝙪𝙖 𝙃𝙖𝙙𝙞𝙧 𝘾𝙤𝙣𝙩𝙤𝙡** 😁",
+    "**𝙂𝙪𝙖 𝙃𝙖𝙙𝙞𝙧 𝙂𝙖𝙣𝙩𝙚𝙣𝙜** 🥵",
+    "**𝙃𝙖𝙙𝙞𝙧 𝙉𝙜𝙖𝙗** 😎",
+    "**𝙂𝙪𝙖 𝙃𝙖𝙙𝙞𝙧 𝘼𝙗𝙖𝙣𝙜** 🥺",
+    "**𝙎𝙞 𝘾𝙖𝙠𝙚𝙥 𝙃𝙖𝙙𝙞𝙧 𝘽𝙖𝙣𝙜** 😎",
+]
+
+ayiincakep = [
+    "**𝙄𝙮𝙖 𝙂𝙖𝙣𝙩𝙚𝙣𝙜 𝘽𝙖𝙣𝙜𝙚𝙩** 😍",
+    "**𝙂𝙖𝙣𝙩𝙚𝙣𝙜𝙣𝙮𝙖 𝙂𝙖𝙠 𝘼𝙙𝙖 𝙇𝙖𝙬𝙖𝙣** 😚",
+    "**𝙠𝙖𝙢𝙪 𝙂𝙖𝙣𝙩𝙚𝙣𝙜𝙣𝙮𝙖 𝘼𝙠𝙪 𝙆𝙖𝙣** 😍",
+    "**𝙞𝙮𝙖𝙖 𝙜𝙖𝙙𝙖 𝙖𝙙𝙖 𝙨𝙖𝙞𝙣𝙜** 😎",
+    "**𝙠𝙖𝙢𝙪 𝙟𝙖𝙢𝙚𝙩 𝙏𝙖𝙥𝙞 𝘽𝙤𝙤𝙣𝙜** 😚",
+]
+
+
+@ayiinCmd("cping$", devs=True)
+async def _(ping):
+    start = time.time()
+    x = await ping.eor("Pong !")
+    end = round((time.time() - start) * 1000)
+    uptime = time_formatter((time.time() - start_time) * 1000)
+    user = await ping.client.get_me()
+    message = "**✧ ᴀʏɪɪɴ-ᴜsᴇʀʙᴏᴛ ✧**\n\n✧ **ᴘɪɴɢᴇʀ :** `{} ms`\n✧ **ᴜᴘᴛɪᴍᴇ :** `{}`\n✧ **ᴏᴡɴᴇʀ :** `{}`\n✧ **ɪᴅ :** `{}`"
+    await ping.reply(
+        message.format(
+            end,
+            uptime,
+            user.first_name,
+            user.id
+        )
+    )
+
+
+# KALO NGEFORK absen ini GA USAH DI HAPUS YA GOBLOK 😡
+# JANGAN DI HAPUS GOBLOK 😡 LU COPY AJA TINGGAL TAMBAHIN
+# DI HAPUS GUA GBAN YA 🥴 GUA TANDAIN LU AKUN TELENYA 😡
+
+# Absen by : mrismanaziz <https://github.com/mrismanaziz/man-userbot>
+
+@ayiinCmd("absen$", devs=True)
+async def ayiinabsen(ganteng):
+    await ganteng.reply(choice(absen))
+
+
+@ayiinCmd("Aku ganteng kan$", devs=True)
+async def ayiin(ganteng):
+    await ganteng.reply(choice(ayiincakep))
+
+
+# ========================×========================
+#            Jangan Hapus Credit Ngentod
+# ========================×========================
+

plugins/admintools.py

@@ -0,0 +1,472 @@
+# Ultroid - UserBot
+# Copyright (C) 2021-2023 TeamUltroid
+#
+# This file is a part of < https://github.com/TeamUltroid/Ultroid/ >
+# PLease read the GNU Affero General Public License in
+# <https://www.github.com/TeamUltroid/Ultroid/blob/main/LICENSE/>.
+
+from . import get_help
+
+__doc__ = get_help("help_admintools")
+
+import asyncio
+
+from telethon.errors import BadRequestError
+from telethon.errors.rpcerrorlist import ChatNotModifiedError, UserIdInvalidError
+from telethon.tl.functions.channels import EditAdminRequest, GetFullChannelRequest
+from telethon.tl.functions.messages import GetFullChatRequest, SetHistoryTTLRequest
+from telethon.tl.types import InputMessagesFilterPinned
+from telethon.utils import get_display_name
+
+from xteam.dB import DEVLIST
+from xteam.fns.admins import ban_time
+from xteam.fns.info import get_uinfo
+
+from . import HNDLR, LOGS, eod, eor, get_string, inline_mention, types, ultroid_cmd
+
+
+@ultroid_cmd(
+    pattern="promote( (.*)|$)",
+    admins_only=True,
+    manager=True,
+    require="add_admins",
+    fullsudo=True,
+)
+async def prmte(ult):
+    xx = await ult.eor(get_string("com_1"))
+    user, rank = await get_uinfo(ult)
+    rank = rank or "Admin"
+    FullRight = False
+    if not user:
+        return await xx.edit(get_string("pro_1"))
+    if rank.split()[0] == "-f":
+        try:
+            rank = rank.split(maxsplit=1)[1]
+        except IndexError:
+            rank = "Admin"
+        FullRight = True
+    try:
+        if FullRight:
+            await ult.client(
+                EditAdminRequest(ult.chat_id, user.id, ult.chat.admin_rights, rank)
+            )
+        else:
+            await ult.client.edit_admin(
+                ult.chat_id,
+                user.id,
+                invite_users=True,
+                ban_users=True,
+                delete_messages=True,
+                pin_messages=True,
+                manage_call=True,
+                title=rank,
+            )
+        await eod(
+            xx, get_string("pro_2").format(inline_mention(user), ult.chat.title, rank)
+        )
+    except Exception as ex:
+        return await xx.edit(f"`{ex}`")
+
+
+@ultroid_cmd(
+    pattern="demote( (.*)|$)",
+    admins_only=True,
+    manager=True,
+    require="add_admins",
+    fullsudo=True,
+)
+async def dmote(ult):
+    xx = await ult.eor(get_string("com_1"))
+    user, rank = await get_uinfo(ult)
+    if not rank:
+        rank = "Not Admin"
+    if not user:
+        return await xx.edit(get_string("de_1"))
+    try:
+        await ult.client.edit_admin(
+            ult.chat_id,
+            user.id,
+            invite_users=None,
+            ban_users=None,
+            delete_messages=None,
+            pin_messages=None,
+            manage_call=None,
+            title=rank,
+        )
+        await eod(xx, get_string("de_2").format(inline_mention(user), ult.chat.title))
+    except Exception as ex:
+        return await xx.edit(f"`{ex}`")
+
+
+@ultroid_cmd(
+    pattern="ban( (.*)|$)",
+    admins_only=True,
+    manager=True,
+    require="ban_users",
+    fullsudo=True,
+)
+async def bban(ult):
+    something = await get_uinfo(ult)
+    if not something:
+        return
+    user, reason = something
+    if not user:
+        return await eod(ult, get_string("ban_1"))
+    if user.id in DEVLIST:
+        return await eod(ult, get_string("ban_2"))
+    try:
+        await ult.client.edit_permissions(ult.chat_id, user.id, view_messages=False)
+    except UserIdInvalidError:
+        return await eod(ult, get_string("adm_1"))
+    except BadRequestError:
+        return await eod(ult, get_string("ban_3"))
+    senderme = inline_mention(await ult.get_sender())
+    userme = inline_mention(user)
+    text = get_string("ban_4").format(userme, senderme, ult.chat.title)
+    if reason:
+        text += get_string("ban_5").format(reason)
+    await eod(ult, text)
+
+
+@ultroid_cmd(
+    pattern="unban( (.*)|$)",
+    admins_only=True,
+    manager=True,
+    require="ban_users",
+    fullsudo=True,
+)
+async def uunban(ult):
+    xx = await ult.eor(get_string("com_1"))
+    if ult.text[1:].startswith("unbanall"):
+        return
+    something = await get_uinfo(ult)
+    if not something:
+        return
+    user, reason = something
+    if not user:
+        return await xx.edit(get_string("unban_1"))
+    try:
+        await ult.client.edit_permissions(ult.chat_id, user.id, view_messages=True)
+    except UserIdInvalidError:
+        return await eod(ult, get_string("adm_1"))
+    except BadRequestError:
+        return await xx.edit(get_string("adm_2"))
+    sender = inline_mention(await ult.get_sender())
+    text = get_string("unban_3").format(inline_mention(user), sender, ult.chat.title)
+    if reason:
+        text += get_string("ban_5").format(reason)
+    await xx.edit(text)
+
+
+@ultroid_cmd(
+    pattern="kick( (.*)|$)",
+    manager=True,
+    require="ban_users",
+    fullsudo=True,
+)
+async def kck(ult):
+    if "kickme" in ult.text:
+        return
+    if ult.is_private:
+        return await ult.eor("`Use this in Group/Channel.`", time=5)
+    ml = ult.text.split(" ", maxsplit=1)[0]
+    xx = await ult.eor(get_string("com_1"))
+    something = await get_uinfo(ult)
+    if not something:
+        return
+    user, reason = something
+    if not user:
+        return await xx.edit(get_string("adm_1"))
+    if user.id in DEVLIST:
+        return await xx.edit(get_string("kick_2"))
+    if getattr(user, "is_self", False):
+        return await xx.edit(get_string("kick_3"))
+    try:
+        await ult.client.kick_participant(ult.chat_id, user.id)
+    except BadRequestError as er:
+        LOGS.info(er)
+        return await xx.edit(get_string("kick_1"))
+    except Exception as e:
+        LOGS.exception(e)
+        return
+    text = get_string("kick_4").format(
+        inline_mention(user), inline_mention(await ult.get_sender()), ult.chat.title
+    )
+    if reason:
+        text += get_string("ban_5").format(reason)
+    await xx.edit(text)
+
+
+@ultroid_cmd(
+    pattern="tban( (.*)|$)",
+    admins_only=True,
+    manager=True,
+    require="ban_users",
+    fullsudo=True,
+)
+async def tkicki(e):
+    huh = e.text.split()
+    inputt = None
+    try:
+        tme = huh[1]
+    except IndexError:
+        return await e.eor(get_string("adm_3"), time=15)
+    try:
+        inputt = huh[2]
+    except IndexError:
+        if e.reply_to_msg_id:
+            inputt = (await e.get_reply_message()).sender_id
+    if not inputt:
+        return await e.eor(get_string("tban_1"))
+    userid = await e.client.parse_id(inputt)
+    try:
+        user = await e.client.get_entity(userid)
+    except Exception as ex:
+        return await eor(e, f"`{ex}`")
+    try:
+        bun = ban_time(tme)
+        await e.client.edit_permissions(
+            e.chat_id, user.id, until_date=bun, view_messages=False
+        )
+        await eod(
+            e,
+            get_string("tban_2").format(inline_mention(user), e.chat.title, tme),
+            time=15,
+        )
+    except Exception as m:
+        return await e.eor(str(m))
+
+
+@ultroid_cmd(pattern="pin$", manager=True, require="pin_messages", fullsudo=True)
+async def pin(msg):
+    if not msg.is_reply:
+        return await eor(msg, get_string("pin_1"))
+    me = await msg.get_reply_message()
+    if me.is_private:
+        text = "`Pinned.`"
+    else:
+        text = f"Pinned [This Message]({me.message_link}) !"
+    try:
+        await msg.client.pin_message(msg.chat_id, me.id, notify=False)
+    except BadRequestError:
+        return await eor(msg, get_string("adm_2"))
+    except Exception as e:
+        return await eor(msg, f"**ERROR:**`{e}`")
+    await eor(msg, text)
+
+
+@ultroid_cmd(
+    pattern="unpin($| (.*))",
+    manager=True,
+    require="pin_messages",
+    fullsudo=True,
+)
+async def unp(ult):
+    xx = await ult.eor(get_string("com_1"))
+    ch = (ult.pattern_match.group(1).strip()).strip()
+    msg = None
+    if ult.is_reply:
+        msg = ult.reply_to_msg_id
+    elif ch != "all":
+        return await xx.edit(get_string("unpin_1").format(HNDLR))
+    try:
+        await ult.client.unpin_message(ult.chat_id, msg)
+    except BadRequestError:
+        return await xx.edit(get_string("adm_2"))
+    except Exception as e:
+        return await xx.edit(f"**ERROR:**`{e}`")
+    await xx.edit("`Unpinned!`")
+
+
+@ultroid_cmd(
+    pattern="tpin( (.*)|$)",
+    admins_only=True,
+    manager=True,
+    require="pin_messages",
+    fullsudo=True,
+)
+async def pin_message(ult):
+    match = ult.pattern_match.group(1).strip()
+    if not ult.is_reply:
+        return await ult.eor("`Reply to message..`", time=6)
+    if not match:
+        return await ult.eor("`Please provide time..`", time=8)
+    msg = await ult.eor(get_string("com_1"))
+    msg_id = ult.reply_to_msg_id
+    try:
+        time = ban_time(match)
+        await ult.client.pin_message(ult.chat_id, msg_id)
+        await msg.eor(f"`pinned for time` `{time}`", time=8)
+    except Exception as er:
+        return await msg.edit(str(er))
+    await asyncio.sleep(time)
+    try:
+        await ult.client.unpin_message(ult.chat_id, msg_id)
+    except Exception as er:
+        LOGS.exception(er)
+
+
+@ultroid_cmd(pattern="purge( (.*)|$)", manager=True, require="delete_messages")
+async def fastpurger(purg):
+    match = purg.pattern_match.group(1).strip()
+    try:
+        ABC = purg.text[6]
+    except IndexError:
+        ABC = None
+    if ABC and purg.text[6] in ["m", "a"]:
+        return
+    if not purg._client._bot and (
+        (match)
+        or (purg.is_reply and (purg.is_private or isinstance(purg.chat, types.Chat)))
+    ):
+        p = 0
+        async for msg in purg.client.iter_messages(
+            purg.chat_id,
+            limit=int(match) if match else None,
+            min_id=purg.reply_to_msg_id if purg.is_reply else None,
+        ):
+            await msg.delete()
+            p += 0
+        return await eor(purg, f"Purged {p} Messages! ", time=5)
+    if not purg.reply_to_msg_id:
+        return await eor(purg, get_string("purge_1"), time=10)
+    try:
+        await purg.client.delete_messages(
+            purg.chat_id, list(range(purg.reply_to_msg_id, purg.id))
+        )
+
+    except Exception as er:
+        LOGS.info(er)
+    await purg.eor("__Fast purge complete!__", time=5)
+
+
+@ultroid_cmd(
+    pattern="purgeme( (.*)|$)",
+)
+async def fastpurgerme(purg):
+    if num := purg.pattern_match.group(1).strip():
+        try:
+            nnt = int(num)
+        except BaseException:
+            await eor(purg, get_string("com_3"), time=5)
+            return
+        mp = 0
+        async for mm in purg.client.iter_messages(
+            purg.chat_id, limit=nnt, from_user="me"
+        ):
+            await mm.delete()
+            mp += 1
+        await eor(purg, f"Purged {mp} Messages!", time=5)
+        return
+    elif not purg.reply_to_msg_id:
+        return await eod(
+            purg,
+            "`Reply to a message to purge from or use it like ``purgeme <num>`",
+            time=10,
+        )
+    chat = await purg.get_input_chat()
+    msgs = []
+    async for msg in purg.client.iter_messages(
+        chat,
+        from_user="me",
+        min_id=purg.reply_to_msg_id,
+    ):
+        msgs.append(msg)
+    if msgs:
+        await purg.client.delete_messages(chat, msgs)
+    await purg.eor(
+        "__Fast purge complete!__\n**Purged** `" + str(len(msgs)) + "` **messages.**",
+        time=5,
+    )
+
+
+@ultroid_cmd(
+    pattern="purgeall$",
+)
+async def _(e):
+    if not e.is_reply:
+        return await eod(
+            e,
+            get_string("purgeall_1"),
+        )
+
+    msg = await e.get_reply_message()
+    name = msg.sender
+    try:
+        await e.client.delete_messages(e.chat_id, from_user=msg.sender_id)
+        await e.eor(get_string("purgeall_2").format(name.first_name), time=5)
+    except Exception as er:
+        return await e.eor(str(er), time=5)
+
+
+@ultroid_cmd(pattern="pinned", manager=True, groups_only=True)
+async def djshsh(event):
+    chat = await event.get_chat()
+    if isinstance(chat, types.Chat):
+        FChat = await event.client(GetFullChatRequest(chat.id))
+    elif isinstance(chat, types.Channel):
+        FChat = await event.client(GetFullChannelRequest(chat.id))
+    else:
+        return
+    msg_id = FChat.full_chat.pinned_msg_id
+    if not msg_id:
+        return await event.eor(get_string("pinned_1"))
+    msg = await event.client.get_messages(chat.id, ids=msg_id)
+    if msg:
+        await event.eor(get_string("pinned_2").format(msg.message_link))
+
+
+@ultroid_cmd(
+    pattern="listpinned$",
+)
+async def get_all_pinned(event):
+    x = await event.eor(get_string("com_1"))
+    chat_id = (str(event.chat_id)).replace("-100", "")
+    chat_name = get_display_name(event.chat)
+    a = ""
+    c = 1
+    async for i in event.client.iter_messages(
+        event.chat_id, filter=InputMessagesFilterPinned
+    ):
+        if i.message:
+            t = " ".join(i.message.split()[:4])
+            txt = f"{t}...."
+        else:
+            txt = "Go to message."
+        a += f"{c}. <a href=https://t.me/c/{chat_id}/{i.id}>{txt}</a>\n"
+        c += 1
+
+    if c == 1:
+        m = f"<b>The pinned message in {chat_name}:</b>\n\n"
+    else:
+        m = f"<b>List of pinned message(s) in {chat_name}:</b>\n\n"
+
+    if not a:
+        return await eor(x, get_string("listpin_1"), time=5)
+
+    await x.edit(m + a, parse_mode="html")
+
+
+@ultroid_cmd(
+    pattern="autodelete( (.*)|$)",
+    admins_only=True,
+)
+async def autodelte(ult):
+    match = ult.pattern_match.group(1).strip()
+    if not match or match not in ["24h", "7d", "1m", "off"]:
+        return await ult.eor("`Please Use in Proper Format..`", time=5)
+    if match == "24h":
+        tt = 3600 * 24
+    elif match == "7d":
+        tt = 3600 * 24 * 7
+    elif match == "1m":
+        tt = 3600 * 24 * 31
+    else:
+        tt = 0
+    try:
+        await ult.client(SetHistoryTTLRequest(ult.chat_id, period=tt))
+    except ChatNotModifiedError:
+        return await ult.eor(
+            f"Auto Delete Setting is Already same to `{match}`", time=5
+        )
+    await ult.eor(f"Auto Delete Status Changed to `{match}` !")

plugins/afk.py

@@ -0,0 +1,166 @@
+# Ultroid - UserBot
+# Copyright (C) 2021-2023 TeamUltroid
+#
+# This file is a part of < https://github.com/TeamUltroid/Ultroid/ >
+# PLease read the GNU Affero General Public License in
+# <https://www.github.com/TeamUltroid/Ultroid/blob/main/LICENSE/>.
+
+from . import get_help
+
+__doc__ = get_help("help_afk")
+
+
+import asyncio
+
+from telegraph import upload_file as uf
+from telethon import events
+
+from xteam.dB.afk_db import add_afk, del_afk, is_afk
+from xteam.dB.base import KeyManager
+
+from . import (
+    LOG_CHANNEL,
+    NOSPAM_CHAT,
+    Redis,
+    asst,
+    get_string,
+    mediainfo,
+    udB,
+    ultroid_bot,
+    ultroid_cmd,
+)
+
+old_afk_msg = []
+
+is_approved = KeyManager("PMPERMIT", cast=list).contains
+
+
+@ultroid_cmd(pattern="afk( (.*)|$)", owner_only=True)
+async def set_afk(event):
+    if event.client._bot or is_afk():
+        return
+    text, media, media_type = None, None, None
+    if event.pattern_match.group(1).strip():
+        text = event.text.split(maxsplit=1)[1]
+    reply = await event.get_reply_message()
+    if reply:
+        if reply.text and not text:
+            text = reply.text
+        if reply.media:
+            media_type = mediainfo(reply.media)
+            if media_type.startswith(("pic", "gif")):
+                file = await event.client.download_media(reply.media)
+                iurl = uf(file)
+                media = f"https://graph.org{iurl[0]}"
+            else:
+                media = reply.file.id
+    await event.eor("`Done`", time=2)
+    add_afk(text, media_type, media)
+    ultroid_bot.add_handler(remove_afk, events.NewMessage(outgoing=True))
+    ultroid_bot.add_handler(
+        on_afk,
+        events.NewMessage(
+            incoming=True, func=lambda e: bool(e.mentioned or e.is_private)
+        ),
+    )
+    msg1, msg2 = None, None
+    if text and media:
+        if "sticker" in media_type:
+            msg1 = await ultroid_bot.send_file(event.chat_id, file=media)
+            msg2 = await ultroid_bot.send_message(
+                event.chat_id, get_string("afk_5").format(text)
+            )
+        else:
+            msg1 = await ultroid_bot.send_message(
+                event.chat_id, get_string("afk_5").format(text), file=media
+            )
+    elif media:
+        if "sticker" in media_type:
+            msg1 = await ultroid_bot.send_file(event.chat_id, file=media)
+            msg2 = await ultroid_bot.send_message(event.chat_id, get_string("afk_6"))
+        else:
+            msg1 = await ultroid_bot.send_message(
+                event.chat_id, get_string("afk_6"), file=media
+            )
+    elif text:
+        msg1 = await event.respond(get_string("afk_5").format(text))
+    else:
+        msg1 = await event.respond(get_string("afk_6"))
+    old_afk_msg.append(msg1)
+    if msg2:
+        old_afk_msg.append(msg2)
+        return await asst.send_message(LOG_CHANNEL, msg2.text)
+    await asst.send_message(LOG_CHANNEL, msg1.text)
+
+
+async def remove_afk(event):
+    if event.is_private and udB.get_key("PMSETTING") and not is_approved(event.chat_id):
+        return
+    elif "afk" in event.text.lower():
+        return
+    elif event.chat_id in NOSPAM_CHAT:
+        return
+    if is_afk():
+        _, _, _, afk_time = is_afk()
+        del_afk()
+        off = await event.reply(get_string("afk_1").format(afk_time))
+        await asst.send_message(LOG_CHANNEL, get_string("afk_2").format(afk_time))
+        for x in old_afk_msg:
+            try:
+                await x.delete()
+            except BaseException:
+                pass
+        await asyncio.sleep(10)
+        await off.delete()
+
+
+async def on_afk(event):
+    if event.is_private and Redis("PMSETTING") and not is_approved(event.chat_id):
+        return
+    elif "afk" in event.text.lower():
+        return
+    elif not is_afk():
+        return
+    if event.chat_id in NOSPAM_CHAT:
+        return
+    sender = await event.get_sender()
+    if sender.bot or sender.verified:
+        return
+    text, media_type, media, afk_time = is_afk()
+    msg1, msg2 = None, None
+    if text and media:
+        if "sticker" in media_type:
+            msg1 = await event.reply(file=media)
+            msg2 = await event.reply(get_string("afk_3").format(afk_time, text))
+        else:
+            msg1 = await event.reply(
+                get_string("afk_3").format(afk_time, text), file=media
+            )
+    elif media:
+        if "sticker" in media_type:
+            msg1 = await event.reply(file=media)
+            msg2 = await event.reply(get_string("afk_4").format(afk_time))
+        else:
+            msg1 = await event.reply(get_string("afk_4").format(afk_time), file=media)
+    elif text:
+        msg1 = await event.reply(get_string("afk_3").format(afk_time, text))
+    else:
+        msg1 = await event.reply(get_string("afk_4").format(afk_time))
+    for x in old_afk_msg:
+        try:
+            await x.delete()
+        except BaseException:
+            pass
+    old_afk_msg.append(msg1)
+    if msg2:
+        old_afk_msg.append(msg2)
+
+
+if udB.get_key("AFK_DB"):
+    ultroid_bot.add_handler(remove_afk, events.NewMessage(outgoing=True))
+    ultroid_bot.add_handler(
+        on_afk,
+        events.NewMessage(
+            incoming=True, func=lambda e: bool(e.mentioned or e.is_private)
+        ),
+    )

plugins/allive.py

@@ -0,0 +1,152 @@
+import os
+import asyncio
+import platform
+import subprocess
+import time
+import random
+from datetime import datetime
+from secrets import choice
+from telethon import Button, events
+from telethon.errors.rpcerrorlist import MessageDeleteForbiddenError
+from telethon.utils import get_display_name
+from telethon.errors.rpcerrorlist import MessageDeleteForbiddenError
+from telethon.utils import get_display_name
+from telethon.tl.types import InputMessagesFilterVideo, InputMessagesFilterVoice, InputMessagesFilterPhotos
+
+from xteam._misc import SUDO_M, owner_and_sudos
+from xteam.dB.base import KeyManager
+from xteam.fns.helper import inline_mention
+from strings import get_string
+
+from xteam._misc import SUDO_M, owner_and_sudos
+from xteam.dB.base import KeyManager
+from xteam.fns.helper import inline_mention
+
+from platform import python_version as pyver
+from pyrogram import __version__ as pver
+from telegram import __version__ as lver
+from telethon import __version__ as tver
+from pytgcalls import __version__ as pytver
+from pyrogram import filters
+from pyrogram.types import Message
+from telethon import TelegramClient, events
+from telethon.tl.custom import Button
+from . import *
+from . import ultroid_bot as client
+import resources
+from xteam.fns.helper import inline_mention
+from . import (
+    OWNER_NAME,
+    OWNER_ID,
+    BOT_NAME,
+    OWNER_USERNAME,
+    asst,
+    start_time,
+    time_formatter,
+    udB,
+    ultroid_cmd as xteam_cmd,
+    get_string,
+    ultroid_bot as client,
+    eor,
+    ultroid_bot,
+    call_back,
+    callback,
+)
+
+async def member_permissions(chat_id: int, user_id: int):
+    perms = []
+    member = (await ultroid_bot.get_chat_member(chat_id, user_id)).privileges
+    if not member:
+        return []
+    if member.can_post_messages:
+        perms.append("can_post_messages")
+    if member.can_edit_messages:
+        perms.append("can_edit_messages")
+    if member.can_delete_messages:
+        perms.append("can_delete_messages")
+    if member.can_restrict_members:
+        perms.append("can_restrict_members")
+    if member.can_promote_members:
+        perms.append("can_promote_members")
+    if member.can_change_info:
+        perms.append("can_change_info")
+    if member.can_invite_users:
+        perms.append("can_invite_users")
+    if member.can_pin_messages:
+        perms.append("can_pin_messages")
+    if member.can_manage_video_chats:
+        perms.append("can_manage_video_chats")
+    return perms
+
+PHOTO = [
+    "https://files.catbox.moe/fqx4vz.mp4"
+]
+
+Mukesh = [
+    [
+        Button.url("ɴᴏᴏʙ", url=f"https://t.me/{OWNER_USERNAME}"),
+        Button.url("ꜱᴜᴘᴘᴏʀᴛ", url=f"https://t.me/xteam_cloner"),
+    ],
+    [
+        Button.url("➕ᴀᴅᴅ ᴍᴇ ᴇʟsᴇ ʏᴏᴜʀ ɢʀᴏᴜᴘ➕",
+            url=f"https://t.me/{BOT_USERNAME}?startgroup=true",
+        ),
+    ],
+]
+
+def format_message_text(uptime):
+    return f"<blockquote>ʜᴇʏ, ɪ ᴀᴍ {BOT_NAME} 🥀</blockquote>\n" \
+           f"<blockquote>❍ ᴍʏ ᴏᴡɴᴇʀ : {OWNER_NAME}\n" \
+           f"❍ ʟɪʙʀᴀʀʏ : {lver}\n" \
+           f"❍ ᴜᴘᴛɪᴍᴇ : {uptime}\n" \
+           f"❍ ᴛᴇʟᴇᴛʜᴏɴ : {tver}\n" \
+           f"❍ ᴘʏʀᴏɢʀᴀᴍ : {pver}\n" \
+           f"❍ ᴘʏ-ᴛɢᴄᴀʟʟꜱ : {pytver}\n" \
+           f"❍ ᴘʏᴛʜᴏɴ : {pyver()}\n</blockquote>"
+
+@xteam_cmd(pattern="alive$")
+async def alive(event):
+    start = time.time()
+    pro = await event.eor("⚡")
+    await asyncio.sleep(2)
+    await pro.delete()
+    end = round((time.time() - start) * 1000)
+    uptime = time_formatter((time.time() - start_time) * 1000)
+    message_text = format_message_text(uptime)
+    await event.client.send_file(
+        event.chat.id, 
+        file=random.choice(PHOTO), 
+        caption=message_text, 
+        parse_mode="html")
+
+@xteam_cmd(pattern="Alive$")
+async def alive_video(event):
+    try:
+        asupannya = [
+            asupan
+            async for asupan in event.client.iter_messages(
+                "@xcryasupan", filter=InputMessagesFilterVideo
+            )
+        ]
+
+        if not asupannya:
+            await event.respond("No video found in @xcryasupan.")
+            return
+
+        pro = await event.eor("⚡")
+        await asyncio.sleep(2)
+        await pro.delete()
+
+        uptime = time_formatter((time.time() - start_time) * 1000)
+        message_text = format_message_text(uptime)
+
+        await event.client.send_file(
+            event.chat.id,
+            file=random.choice(asupannya),
+            caption=message_text,
+            parse_mode="html",
+        )
+
+    except Exception as e:
+        await event.respond(f"An error occurred: {e}")
+                     

plugins/antiflood.py

@@ -0,0 +1,121 @@
+# Ultroid - UserBot
+# Copyright (C) 2021-2023 TeamUltroid
+#
+# This file is a part of < https://github.com/TeamUltroid/Ultroid/ >
+# PLease read the GNU Affero General Public License in
+# <https://www.github.com/TeamUltroid/Ultroid/blob/main/LICENSE/>.
+
+from . import get_help
+
+__doc__ = get_help("help_antiflood")
+
+
+import re
+
+from telethon.events import NewMessage as NewMsg
+
+from xteam.dB import DEVLIST
+from xteam.dB.antiflood_db import get_flood, get_flood_limit, rem_flood, set_flood
+from xteam.fns.admins import admin_check
+
+from . import Button, Redis, asst, callback, eod, get_string, ultroid_bot, ultroid_cmd
+
+_check_flood = {}
+
+if Redis("ANTIFLOOD"):
+
+    @ultroid_bot.on(
+        NewMsg(
+            chats=list(get_flood().keys()),
+        ),
+    )
+    async def flood_checm(event):
+        count = 1
+        chat = (await event.get_chat()).title
+        if event.chat_id in _check_flood.keys():
+            if event.sender_id == list(_check_flood[event.chat_id].keys())[0]:
+                count = _check_flood[event.chat_id][event.sender_id]
+                _check_flood[event.chat_id] = {event.sender_id: count + 1}
+            else:
+                _check_flood[event.chat_id] = {event.sender_id: count}
+        else:
+            _check_flood[event.chat_id] = {event.sender_id: count}
+        if await admin_check(event, silent=True) or getattr(event.sender, "bot", None):
+            return
+        if event.sender_id in DEVLIST:
+            return
+        if _check_flood[event.chat_id][event.sender_id] >= int(
+            get_flood_limit(event.chat_id)
+        ):
+            try:
+                name = event.sender.first_name
+                await event.client.edit_permissions(
+                    event.chat_id, event.sender_id, send_messages=False
+                )
+                del _check_flood[event.chat_id]
+                await event.reply(f"#AntiFlood\n\n{get_string('antiflood_3')}")
+                await asst.send_message(
+                    int(Redis("LOG_CHANNEL")),
+                    f"#Antiflood\n\n`Muted `[{name}](tg://user?id={event.sender_id})` in {chat}`",
+                    buttons=Button.inline(
+                        "Unmute", data=f"anti_{event.sender_id}_{event.chat_id}"
+                    ),
+                )
+            except BaseException:
+                pass
+
+
+@callback(
+    re.compile(
+        "anti_(.*)",
+    ),
+)
+async def unmuting(e):
+    ino = (e.data_match.group(1)).decode("UTF-8").split("_")
+    user = int(ino[0])
+    chat = int(ino[1])
+    user_name = (await ultroid_bot.get_entity(user)).first_name
+    chat_title = (await ultroid_bot.get_entity(chat)).title
+    await ultroid_bot.edit_permissions(chat, user, send_messages=True)
+    await e.edit(
+        f"#Antiflood\n\n`Unmuted `[{user_name}](tg://user?id={user})` in {chat_title}`"
+    )
+
+
+@ultroid_cmd(
+    pattern="setflood ?(\\d+)",
+    admins_only=True,
+)
+async def setflood(e):
+    input_ = e.pattern_match.group(1).strip()
+    if not input_:
+        return await e.eor("`What?`", time=5)
+    if not input_.isdigit():
+        return await e.eor(get_string("com_3"), time=5)
+    if m := set_flood(e.chat_id, input_):
+        return await eod(e, get_string("antiflood_4").format(input_))
+
+
+@ultroid_cmd(
+    pattern="remflood$",
+    admins_only=True,
+)
+async def remove_flood(e):
+    hmm = rem_flood(e.chat_id)
+    try:
+        del _check_flood[e.chat_id]
+    except BaseException:
+        pass
+    if hmm:
+        return await e.eor(get_string("antiflood_1"), time=5)
+    await e.eor(get_string("antiflood_2"), time=5)
+
+
+@ultroid_cmd(
+    pattern="getflood$",
+    admins_only=True,
+)
+async def getflood(e):
+    if ok := get_flood_limit(e.chat_id):
+        return await e.eor(get_string("antiflood_5").format(ok), time=5)
+    await e.eor(get_string("antiflood_2"), time=5)

plugins/bot.py

@@ -0,0 +1,363 @@
+# Ultroid - UserBot
+# Copyright (C) 2021-2025 TeamUltroid
+#
+# This file is a part of < https://github.com/TeamUltroid/Ultroid/ >
+# PLease read the GNU Affero General Public License in
+# <https://www.github.com/TeamUltroid/Ultroid/blob/main/LICENSE/>.
+
+from . import get_help
+
+__doc__ = get_help("help_bot")
+
+import os
+import sys
+import time
+from platform import python_version as pyver
+from random import choice
+
+from telethon import __version__
+from telethon.errors.rpcerrorlist import (
+    BotMethodInvalidError,
+    ChatSendMediaForbiddenError,
+)
+
+from xteam.version import __version__ as UltVer
+
+from . import HOSTED_ON, LOGS
+
+try:
+    from git import Repo
+except ImportError:
+    LOGS.error("bot: 'gitpython' module not found!")
+    Repo = None
+
+from telethon.utils import resolve_bot_file_id
+from config import Var
+from . import (
+    ATRA_COL,
+    LOGS,
+    OWNER_NAME,
+    ULTROID_IMAGES,
+    Button,
+    Carbon,
+    Telegraph,
+    allcmds,
+    asst,
+    bash,
+    call_back,
+    callback,
+    def_logs,
+    eor,
+    get_string,
+    heroku_logs,
+    in_pattern,
+    inline_pic,
+    restart,
+    shutdown,
+    start_time,
+    time_formatter,
+    udB,
+    ultroid_cmd,
+    ultroid_version,
+    updater,
+)
+
+
+def ULTPIC():
+    return inline_pic() or choice(ULTROID_IMAGES)
+
+
+buttons = [
+    [
+        Button.url(get_string("bot_3"), "https://github.com/TeamUltroid/Ultroid"),
+        Button.url(get_string("bot_4"), "t.me/UltroidSupportChat"),
+    ]
+]
+
+# Will move to strings
+alive_txt = """
+ᴜꜱᴇʀʙᴏᴛ ɪꜱ ᴀʟɪᴠᴇ
+
+  ◍ ᴜꜱᴇʀʙᴏᴛ - {}
+  ◍ ᴅᴀᴛᴀʙᴀꜱᴇ - {}
+  ◍ ᴛᴇʟᴇᴛʜᴏɴ - {}
+"""
+
+in_alive = "{}\n\n🌀 <b>Ultroid Version -><b> <code>{}</code>\n🌀 <b>xteam -></b> <code>{}</code>\n🌀 <b>Python -></b> <code>{}</code>\n🌀 <b>Uptime -></b> <code>{}</code>\n🌀 <b>Branch -></b>[ {} ]\n\n• <b>Join @TeamUltroid</b>"
+
+
+@callback("alive")
+async def alive(event):
+    text = alive_txt.format(ultroid_version, UltVer, __version__)
+    await event.answer(text, alert=True)
+
+
+"""@ultroid_cmd(
+    pattern="alive( (.*)|$)",
+)
+async def lol(ult):
+    match = ult.pattern_match.group(1).strip()
+    inline = None
+    if match in ["inline", "i"]:
+        try:
+            res = await ult.client.inline_query(asst.me.username, "alive")
+            return await res[0].click(ult.chat_id)
+        except BotMethodInvalidError:
+            pass
+        except BaseException as er:
+            LOGS.exception(er)
+        inline = True
+    pic = udB.get_key("ALIVE_PIC")
+    if isinstance(pic, list):
+        pic = choice(pic)
+    uptime = time_formatter((time.time() - start_time) * 1000)
+    header = udB.get_key("ALIVE_TEXT") or get_string("bot_1")
+    y = Repo().active_branch
+    xx = Repo().remotes[0].config_reader.get("url")
+    rep = xx.replace(".git", f"/tree/{y}")
+    kk = f" `[{y}]({rep})` "
+    if inline:
+        kk = f"<a href={rep}>{y}</a>"
+        parse = "html"
+        als = in_alive.format(
+            header,
+            f"{ultroid_version} [{HOSTED_ON}]",
+            UltVer,
+            pyver(),
+            uptime,
+            kk,
+        )
+
+        if _e := udB.get_key("ALIVE_EMOJI"):
+            als = als.replace("🌀", _e)
+    else:
+        parse = "md"
+        als = (get_string("alive_1")).format(
+            header,
+            OWNER_NAME,
+            f"{ultroid_version} [{HOSTED_ON}]",
+            UltVer,
+            uptime,
+            pyver(),
+            __version__,
+            kk,
+        )
+
+        if a := udB.get_key("ALIVE_EMOJI"):
+            als = als.replace("✵", a)
+    if pic:
+        try:
+            await ult.reply(
+                als,
+                file=pic,
+                parse_mode=parse,
+                link_preview=False,
+                buttons=buttons if inline else None,
+            )
+            return await ult.try_delete()
+        except ChatSendMediaForbiddenError:
+            pass
+        except BaseException as er:
+            LOGS.exception(er)
+            try:
+                await ult.reply(file=pic)
+                await ult.reply(
+                    als,
+                    parse_mode=parse,
+                    buttons=buttons if inline else None,
+                    link_preview=False,
+                )
+                return await ult.try_delete()
+            except BaseException as er:
+                LOGS.exception(er)
+    await eor(
+        ult,
+        als,
+        parse_mode=parse,
+        link_preview=False,
+        buttons=buttons if inline else None,
+    )
+
+
+@ultroid_cmd(pattern="ping$", chats=[], type=["official", "assistant"])
+async def _(event):
+    start = time.time()
+    x = await event.eor("Pong !")
+    end = round((time.time() - start) * 1000)
+    uptime = time_formatter((time.time() - start_time) * 1000)
+    await x.edit(get_string("ping").format(end, uptime))
+"""
+
+@ultroid_cmd(
+    pattern="cmds$",
+)
+async def cmds(event):
+    await allcmds(event, Telegraph)
+
+
+heroku_api = Var.HEROKU_API
+
+
+@ultroid_cmd(
+    pattern="restart$",
+    fullsudo=True,
+)
+async def restartbt(ult):
+    ok = await ult.eor(get_string("bot_5"))
+    call_back()
+    who = "bot" if ult.client._bot else "user"
+    udB.set_key("_RESTART", f"{who}_{ult.chat_id}_{ok.id}")
+    if heroku_api:
+        return await restart(ok)
+    await bash("git pull && pip3 install -r requirements.txt")
+    if len(sys.argv) > 1:
+        os.execl(sys.executable, sys.executable, "main.py")
+    else:
+        os.execl(sys.executable, sys.executable, "-m", "xteam")
+
+
+@ultroid_cmd(
+    pattern="shutdown$",
+    fullsudo=True,
+)
+async def shutdownbot(ult):
+    await shutdown(ult)
+
+
+@ultroid_cmd(
+    pattern="logs( (.*)|$)",
+    chats=[],
+)
+async def _(event):
+    opt = event.pattern_match.group(1).strip()
+    file = f"userbot{sys.argv[-1]}.log" if len(sys.argv) > 1 else "userbot.log"
+    if opt == "heroku":
+        await heroku_logs(event)
+    elif opt == "carbon" and Carbon:
+        event = await event.eor(get_string("com_1"))
+        with open(file, "r") as f:
+            code = f.read()[-2500:]
+        file = await Carbon(
+            file_name="userbot-logs",
+            code=code,
+            backgroundColor=choice(ATRA_COL),
+        )
+        if isinstance(file, dict):
+            await event.eor(f"`{file}`")
+            return
+        await event.reply("**Userbot Logs.**", file=file)
+    elif opt == "open":
+        with open("userbot.log", "r") as f:
+            file = f.read()[-4000:]
+        return await event.eor(f"`{file}`")
+    elif (
+        opt.isdigit() and 5 <= int(opt) <= 100
+    ):  # Check if input is a number between 10 and 100
+        num_lines = int(opt)
+        with open("userbot.log", "r") as f:
+            lines = f.readlines()[-num_lines:]
+            file = "".join(lines)
+        return await event.eor(f"`{file}`")
+    else:
+        await def_logs(event, file)
+    await event.try_delete()
+
+
+@in_pattern("alive", owner=True)
+async def inline_alive(ult):
+    pic = udB.get_key("ALIVE_PIC")
+    if isinstance(pic, list):
+        pic = choice(pic)
+    uptime = time_formatter((time.time() - start_time) * 1000)
+    header = udB.get_key("ALIVE_TEXT") or get_string("bot_1")
+    y = Repo().active_branch
+    xx = Repo().remotes[0].config_reader.get("url")
+    rep = xx.replace(".git", f"/tree/{y}")
+    kk = f"<a href={rep}>{y}</a>"
+    als = in_alive.format(
+        header, f"{ultroid_version} [{HOSTED_ON}]", UltVer, pyver(), uptime, kk
+    )
+
+    if _e := udB.get_key("ALIVE_EMOJI"):
+        als = als.replace("🌀", _e)
+    builder = ult.builder
+    if pic:
+        try:
+            if ".jpg" in pic:
+                results = [
+                    await builder.photo(
+                        pic, text=als, parse_mode="html", buttons=buttons
+                    )
+                ]
+            else:
+                if _pic := resolve_bot_file_id(pic):
+                    pic = _pic
+                    buttons.insert(
+                        0, [Button.inline(get_string("bot_2"), data="alive")]
+                    )
+                results = [
+                    await builder.document(
+                        pic,
+                        title="Inline Alive",
+                        description="@TeamUltroid",
+                        parse_mode="html",
+                        buttons=buttons,
+                    )
+                ]
+            return await ult.answer(results)
+        except BaseException as er:
+            LOGS.exception(er)
+    result = [
+        await builder.article(
+            "Alive", text=als, parse_mode="html", link_preview=False, buttons=buttons
+        )
+    ]
+    await ult.answer(result)
+
+
+@ultroid_cmd(pattern="update( (.*)|$)")
+async def _(e):
+    xx = await e.eor(get_string("upd_1"))
+    if e.pattern_match.group(1).strip() and (
+        "fast" in e.pattern_match.group(1).strip()
+        or "soft" in e.pattern_match.group(1).strip()
+    ):
+        await bash("git pull -f && pip3 install -r requirements.txt")
+        call_back()
+        await xx.edit(get_string("upd_7"))
+        os.execl(sys.executable, "python3", "-m", "xteam")
+        # return
+    m = await updater()
+    branch = (Repo.init()).active_branch
+    if m:
+        x = await asst.send_file(
+            udB.get_key("LOG_CHANNEL"),
+            ULTPIC(),
+            caption="• **Update Available** •",
+            force_document=False,
+            buttons=Button.inline("Changelogs", data="changes"),
+        )
+        Link = x.message_link
+        await xx.edit(
+            f'<strong><a href="{Link}">[ChangeLogs]</a></strong>',
+            parse_mode="html",
+            link_preview=False,
+        )
+    else:
+        await xx.edit(
+            f'<code>Your BOT is </code><strong>up-to-date</strong><code> with </code><strong><a href="https://github.com/TeamUltroid/Ultroid/tree/{branch}">[{branch}]</a></strong>',
+            parse_mode="html",
+            link_preview=False,
+        )
+
+
+@callback("updtavail", owner=True)
+async def updava(event):
+    await event.delete()
+    await asst.send_file(
+        udB.get_key("LOG_CHANNEL"),
+        ULTPIC(),
+        caption="• **Update Available** •",
+        force_document=False,
+        buttons=Button.inline("Changelogs", data="changes"),
+    )

plugins/chatgpt.py

@@ -0,0 +1,394 @@
+# Ultroid - UserBot
+# Copyright (C) 2021-2025 TeamUltroid
+#
+# This file is a part of < https://github.com/TeamUltroid/Ultroid/ >
+# PLease read the GNU Affero General Public License in
+# <https://www.github.com/TeamUltroid/Ultroid/blob/main/LICENSE/>.
+
+"""
+✘ Commands Available -
+
+• `{i}gemini <prompt>`
+    Get response from Google Gemini.
+
+• `{i}antr <prompt>`
+    Get response from Anthropic Claude.
+
+• `{i}gpt <prompt>`
+    Get response from OpenAI GPT.
+
+• `{i}deepseek <prompt>`
+    Get response from DeepSeek AI.
+
+Set custom models using:
+    • OPENAI_MODEL
+    • ANTHROPIC_MODEL
+    • GEMINI_MODEL
+    • DEEPSEEK_MODEL
+"""
+
+import json
+from . import LOGS, eor, get_string, udB, ultroid_cmd, async_searcher
+import aiohttp
+import asyncio
+
+
+ENDPOINTS = {
+    "gpt": "https://api.openai.com/v1/chat/completions",
+    "antr": "https://api.anthropic.com/v1/messages",
+    "gemini": "https://generativelanguage.googleapis.com/v1/models/gemini-1.5-flash:generateContent",
+    "deepseek": "https://api.deepseek.com/v3/chat/completions"
+}
+
+DEFAULT_MODELS = {
+    "gpt": "gpt-3.5-turbo",
+    "antr": "claude-3-haiku",
+    "gemini": "gemini-1.5-flash",
+    "deepseek": "DeepSeek-V3"
+}
+
+
+
+def get_model(provider):
+    """Get model name from database or use default"""
+    model_keys = {
+        "gpt": "OPENAI_MODEL",
+        "antr": "ANTHROPIC_MODEL",
+        "gemini": "GEMINI_MODEL",
+        "deepseek": "DEEPSEEK_MODEL"
+    }
+    return udB.get_key(model_keys[provider]) or DEFAULT_MODELS[provider]
+
+
+async def stream_response(msg, text):
+    """Stream response by editing message"""
+    current = ""
+    # Split into chunks of ~100 characters at word boundaries
+    words = text.split()
+    chunks = []
+    current_chunk = []
+    
+    for word in words:
+        current_chunk.append(word)
+        if len(" ".join(current_chunk)) > 100:
+            chunks.append(" ".join(current_chunk[:-1]))
+            current_chunk = [word]
+    if current_chunk:
+        chunks.append(" ".join(current_chunk))
+    
+    for chunk in chunks:
+        current += chunk + " "
+        try:
+            await msg.edit(current)
+        except Exception:
+            pass
+        await asyncio.sleep(0.5)
+    return current
+
+
+async def get_ai_response(provider, prompt, api_key, stream=False):
+    """Get response from AI provider"""
+    try:
+        headers = {"Content-Type": "application/json"}
+        model = get_model(provider)
+        
+        if provider == "gpt":
+            headers["Authorization"] = f"Bearer {api_key}"
+            data = {
+                "model": model,
+                "messages": [{"role": "user", "content": prompt}],
+                "stream": stream
+            }
+            if not stream:
+                response = await async_searcher(
+                    ENDPOINTS[provider],
+                    headers=headers,
+                    post=True,
+                    json=data,
+                    re_json=True
+                )
+                yield response["choices"][0]["message"]["content"]
+                return
+                
+            async with aiohttp.ClientSession() as session:
+                async with session.post(
+                    ENDPOINTS[provider],
+                    headers=headers,
+                    json=data
+                ) as resp:
+                    async for line in resp.content:
+                        if line:
+                            try:
+                                json_line = json.loads(line.decode('utf-8').strip().strip('data:').strip())
+                                if 'choices' in json_line and json_line['choices']:
+                                    content = json_line['choices'][0].get('delta', {}).get('content', '')
+                                    if content:
+                                        yield content
+                            except Exception:
+                                continue
+
+        elif provider == "antr":
+            headers["x-api-key"] = api_key
+            headers["anthropic-version"] = "2023-06-01"
+            data = {
+                "model": model,
+                "messages": [{"role": "user", "content": prompt}],
+                "stream": stream
+            }
+            if not stream:
+                response = await async_searcher(
+                    ENDPOINTS[provider],
+                    headers=headers,
+                    post=True,
+                    json=data,
+                    re_json=True
+                )
+                yield response["content"][0]["text"]
+                return
+                
+            async with aiohttp.ClientSession() as session:
+                async with session.post(
+                    ENDPOINTS[provider],
+                    headers=headers,
+                    json=data
+                ) as resp:
+                    async for line in resp.content:
+                        if line:
+                            try:
+                                json_line = json.loads(line.decode('utf-8').strip())
+                                if 'content' in json_line:
+                                    content = json_line['content'][0]['text']
+                                    if content:
+                                        yield content
+                            except Exception:
+                                continue
+
+        elif provider == "gemini":
+            params = {"key": api_key}
+            data = {
+                "contents": [{
+                    "parts": [{"text": prompt}]
+                }]
+            }
+            response = await async_searcher(
+                ENDPOINTS[provider],
+                params=params,
+                headers=headers,
+                post=True,
+                json=data,
+                re_json=True
+            )
+            text = response["candidates"][0]["content"]["parts"][0]["text"]
+            if not stream:
+                yield text
+                return
+                
+            # Simulate streaming by yielding chunks
+            words = text.split()
+            buffer = []
+            for word in words:
+                buffer.append(word)
+                if len(' '.join(buffer)) > 20:  # Adjust chunk size as needed
+                    yield ' '.join(buffer) + ' '
+                    buffer = []
+            if buffer:
+                yield ' '.join(buffer)
+
+        elif provider == "deepseek":
+            headers["Authorization"] = f"Bearer {api_key}"
+            data = {
+                "model": model,
+                "messages": [{"role": "user", "content": prompt}],
+                "stream": stream
+            }
+            if not stream:
+                response = await async_searcher(
+                    ENDPOINTS[provider],
+                    headers=headers,
+                    post=True,
+                    json=data,
+                    re_json=True
+                )
+                yield response["choices"][0]["message"]["content"]
+                return
+                
+            async with aiohttp.ClientSession() as session:
+                async with session.post(
+                    ENDPOINTS[provider],
+                    headers=headers,
+                    json=data
+                ) as resp:
+                    async for line in resp.content:
+                        if line:
+                            try:
+                                json_line = json.loads(line.decode('utf-8').strip())
+                                if 'choices' in json_line and json_line['choices']:
+                                    content = json_line['choices'][0].get('delta', {}).get('content', '')
+                                    if content:
+                                        yield content
+                            except Exception:
+                                continue
+
+    except Exception as e:
+        LOGS.exception(e)
+        yield f"Error: {str(e)}"
+
+
+@ultroid_cmd(pattern="gemini( (.*)|$)")
+async def gemini_ai(event):
+    """Use Google Gemini"""
+    prompt = event.pattern_match.group(1).strip()
+    if not prompt:
+        return await event.eor("❌ Please provide a prompt!")
+
+    api_key = udB.get_key("GEMINI_API_KEY")
+    if not api_key:
+        return await event.eor("⚠️ Please set Gemini API key using `setdb GEMINI_API_KEY your_api_key`")
+
+    msg = await event.eor(f"<blockquote>🤔 Thinking...</blockquote>", parse_mode="html")
+    model = get_model("gemini")
+    
+    header = (
+        f"<blockquote>🔍 Prompt:\n{prompt}</blockquote>\n"
+        "<blockquote>💡 Response:</blockquote>\n"
+    )
+    
+    if event.client.me.bot:
+        await msg.edit(header)
+        response = ""
+        async for chunk in get_ai_response("gemini", prompt, api_key, stream=False):
+            response += chunk
+            try:
+                await msg.edit(header + f"<blockquote>{response}</blockquote>", parse_mode="html")
+            except Exception:
+                pass
+    else:
+        response = ""
+        async for chunk in get_ai_response("gemini", prompt, api_key, stream=False):
+            response += chunk
+        try:
+            await msg.edit(header + f"<blockquote>{response}</blockquote>", parse_mode="html")
+        except Exception:
+            pass
+
+@ultroid_cmd(pattern="antr( (.*)|$)")
+async def anthropic_ai(event):
+    """Use Anthropic Claude"""
+    prompt = event.pattern_match.group(1).strip()
+    if not prompt:
+        return await event.eor("❌ Please provide a prompt!")
+
+    api_key = udB.get_key("ANTHROPIC_KEY")
+    if not api_key:
+        return await event.eor("⚠️ Please set Anthropic API key using `setdb ANTHROPIC_KEY your_api_key`")
+
+    msg = await event.eor("🤔 Thinking...")
+    model = get_model("antr")
+    
+    formatted_response = (
+        "🧠 **Anthropic Claude**\n"
+        f"**Model:** `{model}`\n"
+        "➖➖➖➖➖➖➖➖➖➖\n\n"
+        f"**🔍 Prompt:**\n{prompt}\n\n"
+        f"**💡 Response:**\n"
+    )
+    
+    if event.client.me.bot:
+        await msg.edit(formatted_response)
+        response = ""
+        async for chunk in get_ai_response("antr", prompt, api_key, stream=True):
+            response += chunk
+            try:
+                await msg.edit(formatted_response + response)
+            except Exception:
+                pass
+    else:
+        response = ""
+        async for chunk in get_ai_response("antr", prompt, api_key, stream=True):
+            response += chunk
+        try:
+            await msg.edit(formatted_response + response)
+        except Exception:
+            pass
+
+@ultroid_cmd(pattern="gpt( (.*)|$)")
+async def openai_ai(event):
+    """Use OpenAI GPT"""
+    prompt = event.pattern_match.group(1).strip()
+    if not prompt:
+        return await event.eor("❌ Please provide a prompt!")
+
+    api_key = udB.get_key("OPENAI_API_KEY")
+    if not api_key:
+        return await event.eor("⚠️ Please set GPT API key using `setdb OPENAI_API_KEY your_api_key`")
+
+    msg = await event.eor("🤔 Thinking...")
+    model = get_model("gpt")
+    
+    header = (
+        "🌟 **OpenAI GPT**\n"
+        f"**Model:** `{model}`\n"
+        "➖➖➖➖➖➖➖➖➖➖\n\n"
+        f"**🔍 Prompt:**\n{prompt}\n\n"
+        "**💡 Response:**\n"
+    )
+    
+    if event.client.me.bot:
+        await msg.edit(header)
+        response = ""
+        async for chunk in get_ai_response("gpt", prompt, api_key, stream=True):
+            response += chunk
+            try:
+                await msg.edit(header + response)
+            except Exception:
+                pass
+    else:
+        response =""
+        async for chunk in get_ai_response("gpt", prompt, api_key, stream=True):
+            response += chunk
+        try:
+            await msg.edit(header + response)
+        except Exception:
+            pass
+
+@ultroid_cmd(pattern="deepseek( (.*)|$)")
+async def deepseek_ai(event):
+    """Use DeepSeek AI"""
+    prompt = event.pattern_match.group(1).strip()
+    if not prompt:
+        return await event.eor("❌ Please provide a prompt!")
+
+    api_key = udB.get_key("DEEPSEEK_API_KEY")
+    if not api_key:
+        return await event.eor("⚠️ Please set DeepSeek API key using `setdb DEEPSEEK_API_KEY your_api_key`")
+
+    msg = await event.eor("🤔 Thinking...")
+    model = get_model("deepseek")
+    
+    formatted_response = (
+        "🤖 **DeepSeek AI**\n"
+        f"**Model:** `{model}`\n"
+        "➖➖➖➖➖➖➖➖➖➖\n\n"
+        f"**🔍 Prompt:**\n{prompt}\n\n"
+        f"**💡 Response:**\n"
+    )
+    
+    if event.client.me.bot:
+        await msg.edit(formatted_response)
+        response = ""
+        async for chunk in get_ai_response("deepseek", prompt, api_key, stream=True):
+            response += chunk
+            try:
+                await msg.edit(formatted_response + response)
+            except Exception:
+                pass
+    else:
+        response = ""
+        async for chunk in get_ai_response("deepseek", prompt, api_key, stream=True):
+            response += chunk
+
+        try:
+            await msg.edit(formatted_response + response)
+        except Exception:
+            pass
+

plugins/devtools.py

@@ -0,0 +1,387 @@
+# Ultroid - UserBot
+# Copyright (C) 2021-2023 TeamUltroid
+#
+# This file is a part of < https://github.com/TeamUltroid/Ultroid/ >
+# PLease read the GNU Affero General Public License in
+# <https://www.github.com/TeamUltroid/Ultroid/blob/main/LICENSE/>.
+
+from . import get_help
+
+__doc__ = get_help("help_devtools")
+
+import inspect
+import sys
+import traceback
+from io import BytesIO, StringIO
+from os import remove
+from pprint import pprint
+
+from telethon.utils import get_display_name
+
+from xteam import _ignore_eval
+
+from . import *
+
+# Used for Formatting Eval Code, if installed
+try:
+    import black
+except ImportError:
+    black = None
+from random import choice
+
+try:
+    from yaml import safe_load
+except ImportError:
+    from xteam.fns.tools import safe_load
+try:
+    from telegraph import upload_file as uf
+except ImportError:
+    uf = None
+from telethon.tl import functions
+
+fn = functions
+
+
+@ultroid_cmd(
+    pattern="sysinfo$",
+)
+async def _(e):
+    xx = await e.eor(get_string("com_1"))
+    x, y = await bash("neofetch|sed 's/\x1B\\[[0-9;\\?]*[a-zA-Z]//g' >> neo.txt")
+    if y and y.endswith("NOT_FOUND"):
+        return await xx.edit(f"Error: `{y}`")
+    with open("neo.txt", "r", encoding="utf-8") as neo:
+        p = (neo.read()).replace("\n\n", "")
+    haa = await Carbon(code=p, file_name="neofetch", backgroundColor=choice(ATRA_COL))
+    if isinstance(haa, dict):
+        await xx.edit(f"`{haa}`")
+    else:
+        await e.reply(file=haa)
+        await xx.delete()
+    remove("neo.txt")
+
+
+@ultroid_cmd(pattern="sh", fullsudo=True, only_devs=True)
+async def _(event):
+    carb, rayso, yamlf = None, None, False
+    try:
+        cmd = event.text.split(" ", maxsplit=1)[1]
+        if cmd.split()[0] in ["-c", "--carbon"]:
+            cmd = cmd.split(maxsplit=1)[1]
+            carb = True
+        if cmd.split()[0] in ["-r", "--rayso"]:
+            cmd = cmd.split(maxsplit=1)[1]
+            rayso = True
+    except IndexError:
+        return await event.eor(get_string("devs_1"), time=10)
+    xx = await event.eor(get_string("com_1"))
+    reply_to_id = event.reply_to_msg_id or event.id
+    stdout, stderr = await bash(cmd, run_code=1)
+    OUT = f"**```• Input:**\n{cmd}\n\n```"
+    err, out = "", ""
+    if stderr:
+        err = f"**```• Input:**```\n```{stderr}`\n\n```"
+    if stdout:
+        if (carb or udB.get_key("CARBON_ON_BASH")) and (
+            event.is_private
+            or event.chat.admin_rights
+            or event.chat.creator
+            or event.chat.default_banned_rights.embed_links
+        ):
+            li = await Carbon(
+                code=stdout,
+                file_name="bash",
+                download=True,
+                backgroundColor=choice(ATRA_COL),
+            )
+            if isinstance(li, dict):
+                await xx.edit(
+                    f"Unknown Response from Carbon: `{li}`\n\nstdout`:{stdout}`\nstderr: `{stderr}`"
+                )
+                return
+            url = f"https://graph.org{uf(li)[-1]}"
+            OUT = f"[\xad]({url}){OUT}"
+            out = "**```• Output:```**"
+            remove(li)
+        elif (rayso or udB.get_key("RAYSO_ON_BASH")) and (
+            event.is_private
+            or event.chat.admin_rights
+            or event.chat.creator
+            or event.chat.default_banned_rights.embed_links
+        ):
+            li = await Carbon(
+                code=stdout,
+                file_name="bash",
+                download=True,
+                backgroundColor=choice(ATRA_COL),
+                rayso=True,
+            )
+            if isinstance(li, dict):
+                await xx.edit(
+                    f"Unknown Response from Carbon: `{li}`\n\nstdout`:{stdout}`\nstderr: `{stderr}`"
+                )
+                return
+            url = f"https://graph.org{uf(li)[-1]}"
+            OUT = f"[\xad]({url}){OUT}"
+            out = "**```• OUTPUT:```**"
+            remove(li)
+        else:
+            if "pip" in cmd and all(":" in line for line in stdout.split("\n")):
+                try:
+                    load = safe_load(stdout)
+                    stdout = ""
+                    for data in list(load.keys()):
+                        res = load[data] or ""
+                        if res and "http" not in str(res):
+                            res = f"```{res}```"
+                        stdout += f"```**{data}**  :  {res}\n```"
+                    yamlf = True
+                except Exception as er:
+                    stdout = f"```{stdout}```"
+                    LOGS.exception(er)
+            else:
+                stdout = f"`{stdout}`"
+            out = f"**```• OUTPUT:```**\n```{stdout}```"
+    if not stderr and not stdout:
+        out = "**```• OUTPUT:```**\n`Success`"
+    OUT += err + out
+    if len(OUT) > 4096:
+        ultd = err + out
+        with BytesIO(str.encode(ultd)) as out_file:
+            out_file.name = "bash.txt"
+            await event.client.send_file(
+                event.chat_id,
+                out_file,
+                force_document=True,
+                thumb=ULTConfig.thumb,
+                allow_cache=False,
+                caption=f"```{cmd}```" if len(cmd) < 998 else None,
+                reply_to=reply_to_id,
+            )
+
+            await xx.delete()
+    else:
+        await xx.edit(OUT, link_preview=not yamlf)
+
+
+pp = pprint  # ignore: pylint
+bot = ultroid = ultroid_bot
+
+
+class u:
+    _ = ""
+
+
+def _parse_eval(value=None):
+    if not value:
+        return value
+    if hasattr(value, "stringify"):
+        try:
+            return value.stringify()
+        except TypeError:
+            pass
+    elif isinstance(value, dict):
+        try:
+            return json_parser(value, indent=1)
+        except BaseException:
+            pass
+    elif isinstance(value, list):
+        newlist = "["
+        for index, child in enumerate(value):
+            newlist += "\n  " + str(_parse_eval(child))
+            if index < len(value) - 1:
+                newlist += ","
+        newlist += "\n]"
+        return newlist
+    return str(value)
+
+
+@ultroid_cmd(pattern="eval", fullsudo=True, only_devs=True)
+async def _(event):
+    try:
+        cmd = event.text.split(maxsplit=1)[1]
+    except IndexError:
+        return await event.eor(get_string("devs_2"), time=5)
+    xx = None
+    mode = ""
+    spli = cmd.split()
+
+    async def get_():
+        try:
+            cm = cmd.split(maxsplit=1)[1]
+        except IndexError:
+            await event.eor("->> Wrong Format <<-")
+            cm = None
+        return cm
+
+    if spli[0] in ["-s", "--silent"]:
+        await event.delete()
+        mode = "silent"
+    elif spli[0] in ["-n", "-noedit"]:
+        mode = "no-edit"
+        xx = await event.reply(get_string("com_1"))
+    elif spli[0] in ["-gs", "--source"]:
+        mode = "gsource"
+    elif spli[0] in ["-ga", "--args"]:
+        mode = "g-args"
+    if mode:
+        cmd = await get_()
+    if not cmd:
+        return
+    if not mode == "silent" and not xx:
+        xx = await event.eor(get_string("com_1"))
+    if black:
+        try:
+            cmd = black.format_str(cmd, mode=black.Mode())
+        except BaseException:
+            # Consider it as Code Error, and move on to be shown ahead.
+            pass
+    reply_to_id = event.reply_to_msg_id or event
+    if any(item in cmd for item in KEEP_SAFE().All) and (
+        not (event.out or event.sender_id == ultroid_bot.uid)
+    ):
+        warning = await event.forward_to(udB.get_key("LOG_CHANNEL"))
+        await warning.reply(
+            f"Malicious Activities suspected by {inline_mention(await event.get_sender())}"
+        )
+        _ignore_eval.append(event.sender_id)
+        return await xx.edit(
+            "`Malicious Activities suspected⚠️!\nReported to owner. Aborted this request!`"
+        )
+    old_stderr = sys.stderr
+    old_stdout = sys.stdout
+    redirected_output = sys.stdout = StringIO()
+    redirected_error = sys.stderr = StringIO()
+    stdout, stderr, exc, timeg = None, None, None, None
+    tima = time.time()
+    try:
+        value = await aexec(cmd, event)
+    except Exception:
+        value = None
+        exc = traceback.format_exc()
+    tima = time.time() - tima
+    stdout = redirected_output.getvalue()
+    stderr = redirected_error.getvalue()
+    sys.stdout = old_stdout
+    sys.stderr = old_stderr
+    if value:
+        try:
+            if mode == "gsource":
+                exc = inspect.getsource(value)
+            elif mode == "g-args":
+                args = inspect.signature(value).parameters.values()
+                name = ""
+                if hasattr(value, "__name__"):
+                    name = value.__name__
+                exc = f"**{name}**\n\n" + "\n ".join([str(arg) for arg in args])
+        except Exception:
+            exc = traceback.format_exc()
+    evaluation = exc or stderr or stdout or _parse_eval(value) or get_string("instu_4")
+    if mode == "silent":
+        if exc:
+            msg = f"• <b>EVAL ERROR\n\n• CHAT:</b> <code>{get_display_name(event.chat)}</code> [<code>{event.chat_id}</code>]"
+            msg += f"\n\n∆ <b>CODE:</b>\n<code>{cmd}</code>\n\n∆ <b>ERROR:</b>\n<code>{exc}</code>"
+            log_chat = udB.get_key("LOG_CHANNEL")
+            if len(msg) > 4000:
+                with BytesIO(msg.encode()) as out_file:
+                    out_file.name = "Eval-Error.txt"
+                return await event.client.send_message(
+                    log_chat, f"`{cmd}`", file=out_file
+                )
+            await event.client.send_message(log_chat, msg, parse_mode="html")
+        return
+    tmt = tima * 1000
+    timef = time_formatter(tmt)
+    timeform = timef if not timef == "0s" else f"{tmt:.3f}µs"
+    final_output = "<blockquote>Input:\n{}</blockquote>\n<blockquote>Output:\n{}</blockquote>\n<blockquote>Timsec:{}\n</blockquote>".format(
+        cmd,
+        evaluation,
+        timeform,
+    )
+    if len(final_output) > 4096:
+        final_output = evaluation
+        with BytesIO(str.encode(final_output)) as out_file:
+            out_file.name = "eval.txt"
+            await event.client.send_file(
+                event.chat_id,
+                out_file,
+                force_document=True,
+                thumb=ULTConfig.thumb,
+                allow_cache=False,
+                caption=f"```{cmd}```" if len(cmd) < 998 else None,
+                reply_to=reply_to_id,
+                parse_mode="html",
+            )
+        return await xx.delete()
+    await xx.edit(final_output, parse_mode="html")
+
+
+def _stringify(text=None, *args, **kwargs):
+    if text:
+        u._ = text
+        text = _parse_eval(text)
+    return print(text, *args, **kwargs)
+
+
+async def aexec(code, event):
+    exec(
+        (
+            "async def __aexec(e, client): "
+            + "\n print = p = _stringify"
+            + "\n message = event = e"
+            + "\n u.r = reply = await event.get_reply_message()"
+            + "\n chat = event.chat_id"
+            + "\n u.lr = locals()"
+        )
+        + "".join(f"\n {l}" for l in code.split("\n"))
+    )
+
+    return await locals()["__aexec"](event, event.client)
+
+
+DUMMY_CPP = """#include <iostream>
+using namespace std;
+
+int main(){
+!code
+}
+"""
+
+
+@ultroid_cmd(pattern="cpp", only_devs=True)
+async def doie(e):
+    match = e.text.split(" ", maxsplit=1)
+    try:
+        match = match[1]
+    except IndexError:
+        return await e.eor(get_string("devs_3"))
+    msg = await e.eor(get_string("com_1"))
+    if "main(" not in match:
+        new_m = "".join(" " * 4 + i + "\n" for i in match.split("\n"))
+        match = DUMMY_CPP.replace("!code", new_m)
+    open("cpp-ultroid.cpp", "w").write(match)
+    m = await bash("g++ -o CppUltroid cpp-ultroid.cpp")
+    o_cpp = f"• **Eval-Cpp**\n`{match}`"
+    if m[1]:
+        o_cpp += f"\n\n**• Error :**\n`{m[1]}`"
+        if len(o_cpp) > 3000:
+            os.remove("cpp-ultroid.cpp")
+            if os.path.exists("CppUltroid"):
+                os.remove("CppUltroid")
+            with BytesIO(str.encode(o_cpp)) as out_file:
+                out_file.name = "error.txt"
+                return await msg.reply(f"`{match}`", file=out_file)
+        return await eor(msg, o_cpp)
+    m = await bash("./CppUltroid")
+    if m[0] != "":
+        o_cpp += f"\n\n**• Output :**\n`{m[0]}`"
+    if m[1]:
+        o_cpp += f"\n\n**• Error :**\n`{m[1]}`"
+    if len(o_cpp) > 3000:
+        with BytesIO(str.encode(o_cpp)) as out_file:
+            out_file.name = "eval.txt"
+            await msg.reply(f"`{match}`", file=out_file)
+    else:
+        await eor(msg, o_cpp)
+    os.remove("CppUltroid")
+    os.remove("cpp-ultroid.cpp")

plugins/ping.py

@@ -0,0 +1,184 @@
+# UserBot
+# Copyright (C) 2021-2023 Teamx-cloner 
+#
+# This file is a part of < https://github.com/TeamUltroid/Ultroid/ >
+# PLease read the GNU Affero General Public License in
+# <https://www.github.com/TeamUltroid/Ultroid/blob/main/LICENSE/>.
+
+from . import get_help
+
+__doc__ = get_help("help_bot")
+
+import asyncio
+import os
+import sys
+import time
+from telethon import events, TelegramClient
+from telethon.tl.functions import PingRequest
+from secrets import choice
+from telethon import Button
+from xteam._misc import sudoers
+from telethon.tl.types import InputMessagesFilterVideo, InputMessagesFilterVoice
+from telethon.tl.types import InputMessagesFilterPhotos
+from xteam.fns.custom_markdown import CustomMarkdown
+from xteam.fns.helper import download_file, inline_mention
+from ._inline import *
+from xteam.fns.helper import inline_mention
+from . import (
+OWNER_NAME,
+OWNER_ID,
+BOT_NAME,
+OWNER_USERNAME,
+asst,
+start_time,
+time_formatter,
+udB,
+ultroid_cmd as xteam_cmd,
+get_string,
+ultroid_bot as client,
+eor,
+ultroid_bot,
+call_back,
+callback,
+)
+
+PING = [
+    [  # First row of buttons (you can have multiple rows)
+            #InlineKeyboardButton("Button 1 Text", url="https://example.com/1"),  # Example URL button
+            Button.inline("CLOSE", data="close"),
+        #InlineKeyboardButton("ᴘɪɴɢ", callback_data="close") # Example callback button
+        ]
+]
+
+#markup = ReplyInlineMarkup(PING)
+
+
+
+async def mention_user(user_id):
+    try:
+        user_entity = await ultroid_bot.get_entity(user_id)
+        first_name = user_entity.first_name
+        mention_text = f"[{first_name}](tg://user?id={user_id})"
+        return mention_text
+    except Exception as e:
+        print(f"Failed to mention user: {e}")
+
+
+@xteam_cmd(pattern="xping$", chats=[], type=["official", "assistant"])
+async def _(event):
+    start = time.time()
+    x = await event.edit("ping")
+    end = round((time.time() - start) * 1000)
+    uptime = time_formatter((time.time() - start_time) * 1000)
+    await x.edit(f"**Pong!\n{end}ms**")
+
+
+"""
+papnya = [
+        pap
+        async for pap in e.client.iter_messages(
+            "@CeweLogoPack", filter=InputMessagesFilterPhotos
+        )
+    ]
+
+ppcpnya = [
+        ppcp
+        async for ppcp in event.client.iter_messages(
+            "@ppcpcilik", filter=InputMessagesFilterPhotos
+        )
+    ]
+
+desahcewe = [
+        desah
+        async for desah in event.client.iter_messages(
+            "@desahancewesangesange", filter=InputMessagesFilterVoice
+        )
+    ]
+"""
+"""@xteam_cmd(pattern="Cping")
+async def wping(e):
+    asupannya = [
+        asupan
+        async for asupan in e.client.iter_messages(
+            "@xcryasupan", filter=InputMessagesFilterVideo
+        )
+    ]
+    start = time.time()
+    x = await e.eor("Pong!")
+    end = round((time.time() - start) * 1000)
+    uptime = time_formatter((time.time() - start_time) * 1000)
+    #await asyncio.sleep(1)
+    try:
+       await asst.send_message(
+    e.chat.id,
+    f"<blockquote> Ping : {end}ms\nUptime : {uptime}\nOwner : `{inline_mention(ultroid_bot.me)}`</blockquote>",
+           file=choice(asupannya),
+           buttons=[
+               [
+                   Button.inline("• x🥰x •", data="close")
+               ]
+           ],
+           parse_mode="html",
+       )
+   
+except Exception as e:
+      await x.edit(f"**Ping Error:** {e}")
+"""
+@xteam_cmd(pattern="ping$", chats=[], type=["official", "assistant"])
+async def _(event):
+    start = time.time()
+    x = await event.reply("Ping")
+    end = round((time.time() - start) * 1000)
+    uptime = time_formatter((time.time() - start_time) * 1000)
+    await x.edit(f"<blockquote>Pong !! {end}ms\nUptime - {uptime}</blockquote>", parse_mode="html")
+    
+import time
+import asyncio
+from telethon import Button
+from telethon.tl.types import InputMessagesFilterVideo
+import random
+
+# Assuming you have these defined elsewhere in your code:
+# @xteam_cmd, e, client, start_time, time_formatter, OWNER_NAME
+
+@xteam_cmd(pattern="kping")
+async def wping(e):
+    try:
+        asupannya = [
+            asupan
+            async for asupan in e.client.iter_messages(
+                "@xcryasupan", filter=InputMessagesFilterVideo
+            )
+        ]
+
+        if not asupannya:
+            await e.respond("No video found in @xcryasupan.")
+            return
+
+        start = time.time()
+        x = await e.respond("Pong!")  # Use respond instead of eor for initial message
+        end = round((time.time() - start) * 1000)
+        uptime = time_formatter((time.time() - start_time) * 1000)
+
+        await e.client.send_file( # send_file is used for sending files with caption and buttons.
+            e.chat.id,
+            file=random.choice(asupannya),
+            caption=f"<blockquote> Ping : {end}ms\nUptime : {uptime}\nOwner :{OWNER_NAME}</blockquote>",
+            parse_mode="html",
+            buttons=Button.inline("• x •", "close"),
+        )
+
+        await x.delete() # delete the "pong" message after sending the video with caption.
+
+    except Exception as ex:
+        try:
+            await x.edit(f"**Ping Error:** {ex}")
+        except:
+             await e.respond(f"**Ping Error:** {ex}") #in case x was not defined.
+
+@callback(data="close", owner=True)
+async def on_plug_in_callback_query_handler(event):
+    await event.edit(
+        get_string("inline_5"),
+        buttons=Button.inline("OPEN", data="open"),
+    )