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

setup

Browse Source
This commit is contained in:
levina 2021-10-28 14:39:55 +07:00 committed by GitHub
parent ce080fafcc
commit 5aa205ebb1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
program/admins.py
View File

@ -30,14 +30,14 @@ async def skip(client, m: Message):
if len(m.command) < 2: if len(m.command) < 2:
op = await skip_current_song(chat_id) op = await skip_current_song(chat_id)
if op==0: if op==0:
await m.reply("`Nothing Is Playing`") await m.reply("❌ nothing is currently playing")
elif op==1: elif op==1:
await m.reply("`Queue is Empty, Leaving Voice Chat...`") await m.reply("✅ __Queues__ is empty.\n\n• userbot leaving voice chat")
else: else:
await m.reply(f"**Skipped ⏭** \n**🎧 Now Playing** - [{op[0]}]({op[1]}) | `{op[2]}`", disable_web_page_preview=True) await m.reply(f"⏭ **Skipped streaming.**\n\n💡 **now playing:** [{op[0]}]({op[1]}) | `{op[2]}`", disable_web_page_preview=True)
else: else:
skip = m.text.split(None, 1)[1] skip = m.text.split(None, 1)[1]
OP = "**Removed the following songs from Queue:-**" OP = "🗑 **removed song from queue:**"
if chat_id in QUEUE: if chat_id in QUEUE:
items = [int(x) for x in skip.split(" ") if x.isdigit()] items = [int(x) for x in skip.split(" ") if x.isdigit()]
items.sort(reverse=True) items.sort(reverse=True)
@ -61,11 +61,11 @@ async def stop(client, m: Message):
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 m.reply("**Stopped Streaming ⏹️**") await m.reply("✅ **streaming has ended.**")
except Exception as e: except Exception as e:
await m.reply(f"**ERROR** \n`{e}`") await m.reply(f"**ERROR:** \n`{e}`")
else: else:
await m.reply("`Nothing is Streaming`") await m.reply("❌ **nothing in streaming**")
@Client.on_message(command(["pause", f"pause@{BOT_USERNAME}"]) & other_filters) @Client.on_message(command(["pause", f"pause@{BOT_USERNAME}"]) & other_filters)
@ -75,11 +75,11 @@ async def pause(client, m: Message):
if chat_id in QUEUE: if chat_id in QUEUE:
try: try:
await call_py.pause_stream(chat_id) await call_py.pause_stream(chat_id)
await m.reply("**Paused Streaming ⏸️**") await m.reply("⏸️ **streaming has paused**")
except Exception as e: except Exception as e:
await m.reply(f"**ERROR** \n`{e}`") await m.reply(f"**ERROR:** \n`{e}`")
else: else:
await m.reply("`Nothing is Streaming`") await m.reply("❌ **nothing in streaming**")
@Client.on_message(command(["resume", f"resume@{BOT_USERNAME}"]) & other_filters) @Client.on_message(command(["resume", f"resume@{BOT_USERNAME}"]) & other_filters)
@ -89,8 +89,8 @@ async def resume(client, m: Message):
if chat_id in QUEUE: if chat_id in QUEUE:
try: try:
await call_py.resume_stream(chat_id) await call_py.resume_stream(chat_id)
await m.reply("**Resumed Streaming ▶**") await m.reply("▶ **streaming has resumed.**")
except Exception as e: except Exception as e:
await m.reply(f"**ERROR** \n`{e}`") await m.reply(f"**ERROR:** \n`{e}`")
else: else:
await m.reply("`Nothing is Streaming`") await m.reply("❌ **nothing in streaming**")