Spaces:
Running
Running
File size: 2,854 Bytes
fefc4fb |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 |
# < Source - t.me/testingpluginnn >
# < Made for Ultroid by @Spemgod! >
# < https://github.com/TeamUltroid/Ultroid >
#
# 'TG Regex taken from @TheUserge'
"""
✘ **Download Forward restricted files!**
• **CMD:**
> `{i}fwdl <msg_link>`
> `{i}fwdl https://t.me/nofwd/14`
"""
import os
import re
import time
import asyncio
from datetime import datetime as dt
from telethon.errors.rpcerrorlist import MessageNotModifiedError
from . import LOGS, time_formatter, downloader, random_string, ultroid_cmd
from . import *
# Source: https://github.com/UsergeTeam/Userge/blob/7eef3d2bec25caa53e88144522101819cb6cb649/userge/plugins/misc/download.py#L76
REGEXA = r"^(?:(?:https|tg):\/\/)?(?:www\.)?(?:t\.me\/|openmessage\?)(?:(?:c\/(\d+))|(\w+)|(?:user_id\=(\d+)))(?:\/|&message_id\=)(\d+)(?:\?single)?$"
DL_DIR = "resources/downloads"
def rnd_filename(path):
if not os.path.exists(path):
return path
spl = os.path.splitext(path)
rnd = "_" + random_string(5).lower() + "_"
return spl[0] + rnd + spl[1]
@ultroid_cmd(
pattern="fwdl(?: |$)((?:.|\n)*)",
)
async def fwd_dl(e):
ghomst = await e.eor("`checking...`")
args = e.pattern_match.group(1)
if not args:
reply = await e.get_reply_message()
if reply and reply.text:
args = reply.message
else:
return await eod(ghomst, "Give a tg link to download", time=10)
remgx = re.findall(REGEXA, args)
if not remgx:
return await ghomst.edit("`probably a invalid Link !?`")
try:
chat, id = [i for i in remgx[0] if i]
channel = int(chat) if chat.isdigit() else chat
msg_id = int(id)
except Exception as ex:
return await ghomst.edit("`Give a valid tg link to proceed`")
try:
msg = await e.client.get_messages(channel, ids=msg_id)
except Exception as ex:
return await ghomst.edit(f"**Error:** `{ex}`")
start_ = dt.now()
if (msg and msg.media) and hasattr(msg.media, "photo"):
dls = await e.client.download_media(msg, DL_DIR)
elif (msg and msg.media) and hasattr(msg.media, "document"):
fn = msg.file.name or f"{channel}_{msg_id}{msg.file.ext}"
filename = rnd_filename(os.path.join(DL_DIR, fn))
try:
dlx = await downloader(
filename,
msg.document,
ghomst,
time.time(),
f"Downloading {filename}...",
)
dls = dlx.name
except MessageNotModifiedError as err:
LOGS.exception(err)
return await xx.edit(str(err))
else:
return await ghomst.edit("`Message doesn't contain any media to download.`")
end_ = dt.now()
ts = time_formatter(((end_ - start_).seconds) * 1000)
await ghomst.edit(f"**Downloaded in {ts} !!**\n » `{dls}`")
|