fixes

.gitignore

@@ -7,6 +7,7 @@ postgres-data/
 logs/
 Powers/local_vars.py
 .idea/
+scrapped/
 
 # Byte-compiled / optimized / DLL files
 __pycache__/

Powers/__init__.py

@@ -119,7 +119,7 @@ API_ID = Config.API_ID
 API_HASH = Config.API_HASH
 
 # General Config
-MESSAGE_DUMP = Config.MESSAGE_DUMP
+MESSAGE_DUMP = Config.MESSAGE_DUMP if Config.MESSAGE_DUMP else Config.OWNER_ID
 SUPPORT_GROUP = Config.SUPPORT_GROUP
 SUPPORT_CHANNEL = Config.SUPPORT_CHANNEL
 
@@ -151,6 +151,12 @@ else:
     shutil.rmtree(youtube_dir)
     mkdir(youtube_dir)
 
+scrap_dir = "./scrapped/"
+if not path.isdir(scrap_dir):
+    mkdir(scrap_dir)
+else:
+    shutil.rmtree(scrap_dir)
+    mkdir(scrap_dir)
 scheduler = AsyncIOScheduler(timezone=TIME_ZONE)
 
 

Powers/bot_class.py

@@ -70,8 +70,6 @@ class Gojo(Client):
         await load_support_users()
         await cache_support()
         LOGGER.info(f"Plugins Loaded: {cmd_list}")
-        scheduler.add_job(clean_my_db, 'cron', [
-                          self], hour=3, minute=0, second=0)
         if BDB_URI:
             scheduler.add_job(send_wishish, 'cron', [
                               self], hour=0, minute=0, second=0)

Powers/plugins/clean_db.py

@@ -1,68 +0,0 @@
-import time
-from traceback import format_exc
-
-from pyrogram.enums import ChatMemberStatus as CMS
-from pyrogram.errors import UserNotParticipant
-
-from Powers import LOGGER, MESSAGE_DUMP
-from Powers.bot_class import Gojo
-from Powers.database.approve_db import Approve
-from Powers.database.blacklist_db import Blacklist
-from Powers.database.chats_db import Chats
-from Powers.database.disable_db import Disabling
-from Powers.database.filters_db import Filters
-from Powers.database.flood_db import Floods
-from Powers.database.greetings_db import Greetings
-from Powers.database.notes_db import Notes, NotesSettings
-from Powers.database.pins_db import Pins
-from Powers.database.reporting_db import Reporting
-# from Powers.database.users_db import Users
-from Powers.database.warns_db import Warns, WarnSettings
-
-
-async def clean_my_db(c: Gojo, is_cmd=False, id=None):
-    to_clean = list()
-    chats_list = Chats.list_chats_by_id()
-    to_clean.clear()
-    start = time.time()
-    for chats in chats_list:
-        try:
-            stat = await c.get_chat_member(chat_id=chats, user_id=c.me.id)
-            if stat.status not in [CMS.MEMBER, CMS.ADMINISTRATOR, CMS.OWNER]:
-                to_clean.append(chats)
-        except UserNotParticipant:
-            to_clean.append(chats)
-        except Exception as e:
-            LOGGER.error(e)
-            LOGGER.error(format_exc())
-            if not is_cmd:
-                return e
-            else:
-                to_clean.append(chats)
-    for i in to_clean:
-        Approve(i).clean_approve()
-        Blacklist(i).clean_blacklist()
-        Chats.remove_chat(i)
-        Disabling(i).clean_disable()
-        Filters().rm_all_filters(i)
-        Floods().rm_flood(i)
-        Greetings(i).clean_greetings()
-        Notes().rm_all_notes(i)
-        NotesSettings().clean_notes(i)
-        Pins(i).clean_pins()
-        Reporting(i).clean_reporting()
-        Warns(i).clean_warn()
-        WarnSettings(i).clean_warns()
-    x = len(to_clean)
-    txt = f"#INFO\n\nCleaned db:\nTotal chats removed: {x}"
-    to_clean.clear()
-    nums = time.time()-start
-    if is_cmd:
-        txt += f"\nClean type: Forced\nInitiated by: {(await c.get_users(user_ids=id)).mention}"
-        txt += f"\nClean type: Manual\n\tTook {round(nums,2)} seconds to complete the process"
-        await c.send_message(chat_id=MESSAGE_DUMP, text=txt)
-        return txt
-    else:
-        txt += f"\nClean type: Auto\n\tTook {round(nums,2)} seconds to complete the process"
-        await c.send_message(chat_id=MESSAGE_DUMP, text=txt)
-        return txt

