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

something

Browse Source
This commit is contained in:
levina 2022-01-18 14:01:51 +07:00 committed by GitHub
parent 5cb4d4076e
commit 923a065290
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
driver/utils.py
View File

@ -3,7 +3,12 @@ import asyncio
from driver.veez import bot, call_py from driver.veez import bot, call_py
from pytgcalls.types import Update from pytgcalls.types import Update
from pytgcalls.types.input_stream import AudioPiped, AudioVideoPiped from pytgcalls.types.input_stream import AudioPiped, AudioVideoPiped
from driver.queues import QUEUE, clear_queue, get_queue, pop_an_item from driver.queues import (
QUEUE,
clear_queue,
get_queue,
pop_an_item,
)
from pytgcalls.types.input_stream.quality import ( from pytgcalls.types.input_stream.quality import (
HighQualityAudio, HighQualityAudio,
HighQualityVideo, HighQualityVideo,
@ -45,6 +50,7 @@ async def skip_current_song(chat_id):
type = chat_queue[1][3] type = chat_queue[1][3]
resol = chat_queue[1][4] resol = chat_queue[1][4]
image = chat_queue[1][5] image = chat_queue[1][5]
duration = chat_queue[1][6]
if type == "Audio": if type == "Audio":
await call_py.change_stream( await call_py.change_stream(
chat_id, chat_id,
@ -68,7 +74,7 @@ async def skip_current_song(chat_id):
) )
) )
pop_an_item(chat_id) pop_an_item(chat_id)
return [songname, link, type, image] return [songname, link, type, image, duration]
except: except:
await call_py.leave_group_call(chat_id) await call_py.leave_group_call(chat_id)
clear_queue(chat_id) clear_queue(chat_id)
@ -121,7 +127,7 @@ async def stream_end_handler(_, u: Update):
elif op==2: elif op==2:
await bot.send_message(chat_id, "❌ an error occurred\n\n» **Clearing** __Queues__ and leaving video chat.") await bot.send_message(chat_id, "❌ an error occurred\n\n» **Clearing** __Queues__ and leaving video chat.")
else: else:
await bot.send_message(chat_id, f"💡 **Streaming next track**\n\n🏷 **Name:** [{op[0]}]({op[1]}) | `{op[2]}`\n💭 **Chat:** `{chat_id}`", disable_web_page_preview=True, reply_markup=keyboard) await bot.send_message(chat_id, f"💡 **Streaming next track**\n\n🏷 **Name:** [{op[0]}]({op[1]}) | `{op[2]}`\n⏱ **Duration:** `{op[3]}`", disable_web_page_preview=True, reply_markup=keyboard)
else: else:
pass pass