Upload 100 files

plugins/__init__.py

@@ -47,6 +47,8 @@ asst: UltroidClient
 LOG_CHANNEL = udB.get_key("LOG_CHANNEL")
 StartTime = time.time()
 
+xteam = ultroid_cmd
+
 def inline_pic():
     INLINE_PIC = udB.get_key("INLINE_PIC")
     if INLINE_PIC is None:

plugins/_bot.py

@@ -104,22 +104,36 @@ heroku_api = Var.HEROKU_API
 
 @ultroid_cmd(
     pattern="restart$",
-    fullsudo=False,
+    fullsudo=True,
 )
-async def restart(e):
-    await e.eor("`Processing...`")
+async def restark(ult):
+    ok = await ult.eor(get_string("bot_5"))
+    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")
-    os.execl(sys.executable, sys.executable, "-m", "xteam")
-
+    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="Restart$",
+    pattern="gs$",
     fullsudo=False,
 )
 async def restart(e):
-    await e.eor("`Processing...`")
-    await bash("git pull")
-    await e.eor("Done.")
-    os.execl(sys.executable, sys.executable, "-m", "xteam")
+    try:
+        await e.eor("`Processing...`")
+        process = await bash("git pull && pip3 install -r requirements.txt")
+        if process == 0:  # Check if the bash command was successful (exit code 0)
+            await e.eor("`Restarting Success...`")
+            os.execl(sys.executable, sys.executable, "-m", "xteam")
+        else:
+            await e.eor("`Restarting Failed!`\n`Check logs for more info.`")
+    except Exception as err:
+        await e.eor(f"`An error occurred during restart!`\n`{err}`")
+
 
 @ultroid_cmd(
     pattern="shutdown$",

plugins/_help.py

@@ -32,94 +32,66 @@ from . import HNDLR, LOGS, OWNER_NAME, asst, get_string, inline_pic, udB, ultroi
 
 _main_help_menu = [
     [
-        Button.url("18+",url=f"https://t.me/+5WS60Gdkpt84YWM1"),
-        Button.inline("ᴍᴏᴅᴜʟᴇꜱ", data="uh_Official_"),
+        Button.inline("🏡 Modules 🏡", 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()
+async def _help(event):
+    plug = event.pattern_match.group(1).strip()
+    chat = await event.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)
+            x = get_string("help_11").format(plug)
+            if plug in LIST:
+                for d in LIST[plug]:
+                    x += "" + d
+                    x += "\n"
+                x += "\n© @teamX"
+                await event.eor(x)
             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.")
+                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 enter 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 event.eor(text)
+                output = f"Command `{plug}` found in plugin - `{file}`\n"
+                if HELP.get("Official") and 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© @teamX"
+                await event.eor(output)
+        except BaseException as e:
+            await event.eor(f"{e}")
     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.",
-            )
+            results = await event.client.inline_query(asst.me.username, "help")
         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()
+            return await event.eor(get_string("help_3"))
+        await results[0].click(chat.id, reply_to=event.reply_to_msg_id)
+        await event.delete()

plugins/_inline.py

@@ -85,32 +85,39 @@ async def inline_alive(o):
         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(
+@in_pattern("helpme", owner=False)
+async def inline_haandler(event):
+    key = "Official"
+    count = 0
+    text = get_string("inline_4", key).format(
         OWNER_NAME,
         len(HELP.get("Official", [])),
         len(HELP.get("Addons", [])),
-        len(z),
+        len(key),
     )
-    if inline_pic():
-        result = await event.builder.photo(
-            file=inline_pic(),
-            link_preview=False,
-            text=text,
-            buttons=_main_help_menu,
-        )
-    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)
-
+    text = f"<blockquote> {text}</blockquote>"  # Menambahkan blockquote di awal teks
+    result = await event.builder.article(
+        title="Menu Help", text=text, buttons=page_num(count, key), parse_mode="html"
+    )
+    await event.answer([result], cache_time=0, parse_mode="html")
+    
+
+@in_pattern("help", owner=False)
+async def inline_handler(ult):
+    key = "Official"
+    count = 0
+    text = get_string("inline_4", key).format(
+        OWNER_NAME,
+        len(HELP.get("Official", [])),
+        len(HELP.get("Addons", [])),
+        len(key),
+    )
+    result = await ult.builder.article(
+        title="Menu Help", text=text, buttons=page_num(count, key)
+    )
+    await ult.answer([result], cache_time=0)
 
+    
 @in_pattern("pasta", owner=True)
 async def _(event):
     ok = event.text.split("-")[1]
@@ -159,7 +166,6 @@ async def setting(event):
 
 _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("_")
@@ -175,8 +181,8 @@ async def help_func(ult):
 
 
 @callback(re.compile("uplugin_(.*)"), owner=True)
-async def uptd_plugin(event):
-    key, file = event.data_match.group(1).decode("utf-8").split("_")
+async def uptd_plugin(ult):
+    key, file = ult.data_match.group(1).decode("utf-8").split("_")
     index = None
     if "|" in file:
         file, index = file.split("|")
@@ -217,11 +223,11 @@ async def uptd_plugin(event):
         ]
     )
     try:
-        await event.edit(help_, buttons=buttons)
+        await ult.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)
+        await ult.edit(help, buttons=buttons)
 
 
 @callback(data="doupdate", owner=True)
@@ -291,7 +297,6 @@ async def _(e):
     )
     await e.edit(buttons=button, link_preview=False)
 
-
 @callback(data="open", owner=True)
 async def opner(event):
     z = []
@@ -308,17 +313,63 @@ async def opner(event):
         link_preview=False,
     )
 
-
-@callback(data="close", owner=True)
-async def on_plug_in_callback_query_handler(event):
+@callback(data="tutupbotol", owner=False)
+async def tutupbotol(event):
     await event.delete()
+    
+    
+    """await event.edit(
+        buttons=Button.inline("🏡 Modules 🏡", data="uh_Official_"),
+    )"""
 
 
 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 "🫧"
+    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
+
+    nav_buttons = []
+    if len(fl_) > 1:
+        nav_buttons.append(
+            Button.inline(
+                "<",
+                data=f"uh_{key}_{index-1}",
+            )
+        )
+    nav_buttons.append(Button.inline("×", data="tutupbotol"))
+    if len(fl_) > 1:
+        nav_buttons.append(
+            Button.inline(
+                ">",
+                data=f"uh_{key}_{index+1}",
+            )
+        )
+
+    if nav_buttons:
+        new_.append(nav_buttons)
+    elif not new_:  # Tambahkan tombol close jika tidak ada tombol lain dan tidak ada item bantuan
+        new_.append([Button.inline("×", data="tutupbotol")])
+
+    return new_
+
+
+"""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)
@@ -331,7 +382,7 @@ def page_num(index, key):
         new_ = fl_[0] if fl_ else []
         index = 0
     if index == 0 and len(fl_) == 1:
-        new_.append([Button.inline("×", data="open")])
+        new_.append([Button.inline("×", data="close")])
     else:
         new_.append(
             [
@@ -339,7 +390,7 @@ def page_num(index, key):
                     "<",
                     data=f"uh_{key}_{index-1}",
                 ),
-                Button.inline("×", data="open"),
+                Button.inline("×", data="close"),
                 Button.inline(
                     ">",
                     data=f"uh_{key}_{index+1}",
@@ -347,7 +398,7 @@ def page_num(index, key):
             ]
         )
     return new_
-
+"""
 
 # --------------------------------------------------------------------------------- #
 

plugins/alive.py