Powers/plugins/dev.py

@@ -24,7 +24,6 @@ from Powers.database import MongoDB
 from Powers.database.chats_db import Chats
 from Powers.database.support_db import SUPPORTS
 from Powers.database.users_db import Users
-from Powers.plugins.scheduled_jobs import clean_my_db
 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
@@ -738,23 +737,6 @@ async def forward_type_broadcast(c: Gojo, m: Message):
     return
 
 
-@Gojo.on_message(command(["cleandb","cleandatabase"],sudo_cmd=True))
-async def cleeeen(c:Gojo,m:Message):
-    x = await m.reply_text("Cleaning the database...")
-    try:
-        z = await clean_my_db(c,True,m.from_user.id)
-        try:
-            await x.delete()
-        except Exception:
-            pass
-        await m.reply_text(z)
-        return
-    except Exception as e:
-        await m.reply_text(e)
-        await x.delete()
-        LOGGER.error(e)
-        LOGGER.error(format_exc())
-        return
 
 __PLUGIN__ = "devs"
 

Powers/plugins/flood.py

@@ -436,8 +436,11 @@ async def flood_watcher(c: Gojo, m: Message):
         if y-x <= within:
             action = action.split("_")
             if len(action) == 2:
-                to_do = action[0]
-                for_tim = int(action[1].replace("min",""))
+                try:
+                    to_do = action[0]
+                    for_tim = int(action[1].replace("min",""))
+                except:
+                    for_tim = 30
                 for_how_much = datetime.now() + timedelta(minutes=for_tim)
                 if to_do == "ban":
                     try:
@@ -452,7 +455,7 @@ async def flood_watcher(c: Gojo, m: Message):
                                 ],
                             ],
                         )
-                        txt = "Don't dare to spam here if I am around! Nothing can escape my 6 eyes\nAction: Baned\nReason: Spaming"
+                        txt = f"Don't dare to spam here if I am around! Nothing can escape my 6 eyes\nAction: Baned\nReason: Spaming\nUntril: {for_how_much}"
                         await m.reply_animation(
                             animation=str(choice(BAN_GIFS)),
                             caption=txt,
@@ -497,7 +500,7 @@ async def flood_watcher(c: Gojo, m: Message):
                                 ],
                             ],
                         )
