Xtao-Labs/video-stream
3
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

some fixes

Browse Source
This commit is contained in:
levina 2022-01-20 21:11:35 +07:00 committed by GitHub
parent e02a14f361
commit 3794ad907c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 45 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
program/admins.py
View File

@ -1,8 +1,6 @@
from cache.admins import admins from cache.admins import admins
from driver.veez import call_py, bot from driver.veez import call_py, bot
from pyrogram import Client, filters from pyrogram import Client, filters
from driver.chat_author import adminsOnly
from driver.perms import member_permissions
from driver.queues import QUEUE, clear_queue from driver.queues import QUEUE, clear_queue
from driver.filters import command, other_filters from driver.filters import command, other_filters
from driver.decorators import authorized_users_only from driver.decorators import authorized_users_only
@ -32,13 +30,8 @@ async def update_admin(client, message):
@Client.on_message(command(["skip", f"skip@{BOT_USERNAME}", "vskip"]) & other_filters) @Client.on_message(command(["skip", f"skip@{BOT_USERNAME}", "vskip"]) & other_filters)
@authorized_users_only
async def skip(client, m: Message): async def skip(client, m: Message):
if m.sender_chat:
return await m.reply_text("you're an __Anonymous__ Admin !\n\n» revert back to user account.")
permission = "can_manage_voice_chats"
s = await adminsOnly(permission, m)
if s == 1:
return
user_id = m.from_user.id user_id = m.from_user.id
chat_id = m.chat.id chat_id = m.chat.id
if len(m.command) < 2: if len(m.command) < 2:
@ -79,13 +72,8 @@ async def skip(client, m: Message):
command(["stop", f"stop@{BOT_USERNAME}", "end", f"end@{BOT_USERNAME}", "vstop"]) command(["stop", f"stop@{BOT_USERNAME}", "end", f"end@{BOT_USERNAME}", "vstop"])
& other_filters & other_filters
) )
@authorized_users_only
async def stop(client, m: Message): async def stop(client, m: Message):
if m.sender_chat:
return await m.reply_text("you're an __Anonymous__ Admin !\n\n» revert back to user account.")
permission = "can_manage_voice_chats"
s = await adminsOnly(permission, m)
if s == 1:
return
chat_id = m.chat.id chat_id = m.chat.id
if chat_id in QUEUE: if chat_id in QUEUE:
try: try:
@ -101,13 +89,8 @@ async def stop(client, m: Message):
@Client.on_message( @Client.on_message(
command(["pause", f"pause@{BOT_USERNAME}", "vpause"]) & other_filters command(["pause", f"pause@{BOT_USERNAME}", "vpause"]) & other_filters
) )
@authorized_users_only
async def pause(client, m: Message): async def pause(client, m: Message):
if m.sender_chat:
return await m.reply_text("you're an __Anonymous__ Admin !\n\n» revert back to user account.")
permission = "can_manage_voice_chats"
s = await adminsOnly(permission, m)
if s == 1:
return
chat_id = m.chat.id chat_id = m.chat.id
if chat_id in QUEUE: if chat_id in QUEUE:
try: try:
@ -124,13 +107,8 @@ async def pause(client, m: Message):
@Client.on_message( @Client.on_message(
command(["resume", f"resume@{BOT_USERNAME}", "vresume"]) & other_filters command(["resume", f"resume@{BOT_USERNAME}", "vresume"]) & other_filters
) )
@authorized_users_only
async def resume(client, m: Message): async def resume(client, m: Message):
if m.sender_chat:
return await m.reply_text("you're an __Anonymous__ Admin !\n\n» revert back to user account.")
permission = "can_manage_voice_chats"
s = await adminsOnly(permission, m)
if s == 1:
return
chat_id = m.chat.id chat_id = m.chat.id
if chat_id in QUEUE: if chat_id in QUEUE:
try: try:
@ -147,13 +125,8 @@ async def resume(client, m: Message):
@Client.on_message( @Client.on_message(
command(["mute", f"mute@{BOT_USERNAME}", "vmute"]) & other_filters command(["mute", f"mute@{BOT_USERNAME}", "vmute"]) & other_filters
) )
@authorized_users_only
async def mute(client, m: Message): async def mute(client, m: Message):
if m.sender_chat:
return await m.reply_text("you're an __Anonymous__ Admin !\n\n» revert back to user account.")
permission = "can_manage_voice_chats"
s = await adminsOnly(permission, m)
if s == 1:
return
chat_id = m.chat.id chat_id = m.chat.id
if chat_id in QUEUE: if chat_id in QUEUE:
try: try:
@ -170,13 +143,8 @@ async def mute(client, m: Message):
@Client.on_message( @Client.on_message(
command(["unmute", f"unmute@{BOT_USERNAME}", "vunmute"]) & other_filters command(["unmute", f"unmute@{BOT_USERNAME}", "vunmute"]) & other_filters
) )
@authorized_users_only
async def unmute(client, m: Message): async def unmute(client, m: Message):
if m.sender_chat:
return await m.reply_text("you're an __Anonymous__ Admin !\n\n» revert back to user account.")
permission = "can_manage_voice_chats"
s = await adminsOnly(permission, m)
if s == 1:
return
chat_id = m.chat.id chat_id = m.chat.id
if chat_id in QUEUE: if chat_id in QUEUE:
try: try:
@ -286,13 +254,8 @@ async def cbunmute(_, query: CallbackQuery):
@Client.on_message( @Client.on_message(
command(["volume", f"volume@{BOT_USERNAME}", "vol"]) & other_filters command(["volume", f"volume@{BOT_USERNAME}", "vol"]) & other_filters
) )
@authorized_users_only
async def change_volume(client, m: Message): async def change_volume(client, m: Message):
if m.sender_chat:
return await m.reply_text("you're an __Anonymous__ Admin !\n\n» revert back to user account.")
permission = "can_manage_voice_chats"
s = await adminsOnly(permission, m)
if s == 1:
return
range = m.command[1] range = m.command[1]
chat_id = m.chat.id chat_id = m.chat.id
if chat_id in QUEUE: if chat_id in QUEUE: