108 lines
4.0 KiB
Python
108 lines
4.0 KiB
Python
|
import os
|
||
|
|
import re
|
||
|
|
import pafy
|
||
|
|
import time
|
||
|
|
import asyncio
|
||
|
|
import ffmpeg
|
||
|
|
from asyncio import sleep
|
||
|
|
|
||
|
|
from pyrogram import Client, filters
|
||
|
|
from pyrogram.types import Message
|
||
|
|
from pytgcalls import GroupCallFactory
|
||
|
|
from youtube_dl import YoutubeDL
|
||
|
|
|
||
|
|
from config import API_ID, API_HASH, SESSION_NAME, BOT_USERNAME
|
||
|
|
from helpers.decorators import authorized_users_only
|
||
|
|
from helpers.filters import command
|
||
|
|
|
||
|
|
|
||
|
|
ydl_opts = {
|
||
|
|
"geo-bypass": True,
|
||
|
|
"nocheckcertificate": True,
|
||
|
|
}
|
||
|
|
ydl = YoutubeDL(ydl_opts)
|
||
|
|
|
||
|
|
STREAM = {8}
|
||
|
|
VIDEO_CALL = {}
|
||
|
|
|
||
|
|
app = Client(
|
||
|
|
SESSION_NAME,
|
||
|
|
api_id=API_ID,
|
||
|
|
api_hash=API_HASH,
|
||
|
|
)
|
||
|
|
group_call_factory = GroupCallFactory(app, GroupCallFactory.MTPROTO_CLIENT_TYPE.PYROGRAM)
|
||
|
|
|
||
|
|
|
||
|
|
@Client.on_message(command(["vstream", f"vstream@{BOT_USERNAME}"]) & filters.group & ~filters.edited)
|
||
|
|
@authorized_users_only
|
||
|
|
async def stream(client, m: Message):
|
||
|
|
replied = m.reply_to_message
|
||
|
|
if not replied:
|
||
|
|
if len(m.command) < 2:
|
||
|
|
await m.reply("💡 reply to video or provide youtube video url to start video streaming")
|
||
|
|
else:
|
||
|
|
video = m.text.split(None, 1)[1]
|
||
|
|
youtube_regex = (
|
||
|
|
r'(https?://)?(www\.)?'
|
||
|
|
'(youtube|youtu|youtube-nocookie)\.(com|be)/'
|
||
|
|
'(watch\?v=|embed/|v/|.+\?v=)?([^&=%\?]{11})')
|
||
|
|
youtube_regex_match = re.match(youtube_regex, video)
|
||
|
|
if youtube_regex_match:
|
||
|
|
try:
|
||
|
|
yt = pafy.new(video)
|
||
|
|
best = yt.getbest()
|
||
|
|
video_url = best.url
|
||
|
|
except Exception as e:
|
||
|
|
await m.reply(f"🚫 **error** - `{e}`")
|
||
|
|
return
|
||
|
|
msg = await m.reply("🔁 **starting video streaming...**")
|
||
|
|
chat_id = m.chat.id
|
||
|
|
await asyncio.sleep(1)
|
||
|
|
try:
|
||
|
|
group_call = group_call_factory.get_group_call()
|
||
|
|
await group_call.join(chat_id)
|
||
|
|
await group_call.start_video(video_url, repeat=False)
|
||
|
|
VIDEO_CALL[chat_id] = group_call
|
||
|
|
await msg.edit((f"💡 **started [video streaming]({video_url}) !\n\n» join to video chat on the top to watch streaming."), disable_web_page_preview=True)
|
||
|
|
except Exception as e:
|
||
|
|
await msg.edit(f"**Error** -- `{e}`")
|
||
|
|
else:
|
||
|
|
msg = await m.reply("🔁 **starting video streaming...**")
|
||
|
|
chat_id = m.chat.id
|
||
|
|
await asyncio.sleep(1)
|
||
|
|
try:
|
||
|
|
group_call = group_call_factory.get_group_call()
|
||
|
|
await group_call.join(chat_id)
|
||
|
|
await group_call.start_video(video, repeat=False)
|
||
|
|
VIDEO_CALL[chat_id] = group_call
|
||
|
|
await msg.edit((f"💡 **started [video streaming]({video}) !\n\n» join to video chat on the top to watch streaming."), disable_web_page_preview=True)
|
||
|
|
except Exception as e:
|
||
|
|
await msg.edit(f"**🚫 error** - `{e}`")
|
||
|
|
|
||
|
|
elif replied.video or replied.document:
|
||
|
|
msg = await m.reply("📥 downloading video...")
|
||
|
|
video = await client.download_media(m.reply_to_message)
|
||
|
|
chat_id = m.chat.id
|
||
|
|
await asyncio.sleep(2)
|
||
|
|
try:
|
||
|
|
group_call = group_call_factory.get_group_call()
|
||
|
|
await group_call.join(chat_id)
|
||
|
|
await group_call.start_video(video)
|
||
|
|
VIDEO_CALL[chat_id] = group_call
|
||
|
|
await msg.edit("💡 **video streaming started!**\n\n» **join to video chat to watch the video.**")
|
||
|
|
except Exception as e:
|
||
|
|
await msg.edit(f"**🚫 error** - `{e}`")
|
||
|
|
else:
|
||
|
|
await m.reply("💭 please reply to video or video file to stream")
|
||
|
|
|
||
|
|
|
||
|
|
@Client.on_message(command(["vstop", f"vstop@{BOT_USERNAME}"]) & filters.group & ~filters.edited)
|
||
|
|
@authorized_users_only
|
||
|
|
async def stopvideo(client, m: Message):
|
||
|
|
chat_id = m.chat.id
|
||
|
|
try:
|
||
|
|
await VIDEO_CALL[chat_id].stop()
|
||
|
|
await m.reply("✅ **streaming has ended successfully !**")
|
||
|
|
except Exception as e:
|
||
|
|
await m.reply(f"🚫 **error** - `{e}`")
|