Removed dependecy of HTTPx

Powers/__init__.py

@@ -60,6 +60,8 @@ LOGGER.info("Source Code: https://github.com/iamgojoof6eyes/Gojo_Satarou\n")
 BOT_TOKEN = Config.BOT_TOKEN
 API_ID = Config.API_ID
 API_HASH = Config.API_HASH
+ARQ_API_URL = Config.ARQ_API_URL
+ARQ_API_KEY = Config.ARQ_API_KEY
 
 # General Config
 MESSAGE_DUMP = Config.MESSAGE_DUMP

Powers/bot_class.py

@@ -1,6 +1,9 @@
 from platform import python_version
 from threading import RLock
 from time import gmtime, strftime, time
+from aiohttp import ClientSession
+from Python_ARQ import ARQ
+import asyncio
 
 from pyrogram import Client, __version__
 from pyrogram.raw.all import layer
@@ -16,6 +19,8 @@ from Powers import (
     NO_LOAD,
     UPTIME,
     WORKERS,
+    ARQ_API_URL,
+    ARQ_API_KEY,
     load_cmds,
 )
 from Powers.database import MongoDB
@@ -29,7 +34,9 @@ if MESSAGE_DUMP == -100 or not str(MESSAGE_DUMP).startswith("-100"):
     raise Exception(
         "Please enter a vaild Supergroup ID, A Supergroup ID starts with -100",
     )
-
+    
+aiohttpsession = ClientSession()
+arq = ARQ(ARQ_API_URL, ARQ_API_KEY, aiohttpsession)
 
 class Gojo(Client):
     """Starts the Pyrogram Client on the Bot Token when we do 'python3 -m Powers'"""

Powers/plugins/admin.py

@@ -555,21 +555,21 @@ __alt_name__ = [
 __HELP__ = """Lazy to promote or demote someone for admins? Want to see basic information about chat?
 All stuff about chatroom such as admin lists, pinning or grabbing an invite link can be done easily using the bot.
 **User Commands:**
-× /adminlist: List all the admins in the Group.
+* /adminlist: List all the admins in the Group.
 **Admin only:**
-× /invitelink: Gets chat invitelink.
-× /promote: Promotes the user replied to or tagged (supports with title).
-× /fullpromote: Fully Promotes the user replied to or tagged (supports with title).
-× /demote: Demotes the user replied to or tagged.
-× /admincache: Reloads the List of all the admins in the Group.
-× /zombies: Bans all the deleted accounts. (owner only)
-× /title: sets a custom title for an admin that the bot promoted.
-× /disable <commandname>: Stop users from using "commandname" in this group.
-× /enable <item name>: Allow users from using "commandname" in this group.
-× /disableable: List all disableable commands.
-× /disabledel <yes/off>: Delete disabled commands when used by non-admins.
-× /disabled: List the disabled commands in this chat.
-× /enableall: enable all disabled commands.
+* /invitelink: Gets chat invitelink.
+* /promote: Promotes the user replied to or tagged (supports with title).
+* /fullpromote: Fully Promotes the user replied to or tagged (supports with title).
+* /demote: Demotes the user replied to or tagged.
+* /admincache: Reloads the List of all the admins in the Group.
+* /zombies: Bans all the deleted accounts. (owner only)
+* /title: sets a custom title for an admin that the bot promoted.
+* /disable <commandname>: Stop users from using "commandname" in this group.
+* /enable <item name>: Allow users from using "commandname" in this group.
+* /disableable: List all disableable commands.
+* /disabledel <yes/off>: Delete disabled commands when used by non-admins.
+* /disabled: List the disabled commands in this chat.
+* /enableall: enable all disabled commands.
 
 **Example:**
 `/promote @username`: this promotes a user to admin."""

Powers/plugins/approve.py

@@ -238,10 +238,10 @@ __HELP__ = """Sometimes, you might trust a user not to send unwanted content.
 Maybe not enough to make them admin, but you might be ok with locks, blacklists, and antiflood not applying to them.
 That's what approvals are for - approve trustworthy users to allow them to send stuff without restrictions!
 **Admin commands:**
-× /approval: Check a user's approval status in this chat.
-× /approve: Approve of a user. Locks, blacklists, and antiflood won't apply to them anymore.
-× /unapprove: Unapprove of a user. They will now be subject to blocklists.
-× /approved: List all approved users.
-× /unapproveall: Unapprove *ALL* users in a chat. This cannot be undone!
+* /approval: Check a user's approval status in this chat.
+* /approve: Approve of a user. Locks, blacklists, and antiflood won't apply to them anymore.
+* /unapprove: Unapprove of a user. They will now be subject to blocklists.
+* /approved: List all approved users.
+* /unapproveall: Unapprove *ALL* users in a chat. This cannot be undone!
 **Example:**
 `/approve @username`: this approves a user in the chat."""

Powers/plugins/bans.py

@@ -884,15 +884,15 @@ __HELP__ = """Someone annoying entered your group?
 Want to ban/restriction him/her?
 This is the plugin for you, easily kick, ban and unban members in a group.
 **Admin only:**
-× /kick: Kick the user replied or tagged.
-× /skick: Kick the user replied or tagged and delete your messsage.
-× /dkick: Kick the user replied and delete their message.
-× /ban: Bans the user replied to or tagged.
-× /sban: Bans the user replied or tagged and delete your messsage.
-× /dban: Bans the user replied and delete their message.
-× /tban <userhandle> x(m/h/d): Bans a user for x time. (via handle, or reply). m = minutes, h = hours, d = days.
-× /stban <userhandle> x(m/h/d): Silently bans a user for x time. (via handle, or reply). m = minutes, h = hours, d = days.
-× /dtban <userhandle> x(m/h/d): Silently bans a user for x time and delete the replied message. (via reply). m = minutes, h = hours, d = days.
-× /unban: Unbans the user replied to or tagged.
+* /kick: Kick the user replied or tagged.
+* /skick: Kick the user replied or tagged and delete your messsage.
+* /dkick: Kick the user replied and delete their message.
+* /ban: Bans the user replied to or tagged.
+* /sban: Bans the user replied or tagged and delete your messsage.
+* /dban: Bans the user replied and delete their message.
+* /tban <userhandle> x(m/h/d): Bans a user for x time. (via handle, or reply). m = minutes, h = hours, d = days.
+* /stban <userhandle> x(m/h/d): Silently bans a user for x time. (via handle, or reply). m = minutes, h = hours, d = days.
+* /dtban <userhandle> x(m/h/d): Silently bans a user for x time and delete the replied message. (via reply). m = minutes, h = hours, d = days.
+* /unban: Unbans the user replied to or tagged.
 **Example:**
 `/ban @username`: this bans a user in the chat."""

Powers/plugins/blacklist.py

@@ -213,14 +213,14 @@ __HELP__ = """Want to restrict certain words or sentences in your group?
 Blacklists are used to stop certain triggers from being said in a group. Any time the trigger is mentioned, that message will immediately be deleted.
 A good combo is sometimes to pair this up with warn filters!
 **NOTE:** blacklists do not affect group admins.
-× /blacklist: View the current blacklisted words.
+* /blacklist: View the current blacklisted words.
 **Admin only:**
-× /addblacklist `<triggers>`: Add a trigger to the blacklist. Each line is considered one trigger, so using different lines will allow you to add multiple triggers.
-× /unblacklist `<triggers>`: Remove triggers from the blacklist. Same newline logic applies here, so you can remove multiple triggers at once.
-× /blaction `<action>`: This action will occur when user uses a blacklist word. Choose from - 'kick', 'ban', 'mute', 'warn'.
+* /addblacklist `<triggers>`: Add a trigger to the blacklist. Each line is considered one trigger, so using different lines will allow you to add multiple triggers.
+* /unblacklist `<triggers>`: Remove triggers from the blacklist. Same newline logic applies here, so you can remove multiple triggers at once.
+* /blaction `<action>`: This action will occur when user uses a blacklist word. Choose from - 'kick', 'ban', 'mute', 'warn'.
 Default is 'none', which will delete the users message on typing a blacklist word.
 **Owner Only**
-× /rmallblacklist: Removes all the blacklists from the current chat.
+* /rmallblacklist: Removes all the blacklists from the current chat.
 **Note:** Can only add or remove one blacklist at a time!
 **Example:**
 `/addblacklist hello`: this adds the word 'hello' as blacklist in the chat."""

Powers/plugins/dev.py

@@ -21,7 +21,7 @@ from Powers.bot_class import Gojo
 from Powers.database.chats_db import Chats
 from Powers.utils.clean_file import remove_markdown_and_html
 from Powers.utils.custom_filters import command
-from Powers.utils.http_helper import HTTPx
+from Powers.utils.http_helper import *
 from Powers.utils.kbhelpers import ikb
 from Powers.utils.parser import mention_markdown
 from Powers.vars import Config
@@ -55,28 +55,6 @@ async def send_log(c: Gojo, m: Message):
     return
 
 
-@Gojo.on_message(command("ginfo", sudo_cmd=True))
-async def group_info(c: Gojo, m: Message):
-    if len(m.text.split()) != 2:
-        await m.reply_text(
-            f"It works like this: <code>{Config.PREFIX_HANDLER} chat_id</code>",
-        )
-        return
-
-    chat_id = m.text.split(None, 1)[1]
-
-    replymsg = await m.reply_text("Fetching info about group...!")
-    grp_data = await c.get_chat(chat_id)
-    msg = (
-        f"Information for group: {chat_id}\n\n"
-        f"Group Name: {grp_data['title']}\n"
-        f"Members Count: {grp_data['members_count']}\n"
-        f"Type: {grp_data['type']}\n"
-        f"Group ID: {grp_data['id']}"
-    )
-    await replymsg.edit_text(msg)
-    return
-
 @Gojo.on_message(command("neofetch", dev_cmd=True))
 async def neofetch_stats(_, m: Message):
     cmd = "neofetch --stdout"
@@ -211,21 +189,6 @@ async def execution(_, m: Message):
     return
 
 
-@Gojo.on_message(command("ip", dev_cmd=True))
-async def public_ip(c: Gojo, m: Message):
-    ip = await HTTPx.get("https://api.ipify.org")
-    await c.send_message(
-        MESSAGE_DUMP,
-        f"#IP\n\n**User:** {(await mention_markdown(m.from_user.first_name, m.from_user.id))}",
-    )
-    await m.reply_text(
-        text=f"""<b>Bot IP Address:</b>
-      <code>{ip.text}</code>""",
-        quote=True,
-    )
-    return
-
-
 @Gojo.on_message(command("chatlist", dev_cmd=True))
 async def chats(c: Gojo, m: Message):
     exmsg = await m.reply_text(text="Exporting Charlist...")

Powers/plugins/fun.py

@@ -209,15 +209,15 @@ _DISABLE_CMDS_ = [
     "shrug",
 ]
 
-__HELP__ = """× /runs: reply a random string from an array of replies.
-× /slap: slap a user, or get slapped if not a reply.
-× /insult: to insult a user, or get insulted if not a reply
-× /shrug : get shrug XD.
-× /decide : Randomly answers yes/no/maybe
-× /toss : Tosses A coin
-× /yes : check urself :V
-× /no : check urself :V
-× /bluetext : check urself :V
-× /roll : Roll a dice.
-× /react : Random Reaction
-× /shout `<keyword>`: write anything you want to give loud shout."""
+__HELP__ = """* /runs: reply a random string from an array of replies.
+* /slap: slap a user, or get slapped if not a reply.
+* /insult: to insult a user, or get insulted if not a reply
+* /shrug : get shrug XD.
+* /decide : Randomly answers yes/no/maybe
+* /toss : Tosses A coin
+* /yes : check urself :V
+* /no : check urself :V
+* /bluetext : check urself :V
+* /roll : Roll a dice.
+* /react : Random Reaction
+* /shout `<keyword>`: write anything you want to give loud shout."""

Powers/plugins/greetings.py

@@ -485,17 +485,17 @@ a) Currently it supports only text!
 b) Gojo must be an admin to greet and goodbye users.
 
 Admin Commands:
