Upload asupan.py
Browse files- Akeno/plugins/asupan.py +46 -0
Akeno/plugins/asupan.py
ADDED
@@ -0,0 +1,46 @@
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
1 |
+
from asyncio import *
|
2 |
+
import asyncio
|
3 |
+
from random import *
|
4 |
+
from pyrogram import *
|
5 |
+
from pyrogram.types import *
|
6 |
+
from Akeno.utils.handler import *
|
7 |
+
from Akeno.utils.database import db
|
8 |
+
from config import *
|
9 |
+
|
10 |
+
@Akeno(
|
11 |
+
~filters.scheduled
|
12 |
+
& filters.command(["asupan"], CMD_HANDLER)
|
13 |
+
& filters.me
|
14 |
+
& ~filters.forwarded
|
15 |
+
)
|
16 |
+
async def asupan_channel(client: Client, message: Message):
|
17 |
+
pro = await message.reply_text("`Processing....`")
|
18 |
+
user_id = message.from_user.id
|
19 |
+
get_username = await db.get_env(ENV_TEMPLATE.asupan_username)
|
20 |
+
if not get_username:
|
21 |
+
return await message.reply_text("required `.setvar ASUPAN_USERNAME`")
|
22 |
+
if not get_username.startswith("@"):
|
23 |
+
return await message.reply_text("Invalid username")
|
24 |
+
custom_emoji = "<emoji id=5328317370647715629>✅</emoji>"
|
25 |
+
prem = await client.get_users("me")
|
26 |
+
if prem.is_premium:
|
27 |
+
caption = f"{custom_emoji}**Uploaded by** {client.me.mention}"
|
28 |
+
else:
|
29 |
+
caption = f"**Uploaded by** {client.me.mention}"
|
30 |
+
await asyncio.gather(
|
31 |
+
pro.delete(),
|
32 |
+
client.send_video(
|
33 |
+
message.chat.id,
|
34 |
+
choice(
|
35 |
+
[
|
36 |
+
asupan.video.file_id
|
37 |
+
async for asupan in client.search_messages(
|
38 |
+
get_username,
|
39 |
+
filter=enums.MessagesFilter.VIDEO
|
40 |
+
)
|
41 |
+
]
|
42 |
+
),
|
43 |
+
caption=caption,
|
44 |
+
reply_to_message_id=message.id
|
45 |
+
),
|
46 |
+
)
|