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

fixes

Browse Source
This commit is contained in:
levina 2021-09-13 13:38:04 +07:00 committed by GitHub
parent 0863d87fcd
commit db6d506b7a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
bot/videoplayer.py
View File

@ -126,10 +126,11 @@ async def startvideo(client, m: Message):
),
stream_type=StreamType().local_stream,
)
await msg.reply_photo(
await m.reply_photo(
photo="https://telegra.ph/file/422650a849a8d6831bde8.png",
reply_markup=keyboard,
caption=f"💡 **video streaming started!**\n\n🏷 **Name:** {title}\n⏱ **Duration:** `{duration} minutes`\n\n» **join to video chat on the top to watch the video.**")
return await msg.delete()
await idle()
except Exception as e:
await msg.edit(f"🚫 **error** | `{e}`")
@ -138,7 +139,7 @@ async def startvideo(client, m: Message):
msg = await m.reply("📥 downloading video...")
video = await client.download_media(m.reply_to_message)
chat_id = m.chat.id
await msg.edit("🔁 **preparing...**")
await msg.edit("🔁 **preparing video...**")
os.system(f"ffmpeg -i '{video}' -f s16le -ac 1 -ar 48000 'audio{chat_id}.raw' -y -f rawvideo -r 20 -pix_fmt yuv420p -vf scale=640:360 'video{chat_id}.raw' -y")
try:
audio_file = f'audio{chat_id}.raw'
@ -164,12 +165,13 @@ async def startvideo(client, m: Message):
),
stream_type=StreamType().local_stream,
)
await msg.reply_photo(
await m.reply_photo(
photo="https://telegra.ph/file/dc90e91cc77e68568e7b4.png",
reply_markup=keyboard,
caption=f"💡 **video streaming started!**\n\n🏷 **Name:** {title}\n⏱ **Duration:** `{duration} minutes`\n\n» **join to video chat on the top to watch the video.**")
caption=f"💡 **video streaming started !**\n\n» **join to video chat on the top to watch the video.**")
return await msg.delete()
except Exception as e:
await msg.edit(f"🚫 **Error** | `{e}`")
await msg.edit(f"🚫 **error** | `{e}`")
await idle()
else:
await m.reply("💭 please reply to video or video file to stream")
@ -196,4 +198,4 @@ async def stopvideo(client, m: Message):
@call_py.on_stream_end()
async def handler(client: PyTgCalls, update: Update):
chat_id = update.chat.id
await leave_call(chat_id)
await call_py.leave_group_call(chat_id)