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

fixes error NoneType object

Browse Source
This commit is contained in:
levina 2021-11-01 15:57:52 +07:00 committed by GitHub
parent 3c6b9b6539
commit 2f697c760c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 15 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
program/admins.py
View File

@ -1,4 +1,3 @@
from typing import Callable
from cache.admins import admins from cache.admins import admins
from driver.veez import call_py from driver.veez import call_py
from pyrogram import Client, filters from pyrogram import Client, filters
@ -15,18 +14,6 @@ from pyrogram.types import (
) )
def admin_only(func: Callable) -> Callable:
async def decorator(client, cb):
author = admins.get(cb.message.chat.id)
if cb.from_user.id in author:
return await func(client, cb)
else:
await cb.answer("💡 only admin can tap this button !", show_alert=True)
return
return decorator
bttn = InlineKeyboardMarkup( bttn = InlineKeyboardMarkup(
[[InlineKeyboardButton("🔙 Go Back", callback_data="cbmenu")]] [[InlineKeyboardButton("🔙 Go Back", callback_data="cbmenu")]]
) )
@ -190,8 +177,10 @@ async def unmute(client, m: Message):
@Client.on_callback_query(filters.regex("cbpause")) @Client.on_callback_query(filters.regex("cbpause"))
@admin_only
async def cbpause(_, query: CallbackQuery): async def cbpause(_, query: CallbackQuery):
a = await _.get_chat_member(query.message.chat.id, query.from_user.id)
if not a.can_manage_voice_chats:
return await query.answer("💡 only admin can tap this button !")
chat_id = query.message.chat.id chat_id = query.message.chat.id
if chat_id in QUEUE: if chat_id in QUEUE:
try: try:
@ -206,8 +195,10 @@ async def cbpause(_, query: CallbackQuery):
@Client.on_callback_query(filters.regex("cbresume")) @Client.on_callback_query(filters.regex("cbresume"))
@admin_only
async def cbresume(_, query: CallbackQuery): async def cbresume(_, query: CallbackQuery):
a = await _.get_chat_member(query.message.chat.id, query.from_user.id)
if not a.can_manage_voice_chats:
return await query.answer("💡 only admin can tap this button !")
chat_id = query.message.chat.id chat_id = query.message.chat.id
if chat_id in QUEUE: if chat_id in QUEUE:
try: try:
@ -222,8 +213,10 @@ async def cbresume(_, query: CallbackQuery):
@Client.on_callback_query(filters.regex("cbstop")) @Client.on_callback_query(filters.regex("cbstop"))
@admin_only
async def cbstop(_, query: CallbackQuery): async def cbstop(_, query: CallbackQuery):
a = await _.get_chat_member(query.message.chat.id, query.from_user.id)
if not a.can_manage_voice_chats:
return await query.answer("💡 only admin can tap this button !")
chat_id = query.message.chat.id chat_id = query.message.chat.id
if chat_id in QUEUE: if chat_id in QUEUE:
try: try:
@ -237,8 +230,10 @@ async def cbstop(_, query: CallbackQuery):
@Client.on_callback_query(filters.regex("cbmute")) @Client.on_callback_query(filters.regex("cbmute"))
@admin_only
async def cbmute(_, query: CallbackQuery): async def cbmute(_, query: CallbackQuery):
a = await _.get_chat_member(query.message.chat.id, query.from_user.id)
if not a.can_manage_voice_chats:
return await query.answer("💡 only admin can tap this button !")
chat_id = query.message.chat.id chat_id = query.message.chat.id
if chat_id in QUEUE: if chat_id in QUEUE:
try: try:
@ -253,8 +248,10 @@ async def cbmute(_, query: CallbackQuery):
@Client.on_callback_query(filters.regex("cbunmute")) @Client.on_callback_query(filters.regex("cbunmute"))
@admin_only
async def cbunmute(_, query: CallbackQuery): async def cbunmute(_, query: CallbackQuery):
a = await _.get_chat_member(query.message.chat.id, query.from_user.id)
if not a.can_manage_voice_chats:
return await query.answer("💡 only admin can tap this button !")
chat_id = query.message.chat.id chat_id = query.message.chat.id
if chat_id in QUEUE: if chat_id in QUEUE:
try: try: