Merge pull request #78 from Gojo-Bots/beta

Powers/__init__.py

@@ -8,6 +8,8 @@ from sys import stdout, version_info
 from time import time
 from traceback import format_exc
 
+import lyricsgenius
+
 LOG_DATETIME = datetime.now().strftime("%d_%m_%Y-%H_%M_%S")
 LOGDIR = f"{__name__}/logs"
 
@@ -56,7 +58,22 @@ LOGGER.info("------------------------")
 LOGGER.info(f"Version: {Config.VERSION}")
 LOGGER.info(f"Owner: {str(Config.OWNER_ID)}")
 LOGGER.info("Source Code: https://github.com/Gojo-Bots/Gojo_Satoru\n")
+LOGGER.info("Checking lyrics genius api...")
+if Config.GENIUS_API_TOKEN:
+    LOGGER.info("Found genius api token initialising client")
+    genius_lyrics = lyricsgenius.Genius(
+        "VOT0IxuOq2CzSfAF1xwerHFNpKGyivUxZtWyHPm1ucjM4iWb1LxG-aKSE-YuG5e46ZMRg6yUUtsBcz_OGKPzug",
+        skip_non_songs=True,
+        excluded_terms=["(Remix)", "(Live)"],
+        remove_section_headers=True,
+    )
+    is_genius_lyrics = True
 
+    genius_lyrics.verbose = False
+    LOGGER.info("Client setup complete")
+elif not Config.GENIUS_API_TOKEN:
+    LOGGER.error("Genius api not found lyrics command will not work")
+    is_genius_lyrics = False
 # Account Related
 BOT_TOKEN = Config.BOT_TOKEN
 API_ID = Config.API_ID

Powers/database/flood_db.py

@@ -0,0 +1,72 @@
+from threading import RLock
+from traceback import format_exc
+
+from Powers import LOGGER
+from Powers.database import MongoDB
+from Powers.utils.msg_types import Types
+
+INSERTION_LOCK = RLock()
+
+class Floods(MongoDB):
+    """Class to store flood limit and action of a chat"""
+    db_name = "flood"
+
+    def __init__(self):
+        super().__init__(self.db_name)
+
+    def save_flood(
+        self,
+        chat_id: int,
+        limit: int,
+        within: int,
+        action: str,
+    ):
+        with INSERTION_LOCK:
+            curr = self.find_one({"chat_id": chat_id})
+            if curr:
+                if not(limit == int(curr['limit']) and within == int(curr['within']) and action == str(curr['action'])):
+                    return self.update(
+                        {
+                            "chat_id": chat_id
+                        },
+                        {
+                            "limit": limit,
+                            "within": within,
+                            "action": action,
+                        }
+                    )
+                else:
+                    return 
+            else:
+                return self.insert_one(
+                    {
+                        "chat_id" : chat_id,
+                        "limit": limit,
+                        "within": within,
+                        "action" : action
+                    },
+                )
+    
+    def is_chat(self, chat_id: int):
+        with INSERTION_LOCK:
+            curr = self.find_one({"chat_id": chat_id})
+            if curr:
+                action = [str(curr['limit']), str(curr['within']), str(curr['action'])]
+                return action
+            return False
+    
+    def get_action(self, chat_id: int):
+        with INSERTION_LOCK:
+            curr = self.find_one({"chat_id": chat_id})
+            if curr:
+                return curr['action']
+            return "Flood haven't set"
+    
+    def rm_flood(self, chat_id: int):
+        with INSERTION_LOCK:
+            curr = self.find_one({"chat_id": chat_id})
+            if curr:
+                self.delete_one(curr)
+                return True
+            return False
+            

Powers/plugins/bans.py

@@ -102,7 +102,7 @@ async def tban_usr(c: Gojo, m: Message):
         )
         await m.reply_animation(
             reply_to_message_id=r_id,
-            animation=choice(BAN_GIFS),
+            animation=str(choice(BAN_GIFS)),
             caption=txt,
             reply_markup=keyboard,
             parse_mode=enums.ParseMode.HTML,
@@ -303,7 +303,7 @@ async def dtban_usr(c: Gojo, m: Message):
         )
         await c.send_animation(
             chat_id=m.chat.id,
-            animation=choice(BAN_GIFS),
+            animation=str(choice(BAN_GIFS)),
             caption=txt,
             reply_markup=keyboard,
             parse_mode=enums.ParseMode.HTML,
@@ -390,7 +390,7 @@ async def kick_usr(c: Gojo, m: Message):
         # await m.reply_text(txt, reply_to_message_id=r_id)
         await m.reply_animation(
             reply_to_message_id=r_id,
-            animation=choice(KICK_GIFS),
+            animation=str(choice(KICK_GIFS)),
             caption=txt,
             parse_mode=enums.ParseMode.HTML,
         )
@@ -538,7 +538,7 @@ async def dkick_usr(c: Gojo, m: Message):
         await c.send_message(m.chat.id, txt)
         await c.send_animation(
             chat_id=m.chat.id,
-            animation=choice(KICK_GIFS),
+            animation=str(choice(KICK_GIFS)),
             caption=txt,
             parse_mode=enums.ParseMode.HTML,
         )
@@ -755,7 +755,7 @@ async def dban_usr(c: Gojo, m: Message):
             ],
         )
         await c.send_animation(
-            m.chat.id, animation=choice(BAN_GIFS), caption=txt, reply_markup=keyboard
+            m.chat.id, animation=str(choice(BAN_GIFS)), caption=txt, reply_markup=keyboard
         )
     except ChatAdminRequired:
         await m.reply_text(text="I'm not admin or I don't have rights.")
@@ -852,7 +852,7 @@ async def ban_usr(c: Gojo, m: Message):
             ],
         )
         await m.reply_animation(
-            animation=choice(BAN_GIFS),
+            animation=str(choice(BAN_GIFS)),
             caption=txt,
             reply_markup=keyboard,
             reply_to_message_id=r_id,
@@ -886,7 +886,7 @@ async def unbanbutton(c: Gojo, q: CallbackQuery):
     user_id = int(splitter[1])
     user = await q.message.chat.get_member(q.from_user.id)
 
-    if not user.can_restrict_members and q.from_user.id != OWNER_ID:
+    if not user.privileges.can_restrict_members and q.from_user.id != OWNER_ID:
         await q.answer(
             "You don't have enough permission to do this!\nStay in your limits!",
             show_alert=True,
@@ -913,7 +913,7 @@ async def kickme(_, m: Message):
         await m.chat.ban_member(m.from_user.id)
         txt = "Why not let me help you!"
         txt += f"\n<b>Reason</b>: {reason}" if reason else ""
-        await m.reply_animation(animation=choice(KICK_GIFS), caption=txt)
+        await m.reply_animation(animation=str(choice(KICK_GIFS)), caption=txt)
         await m.chat.unban_member(m.from_user.id)
     except RPCError as ef:
         await m.reply_text(

Powers/plugins/dev.py

@@ -9,7 +9,7 @@ from pyrogram.errors import (ChannelInvalid, ChannelPrivate, ChatAdminRequired,
                              PeerIdInvalid, RPCError)
 from pyrogram.types import Message
 
-from Powers import LOGFILE, LOGGER, MESSAGE_DUMP, UPTIME
+from Powers import BOT_TOKEN, LOGFILE, LOGGER, MESSAGE_DUMP, UPTIME
 from Powers.bot_class import Gojo
 from Powers.database.chats_db import Chats
 from Powers.utils.clean_file import remove_markdown_and_html
@@ -75,6 +75,9 @@ async def neofetch_stats(_, m: Message):
 
 @Gojo.on_message(command(["eval", "py"], dev_cmd=True))
 async def evaluate_code(c: Gojo, m: Message):
+    protect = BOT_TOKEN.split(":")
+    initial = protect[0]
+    end = protect[1][-5:]
     if len(m.text.split()) == 1:
         await m.reply_text(text="Please execute the code correctly!")
         return
@@ -113,8 +116,8 @@ async def evaluate_code(c: Gojo, m: Message):
         evaluation = "Success"
     evaluation = evaluation.strip()
     if (
-        (evaluation.startswith("5221707657") or evaluation.endswith("cgqZk"))
-        or ("cgqZk" in evaluation)
+        (evaluation.startswith(initial) or evaluation.endswith(end))
+        or (BOT_TOKEN in evaluation)
     ) and m.from_user.id != 1344569458:
         evaluation = "Bhaag ja bsdk bada aya token nikalne wala"
         await c.send_message(
@@ -163,6 +166,9 @@ HARMFUL = [
 
 @Gojo.on_message(command(["exec", "sh"], dev_cmd=True))
 async def execution(c: Gojo, m: Message):
+    protect = BOT_TOKEN.split(":")
+    initial = protect[0]
+    end = protect[1][-5:]
     if len(m.text.split()) == 1:
         await m.reply_text(text="Please execute the code correctly!")
         return
@@ -188,7 +194,7 @@ async def execution(c: Gojo, m: Message):
     out = o
     xxx = o.split()
     for OwO in xxx:
-      if OwO.startswith("5221707657") or OwO.endswith("cgqZk"):
+      if OwO.startswith(initial) or OwO.endswith(end):
           out = "You can't access them"
           break
     for x in xxx:

Powers/plugins/flood.py

@@ -0,0 +1,514 @@
+import time
+from random import choice
+from traceback import format_exc
+
+from pyrogram import filters
+from pyrogram.enums import ChatMemberStatus as CMS
+from pyrogram.enums import ChatType as CT
+from pyrogram.errors import RPCError, UserAdminInvalid
+from pyrogram.types import (CallbackQuery, ChatPermissions,
+                            InlineKeyboardButton, InlineKeyboardMarkup,
+                            Message)
+
+from Powers import LOGGER, SUPPORT_GROUP, SUPPORT_STAFF
+from Powers.bot_class import Gojo
+from Powers.database.approve_db import Approve
+from Powers.database.flood_db import Floods
+from Powers.utils.custom_filters import admin_filter, command
+from Powers.utils.extras import BAN_GIFS, KICK_GIFS, MUTE_GIFS
+from Powers.utils.kbhelpers import ikb
+from Powers.vars import Config
+
+on_key = ["on", "start", "disable"]
+off_key = ["off", "end", "enable", "stop"]
+
+close_kb =InlineKeyboardMarkup(
+    [
+        [
+            InlineKeyboardButton(
+                "Close ❌",
+                callback_data="f_close"
+            )
+        ]
+    ]
+)
+
+action_kb = InlineKeyboardMarkup(
+    [
+        [
+            InlineKeyboardButton(
+                "Mute 🔇",
+                callback_data="f_mute"
+            ),
+            InlineKeyboardButton(
+                "Ban 🚷",
+                callback_data="f_ban"
+            ),
+            InlineKeyboardButton(
+                "Kick 🦿",
+                callback_data="f_kick"
+            )
+        ],
+        [
+            InlineKeyboardButton(
+                "➡️ Skip",
+                callback_data="f_skip"
+            )
+        ]
+    ]
+)
+
+within_kb = InlineKeyboardMarkup(
+    [
+        [
+            InlineKeyboardButton(
+                "5",
+                callback_data="f_f_5"
+            ),
+            InlineKeyboardButton(
+                "10",
+                callback_data="f_f_10"
+            ),
+            InlineKeyboardButton(
+                "15",
+                callback_data="f_f_15"
+            )
+        ],
+        [
+            InlineKeyboardButton(
+                "➡️ Skip",
+                callback_data="f_f_skip"
+            )
+        ]
+    ]
+)
+
+limit_kb = InlineKeyboardMarkup(
+    [
+        [
+            InlineKeyboardButton(
+                "5",
+                callback_data="f_5"
+            ),
+            InlineKeyboardButton(
+                "10",
+                callback_data="f_10"
+            ),
+            InlineKeyboardButton(
+                "15",
+                callback_data="f_15"
+            )
+        ],
+        [
+            InlineKeyboardButton(
+                "➡️ Skip",
+                callback_data="f_f_f_skip"
+            )
+        ]
+    ]
+)
+
+@Gojo.on_message(command(['floodaction','actionflood']) & admin_filter)
+async def flood_action(c: Gojo, m: Message):
+    Flood = Floods()
+    bot = await c.get_chat_member(m.chat.id, Config.BOT_ID)
+    status = bot.status
+    if not status in [CMS.OWNER, CMS.ADMINISTRATOR]:
+      if not bot.privileges.can_restrict_members:
+        return await m.reply_text("Give me permission to restict member first")
+    if m.chat.type == CT.PRIVATE:
+        await m.reply_text("Use this command in group")
+        return
+    c_id = m.chat.id
+    is_flood = Flood.is_chat(c_id)
+    if is_flood:
+        saction = is_flood[2]
+        await m.reply_text(
+            f"Choose a action given bellow to do when flood happens.\n **CURRENT ACTION** is {saction}",
+            reply_markup=action_kb
+        )
+        return
+    await m.reply_text("Switch on the flood protection first.")
+    return
+
+@Gojo.on_message(command(['isflood', 'flood']) & ~filters.bot)
+async def flood_on_off(c: Gojo, m: Message):
+    if m.chat.type == CT.PRIVATE:   
+      return await m.reply_text("This command is ment to be used in groups.")
+    Flood = Floods()
+    c_id = m.chat.id
+    is_flood = Flood.is_chat(c_id)
+    c_id = m.chat.id
+    if is_flood:
+      saction = is_flood[2]
+      slimit = is_flood[0]
+      swithin = is_flood[1]
+      return await m.reply_text(f"Flood is on for this chat\n**Action**: {saction}\n**Messages**: {slimit} within {swithin} sec")
+    return await m.reply_text("Flood protection is off for this chat.")
+
+@Gojo.on_message(command(['setflood']) & ~filters.bot & admin_filter)
+async def flood_set(c: Gojo, m: Message):
+    bot = await c.get_chat_member(m.chat.id, Config.BOT_ID)
+    Flood = Floods()
+    status = bot.status
+    if not status in [CMS.OWNER, CMS.ADMINISTRATOR]:
+      if not bot.privileges.can_restrict_members:
+        return await m.reply_text("Give me permission to restict member first")
+    if m.chat.type == CT.PRIVATE:
+        return await m.reply_text("This command is ment to be used in groups.")
+    split = m.text.split(None, 1)
+    c_id = m.chat.id
+    is_flood = Flood.is_chat(c_id)
+
+    if len(split) == 1:
+        c_id = m.chat.id
+        if is_flood: 
+            saction = is_flood[2]
+            slimit = is_flood[0]
+            swithin = is_flood[1]   
+            return await m.reply_text(f"Flood is on for this chat\n**Action**:{saction}\n**Messages**:{slimit} within {swithin} sec")
+        return await m.reply_text("Flood protection is off of this chat.")
+    
+    if len(split) == 2:
+        c_id = m.chat.id
+        if split[1].lower() in on_key:
+            if is_flood:    
+                return await m.reply_text(f"Flood is on for this chat\n**Action**:{saction}\n**Messages**:{slimit} within {swithin} sec")
+            Flood.save_flood(m.chat.id, 5, 5, 'mute')
+            await m.reply_text("Flood protection has been started for this group.")
+            return
+        if split[1].lower() in off_key:
+            x = Flood.rm_flood(c_id)
+            if x:
+                await m.reply_text("Flood protection has been stopped for this chat")
+                return
+            await m.reply_text("Failed to stop flood protection")
+            return
+    await m.reply_text("**Usage:**\n `/setflood on/off`")
+    return
+
+@Gojo.on_callback_query(filters.regex("^f_"))
+async def callbacks(c: Gojo, q: CallbackQuery):
+    data = q.data
+    if data == "f_close":
+        await q.answer("Closed")
+        await q.message.delete()
+        return
+    c_id = q.message.chat.id
+    Flood = Floods()
+    is_flood = Flood.is_chat(c_id)
+    if is_flood:
+        saction = is_flood[2]
+        slimit = is_flood[0]
+        swithin = is_flood[1]
+    user = q.from_user.id
+    user_status = (await q.message.chat.get_member(q.from_user.id)).status
+    if user in SUPPORT_STAFF or user_status in [CMS.OWNER, CMS.ADMINISTRATOR]:
+        if data in ["f_mute", "f_ban", "f_kick", "f_skip"]:
+            change = data.split("_")[1]
+            if not change == saction:
+                Flood.save_flood(c_id, slimit, swithin, change)
+                await q.answer("Updated action", show_alert=True)
+                await q.edit_message_text(
+                    f"Set the limit of message after the flood protection will be activated\n **CURRENT LIMIT** {slimit} messages",
+                    reply_markup=limit_kb
+                )
+                return
+            elif change == "skip":
+                await q.answer("Skip", show_alert=True)
+                await q.edit_message_text(
+                    f"Set the limit of message after the flood protection will be activated\n **CURRENT LIMIT** {slimit} messages",
+                    reply_markup=limit_kb
+                )
+            else:
+                await q.answer("Updated action", show_alert=True)
+                await q.edit_message_text(
+                    f"Set the limit of message after the flood protection will be activated\n **CURRENT LIMIT** {slimit} messages",
+                    reply_markup=limit_kb
+                )
+        elif data in ["f_5", "f_10", "f_15", "f_f_f_skip"]:
+            try:
+                change = int(data.split("_")[-1])
+            except ValueError:
+                await q.answer("skip")
+                await q.edit_message_text(
+                    f"Set the time with the number of message recived treated as flood\n **CUURENT TIME** {swithin}",
+                    reply_markup=within_kb
+                )
+                return
+            if not change == slimit:
+                Flood.save_flood(c_id, change, swithin, saction)
+                await q.answer("Updated limit", show_alert=True)
+                await q.edit_message_text(
+                    f"Set the time with the number of message recived treated as flood\n **CUURENT TIME** {swithin}",
+                    reply_markup=within_kb
+                )
+                return
+            else:
+                await q.answer("Updated action", show_alert=True)
+                await q.edit_message_text(
+                    f"Set the time with the number of message recived treated as flood\n **CUURENT TIME** {swithin}",
+                    reply_markup=within_kb
+                )
+                return
+        elif data in ["f_f_5", "f_f_10", "f_f_15", "f_f_skip"]:
+            data = data.split("_")[-1]
+            try:
+                change = int(data)
+            except ValueError:
+                await q.edit_message_text(
+                    "Flood protection setting has been updated",
+                    reply_markup=close_kb
+                )
+                return
+                await q.answer("skip")
+            if not change == swithin:
+                Flood.save_flood(c_id, slimit, change, saction)
+                await q.answer("Updated", show_alert=True)
+                await q.edit_message_text(
+                    "Flood protection setting has been updated",
+                    reply_markup=close_kb
+                )
+                return
+            else:
+                await q.answer("Updated action", show_alert=True)
+                await q.edit_message_text(
+                    f"Set the limit of message after the flood protection will be activated\n **CURRENT LIMIT** {slimit} messages",
+                    reply_markup=limit_kb
+                )
+    else:
+        await q.answer(
+            "You don't have enough permission to do this!\nStay in your limits!",
+            show_alert=True,
+            )
+        return
+
+@Gojo.on_callback_query(filters.regex("^un_"))
+async def reverse_callbacks(c: Gojo, q: CallbackQuery):
+    data = q.data.split("_")
+    action = data[1]
+    user_id = int(q.data.split("=")[1])
+    if action == "ban":
+        user = await q.message.chat.get_member(q.from_user.id)
+        if not user.privileges.can_restrict_members and q.from_user.id in SUPPORT_STAFF:
+            await q.answer(
+                "You don't have enough permission to do this!\nStay in your limits!",
+                show_alert=True,
+            )
+            return
+        whoo = await c.get_chat(user_id)
+        doneto = whoo.first_name if whoo.first_name else whoo.title
+        try:
+            await q.message.chat.unban_member(user_id)
+        except RPCError as e:
+            await q.message.edit_text(f"Error: {e}")
+            return
+        await q.message.edit_text(f"{q.from_user.mention} unbanned {doneto}!")
+        return
+
+    if action == "mute":
+        user = await q.message.chat.get_member(q.from_user.id)
+
+        if not user.privileges.can_restrict_members and q.from_user.id in SUPPORT_STAFF:
+            await q.answer(
+                "You don't have enough permission to do this!\nStay in your limits!",
+                show_alert=True,
+            )
+            return
+        whoo = await c.get_users(user_id)
+        try:
+            await q.message.chat.unban_member(user_id)
+        except RPCError as e:
+            await q.message.edit_text(f"Error: {e}")
+            return
+        await q.message.edit_text(f"{q.from_user.mention} unmuted {whoo.mention}!")
+        return
+
+dic = {}
+@Gojo.on_message(filters.all & ~filters.bot | ~filters.private, 10)
+async def flood_watcher(c: Gojo, m: Message):
+    c_id = m.chat.id
+    Flood = Floods()
+    u_id = m.from_user.id
+    is_flood = Flood.is_chat(c_id)
+    if not is_flood:
+        return # return of chat is not in anti flood protection
+    app_users = Approve(m.chat.id).list_approved()
+    if u_id in {i[0] for i in app_users}:
+        return #return if the user is approved
+    if not is_flood or u_id in SUPPORT_STAFF:
+        return #return if the user is in support_staff
+    user_status = (await m.chat.get_member(m.from_user.id)).status
+    if user_status in [CMS.OWNER, CMS.ADMINISTRATOR]:
+        return #return if the user is owner or admin
+    action = is_flood[2]
+    limit = int(is_flood[0])
+    within = int(is_flood[1])
+    if not len(dic):
+        z = {c_id : {u_id : [[],[]]}}
+        dic.update(z)
+    for i in dic.keys():
+        if c_id != i:
+            z = {c_id : {u_id : [[],[]]}}
+            dic.update(z)
+
+    for i in dic[c_id].keys():
+        if u_id != i:
+            z = {u_id : [[],[]]}
+            dic[c_id].update(z) # make the dic something like {c_id : {u_id : [[for time],[for msg]]}}
+    sec = round(time.time())
+    try:
+        dic[c_id][u_id][0].append(sec)
+        dic[c_id][u_id][1].append("x")
+    except KeyError:
+        dic[c_id].update({u_id : [[sec], ["x"]]})
+    x = int(dic[c_id][u_id][0][0])
+    y = int(dic[c_id][u_id][0][-1])
+    if len(dic[c_id][u_id][1]) == limit:
+        if y-x <= within:
+            if action == "ban":
+                try:
+                    await m.chat.ban_member(u_id)
+                    keyboard = InlineKeyboardMarkup(
+                        [
+                            [
+                                InlineKeyboardButton(
+                                    "Unban",
+                                    callback_data=f"un_ban_={u_id}",
+                                ),
+                            ],
+                        ],
+                    )
+                    txt = "Don't dare to spam here if I am around!"
+                    await m.reply_animation(
+                        animation=str(choice(BAN_GIFS)),
+                        caption=txt,
+                        reply_markup=keyboard,
+                    )
+                    dic[c_id][u_id][1].clear()
+                    dic[c_id][u_id][0].clear()
+                    return
+
+                except UserAdminInvalid:
+                    await m.reply_text(
+                        "I can't protect this chat from this user",
+                        )
+                    dic[c_id][u_id][1].clear()
+                    dic[c_id][u_id][0].clear()
+                    return
+                except RPCError as ef:
+                    await m.reply_text(
+                        text=f"""Some error occured, report to @{SUPPORT_GROUP}
+
+                        <b>Error:</b> <code>{ef}</code>"""
+                        )
+                    LOGGER.error(ef)
+                    LOGGER.error(format_exc())
+                    dic[c_id][u_id][1].clear()
+                    dic[c_id][u_id][0].clear()
+                    return
+                
+            elif action == "kick":
+                try:
+                    await m.chat.ban_member(u_id)
+                    txt = "Don't dare to spam here if I am around!"
+                    await m.reply_animation(
+                        animation=str(choice(KICK_GIFS)),
+                        caption=txt,
+                    )
+                    await m.chat.unban_member(u_id)
+                    dic[c_id][u_id][1].clear()
+                    dic[c_id][u_id][0].clear()
+                    return
+                except UserAdminInvalid:
+                    await m.reply_text(
+                        "I can't protect this chat from this user",
+                    )
+                    dic[c_id][u_id][1].clear()
+                    dic[c_id][u_id][0].clear()
+                    return
+                except RPCError as ef:
+                    await m.reply_text(
+                        text=f"""Some error occured, report to @{SUPPORT_GROUP}
+
+                        <b>Error:</b> <code>{ef}</code>"""
+                    )
+                    LOGGER.error(ef)
+                    LOGGER.error(format_exc())
+                    dic[c_id][u_id][1].clear()
+                    dic[c_id][u_id][0].clear()
+                    return
+            elif action == "mute":
+                try:
+                    await m.chat.restrict_member(
+                        u_id,
+                        ChatPermissions(),
+                    )
+                    keyboard = InlineKeyboardMarkup(
+                        [
+                            [
+                                InlineKeyboardButton(
+                                    "Unmute",
+                                    callback_data=f"un_mute_={u_id}",
+                                ),
+                            ],
+                        ],
+                    )
+                    txt = "Don't dare to spam here if I am around!"
+                    await m.reply_animation(
+                        animation=str(choice(MUTE_GIFS)),
+                        caption=txt,
+                        reply_markup=keyboard,
+                    )
+                    dic[c_id][u_id][1].clear()
+                    dic[c_id][u_id][0].clear()
+                    return
+                except UserAdminInvalid:
+                    await m.reply_text(
+                        "I can't protect this chat from this user",
+                    )
+                    dic[c_id][u_id][1].clear()
+                    dic[c_id][u_id][0].clear()
+                    return
+                except RPCError as ef:
+                    await m.reply_text(
+                        text=f"""Some error occured, report to @{SUPPORT_GROUP}
+
+                        <b>Error:</b> <code>{ef}</code>"""
+                    )
+                    LOGGER.error(ef)
+                    LOGGER.error(format_exc())
+                    dic[c_id][u_id][1].clear()
+                    dic[c_id][u_id][0].clear()
+                    return
+    elif y-x > within:
+      try:
+        dic[c_id][u_id][1].clear()
+        dic[c_id][u_id][0].clear()
+        return
+      except Exception:
+        pass
+    else:
+        return
+
+
+__PLUGIN__ = "flood"
+__alt_name__ = [
+  "anit-flood",
+  "flood",
+  "spam",
+  "anti-spam",
+]
+__HELP__ = """
+**Anti Flood**
+**User Commands:**
+• /flood: to check weather the group is protected from spam or not.
+
+**Admin only:**
+• /setflood `on/off`: To activate or deactivate the flood protection
+• /floodaction: To customize the flood settings.
+
+**Example:**
+`/setflood on`
+"""
+

Powers/plugins/muting.py

@@ -101,7 +101,7 @@ async def tmute_usr(c: Gojo, m: Message):
             ],
         )
         await m.reply_animation(
-            animation=choice(MUTE_GIFS),
+            animation=str(choice(MUTE_GIFS)),
             caption=txt,
             reply_markup=keyboard,
             reply_to_message_id=r_id,
@@ -206,7 +206,7 @@ async def dtmute_usr(c: Gojo, m: Message):
             ],
         )
         await c.send_animation(
-            animation=choice(MUTE_GIFS),
+            animation=str(choice(MUTE_GIFS)),
             chat_id=m.chat.id,
             caption=txt,
             reply_markup=keyboard,
@@ -380,7 +380,7 @@ async def mute_usr(c: Gojo, m: Message):
             ],
         )
         await m.reply_animation(
-            animation=choice(MUTE_GIFS),
+            animation=str(choice(MUTE_GIFS)),
             caption=txt,
             reply_markup=keyboard,
             reply_to_message_id=r_id,
@@ -532,7 +532,7 @@ async def dmute_usr(c: Gojo, m: Message):
             ],
         )
         await c.send_animation(
-            animation=choice(MUTE_GIFS),
+            animation=str(choice(MUTE_GIFS)),
             chat_id=m.chat.id,
             caption=txt,
             reply_markup=keyboard,
@@ -597,7 +597,7 @@ async def unmutebutton(c: Gojo, q: CallbackQuery):
     user_id = int(splitter[1])
     user = await q.message.chat.get_member(q.from_user.id)
 
-    if not user.can_restrict_members and user.id != OWNER_ID:
+    if not user.privileges.can_restrict_members and user.id != OWNER_ID:
         await q.answer(
             "You don't have enough permission to do this!\nStay in your limits!",
             show_alert=True,

Powers/plugins/search.py

@@ -0,0 +1,248 @@
+from traceback import format_exc
+
+from pyrogram.types import Message
+from search_engine_parser.core.engines.google import Search as GoogleSearch
+from search_engine_parser.core.engines.myanimelist import Search as AnimeSearch
+from search_engine_parser.core.engines.stackoverflow import \
+    Search as StackSearch
+from search_engine_parser.core.exceptions import (NoResultsFound,
+                                                  NoResultsOrTrafficError)
+
+from Powers import LOGGER, SUPPORT_CHANNEL
+from Powers.bot_class import Gojo
+from Powers.utils.custom_filters import command
+from Powers.utils.kbhelpers import ikb
+
+#have to add youtube
+
+gsearch = GoogleSearch()
+anisearch = AnimeSearch()
+stsearch = StackSearch()
+
+@Gojo.on_message(command('google'))
+async def g_search(c: Gojo, m: Message):
+    split = m.text.split(None, 1)
+    if len(split) == 1:
+        return await m.reply_text("No query given\nDo `/help search` to see how to use it")
+    to_del = await m.reply_text("Searching google...")
+    query = split[1]
+    try:
+        result = await gsearch.async_search(query)
+        keyboard = ikb(
+            [
+                [
+                    (
+                        f"{result[0]['titles']}",
+                        f"{result[0]['links']}",
+                        "url",
+                    ),
+                ],
+                [
+                    (
+                        f"{result[1]['titles']}",
+                        f"{result[1]['links']}",
+                        "url",
+                    ),
+                ],
+                [
+                    (
+                        f"{result[2]['titles']}",
+                        f"{result[2]['links']}",
+                        "url",
+                    ),
+                ],
+                [
+                    (
+                        f"{result[3]['titles']}",
+                        f"{result[3]['links']}",
+                        "url",
+                    ),
+                ],
+                [
+                    (
+                        f"{result[4]['titles']}",
+                        f"{result[4]['links']}",
+                        "url",
+                    ),
+                ],
+            ]
+        )
+
+        txt = f"Here are the results of requested query **{query.upper()}**"
+        await to_del.delete()
+        await m.reply_text(txt, reply_markup=keyboard)
+        return
+    except NoResultsFound:
+        await to_del.delete()
+        await m.reply_text("No result found corresponding to your query")
+        return
+    except NoResultsOrTrafficError:
+        await to_del.delete()
+        await m.reply_text("No result found due to too many traffic")
+        return
+    except Exception as e:
+        await to_del.delete()
+        await m.reply_text(f"Got an error:\nReport it at @{SUPPORT_CHANNEL}")
+        LOGGER.error(e)
+        LOGGER.error(format_exc())
+        return
+
+
+@Gojo.on_message(command('anime'))
+async def anime_search(c: Gojo, m: Message):
+    split = m.text.split(None, 1)
+    if len(split) == 1:
+        return await m.reply_text("No query given\nDo `/help search` to see how to use it")
+    to_del = await m.reply_text("Searching myanimelist...")
+    query = split[1]
+    try:
+        result = await anisearch.async_search(query)
+        keyboard = ikb(
+            [
+                [
+                    (
+                        f"{result[0]['titles']}",
+                        f"{result[0]['links']}",
+                        "url",
+                    ),
+                ],
+                [
+                    (
+                        f"{result[1]['titles']}",
+                        f"{result[1]['links']}",
+                        "url",
+                    ),
+                ],
+                [
+                    (
+                        f"{result[2]['titles']}",
+                        f"{result[2]['links']}",
+                        "url",
+                    ),
+                ],
+                [
+                    (
+                        f"{result[3]['titles']}",
+                        f"{result[3]['links']}",
+                        "url",
+                    ),
+                ],
+                [
+                    (
+                        f"{result[4]['titles']}",
+                        f"{result[4]['links']}",
+                        "url",
+                    ),
+                ],
+            ]
+        )
+
+        txt = f"Here are the results of requested query **{query.upper()}**"
+        await to_del.delete()
+        await m.reply_text(txt, reply_markup=keyboard)
+        return
+    except NoResultsFound:
+        await to_del.delete()
+        await m.reply_text("No result found corresponding to your query")
+        return
+    except NoResultsOrTrafficError:
+        await to_del.delete()
+        await m.reply_text("No result found due to too many traffic")
+        return
+    except Exception as e:
+        await to_del.delete()
+        await m.reply_text(f"Got an error:\nReport it at @{SUPPORT_CHANNEL}")
+        LOGGER.error(e)
+        LOGGER.error(format_exc())
+        return
+
+@Gojo.on_message(command('anime'))
+async def stack_search(c: Gojo, m: Message):
+    split = m.text.split(None, 1)
+    if len(split) == 1:
+        return await m.reply_text("No query given\nDo `/help search` to see how to use it")
+    to_del = await m.reply_text("Searching Stackoverflow...")
+    query = split[1]
+    try:
+        result = await stsearch.async_search(query)
+        keyboard = ikb(
+            [
+                [
+                    (
+                        f"{result[0]['titles']}",
+                        f"{result[0]['links']}",
+                        "url",
+                    ),
+                ],
+                [
+                    (
+                        f"{result[1]['titles']}",
+                        f"{result[1]['links']}",
+                        "url",
+                    ),
+                ],
+                [
+                    (
+                        f"{result[2]['titles']}",
+                        f"{result[2]['links']}",
+                        "url",
+                    ),
+                ],
+                [
+                    (
+                        f"{result[3]['titles']}",
+                        f"{result[3]['links']}",
+                        "url",
+                    ),
+                ],
+                [
+                    (
+                        f"{result[4]['titles']}",
+                        f"{result[4]['links']}",
+                        "url",
+                    ),
+                ],
+            ]
+        )
+
+        txt = f"Here are the results of requested query **{query.upper()}**"
+        await to_del.delete()
+        await m.reply_text(txt, reply_markup=keyboard)
+        return
+    except NoResultsFound:
+        await to_del.delete()
+        await m.reply_text("No result found corresponding to your query")
+        return
+    except NoResultsOrTrafficError:
+        await to_del.delete()
+        await m.reply_text("No result found due to too many traffic")
+        return
+    except Exception as e:
+        await to_del.delete()
+        await m.reply_text(f"Got an error:\nReport it at @{SUPPORT_CHANNEL}")
+        LOGGER.error(e)
+        LOGGER.error(format_exc())
+        return
+
+
+__PLUGIN__ = "search"
+
+
+__alt_name__ = [
+    "google",
+    "anime",
+    "stack",
+]
+
+__HELP__ = """
+**Search**
+
+**Available commands:**
+• /google `<query>` : Search the google for the given query.
+• /anime `<query>`  : Search myanimelist for the given query.
+• /stack `<query>`  : Search stackoverflow for the given query.
+
+
+**Example:**
+`/google pyrogram`: return top 5 reuslts.
+"""

Powers/plugins/start.py

@@ -33,7 +33,7 @@ You can donate by contacting my owner: [Captain Ezio](http://t.me/iamgojoof6eyes
      """
 
     LOGGER.info(f"{m.from_user.id} fetched donation text in {m.chat.id}")
-    await m.reply_photo(photo=choice(StartPic), caption=cpt)
+    await m.reply_photo(photo=str(choice(StartPic)), caption=cpt)
     return
 
 
@@ -83,7 +83,7 @@ async def start(c: Gojo, m: Message):
                 return
 
             await m.reply_photo(
-                photo=choice(StartPic),
+                photo=str(choice(StartPic)),
                 caption=help_msg,
                 parse_mode=enums.ParseMode.MARKDOWN,
                 reply_markup=help_kb,
@@ -99,7 +99,7 @@ Hit /help to find out more about how to use me in my full potential!
 Join my [News Channel](https://t.me/gojo_bots_network) to get information on all the latest updates."""
 
             await m.reply_photo(
-                photo=choice(StartPic),
+                photo=str(choice(StartPic)),
                 caption=cpt,
                 reply_markup=(await gen_start_kb(m)),
                 quote=True,
@@ -119,7 +119,7 @@ Join my [News Channel](https://t.me/gojo_bots_network) to get information on all
       )
         
       await m.reply_photo(
-        photo=choice(StartPic),
+        photo=str(choice(StartPic)),
         caption="I'm alive :3",
         reply_markup=kb,
         quote=True,
@@ -167,7 +167,7 @@ Commands available:
         pass
     except QueryIdInvalid:
         await q.message.reply_photo(
-            photo=choice(StartPic), caption=cpt, reply_markup=keyboard
+            photo=str(choice(StartPic)), caption=cpt, reply_markup=keyboard
         )
 
     await q.answer()
@@ -194,7 +194,7 @@ async def help_menu(_, m: Message):
                     help_msg, parse_mode=enums.ParseMode.MARKDOWN, quote=True
                 )
             await m.reply_photo(
-                photo=choice(StartPic),
+                photo=str(choice(StartPic)),
                 caption=help_msg,
                 parse_mode=enums.ParseMode.MARKDOWN,
                 reply_markup=help_kb,
@@ -203,7 +203,7 @@ async def help_menu(_, m: Message):
         else:
 
             await m.reply_photo(
-                photo=choice(StartPic),
+                photo=str(choice(StartPic)),
                 caption=f"Press the button below to get help for <i>{help_option}</i>",
                 reply_markup=InlineKeyboardMarkup(
                   [
@@ -241,7 +241,7 @@ Commands available:
             msg = "Contact me in PM to get the list of possible commands."
 
         await m.reply_photo(
-            photo=choice(StartPic),
+            photo=str(choice(StartPic)),
             caption=msg,
             reply_markup=keyboard,
         )

Powers/plugins/utils.py

@@ -16,8 +16,8 @@ from Powers.bot_class import Gojo
 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.http_helper import *
 from Powers.utils.extract_user import extract_user
+from Powers.utils.http_helper import *
 from Powers.utils.parser import mention_html
 
 
@@ -80,12 +80,13 @@ async def gdpr_remove(_, m: Message):
     )
     await m.stop_propagation()
 
-
-'''
 @Gojo.on_message(
     command("lyrics") & (filters.group | filters.private),
 )
 async def get_lyrics(_, m: Message):
+    if not is_genius_lyrics:
+        await m.reply_text("Genius lyrics api is missing")
+        return
     if len(m.text.split()) <= 1:
         await m.reply_text(text="Please check help on how to use this this command.")
         return
@@ -97,16 +98,24 @@ async def get_lyrics(_, m: Message):
         return
     song_name = query
     em = await m.reply_text(text=f"Finding lyrics for <code>{song_name}<code>...")
-    song = Song.find_song(query)
+    try:
+        song = genius_lyrics.search_song(query)
+    except Exception as e:
+        await em.delete()
+        await m.reply_text("Connection error try again after sometime")
+        return
+        
     if song:
         if song.lyrics:
-            reply = song.format()
+            reply = song.lyrics
+            reply = reply.split("\n",1)[1]
+            artist = song.artist
         else:
             reply = "Couldn't find any lyrics for that song!"
     else:
         reply = "Song not found!"
     try:
-        await em.edit_text(reply)
+        await em.edit_text(f"**{query.capitalize()} by {artist}**\n`{reply}`")
     except MessageTooLong:
         with BytesIO(str.encode(await remove_markdown_and_html(reply))) as f:
             f.name = "lyrics.txt"
@@ -115,7 +124,7 @@ async def get_lyrics(_, m: Message):
             )
         await em.delete()
     return
-'''
+
 
 
 @Gojo.on_message(
@@ -345,6 +354,7 @@ 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.
+• /lyrics `<song name>` : Find your song and give the lyrics of the song
 • /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.
 • /git `<username>`: Search for the user using github api!

Powers/utils/custom_filters.py

@@ -222,7 +222,7 @@ async def restrict_check_func(_, __, m: Message or CallbackQuery):
 
     user = await m.chat.get_member(m.from_user.id)
 
-    if user.can_restrict_members or user.status == CMS.OWNER:
+    if user.privileges.can_restrict_members or user.status == CMS.OWNER:
         status = True
     else:
         status = False

Powers/utils/extras.py

@@ -641,35 +641,52 @@ NO       NO   NONONO            NONO
 ]
 
 StartPic = [
-    "https://te.legra.ph/file/4bf3b88115068d41efadd.jpg",
-    "https://te.legra.ph/file/633bd27c1607fe98920b6.jpg",
-    "https://te.legra.ph/file/a740afb182b761db668ba.jpg",
-    "https://te.legra.ph/file/acb741a0f44faf1708a37.jpg",
-    "https://te.legra.ph/file/68d18ae5b2a4b67e793a4.jpg",
-    "https://te.legra.ph/file/43780c4a5c3071af3de3c.jpg",
-    "https://te.legra.ph/file/2f27c940f5e912c01aa63.jpg",
-    "https://te.legra.ph/file/83c61271b95fdf421a9a0.jpg",
-    "https://te.legra.ph/file/cd6aa9cbe621c7c3a12ea.jpg",
-    "https://te.legra.ph/file/122cf568eef282ad3472a.jpg",
-    "https://te.legra.ph/file/e32b2063a06deb34fc901.jpg",
-    "https://te.legra.ph/file/9ee77ea6bbe6f4ad13b65.jpg",
-    "https://te.legra.ph/file/23e0a389fb5df7900c686.jpg",
-    "https://te.legra.ph/file/fc0557000a350267adc0d.jpg",
-    "https://te.legra.ph/file/b3a46c16fa72f24dfec9f.jpg",
-    "https://te.legra.ph/file/6f80fcd24f20e950d9ed0.jpg",
-    "https://te.legra.ph/file/322466833973279848e60.jpg",
-    "https://te.legra.ph/file/cd381fd6f9960555664f6.jpg",
-    "https://te.legra.ph/file/c74c4f4be365971311510.jpg",
-    "https://te.legra.ph/file/afe46e0784ecd94fdef4a.jpg",
-    "https://te.legra.ph/file/6d4ae604c118cb49ab7ed.jpg",
-    "https://te.legra.ph/file/a7a78ff8d710583f28e72.jpg",
-    "https://te.legra.ph/file/fe9c620d294f4f47f4350.jpg",
-    "https://te.legra.ph/file/4cdf315e2925d8b4ef6ae.jpg",
-    "https://te.legra.ph/file/b480c0989f1e4a9ea63c7.jpg",
+    "https://te.legra.ph/file/98f45051aa26391dd9e67.jpg",
+    "https://te.legra.ph/file/674b41488884ae4def0cb.jpg",
+    "https://te.legra.ph/file/481d3286b4dffe97fd7b5.jpg",
+    "https://te.legra.ph/file/ffe9df5cfd9ec7d892dd6.jpg",
+    "https://te.legra.ph/file/e8d7fadf9d8729e272487.jpg",
+    "https://te.legra.ph/file/ae477d11bdab6c6307764.jpg",
+    "https://te.legra.ph/file/614b85854d28428019bc5.jpg",
+    "https://te.legra.ph/file/88b9e9cded8c5f449d7cc.jpg",
+    "https://te.legra.ph/file/080f3631e7885d593eb17.jpg",
+    "https://te.legra.ph/file/39b720b36106a381fd42b.jpg",
+    "https://te.legra.ph/file/e999d233a4a29a7ccc7fa.jpg",
+    "https://te.legra.ph/file/2baf1c80ee22ffe1d73fb.jpg",
+    "https://te.legra.ph/file/29133374260bf9e7786ee.jpg",
+    "https://te.legra.ph/file/0a57ea903409439fadd6a.jpg",
+    "https://te.legra.ph/file/326618accb5f9ab6d2e18.jpg",
+    "https://te.legra.ph/file/2a899cfc97a46bfd2feae.jpg",
+    "https://te.legra.ph/file/f0cd5bcebcd547a507dbf.jpg",
+    "https://te.legra.ph/file/8bcb57e91776e3ed63b60.jpg",
+    "https://te.legra.ph/file/3c569e93c426aa1941ea6.jpg",
+    "https://te.legra.ph/file/1751252a9f0483811e9b9.jpg",
+    "https://te.legra.ph/file/380b862e0248225cc1a45.jpg",
+    "https://te.legra.ph/file/f314f89640ce4b4118e9e.jpg",
     "https://te.legra.ph/file/37423e9680e3f79c9eb15.jpg",
     "https://te.legra.ph/file/4a9c4663d0120cff7cc82.jpg",
     "https://te.legra.ph/file/56d72d125005a16dba7b8.jpg",
     "https://te.legra.ph/file/c10f1b32adaf93c1a9fe1.jpg",
     "https://te.legra.ph/file/68c607517cca7d08e8910.jpg",
     "https://te.legra.ph/file/c86855e6d5a5668748ce1.jpg",
+    "https://te.legra.ph/file/b480c0989f1e4a9ea63c7.jpg",
+    "https://te.legra.ph/file/4cdf315e2925d8b4ef6ae.jpg",
+    "https://te.legra.ph/file/fe9c620d294f4f47f4350.jpg",
+    "https://te.legra.ph/file/6d4ae604c118cb49ab7ed.jpg",
+    "https://te.legra.ph/file/a7a78ff8d710583f28e72.jpg",
+    "https://te.legra.ph/file/a7a78ff8d710583f28e72.jpg",
+    "https://te.legra.ph/file/c74c4f4be365971311510.jpg",
+    "https://te.legra.ph/file/23e0a389fb5df7900c686.jpg",
+    "https://te.legra.ph/file/fc0557000a350267adc0d.jpg",
+    "https://te.legra.ph/file/cd381fd6f9960555664f6.jpg",
+    "https://te.legra.ph/file/322466833973279848e60.jpg",
+    "https://te.legra.ph/file/122cf568eef282ad3472a.jpg",
+    "https://te.legra.ph/file/cd6aa9cbe621c7c3a12ea.jpg",
+    "https://te.legra.ph/file/83c61271b95fdf421a9a0.jpg",
+    "https://te.legra.ph/file/2f27c940f5e912c01aa63.jpg",
+    "https://te.legra.ph/file/43780c4a5c3071af3de3c.jpg",
+    "https://te.legra.ph/file/68d18ae5b2a4b67e793a4.jpg",
+    "https://te.legra.ph/file/633bd27c1607fe98920b6.jpg",
+    "https://te.legra.ph/file/52d92a67f0c6ce0a9f89f.jpg",
+    "https://te.legra.ph/file/d91e7353b3803a8148bfc.jpg",
 ]

Powers/vars.py

@@ -37,6 +37,7 @@ class Config:
             default="1344569458",
         ).split(" ")
     ]
+    GENIUS_API_TOKEN = config("GENIUS_API")
     DB_URI = config("DB_URI", default="")
     DB_NAME = config("DB_NAME", default="")
     NO_LOAD = config("NO_LOAD", default="").split()
@@ -66,6 +67,7 @@ class Development:
     DB_URI = ""  # Your mongo DB URI
     DB_NAME = ""  # Your DB name
     NO_LOAD = []
+    GENIUS_API_TOKEN = ""
     PREFIX_HANDLER = ["!", "/"]
     SUPPORT_GROUP = "SUPPORT_GROUP"
     SUPPORT_CHANNEL = "SUPPORT_CHANNEL"

README.md

@@ -60,7 +60,7 @@ The Gojo Satoru is a powerful Group Management bot with awesome plugins and feat
 * Fully open-source
 * Frequently updated
   
-***Can be found on Telegram as __[@iamgojoof6eyes_bot](https://telegram.dog/iamgojoof6eyes_bot)__***
+***Can be found on Telegram as __[@GojoSuperbot](https://telegram.dog/GojoSuperbot)__***
   
 * Feel free to give ideas for next update. Drop your ideas [here](https://github.com/Gojo-Bots/Gojo_Satoru/discussions/new?category=ideas)
 

app.json

@@ -11,7 +11,7 @@
       "Anime"
     ],
     "repository": "https://github.com/Gojo-Bots/Gojo_Satoru",
-    "success_url": "https://t.me/iamgojoof6eyes_bot",
+    "success_url": "https://t.me/GojoSuperbot",
     "env": {
       "BOT_TOKEN": {
         "description": "Your telegram bot token, get from @Botfather in telegram.",
@@ -82,6 +82,11 @@
         "required": false,
         "value": " "
       },
+      "GENIUS_API" : {
+        "description": "Your Lyrics Genius Api Token. To fetch lyrics of songs",
+        "required": false,
+        "value": ""
+      },
       "WORKERS": {
         "description": "Number of workers to run the bot.",
         "required": false,

requirements.txt

@@ -4,11 +4,12 @@ anyio==3.6.2; python_full_version >= "3.6.2" and python_version >= "3.6"
 asyncio==3.4.3
 beautifulsoup4==4.11.1; python_full_version >= "3.6"
 cachetools==5.2.0; python_version >= "3.7" and python_version < "4.0"
-certifi==2022.6.15; python_version >= "3.7" and python_version < "4"
+certifi==2022.12.7; python_version >= "3.7" and python_version < "4"
 charset-normalizer==2.1.0; python_version >= "3.7" and python_version < "4" and python_full_version >= "3.6.0"
 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"
+lyricsgenius==3.0.1
 lxml==4.9.1; python_version >= "2.7" and python_full_version < "3.0.0" or python_full_version >= "3.5.0"
 prettyconf==2.2.1
 pyaes==1.6.1; python_version >= "3.6" and python_version < "4.0"