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

none

Browse Source
This commit is contained in:
levina 2021-11-07 18:52:30 +07:00 committed by GitHub
parent 381288caa8
commit 79f76faac2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
program/admins.py
View File

@ -188,12 +188,12 @@ async def cbpause(_, query: CallbackQuery):
try: try:
await call_py.pause_stream(chat_id) await call_py.pause_stream(chat_id)
await query.edit_message_text( await query.edit_message_text(
"⏸ streaming has paused", reply_markup=bttn "⏸ the streaming has paused", reply_markup=bttn
) )
except Exception as e: except Exception as e:
await query.edit_message_text(f"🚫 **error:**\n\n`{e}`", reply_markup=bcl) await query.edit_message_text(f"🚫 **error:**\n\n`{e}`", reply_markup=bcl)
else: else:
await query.edit_message_text("❌ **nothing in streaming**", reply_markup=bcl) await query.answer("❌ nothing is currently streaming", show_alert=True)
@Client.on_callback_query(filters.regex("cbresume")) @Client.on_callback_query(filters.regex("cbresume"))
@ -208,12 +208,12 @@ async def cbresume(_, query: CallbackQuery):
try: try:
await call_py.resume_stream(chat_id) await call_py.resume_stream(chat_id)
await query.edit_message_text( await query.edit_message_text(
"▶️ streaming has resumed", reply_markup=bttn "▶️ the streaming has resumed", reply_markup=bttn
) )
except Exception as e: except Exception as e:
await query.edit_message_text(f"🚫 **error:**\n\n`{e}`", reply_markup=bcl) await query.edit_message_text(f"🚫 **error:**\n\n`{e}`", reply_markup=bcl)
else: else:
await query.edit_message_text("❌ **nothing in streaming**", reply_markup=bcl) await query.answer("❌ nothing is currently streaming", show_alert=True)
@Client.on_callback_query(filters.regex("cbstop")) @Client.on_callback_query(filters.regex("cbstop"))
@ -228,11 +228,11 @@ async def cbstop(_, query: CallbackQuery):
try: try:
await call_py.leave_group_call(chat_id) await call_py.leave_group_call(chat_id)
clear_queue(chat_id) clear_queue(chat_id)
await query.edit_message_text("✅ **streaming has ended**", reply_markup=bcl) await query.edit_message_text("✅ **the streaming has ended**", reply_markup=bcl)
except Exception as e: except Exception as e:
await query.edit_message_text(f"🚫 **error:**\n\n`{e}`", reply_markup=bcl) await query.edit_message_text(f"🚫 **error:**\n\n`{e}`", reply_markup=bcl)
else: else:
await query.edit_message_text("❌ **nothing in streaming**", reply_markup=bcl) await query.answer("❌ nothing is currently streaming", show_alert=True)
@Client.on_callback_query(filters.regex("cbmute")) @Client.on_callback_query(filters.regex("cbmute"))
@ -252,7 +252,7 @@ async def cbmute(_, query: CallbackQuery):
except Exception as e: except Exception as e:
await query.edit_message_text(f"🚫 **error:**\n\n`{e}`", reply_markup=bcl) await query.edit_message_text(f"🚫 **error:**\n\n`{e}`", reply_markup=bcl)
else: else:
await query.edit_message_text("❌ **nothing in streaming**", reply_markup=bcl) await query.answer("❌ nothing is currently streaming", show_alert=True)
@Client.on_callback_query(filters.regex("cbunmute")) @Client.on_callback_query(filters.regex("cbunmute"))
@ -272,7 +272,7 @@ async def cbunmute(_, query: CallbackQuery):
except Exception as e: except Exception as e:
await query.edit_message_text(f"🚫 **error:**\n\n`{e}`", reply_markup=bcl) await query.edit_message_text(f"🚫 **error:**\n\n`{e}`", reply_markup=bcl)
else: else:
await query.edit_message_text("❌ **nothing in streaming**", reply_markup=bcl) await query.answer("❌ nothing is currently streaming", show_alert=True)
@Client.on_message( @Client.on_message(