Update music.py

ok
This commit is contained in:
Tofik Denianto 2021-10-30 03:24:14 +07:00 committed by GitHub
parent 617af04c04
commit 98ae3ce740
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -2,29 +2,29 @@
# Commit Start Date 20/10/2021
# Finished On 28/10/2021
import os
import re
import asyncio
from driver.veez import call_py
from pytgcalls import StreamType
import re
from config import BOT_USERNAME, GROUP_SUPPORT, IMG_1, IMG_2, UPDATES_CHANNEL
from driver.filters import command, other_filters
from pyrogram import Client, filters
from youtubesearchpython import VideosSearch
from driver.queues import QUEUE, add_to_queue
from driver.veez import call_py
from pyrogram import Client
from pyrogram.types import InlineKeyboardButton, InlineKeyboardMarkup, Message
from pytgcalls import StreamType
from pytgcalls.types.input_stream import AudioPiped
from config import BOT_USERNAME, IMG_1, IMG_2, GROUP_SUPPORT, UPDATES_CHANNEL
from pyrogram.types import Message, InlineKeyboardButton, InlineKeyboardMarkup
from youtubesearchpython import VideosSearch
def ytsearch(query):
try:
search = VideosSearch(query, limit=1)
for r in search.result()["result"]:
ytid = r['id']
if len(r['title']) > 34:
songname = r['title'][:60] + "..."
ytid = r["id"]
if len(r["title"]) > 34:
songname = r["title"][:60] + "..."
else:
songname = r['title']
songname = r["title"]
url = f"https://www.youtube.com/watch?v={ytid}"
return [songname, url]
except Exception as e:
@ -34,17 +34,17 @@ def ytsearch(query):
async def ytdl(link):
proc = await asyncio.create_subprocess_exec(
'yt-dlp',
'-g',
'-f',
'bestaudio',
f'{link}',
"yt-dlp",
"-g",
"-f",
"bestaudio",
f"{link}",
stdout=asyncio.subprocess.PIPE,
stderr=asyncio.subprocess.PIPE,
)
stdout, stderr = await proc.communicate()
if stdout:
return 1, stdout.decode().split('\n')[0]
return 1, stdout.decode().split("\n")[0]
else:
return 0, stderr.decode()
@ -56,11 +56,11 @@ async def play(client, m: Message):
[
[
InlineKeyboardButton(
text="✨ ɢʀᴏᴜᴘ",
url=f"https://t.me/{GROUP_SUPPORT}"),
text="✨ ɢʀᴏᴜᴘ", url=f"https://t.me/{GROUP_SUPPORT}"
),
InlineKeyboardButton(
text="🌻 ᴄʜᴀɴɴᴇʟ",
url=f"https://t.me/{UPDATES_CHANNEL}")
text="🌻 ᴄʜᴀɴɴᴇʟ", url=f"https://t.me/{UPDATES_CHANNEL}"
),
]
]
)
@ -103,7 +103,9 @@ async def play(client, m: Message):
)
else:
if len(m.command) < 2:
await m.reply("» reply to an **audio file** or **give something to search.**")
await m.reply(
"» reply to an **audio file** or **give something to search.**"
)
else:
suhu = await m.reply("🔎 **searching...**")
query = m.text.split(None, 1)[1]
@ -118,7 +120,9 @@ async def play(client, m: Message):
await suhu.edit(f"❌ yt-dl issues detected\n\n» `{ytlink}`")
else:
if chat_id in QUEUE:
pos = add_to_queue(chat_id, songname, ytlink, url, "Audio", 0)
pos = add_to_queue(
chat_id, songname, ytlink, url, "Audio", 0
)
await suhu.delete()
await m.reply_photo(
photo=f"{IMG_1}",
@ -146,7 +150,9 @@ async def play(client, m: Message):
else:
if len(m.command) < 2:
await m.reply("» reply to an **audio file** or **give something to search.**")
await m.reply(
"» reply to an **audio file** or **give something to search.**"
)
else:
suhu = await m.reply("🔎 **searching...**")
query = m.text.split(None, 1)[1]
@ -187,8 +193,10 @@ async def play(client, m: Message):
except Exception as ep:
await m.reply_text(f"🚫 error: `{ep}`")
# stream is used for live streaming only
@Client.on_message(command(["stream", f"stream@{BOT_USERNAME}"]) & other_filters)
async def stream(client, m: Message):
@ -196,11 +204,11 @@ async def stream(client, m: Message):
[
[
InlineKeyboardButton(
text="✨ ɢʀᴏᴜᴘ",
url=f"https://t.me/{GROUP_SUPPORT}"),
text="✨ ɢʀᴏᴜᴘ", url=f"https://t.me/{GROUP_SUPPORT}"
),
InlineKeyboardButton(
text="🌻 ᴄʜᴀɴɴᴇʟ",
url=f"https://t.me/{UPDATES_CHANNEL}")
text="🌻 ᴄʜᴀɴɴᴇʟ", url=f"https://t.me/{UPDATES_CHANNEL}"
),
]
]
)