Upload 6 files

megadl/caption.py

@@ -0,0 +1,13 @@
+# (c) Asm Safone
+# A Part of MegaDL-Bot <https://github.com/AsmSafone/MegaDL-Bot>
+
+from config import Config
+from pyrogram import Client, filters
+
+@Client.on_message(filters.reply & filters.text & filters.private & ~filters.edited)
+async def caption(bot, message):
+    file = message.reply_to_message
+    if file.media and not file.video_note and not file.sticker:
+        await file.copy(message.chat.id, caption=message.text)
+    else:
+        return

megadl/commands.py

@@ -0,0 +1,192 @@
+# (c) Asm Safone
+# A Part of MegaDL-Bot <https://github.com/AsmSafone/MegaDL-Bot>
+
+import os
+import math
+import time
+import shutil
+import asyncio
+import logging
+from pyrogram import Client, filters
+from pyrogram.errors import FloodWait, UserNotParticipant
+from pyrogram.types import Message, InlineKeyboardMarkup, InlineKeyboardButton
+from megadl.forcesub import handle_force_subscribe
+from config import Config, TEXT
+
+
+@Client.on_message(filters.command("help") & filters.private & filters.incoming)
+async def help(bot, message, cb=False):
+    if Config.UPDATES_CHANNEL:
+      fsub = await handle_force_subscribe(bot, message)
+      if fsub == 400:
+        return
+    me = await bot.get_me()
+    button = [[
+        InlineKeyboardButton(f'🏠 HOME', callback_data='back'),
+        InlineKeyboardButton(f'ABOUT 👨', callback_data='about')
+        ],[
+        InlineKeyboardButton(f'📦 SOURCE', url='https://github.com/imseldrith/MegaDL-Bot'),
+        InlineKeyboardButton(f'CLOSE 🔐', callback_data='close')
+        ]]
+    reply_markup = InlineKeyboardMarkup(button)
+    if cb:
+        await message.message.edit(
+            text=TEXT.HELP_USER.format(bot_name=me.mention(style='md')),
+            disable_web_page_preview=True,
+            reply_markup=reply_markup
+        )
+    else:
+        await message.reply_text(
+            text=TEXT.HELP_USER.format(bot_name=me.mention(style='md')),
+            disable_web_page_preview=True,
+            reply_markup=reply_markup,
+            quote=True
+        )
+
+
+@Client.on_message(filters.command("start") & filters.private & filters.incoming)
+async def start(bot, message, cb=False):
+    if Config.UPDATES_CHANNEL:
+      fsub = await handle_force_subscribe(bot, message)
+      if fsub == 400:
+        return
+    me = await bot.get_me()
+    owner = await bot.get_users(Config.OWNER_ID)
+    owner_username = owner.username if owner.username else 'AsmSafone'
+    button = [[
+        InlineKeyboardButton(f'💡 HELP', callback_data='help'),
+        InlineKeyboardButton(f'ABOUT 👨', callback_data="about")
+        ],[
+        InlineKeyboardButton(f'📦 SOURCE', url='https://github.com/imseldrith/MegaDL-Bot'),
+        InlineKeyboardButton(f'CLOSE 🔐', callback_data="close")
+        ]]
+    reply_markup = InlineKeyboardMarkup(button)
+    if cb:
+        await message.message.edit(
+            text=TEXT.START_TEXT.format(user_mention=message.from_user.mention, bot_name=me.mention(style='md'), bot_owner=owner.mention(style="md")), 
+            disable_web_page_preview=True,
+            reply_markup=reply_markup
+        )
+    else:
+        await message.reply_text(
+            text=TEXT.START_TEXT.format(user_mention=message.from_user.mention, bot_name=me.mention(style='md'), bot_owner=owner.mention(style="md")), 
+            disable_web_page_preview=True,
+            reply_markup=reply_markup,
+            quote=True
+        ) 
+
+
+@Client.on_message(filters.command("about") & filters.private & filters.incoming)
+async def about(bot, message, cb=False):
+    if Config.UPDATES_CHANNEL:
+      fsub = await handle_force_subscribe(bot, message)
+      if fsub == 400:
+        return
+    me = await bot.get_me()
+    button = [[
+        InlineKeyboardButton(f'🏠 HOME', callback_data='back'),
+        InlineKeyboardButton(f'HELP 💡', callback_data='help')
+        ],[
+        InlineKeyboardButton(f'📦 SOURCE', url='https://github.com/imseldrith/MegaDL-Bot'),
+        InlineKeyboardButton(f'CLOSE 🔐', callback_data="close")
+        ]]
+    reply_markup = InlineKeyboardMarkup(button)
+    if cb:
+        await message.message.edit(
+            text=TEXT.ABOUT.format(bot_name=me.mention(style='md')),
+            disable_web_page_preview=True,
+            reply_markup=reply_markup
+        )
+    else:
+        await message.reply_text(
+            text=TEXT.ABOUT.format(bot_name=me.mention(style='md')),
+            disable_web_page_preview=True,
+            reply_markup=reply_markup,
+            quote=True
+        )
+
+
+@Client.on_callback_query(filters.regex('^help$'))
+async def help_cb(bot, message):
+    await message.answer()
+    await help(bot, message, True)
+
+
+@Client.on_callback_query(filters.regex('^close$'))
+async def close_cb(bot, message):
+    await message.message.delete()
+    await message.message.reply_to_message.delete()
+
+
+@Client.on_callback_query(filters.regex('^back$'))
+async def back_cb(bot, message):
+    await message.answer()
+    await start(bot, message, True)
+
+
+@Client.on_callback_query(filters.regex('^about$'))
+async def about_cb(bot, message):
+    await message.answer()
+    await about(bot, message, True)
+
+
+@Client.on_callback_query(filters.regex('^refreshmeh$'))
+async def refreshmeh_cb(bot, message):
+    if Config.UPDATES_CHANNEL:
+        invite_link = await bot.create_chat_invite_link(int(Config.UPDATES_CHANNEL))
+        try:
+            user = await bot.get_chat_member(int(Config.UPDATES_CHANNEL), message.from_user.id)
+            if user.status == "kicked":
+                await message.message.edit(
+                    text="Sorry Sir, You are Banned. Contact My [Support Group](https://t.me/url_upload_bots).",
+                    parse_mode="markdown",
+                    disable_web_page_preview=True
+                )
+                return
+        except UserNotParticipant:
+            await message.message.edit(
+                text="**You Still Didn't Join ☹️, Please Join My Updates Channel To Use Me!**\n\nDue to Overload, Only Channel Subscribers Can Use Me!",
+                reply_markup=InlineKeyboardMarkup(
+                    [
+                        [
+                            InlineKeyboardButton("🤖 Join Updates Channel 🤖", url=invite_link.invite_link)
+                        ],
+                        [
+                            InlineKeyboardButton("🔄 Refresh 🔄", callback_data="refreshmeh")
+                        ]
+                    ]
+                ),
+                parse_mode="markdown"
+            )
+            return
+        except Exception:
+            await message.message.edit(
+                text="Something Went Wrong. Contact My [Support Group](https://t.me/url_upload_bots).",
+                parse_mode="markdown",
+                disable_web_page_preview=True
+            )
+            return
+    await message.answer()
+    await start(bot, message, True)
+
+
+
+@Client.on_callback_query(filters.regex('^cancel_mega$'))
+async def cancel_cb(bot, message):
+    basedir = Config.DOWNLOAD_LOCATION
+    userpath = str(message.from_user.id)
+    try:
+        await message.answer(
+            "Trying To Cancel... 🤒",
+                show_alert=True
+            )
+        await asyncio.sleep(5)
+        shutil.rmtree(basedir + "/" + userpath)
+        await message.message.delete()
+        await message.message.reply_text("**Process Cancelled By User 😡!**", reply_to_message_id=message.message_id)
+    except Exception as e:
+        await print(e)
+        await message.answer(
+            "Can't Cancel Right Now! 😡",
+                show_alert=True
+            )