-× /setwelcome <reply> : Sets a custom welcome message.
-× /setgoodbye <reply> : Sets a custom goodbye message.
-× /resetwelcome : Resets to bot default welcome message.
-× /resetgoodbye : Resets to bot default goodbye message.
-× /welcome <on/off> | noformat : enable/disable | Shows the current welcome message | settings.
-× /goodbye <on/off> | noformat : enable/disable | Shows the current goodbye message | settings.
-× /cleanwelcome <on/off> : Shows or sets the current clean welcome settings.
-× /cleangoodbye <on/off> : Shows or sets the current clean goodbye settings.
+* /setwelcome <reply> : Sets a custom welcome message.
+* /setgoodbye <reply> : Sets a custom goodbye message.
+* /resetwelcome : Resets to bot default welcome message.
+* /resetgoodbye : Resets to bot default goodbye message.
+* /welcome <on/off> | noformat : enable/disable | Shows the current welcome message | settings.
+* /goodbye <on/off> | noformat : enable/disable | Shows the current goodbye message | settings.
+* /cleanwelcome <on/off> : Shows or sets the current clean welcome settings.
+* /cleangoodbye <on/off> : Shows or sets the current clean goodbye settings.
 
 ── **Cleaner** ──:
-× /cleanservice <on/off> : Use it to clean all service messages automatically or to view current status.
+* /cleanservice <on/off> : Use it to clean all service messages automatically or to view current status.
 
 ── **Format** ──
 Check /markdownhelp for help related to formatting!"""

Powers/plugins/locks.py

@@ -331,10 +331,10 @@ __HELP__ = """ Use this to lock group permissions.
 Allows you to lock and unlock permission types in the chat.
 
 **Usage:**
-× /lock `<type>`: Lock Chat permission.
-× /unlock `<type>`: Unlock Chat permission.
-× /locks: View Chat permission.
-× /locktypes: Check available lock types!
+* /lock `<type>`: Lock Chat permission.
+* /unlock `<type>`: Unlock Chat permission.
+* /locks: View Chat permission.
+* /locktypes: Check available lock types!
 
 **Example:**
 `/lock media`: this locks all the media messages in the chat."""

Powers/plugins/muting.py

@@ -603,13 +603,13 @@ __HELP__ = """Want someone to keep quite for a while in the group?
 Mute plugin is here to help, mute or unmute any user easily!
 
 **Admin only:**
