Ultroid - v0.0.3

* Ultroid - v0.0.3

Full Changelog - https://t.me/TheUltroid/21


Co-authored-by: Amit Sharma <[email protected]>
Co-authored-by: Danish <[email protected]>
Co-authored-by: Aditya <[email protected]>
Co-authored-by: buddhhu <[email protected]>
Co-authored-by: New-dev0 <[email protected]>
Co-authored-by: 1Danish-00 <[email protected]>
Co-authored-by: Sρι∂у <[email protected]>
Co-authored-by: sppidy <[email protected]>
Co-authored-by: Arnab Paryali <[email protected]>
Co-authored-by: Programming Error <[email protected]>
Co-authored-by: ArnabXD <[email protected]>
Co-authored-by: xditya <[email protected]>
Co-authored-by: ProgrammingError <[email protected]>

.gitignore

@@ -10,4 +10,7 @@ BOT_TOKEN.session
 *.tgs
 logs-ultroid.txt
 .vscode/*
-ultroid-log.txt
+ultroid-log.txt
+/*.jpg
+/*.png
+/*.mp4

README.md

@@ -15,7 +15,7 @@ A stable pluggable Telegram userbot, based on Telethon.
 <details>
 <summary>More Info</summary>
 <br>
-  <b>Documentation</b> - <a href="https://ultroid.netlify.app">ultroid.netlify.app</a>  <br />
+  <b>Documentation</b> - <a href="https://ultroid.tech">ultroid.tech</a>  <br />
 </details>
 
 # Deploy 

assistant/api_setter.py

@@ -17,8 +17,9 @@ async def apiset(event):
         "Choose which API you want to set.",
         buttons=[
             [Button.inline("Remove.bg", data="rmbg")],
-            [custom.Button.inline("« Back", data="setter")]
-            ])
+            [custom.Button.inline("« Back", data="setter")],
+        ],
+    )
 
 
 # remove.bg api

assistant/customvars.py

@@ -22,12 +22,12 @@ auth_url = r["auth_url"]
 @owner
 async def alvcs(event):
     await event.edit(
-        "Customise your {}alive. Choose from the below options -".format(Var.HNDLR),
+        "Customise your {}alive. Choose from the below options -".format(HNDLR),
         buttons=[
-            [Button.inline("Alive Text", data="alvtx")],
-            [Button.inline("Alive Media", data="alvmed")],
-            [Button.inline("Delete Alive Media", data="delmed")],
-            [Button.inline("« Back", data="allcstms")]
+            [Button.inline("Aʟɪᴠᴇ Tᴇxᴛ", data="alvtx")],
+            [Button.inline("Aʟɪᴠᴇ ᴍᴇᴅɪᴀ", data="alvmed")],
+            [Button.inline("Dᴇʟᴇᴛᴇ Aʟɪᴠᴇ Mᴇᴅɪᴀ", data="delmed")],
+            [Button.inline("« Bᴀᴄᴋ", data="setter")],
         ],
     )
 
@@ -50,7 +50,11 @@ async def name(event):
             return await conv.send_message("Cancelled!!")
         else:
             await setit(event, var, themssg)
-            await conv.send_message("{} changed to {}\n\nDo {}restart".format(name, themssg, Var.HNDLR))
+            await conv.send_message(
+                "{} changed to {}\n\nAfter Setting All Things Do restart".format(
+                    name, themssg
+                )
+            )
 
 
 @callback("alvmed")
@@ -101,10 +105,11 @@ async def alvcs(event):
     await event.edit(
         "Customise your PMPERMIT Settings -",
         buttons=[
-            [Button.inline("PM Text", data="pmtxt")],
-            [Button.inline("Pm Media", data="pmmed")],
-            [Button.inline("Delete PM Media", data="delpmmed")],
-            [Button.inline("« Back", data="allcstms")]
+            [Button.inline("Pᴍ Tᴇxᴛ", data="pmtxt")],
+            [Button.inline("Pᴍ Mᴇᴅɪᴀ", data="pmmed")],
+            [Button.inline("PMLOGGER", data="pml")],
+            [Button.inline("Dᴇʟᴇᴛᴇ Pᴍ Mᴇᴅɪᴀ", data="delpmmed")],
+            [Button.inline("« Bᴀᴄᴋ", data="pmset")],
         ],
     )
 
@@ -118,7 +123,7 @@ async def name(event):
     name = "PM Text"
     async with event.client.conversation(pru) as conv:
         await conv.send_message(
-            "**PM Text**\nEnter the new Pmpermit text.\n\nUse /cancel to terminate the operation."
+            "**PM Text**\nEnter the new Pmpermit text.\n\nu can use `{name}` `{fullname}` `{count}` `{mention}` `{username}` Too\n\nUse /cancel to terminate the operation."
         )
         response = conv.wait_event(events.NewMessage(chats=pru))
         response = await response
@@ -127,7 +132,11 @@ async def name(event):
             return await conv.send_message("Cancelled!!")
         else:
             await setit(event, var, themssg)
-            await conv.send_message("{} changed to {}\n\nDo {}restart".format(name, themssg, Var.HNDLR))
+            await conv.send_message(
+                "{} changed to {}\n\nAfter Setting All Things Do restart".format(
+                    name, themssg
+                )
+            )
 
 
 @callback("pmmed")
@@ -139,7 +148,7 @@ async def media(event):
     name = "PM Media"
     async with event.client.conversation(pru) as conv:
         await conv.send_message(
-            "**PM Media**\nSend me a pic/gif/bot api id of sticker to set as Pmpermit media.\n\nUse /cancel to terminate the operation."
+            "**PM Media**\nSend me a pic/gif/bot api id of sticker to set as pmpermit media.\n\nUse /cancel to terminate the operation."
         )
         response = await conv.get_response()
         try:
@@ -170,3 +179,64 @@ async def dell(event):
         return await event.edit("Done!")
     except BaseException:
         return await event.edit("Something went wrong...")
+
+
+@callback("pml")
+@owner
+async def alvcs(event):
+    await event.edit(
+        "PMLOGGER This Will Forward Ur Pm to Ur Private Group -",
+        buttons=[
+            [Button.inline("PMLOGGER ON", data="pmlog")],
+            [Button.inline("PMLOGGER OFF", data="pmlogof")],
+            [Button.inline("« Bᴀᴄᴋ", data="pmcstm")],
+        ],
+    )
+
+
+@callback("pmlog")
+@owner
+async def pmlog(event):
+    var = "PMLOG"
+    await setit(event, var, "True")
+    await event.edit(f"Done!! PMLOGGER  Started!!")
+
+
+@callback("pmlogof")
+@owner
+async def pmlogof(event):
+    try:
+        udB.delete("PMLOG")
+        return await event.edit("Done! PMLOGGER Stopped!!")
+    except BaseException:
+        return await event.edit("Something went wrong...")
+
+
+@callback("pmset")
+@owner
+async def pmset(event):
+    await event.edit(
+        "PMPermit Settings:",
+        buttons=[
+            [Button.inline("Tᴜʀɴ PMPᴇʀᴍɪᴛ Oɴ", data="pmon")],
+            [Button.inline("Tᴜʀɴ PMPᴇʀᴍɪᴛ Oғғ", data="pmoff")],
+            [Button.inline("Cᴜsᴛᴏᴍɪᴢᴇ PMPᴇʀᴍɪᴛ", data="pmcstm")],
+            [Button.inline("« Bᴀᴄᴋ", data="setter")],
+        ],
+    )
+
+
+@callback("pmon")
+@owner
+async def pmonn(event):
+    var = "PMSETTING"
+    await setit(event, var, "True")
+    await event.edit(f"Done! PMPermit has been turned on!!")
+
+
+@callback("pmoff")
+@owner
+async def pmofff(event):
+    var = "PMSETTING"
+    await setit(event, var, "False")
+    await event.edit(f"Done! PMPermit has been turned off!!")

assistant/inlinestuff.py

@@ -16,6 +16,8 @@ from search_engine_parser import GoogleSearch, YahooSearch
 from telethon import Button
 from telethon.tl.types import InputWebDocument as wb
 
+from . import *
+
 gugirl = "https://telegra.ph/file/0df54ae4541abca96aa11.jpg"
 yeah = "https://telegra.ph/file/e3c67885e16a194937516.jpg"
 ps = "https://telegra.ph/file/de0b8d9c858c62fae3b6e.jpg"

assistant/othervars.py

@@ -16,11 +16,65 @@ async def otvaar(event):
     await event.edit(
         "Other Variables to set for @TheUltroid:",
         buttons=[
-            [Button.inline("Tag Logger", data="taglog")],
-            [Button.inline("PM Permit", data="pmset")],
-            [Button.inline("SuperFban", data="sfban")],
-            [Button.inline("« Back", data="setter")]
-        ])
+            [Button.inline("Tᴀɢ Lᴏɢɢᴇʀ", data="taglog")],
+            [Button.inline("SᴜᴘᴇʀFʙᴀɴ", data="sfban")],
+            [
+                Button.inline("Sᴜᴅᴏ Mᴏᴅᴇ", data="sudo"),
+                Button.inline("Hᴀɴᴅʟᴇʀ", data="hhndlr"),
+            ],
+            [
+                Button.inline("Exᴛʀᴀ Pʟᴜɢɪɴs", data="plg"),
+                Button.inline("Aᴅᴅᴏɴs", data="eaddon"),
+            ],
+            [Button.inline("« Bᴀᴄᴋ", data="setter")],
+        ],
+    )
+
+
+@callback("plg")
+@owner
+async def pluginch(event):
+    await event.delete()
+    pru = event.sender_id
+    var = "PLUGIN_CHANNEL"
+    name = "Plugin Channel"
+    async with event.client.conversation(pru) as conv:
+        await conv.send_message(
+            "Send id or username of a channel from where u want to install all plugins\n\nOur Channel~ @ultroidplugins\n\nUse /cancel to cancel."
+        )
+        response = conv.wait_event(events.NewMessage(chats=pru))
+        response = await response
+        themssg = response.message.message
+        if themssg == "/cancel":
+            return await conv.send_message("Cancelled!!")
+        else:
+            await setit(event, var, themssg)
+            await conv.send_message(
+                "{} changed to {}\n After Setting All Things Do Restart".format(
+                    name, themssg
+                )
+            )
+
+
+@callback("hhndlr")
+@owner
+async def hndlrr(event):
+    await event.delete()
+    pru = event.sender_id
+    var = "HNDLR"
+    name = "Handler/ Trigger"
+    async with event.client.conversation(pru) as conv:
+        await conv.send_message(
+            f"Send The Symbol Which u want as Handler/Trigger to use bot\nUr Current Handler is [ `{HNDLR}` ]\n\n use /cancel to cancel."
+        )
+        response = conv.wait_event(events.NewMessage(chats=pru))
+        response = await response
+        themssg = response.message.message
+        if themssg == "/cancel":
+            return await conv.send_message("Cancelled!!")
+        else:
+            await setit(event, var, themssg)
+            await conv.send_message("{} changed to {}".format(name, themssg))
 
 
 @callback("taglog")
@@ -44,33 +98,70 @@ async def tagloggerr(event):
             await conv.send_message("{} changed to {}".format(name, themssg))
 
 
-@callback("pmset")
+@callback("eaddon")
+@owner
+async def pmset(event):
+    await event.edit(
+        "ADDONS~ Extra Plugins:",
+        buttons=[
+            [Button.inline("Aᴅᴅᴏɴs  Oɴ", data="edon")],
+            [Button.inline("Aᴅᴅᴏɴs  Oғғ", data="edof")],
+            [Button.inline("« Bᴀᴄᴋ", data="otvars")],
+        ],
+    )
+
+
+@callback("edon")
+@owner
+async def eddon(event):
+    var = "ADDONS"
+    await setit(event, var, "True")
+    await event.edit(
+        "Done! ADDONS has been turned on!!\n\n After Setting All Things Do Restart"
+    )
+
+
+@callback("edof")
+@owner
+async def eddof(event):
+    var = "ADDONS"
+    await setit(event, var, "False")
+    await event.edit(
+        "Done! ADDONS has been turned off!! After Setting All Things Do Restart"
+    )
+
+
+@callback("sudo")
 @owner
 async def pmset(event):
     await event.edit(
-        "PMPermit Settings:",
+        f"SUDO MODE ~ Some peoples can use ur Bot which u selected. To know More use `{HNDLR}help sudo`",
         buttons=[
-            [Button.inline("Turn PMPermit On", data="pmon")],
-            [Button.inline("Turn PMPermit Off", data="pmoff")],
-            [Button.inline("« Back", data="otvars")]
+            [Button.inline("Sᴜᴅᴏ Mᴏᴅᴇ  Oɴ", data="onsudo")],
+            [Button.inline("Sᴜᴅᴏ Mᴏᴅᴇ  Oғғ", data="ofsudo")],
+            [Button.inline("« Bᴀᴄᴋ", data="otvars")],
         ],
     )
 
 
-@callback("pmon")
+@callback("onsudo")
 @owner
-async def pmonn(event):
-    var = "PMSETTING"
+async def eddon(event):
+    var = "SUDO"
     await setit(event, var, "True")
-    await event.edit(f"Done! PMPermit has been turned on!! Please `{hndlr}restart`")
+    await event.edit(
+        "Done! SUDO MODE has been turned on!!\n\n After Setting All Things Do Restart"
+    )
 
 
-@callback("pmoff")
+@callback("ofsudo")
 @owner
-async def pmofff(event):
-    var = "PMSETTING"
+async def eddof(event):
+    var = "SUDO"
     await setit(event, var, "False")
-    await event.edit(f"Done! PMPermit has been turned off!! Please `{hndlr}restart`")
+    await event.edit(
+        "Done! SUDO MODE has been turned off!! After Setting All Things Do Restart"
+    )
 
 
 @callback("sfban")
@@ -79,9 +170,9 @@ async def sfban(event):
     await event.edit(
         "SuperFban Settings:",
         buttons=[
-            [Button.inline("FBan Group", data="sfgrp")],
-            [Button.inline("Exclude Feds", data="sfexf")],
-            [Button.inline("« Back", data="otvars")]
+            [Button.inline("FBᴀɴ Gʀᴏᴜᴘ", data="sfgrp")],
+            [Button.inline("Exᴄʟᴜᴅᴇ Fᴇᴅs", data="sfexf")],
+            [Button.inline("« Bᴀᴄᴋ", data="otvars")],
         ],
     )
 

assistant/start.py

@@ -27,7 +27,7 @@ async def assistant(event):
                 f"Bot started by [{event.sender_id}](tg://user?id={event.sender_id})",
             )
         ok = ""
-        if Var.MSG_FRWD is True:
+        if udB.get("MSG_FRWD") == True:
             ok = "You can contact me using this bot!!"
         if event.is_private and event.sender_id in sed:
             return
@@ -46,12 +46,13 @@ async def ultroid(event):
         event.chat_id,
         f"Hi {OWNER_NAME}. Please browse through the options",
         buttons=[
-            [Button.inline("Settings ⚙️", data="setter")],
-            [Button.inline("Stats", data="stat")],
-            [Button.inline("Broadcast", data="bcast")],
+            [Button.inline("Sᴇᴛᴛɪɴɢs ⚙️", data="setter")],
+            [Button.inline("Sᴛᴀᴛs", data="stat")],
+            [Button.inline("Bʀᴏᴀᴅᴄᴀsᴛ", data="bcast")],
         ],
     )
 
+
 # aah, repeat the codes..
 @callback("mainmenu")
 @owner
@@ -61,12 +62,13 @@ async def ultroid(event):
     await event.edit(
         f"Hi {OWNER_NAME}. Please browse through the options",
         buttons=[
-            [Button.inline("Settings ⚙️", data="setter")],
-            [Button.inline("Stats", data="stat")],
-            [Button.inline("Broadcast", data="bcast")],
+            [Button.inline("Sᴇᴛᴛɪɴɢs ⚙️", data="setter")],
+            [Button.inline("Sᴛᴀᴛs", data="stat")],
+            [Button.inline("Bʀᴏᴀᴅᴄᴀsᴛ", data="bcast")],
         ],
     )
 
+
 @callback("stat")
 @owner
 async def botstat(event):
@@ -120,20 +122,12 @@ async def setting(event):
     await event.edit(
         "Choose from the below options -",
         buttons=[
-            [Button.inline("Customisations", data="allcstms")],
-            [Button.inline("API Keys", data="apiset")],
-            [Button.inline("Other Vars.", data="otvars")],
-            [Button.inline("« Back", data="mainmenu")]
+            [Button.inline("API Kᴇʏs", data="apiset")],
+            [
+                Button.inline("Aʟɪᴠᴇ", data="alvcstm"),
+                Button.inline("PᴍPᴇʀᴍɪᴛ", data="pmset"),
+            ],
+            [Button.inline("Fᴇᴀᴛᴜʀᴇs", data="otvars")],
+            [Button.inline("« Bᴀᴄᴋ", data="mainmenu")],
         ],
     )
-
-@callback("allcstms")
-@owner
-async def all(event):
-    await event.edit(
-        "All Customisable Stuff.",
-        buttons=[
-            [Button.inline("Alive", data="alvcstm")],
-            [Button.inline("PM Permit", data="pmcstm")],
-            [Button.inline("« Back", data="setter")]
-            ])

plugins/__init__.py

@@ -8,52 +8,20 @@
 import time
 
 from pyUltroid import *
+from pyUltroid.dB import *
 from pyUltroid.dB.core import *
 from pyUltroid.functions import *
 from pyUltroid.functions.all import *
+from pyUltroid.functions.broadcast_db import *
+from pyUltroid.functions.gban_mute_db import *
 from pyUltroid.functions.google_image import googleimagesdownload
 from pyUltroid.functions.sudos import *
 from pyUltroid.utils import *
 
 start_time = time.time()
-ultroid_version = "v0.0.1"
+ultroid_version = "v0.0.3"
 OWNER_NAME = ultroid_bot.me.first_name
 OWNER_ID = ultroid_bot.me.id
-DEVLIST = [
-    "1259468938",
-    "1452145387",
-    "719195224",
-    "1318486004",
-    "1289422521",
-    "1322549723",
-    "611816596",
-    "1003250439",
-    "1152902819",
-    "716243352",
-    "1444249738",
-    "559661211",
-    "881536550",
-    "630654925",
-]
-
-# sudo
-ok = udB.get("SUDOS")
-if ok:
-    SUDO_USERS = set(int(x) for x in ok.split())
-else:
-    SUDO_USERS = ""
-
-if SUDO_USERS:
-    sudos = list(SUDO_USERS)
-else:
-    sudos = ""
-
-on = Var.SUDO
-
-if Var.SUDO:
-    sed = [ultroid_bot.uid, *sudos]
-else:
-    sed = [ultroid_bot.uid]
 
 
 def grt(seconds: int) -> str:

plugins/_help.py

@@ -36,7 +36,7 @@ async def ult(ult):
                 try:
                     x = f"Plugin Name-{plug}\n\n✘ Commands Available-\n\n"
                     for d in LIST[plug]:
-                        x += Var.HNDLR + d
+                        x += HNDLR + d
                         x += "\n"
                     await eor(ult, x)
                 except BaseException:
@@ -50,7 +50,7 @@ async def ult(ult):
             return await eor(
                 ult,
                 "`The bot did not respond to the inline query.\nConsider using {}restart`".format(
-                    Var.HNDLR
+                    HNDLR
                 ),
             )
         except dis:

plugins/_inline.py

@@ -31,8 +31,8 @@ helps = """
 Pʟᴜɢɪɴs ~ {}**
 """
 
-
-if Var.ADDONS:
+add_ons = udB.get("ADDONS")
+if add_ons:
     zhelps = """
 [Uʟᴛʀᴏɪᴅ Sᴜᴘᴘᴏʀᴛ](t.me/ultroidsupport)
 
@@ -48,7 +48,7 @@ else:
 
 Aᴅᴅᴏɴs ~ {}
 
-Gᴏ Aɴᴅ Aᴅᴅ ADDON Vᴀʀ Wɪᴛʜ Vᴀʟᴜᴇ Tʀᴜᴇ**
+Gᴏ Aɴᴅ Aᴅᴅ ADDONS Vᴀʀ Wɪᴛʜ Vᴀʟᴜᴇ Tʀᴜᴇ**
 """
 # ============================================#
 
@@ -60,7 +60,7 @@ async def e(o):
         b = o.builder
         uptime = grt((time.time() - start_time))
         ALIVEMSG = """
-**The Ultroid Userbot...**\n\n
+**The Ultroid Userbot...**\n
 ✵ **Owner** - `{}`
 ✵ **Ultroid** - `{}`
 ✵ **UpTime** - `{}`
@@ -82,6 +82,14 @@ async def e(o):
                 description="Userbot | Telethon ",
                 text=ALIVEMSG,
                 thumb=InputWebDocument(ULTROID_PIC, 0, "image/jpeg", []),
+                buttons=[
+                    [Button.url(text="Support Group", url="t.me/UltroidSupport")],
+                    [
+                        Button.url(
+                            text="Repo", url="https://github.com/Teamultroid/Ultroid"
+                        )
+                    ],
+                ],
             )
         ]
         await o.answer(res, switch_pm=f"👥 ULTROID PORTAL", switch_pm_param="start")
@@ -96,19 +104,37 @@ if Var.BOT_USERNAME is not None and asst is not None:
         result = None
         query = event.text
         if event.query.user_id in sed and query.startswith("ultd"):
+            z = []
+            for x in LIST.values():
+                for y in x:
+                    z.append(y)
+            cmd = len(z) + 10
+            bn = Var.BOT_USERNAME
+            if bn.startswith("@"):
+                bnn = bn.replace("@", "")
+            else:
+                bnn = bn
             result = builder.article(
                 title="Help Menu",
                 description="Help Menu - UserBot | Telethon ",
                 url="https://t.me/TheUltroid",
                 thumb=InputWebDocument(ULTROID_PIC, 0, "image/jpeg", []),
-                text=f"** Bᴏᴛ Oғ {OWNER_NAME}\n\nMᴀɪɴ Mᴇɴᴜ\n\nPʟᴜɢɪɴs ~ {len(PLUGINS) - 4}\nAᴅᴅᴏɴs ~ {len(ADDONS)}**",
+                text=f"** Bᴏᴛ Oғ {OWNER_NAME}\n\nMᴀɪɴ Mᴇɴᴜ\n\nPʟᴜɢɪɴs ~ {len(PLUGINS) - 4}\nAᴅᴅᴏɴs ~ {len(ADDONS)}\nTᴏᴛᴀʟ Cᴏᴍᴍᴀɴᴅs ~ {cmd}**",
                 buttons=[
                     [
                         Button.inline("• Pʟᴜɢɪɴs", data="hrrrr"),
                         Button.inline("• Aᴅᴅᴏɴs", data="frrr"),
                     ],
-                    [Button.inline("Oᴡɴᴇʀ•ᴛᴏᴏʟꜱ", data="ownr")],
-                    [Button.inline("Iɴʟɪɴᴇ•Pʟᴜɢɪɴs", data="inlone")],
+                    [
+                        Button.inline("Oᴡɴᴇʀ•ᴛᴏᴏʟꜱ", data="ownr"),
+                        Button.inline("Iɴʟɪɴᴇ•Pʟᴜɢɪɴs", data="inlone"),
+                    ],
+                    [
+                        Button.url(
+                            "⚙️Sᴇᴛᴛɪɴɢs⚙️",
+                            url=f"https://t.me/{bnn}?start={ultroid_bot.me.id}",
+                        )
+                    ],
                     [Button.inline("••Cʟᴏꜱᴇ••", data="close")],
                 ],
             )
@@ -166,7 +192,7 @@ if Var.BOT_USERNAME is not None and asst is not None:
             [
                 Button.switch_inline(
                     "Sᴇɴᴅ Oғғɪᴄɪᴀʟ Pʟᴜɢɪɴs",
-                    query="send all",
+                    query="send",
                     same_peer=True,
                 )
             ],
@@ -201,7 +227,7 @@ if Var.BOT_USERNAME is not None and asst is not None:
             [
                 Button.switch_inline(
                     "YᴏᴜTᴜʙᴇ Dᴏᴡɴʟᴏᴀᴅᴇʀ",
-                    query="yt How to Deploy Ultroid Userbot",
+                    query="Ed Sheeran Perfect",
                     same_peer=True,
                 )
             ],
@@ -310,17 +336,34 @@ if Var.BOT_USERNAME is not None and asst is not None:
     @callback("open")
     @owner
     async def opner(event):
+        bn = Var.BOT_USERNAME
+        if bn.startswith("@"):
+            bnn = bn.replace("@", "")
+        else:
+            bnn = bn
         buttons = [
             [
                 Button.inline("• Pʟᴜɢɪɴs ", data="hrrrr"),
                 Button.inline("• Aᴅᴅᴏɴs", data="frrr"),
             ],
-            [Button.inline("Oᴡɴᴇʀ•Tᴏᴏʟꜱ", data="ownr")],
-            [Button.inline("Iɴʟɪɴᴇ•Pʟᴜɢɪɴs", data="inlone")],
+            [
+                Button.inline("Oᴡɴᴇʀ•Tᴏᴏʟꜱ", data="ownr"),
+                Button.inline("Iɴʟɪɴᴇ•Pʟᴜɢɪɴs", data="inlone"),
+            ],
+            [
+                Button.url(
+                    "⚙️Sᴇᴛᴛɪɴɢs⚙️", url=f"https://t.me/{bnn}?start={ultroid_bot.me.id}"
+                )
+            ],
             [Button.inline("••Cʟᴏꜱᴇ••", data="close")],
         ]
+        z = []
+        for x in LIST.values():
+            for y in x:
+                z.append(y)
+        cmd = len(z) + 10
         await event.edit(
-            f"** Bᴏᴛ Oғ {OWNER_NAME}\n\nMᴀɪɴ Mᴇɴᴜ\n\nOꜰꜰɪᴄɪᴀʟ Pʟᴜɢɪɴs ~ {len(PLUGINS) - 4}\nUɴᴏꜰꜰɪᴄɪᴀʟ Pʟᴜɢɪɴs ~ {len(ADDONS)}**",
+            f"** Bᴏᴛ Oғ {OWNER_NAME}\n\nMᴀɪɴ Mᴇɴᴜ\n\nPʟᴜɢɪɴs ~ {len(PLUGINS) - 4}\nAᴅᴅᴏɴs ~ {len(ADDONS)}\nTᴏᴛᴀʟ Cᴏᴍᴍᴀɴᴅs ~ {cmd}**",
             buttons=buttons,
             link_preview=False,
         )
@@ -394,7 +437,7 @@ if Var.BOT_USERNAME is not None and asst is not None:
                             f"Plugin Name-{plugin_name}\n\n✘ Commands Available-\n\n"
                         )
                         for d in LIST[plugin_name]:
-                            help_string += Var.HNDLR + d
+                            help_string += HNDLR + d
                             help_string += "\n"
                 except BaseException:
                     pass
@@ -423,8 +466,11 @@ if Var.BOT_USERNAME is not None and asst is not None:
 def paginate_help(page_number, loaded_plugins, prefix):
     number_of_rows = 5
     number_of_cols = 2
-    multi = os.environ.get("EMOJI_TO_DESPLAY_IN_HELP", "✘")
-    mult2i = os.environ.get("EMOJI2_TO_DESPLAY_IN_HELP", "✘")
+    emoji = Redis("EMOJI_IN_HELP")
+    if emoji:
+        multi, mult2i = emoji, emoji
+    else:
+        multi, mult2i = "✘", "✘"
     helpable_plugins = []
     global upage
     upage = page_number
@@ -470,8 +516,11 @@ def paginate_help(page_number, loaded_plugins, prefix):
 def paginate_addon(page_number, loaded_plugins, prefix):
     number_of_rows = 5
     number_of_cols = 2
-    multi = os.environ.get("EMOJI_TO_DESPLAY_IN_HELP", "✘")
-    mult2i = os.environ.get("EMOJI2_TO_DESPLAY_IN_HELP", "✘")
+    emoji = Redis("EMOJI_IN_HELP")
+    if emoji:
+        multi, mult2i = emoji, emoji
+    else:
+        multi, mult2i = "✘", "✘"
     helpable_plugins = []
     global addpage
     addpage = page_number

plugins/_wspr.py

@@ -45,7 +45,7 @@ async def _(e):
             return await eor(
                 e,
                 "`The bot did not respond to the inline query.\nConsider using {}restart`".format(
-                    Var.HNDLR
+                    HNDLR
                 ),
             )
         except dis:

plugins/admintools.py

@@ -154,6 +154,8 @@ async def bban(ult):
     user, reason = await get_user_info(ult)
     if not user:
         return await xx.edit("`Reply to a user or give username to ban him!`")
+    if str(user.id) in DEVLIST:
+        return await xx.edit(" `LoL, I can't Ban my Developer 😂`")
     await xx.edit("`Getting user info...`")
     try:
         await ultroid_bot(
@@ -233,6 +235,13 @@ async def uunban(ult):
     groups_only=True,
 )
 async def kck(ult):
+    tt = ult.text
+    try:
+        tx = tt[5]
+        if tx:
+            return
+    except BaseException:
+        pass
     xx = await eor(ult, "`Processing...`")
     chat = await ult.get_chat()
     isAdmin = chat.admin_rights
@@ -242,6 +251,8 @@ async def kck(ult):
     user, reason = await get_user_info(ult)
     if not user:
         return await xx.edit("`Kick? Whom? I couldn't get his info...`")
+    if str(user.id) in DEVLIST:
+        return await xx.edit(" `Lol, I can't Kick my Developer`😂")
     await xx.edit("`Kicking...`")
     try:
         await ultroid_bot.kick_participant(ult.chat_id, user.id)
@@ -274,7 +285,7 @@ async def pin(msg):
     tt = msg.text
     try:
         kk = tt[4]
-        if kk == "g":
+        if kk:
             return
     except BaseException:
         pass
@@ -451,4 +462,4 @@ async def editer(edit):
         i = i + 1
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/afk.py

@@ -249,4 +249,4 @@ async def _(event):
             logger.warn(str(e))
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/autopic.py

@@ -8,18 +8,14 @@
 """
 ✘ Commands Available -
 
-• `{i}autopic <topic>`
+• `{i}autopic <search query>`
     Will change your profile pic at defined intervals with pics related to the given topic.
 
 """
 import asyncio
 import os
 import random
-import re
-import urllib
 
-from bs4 import BeautifulSoup as bs
-from requests import get
 from telethon import functions
 
 from . import *
@@ -33,7 +29,10 @@ async def autopic(e):
     clls = returnpage(search)
     if len(clls) == 0:
         return await eor(e, f"No Results found for `{search}`")
-    num = random.randrange(0, len(clls) - 1)
+    if not len(clls) == 1:
+        num = random.randrange(0, len(clls) - 1)
+    else:
+        num = 0
     page = clls[num]
     title = page["title"]
     a = await eor(
@@ -47,4 +46,4 @@ async def autopic(e):
         await asyncio.sleep(1100)
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/bot.py

@@ -73,14 +73,14 @@ async def lol(ult):
 
 **{}**
 
-┏━━━━━━━━━━━━━━━━━━━━━━
+┏━━━━━━━━━━━━━━━━━━━━━
 ┣ **Owner** - `{}`
 ┣ **Version** - `{}`
 ┣ **UpTime** - `{}`
 ┣ **Python** - `{}`
 ┣ **Telethon** - `{}`
 ┣ **Branch** - `{}`
-┗━━━━━━━━━━━━━━━━━━━━━━
+┗━━━━━━━━━━━━━━━━━━━━━
 """.format(
         header,
         OWNER_NAME,
@@ -231,4 +231,4 @@ async def shht(event):
     await ultroid_bot.disconnect()
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/broadcast.py

@@ -0,0 +1,319 @@
+# Ultroid - UserBot
+# Copyright (C) 2020 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}add <id/reply to list/none>`
+    Add chat to database. Adds current chat if no id specified.
+
+• `{i}rem <all/id/none>`
+    Removes the specified chat (current chat if none specified), or all chats.
+
+• `{i}broadcast <reply to msg>`
+    Send the replied message to all chats in database.
+
+• `{i}forward <reply to msg>`
+     Forward the message to all chats in database.
+
+• `{i}listchannels`
+    To get list of all added chats.
+"""
+import asyncio
+import io
+
+from . import *
+
+
+@ultroid_cmd(pattern="add ?(.*)")
+async def broadcast_adder(event):
+    if "addsudo" in event.text:  # weird fix
+        return
+    msgg = event.pattern_match.group(1)
+    x = await eor(event, "`Adding to db...`")
+    aldone = new = crsh = 0
+    if msgg == "all":
+        await x.edit("`Trying to add all admin channels to db...`")
+        chats = [
+            e.entity
+            for e in await ultroid.get_dialogs()
+            if (e.is_group or e.is_channel)
+        ]
+        for i in chats:
+            try:
+                if i.broadcast:
+                    if i.creator or i.admin_rights:
+                        if is_channel_added(i.id):
+                            aldone += 1
+                        else:
+                            cid = f"-100{i.id}"
+                            add_channel(int(cid))
+                            new += 1
+            except BaseException:
+                pass
+        await x.edit(
+            f"**Done.**\nChats already in Database: {get_no_channels()}\nNewly Added: {new}"
+        )
+        return
+    if event.reply_to_msg_id:
+        previous_message = await event.get_reply_message()
+        raw_text = previous_message.text
+        lines = raw_text.split("\n")
+        length = len(lines)
+        for line_number in range(1, length - 2):
+            channel_id = lines[line_number][4:-1]
+            if not is_channel_added(channel_id):
+                add_channel(channel_id)
+        await x.edit("Channels added!")
+        await asyncio.sleep(3)
+        await event.delete()
+        return
+    chat_id = event.chat_id
+    try:
+        if int(chat_id) == Var.LOG_CHANNEL:
+            return
+    except BaseException:
+        pass
+    if not is_channel_added(chat_id):
+        x = add_channel(chat_id)
+        if x:
+            await x.edit("`Added to database!`")
+        else:
+            await x.edit("Error")
+        await asyncio.sleep(3)
+        await event.delete()
+    elif is_channel_added(chat_id):
+        await x.edit("`Channel is already is database!`")
+        await asyncio.sleep(3)
+        await event.delete()
+
+
+@ultroid_cmd(pattern="rem ?(.*)")
+async def broadcast_remover(event):
+    chat_id = event.pattern_match.group(1)
+    x = await eor(event, "`Processing...`")
+    if chat_id == "all":
+        await x.edit("`Removing...`")
+        udB.delete("BROADCAST")
+        await x.edit("Database cleared.")
+        return
+    if is_channel_added(chat_id):
+        rem_channel(chat_id)
+        await x.edit("Removed from database")
+        await asyncio.sleep(3)
+        await x.delete()
+    elif is_channel_added(event.chat_id):
+        rem_channel(event.chat_id)
+        await x.edit("Removed from database")
+        await asyncio.sleep(3)
+        await x.delete()
+    elif not is_channel_added(event.chat_id):
+        await x.edit("Channel is already removed from database. ")
+        await asyncio.sleep(3)
+        await x.delete()
+
+
+@ultroid_cmd(pattern="listchannels")
+async def list_all(event):
+    x = await eor(event, "`Calculating...`")
+    channels = get_channels()
+    num = get_no_channels()
+    if num == 0:
+        return await eod(x, "No chats were added.", time=5)
+    msg = "Channels in database:\n"
+    for channel in channels:
+        name = ""
+        try:
+            name = (await ultroid.get_entity(int(channel))).title
+        except:
+            name = ""
+        msg += f"=> **{name}** [`{channel}`]\n"
+    msg += f"\nTotal {get_no_channels()} channels."
+    if len(msg) > 4096:
+        with io.BytesIO(str.encode(msg)) as out_file:
+            out_file.name = "channels.txt"
+            await ultroid_bot.send_file(
+                event.chat_id,
+                out_file,
+                force_document=True,
+                allow_cache=False,
+                caption="Channels in database",
+                reply_to=event,
+            )
+            await x.delete()
+    else:
+        await x.edit(msg)
+
+
+@ultroid_cmd(pattern="forward ?(.*)")
+async def forw(event):
+    if event.fwd_from:
+        return
+    if not event.is_reply:
+        await eor(event, "Reply to a message to broadcast.")
+        return
+    channels = get_channels()
+    x = await eor(event, "Sending...")
+    if get_no_channels() == 0:
+        return await x.edit(f"Please add channels by using `{hndlr}add` in them.")
+    error_count = 0
+    sent_count = 0
+    if event.reply_to_msg_id:
+        previous_message = await event.get_reply_message()
+        previous_message.message
+        previous_message.raw_text
+    error_count = 0
+    for channel in channels:
+        try:
+            await ultroid_bot.forward_messages(int(channel), previous_message)
+            sent_count += 1
+            await x.edit(
+                f"Sent : {sent_count}\nError : {error_count}\nTotal : {len(channels)}",
+            )
+        except Exception as error:
+            try:
+                await ultroid_bot.send_message(
+                    Var.LOG_CHANNEL, f"Error in sending at {channel}."
+                )
+                await ultroid_bot.send_message(Var.LOG_CHANNEL, "Error! " + str(error))
+                if error == "The message cannot be empty unless a file is provided":
+                    return await x.edit(
+                        "For sending files, upload in Saved Messages and reply .forward to it."
+                    )
+            except BaseException:
+                pass
+            error_count += 1
+            await x.edit(
+                f"Sent : {sent_count}\nError : {error_count}\nTotal : {len(channels)}",
+            )
+    await x.edit(f"{sent_count} messages sent with {error_count} errors.")
+    if error_count > 0:
+        try:
+            await ultroid_bot.send_message(Var.LOG_CHANNEL, f"{error_count} Errors")
+        except BaseException:
+            await x.edit("Set up log channel for checking errors.")
+
+
+@ultroid_cmd(pattern="broadcast ?(.*)")
+async def sending(event):
+    x = await eor(event, "`Processing...`")
+    if not event.is_reply:
+        return await x.edit("Reply to a message to broadcast.")
+    channels = get_channels()
+    error_count = 0
+    sent_count = 0
+    if len(channels) == 0:
+        return await x.edit(
+            f"You haven't added any channels. Use `{hndlr}add` in them fist!"
+        )
+    await x.edit("Sending....")
+    if event.reply_to_msg_id:
+        previous_message = await event.get_reply_message()
+        if previous_message.sticker or previous_message.poll:
+            await x.edit(f"Reply `{hndlr}forward` for stickers and polls.")
+            return
+        if (
+            previous_message.gif
+            or previous_message.audio
+            or previous_message.voice
+            or previous_message.video
+            or previous_message.video_note
+            or previous_message.contact
+            or previous_message.game
+            or previous_message.geo
+            or previous_message.invoice
+        ):
+            await x.edit(f"Not supported. Try `{hndlr}forward`")
+            return
+        if not previous_message.web_preview and previous_message.photo:
+            file = await ultroid_bot.download_file(previous_message.media)
+            uploaded_doc = await ultroid_bot.upload_file(file, file_name="img.png")
+            raw_text = previous_message.text
+            for channel in channels:
+                try:
+                    if previous_message.photo:
+                        await ultroid_bot.send_file(
+                            int(channel),
+                            InputMediaUploadedPhoto(file=uploaded_doc),
+                            force_document=False,
+                            caption=raw_text,
+                            link_preview=False,
+                        )
+
+                    sent_count += 1
+                    await x.edit(
+                        f"Sent : {sent_count}\nError : {error_count}\nTotal : {len(channels)}",
+                    )
+                except Exception as error:
+                    try:
+                        await ultroid_bot.send_message(
+                            Var.LOG_CHANNEL, f"Error in sending at {channel}."
+                        )
+                        await ultroid_bot.send_message(
+                            Var.LOG_CHANNEL, "Error! " + str(error)
+                        )
+                        if (
+                            error
+                            == "The message cannot be empty unless a file is provided"
+                        ):
+                            return await x.edit(
+                                f"For sending files, upload in Saved Messages and reply {hndlr}forward to in."
+                            )
+                    except BaseException:
+                        pass
+                    error_count += 1
+                    await x.edit(
+                        f"Sent : {sent_count}\nError : {error_count}\nTotal : {len(channels)}",
+                    )
+            await x.edit(f"{sent_count} messages sent with {error_count} errors.")
+            if error_count > 0:
+                try:
+                    await ultroid_bot.send_message(
+                        Var.LOG_CHANNEL, f"{error_count} Errors"
+                    )
+                except BaseException:
+                    pass
+        else:
+            raw_text = previous_message.text
+            for channel in channels:
+                try:
+                    await ultroid_bot.send_message(
+                        int(channel), raw_text, link_preview=False
+                    )
+                    sent_count += 1
+                    await x.edit(
+                        f"Sent : {sent_count}\nError : {error_count}\nTotal : {len(channels)}",
+                    )
+                except Exception as error:
+                    try:
+                        await ultroid_bot.send_message(
+                            Var.LOG_CHANNEL, f"Error in sending at {channel}."
+                        )
+                        await ultroid_bot.send_message(
+                            Var.LOG_CHANNEL, "Error! " + str(error)
+                        )
+                        if (
+                            error
+                            == "The message cannot be empty unless a file is provided"
+                        ):
+                            return await x.edit(
+                                f"For sending files, upload in Saved Messages and reply {hndlr}forward to in."
+                            )
+                    except BaseException:
+                        pass
+                    error_count += 1
+                    await x.edit(
+                        f"Sent : {sent_count}\nError : {error_count}\nTotal : {len(channels)}",
+                    )
+            await x.edit(f"{sent_count} messages sent with {error_count} errors.")
+            if error_count > 0:
+                try:
+                    await ultroid_bot.send_message(
+                        Var.LOG_CHANNEL, f"{error_count} Errors"
+                    )
+                except BaseException:
+                    await x.edit("Set up log channel for checking errors.")

plugins/carbon.py

@@ -232,4 +232,4 @@ async def crbn(event):
     os.remove(xx)
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/chats.py

@@ -114,4 +114,4 @@ async def _(e):
             await xx.edit(str(ex))
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/converter.py

@@ -0,0 +1,91 @@
+# Ultroid - UserBot
+# Copyright (C) 2020 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}rename <file name with extension>`
+    rename the file
+    
+• `{i}mtoi <reply to media>`
+    media to image conversion
+
+• `{i}mtos <reply to media>`
+    convert media to sticker.
+"""
+
+import os
+
+import cv2
+from PIL import Image
+
+from . import *
+
+
+@ultroid_cmd(pattern="rename ?(.*)")
+async def imak(event):
+    reply = await event.get_reply_message()
+    if not reply:
+        await eor(event, "Reply to any media/Document.")
+        return
+    inp = event.pattern_match.group(1)
+    if not inp:
+        await eor(event, "Give The name nd extension of file")
+        return
+    xx = await eor(event, "`Processing...`")
+    image = await ultroid_bot.download_media(reply)
+    os.rename(image, inp)
+    await ultroid_bot.send_file(event.chat_id, inp, reply_to=reply)
+    os.remove(inp)
+    await xx.delete()
+
+
+@ultroid_cmd(pattern="mtoi$")
+async def imak(event):
+    reply = await event.get_reply_message()
+    if not (reply and (reply.media)):
+        await eor(event, "Reply to any media.")
+        return
+    xx = await eor(event, "`Processing...`")
+    image = await ultroid_bot.download_media(reply)
+    file = "ult.png"
+    if image.endswith((".webp", ".png")):
+        c = Image.open(image)
+        c.save(file)
+    else:
+        img = cv2.VideoCapture(image)
+        ult, roid = img.read()
+        cv2.imwrite(file, roid)
+    await ultroid_bot.send_file(event.chat_id, file, reply_to=reply)
+    await xx.delete()
+    os.remove(file)
+    os.remove(image)
+
+
+@ultroid_cmd(pattern="mtos$")
+async def smak(event):
+    reply = await event.get_reply_message()
+    if not (reply and (reply.media)):
+        await eor(event, "Reply to any media.")
+        return
+    xx = await eor(event, "`Processing...`")
+    image = await ultroid_bot.download_media(reply)
+    file = "ult.webp"
+    if image.endswith((".webp", ".png", ".jpg")):
+        c = Image.open(image)
+        c.save(file)
+    else:
+        img = cv2.VideoCapture(image)
+        ult, roid = img.read()
+        cv2.imwrite(file, roid)
+    await ultroid_bot.send_file(event.chat_id, file, reply_to=reply)
+    await xx.delete()
+    os.remove(file)
+    os.remove(image)
+
+
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/core.py

@@ -119,8 +119,8 @@ async def unload(event):
         try:
             un_plug(shortname)
             await eod(event, f"**Uɴʟᴏᴀᴅᴇᴅ** `{shortname}` **Sᴜᴄᴄᴇssғᴜʟʟʏ.**", time=3)
-        except BaseException:
-            pass
+        except Exception as ex:
+            return await eor(event, str(ex))
     elif zym in lst:
         return await eod(event, "**Yᴏᴜ Cᴀɴ'ᴛ Uɴʟᴏᴀᴅ Oғғɪᴄɪᴀʟ Pʟᴜɢɪɴs**", time=3)
     else:
@@ -143,8 +143,8 @@ async def uninstall(event):
             un_plug(shortname)
             await eod(event, f"**Uɴɪɴsᴛᴀʟʟᴇᴅ** `{shortname}` **Sᴜᴄᴄᴇssғᴜʟʟʏ.**", time=3)
             os.remove(f"addons/{shortname}.py")
-        except BaseException:
-            pass
+        except Exception as ex:
+            return await eor(event, str(ex))
     elif zym in lst:
         return await eod(event, "**Yᴏᴜ Cᴀɴ'ᴛ Uɴɪɴsᴛᴀʟʟ Oғғɪᴄɪᴀʟ Pʟᴜɢɪɴs**", time=3)
     else:
@@ -174,4 +174,4 @@ async def load(event):
         )
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/fedutils.py

@@ -25,7 +25,9 @@ Specify FBan Group and Feds to exclude in the assistant.
 
 import asyncio
 import os
+
 from telethon.errors.rpcerrorlist import YouBlockedUserError
+
 from . import *
 
 bot = "@MissRose_bot"
@@ -391,4 +393,4 @@ async def _(event):
             await ok.edit("**Error**\n `Unblock` @MissRose_Bot `and try again!")
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/gdrive.py

@@ -0,0 +1,211 @@
+# Ultroid - UserBot
+# Copyright (C) 2020 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}ulgdrive <reply/file name>`
+    Reply to file to upload on Google Drive.
+    Add file name to upload on Google Drive.
+
+• `{i}drivesearch <file name>`
+    Search file name on Google Drive and get link.
+
+• `{i}uldir <directory name>`
+    Upload a directory on Google Drive.
+
+• `{i}gfolder`
+    Link to your Google Drive Folder.
+    If added then all uploaded files will be placed here.
+"""
+
+
+import asyncio
+import os
+import time
+from datetime import datetime
+
+from telethon import events
+
+from . import *
+
+TOKEN_FILE = "resources/downloads/auth_token.txt"
+TEMP_DOWNLOAD_DIRECTORY = "resources/downloads/"
+
+
+@asst_cmd("auth")
+async def aut(event):
+    if event.is_group:
+        return
+    if os.path.exists(TOKEN_FILE):
+        return await event.reply("`You have already authorised with Google Drive`")
+    if Redis("GDRIVE_CLIENT_ID") == None or Redis("GDRIVE_CLIENT_SECRET") == None:
+        await event.reply(
+            "Go [here](https://console.developers.google.com/flows/enableapi?apiid=drive) and get your GDRIVE_CLIENT_ID and GDRIVE_CLIENT_SECRET\n\n"
+            + "Send your GDRIVE_CLIENT_ID and GDRIVE_CLIENT_SECRET as this.\n`GDRIVE_CLIENT_ID GDRIVE_CLIENT_SECRET` separated by space.",
+        )
+        async with asst.conversation(ultroid_bot.uid) as conv:
+            reply = conv.wait_event(events.NewMessage(from_users=ultroid_bot.uid))
+            repl = await reply
+            try:
+                creds = repl.text.split(" ")
+                id = creds[0]
+                if not id.endswith("com"):
+                    return await event.reply("`Wrong Client Id`")
+                try:
+                    secret = creds[1]
+                except IndexError:
+                    return await event.reply("`No Client Secret Found`")
+                udB.set("GDRIVE_CLIENT_ID", id)
+                udB.set("GDRIVE_CLIENT_SECRET", secret)
+                return await repl.reply("`Success!` Now send /auth again")
+            except Exception as exx:
+                return await repl.reply(
+                    "`Something went wrong! Send `/auth` again.\nIf same happens contact `@TheUltroid"
+                )
+    else:
+        storage = await create_token_file(TOKEN_FILE, event)
+        http = authorize(TOKEN_FILE, storage)
+        f = open(TOKEN_FILE, "r")
+        token_file_data = f.read()
+        udB.set("GDRIVE_TOKEN", token_file_data)
+        await event.reply(
+            "`Success!\nYou are all set to use Google Drive with Ultroid Userbot.`"
+        )
+
+
+@ultroid_cmd(
+    pattern="ulgdrive ?(.*)",
+)
+async def _(event):
+    mone = await eor(event, "Processing ...")
+    if not os.path.exists(TOKEN_FILE):
+        return await eod(mone, f"`Go to `{Var.BOT_USERNAME}` and send ``/auth.`")
+    input_str = event.pattern_match.group(1)
+    required_file_name = None
+    start = datetime.now()
+    dddd = time.time()
+    if event.reply_to_msg_id and not input_str:
+        reply_message = await event.get_reply_message()
+        try:
+            downloaded_file_name = await event.client.download_media(
+                reply_message,
+                TEMP_DOWNLOAD_DIRECTORY,
+                progress_callback=lambda d, t: asyncio.get_event_loop().create_task(
+                    progress(
+                        d,
+                        t,
+                        mone,
+                        dddd,
+                        "Downloading...",
+                    ),
+                ),
+            )
+        except Exception as e:
+            return await eod(mone, str(e), time=10)
+        end = datetime.now()
+        ms = (end - start).seconds
+        required_file_name = downloaded_file_name
+        await mone.edit(
+            "Downloaded to `{}` in {} seconds.".format(downloaded_file_name, ms)
+        )
+    elif input_str:
+        input_str = input_str.strip()
+        if os.path.exists(input_str):
+            end = datetime.now()
+            ms = (end - start).seconds
+            required_file_name = input_str
+            await mone.edit("Found `{}` in {} seconds.".format(input_str, ms))
+        else:
+            return await eod(
+                mone, "File Not found in local server. Give me a file path :((", time=5
+            )
+    if required_file_name:
+        http = authorize(TOKEN_FILE, None)
+        file_name, mime_type = file_ops(required_file_name)
+        try:
+            g_drive_link = await upload_file(
+                http,
+                required_file_name,
+                file_name,
+                mime_type,
+                mone,
+                Redis("GDRIVE_FOLDER_ID"),
+            )
+            await mone.edit(
+                "**Successfully Uploaded File on G-Drive :**\n\n[{}]({})".format(
+                    file_name, g_drive_link
+                )
+            )
+        except Exception as e:
+            await mone.edit(f"Exception occurred while uploading to gDrive {e}")
+    else:
+        return await eod(mone, "`File Not found in local server.`", time=10)
+
+
+@ultroid_cmd(
+    pattern="drivesearch ?(.*)",
+)
+async def sch(event):
+    if not os.path.exists(TOKEN_FILE):
+        return await eod(mone, f"`Go to `{Var.BOT_USERNAME}` and send ``/auth.`")
+    http = authorize(TOKEN_FILE, None)
+    input_str = event.pattern_match.group(1).strip()
+    a = await eor(event, "Searching for {} in G-Drive.".format(input_str))
+    if Redis("GDRIVE_FOLDER_ID") is not None:
+        query = "'{}' in parents and (title contains '{}')".format(
+            Redis("GDRIVE_FOLDER_ID"), input_str
+        )
+    else:
+        query = "title contains '{}'".format(input_str)
+    try:
+        msg = await gsearch(http, query, input_str)
+        return await a.edit(str(msg))
+    except Exception as ex:
+        return await a.edit(str(ex))
+
+
+@ultroid_cmd(
+    pattern="uldir ?(.*)",
+)
+async def _(event):
+    if not os.path.exists(TOKEN_FILE):
+        return await eod(mone, f"`Go to `{Var.BOT_USERNAME}` and send ``/auth.`")
+    input_str = event.pattern_match.group(1)
+    if os.path.isdir(input_str):
+        http = authorize(TOKEN_FILE, None)
+        a = await eor(event, "Uploading `{}` to G-Drive...".format(input_str))
+        dir_id = await create_directory(
+            http,
+            os.path.basename(os.path.abspath(input_str)),
+            Redis("GDRIVE_FOLDER_ID"),
+        )
+        await DoTeskWithDir(http, input_str, event, dir_id)
+        dir_link = "https://drive.google.com/folderview?id={}".format(dir_id)
+        await eod(
+            a,
+            f"**Successfully Uploaded Folder To G-Drive...**\n[{input_str}]({dir_link})",
+        )
+    else:
+        return await eod(event, f"Directory {input_str} does not seem to exist", time=5)
+
+
+@ultroid_cmd(
+    pattern="gfolder$",
+)
+async def _(event):
+    if Redis("GDRIVE_FOLDER_ID"):
+        folder_link = "https://drive.google.com/folderview?id=" + Redis(
+            "GDRIVE_FOLDER_ID"
+        )
+        await eod(event, "`Here is Your G-Drive Folder link : `\n" + folder_link)
+    else:
+        await eod(event, "Set GDRIVE_FOLDER_ID with value of your folder id")
+
+
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/github.py

@@ -67,4 +67,4 @@ async def gitsearch(event):
     )
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/globaltools.py

@@ -0,0 +1,299 @@
+# Ultroid - UserBot
+# Copyright (C) 2020 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}gban <reply user/ username>`
+    Globally Ban User.
+
+• `{i}ungban <reply user/ username>`
+    Unban Globally.
+
+• `{i}gmute <reply user/ username>`
+    Globally Mute the User.
+
+• `{i}ungmute <reply user/ username>`
+    UnMute Globally.
+
+• `{i}gkick <reply user/ username>`
+    Globally Kick User.
+
+• `{i}gcast <Message>`
+    Globally Send that msg in all grps.
+"""
+
+from telethon import events
+from telethon.tl.functions.channels import EditBannedRequest
+from telethon.tl.types import ChatBannedRights
+
+from . import *
+
+
+@ultroid_cmd(
+    pattern="ungban ?(.*)",
+)
+async def _(e):
+    xx = await eor(e, "`UnGbanning...`")
+    if e.is_private:
+        userid = (await e.get_chat()).id
+    elif e.reply_to_msg_id:
+        userid = (await e.get_reply_message()).sender_id
+    elif e.pattern_match.group(1):
+        if (e.pattern_match.group(1)).isdigit():
+            try:
+                userid = (await e.client.get_entity(int(e.pattern_match.group(1)))).id
+            except ValueError as err:
+                return await eod(xx, f"{str(err)}", time=5)
+        else:
+            try:
+                userid = (await e.client.get_entity(str(e.pattern_match.group(1)))).id
+            except ValueError as err:
+                return await eod(xx, f"{str(err)}", time=5)
+    else:
+        return await eod(xx, "`Reply to some msg or add their id.`", time=5)
+    name = (await e.client.get_entity(userid)).first_name
+    chats = 0
+    if not is_gbanned(userid):
+        return await eod(xx, "`User is not gbanned.`", time=3)
+    async for ggban in e.client.iter_dialogs():
+        if ggban.is_group or ggban.is_channel:
+            try:
+                await e.client.edit_permissions(ggban.id, userid, view_messages=True)
+                chats += 1
+            except:
+                pass
+    ungban(userid)
+    await xx.edit(
+        f"`Ungbanned` [{name}](tg://user?id={userid}) `in {chats} chats.\nRemoved from gbanwatch.`"
+    )
+
+
+@ultroid_cmd(
+    pattern="gban ?(.*)",
+)
+async def _(e):
+    xx = await eor(e, "`Gbanning...`")
+    if e.is_private:
+        userid = (await e.get_chat()).id
+    elif e.reply_to_msg_id:
+        userid = (await e.get_reply_message()).sender_id
+    elif e.pattern_match.group(1):
+        if (e.pattern_match.group(1)).isdigit():
+            try:
+                userid = (await e.client.get_entity(int(e.pattern_match.group(1)))).id
+            except ValueError as err:
+                return await eod(xx, f"{str(err)}", time=5)
+        else:
+            try:
+                userid = (await e.client.get_entity(str(e.pattern_match.group(1)))).id
+            except ValueError as err:
+                return await eod(xx, f"{str(err)}", time=5)
+    else:
+        return await eod(xx, "`Reply to some msg or add their id.`", tome=5)
+    name = (await e.client.get_entity(userid)).first_name
+    chats = 0
+    if userid == ultroid_bot.uid:
+        return await eod(xx, "`I can't gban myself.`", time=3)
+    if str(userid) in DEVLIST:
+        return await eod(xx, "`I can't gban my Developers.`", time=3)
+    if str(userid) in (Redis("SUDOS")).split(" "):
+        return await eod(xx, "`I can't gban a sudo user.`", time=3)
+    if is_gbanned(userid):
+        return await eod(
+            xx, "`User is already gbanned and added to gbanwatch.`", time=4
+        )
+    async for ggban in e.client.iter_dialogs():
+        if ggban.is_group or ggban.is_channel:
+            try:
+                await e.client.edit_permissions(ggban.id, userid, view_messages=False)
+                chats += 1
+            except:
+                pass
+    gban(userid)
+    await xx.edit(
+        f"`Gbanned` [{name}](tg://user?id={userid}) `in {chats} chats.\nAdded to gbanwatch.`"
+    )
+
+
+@ultroid_cmd(
+    pattern="gcast ?(.*)",
+)
+async def gcast(event):
+    xx = event.pattern_match.group(1)
+    if not xx:
+        return eor(event, "`Give some text to Globally Broadcast`")
+    tt = event.text
+    msg = tt[6:]
+    kk = await eor(event, "`Globally Broadcasting Msg...`")
+    er = 0
+    done = 0
+    async for x in ultroid_bot.iter_dialogs():
+        if x.is_group:
+            chat = x.id
+            try:
+                done += 1
+                await ultroid_bot.send_message(chat, msg)
+            except:
+                er += 1
+                pass
+    await kk.edit(f"Done in {done} chats, error in {er} chat(s)")
+
+
+@ultroid_cmd(
+    pattern="gkick ?(.*)",
+)
+async def gkick(e):
+    xx = await eor(e, "`Gkicking...`")
+    if e.is_private:
+        userid = (await e.get_chat()).id
+    elif e.reply_to_msg_id:
+        userid = (await e.get_reply_message()).sender_id
+    elif e.pattern_match.group(1):
+        if (e.pattern_match.group(1)).isdigit():
+            try:
+                userid = (await e.client.get_entity(int(e.pattern_match.group(1)))).id
+            except ValueError as err:
+                return await eod(xx, f"{str(err)}", time=5)
+        else:
+            try:
+                userid = (await e.client.get_entity(str(e.pattern_match.group(1)))).id
+            except ValueError as err:
+                return await eod(xx, f"{str(err)}", time=5)
+    else:
+        return await eod(xx, "`Reply to some msg or add their id.`", time=5)
+    name = (await e.client.get_entity(userid)).first_name
+    chats = 0
+    if userid == ultroid_bot.uid:
+        return await eod(xx, "`I can't gkick myself.`", time=3)
+    if str(userid) in DEVLIST:
+        return await eod(xx, "`I can't gkick my Developers.`", time=3)
+    if str(userid) in (Redis("SUDOS")).split(" "):
+        return await eod(xx, "`I can't gkick a sudo user.`", time=3)
+    async for gkick in e.client.iter_dialogs():
+        if gkick.is_group or gkick.is_channel:
+            try:
+                await ultroid_bot.kick_participant(gkick.id, userid)
+                chats += 1
+            except:
+                pass
+    await xx.edit(f"`Gkicked` [{name}](tg://user?id={userid}) `in {chats} chats.`")
+
+
+@ultroid_cmd(
+    pattern="gmute ?(.*)",
+)
+async def _(e):
+    xx = await eor(e, "`Gmuting...`")
+    if e.is_private:
+        userid = (await e.get_chat()).id
+    elif e.reply_to_msg_id:
+        userid = (await e.get_reply_message()).sender_id
+    elif e.pattern_match.group(1):
+        if (e.pattern_match.group(1)).isdigit():
+            try:
+                userid = (await e.client.get_entity(int(e.pattern_match.group(1)))).id
+            except ValueError as err:
+                return await eod(xx, f"{str(err)}", time=5)
+        else:
+            try:
+                userid = (await e.client.get_entity(str(e.pattern_match.group(1)))).id
+            except ValueError as err:
+                return await eod(xx, f"{str(err)}", time=5)
+    else:
+        return await eod(xx, "`Reply to some msg or add their id.`", tome=5)
+    name = (await e.client.get_entity(userid)).first_name
+    chats = 0
+    if userid == ultroid_bot.uid:
+        return await eod(xx, "`I can't gmute myself.`", time=3)
+    if str(userid) in DEVLIST:
+        return await eod(xx, "`I can't gmute my Developers.`", time=3)
+    if is_gmuted(userid):
+        return await eod(xx, "`User is already gmuted.`", time=4)
+    async for onmute in e.client.iter_dialogs():
+        if onmute.is_group:
+            try:
+                await e.client(
+                    EditBannedRequest(
+                        onmute.id,
+                        userid,
+                        ChatBannedRights(until_date=None, send_messages=True),
+                    )
+                )
+                chats += 1
+            except:
+                pass
+    gmute(userid)
+    await xx.edit(f"`Gmuted` [{name}](tg://user?id={userid}) `in {chats} chats.`")
+
+
+@ultroid_cmd(
+    pattern="ungmute ?(.*)",
+)
+async def _(e):
+    xx = await eor(e, "`UnGmuting...`")
+    if e.is_private:
+        userid = (await e.get_chat()).id
+    elif e.reply_to_msg_id:
+        userid = (await e.get_reply_message()).sender_id
+    elif e.pattern_match.group(1):
+        if (e.pattern_match.group(1)).isdigit():
+            try:
+                userid = (await e.client.get_entity(int(e.pattern_match.group(1)))).id
+            except ValueError as err:
+                return await eod(xx, f"{str(err)}", time=5)
+        else:
+            try:
+                userid = (await e.client.get_entity(str(e.pattern_match.group(1)))).id
+            except ValueError as err:
+                return await eod(xx, f"{str(err)}", time=5)
+    else:
+        return await eod(xx, "`Reply to some msg or add their id.`", time=5)
+    name = (await e.client.get_entity(userid)).first_name
+    chats = 0
+    if not is_gmuted(userid):
+        return await eod(xx, "`User is not gmuted.`", time=3)
+    async for hurr in e.client.iter_dialogs():
+        if hurr.is_group:
+            try:
+                await e.client(
+                    EditBannedRequest(
+                        hurr.id,
+                        userid,
+                        ChatBannedRights(until_date=None, send_messages=False),
+                    )
+                )
+                chats += 1
+            except:
+                pass
+    ungmute(userid)
+    await xx.edit(f"`Ungmuted` [{name}](tg://user?id={userid}) `in {chats} chats.`")
+
+
+@ultroid_bot.on(events.ChatAction)
+async def _(e):
+    if e.user_joined or e.added_by:
+        user = await e.get_user()
+        chat = await e.get_chat()
+        if is_gbanned(str(user.id)):
+            if chat.admin_rights:
+                try:
+                    await e.client.edit_permissions(
+                        chat.id, user.id, view_messages=False
+                    )
+                    gban_watch = f"`Gbanned User` [{user.first_name}](tg://user?id={user.id}) `Spotted\n"
+                    gban_watch += f"Banned Successfully`"
+                except:
+                    pass
+            else:
+                gban_watch = (
+                    f"@admins `Gbanned user` [{user.first_name}]({user.id}) `Spotted.`"
+                )
+            await e.reply(gban_watch)
+
+
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/google.py

@@ -117,4 +117,4 @@ async def reverse(event):
     os.remove(dl)
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/imagetools.py

@@ -465,4 +465,4 @@ async def ultd(event):
     os.remove(ultt)
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/mute.py

@@ -214,4 +214,4 @@ async def _(e):
         await eod(xx, f"`{str(m)}`")
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/pdftools.py

@@ -292,4 +292,4 @@ async def sendpdf(event):
     os.makedirs("pdf/")
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/pmpermit.py

@@ -25,6 +25,7 @@ from pyUltroid.functions.pmpermit_db import *
 from telethon import events
 from telethon.tl.functions.contacts import BlockRequest, UnblockRequest
 from telethon.tl.functions.messages import ReportSpamRequest
+from telethon.utils import get_display_name
 
 from . import *
 
@@ -35,21 +36,20 @@ if Redis("PMPIC"):
     PMPIC = Redis("PMPIC")
 else:
     PMPIC = "https://telegra.ph/file/94f6a4aeb21ce2d58dd41.jpg"
+
 if not Redis("PM_TEXT"):
     UNAPPROVED_MSG = """
 **PMSecurity of {}!**
+
 Please wait for me to respnd or you will be blocked and reported as spam!!
 
 You have {}/{} warnings!"""
 else:
     UNAPPROVED_MSG = (
         """
-**PMSecurity of {}!**
-
-"""
+**PMSecurity of {}!**"""
         f"""{Redis("PM_TEXT")}"""
         """
-
 Please wait for me to respnd or you will be blocked and reported as spam!!
 
 You have {}/{} warnings!"""
@@ -57,6 +57,7 @@ You have {}/{} warnings!"""
 
 UND = "Please wait for me to respnd or you will be blocked and reported as spam!!"
 UNS = "You were spamming my Master's PM, which I didn't like."
+# 1
 
 WARNS = 3
 NO_REPLY = "Reply to someone's msg or try this commmand in private."
@@ -70,7 +71,18 @@ PMCMDS = [
 ]
 # =================================================================
 
-sett = udB.get("PMSETTING")
+
+@ultroid_bot.on(events.NewMessage(incoming=True, func=lambda e: e.is_private))
+async def permitpm(event):
+    user = await event.get_chat()
+    if user.bot or user.is_self:
+        return
+    apprv = is_approved(user.id)
+    if apprv and (Redis("PMLOG") == "True"):
+        await event.forward_to(Var.LOG_CHANNEL)
+
+
+sett = Redis("PMSETTING")
 if sett is None:
     sett = True
 if sett == "True" and sett != "False":
@@ -80,6 +92,8 @@ if sett == "True" and sett != "False":
         miss = await e.get_chat()
         if miss.bot or miss.is_self or miss.verified:
             return
+        if str(miss.id) in DEVLIST:
+            return
         mssg = e.text
         if mssg in PMCMDS:  # do not approve if outgoing is a command.
             return
@@ -94,7 +108,7 @@ if sett == "True" and sett != "False":
                 name0 = str(name.first_name)
                 await e.client.send_message(
                     Var.LOG_CHANNEL,
-                    f"#AutoApproved\nUser - [{name0}](tg://user?id={e.chat_id})",
+                    f"#AutoApproved\nßecoz of outgoing msg\nUser - [{name0}](tg://user?id={e.chat_id})",
                 )
 
     @ultroid_bot.on(events.NewMessage(incoming=True, func=lambda e: e.is_private))
@@ -102,8 +116,15 @@ if sett == "True" and sett != "False":
         user = await event.get_chat()
         if user.bot or user.is_self or user.verified:
             return
+        if str(user.id) in DEVLIST:
+            return
         apprv = is_approved(user.id)
         if not apprv and event.text != UND:
+            name = user.first_name
+            fullname = (user.first_name, user.last_name)
+            username = user.username
+            mention = f"[{get_display_name(user)}](tg://user?id={user.id})"
+            count = len(get_approved())
             try:
                 wrn = COUNT_PM[user.id]
             except KeyError:
@@ -115,6 +136,7 @@ if sett == "True" and sett != "False":
                         user.id, search=UND
                     ):
                         await message.delete()
+
                     async for message in event.client.iter_messages(
                         user.id, search=UNS
                     ):
@@ -176,6 +198,10 @@ if sett == "True" and sett != "False":
             reply = await apprvpm.get_reply_message()
             replied_user = await apprvpm.client.get_entity(reply.sender_id)
             aname = replied_user.id
+            if str(aname) in DEVLIST:
+                return await eor(
+                    apprvpm, "Lol, He is my Developer\nHe is auto Approved"
+                )
             name0 = str(replied_user.first_name)
             uid = replied_user.id
             if not is_approved(uid):
@@ -190,12 +216,17 @@ if sett == "True" and sett != "False":
         elif apprvpm.is_private:
             user = await apprvpm.get_chat()
             aname = await apprvpm.client.get_entity(user.id)
+            if str(user.id) in DEVLIST:
+                return await eor(
+                    apprvpm, "Lol, He is my Developer\nHe is auto Approved"
+                )
             name0 = str(aname.first_name)
             uid = user.id
             if not is_approved(uid):
                 approve_user(uid)
                 await apprvpm.edit(f"[{name0}](tg://user?id={uid}) `approved to PM!`")
                 async for message in apprvpm.client.iter_messages(user.id, search=UND):
+
                     await message.delete()
                 async for message in apprvpm.client.iter_messages(user.id, search=UNS):
                     await message.delete()
@@ -224,6 +255,10 @@ if sett == "True" and sett != "False":
             reply = await e.get_reply_message()
             replied_user = await e.client.get_entity(reply.sender_id)
             aname = replied_user.id
+            if str(aname) in DEVLIST:
+                return await eor(
+                    e, "`Lol, He is my Developer\nHe Can't Be DisApproved.`"
+                )
             name0 = str(replied_user.first_name)
             if is_approved(replied_user.id):
                 disapprove_user(replied_user.id)
@@ -241,6 +276,10 @@ if sett == "True" and sett != "False":
         elif e.is_private:
             bbb = await e.get_chat()
             aname = await e.client.get_entity(bbb.id)
+            if str(bbb.id) in DEVLIST:
+                return await eor(
+                    e, "`Lol, He is my Developer\nHe Can't Be DisApproved.`"
+                )
             name0 = str(aname.first_name)
             if is_approved(bbb.id):
                 disapprove_user(bbb.id)
@@ -265,12 +304,20 @@ if sett == "True" and sett != "False":
             reply = await block.get_reply_message()
             replied_user = await block.client.get_entity(reply.sender_id)
             aname = replied_user.id
+            if str(aname) in DEVLIST:
+                return await eor(
+                    block, "`Lol, He is my Developer\nHe Can't Be Blocked`"
+                )
             name0 = str(replied_user.first_name)
             await block.client(BlockRequest(replied_user.id))
             await block.edit("`You've been blocked!`")
             uid = replied_user.id
         elif block.is_private:
             bbb = await block.get_chat()
+            if str(bbb.id) in DEVLIST:
+                return await eor(
+                    block, "`Lol, He is my Developer\nHe Can't Be Blocked`"
+                )
             await block.client(BlockRequest(bbb.id))
             aname = await block.client.get_entity(bbb.id)
             await block.edit("`You've been blocked!`")
@@ -304,4 +351,4 @@ if sett == "True" and sett != "False":
             )
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/profile.py

@@ -28,7 +28,8 @@ import asyncio
 import os
 
 from telethon.tl import functions
-from telethon.tl.functions.photos import DeletePhotosRequest, GetUserPhotosRequest
+from telethon.tl.functions.photos import (DeletePhotosRequest,
+                                          GetUserPhotosRequest)
 from telethon.tl.types import InputPhoto
 
 from . import *
@@ -160,4 +161,4 @@ async def gpoto(e):
         await eor(e, f"ERROR - {str(e)}")
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/redis.py

@@ -8,6 +8,11 @@
 """
 ✘ Commands Available -
 
+**DataBase Commands, do not use if you don't know what it is.**
+
+• `{i}redisusage`
+    Check Storaged Data Capacity.
+
 • `{i}setredis key | value`
     Redis Set Value.
     e.g :
@@ -39,7 +44,7 @@ async def _(ult):
     ok = await eor(ult, "`...`")
     try:
         delim = " " if re.search("[|]", ult.pattern_match.group(1)) is None else " | "
-        data = ult.pattern_match.group(1).split(delim)
+        data = ult.pattern_match.group(1).split(delim, maxsplit=1)
         udB.set(data[0], data[1])
         redisdata = Redis(data[0])
         await ok.edit(
@@ -112,4 +117,18 @@ async def _(ult):
     await ok.edit("**List of Redis Keys :**\n{}".format(msg))
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+@ultroid_cmd(
+    pattern="redisusage$",
+)
+async def _(ult):
+    ok = await eor(ult, "`Calculating ...`")
+    x = 30 * 1024 * 1024
+    z = 0
+    for n in udB.keys():
+        z += udB.memory_usage(n)
+    a = humanbytes(z) + "/" + humanbytes(x)
+    b = str(round(z / x * 100, 3)) + "%" + "  Used"
+    await ok.edit(f"{a}\n{b}")
+
+
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/specialtools.py

@@ -243,4 +243,4 @@ async def wall(event):
     await nn.delete()
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/stickertools.py

@@ -14,8 +14,8 @@
 • `{i}tiny <reply to media>`
     To create Tiny stickers.
 
-• `{i}convert <gif/img/sticker>`
-    Reply to animated sticker.
+• `{i}convert <gif/img>`
+    Reply to sticker to convert into gif or image.
 
 • `{i}kang <reply to image/sticker>`
     Kang the sticker (add to your pack).
@@ -39,12 +39,10 @@ from os import remove
 import cv2
 import numpy as np
 from PIL import Image, ImageDraw
-from telethon.errors import ChatSendInlineForbiddenError, ChatSendStickersForbiddenError
-from telethon.tl.types import (
-    DocumentAttributeFilename,
-    DocumentAttributeSticker,
-    MessageMediaPhoto,
-)
+from telethon.errors import (ChatSendInlineForbiddenError,
+                             ChatSendStickersForbiddenError)
+from telethon.tl.types import (DocumentAttributeFilename,
+                               DocumentAttributeSticker, MessageMediaPhoto)
 
 from . import *
 
@@ -108,19 +106,19 @@ async def waifu(animu):
 async def uconverter(event):
     xx = await eor(event, "`Processing...`")
     a = await event.get_reply_message()
+    ok = ["image/webp", "application/x-tgsticker"]
+    if not (a.media and a.media.document and a.media.document.mime_type in ok):
+        return await eor(event, "`Reply to a Sticker...`")
     input = event.pattern_match.group(1)
     b = await event.client.download_media(a, "resources/downloads/")
     if "gif" in input:
         cmd = ["lottie_convert.py", b, "something.gif"]
         file = "something.gif"
-    elif "sticker" in input:
-        cmd = ["lottie_convert.py", b, "something.webp"]
-        file = "something.webp"
     elif "img" in input:
         cmd = ["lottie_convert.py", b, "something.png"]
         file = "something.png"
     else:
-        await xx.edit("**Please select from gif/sticker/img**")
+        return await xx.edit("**Please select from gif/img**")
     process = await asyncio.create_subprocess_exec(
         *cmd, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE
     )
@@ -398,9 +396,12 @@ async def ultdround(event):
 )
 async def ultdestroy(event):
     ult = await event.get_reply_message()
-    if not (ult and ("tgsticker" in ult.media.document.mime_type)):
-        await eor(event, "`Reply to Animated Sticker Only...`")
-        return
+    if not event.is_reply:
+        return await eor(event, "`Reply to Animated Sticker Only...`")
+    if not (
+        ult.media and ult.media.document and "tgsticker" in ult.media.document.mime_type
+    ):
+        return await eor(event, "`Reply to Animated Sticker only`")
     roid = await event.client.download_media(ult, "ultroid.tgs")
     xx = await eor(event, "`Processing...`")
     os.system("lottie_convert.py ultroid.tgs json.json")
@@ -431,9 +432,7 @@ async def ultdestroy(event):
         reply_to=event.reply_to_msg_id,
     )
     await xx.delete()
-    os.remove("ultroid.tgs")
     os.remove("json.json")
-    os.remove(roid)
 
 
 @ultroid_cmd(
@@ -511,4 +510,4 @@ async def ultiny(event):
     os.remove(ik)
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/sudo.py

@@ -29,8 +29,18 @@ from . import *
     pattern="addsudo ?(.*)",
 )
 async def _(ult):
+    if Var.BOT_MODE == True:
+        try:
+            if ult.sender_id != Var.OWNER_ID:
+                return await eor(
+                    ult, "You are sudo user, You cant add other sudo user."
+                )
+        except BaseException:
+            pass
+    else:
+        if ult.sender_id != ultroid_bot.uid:
+            return await eor(ult, "You are sudo user, You cant add other sudo user.")
     ok = await eor(ult, "`Updating SUDO Users List ...`")
-
     if ult.reply_to_msg_id:
         replied_to = await ult.get_reply_message()
         id = replied_to.sender.id
@@ -101,8 +111,18 @@ async def _(ult):
     pattern="delsudo ?(.*)",
 )
 async def _(ult):
+    if Var.BOT_MODE == True:
+        try:
+            if ult.sender_id != Var.OWNER_ID:
+                return await eor(
+                    ult, "You are sudo user, You cant add other sudo user."
+                )
+        except BaseException:
+            pass
+    else:
+        if ult.sender_id != ultroid_bot.uid:
+            return await eor(ult, "You are sudo user, You cant add other sudo user.")
     ok = await eor(ult, "`Updating SUDO Users List ...`")
-
     if ult.reply_to_msg_id:
         replied_to = await ult.get_reply_message()
         id = replied_to.sender.id
@@ -191,4 +211,4 @@ async def _(ult):
     return await ok.edit(f"**List of SUDO Users :**\n{msg}")
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/tag.py

@@ -0,0 +1,96 @@
+# Ultroid - UserBot
+# Copyright (C) 2020 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}tagall`
+    Tag Top 100 Members of chat.
+
+• `{i}tagadmins`
+    Tag Admins of that chat.
+
+• `{i}tagowner`
+    Tag Owner of that chat
+    
+• `{i}tagbots`
+    Tag Bots of that chat.
+
+• `{i}tagrec`
+    Tag recently Active Members.
+
+• `{i}tagon`
+    Tag online Members(work only if privacy off).
+
+• `{i}tagoff`
+    Tag Offline Members(work only if privacy off).
+"""
+
+from telethon.tl.types import ChannelParticipantAdmin as admin
+from telethon.tl.types import ChannelParticipantCreator as owner
+from telethon.tl.types import UserStatusOffline as off
+from telethon.tl.types import UserStatusOnline as onn
+from telethon.tl.types import UserStatusRecently as rec
+from telethon.utils import get_display_name
+
+from . import *
+
+
+@ultroid_cmd(
+    pattern="tag(on|off|all|bots|rec|admins|owner)?(.*)",
+    groups_only=True,
+)
+async def _(e):
+    okk = e.text
+    lll = e.pattern_match.group(2)
+    users = 0
+    o = 0
+    nn = 0
+    rece = 0
+    if lll:
+        xx = f"{lll}"
+    else:
+        xx = ""
+    async for bb in e.client.iter_participants(e.chat_id, 99):
+        users = users + 1
+        x = bb.status
+        y = bb.participant
+        if isinstance(x, onn):
+            o = o + 1
+            if "on" in okk:
+                xx += f"\n[{get_display_name(bb)}](tg://user?id={bb.id})"
+        if isinstance(x, off):
+            nn = nn + 1
+            if "off" in okk:
+                if not (bb.bot or bb.deleted):
+                    xx += f"\n[{get_display_name(bb)}](tg://user?id={bb.id})"
+        if isinstance(x, rec):
+            rece = rece + 1
+            if "rec" in okk:
+                if not (bb.bot or bb.deleted):
+                    xx += f"\n[{get_display_name(bb)}](tg://user?id={bb.id})"
+        if isinstance(y, owner):
+            if "admin" or "owner" in okk:
+                xx += f"\n꧁[{get_display_name(bb)}](tg://user?id={bb.id})꧂"
+        if isinstance(y, admin):
+            if "admin" in okk:
+                if not bb.deleted:
+                    xx += f"\n[{get_display_name(bb)}](tg://user?id={bb.id})"
+        if "all" in okk:
+            if not (bb.bot or bb.deleted):
+                xx += f"\n[{get_display_name(bb)}](tg://user?id={bb.id})"
+        if "bot" in okk:
+            if bb.bot:
+                xx += f"\n[{get_display_name(bb)}](tg://user?id={bb.id})"
+    if len(xx) > 4096:
+        await eor(e, "`Telegram Word Limits Exceeds...`")
+    else:
+        await e.client.send_message(e.chat_id, xx)
+        await e.delete()
+
+
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/tools.py

@@ -244,10 +244,10 @@ async def _(e):
     pattern="bash",
 )
 async def _(event):
-    if (Var.I_DEV if Var.I_DEV else Redis("I_DEV")) != "True":
+    if Redis("I_DEV") != "True":
         await eor(
             event,
-            "Developer Restricted!\nIf you know what this does, and want to proceed\n\n set var `I_DEV` as `True`\n\nThis Might Be Dangerous.",
+            f"Developer Restricted!\nIf you know what this does, and want to proceed\n\n `{HNDLR}setredis I_DEV True`\n\nThis Might Be Dangerous.",
         )
         return
     xx = await eor(event, "`Processing...`")
@@ -295,10 +295,10 @@ async def _(event):
     pattern="eval",
 )
 async def _(event):
-    if (Var.I_DEV if Var.I_DEV else Redis("I_DEV")) != "True":
+    if Redis("I_DEV") != "True":
         await eor(
             event,
-            "Developer Restricted!\nIf you know what this does, and want to proceed\n\n set var `I_DEV` as `True`\n\nThis Might Be Dangerous.",
+            f"Developer Restricted!\nIf you know what this does, and want to proceed\n\n `{HNDLR}setredis I_DEV True`\n\nThis Might Be Dangerous.",
         )
         return
     xx = await eor(event, "`Processing ...`")
@@ -412,4 +412,4 @@ async def lastname(steal):
         return await lol.edit("Error: @SangMataInfo_bot is not responding!.")
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/uploads_files.py

@@ -172,4 +172,4 @@ async def _(event):
         return await eod(xx, "`Reply to a readable file`", time=10)
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/utilities.py

@@ -46,6 +46,9 @@
 
 • `{i}json <reply to msg>`
     Get the json encoding of the message.
+
+• `{i}suggest <reply to message>`
+    Create a Yes/No poll for the replied suggestion.
 """
 import asyncio
 import calendar
@@ -62,12 +65,16 @@ import requests
 from telegraph import Telegraph
 from telegraph import upload_file as uf
 from telethon import functions
-from telethon.errors.rpcerrorlist import BotInlineDisabledError, BotResponseTimeoutError
+from telethon.errors.rpcerrorlist import BotInlineDisabledError
+from telethon.errors.rpcerrorlist import BotMethodInvalidError as bmi
+from telethon.errors.rpcerrorlist import (BotResponseTimeoutError,
+                                          ChatSendInlineForbiddenError)
 from telethon.events import NewMessage
 from telethon.tl.custom import Dialog
 from telethon.tl.functions.channels import LeaveChannelRequest
 from telethon.tl.functions.photos import GetUserPhotosRequest
-from telethon.tl.types import Channel, Chat, User
+from telethon.tl.types import (Channel, Chat, InputMediaPoll, Poll, PollAnswer,
+                               User)
 from telethon.utils import get_input_location
 
 # =================================================================#
@@ -305,12 +312,17 @@ async def _(event):
             .get("key")
         )
     q = f"paste-{key}"
+    reply_text = f"• **Pasted to Nekobin :** [Neko](https://nekobin.com/{key})\n• **Raw Url :** : [Raw](https://nekobin.com/raw/{key})"
     try:
         ok = await ultroid_bot.inline_query(Var.BOT_USERNAME, q)
         await ok[0].click(event.chat_id, reply_to=event.reply_to_msg_id, hide_via=True)
         await xx.delete()
-    except BotInlineDisabledError or BotResponseTimeoutError:  # incase the bot doesnt respond
+    except BotInlineDisabledError or BotResponseTimeoutError or ChatSendInlineForbiddenError:  # handling possible exceptions
         await xx.edit(reply_text)
+    except bmi:
+        await xx.edit(
+            f"**Inline Not Available as You Are in Bot Mode\nPasted to Nekobin :**\n{reply_text}"
+        )
 
 
 @ultroid_cmd(
@@ -454,7 +466,7 @@ async def _(ult):
 
 
 @ultroid_cmd(
-    pattern=r"rmbg ?(.*)",
+    pattern=r"rmbg$",
 )
 async def rmbg(event):
     RMBG_API = udB.get("RMBG_API")
@@ -463,50 +475,42 @@ async def rmbg(event):
         return await xx.edit(
             "Get your API key from [here](https://www.remove.bg/) for this plugin to work.",
         )
-    input_str = event.pattern_match.group(1)
-    message_id = event.message.id
     if event.reply_to_msg_id:
-        message_id = event.reply_to_msg_id
-        reply_message = await event.get_reply_message()
-        try:
-            dl_file = await ultroid_bot.download_media(
-                reply_message, TMP_DOWNLOAD_DIRECTORY
-            )
-        except Exception as e:
-            return await xx.edit("**ERROR:**\n`{}`".format(str(e)))
-        else:
-            await xx.edit("`Sending to remove.bg`")
-            output_file_name = ReTrieveFile(dl_file)
-            os.remove(dl_file)
-    elif input_str:
+        reply = await event.get_reply_message()
+        dl = await ultroid_bot.download_media(reply)
+        if not dl.endswith(("webp", "jpg", "png", "jpeg")):
+            os.remove(dl)
+            return await xx.edit("`Unsupported Media`")
         await xx.edit("`Sending to remove.bg`")
-        output_file_name = ReTrieveURL(input_str)
+        out = ReTrieveFile("ult.png")
+        os.remove("ult.png")
+        os.remove(dl)
     else:
-        await xx.edit(
-            f"Use `{Var.HNDLR}rmbg` as reply to a pic to remove its background."
-        )
+        await xx.edit(f"Use `{HNDLR}rmbg` as reply to a pic to remove its background.")
         await asyncio.sleep(5)
         await xx.delete()
         return
-    contentType = output_file_name.headers.get("content-type")
+    contentType = out.headers.get("content-type")
+    rmbgp = "ult.png"
     if "image" in contentType:
-        with io.BytesIO(output_file_name.content) as remove_bg_image:
-            remove_bg_image.name = "rmbg-ult.png"
-            await ultroid_bot.send_file(
-                event.chat_id,
-                remove_bg_image,
-                force_document=True,
-                supports_streaming=False,
-                allow_cache=False,
-                reply_to=message_id,
-            )
-        await xx.edit("`Done.`")
+        with open(rmbgp, "wb") as rmbg:
+            rmbg.write(out.content)
     else:
+        error = out.json()
         await xx.edit(
-            "RemoveBG returned an error - \n`{}`".format(
-                output_file_name.content.decode("UTF-8")
-            ),
+            f"**Error ~** `{error['errors'][0]['title']}`,\n`{error['errors'][0]['detail']}`"
         )
+    zz = Image.open(rmbgp)
+    if zz.mode != "RGB":
+        zz.convert("RGB")
+    zz.save("ult.webp", "webp")
+    await ultroid_bot.send_file(
+        event.chat_id, rmbgp, force_document=True, reply_to=reply
+    )
+    await ultroid_bot.send_file(event.chat_id, "ult.webp", reply_to=reply)
+    os.remove(rmbgp)
+    os.remove("ult.webp")
+    await xx.delete()
 
 
 @ultroid_cmd(
@@ -580,4 +584,31 @@ async def _(event):
         await eor(event, f"```{the_real_message}```")
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+@ultroid_cmd(pattern="suggest")
+async def sugg(event):
+    if await event.get_reply_message():
+        msgid = (await event.get_reply_message()).id
+        try:
+            await ultroid.send_message(
+                event.chat_id,
+                file=InputMediaPoll(
+                    poll=Poll(
+                        id=12345,
+                        question="Do you agree to the replied suggestion?",
+                        answers=[PollAnswer("Yes", b"1"), PollAnswer("No", b"2")],
+                    )
+                ),
+                reply_to=msgid,
+            )
+        except Exception as e:
+            return await eod(
+                event, f"`Oops, you can't send polls here!\n\n{str(e)}`", time=5
+            )
+        await event.delete()
+    else:
+        return await eod(
+            event, "`Please reply to a message to make a suggestion poll!`", time=5
+        )
+
+
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

plugins/words.py

@@ -142,4 +142,4 @@ async def _(event):
         await xx.edit(f"**No result found for** `{word}`")
 
 
-HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=Var.HNDLR)}"})
+HELP.update({f"{__name__.split('.')[1]}": f"{__doc__.format(i=HNDLR)}"})

requirements.txt

@@ -1,10 +1,10 @@
-py-Ultroid==2021.2.24
+py-Ultroid==2021.3.04
 asyncurban
 carbonnow
 cairosvg
 emoji
 GitPython
-googletrans==3.1.0a0
+googletrans==4.0.0rc1
 heroku3
 imutils
 lottie
@@ -20,6 +20,7 @@ psutil
 pytz
 requests>=2.18.4
 scikit-image
+selenium
 speedtest-cli==2.1.2
 telegraph
 validators

resources/startup/deploy.sh

@@ -61,7 +61,9 @@ apt update && apt upgrade -y && apt install --no-install-recommends -y \
     make \
     libopus0 \
     libopus-dev \
-    gcc
+    gcc \
+    mediainfo \
+    megatools
 
 echo '
         •• Cloning Repository
@@ -69,6 +71,7 @@ echo '
 
 git clone https://github.com/Teamultroid/Ultroid.git /root/TeamUltroid/
 
+
 echo '
 	•• Getting Libraries and Installing
 '