megadl/forcesub.py

@@ -0,0 +1,54 @@
+# (c) Asm Safone
+# A Part of MegaDL-Bot <https://github.com/AsmSafone/MegaDL-Bot>
+
+import asyncio
+from config import Config
+from pyrogram import Client
+from pyrogram.errors import FloodWait, UserNotParticipant
+from pyrogram.types import Message, InlineKeyboardMarkup, InlineKeyboardButton
+
+
+async def handle_force_subscribe(bot, message):
+    try:
+        invite_link = await bot.create_chat_invite_link(int(Config.UPDATES_CHANNEL))
+    except FloodWait as e:
+        await asyncio.sleep(e.x)
+        return 400
+    try:
+        user = await bot.get_chat_member(int(Config.UPDATES_CHANNEL), message.from_user.id)
+        if user.status == "kicked":
+            await bot.send_message(
+                chat_id=message.from_user.id,
+                text="Sorry Sir, You are Banned. Contact My [Support Group](https://t.me/AsmSupport).",
+                parse_mode="markdown",
+                disable_web_page_preview=True,
+                reply_to_message_id=message.message_id,
+            )
+            return 400
+    except UserNotParticipant:
+        await bot.send_message(
+            chat_id=message.from_user.id,
+            text="**Please Join My Updates Channel To Use Me!**\n\nDue to Overload, Only Channel Subscribers Can Use Me!",
+            reply_markup=InlineKeyboardMarkup(
+                [
+                    [
+                        InlineKeyboardButton("🤖 Join Updates Channel 🤖", url=invite_link.invite_link)
+                    ],
+                    [
+                        InlineKeyboardButton("🔄 Refresh 🔄", callback_data="refreshmeh")
+                    ]
+                ]
+            ),
+            parse_mode="markdown",
+            reply_to_message_id=message.message_id,
+        )
+        return 400
+    except Exception:
+        await bot.send_message(
+            chat_id=message.from_user.id,
+            text="Something Went Wrong. Contact My [Support Group](https://t.me/AsmSupport).",
+            parse_mode="markdown",
+            disable_web_page_preview=True,
+            reply_to_message_id=message.message_id,
+        )
+        return 400

megadl/mega_dl.py

@@ -0,0 +1,197 @@
+# (c) Asm Safone
+# A Part of MegaDL-Bot <https://github.com/AsmSafone/MegaDL-Bot>
+
+import os
+import time
+import shutil
+import logging
+import filetype
+import subprocess
+import moviepy.editor
+from mega import Mega
+from config import Config
+from posixpath import join
+from functools import partial
+from genericpath import isfile
+from hurry.filesize import size
+from asyncio import get_running_loop
+from pyrogram import Client, filters
+from megadl.progress import progress_for_pyrogram
+from megadl.forcesub import handle_force_subscribe
+from pyrogram.types import InlineKeyboardMarkup, InlineKeyboardButton
+
+# Logging
+
+logging.basicConfig(level=logging.INFO,
+                    format='%(asctime)s - %(name)s - %(levelname)s - %(message)s')
+
+# Mega Client
+mega = Mega()
+m = mega.login()
+
+# Temp Download Directory
+basedir = Config.DOWNLOAD_LOCATION
+
+# Telegram's Max File Size
+TG_MAX_FILE_SIZE = Config.TG_MAX_SIZE
+
+# Automatic Url Detection
+MEGA_REGEX = (r"^((?:https?:)?\/\/)"
+              r"?((?:www)\.)"
+              r"?((?:mega\.nz))"
+              r"(\/)([-a-zA-Z0-9()@:%_\+.~#?&//=]*)([\w\-]+)(\S+)?$")
+
+# Download Mega Link
+def DownloadMegaLink(url, alreadylol, download_msg):
+    try:
+        m.download_url(url, alreadylol, statusdl_msg=download_msg)
+    except Exception as e:
+        print(e)
+
+
+@Client.on_message(filters.regex(MEGA_REGEX) & filters.private & filters.incoming & ~filters.edited)
+async def megadl(bot, message):
+    if Config.UPDATES_CHANNEL:
+      fsub = await handle_force_subscribe(bot, message)
+      if fsub == 400:
+        return
+    url = message.text
+    user_info = f'**User ID:** #id{message.from_user.id} \n**User Name:** [{message.from_user.first_name}](tg://user?id={message.from_user.id})'
+    userpath = str(message.from_user.id)
+    alreadylol = basedir + "/" + userpath
+    if os.path.isdir(alreadylol):
+        await message.reply_text(
+            "**Already One Process is Going On! \nPlease Wait Until It's Get Finished 😕!**",
+            reply_to_message_id=message.message_id,
+        )
+        return
+    else:
+        os.makedirs(alreadylol)
+    try:
+        if 'folder' in url:
+            await message.reply_text(
+                "**Mega Folder Isn't Supported Yet 🤒!**",
+                reply_to_message_id=message.message_id,
+            )
+            return
+        else:
+            logs_msg = await message.forward(Config.LOG_CHANNEL)
+            trace_msg = await logs_msg.reply_text(f"#MegaDL: Download Started! \n\n{user_info}")
+            download_msg = await message.reply_text(
+                "**Trying To Download ...** \n\nThis Process May Take Some Time 🤷\u200d♂️!",
+                reply_markup=InlineKeyboardMarkup(
+                    [
+                        [
+                            InlineKeyboardButton(
+                                "Cancel Mega DL", callback_data="cancel_mega"
+                            )
+                        ]
+                    ]
+                ),
+                reply_to_message_id=message.message_id,
+            )
+            loop = get_running_loop()
+            await loop.run_in_executor(None, partial(DownloadMegaLink, url, alreadylol, download_msg))
+            getfiles = [f for f in os.listdir(alreadylol) if isfile(join(alreadylol, f))]
+            files = getfiles[0]
+            magapylol = f"{alreadylol}/{files}"
+            await download_msg.edit("**Downloaded Successfully 😉!**")
+            await trace_msg.edit(f"#MegaDL: Download Done! \n\n{user_info}")
+    except Exception as e:
+        if "list index out of range" in str(e):
+            await download_msg.edit("**Please Try Again After 30 Seconds 🤒!**")
+            await trace_msg.edit(
+                f"#MegaDL: Download Canceled! \nReason: `{e}` \n\n{user_info}"
+                )
+            os.system(f"kill -9 {os.getpid()} && python3 main.py")
+        else:
+            await download_msg.edit(f"**Error:** `{e}`")
+            await trace_msg.edit(
+                f"#MegaDL: Download Failed! \nReason: `{e}` \n\n{user_info}"
+                )
+        shutil.rmtree(basedir + '/' + userpath)
+        return
+    lmaocheckdis = os.stat(alreadylol).st_size
+    readablefilesize = size(lmaocheckdis) # Convert Bytes into readable size
+    if lmaocheckdis > TG_MAX_FILE_SIZE:
+        await download_msg.edit(f"**Detected File Size:** `{readablefilesize}` \n**Accepted File Size:** `2.0 GB` \n\nOops! File Is Too Large To Send In Telegram 🤒!")
+        await trace_msg.edit(f"#MegaDL: Upload Failed! \nReason: `File is Larger Than 2GB.` \n\n{user_info}")
+        shutil.rmtree(basedir + "/" + userpath)
+        return
+    else:
+        start_time = time.time()
+        guessedfilemime = filetype.guess(f"{magapylol}") # Detecting file type
+        if not guessedfilemime.mime:
+            await download_msg.edit("**Trying To Upload ...** \n**Can't Get File Type, Sending as Document!")
+            safone = await message.reply_document(magapylol, progress=progress_for_pyrogram, progress_args=("**Uploading ...** \n", download_msg, start_time), reply_to_message_id=message.message_id)
+            await safone.reply_text(
+                "**Join @url_upload_bots! \nThanks For Using Me 😘!**",
+                reply_markup=InlineKeyboardMarkup(
+                    [
+                        [
+                            InlineKeyboardButton(
+                                "🙌 SHARE 🙌",
+                                url="https://t.me/share/url?url=Hey%20Guys!%20%20Check%20Out%20@imseldrith%20's%20Bots%20Channel.%20%20Share%20His%20Bots%20And%20Support%20Him%20%F0%9F%98%89!%20%20Here%20Is%20The%20Bots%20Channel:-%20https://t.me/url_upload_bots",
+                            )
+                        ]
+                    ]
+                ),
+                reply_to_message_id=safone.message_id,
+            )
+            await download_msg.delete()
+            await trace_msg.edit(f"#MegaDL: Upload Done! \n\n{user_info}")
+            shutil.rmtree(basedir + "/" + userpath)
+            return
+        # Checking file type
+        filemimespotted = guessedfilemime.mime
+        await download_msg.edit("**Trying To Upload ...**")
+        if "image/gif" in filemimespotted:
+            safone = await message.reply_animation(magapylol, progress=progress_for_pyrogram, progress_args=("**Uploading ...** \n", download_msg, start_time), reply_to_message_id=message.message_id)
+        elif "image" in filemimespotted:
+            safone = await message.reply_photo(magapylol, progress=progress_for_pyrogram, progress_args=("**Uploading ...** \n", download_msg, start_time), reply_to_message_id=message.message_id)
+        elif "video" in filemimespotted:
+            viddura = moviepy.editor.VideoFileClip(f"{magapylol}")
+            vidduration = int(viddura.duration)
+            thumbnail_path = f"{alreadylol}/thumbnail.jpg"
+            subprocess.call(['ffmpeg', '-i', magapylol, '-ss', '00:00:10.000', '-vframes', '1', thumbnail_path])
+            safone = await message.reply_video(magapylol, duration=vidduration, thumb=thumbnail_path, progress=progress_for_pyrogram, progress_args=("**Uploading ...** \n", download_msg, start_time), reply_to_message_id=message.message_id)
+        elif "audio" in filemimespotted:
+            safone = await message.reply_audio(magapylol, progress=progress_for_pyrogram, progress_args=("**Uploading ...** \n", download_msg, start_time), reply_to_message_id=message.message_id)
+        else:
+            safone = await message.reply_document(magapylol, progress=progress_for_pyrogram, progress_args=("**Uploading ...** \n", download_msg, start_time), reply_to_message_id=message.message_id)
+        await safone.reply_text(
+            "**Join @url_upload_bots! \nThanks For Using Me 😘!**",
+            reply_markup=InlineKeyboardMarkup(
+                [
+                    [
+                        InlineKeyboardButton(
+                            "🙌 SHARE 🙌",
+                            url="https://t.me/share/url?url=Hey%20Guys!%20%20Check%20Out%20@imseldrith%20's%20Bots%20Channel.%20%20Share%20His%20Bots%20And%20Support%20Him%20%F0%9F%98%89!%20%20Here%20Is%20The%20Channel:-%20https://t.me/url_upload_bots",
+                        )
+                    ]
+                ]
+            ),
+            reply_to_message_id=safone.message_id,
+        )
+        await download_msg.delete()
+        await trace_msg.edit(f"#MegaDL: Upload Done! \n\n{user_info}")
+    try:
+        shutil.rmtree(basedir + "/" + userpath)
+        print("[ MegaDL-Bot ] Successfully Cleaned Temp Download Directory!")
+    except Exception as e:
+        print(e)
+        return
+
+@Client.on_message(filters.command("cancel") & filters.private & filters.incoming & ~filters.edited)
+async def cancel_dl(bot, message):
+    if Config.UPDATES_CHANNEL:
+      fsub = await handle_force_subscribe(bot, message)
+      if fsub == 400:
+        return
+    userpath = str(message.from_user.id)
+    try:
+        shutil.rmtree(basedir + "/" + userpath)
+        await message.reply_text("✅ **Downloading Canceled Successfully!**", reply_to_message_id=message.message_id)
+    except Exception as e:
+        await print(e)
+        await message.reply_text("❌ **No Active Download Process To Cancel!**", reply_to_message_id=message.message_id)

megadl/mega_dl1.py

@@ -0,0 +1,197 @@
+# (c) Asm Safone
+# A Part of MegaDL-Bot <https://github.com/AsmSafone/MegaDL-Bot>
+
+import os
+import time
+import shutil
+import logging
+import filetype
+import subprocess
+import moviepy.editor
+from mega import Mega
+from config import Config
+from posixpath import join
+from functools import partial
+from genericpath import isfile
+from hurry.filesize import size
+from asyncio import get_running_loop
+from pyrogram import Client, filters
+from megadl.progress import progress_for_pyrogram
+from megadl.forcesub import handle_force_subscribe
+from pyrogram.types import InlineKeyboardMarkup, InlineKeyboardButton
+
+# Logging
+
+logging.basicConfig(level=logging.INFO,
+                    format='%(asctime)s - %(name)s - %(levelname)s - %(message)s')
+
+# Mega Client
+mega = Mega()
+m = mega.login()
+
+# Temp Download Directory
+basedir = Config.DOWNLOAD_LOCATION
+
+# Telegram's Max File Size
+TG_MAX_FILE_SIZE = Config.TG_MAX_SIZE
+
+# Automatic Url Detection
+MEGA_REGEX = (r"^((?:https?:)?\/\/)"
+              r"?((?:www)\.)"
+              r"?((?:mega\.nz))"
+              r"(\/)([-a-zA-Z0-9()@:%_\+.~#?&//=]*)([\w\-]+)(\S+)?$")
+
+# Download Mega Link
+def DownloadMegaLink(url, alreadylol, download_msg):
+    try:
+        m.download_url(url, alreadylol, statusdl_msg=download_msg)
+    except Exception as e:
+        print(e)
+
+
+@Client.on_message(filters.regex(MEGA_REGEX) & filters.private & filters.incoming & ~filters.edited)
+async def megadl(bot, message):
+    if Config.UPDATES_CHANNEL:
+      fsub = await handle_force_subscribe(bot, message)
+      if fsub == 400:
+        return
+    url = message.text
+    user_info = f'**User ID:** #id{message.from_user.id} \n**User Name:** [{message.from_user.first_name}](tg://user?id={message.from_user.id})'
+    userpath = str(message.from_user.id)
+    alreadylol = basedir + "/" + userpath
+    if os.path.isdir(alreadylol):
+        await message.reply_text(
+            "**Already One Process is Going On! \nPlease Wait Until It's Get Finished 😕!**",
+            reply_to_message_id=message.message_id,
+        )
+        return
+    else:
+        os.makedirs(alreadylol)
+    try:
+        if 'folder' in url:
+            await message.reply_text(
+                "**Mega Folder Isn't Supported Yet 🤒!**",
+                reply_to_message_id=message.message_id,
+            )
+            return
+        else:
+            logs_msg = await message.forward(Config.LOG_CHANNEL)
+            trace_msg = await logs_msg.reply_text(f"#MegaDL: Download Started! \n\n{user_info}")
+            download_msg = await message.reply_text(
+                "**Trying To Download ...** \n\nThis Process May Take Some Time 🤷\u200d♂️!",
+                reply_markup=InlineKeyboardMarkup(
+                    [
+                        [
+                            InlineKeyboardButton(
+                                "Cancel Mega DL", callback_data="cancel_mega"
+                            )
+                        ]
+                    ]
+                ),
+                reply_to_message_id=message.message_id,
+            )
+            loop = get_running_loop()
+            await loop.run_in_executor(None, partial(DownloadMegaLink, url, alreadylol, download_msg))
+            getfiles = [f for f in os.listdir(alreadylol) if isfile(join(alreadylol, f))]
+            files = getfiles[0]
+            magapylol = f"{alreadylol}/{files}"
+            await download_msg.edit("**Downloaded Successfully 😉!**")
+            await trace_msg.edit(f"#MegaDL: Download Done! \n\n{user_info}")
+    except Exception as e:
+        if "list index out of range" in str(e):
+            await download_msg.edit("**Please Try Again After 30 Seconds 🤒!**")
+            await trace_msg.edit(
+                f"#MegaDL: Download Canceled! \nReason: `{e}` \n\n{user_info}"
+                )
+            os.system(f"kill -9 {os.getpid()} && python3 main.py")
+        else:
+            await download_msg.edit(f"**Error:** `{e}`")
+            await trace_msg.edit(
+                f"#MegaDL: Download Failed! \nReason: `{e}` \n\n{user_info}"
+                )
+        shutil.rmtree(basedir + '/' + userpath)
+        return
+    lmaocheckdis = os.stat(alreadylol).st_size
+    readablefilesize = size(lmaocheckdis) # Convert Bytes into readable size
+    if lmaocheckdis > TG_MAX_FILE_SIZE:
+        await download_msg.edit(f"**Detected File Size:** `{readablefilesize}` \n**Accepted File Size:** `2.0 GB` \n\nOops! File Is Too Large To Send In Telegram 🤒!")
+        await trace_msg.edit(f"#MegaDL: Upload Failed! \nReason: `File is Larger Than 2GB.` \n\n{user_info}")
+        shutil.rmtree(basedir + "/" + userpath)
+        return
+    else:
+        start_time = time.time()
+        guessedfilemime = filetype.guess(f"{magapylol}") # Detecting file type
+        if not guessedfilemime.mime:
+            await download_msg.edit("**Trying To Upload ...** \n**Can't Get File Type, Sending as Document!")
+            safone = await message.reply_document(magapylol, progress=progress_for_pyrogram, progress_args=("**Uploading ...** \n", download_msg, start_time), reply_to_message_id=message.message_id)
+            await safone.reply_text(
+                "**Join @url_upload_bots ! \nThanks For Using Me 😘!**",
+                reply_markup=InlineKeyboardMarkup(
+                    [
+                        [
+                            InlineKeyboardButton(
+                                "🙌 SHARE 🙌",
+                                url="https://t.me/share/url?url=**Hey%20Guys!%20%20Check%20Out%20@imseldrith%20Bots%20Channel.%20%20Share%20His%20Bots%20And%20Support%20Him%20%F0%9F%98%89!%20%20Here%20Is%20The%20Bots%20List%20:-%20https://t.me/url_upload_bots **",
+                            )
+                        ]
+                    ]
+                ),
+                reply_to_message_id=safone.message_id,
+            )
+            await download_msg.delete()
+            await trace_msg.edit(f"#MegaDL: Upload Done! \n\n{user_info}")
+            shutil.rmtree(basedir + "/" + userpath)
+            return
+        # Checking file type
+        filemimespotted = guessedfilemime.mime
+        await download_msg.edit("**Trying To Upload ...**")
+        if "image/gif" in filemimespotted:
+            safone = await message.reply_animation(magapylol, progress=progress_for_pyrogram, progress_args=("**Uploading ...** \n", download_msg, start_time), reply_to_message_id=message.message_id)
+        elif "image" in filemimespotted:
+            safone = await message.reply_photo(magapylol, progress=progress_for_pyrogram, progress_args=("**Uploading ...** \n", download_msg, start_time), reply_to_message_id=message.message_id)
+        elif "video" in filemimespotted:
+            viddura = moviepy.editor.VideoFileClip(f"{magapylol}")
+            vidduration = int(viddura.duration)
+            thumbnail_path = f"{alreadylol}/thumbnail.jpg"
+            subprocess.call(['ffmpeg', '-i', magapylol, '-ss', '00:00:10.000', '-vframes', '1', thumbnail_path])
+            safone = await message.reply_video(magapylol, duration=vidduration, thumb=thumbnail_path, progress=progress_for_pyrogram, progress_args=("**Uploading ...** \n", download_msg, start_time), reply_to_message_id=message.message_id)
+        elif "audio" in filemimespotted:
+            safone = await message.reply_audio(magapylol, progress=progress_for_pyrogram, progress_args=("**Uploading ...** \n", download_msg, start_time), reply_to_message_id=message.message_id)
+        else:
+            safone = await message.reply_document(magapylol, progress=progress_for_pyrogram, progress_args=("**Uploading ...** \n", download_msg, start_time), reply_to_message_id=message.message_id)
+        await safone.reply_text(
+            "**Join @url_upload_bots ! \nThanks For Using Me 😘!**",
+            reply_markup=InlineKeyboardMarkup(
+                [
+                    [
+                        InlineKeyboardButton(
+                            "🙌 SHARE 🙌",
+                            url="https://t.me/share/url?url=**Hey%20Guys!%20%20Check%20Out%20@imseldrith%20Bots%20Channel.%20%20Share%20His%20Bots%20And%20Support%20Him%20%F0%9F%98%89!%20%20Here%20Is%20The%20Bots%20List%20:-%20https://t.me/url_upload_bots **",
+                        )
+                    ]
+                ]
+            ),
+            reply_to_message_id=safone.message_id,
+        )
+        await download_msg.delete()
+        await trace_msg.edit(f"#MegaDL: Upload Done! \n\n{user_info}")
+    try:
+        shutil.rmtree(basedir + "/" + userpath)
+        print("[ MegaDL-Bot ] Successfully Cleaned Temp Download Directory!")
+    except Exception as e:
+        print(e)
+        return
+
+@Client.on_message(filters.command("cancel") & filters.private & filters.incoming & ~filters.edited)
+async def cancel_dl(bot, message):
+    if Config.UPDATES_CHANNEL:
+      fsub = await handle_force_subscribe(bot, message)
+      if fsub == 400:
+        return
+    userpath = str(message.from_user.id)
+    try:
+        shutil.rmtree(basedir + "/" + userpath)
+        await message.reply_text("✅ **Downloading Canceled Successfully!**", reply_to_message_id=message.message_id)
+    except Exception as e:
+        await print(e)
+        await message.reply_text("❌ **No Active Download Process To Cancel!**", reply_to_message_id=message.message_id)