@@ -0,0 +1,155 @@
+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>┏──────────────────┓\n❍─┫ᴜʀʙᴏᴛ ɪꜱ ɴᴏᴡ ᴀʟɪᴠᴇ!┣─❍\n" \
+                     f"┣──────────────────┫\n\n" \
+                     f"❍ ᴏᴡɴᴇʀ : {OWNER_NAME}\n\n" \
+                     f"❍ ʟɪʙʀᴀʀʏ : {lver}\n\n" \
+                     f"❍ ᴜᴘᴛɪᴍᴇ : {uptime}\n\n" \
+                     f"❍ ᴛᴇʟᴇᴛʜᴏɴ : {tver}\n\n" \
+                     f"❍ ᴘʏʀᴏɢʀᴀᴍ :  {pver}\n\n" \
+                     f"❍ ᴘʏᴛʜᴏɴ : {pyver()}\n\n" \
+                     f"┗──────────────────┛\n</blockquote>"
+
+@xteam_cmd(pattern="alive$")
+async def alive(event):
+    start = time.time()
+    pro = await event.eor("🔥")
+    await asyncio.sleep(1)
+    end = round((time.time() - start) * 1000)
+    uptime = time_formatter((time.time() - start_time) * 1000)
+    message_text = format_message_text(uptime)
+    await pro.edit(f"<blockquote><b>✰ {asst.full_name} ɪꜱ ᴀʟɪᴠᴇ ✰</b>\n\n" \
+                     f"✵ Owner : {OWNER_NAME}\n" \
+                     f"✵ Dc id : {ultroid_bot.dc_id}\n" \
+                     f"✵ Library : {lver}\n" \
+                     f"✵ Uptime : {uptime}\n" \
+                     f"✵ Telethon : {tver}\n" \
+                     f"✵ Pyrogram :  {pver}\n" \
+                     f"✵ Python : {pyver()}\n</blockquote>",
+                   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 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/chatgpt.py

@@ -5,7 +5,7 @@
 # PLease read the GNU Affero General Public License in
 # <https://www.github.com/TeamUltroid/Ultroid/blob/main/LICENSE/>.
 
-"""<blockquote>
+"""
 ✘ Commands Available -
 
 • `{i}gemini <prompt>`
@@ -24,7 +24,7 @@ Set custom models using:
     • OPENAI_MODEL
     • ANTHROPIC_MODEL
     • GEMINI_MODEL
-    • DEEPSEEK_MODEL</blockquote>
+    • DEEPSEEK_MODEL
 """
 
 import json
@@ -249,8 +249,8 @@ async def gemini_ai(event):
     model = get_model("gemini")
     
     header = (
-        f"<blockquote>Question :\n{prompt}</blockquote>\n"
-        "<blockquote>Answer :</blockquote>\n"
+        f"<blockquote>🔍 Prompt:\n{prompt}</blockquote>\n"
+        "<blockquote>💡 Response:</blockquote>\n"
     )
     
     if event.client.me.bot:

plugins/gikes.py

@@ -0,0 +1,133 @@
+# xteam - UserBot
+# Copyright (C) 2021-2022 senpai80
+#
+# This file is a part of < https://github.com/senpai80/xteam/ >
+# PLease read the GNU Affero General Public License in
+# <https://www.github.com/senpai80/xteam/blob/main/LICENSE/>.
+"""
+✘ **Bantuan Untuk Broadcast**
+
+๏ **Perintah:** `gcast`
+◉ **Keterangan:** Kirim pesan ke semua obrolan grup.
+
+๏ **Perintah:** `gucast`
+◉ **Keterangan:** Kirim pesan ke semua pengguna pribadi.
+
+๏ **Perintah:** `addbl`
+◉ **Keterangan:** Tambahkan grup ke dalam anti gcast.
+
+๏ **Perintah:** `delbl`
+◉ **Keterangan:** Hapus grup dari daftar anti gcast.
+
+๏ **Perintah:** `blchat`
+◉ **Keterangan:** Melihat daftar anti gcast.
+"""
+import asyncio
+
+from xteam.dB import DEVLIST as DEVS
+from xteam.dB.gcast_blacklist_db import add_gblacklist, rem_gblacklist
+from xteam.dB.blacklist_chat_db import add_black_chat
+from telethon.errors.rpcerrorlist import FloodWaitError
+
+from . import *
+
+
+@ultroid_cmd(pattern="gcast( (.*)|$)", fullsudo=False)
+async def gcast(event):
+    if xx := event.pattern_match.group(1):
+        msg = xx
+    elif event.is_reply:
+        msg = await event.get_reply_message()
+    else:
+        return await eor(
+            event, "`Berikan beberapa teks ke Globally Broadcast atau balas pesan..`"
+        )
+    kk = await event.eor("`Sebentar Kalo Limit Jangan Salahin Kynan Ya...`")
+    er = 0
+    done = 0
+    err = ""
+    chat_blacklist = udB.get_key("GBLACKLISTS") or []
+    chat_blacklist.append(-1001608847572)
+    udB.set_key("GBLACKLISTS", chat_blacklist)
+    async for x in event.client.iter_dialogs():
+        if x.is_group:
+            chat = x.id
+
+            if chat not in chat_blacklist and chat not in NOSPAM_CHAT:
+                try:
+                    await event.client.send_message(chat, msg)
+                    done += 1
+                except FloodWaitError as fw:
+                    await asyncio.sleep(fw.seconds + 10)
+                    try:
+                        await event.client.send_message(chat, msg)
+                        done += 1
+                    except Exception as rr:
+                        err += f"• {rr}\n"
+                        er += 1
+                except BaseException as h:
+                    err += f"• {str(h)}" + "\n"
+                    er += 1
+    await kk.edit(
+        f"**Pesan Broadcast Berhasil Terkirim Ke : `{done}` Grup.\nDan Gagal Terkirim Ke : `{er}` Grup.**"
+    )
+
+
+@ultroid_cmd(pattern="gucast( (.*)|$)", fullsudo=False)
+async def gucast(event):
+    if xx := event.pattern_match.group(1):
+        msg = xx
+    elif event.is_reply:
+        msg = await event.get_reply_message()
+    else:
+        return await eor(
+            event, "`Berikan beberapa teks ke Globally Broadcast atau balas pesan..`"
+        )
+    kk = await event.eor("`Sebentar Kalo Limit Jangan Salahin Kynan Ya...`")
+    er = 0
+    done = 0
+    chat_blacklist = udB.get_key("GBLACKLISTS") or []
+    chat_blacklist.append(482945686)
+    udB.set_key("GBLACKLISTS", chat_blacklist)
+    async for x in event.client.iter_dialogs():
+        if x.is_user and not x.entity.bot:
+            chat = x.id
+            if chat not in DEVS and chat not in chat_blacklist:
+                try:
+                    await event.client.send_message(chat, msg)
+                    await asyncio.sleep(0.1)
+                    done += 1
+                except FloodWaitError as anj:
+                    await asyncio.sleep(int(anj.seconds))
+                    await event.client.send_message(chat, msg)
+                    done += 1
+                except BaseException:
+                    er += 1
+    await kk.edit(
+        f"**Pesan Broadcast Berhasil Terkirim Ke : `{done}` Pengguna.\nDan Gagal Terkirim Ke : `{er}` Pengguna.**"
+    )
+
+
+@ultroid_cmd(pattern="addbl")
+async def blacklist_(event):
+    await gblacker(event, "add")
+
+
+@ultroid_cmd(pattern="dlbl")
+async def ungblacker(event):
+    await gblacker(event, "remove")
+
+
+async def gblacker(event, type_):
+    args = event.text.split()
+    if len(args) > 2:
+        return await event.eor("**Gunakan Format:**\n `delbl` or `addbl`")
+    chat_id = None
+    chat_id = int(args[1]) if len(args) == 2 else event.chat_id
+    if type_ == "add":
+        add_gblacklist(chat_id)
+        await event.eor(f"**Ditambahkan ke dalam Blacklist Gcast**\n`{chat_id}`")
+    elif type_ == "remove":
+        rem_gblacklist(chat_id)
+        await event.eor(f"**Dihapus dari Blacklist Gcast**\n`{chat_id}`")
+              

plugins/globaltools.py

@@ -429,142 +429,6 @@ async def _(e):
         gb_msg += f"\n**Reason** : {reason}"
     await xx.edit(gb_msg)
 
-
-@ultroid_cmd(pattern="g(admin|)cast( (.*)|$)", fullsudo=True)
-async def gcast(event):
-    text, btn, reply = "", None, None
-    if xx := event.pattern_match.group(2):
-        msg, btn = get_msg_button(event.text.split(maxsplit=1)[1])
-    elif event.is_reply:
-        reply = await event.get_reply_message()
-        msg = reply.text
-        if reply.buttons:
-            btn = format_btn(reply.buttons)
-        else:
-            msg, btn = get_msg_button(msg)
-    else:
-        return await eor(
-            event, "`Give some text to Globally Broadcast or reply a message..`"
-        )
-
-    kk = await event.eor("`Globally Broadcasting Msg...`")
-    er = 0
-    done = 0
-    err = ""
-    if event.client._dialogs:
-        dialog = event.client._dialogs
-    else:
-        dialog = await event.client.get_dialogs()
-        event.client._dialogs.extend(dialog)
-    for x in dialog:
-        if x.is_group:
-            chat = x.entity.id
-            if (
-                not keym.contains(chat)
-                and int(f"-100{str(chat)}") not in NOSPAM_CHAT
-                and (
-                    (
-                        event.text[2:7] != "admin"
-                        or (x.entity.admin_rights or x.entity.creator)
-                    )
-                )
-            ):
-                try:
-                    if btn:
-                        bt = create_tl_btn(btn)
-                        await something(
-                            event,
-                            msg,
-                            reply.media if reply else None,
-                            bt,
-                            chat=chat,
-                            reply=False,
-                        )
-                    else:
-                        await event.client.send_message(
-                            chat, msg, file=reply.media if reply else None
-                        )
-                    done += 1
-                except FloodWaitError as fw:
-                    await asyncio.sleep(fw.seconds + 10)
-                    try:
-                        if btn:
-                            bt = create_tl_btn(btn)
-                            await something(
-                                event,
-                                msg,
-                                reply.media if reply else None,
-                                bt,
-                                chat=chat,
-                                reply=False,
-                            )
-                        else:
-                            await event.client.send_message(
-                                chat, msg, file=reply.media if reply else None
-                            )
-                        done += 1
-                    except Exception as rr:
-                        err += f"• {rr}\n"
-                        er += 1
-                except BaseException as h:
-                    err += f"• {str(h)}" + "\n"
-                    er += 1
-    text += f"Done in {done} chats, error in {er} chat(s)"
-    if err != "":
-        open("gcast-error.log", "w+").write(err)
-        text += f"\nYou can do `{HNDLR}ul gcast-error.log` to know error report."
-    await kk.edit(text)
-
-
-@ultroid_cmd(pattern="gucast( (.*)|$)", fullsudo=True)
-async def gucast(event):
-    msg, btn, reply = "", None, None
-    if xx := event.pattern_match.group(1).strip():
-        msg, btn = get_msg_button(event.text.split(maxsplit=1)[1])
-    elif event.is_reply:
-        reply = await event.get_reply_message()
-        msg = reply.text
-        if reply.buttons:
-            btn = format_btn(reply.buttons)
-        else:
-            msg, btn = get_msg_button(msg)
-    else:
-        return await eor(
-            event, "`Give some text to Globally Broadcast or reply a message..`"
-        )
-    kk = await event.eor("`Globally Broadcasting Msg...`")
-    er = 0
-    done = 0
-    if event.client._dialogs:
-        dialog = event.client._dialogs
-    else:
-        dialog = await event.client.get_dialogs()
-        event.client._dialogs.extend(dialog)
-    for x in dialog:
-        if x.is_user and not x.entity.bot:
-            chat = x.id
-            if not keym.contains(chat):
-                try:
-                    if btn:
-                        bt = create_tl_btn(btn)
-                        await something(
-                            event,
-                            msg,
-                            reply.media if reply else None,
-                            bt,
-                            chat=chat,
-                            reply=False,
-                        )
-                    else:
-                        await event.client.send_message(
-                            chat, msg, file=reply.media if reply else None
-                        )
-                    done += 1
-                except BaseException:
-                    er += 1
-    await kk.edit(f"Done in {done} chats, error in {er} chat(s)")
-
-
 @ultroid_cmd(pattern="gkick( (.*)|$)", fullsudo=True)
 async def gkick(e):
     xx = await e.eor("`Gkicking...`")

plugins/ping.py

@@ -13,6 +13,7 @@ import asyncio
 import os
 import sys
 import time
+import pyrogram
 from telethon import events, TelegramClient
 from telethon.tl.functions import PingRequest
 from secrets import choice

plugins/search.py

@@ -68,20 +68,20 @@ async def gitsearch(event):
         ufollowing = ult["following"]
     except BaseException:
         return await event.eor(get_string("srch_2"))
-    fullusr = f"""
-**[GITHUB]({ulink})**
-**Name** - {uacc}
-**UserName** - {uname}
-**ID** - {uid}
-**Company** - {ucomp}
-**Blog** - {ublog}
-**Location** - {ulocation}
-**Bio** - {ubio}
-**Repos** - {urepos}
-**Followers** - {ufollowers}
-**Following** - {ufollowing}
-"""
-    await event.respond(fullusr, file=upic)
+    fullusr = f"""<blockquote>
+[GITHUB]({ulink})
+Name - {uacc}
+UserName - {uname}
+ID** - {uid}
+Company - {ucomp}
+Blog - {ublog}
+Location - {ulocation}
+Bio** - {ubio}
+Repos - {urepos}
+Followers - {ufollowers}
+Following - {ufollowing}
+</blockquote>"""
+    await event.respond(fullusr, file=upic, parse_mode="html")
     await event.delete()
 
 

plugins/sysinfo.py

@@ -0,0 +1,172 @@
+"""
+✘ Commands Available -
+
+• `{i}sinfo`
+    __Get all information about the server.__
+"""
+
+import os
+import platform
+import sys
+
+import psutil
+from xteam.fns.helper import humanbytes
+from xteam.version import __version__ as UltVer
+from telethon import __version__ as TelethonVer
+from . import *
+
+def find_lib_version(lib: str) -> str:
+    """Find the version of a Python library installed via pip."""
+    try:
+        result = os.popen(f"python3 -m pip freeze | grep '^{lib}=='").read().strip()
+        return result.split("==")[1] if result else "Not Installed"
+    except IndexError:
+        return "Not Installed"
+
+
+def escape_html(text: str) -> str:
+    """Escape special characters in HTML."""
+    return text.replace("<", "").replace(">", "")
+
+
+def get_system_info():
+    """Get system-related information like CPU, RAM, and OS details."""
+    try:
+        cpu_cores = psutil.cpu_count(logical=True) or "n/a"
+        cpu_percent = psutil.cpu_percent() or "n/a"
+        ram_used = humanbytes(psutil.virtual_memory().used)
+        ram_total = humanbytes(psutil.virtual_memory().total)
+        ram_percent = psutil.virtual_memory().percent or "n/a"
+        disk_used = humanbytes(psutil.disk_usage("/").used)
+        disk_total = humanbytes(psutil.disk_usage("/").total)
+        disk_percent = humanbytes(psutil.disk_usage("/").percent) or "n/a"
+        kernel = escape_html(platform.release())
+        architecture = escape_html(platform.architecture()[0])
+        return (
+            cpu_cores,
+            cpu_percent,
+            ram_used,
+            ram_total,
+            ram_percent,
+            disk_used,
+            disk_total,
+            disk_percent,
+            kernel,
+            architecture,
+        )
+    except Exception:
+        return ["n/a"] * 10
+
+
+def get_os_info():
+    """Get operating system distribution information."""
+    try:
+        system = os.popen("cat /etc/*release").read()
+        b = system[system.find("PRETTY_NAME=") + 13 : -1]
+        system = b[: b.find('"')]
+        return escape_html(system)
+    except Exception:
+        return "N/A"
+
+
+def get_python_info():
+    """Get Python and pip version information."""
+    try:
+        python_version = f"{sys.version_info.major}.{sys.version_info.minor}.{sys.version_info.micro}"
+        pip_version = os.popen("python3 -m pip --version").read().split()[1]
+        return python_version, pip_version
+    except Exception:
+        return "n/a", "n/a"
+
+
+def bandwidth():
+    try:
+        download = 0
+        upload = 0
+        for net_io in psutil.net_io_counters(pernic=True).values():
+            download += net_io.bytes_recv
+            upload += net_io.bytes_sent
+        up = humanbytes(upload)
+        down = humanbytes(download)
+        total = humanbytes(upload + download)
+        return up, down, total
+    except:
+        return ["N/A"] * 3
+
+
+# Text template for displaying server info
+INFO_TEMPLATE = (
+    "<b><u><blockquote>👾 Server Info:</blockquote></u>\n"
+    "<u><blockquote>🗄 Used resources:</u>\n"
+    "    CPU: {} Cores ({}%)\n"
+    "    RAM: {} / {} ({}%)\n"
+    "    DISK: {} / {} ({}%)\n\n</blockquote>"
+    "<u><blockquote>🌐 Network Stats:</u>\n"
+    "    Upload: {}\n"
+    "    Download: {}\n"
+    "    Total: {}\n\n</blockquote>"
+    "<u><blockquote>🧾 Dist info:</u>\n"
+    "    Kernel: {}\n"
+    "    Arch: {}\n"
+    "    OS: {}\n\n</blockquote>"
+    "<u><blockquote>📦 Python libs:</u>\n"
+    "    Telethon: {}\n"
+    "    Aiohttp: {}\n"
+    "    GitPython: {}\n"
+    "    Xteam: {}\n"
+    "    Python: {}\n"
+    "    Pip: {}</b></blockquote>"
+)
+
+
+@ultroid_cmd(pattern="sinfo$")
+async def serverinfo_cmd(message):
+    """server information."""
+    await message.edit("<b><i><blockquote>🔄 Getting server info...</i></b></blockquote>", parse_mode="html")
+
+    (
+        cpu_cores,
+        cpu_percent,
+        ram_used,
+        ram_total,
+        ram_percent,
+        disk_used,
+        disk_total,
+        disk_percent,
+        kernel,
+        architecture,
+    ) = get_system_info()
+    os_info = get_os_info()
+    python_version, pip_version = get_python_info()
+    up, down, total = bandwidth()
+
+    telethon_version = TelethonVer
+    aiohttp_version = find_lib_version("aiohttp")
+    gitpython_version = find_lib_version("GitPython")
+    xteam_version = UltVer
+
+    # Format the final text
+    info_text = INFO_TEMPLATE.format(
+        cpu_cores,
+        cpu_percent,
+        ram_used,
+        ram_total,
+        ram_percent,
+        disk_used,
+        disk_total,
+        disk_percent,
+        up,
+        down,
+        total,
+        kernel,
+        architecture,
+        os_info,
+        telethon_version,
+        aiohttp_version,
+        gitpython_version,
+        xteam_version,
+        python_version,
+        pip_version,
+    )
+
+    await message.eor(info_text, parse_mode="html")

plugins/ytdl.py

@@ -0,0 +1,140 @@
+# Ayra - UserBot
+# Copyright (C) 2021-2022 senpai80
+#
+# This file is a part of < https://github.com/senpai80/Ayra/ >
+# PLease read the GNU Affero General Public License in
+# <https://www.github.com/senpai80/Ayra/blob/main/LICENSE/>.
+"""
+✘ **Bantuan Untuk Youtube**
+
+๏ **Perintah:** video
+◉ **Keterangan:** Unduh Video Dari Youtube.
+
+๏ **Perintah:** song
+◉ **Keterangan:** Unduh Lagu Dari Youtube.
+"""
+import os
+from asyncio import get_event_loop
+from functools import partial
+
+import wget
+from youtubesearchpython import SearchVideos
+from yt_dlp import YoutubeDL
+
+from . import *
+
+
+def run_sync(func, *args, **kwargs):
+    return get_event_loop().run_in_executor(None, partial(func, *args, **kwargs))
+
+
+@ultroid_cmd(pattern="Video( (.*)|$)")
+async def yt_video(e):
+    infomsg = await e.eor("`Processing...`")
+    try:
+        search = (
+            SearchVideos(
+                str(e.text.split(None, 1)[1]), offset=1, mode="dict", max_results=1
+            )
+            .result()
+            .get("search_result")
+        )
+        link = f"https://youtu.be/{search[0]['id']}"
+    except Exception as error:
+        return await infomsg.edit(f"**Pencarian...\n\n❌ Error: {error}**")
+    ydl = YoutubeDL(
+        {
+            "quiet": True,
+            "no_warnings": True,
+            "format": "(bestvideo[height<=?720][width<=?1280][ext=mp4])+(bestaudio[ext=m4a])",
+            "outtmpl": "downloads/%(id)s.%(ext)s",
+            "nocheckcertificate": True,
+            "geo_bypass": True,
+            "cookiefile": "cookies.txt",
+        }
+    )
+    await infomsg.eor("Mulai Mendownload...")
+    try:
+        ytdl_data = await run_sync(ydl.extract_info, link, download=True)
+        file_path = ydl.prepare_filename(ytdl_data)
+        videoid = ytdl_data["id"]
+        title = ytdl_data["title"]
+        url = f"https://youtu.be/{videoid}"
+        duration = ytdl_data["duration"]
+        channel = ytdl_data["uploader"]
+        views = f"{ytdl_data['view_count']:,}".replace(",", ".")
+        thumbs = f"https://img.youtube.com/vi/{videoid}/hqdefault.jpg"
+    except Exception as error:
+        return await infomsg.eor(f"**Gagal...\n\n❌ Error: {error}**")
+    thumbnail = wget.download(thumbs)
+    await e.client.send_file(
+        e.chat.id,
+        file=file_path,
+        thumb=thumbnail,
+        file_name=title,
+        duration=duration,
+        supports_streaming=True,
+        caption=f'<blockquote>💡 Informasi {"video"}\n\n🏷 Nama: {title}\n🧭 Durasi: {duration}\n👀 Dilihat: {views}\n📢 Channel: {channel}\nUpload By: {ultroid_bot.full_name}</blockquote>',
+        reply_to=e.reply_to_msg_id,
+        parse_mode="html",
+    )
+    await infomsg.delete()
+    for files in (thumbnail, file_path):
+        if files and os.path.exists(files):
+            os.remove(files)
+
+
+@ultroid_cmd(pattern="Song( (.*)|$)")
+async def yt_audio(e):
+    infomsg = await e.eor("`Processing...`")
+    try:
+        search = (
+            SearchVideos(
+                str(e.text.split(None, 1)[1]), offset=1, mode="dict", max_results=1
+            )
+            .result()
+            .get("search_result")
+        )
+        link = f"https://youtu.be/{search[0]['id']}"
+    except Exception as error:
+        return await infomsg.eor(f"**Pencarian...\n\n❌ Error: {error}**")
+    ydl = YoutubeDL(
+        {
+            "quiet": True,
+            "no_warnings": True,
+            "format": "bestaudio[ext=m4a]",
+            "outtmpl": "downloads/%(id)s.%(ext)s",
+            "nocheckcertificate": True,
+            "geo_bypass": True,
+            "cookiefile": "cookies.txt",
+        }
+    )
+    await infomsg.edit("Mulai Mendownload...")
+    try:
+        ytdl_data = await run_sync(ydl.extract_info, link, download=True)
+        file_path = ydl.prepare_filename(ytdl_data)
+        videoid = ytdl_data["id"]
+        title = ytdl_data["title"]
+        url = f"https://youtu.be/{videoid}"
+        duration = ytdl_data["duration"]
+        channel = ytdl_data["uploader"]
+        views = f"{ytdl_data['view_count']:,}".replace(",", ".")
+        thumbs = f"https://img.youtube.com/vi/{videoid}/hqdefault.jpg"
+    except Exception as error:
+        return await infomsg.edit(f"**Downloader...\n\n❌ Error: {error}**")
+    thumbnail = wget.download(thumbs)
+    await e.client.send_file(
+        e.chat.id,
+        file=file_path,
+        thumb=thumbnail,
+        file_name=title,
+        duration=duration,
+        supports_streaming=False,
+        caption=f'<blockquote>💡 Informasi {"Audio"}\n\n🏷 Nama: {title}\n🧭 Durasi: {duration}\n👀 Dilihat: {views}\n**📢 Channel: {channel}\nUpload By: {ultroid_bot.full_name}</blockquote>',
+        reply_to=e.reply_to_msg_id,
+        parse_mode="html",
+    )
+    await infomsg.delete()
+    for files in (thumbnail, file_path):
+        if files and os.path.exists(files):
+            os.remove(files)