-× /mute: Mute the user replied to or mentioned.
-× /smute: silences a user without notifying. Can also be used as a reply, muting the replied to user.
-× /dmute: Mute a user by reply, and delete their message.
-× /tmute <userhandle> x(m/h/d): mutes a user for x time. (via handle, or reply). m = minutes, h = hours, d = days.
-× /stmute <userhandle> x(m/h/d): mutes a user for x time without notifying. (via handle, or reply). m = minutes, h = hours, d = days.
-× /dtmute <userhandle> x(m/h/d): Mute the replied user, and delete the replied message. (via reply). m = minutes, h = hours, d = days.
-× /unmute: Unmutes the user mentioned or replied to.
+* /mute: Mute the user replied to or mentioned.
+* /smute: silences a user without notifying. Can also be used as a reply, muting the replied to user.
+* /dmute: Mute a user by reply, and delete their message.
+* /tmute <userhandle> x(m/h/d): mutes a user for x time. (via handle, or reply). m = minutes, h = hours, d = days.
+* /stmute <userhandle> x(m/h/d): mutes a user for x time without notifying. (via handle, or reply). m = minutes, h = hours, d = days.
+* /dtmute <userhandle> x(m/h/d): Mute the replied user, and delete the replied message. (via reply). m = minutes, h = hours, d = days.
+* /unmute: Unmutes the user mentioned or replied to.
 
 **Example:**
 `/mute @username`; this mutes a user."""

Powers/plugins/notes.py

@@ -429,26 +429,26 @@ __HELP__ = """Save a note, get that, even you can delete that note.
 This note only avaiable for your whole group!
 Only admins can save and deletenotes, anyone can get them.
 
-× /save `<notename>` <`note content or reply to message>`
+* /save `<notename>` <`note content or reply to message>`
     Save a note, you can get or delete that later.
 
-× /get `<note>` or #<note>
+* /get `<note>` or #<note>
     Get that note, if avaiable.
 
-× /get `<note>` noformat or /get `<note>` raw
+* /get `<note>` noformat or /get `<note>` raw
     Get that note in raw format, so you can edit and update it.
 
-× /clear `<note>`
+* /clear `<note>`
     Delete that note, if avaiable.
 
-× /clearall
+* /clearall
     Clears all notes in the chat!
     **NOTE:** Can only be used by owner of chat!
 
-× /saved or /notes
+* /saved or /notes
     Get all your notes, if too much notes, please use this in your saved message instead!
 
-× /privatenotes `<on/yes/no/off>`: Whether to turn private rules on or off, prevents spam in chat when people use notes command.
+* /privatenotes `<on/yes/no/off>`: Whether to turn private rules on or off, prevents spam in chat when people use notes command.
 
 ── **Note Format** ──
     Check /markdownhelp for help related to formatting!"""

Powers/plugins/pin.py

@@ -239,10 +239,10 @@ __alt_name__ = ["pin", "unpin"]
 __HELP__ = """Here you find find all help related to groups pins and how to manage them via me.
 
 **Admin Cmds:**
-× /pin: Silently pins the message replied to - add `loud`, `notify` or `alert` to give notificaton to users.
-× /unpin: Unpins the last pinned message.
-× /pinned: Gives the current pinned message of the chat.
-× /unpinall: Unpins all the pinned message in the current chat.
-× /antichannelpin `<on/off/yes/no>`: Toggle antichannelpin status. All the messages from linked channel will be unpinned if enabled!
-× /cleanlinked `<on/off/yes/no>`: Toggle cleanlinked status. All the messages from linked channel will be deleted if enabled!
-× /permapin `<text>`: Pin a custom messages via bot. This message can contain markdown, and can be used in replies to the media include additional buttons and text."""
+* /pin: Silently pins the message replied to - add `loud`, `notify` or `alert` to give notificaton to users.
+* /unpin: Unpins the last pinned message.
+* /pinned: Gives the current pinned message of the chat.
+* /unpinall: Unpins all the pinned message in the current chat.
+* /antichannelpin `<on/off/yes/no>`: Toggle antichannelpin status. All the messages from linked channel will be unpinned if enabled!
+* /cleanlinked `<on/off/yes/no>`: Toggle cleanlinked status. All the messages from linked channel will be deleted if enabled!
+* /permapin `<text>`: Pin a custom messages via bot. This message can contain markdown, and can be used in replies to the media include additional buttons and text."""

Powers/plugins/purge.py

@@ -117,6 +117,6 @@ __PLUGIN__ = "purges"
 __alt_name__ = ["purge", "del", "spurge"]
 
 __HELP__ = """Want to delete messages in you group?
-× /purge: Deletes messages upto replied message.
-× /spurge: Deletes messages upto replied message without a success message.
-× /del: Deletes a single message, used as a reply to message."""
+* /purge: Deletes messages upto replied message.
+* /spurge: Deletes messages upto replied message without a success message.
+* /del: Deletes a single message, used as a reply to message."""

Powers/plugins/report.py

@@ -201,11 +201,11 @@ __PLUGIN__ = "reporting"
 
 __alt_name__ = ["reports", "report"]
 
-__HELP__ = """× /report `<reason>`: reply to a message to report it to admins.
+__HELP__ = """* /report `<reason>`: reply to a message to report it to admins.
 - @admin: reply to a message to report it to admins.
 **NOTE:** Neither of these will get triggered if used by admins.
 
 **Admins Only:**
-× /reports `<on/off/yes/no>`: change report setting, or view current status.
+* /reports `<on/off/yes/no>`: change report setting, or view current status.
     - If done in PM, toggles your status.
     - If in group, toggles that groups's status."""

Powers/plugins/rules.py

@@ -149,9 +149,9 @@ __alt_name__ = ["rule"]
 
 __HELP__ = """Set rules for you chat so that members know what to do and what not to do in your group!
 
-× /rules: get the rules for current chat.
+* /rules: get the rules for current chat.
 
 **Admin only:**
-× /setrules `<rules>`: Set the rules for this chat, also works as a reply to a message.
-× /clearrules: Clear the rules for this chat.
-× /privrules `<on/yes/no/off>`: Turns on/off the option to send the rules to PM of user or group."""
+* /setrules `<rules>`: Set the rules for this chat, also works as a reply to a message.
+* /clearrules: Clear the rules for this chat.
+* /privrules `<on/yes/no/off>`: Turns on/off the option to send the rules to PM of user or group."""

Powers/plugins/utils.py

@@ -1,31 +1,29 @@
-from html import escape
 from io import BytesIO
 from os import remove
+import re
+import aiofiles
+from search_engine_parser import GoogleSearch
+from datetime import datetime
+from aiohttp import ClientSession
+from tswift import Song
+from wikipedia import summary
+from wikipedia.exceptions import DisambiguationError, PageError
+
 
 from gpytranslate import Translator
 from pyrogram import filters
 from pyrogram.errors import MessageTooLong, PeerIdInvalid, RPCError
-from pyrogram.types import Message
-from tswift import Song
-from wikipedia import summary
-from wikipedia.exceptions import DisambiguationError, PageError
+from pyrogram.types import Message,InlineKeyboardButton, InlineKeyboardMarkup
 
-from Powers import (
-    DEV_USERS,
-    LOGGER,
-    OWNER_ID,
-    SUDO_USERS,
-    SUPPORT_GROUP,
-    SUPPORT_STAFF,
-    WHITELIST_USERS,
-)
+
+from Powers import *
 from Powers.bot_class import Gojo
 from Powers.database.antispam_db import GBan
 from Powers.database.users_db import Users
 from Powers.utils.clean_file import remove_markdown_and_html
 from Powers.utils.custom_filters import command
 from Powers.utils.extract_user import extract_user
-from Powers.utils.http_helper import HTTPx, http
+from Powers.utils.http_helper import *
 from Powers.utils.kbhelpers import ikb
 from Powers.utils.parser import mention_html
 from Powers.vars import Config
@@ -198,176 +196,131 @@ async def get_gifid(_, m: Message):
 @Gojo.on_message(
     command("github") & (filters.group | filters.private),
 )
-async def github(_, m: Message):
-    if len(m.text.split()) == 2:
-        username = m.text.split(None, 1)[1]
-        LOGGER.info(f"{m.from_user.id} used github cmd in {m.chat.id}")
-    else:
-        await m.reply_text(
-            f"Usage: <code>{Config.PREFIX_HANDLER}github username</code>",
-        )
-        return
+async def github(_, message):
+    try:
+        if len(message.command) < 2:
+            await message.reply_text('"/github" Needs An Argument')
+            return
+        gett = message.text.split(None, 1)[1]
+        text = gett + ' "site:github.com"'
+        gresults = await GoogleSearch().async_search(text, 1)
+        result = ""
+        for i in range(4):
+            try:
+                title = gresults["titles"][i].replace("\n", " ")
+                source = gresults["links"][i]
+                description = gresults["descriptions"][i]
+                result += f"[{title}]({source})\n"
+                result += f"`{description}`\n\n"
+            except IndexError:
+                pass
+        await message.reply_text(result, disable_web_page_preview=True)
+    except Exception as e:
+        await message.reply_text(str(e))
+
+#paste here
+session = ClientSession()
+pattern = re.compile(r"^text/|json$|yaml$|xml$|toml$|x-sh$|x-shellscript$")
+BASE = "https://batbin.me/"
 
-    URL = f"https://api.github.com/users/{username}"
-    r = await HTTPx.get(URL)
-    if r.status_code == 404:
-        await m.reply_text(f"<code>{username}</code> not found", quote=True)
+async def post(url: str, *args, **kwargs):
+    async with session.post(url, *args, **kwargs) as resp:
+        try:
+            data = await resp.json()
+        except Exception:
+            data = await resp.text()
+    return data
+
+async def paste(content: str):
+    resp = await post(f"{BASE}api/v2/paste", data=content)
+    if not resp["success"]:
         return
+    return BASE + resp["message"]
 
-    r_json = r.json()
-    url = r_json.get("html_url", None)
-    name = r_json.get("name", None)
-    company = r_json.get("company", None)
-    followers = r_json.get("followers", 0)
-    following = r_json.get("following", 0)
-    public_repos = r_json.get("public_repos", 0)
-    bio = r_json.get("bio", None)
-    created_at = r_json.get("created_at", "Not Found")
-
-    REPLY = (
-        f"<b>GitHub Info for @{username}:</b>"
-        f"\n<b>Name:</b> <code>{name}</code>\n"
-        f"<b>Bio:</b> <code>{bio}</code>\n"
-        f"<b>URL:</b> {url}\n"
-        f"<b>Public Repos:</b> {public_repos}\n"
-        f"<b>Followers:</b> {followers}\n"
-        f"<b>Following:</b> {following}\n"
-        f"<b>Company:</b> <code>{company}</code>\n"
-        f"<b>Created at:</b> <code>{created_at}</code>"
-    )
 
-    await m.reply_text(REPLY, quote=True, disable_web_page_preview=True)
-    return
+@Gojo.on_message(command("paste"))
+async def paste_func(_, message: Message):
+    if not message.reply_to_message:
+        return await message.reply_text("Reply To A Message With `/paste`")
+   
+    r = message.reply_to_message
 
+    if not r.text and not r.document:
+        return await message.reply_text("Only text and documents are supported")
 
-@Gojo.on_message(
-    command("info") & (filters.group | filters.private),
-)
-async def my_info(c: Gojo, m: Message):
-    try:
-        user_id, name, user_name = await extract_user(c, m)
-    except PeerIdInvalid:
-        await m.reply_text(text="I haven't seen this user, mind forwarding one of their messages so I can recognize them?")
-        return
-    except ValueError as ef:
-        if "Peer id invalid" in str(ef):
-            await m.reply_text(text="User not found, please check the ID again")
-        return
-    try:
-        user = Users.get_user_info(int(user_id))
-        name = user["name"]
-        user_name = user["username"]
-        user_id = user["_id"]
-    except KeyError:
-        LOGGER.warning(f"Calling api to fetch info about user {user_id}")
-        user = await c.get_users(user_id)
-        name = (
-            escape(user["first_name"] + " " + user["last_name"])
-            if user["last_name"]
-            else user["first_name"]
-        )
-        user_name = user["username"]
-        user_id = user["id"]
-    except PeerIdInvalid:
-        await m.reply_text(text="""Failed to get user
-      Peer ID invalid, I haven't seen this user anywhere earlier, maybe username would help to know them!""")
-        return
-    except (RPCError, Exception) as ef:
-        await m.reply_text(
-           text=f"""Some error occured, report to @{SUPPORT_GROUP}
-            <b>Error:</b> <code>{ef}</code>"""
-        )
-        return
+    m = await message.reply_text("Pasting...")
 
-    gbanned, reason_gban = gban_db.get_gban(user_id)
-    LOGGER.info(f"{m.from_user.id} used info cmd for {user_id} in {m.chat.id}")
-    user_id=user_id,
-    user_name=name,
-    text = f"""<b>Characteristics:</b>
-          <b>ID:</b> <code>{user_id}</code>
-          <b>First Name:</b> {user_name}"""
-
-    if user_name:
-        text += f"<b>Username:</b> @{user_name}"
-    perma_link=(await mention_html("Click Here", user_id))
-    text += f"<b>Permanent User Link:</b> {perma_link}"
-
-    if gbanned:
-        text += f"\nThis user is Globally banned beacuse: {reason_gban}\n"
-
-    if user_id == OWNER_ID:
-        text += "This person is my Owner, I would never do anything against them!"
-    elif user_id in DEV_USERS:
-        text += "This member is one of my Developers ⚡️"
-    elif user_id in SUDO_USERS:
-        text += "This user is one of my Sudos, he has powers which are approximately same to owner!"
-    elif user_id in WHITELIST_USERS:
-        text += "This person is 'Whitelist User', they cannot be banned!"
-
-    await m.reply_text(text, parse_mode="html", disable_web_page_preview=True)
-    return
+    if r.text:
+        content = str(r.text)
+    elif r.document:
+        if r.document.file_size > 40000:
+            return await m.edit("You can only paste files smaller than 40KB.")
 
+        if not pattern.search(r.document.mime_type):
+            return await m.edit("Only text files can be pasted.")
 
-@Gojo.on_message(command("paste"))
-async def paste_it(_, m: Message):
-    replymsg = await m.reply_text(text="Pasting...", quote=True)
+        doc = await message.reply_to_message.download()
+
+        async with aiofiles.open(doc, mode="r") as f:
+            content = await f.read()
+
+        remove(doc)
+
+    link = await paste(content)
+    kb = [[InlineKeyboardButton(text="Paste Link ", url=link)]]
     try:
-        if m.reply_to_message:
-            if m.reply_to_message.document:
-                dl_loc = await m.reply_to_message.download()
-                with open(dl_loc) as f:
-                    txt = f.read()
-                remove(dl_loc)
-            else:
-                txt = m.reply_to_message.text
+        if m.from_user.is_bot:
+            await message.reply_photo(
+                photo=link,
+                quote=False,
+                caption="Pasted",
+                reply_markup=InlineKeyboardMarkup(kb),
+            )
         else:
-            txt = m.text.split(None, 1)[1]
-        ur = "https://hastebin.com/documents"
-        r = await http.post(ur, json={"content": txt})
-        url = f"https://hastebin.com/{r.json().get('key')}"
-        await replymsg.edit_text(
-            text="Pasted to NekoBin!",
-            reply_markup=ikb([[("NekoBin"), url, "url"]]),
-        )
-        LOGGER.info(f"{m.from_user.id} used paste cmd in {m.chat.id}")
-    except Exception as e:
-        await replymsg.edit_text(f"Error: {e}")
-        return
-    return
+            await message.reply_photo(
+                photo=link,
+                quote=False,
+                caption="Pasted",
+                reply_markup=InlineKeyboardMarkup(kb),
+            )
+        await m.delete()
+    except Exception:
+        await m.edit("Here is the link of the document....", reply_markup=InlineKeyboardMarkup(kb))
 
 
 @Gojo.on_message(command("tr"))