-                        txt = "Don't dare to spam here if I am around! Nothing can escape my 6 eyes\nAction: Muted\nReason: Spaming"
+                        txt = f"Don't dare to spam here if I am around! Nothing can escape my 6 eyes\nAction: Muted\nReason: Spaming\nUntil: {for_how_much}"
                         await m.reply_animation(
                             animation=str(choice(MUTE_GIFS)),
                             caption=txt,
@@ -570,7 +573,7 @@ async def flood_watcher(c: Gojo, m: Message):
                 
             elif action == "kick":
                 try:
-                    await m.chat.ban_member(u_id, datetime.now()+timedelta(seconds=10))
+                    await m.chat.ban_member(u_id, datetime.now()+timedelta(seconds=1))
                     txt = "Don't dare to spam here if I am around! Nothing can escape my 6 eyes\nAction: kicked\nReason: Spaming"
                     await m.reply_animation(
                         animation=str(choice(KICK_GIFS)),

Powers/plugins/greetings.py

@@ -239,7 +239,7 @@ async def cleannnnn(_, m: Message):
 @Gojo.on_chat_member_updated(filters.group, group=69)
 async def member_has_joined(c: Gojo, member: ChatMemberUpdated):
 
-    if member.new_chat_member.status not in {CMS.BANNED, CMS.LEFT, CMS.RESTRICTED}:
+    if member.old_chat_member.status not in {CMS.MEMBER, CMS.OWNER, CMS.ADMINISTRATOR}:
         pass
     else:
         return
@@ -337,7 +337,7 @@ async def member_has_joined(c: Gojo, member: ChatMemberUpdated):
 @Gojo.on_chat_member_updated(filters.group, group=99)
 async def member_has_left(c: Gojo, member: ChatMemberUpdated):
 
-    if member.old_chat_member.status == CMS.LEFT:
+    if member.old_chat_member.status not in [CMS.LEFT, CMS.BANNED, CMS.RESTRICTED]:
         pass
     else:
         return

Powers/plugins/scheduled_jobs.py

@@ -1,74 +1,10 @@
-import time as TIME
-from traceback import format_exc
-
 from apscheduler.schedulers.asyncio import AsyncIOScheduler
 from pyrogram import Client
-from pyrogram.enums import ChatMemberStatus as CMS
-from pyrogram.errors import UserNotParticipant
 
-from Powers import BDB_URI, LOGGER, MESSAGE_DUMP, TIME_ZONE
-from Powers.database.approve_db import Approve
-from Powers.database.blacklist_db import Blacklist
+from Powers import BDB_URI, TIME_ZONE
 from Powers.database.chats_db import Chats
-from Powers.database.disable_db import Disabling
-from Powers.database.filters_db import Filters
-from Powers.database.flood_db import Floods
-from Powers.database.greetings_db import Greetings
-from Powers.database.notes_db import Notes, NotesSettings
-from Powers.database.pins_db import Pins
-from Powers.database.reporting_db import Reporting
-# from Powers.database.users_db import Users
-from Powers.database.warns_db import Warns, WarnSettings
-
-
-async def clean_my_db(c:Client,is_cmd=False, id=None):
-    to_clean = list()
-    chats_list = Chats.list_chats_by_id()
-    to_clean.clear()
-    start = TIME.time()
-    for chats in chats_list:
-        try:
-            stat = await c.get_chat_member(chat_id=chats,user_id=c.me.id)
-            if stat.status not in [CMS.MEMBER, CMS.ADMINISTRATOR, CMS.OWNER]:
-                to_clean.append(chats)
-        except UserNotParticipant:
-            to_clean.append(chats)
-        except Exception as e:
-            LOGGER.error(e)
-            LOGGER.error(format_exc())
-            if not is_cmd:
-                return e
-            else:
-                to_clean.append(chats)
-    for i in to_clean:
-        Approve(i).clean_approve()
-        Blacklist(i).clean_blacklist()
-        Chats.remove_chat(i)
-        Disabling(i).clean_disable()
-        Filters().rm_all_filters(i)
-        Floods().rm_flood(i)
-        Greetings(i).clean_greetings()
-        Notes().rm_all_notes(i)
-        NotesSettings().clean_notes(i)
-        Pins(i).clean_pins()
-        Reporting(i).clean_reporting()
-        Warns(i).clean_warn()
-        WarnSettings(i).clean_warns()
-    x = len(to_clean)
-    txt = f"#INFO\n\nCleaned db:\nTotal chats removed: {x}"
-    to_clean.clear()
-    nums = TIME.time()-start
-    if is_cmd:
-        txt += f"\nClean type: Forced\nInitiated by: {(await c.get_users(user_ids=id)).mention}"
-        txt += f"\nClean type: Manual\n\tTook {round(nums,2)} seconds to complete the process"
-        await c.send_message(chat_id=MESSAGE_DUMP,text=txt)
-        return txt
-    else:
-        txt += f"\nClean type: Auto\n\tTook {round(nums,2)} seconds to complete the process"
-        await c.send_message(chat_id=MESSAGE_DUMP,text=txt)
-        return txt
-    
 
+# from Powers.database.users_db import Users
 if BDB_URI:
     from Powers.plugins import bday_cinfo, bday_info
 

Powers/plugins/start.py

@@ -222,7 +222,6 @@ async def help_menu(c: Gojo, m: Message):
                 f"No help_msg found for help_option - {help_option}!!")
             return
 
-
         if m.chat.type == ChatType.PRIVATE:
             if len(help_msg) >= 1026:
                 await m.reply_text(
@@ -377,8 +376,8 @@ async def get_module_info(c: Gojo, q: CallbackQuery):
         caption, kb = await get_divided_msg(f"plugins.{module}", back_to_do="commands")
         await q.edit_message_caption(
             caption,
-            parse_mode=enums.ParseMode.MARKDOWN,
-            reply_markup=kb
+            enums.ParseMode.MARKDOWN,
+            kb
         )
     await q.answer()
     return

Powers/plugins/web_con.py

@@ -34,7 +34,7 @@ from Powers.utils.web_scrapper import INSTAGRAM, SCRAP_DATA
 #         await m.reply_text("Reply to a video or audio file")
 #         return
 #     try:
-#         XnX = await m.reply_text("⏳")
+#         to_edit = await m.reply_text("⏳")
 #         URL = "https://api.audd.io/"
 #         sizee = (await get_file_size(reply)).split()
 #         if (int(sizee[0]) <= 30 and sizee[1] == "mb") or sizee[1] == "kb":
@@ -55,10 +55,10 @@ from Powers.utils.web_scrapper import INSTAGRAM, SCRAP_DATA
 #         #     }
 #         #    result = resp_post(URL,data=BASE_AUDD)
 #         else:
-#             await XnX.edit_text("File size too big\nI can only fetch file of size upto 30 mbs for now")
+#             await to_edit.edit_text("File size too big\nI can only fetch file of size upto 30 mbs for now")
 #             return
 #         if result.status_code != 200:
-#             await XnX.edit_text(f"{result.status_code}:{result.text}")
+#             await to_edit.edit_text(f"{result.status_code}:{result.text}")
 #             return
 #         result = result.json()
 #         data = result["result"]
@@ -93,11 +93,11 @@ from Powers.utils.web_scrapper import INSTAGRAM, SCRAP_DATA
 #         if is_genius_lyrics:
 #             g_k = [IKB("📝 Lyrics",f"lyrics_{Title}:{Artist}")]
 #             kb.append(g_k)
-#         await XnX.delete()
+#         await to_edit.delete()
 #         os.remove(fpath)
 #         await m.reply_photo(photo,caption=cap,reply_markup=IKM(kb))
 #     except Exception as e:
-#         await XnX.delete()
+#         await to_edit.delete()
 #         await m.reply_text(f"Error\n{e}")
 #         try:
 #             os.remove(fpath)
@@ -209,7 +209,7 @@ async def remove_background(c: Gojo, m: Message):
     elif reply.sticker and (reply.sticker.is_video or reply.sticker.is_animated):
         await m.reply_text("Reply to normal sticker to remove it's background")
         return
-    XnX = await m.reply_text("⏳")
+    to_edit = await m.reply_text("⏳")
     URL = "https://api.remove.bg/v1.0/removebg"
     if reply.sticker:
         filee = await reply.download()
@@ -220,7 +220,7 @@ async def remove_background(c: Gojo, m: Message):
     Data = {'size':'auto'}
     Headers = {'X-Api-Key':RMBG}
     result = resp_post(URL,files=finfo,data=Data,headers=Headers)
-    await XnX.delete()
+    await to_edit.delete()
     contentType = result.headers.get("content-type")
     if result.status_code != 200:
         await m.reply_text(f"{result.status_code}:{result.text}")
@@ -260,16 +260,16 @@ async def song_down_up(c: Gojo, m: Message):
         query = splited
     else:
         query = _id
-    XnX = await m.reply_text("⏳")
+    to_edit = await m.reply_text("⏳")
     try:
         await youtube_downloader(c,m,query, "a")
-        await XnX.delete()
+        await to_edit.delete()
         return
     except KeyError:
-        await XnX.edit_text(f"Failed to find any result")
+        await to_edit.edit_text(f"Failed to find any result")
         return
     except Exception as e:
-        await XnX.edit_text(f"Got an error\n{e}")
+        await to_edit.edit_text(f"Got an error\n{e}")
         LOGGER.error(e)
         LOGGER.error(format_exc())
         return
@@ -286,16 +286,16 @@ async def video_down_up(c: Gojo, m: Message):
         query = splited
     else:
         query = _id
-    XnX = await m.reply_text("⏳")
+    to_edit = await m.reply_text("⏳")
     try:
         await youtube_downloader(c,m,query,"v")
-        await XnX.delete()
+        await to_edit.delete()
         return
     except KeyError:
-        await XnX.edit_text(f"Failed to find any result")
+        await to_edit.edit_text(f"Failed to find any result")
         return
     except Exception as e:
-        await XnX.edit_text(f"Got an error\n{e}")
+        await to_edit.edit_text(f"Got an error\n{e}")
         LOGGER.error(e)
         LOGGER.error(format_exc())
         return

Powers/utils/sticker_help.py

@@ -16,6 +16,7 @@ from pyrogram.types import InlineKeyboardMarkup as ikm
 from pyrogram.types import Message
 from unidecode import unidecode
 
+from Powers import scrap_dir
 from Powers.bot_class import Gojo
 from Powers.utils.string import encode_decode
 
@@ -204,7 +205,7 @@ async def resize_file_to_sticker_size(file_path: str, length: int = 512, width:
     else:
         im.thumbnail(STICKER_DIMENSIONS)
 
-    file_pathh = "./downloads/resized.png"
+    file_pathh = f"{scrap_dir}r{str(time()).replace('.','_')}.png"
     im.save(file_pathh)
     os.remove(file_path)
     return file_pathh

Powers/utils/web_helpers.py

@@ -8,11 +8,13 @@ from pyrogram.types import InlineKeyboardMarkup as IKM
 from pyrogram.types import Message
 from pytube import YouTube, extract
 from youtubesearchpython.__future__ import VideosSearch
+from yt_dlp import YoutubeDL
 
 from Powers import youtube_dir
-from Powers.bot_class import LOGGER, MESSAGE_DUMP, Gojo
+from Powers.bot_class import LOGGER, Gojo
 from Powers.utils.http_helper import *
 from Powers.utils.sticker_help import resize_file_to_sticker_size
+from Powers.utils.web_scrapper import SCRAP_DATA
 
 backUP = "https://artfiles.alphacoders.com/160/160160.jpeg"
 
@@ -174,16 +176,54 @@ async def song_search(query, max_results=1):
             pass
     return yt_dict
 
+song_opts = {
+    "format": "bestaudio",
+    "addmetadata": True,
+    "key": "FFmpegMetadata",
+    "prefer_ffmpeg": True,
+    "geo_bypass": True,
+    "nocheckcertificate": True,
+    "postprocessors": [
+        {
+            "key": "FFmpegExtractAudio",
+            "preferredcodec": "mp3",
+            "preferredquality": "480",
+        }
+    ],
+    "outtmpl": "%(id)s",
+    "quiet": True,
+    "logtostderr": False,
+}
 
-async def youtube_downloader(c: Gojo, m: Message, query: str, is_direct: bool, type_: str):
+video_opts = {
+        "format": "best",
+        "addmetadata": True,
+        "key": "FFmpegMetadata",
+        "prefer_ffmpeg": True,
+        "geo_bypass": True,
+        "nocheckcertificate": True,
+        "postprocessors": [
+            {
+                "key": "FFmpegVideoConvertor",
+                "preferedformat": "mp4",
+            }
+        ],
+        "outtmpl": "%(id)s.mp4",
+        "quiet": True,
+        "logtostderr": False,
+    }
+
+async def youtube_downloader(c: Gojo, m: Message, query: str, type_: str):
     if type_ == "a":
-        # opts = song_opts
+        opts = song_opts
         video = False
         song = True
+        ext = "mp3"
     elif type_ == "v":
-        # opts = video_opts
+        opts = video_opts
         video = True
         song = False
+        ext = "mp4"
     # ydl = yt_dlp.YoutubeDL(opts)
     dicti = await song_search(query, 1)
     if not dicti and type(dicti) != str:
@@ -209,15 +249,22 @@ async def youtube_downloader(c: Gojo, m: Message, query: str, is_direct: bool, t
     vid_dur = get_duration_in_sec(dicti["DURATION"])
     published_on = dicti["published"]
     if thumb:
-        thumb_ = await c.send_photo(MESSAGE_DUMP, thumb)
+        try:
+            thumb = SCRAP_DATA(thumb).get_images()
+            thumb = await resize_file_to_sticker_size(thumb[0], 320, 320)
+        except Exception as e:
+            LOGGER.error(e)
+            LOGGER.error(format_exc())
+            LOGGER.info("Using back up image as thumbnail")
+            thumb = SCRAP_DATA(backUP).get_images()
+            thumb = await resize_file_to_sticker_size(thumb[0], 320, 320)
+            
     else:
-        thumb_ = await c.send_photo(MESSAGE_DUMP, backUP)
+        thumb = SCRAP_DATA(backUP).get_images()
+        thumb = await resize_file_to_sticker_size(thumb[0], 320, 320)
+
     # FILE = ydl.extract_info(query,download=video)
     url = query
-    thumb = await thumb_.download()
-    if not thumb:
-        thumb = await resize_file_to_sticker_size(thumb, 320, 320)
-    await thumb_.delete()
     cap = f"""
 ⤷ Name: `{f_name}`
 ⤷ Duration: `{dura}`
@@ -237,23 +284,41 @@ Downloaded by: @{c.me.username}
             ]
         ]
     )
+
+    def get_my_file(opts, ext):
+        try:
+            with YoutubeDL(opts) as ydl:
+                ydl.download([query])
+                info = ydl.extract_info(query, False)
+            file_name = ydl.prepare_filename(info)
+            if len(file_name.rsplit(".", 1)) == 2:
+                pass
+            else:
+                file_name = f"{file_name}.{ext}"
+            new = info['title'].replace('/','|').replace('\\','|')
+            new_file = f"{youtube_dir}{new}.{ext}"
+            os.rename(file_name, new_file)
+            return True, new_file
+        except Exception as e:
+            return False, str(e)
+
     if song:
+        success, file_path = get_my_file(opts, ext)
+        if not success:
+            await m.reply_text(file_path)
+            return
         msg = await m.reply_text(upload_text)
-        audio_stream = yt.streams.filter(only_audio=True).first()
-        f_path = audio_stream.download()
-        file_path = f"{youtube_dir}{f_name.strip()}.mp3"
-        os.rename(f_path, file_path)
-
         await m.reply_audio(file_path, caption=cap, reply_markup=kb, duration=vid_dur, thumb=thumb, title=f_name,performer=uploader, progress=progress, progress_args=(msg, time.time(), upload_text))
+        await msg.delete()
         os.remove(file_path)
-        os.remove(thumb)
         return
     elif video:
-        video_stream = yt.streams.get_highest_resolution()
-        file_path = video_stream.download()
-        new_file_path = f"{youtube_dir}{f_name}.mp4"
-        os.rename(file_path, new_file_path)
+        success, file_path = get_my_file(opts, ext)
+        if not success:
+            await m.reply_text(file_path)
+            return
+        msg = await m.reply_text(upload_text)
         await m.reply_video(file_path, caption=cap, reply_markup=kb, duration=vid_dur, thumb=thumb, progress=progress, progress_args=(msg, time.time(), upload_text))
-        os.remove(new_file_path)
-        os.remove(thumb)
+        await msg.delete()
+        os.remove(file_path)
         return

Powers/utils/web_scrapper.py

@@ -1,6 +1,5 @@
 import os
 import re
-import time
 from typing import List
 
 import httpx
@@ -23,21 +22,22 @@ class SCRAP_DATA:
 
     def __init__(self, urls: List[str] or str) -> None:
         self.urls = urls
-        self.path = "./scrapped/"
+        self.path = scrap_dir
         if not os.path.isdir(self.path):
-            os.makedirs("./scrapped/")
+            os.makedirs(self.path)
 
     def get_images(self) -> list:
         images = []
         if isinstance(self.urls, str):
             requested = httpx.get(self.urls)
             try:
-                name = self.path + f"img_{time.time()}.jpg"
+                name = self.path + f"img_{str(time()).replace('.','_')}.jpg"
                 with open(name, "wb") as f:
                     f.write(requested.content)
                 images.append(name)
             except Exception as e:
                 LOGGER.error(e)
+                LOGGER.error(format_exc())
                 requested.close()
         else:
             for i in self.urls:
@@ -46,11 +46,12 @@ class SCRAP_DATA:
                 else:
                     continue
                 try:
-                    name = self.path + f"img_{time.time()}.jpg"
+                    name = self.path + f"img_{str(time()).replace('.','_')}.jpg"
                     with open(name, "wb") as f:
                         f.write(requested.content)
                     images.append(name)
                 except Exception as e:
+                    LOGGER.error(format_exc())
                     LOGGER.error(e)
                     requested.close()
                     continue
@@ -64,12 +65,13 @@ class SCRAP_DATA:
             else:
                 return []
             try:
-                name = self.path + f"vid_{time.time()}.mp4"
+                name = self.path + f"vid_{str(time()).replace('.','_')}.mp4"
                 with open(name, "wb") as f:
                     f.write(requested.content)
                 videos.append(name)
             except Exception as e:
                 LOGGER.error(e)
+                LOGGER.error(format_exc())
                 requested.close()
         else:
             for i in self.urls:
@@ -78,12 +80,13 @@ class SCRAP_DATA:
                 else:
                     continue
                 try:
-                    name = self.path + f"vid_{time.time()}.mp4"
+                    name = self.path + f"vid_{str(time()).replace('.','_')}.mp4"
                     with open(name, "wb") as f:
                         f.write(requested.content)
                     videos.append(name)
                 except Exception as e:
                     LOGGER.error(e)
+                    LOGGER.error(format_exc())
                     requested.close()
                     continue
         return videos

Powers/vars.py

@@ -15,7 +15,7 @@ class Config:
     API_ID = int(config("API_ID", default="123"))
     API_HASH = config("API_HASH", default=None)
     OWNER_ID = int(config("OWNER_ID", default=1344569458))
-    MESSAGE_DUMP = int(config("MESSAGE_DUMP"))
+    MESSAGE_DUMP = int(config("MESSAGE_DUMP", default = "0")) # if not given owner id will be msg dump :)
     DEV_USERS = [
         int(i)
         for i in config(
@@ -65,7 +65,7 @@ class Development:
     API_ID = 12345  # Your APP_ID from Telegram
     API_HASH = "YOUR API HASH"  # Your APP_HASH from Telegram
     OWNER_ID = 1344569458  # Your telegram user id defult to mine
-    MESSAGE_DUMP = -100845454887  # Your Private Group ID for logs
+    MESSAGE_DUMP = 0  # Your Private Group ID for logs if not passed your owner id will be msg dump
     DEV_USERS = []
     SUDO_USERS = []
     WHITELIST_USERS = []

README.md

@@ -39,7 +39,7 @@ Not a particular inspiration, inspired by many bots
 Mainly:
 
 * [Alita_Robot](https://github.com/divideprojects/Alita_Robot)
-
+* [WilliamButcherBot](https://github.com/TheHamkerCat/WilliamButcherBot)
 
 ---------
 
@@ -173,7 +173,7 @@ If all works well, the bot should send a message to the MESSAGE_DUMP Group!--->
 
 `DB_URI` Your [MongoDB](https://www.mongodb.com/) connection string.
 
-`MESSAGE_DUMP`: Event logs channel where the bot will send updates. Note that it should start with `-100`.
+`MESSAGE_DUMP`: Event logs channel where the bot will send updates. Note that it should start with `-100`. If you don't give it or pass 0 in it your owner id will be the message dump for the bot.
 </details>
 
 
@@ -289,6 +289,8 @@ Some special thanks to the person/repo who/which helped and motivated me to crea
 
 * [Alita_Robot](https://github.com/divideprojects/Alita_Robot) for base code.
 
+* [WilliamButcherBot](https://github.com/TheHamkerCat/WilliamButcherBot) for few plugins inspirations.
+
 ---------
 
 # Powered by [ɢօʝօ ɮօȶֆ](https://github.com/Gojo-Bots)