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

revert back

Browse Source
This commit is contained in:
levina 2022-02-11 14:05:22 +07:00 committed by GitHub
parent e89cc36678
commit 8e4945f8fa
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 114 additions and 105 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
program/admins.py
View File

@ -232,23 +232,16 @@ async def unmute(client, m: Message):
await m.reply("❌ **nothing is streaming**") await m.reply("❌ **nothing is streaming**")
@Client.on_callback_query( @Client.on_callback_query(filters.regex("set_pause"))
filters.regex( async def cbpause(_, query: CallbackQuery):
pattern=r"^(set_pause|set_resume|set_stop|set_mute|set_unmute)$"
)
)
async def data_stream_markup(_, query: CallbackQuery):
user_id = query.from_user.id user_id = query.from_user.id
chat_id = query.message.chat.id
data = query.matches[0].group(1)
if data == "set_pause":
if await is_gbanned_user(user_id): if await is_gbanned_user(user_id):
await query.answer("❗️ You've blocked from using this bot!", show_alert=True) await query.answer("❗️ You've blocked from using this bot!", show_alert=True)
return return
a = await _.get_chat_member(query.message.chat.id, query.from_user.id) a = await _.get_chat_member(query.message.chat.id, query.from_user.id)
if not a.can_manage_voice_chats: if not a.can_manage_voice_chats:
await query.answer("💡 Only admin with manage video chat permission that can tap this button !", show_alert=True) return await query.answer("💡 Only admin with manage video chat permission that can tap this button !", show_alert=True)
return chat_id = query.message.chat.id
if chat_id in QUEUE: if chat_id in QUEUE:
try: try:
if not await is_music_playing(chat_id): if not await is_music_playing(chat_id):
@ -261,14 +254,18 @@ async def data_stream_markup(_, query: CallbackQuery):
await query.edit_message_text(f"🚫 **error:**\n\n`{e}`", reply_markup=close_mark) await query.edit_message_text(f"🚫 **error:**\n\n`{e}`", reply_markup=close_mark)
else: else:
await query.answer("❌ nothing is currently streaming", show_alert=True) await query.answer("❌ nothing is currently streaming", show_alert=True)
elif data == "set_resume":
@Client.on_callback_query(filters.regex("set_resume"))
async def cbresume(_, query: CallbackQuery):
user_id = query.from_user.id
if await is_gbanned_user(user_id): if await is_gbanned_user(user_id):
await query.answer("❗️ You've blocked from using this bot!", show_alert=True) await query.answer("❗️ You've blocked from using this bot!", show_alert=True)
return return
a = await _.get_chat_member(query.message.chat.id, query.from_user.id) a = await _.get_chat_member(query.message.chat.id, query.from_user.id)
if not a.can_manage_voice_chats: if not a.can_manage_voice_chats:
await query.answer("💡 Only admin with manage video chat permission that can tap this button !", show_alert=True) return await query.answer("💡 Only admin with manage video chat permission that can tap this button !", show_alert=True)
return chat_id = query.message.chat.id
if chat_id in QUEUE: if chat_id in QUEUE:
try: try:
if await is_music_playing(chat_id): if await is_music_playing(chat_id):
@ -281,14 +278,18 @@ async def data_stream_markup(_, query: CallbackQuery):
await query.edit_message_text(f"🚫 **error:**\n\n`{e}`", reply_markup=close_mark) await query.edit_message_text(f"🚫 **error:**\n\n`{e}`", reply_markup=close_mark)
else: else:
await query.answer("❌ nothing is currently streaming", show_alert=True) await query.answer("❌ nothing is currently streaming", show_alert=True)
elif data == "set_stop":
@Client.on_callback_query(filters.regex("set_stop"))
async def cbstop(_, query: CallbackQuery):
user_id = query.from_user.id
if await is_gbanned_user(user_id): if await is_gbanned_user(user_id):
await query.answer("❗️ You've blocked from using this bot!", show_alert=True) await query.answer("❗️ You've blocked from using this bot!", show_alert=True)
return return
a = await _.get_chat_member(query.message.chat.id, query.from_user.id) a = await _.get_chat_member(query.message.chat.id, query.from_user.id)
if not a.can_manage_voice_chats: if not a.can_manage_voice_chats:
await query.answer("💡 Only admin with manage video chat permission that can tap this button !", show_alert=True) return await query.answer("💡 Only admin with manage video chat permission that can tap this button !", show_alert=True)
return chat_id = query.message.chat.id
if chat_id in QUEUE: if chat_id in QUEUE:
try: try:
await calls.leave_group_call(chat_id) await calls.leave_group_call(chat_id)
@ -299,14 +300,18 @@ async def data_stream_markup(_, query: CallbackQuery):
await query.edit_message_text(f"🚫 **error:**\n\n`{e}`", reply_markup=close_mark) await query.edit_message_text(f"🚫 **error:**\n\n`{e}`", reply_markup=close_mark)
else: else:
await query.answer("❌ nothing is currently streaming", show_alert=True) await query.answer("❌ nothing is currently streaming", show_alert=True)
elif data == "set_mute":
@Client.on_callback_query(filters.regex("set_mute"))
async def cbmute(_, query: CallbackQuery):
user_id = query.from_user.id
if await is_gbanned_user(user_id): if await is_gbanned_user(user_id):
await query.answer("❗️ You've blocked from using this bot!", show_alert=True) await query.answer("❗️ You've blocked from using this bot!", show_alert=True)
return return
a = await _.get_chat_member(query.message.chat.id, query.from_user.id) a = await _.get_chat_member(query.message.chat.id, query.from_user.id)
if not a.can_manage_voice_chats: if not a.can_manage_voice_chats:
await query.answer("💡 Only admin with manage video chat permission that can tap this button !", show_alert=True) return await query.answer("💡 Only admin with manage video chat permission that can tap this button !", show_alert=True)
return chat_id = query.message.chat.id
if chat_id in QUEUE: if chat_id in QUEUE:
try: try:
if not await is_music_playing(chat_id): if not await is_music_playing(chat_id):
@ -319,14 +324,18 @@ async def data_stream_markup(_, query: CallbackQuery):
await query.edit_message_text(f"🚫 **error:**\n\n`{e}`", reply_markup=close_mark) await query.edit_message_text(f"🚫 **error:**\n\n`{e}`", reply_markup=close_mark)
else: else:
await query.answer("❌ nothing is currently streaming", show_alert=True) await query.answer("❌ nothing is currently streaming", show_alert=True)
elif data == "set_unmute":
@Client.on_callback_query(filters.regex("set_unmute"))
async def cbunmute(_, query: CallbackQuery):
user_id = query.from_user.id
if await is_gbanned_user(user_id): if await is_gbanned_user(user_id):
await query.answer("❗️ You've blocked from using this bot!", show_alert=True) await query.answer("❗️ You've blocked from using this bot!", show_alert=True)
return return
a = await _.get_chat_member(query.message.chat.id, query.from_user.id) a = await _.get_chat_member(query.message.chat.id, query.from_user.id)
if not a.can_manage_voice_chats: if not a.can_manage_voice_chats:
await query.answer("💡 Only admin with manage video chat permission that can tap this button !", show_alert=True) return await query.answer("💡 Only admin with manage video chat permission that can tap this button !", show_alert=True)
return chat_id = query.message.chat.id
if chat_id in QUEUE: if chat_id in QUEUE:
try: try:
if await is_music_playing(chat_id): if await is_music_playing(chat_id):