gigidsss/Plex-Bot-Music
1
0
Fork 0
mirror of https://github.com/jarulsamy/Plex-Bot.git synced 2024-08-19 15:01:55 +02:00
Code Issues Projects Releases Wiki Activity

Merge branch 'master' of github.com:jarulsamy/Plex-Bot

Browse Source
This commit is contained in:
Joshua Arulsamy 2022-08-03 16:45:12 -06:00
commit 360416bb02
1 changed files with 16 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
PlexBot/bot.py
View File

@ -210,7 +210,7 @@ class Plex(commands.Cog):
self.is_looping = False self.is_looping = False
self.loop_queue = None self.loop_queue = None
self.np_message_id = None self.np_message_id = None
self.show_queue_message_ids = [] self.show_queue_message_ids = []
self.ctx = None self.ctx = None
# Initialize events # Initialize events
@ -307,13 +307,13 @@ class Plex(commands.Cog):
while self.voice_channel and self.voice_channel.is_playing(): while self.voice_channel and self.voice_channel.is_playing():
bot_log.debug("waiting for track to finish") bot_log.debug("waiting for track to finish")
await asyncio.sleep(2) await asyncio.sleep(2)
bot_log.debug("track finished") bot_log.debug("track finished")
if self.voice_channel: if self.voice_channel:
self.voice_channel.play(audio_stream, after=self._toggle_next) self.voice_channel.play(audio_stream, after=self._toggle_next)
plex_log.debug("%s - URL: %s", self.current_track, track_url) plex_log.debug("%s - URL: %s", self.current_track, track_url)
embed, img = self._build_embed_track(self.current_track) embed, img = self._build_embed_track(self.current_track)
self.np_message_id = await self.ctx.send(embed=embed, file=img) self.np_message_id = await self.ctx.send(embed=embed, file=img)
@ -329,7 +329,7 @@ class Plex(commands.Cog):
self.current_track = await self.play_queue.get() self.current_track = await self.play_queue.get()
except CancelledError: except CancelledError:
bot_log.debug("failed to pop queue") bot_log.debug("failed to pop queue")
if not self.current_track and self.loop_queue: if not self.current_track and self.loop_queue:
bot_log.debug("swapping loop queue and play queue") bot_log.debug("swapping loop queue and play queue")
for item in self.loop_queue: for item in self.loop_queue:
@ -339,7 +339,7 @@ class Plex(commands.Cog):
self.current_track = await self.play_queue.get() self.current_track = await self.play_queue.get()
except CancelledError: except CancelledError:
bot_log.debug("failed to pop queue") bot_log.debug("failed to pop queue")
async def _audio_player_task(self): async def _audio_player_task(self):
""" """
Coroutine to handle playback and queuing Coroutine to handle playback and queuing
@ -425,7 +425,7 @@ class Plex(commands.Cog):
art_file = discord.File(img, filename="image0.png") art_file = discord.File(img, filename="image0.png")
else: else:
art_file = None art_file = None
# Get appropiate status message # Get appropiate status message
if type_ == "play": if type_ == "play":
title = f"Now Playing - {track.title}" title = f"Now Playing - {track.title}"
@ -551,7 +551,7 @@ class Plex(commands.Cog):
self.voice_channel = await ctx.author.voice.channel.connect() self.voice_channel = await ctx.author.voice.channel.connect()
bot_log.debug("Connected to vc.") bot_log.debug("Connected to vc.")
except asyncio.exceptions.TimeoutError: except asyncio.exceptions.TimeoutError:
bot_log.debug("Cannot connect to vc - timeout") bot_log.debug("Cannot connect to vc - timeout")
@command() @command()
async def play(self, ctx, *args): async def play(self, ctx, *args):
@ -661,13 +661,13 @@ class Plex(commands.Cog):
for item in items: for item in items:
await self.play_queue.put(item) await self.play_queue.put(item)
bot_log.debug("Added to queue - %s", title) bot_log.debug("Added to queue - %s", title)
except MediaNotFoundError: except MediaNotFoundError:
await self.ctx.send(message="Playlist "+title+" seems to be empty!") await self.ctx.send(message="Playlist "+title+" seems to be empty!")
bot_log.debug("Playlist empty - %s", title) bot_log.debug("Playlist empty - %s", title)
@command() @command()
async def playlist(self, ctx, *args): async def playlist(self, ctx, *args):
""" """
@ -712,9 +712,9 @@ class Plex(commands.Cog):
# Save the context to use with async callbacks # Save the context to use with async callbacks
self.ctx = ctx self.ctx = ctx
title = " ".join(args) title = " ".join(args)
await self.play_playlist(title,shuffle=True) await self.play_playlist(title,shuffle=True)
@command() @command()
async def show_playlists(self, ctx, *args): async def show_playlists(self, ctx, *args):
""" """
@ -789,7 +789,7 @@ class Plex(commands.Cog):
Raises: Raises:
None None
""" """
bot_log.debug("Looping "+str(self.current_track)) bot_log.debug("Looping "+str(self.current_track))
self.is_looping = self.current_track self.is_looping = self.current_track
@command() @command()
@ -828,7 +828,7 @@ class Plex(commands.Cog):
Raises: Raises:
None None
""" """
bot_log.debug("Looping current queue") bot_log.debug("Looping current queue")
self.is_looping = False self.is_looping = False
@command() @command()
@ -847,7 +847,7 @@ class Plex(commands.Cog):
""" """
bot_log.debug("Unlooping") bot_log.debug("Unlooping")
self.loop_queue = None self.loop_queue = None
@command() @command()
async def pause(self, ctx): async def pause(self, ctx):