megadl/progress.py

@@ -0,0 +1,89 @@
+# (c) Asm Safone
+# A Part of MegaDL-Bot <https://github.com/AsmSafone/MegaDL-Bot>
+
+
+import os
+import time
+import math
+from config import Config
+from pyrogram.types import InlineKeyboardMarkup, InlineKeyboardButton
+
+
+async def progress_for_pyrogram(
+    current,
+    total,
+    ud_type,
+    message,
+    start
+):
+    now = time.time()
+    diff = now - start
+    if round(diff % 10.00) == 0 or current == total:
+        # if round(current / total * 100, 0) % 5 == 0:
+        percentage = current * 100 / total
+        speed = current / diff
+        elapsed_time = round(diff) * 1000
+        time_to_completion = round((total - current) / speed) * 1000
+        estimated_total_time = elapsed_time + time_to_completion
+
+        elapsed_time = TimeFormatter(milliseconds=elapsed_time)
+        estimated_total_time = TimeFormatter(milliseconds=estimated_total_time)
+
+        progress = "`[{0}{1}]` \n".format(
+            ''.join(["●" for i in range(math.floor(percentage / 5))]),
+            ''.join(["○" for i in range(20 - math.floor(percentage / 5))])
+            )
+        
+        ok = "`{0}%` \n".format(
+            round(percentage, 2)
+            )
+
+        tmp = ok + progress + "\n➩ **Done:** `{0}` \n➩ **Total:** `{1}` \n➩ **Speed:** `{2}/s` \n➩ **Time Left:** `{3}`".format(
+            humanbytes(current),
+            humanbytes(total),
+            humanbytes(speed),
+            estimated_total_time if estimated_total_time != '' else "0 s"
+        )
+        try:
+            await message.edit(
+                text="**{}** {} \n\n**@imseldtith | @url_upload_bots**".format(
+                    ud_type,
+                    tmp
+                ),
+                reply_markup=InlineKeyboardMarkup(
+                    [
+                        [
+                            InlineKeyboardButton("Cancel Upload", callback_data="cancel_up")
+                        ]
+                    ]
+                )
+            )
+        except:
+            pass
+
+
+def humanbytes(size):
+    # https://stackoverflow.com/a/49361727/4723940
+    # 2**10 = 1024
+    if not size:
+        return ""
+    power = 2**10
+    n = 0
+    Dic_powerN = {0: ' ', 1: 'Ki', 2: 'Mi', 3: 'Gi', 4: 'Ti'}
+    while size > power:
+        size /= power
+        n += 1
+    return str(round(size, 2)) + " " + Dic_powerN[n] + 'B'
+
+
+def TimeFormatter(milliseconds: int) -> str:
+    seconds, milliseconds = divmod(int(milliseconds), 1000)
+    minutes, seconds = divmod(seconds, 60)
+    hours, minutes = divmod(minutes, 60)
+    days, hours = divmod(hours, 24)
+    tmp = ((str(days) + "d, ") if days else "") + \
+        ((str(hours) + "h, ") if hours else "") + \
+        ((str(minutes) + "m, ") if minutes else "") + \
+        ((str(seconds) + "s, ") if seconds else "") + \
+        ((str(milliseconds) + "ms, ") if milliseconds else "")
+    return tmp[:-2]