|
|
@ -2,9 +2,10 @@ import discord |
|
|
|
import yt_dlp as youtube_dl |
|
|
|
import yt_dlp as youtube_dl |
|
|
|
import time |
|
|
|
import time |
|
|
|
import asyncio |
|
|
|
import asyncio |
|
|
|
|
|
|
|
import subprocess |
|
|
|
|
|
|
|
|
|
|
|
g_client = discord.Client() |
|
|
|
g_client = discord.Client() |
|
|
|
queue = [] |
|
|
|
queue = []#dicts with keys link and type |
|
|
|
last_playing = {} |
|
|
|
last_playing = {} |
|
|
|
voice_client = None |
|
|
|
voice_client = None |
|
|
|
last_start = 0 |
|
|
|
last_start = 0 |
|
|
@ -15,14 +16,28 @@ async def on_ready(): |
|
|
|
await asyncio.sleep(.1) |
|
|
|
await asyncio.sleep(.1) |
|
|
|
if len(queue) > 0: |
|
|
|
if len(queue) > 0: |
|
|
|
if not voice_client.is_playing() and voice_client is not None: |
|
|
|
if not voice_client.is_playing() and voice_client is not None: |
|
|
|
|
|
|
|
link = None |
|
|
|
|
|
|
|
res = {} |
|
|
|
|
|
|
|
if queue[0]["type"] == "yt": |
|
|
|
ydl = youtube_dl.YoutubeDL({"simulate": True}) |
|
|
|
ydl = youtube_dl.YoutubeDL({"simulate": True}) |
|
|
|
res = ydl.extract_info(queue[0], |
|
|
|
try: |
|
|
|
|
|
|
|
res = ydl.extract_info(queue[0]["link"], |
|
|
|
force_generic_extractor=ydl.params.get('force_generic_extractor', False))#lifted the second bit from the ytdl innards |
|
|
|
force_generic_extractor=ydl.params.get('force_generic_extractor', False))#lifted the second bit from the ytdl innards |
|
|
|
link = None |
|
|
|
except: |
|
|
|
|
|
|
|
queue.pop(0) |
|
|
|
|
|
|
|
continue |
|
|
|
|
|
|
|
if "requested_formats" in res: |
|
|
|
for format in res["requested_formats"]: |
|
|
|
for format in res["requested_formats"]: |
|
|
|
if not (format["asr"] is None): |
|
|
|
if not (format["asr"] is None): |
|
|
|
link = format["url"] |
|
|
|
link = format["url"] |
|
|
|
|
|
|
|
else: link = res["url"] |
|
|
|
last_playing = res |
|
|
|
last_playing = res |
|
|
|
|
|
|
|
last_playing["raw"] = False |
|
|
|
|
|
|
|
else: |
|
|
|
|
|
|
|
link = queue[0]["link"] |
|
|
|
|
|
|
|
last_playing = {"raw":True} |
|
|
|
|
|
|
|
result = subprocess.run(['ffprobe', '-v', 'error', '-show_entries', 'format=duration', '-of', 'default=noprint_wrappers=1:nokey=1', queue[0]["link"]], stdout=subprocess.PIPE, stderr=subprocess.STDOUT) |
|
|
|
|
|
|
|
res["duration"] = int(float(result.stdout))#you actually need to do this laffo |
|
|
|
voice_client.play(discord.PCMVolumeTransformer(discord.FFmpegPCMAudio(link, before_options="-reconnect 1 -reconnect_streamed 1 -reconnect_delay_max 5"), volume=1.0)) |
|
|
|
voice_client.play(discord.PCMVolumeTransformer(discord.FFmpegPCMAudio(link, before_options="-reconnect 1 -reconnect_streamed 1 -reconnect_delay_max 5"), volume=1.0)) |
|
|
|
print("playan") |
|
|
|
print("playan") |
|
|
|
sav = queue[0] |
|
|
|
sav = queue[0] |
|
|
@ -51,15 +66,21 @@ async def on_message(message): |
|
|
|
return |
|
|
|
return |
|
|
|
|
|
|
|
|
|
|
|
if message.content.startswith("*play"): |
|
|
|
if message.content.startswith("*play"): |
|
|
|
|
|
|
|
if (len(message.content.split(" ")) < 2): |
|
|
|
|
|
|
|
await message.channel.send("missing argument") |
|
|
|
|
|
|
|
return |
|
|
|
try: |
|
|
|
try: |
|
|
|
voice_client = await message.author.voice.channel.connect() |
|
|
|
voice_client = await message.author.voice.channel.connect() |
|
|
|
except: #already conn'd/user not in chan/probably something else (?). fails are not /broadly/ (really) destructive neway so who cares#nevermind |
|
|
|
except: #already conn'd/user not in chan/probably something else (?). fails are not /broadly/ (really) destructive neway so who cares#nevermind |
|
|
|
print("AAHHHHHHHHHHHHHHHHHHHH OH GOD") |
|
|
|
print("AAHHHHHHHHHHHHHHHHHHHH OH GOD") |
|
|
|
pass #it's ok if we do it ON PURPOSE ;^) |
|
|
|
pass #it's ok if we do it ON PURPOSE ;^) |
|
|
|
queue.append(message.content.split(" ")[1]) |
|
|
|
queue.append({"link":message.content.split(" ")[1], "type":("raw" if message.content.split(" ")[0] == "*playraw" else "yt")}) |
|
|
|
await message.channel.send("k") |
|
|
|
await message.channel.send("k") |
|
|
|
|
|
|
|
|
|
|
|
if message.content.startswith("*lp"): |
|
|
|
if message.content == "*np": |
|
|
|
|
|
|
|
if last_playing["raw"]: |
|
|
|
|
|
|
|
await message.channel.send("`source is raw! link: {0}`".format(queue[0]["link"])) |
|
|
|
|
|
|
|
return |
|
|
|
embed = discord.Embed(title="now playing...") |
|
|
|
embed = discord.Embed(title="now playing...") |
|
|
|
embed.add_field(name="song:", value=last_playing["title"], inline=False) |
|
|
|
embed.add_field(name="song:", value=last_playing["title"], inline=False) |
|
|
|
embed.set_image(url = last_playing["thumbnail"]) |
|
|
|
embed.set_image(url = last_playing["thumbnail"]) |
|
|
@ -69,7 +90,7 @@ async def on_message(message): |
|
|
|
if message.content.startswith("*q"): |
|
|
|
if message.content.startswith("*q"): |
|
|
|
embed = discord.Embed(title="queue") |
|
|
|
embed = discord.Embed(title="queue") |
|
|
|
for q in queue: |
|
|
|
for q in queue: |
|
|
|
embed.add_field(name="", value=q, inline=False) |
|
|
|
embed.add_field(name=".", value=q["link"], inline=False) |
|
|
|
await message.channel.send(embed=embed) |
|
|
|
await message.channel.send(embed=embed) |
|
|
|
|
|
|
|
|
|
|
|
if message.content.startswith("*s"): |
|
|
|
if message.content.startswith("*s"): |
|
|
|