-async def translate(_, m: Message):
+async def tr(_, message):
     trl = Translator()
-    if m.reply_to_message and (m.reply_to_message.text or m.reply_to_message.caption):
-        if len(m.text.split()) == 1:
+    if message.reply_to_message and (message.reply_to_message.text or message.reply_to_message.caption):
+        if len(message.text.split()) == 1:
             target_lang = "en"
         else:
-            target_lang = m.text.split()[1]
-        if m.reply_to_message.text:
-            text = m.reply_to_message.text
+            target_lang = message.text.split()[1]
+        if message.reply_to_message.text:
+            text = message.reply_to_message.text
         else:
-            text = m.reply_to_message.caption
+            text = message.reply_to_message.caption
     else:
-        if len(m.text.split()) <= 2:
-            await m.reply_text(
-                "Provide lang code.\n[Available options](https://telegra.ph/Lang-Codes-11-08).\n<b>Usage:</b> <code>/tr en</code>",
+        if len(message.text.split()) <= 2:
+            await message.reply_text(
+                "Provide lang code.\n[Available options](https://telegra.ph/Lang-Codes-02-22).\n<b>Usage:</b> <code>/tr en</code>",
             )
             return
-        target_lang = m.text.split(None, 2)[1]
-        text = m.text.split(None, 2)[2]
+        target_lang = message.text.split(None, 2)[1]
+        text = message.text.split(None, 2)[2]
     detectlang = await trl.detect(text)
     try:
         tekstr = await trl(text, targetlang=target_lang)
     except ValueError as err:
-        await m.reply_text(f"Error: <code>{str(err)}</code>")
+        await message.reply_text(f"Error: <code>{str(err)}</code>")
         return
-    LOGGER.info(f"{m.from_user.id} used translate cmd in {m.chat.id}")
-    return await m.reply_text(
+    return await message.reply_text(
         f"<b>Translated:</b> from {detectlang} to {target_lang} \n<code>``{tekstr.text}``</code>",
     )
 
 
+
+
 __PLUGIN__ = "utils"
 _DISABLE_CMDS_ = [
     "paste",
@@ -384,14 +337,14 @@ __alt_name__ = ["util", "misc", "tools"]
 
 __HELP__ = """Some utils provided by bot to make your tasks easy!
 
-× /id: Get the current group id. If used by replying to a message, get that user's id.
-× /info: Get information about a user.
-× /gifid: Reply to a gif to me to tell you its file ID.
-× /wiki: `<query>`: wiki your query.
-× /tr `<language>`: Translates the text and then replies to you with the language you have specifed, works as a reply to message.
-× /github `<username>`: Search for the user using github api!
-× /lyrics `<song>`: Get the lyrics of the song you specify!
-× /weebify `<text>` or `<reply to message>`: To weebify the text.
+* /id: Get the current group id. If used by replying to a message, get that user's id.
+* /info: Get information about a user.
+* /gifid: Reply to a gif to me to tell you its file ID.
+* /wiki: `<query>`: wiki your query.
+* /tr `<language>`: Translates the text and then replies to you with the language you have specifed, works as a reply to message.
+* /github `<username>`: Search for the user using github api!
+* /lyrics `<song>`: Get the lyrics of the song you specify!
+* /weebify `<text>` or `<reply to message>`: To weebify the text.
 
 **Example:**
-`/info @username`: this fetches the information about a user from the database."""
+`/github @iamgojoof6eyes`: this fetches the information about a user from the database."""

Powers/utils/http_helper.py

@@ -1,14 +1,48 @@
-from httpx import AsyncClient, Timeout
+from asyncio import gather
+from bot_class import aiohttpsession as session
 
-timeout = Timeout(40, pool=None)
-http = AsyncClient(http2=True, timeout=timeout)
+async def get(url: str, *args, **kwargs):
+    async with session.get(url, *args, **kwargs) as resp:
+        try:
+            data = await resp.json()
+        except Exception:
+            data = await resp.text()
+    return data
 
 
-class HTTPx:
-    """class for helping get the data from url using aiohttp."""
+async def head(url: str, *args, **kwargs):
+    async with session.head(url, *args, **kwargs) as resp:
+        try:
+            data = await resp.json()
+        except Exception:
+            data = await resp.text()
+    return data
 
-    @staticmethod
-    async def get(link: str):
-        """Get JSON data from the provided link."""
-        async with AsyncClient() as sess:
-            return await sess.get(link)
+
+async def post(url: str, *args, **kwargs):
+    async with session.post(url, *args, **kwargs) as resp:
+        try:
+            data = await resp.json()
+        except Exception:
+            data = await resp.text()
+    return data
+
+
+async def multiget(url: str, times: int, *args, **kwargs):
+    return await gather(*[get(url, *args, **kwargs) for _ in range(times)])
+
+
+async def multihead(url: str, times: int, *args, **kwargs):
+    return await gather(*[head(url, *args, **kwargs) for _ in range(times)])
+
+
+async def multipost(url: str, times: int, *args, **kwargs):
+    return await gather(*[post(url, *args, **kwargs) for _ in range(times)])
+
+
+async def resp_get(url: str, *args, **kwargs):
+    return await session.get(url, *args, **kwargs)
+
+
+async def resp_post(url: str, *args, **kwargs):
+    return await session.post(url, *args, **kwargs)

Powers/utils/start_utils.py

@@ -256,8 +256,8 @@ async def get_help_msg(m: Message or CallbackQuery, help_option: str):
         Hey There! My name is Gojo.
         I'm here to help you manage your groups!
         Commands available:
-        × /start: Start the bot
-        × /help: Give's you this message.
+        * /start: Start the bot
+        * /help: Give's you this message.
         """
         help_kb = [
             *(await gen_cmds_kb(m)),

Powers/vars.py

@@ -29,6 +29,8 @@ class Config:
     SUPPORT_CHANNEL = config("SUPPORT_CHANNEL", default="gojo_updates")
     VERSION = config("VERSION", default="v2.0")
     WORKERS = int(config("WORKERS", default=16))
+    ARQ_API_URL = config("ARQ_API_URL", default="https://arq.hamker.in")
+    ARQ_API_KEY = config("ARQ_API_KEY", default=None)
     BOT_USERNAME = ""
     BOT_ID = ""
     BOT_NAME = ""
@@ -55,3 +57,5 @@ class Development:
     SUPPORT_CHANNEL = "SUPPORT_CHANNEL"
     VERSION = "VERSION"
     WORKERS = 8
+    ARQ_API_URL = "ARQ API url here"
+    ARQ_API_KEY = "ARQ API key here"

app.json

@@ -63,6 +63,16 @@
         "required": true,
         "value": "/ ! $"
       },
+      "ARQ_API_URL": {
+          "description": "Leave it as it is....",
+          "required": true,
+          "value": "https://arq.hamker.in"
+      },
+      "ARQ_API_KEY": {
+          "description": "Get this from @ARQRobot.",
+          "required": true,
+          "value":""
+      },
       "DEV_USERS": {
         "description": "ID of users who are Devs of your bot (can use /py etc.)...Don't give comma or anything after 1 id just give and space then enter second id. If you are a noob and would come and bother Hell support then keep the current ID's here at they are and add yours.",
         "required": false,

requirements.txt

@@ -1,4 +1,5 @@
-aiofiles==0.8.0; python_version >= "3.6" and python_version < "4.0"
+aiofiles
+aiohttp
 anyio==3.5.0; python_full_version >= "3.6.2" and python_version >= "3.6"
 asyncio==3.4.3
 beautifulsoup4==4.10.0; python_full_version > "3.0.0"
@@ -8,11 +9,11 @@ charset-normalizer==2.0.12; python_full_version >= "3.6.0" and python_version >=
 dnspython==2.2.1; python_version >= "3.6" and python_version < "4.0"
 google==3.0.0
 gpytranslate==1.4.0; python_version >= "3.6"
+gTTS
 h11==0.12.0; python_version >= "3.6"
 h2==4.1.0; python_version >= "3.6" and python_full_version >= "3.6.1"
 hpack==4.0.0; python_version >= "3.6" and python_full_version >= "3.6.1"
 httpcore==0.13.7; python_version >= "3.6"
-httpx==0.22.0; python_version >= "3.7"
 hyperframe==6.0.1; python_version >= "3.6" and python_full_version >= "3.6.1"
 idna==3.3; python_version >= "3.6" and (python_version >= "3.5" and python_full_version < "3.0.0" or python_full_version >= "3.6.0" and python_version >= "3.5") and python_full_version >= "3.6.2"
 lxml==4.8.0; python_version >= "2.7" and python_full_version < "3.0.0" or python_full_version >= "3.5.0"
@@ -21,15 +22,16 @@ pyaes==1.6.1; python_version >= "3.6" and python_version < "4.0"
 pymongo==3.12.3
 pyrogram==2.0.19; python_version >= "3.7"
 pysocks==1.7.1; python_version >= "3.6" and python_full_version < "3.0.0" and python_version < "4.0" or python_version >= "3.6" and python_version < "4.0" and python_full_version >= "3.4.0"
+python-arq
 python-dateutil==2.8.2; (python_version >= "2.7" and python_full_version < "3.0.0") or (python_full_version >= "3.3.0")
 pyyaml==6.0; python_version >= "3.6"
 regex==2021.11.10
 requests==2.27.1; python_version >= "2.7" and python_full_version < "3.0.0" or python_full_version >= "3.6.0"
 rfc3986==1.5.0; python_version >= "3.6"
+search_engine_parser
 six==1.16.0; python_version >= "2.7" and python_full_version < "3.0.0" or python_full_version >= "3.3.0"
 sniffio==1.2.0; python_full_version >= "3.6.2" and python_version >= "3.6"
 soupsieve==2.3.1; python_version >= "3.6" and python_full_version > "3.0.0"
-speedtest-cli==2.1.3
 tgcrypto==1.2.3; python_version >= "3.6" and python_version < "4.0"
 tswift==0.7.0
 typing-extensions==4.1.1; python_full_version >= "3.6.2" and python_version >= "3.6" and python_version < "3.8"