mirror of
https://github.com/jarulsamy/Plex-Bot.git
synced 2024-08-19 15:01:55 +02:00
Compare commits
No commits in common. "19360e3101e1bbfc29dfe59e2c960777238c80f0" and "6521e7e26c0a82bc3fbe587da432c9c344d625fa" have entirely different histories.
19360e3101
...
6521e7e26c
@ -1,6 +1,8 @@
|
|||||||
"""
|
"""
|
||||||
Plex music bot for discord.
|
Plex music bot for discord.
|
||||||
|
|
||||||
|
Do not import this module, it is intended to be
|
||||||
|
used exclusively within a docker environment.
|
||||||
"""
|
"""
|
||||||
import logging
|
import logging
|
||||||
import sys
|
import sys
|
||||||
@ -17,7 +19,7 @@ plex_log = logging.getLogger("Plex")
|
|||||||
bot_log = logging.getLogger("Bot")
|
bot_log = logging.getLogger("Bot")
|
||||||
|
|
||||||
|
|
||||||
def load_config(basedir: str,filename: str) -> Dict[str, str]:
|
def load_config(filename: str) -> Dict[str, str]:
|
||||||
"""Loads config from yaml file
|
"""Loads config from yaml file
|
||||||
|
|
||||||
Grabs key/value config pairs from a file.
|
Grabs key/value config pairs from a file.
|
||||||
@ -33,12 +35,12 @@ def load_config(basedir: str,filename: str) -> Dict[str, str]:
|
|||||||
"""
|
"""
|
||||||
# All config files should be in /config
|
# All config files should be in /config
|
||||||
# for docker deployment.
|
# for docker deployment.
|
||||||
filename = Path(basedir, filename)
|
filename = Path("/config", filename)
|
||||||
try:
|
try:
|
||||||
with open(filename, "r") as config_file:
|
with open(filename, "r") as config_file:
|
||||||
config = yaml.safe_load(config_file)
|
config = yaml.safe_load(config_file)
|
||||||
except FileNotFoundError:
|
except FileNotFoundError:
|
||||||
root_log.fatal("Configuration file not found at '"+str(filename)+"'.")
|
root_log.fatal("Configuration file not found.")
|
||||||
sys.exit(-1)
|
sys.exit(-1)
|
||||||
|
|
||||||
# Convert str level type to logging constant
|
# Convert str level type to logging constant
|
||||||
@ -54,7 +56,7 @@ def load_config(basedir: str,filename: str) -> Dict[str, str]:
|
|||||||
config["plex"]["log_level"] = levels[config["plex"]["log_level"].upper()]
|
config["plex"]["log_level"] = levels[config["plex"]["log_level"].upper()]
|
||||||
config["discord"]["log_level"] = levels[config["discord"]["log_level"].upper()]
|
config["discord"]["log_level"] = levels[config["discord"]["log_level"].upper()]
|
||||||
|
|
||||||
if config["lyrics"] and config["lyrics"]["token"].lower() == "none":
|
if config["lyrics"]["token"].lower() == "none":
|
||||||
config["lyrics"] = None
|
config["lyrics"]["token"] = None
|
||||||
|
|
||||||
return config
|
return config
|
||||||
|
@ -11,11 +11,7 @@ from .bot import General
|
|||||||
from .bot import Plex
|
from .bot import Plex
|
||||||
|
|
||||||
# Load config from file
|
# Load config from file
|
||||||
configdir = "config"
|
config = load_config("config.yaml")
|
||||||
from os import geteuid
|
|
||||||
if geteuid() == 0:
|
|
||||||
configdir = "/config"
|
|
||||||
config = load_config(configdir,"config.yaml")
|
|
||||||
|
|
||||||
BOT_PREFIX = config["discord"]["prefix"]
|
BOT_PREFIX = config["discord"]["prefix"]
|
||||||
TOKEN = config["discord"]["token"]
|
TOKEN = config["discord"]["token"]
|
||||||
@ -24,10 +20,7 @@ BASE_URL = config["plex"]["base_url"]
|
|||||||
PLEX_TOKEN = config["plex"]["token"]
|
PLEX_TOKEN = config["plex"]["token"]
|
||||||
LIBRARY_NAME = config["plex"]["library_name"]
|
LIBRARY_NAME = config["plex"]["library_name"]
|
||||||
|
|
||||||
if config["lyrics"]:
|
LYRICS_TOKEN = config["lyrics"]["token"]
|
||||||
LYRICS_TOKEN = config["lyrics"]["token"]
|
|
||||||
else:
|
|
||||||
LYRICS_TOKEN = None
|
|
||||||
|
|
||||||
# Set appropiate log level
|
# Set appropiate log level
|
||||||
root_log = logging.getLogger()
|
root_log = logging.getLogger()
|
||||||
|
@ -6,6 +6,7 @@ from urllib.request import urlopen
|
|||||||
import requests
|
import requests
|
||||||
|
|
||||||
import discord
|
import discord
|
||||||
|
import lyricsgenius
|
||||||
from async_timeout import timeout
|
from async_timeout import timeout
|
||||||
from discord import FFmpegPCMAudio
|
from discord import FFmpegPCMAudio
|
||||||
from discord.ext import commands
|
from discord.ext import commands
|
||||||
@ -31,13 +32,11 @@ Plex:
|
|||||||
play <SONG_NAME> - Play a song from the plex server.
|
play <SONG_NAME> - Play a song from the plex server.
|
||||||
album <ALBUM_NAME> - Queue an entire album to play.
|
album <ALBUM_NAME> - Queue an entire album to play.
|
||||||
playlist <PLAYLIST_NAME> - Queue an entire playlist to play.
|
playlist <PLAYLIST_NAME> - Queue an entire playlist to play.
|
||||||
show_playlists <ARG> <ARG> - Query for playlists with a name matching any of the arguments.
|
|
||||||
lyrics - Print the lyrics of the song (Requires Genius API)
|
lyrics - Print the lyrics of the song (Requires Genius API)
|
||||||
np - Print the current playing song.
|
np - Print the current playing song.
|
||||||
stop - Halt playback and leave vc.
|
stop - Halt playback and leave vc.
|
||||||
pause - Pause playback.
|
pause - Pause playback.
|
||||||
resume - Resume playback.
|
resume - Resume playback.
|
||||||
skip - Skip the current song.
|
|
||||||
clear - Clear play queue.
|
clear - Clear play queue.
|
||||||
|
|
||||||
[] - Optional args.
|
[] - Optional args.
|
||||||
@ -183,7 +182,6 @@ class Plex(commands.Cog):
|
|||||||
self.bot_prefix = bot.command_prefix
|
self.bot_prefix = bot.command_prefix
|
||||||
|
|
||||||
if kwargs["lyrics_token"]:
|
if kwargs["lyrics_token"]:
|
||||||
import lyricsgenius
|
|
||||||
self.genius = lyricsgenius.Genius(kwargs["lyrics_token"])
|
self.genius = lyricsgenius.Genius(kwargs["lyrics_token"])
|
||||||
else:
|
else:
|
||||||
plex_log.warning("No lyrics token specified, lyrics disabled")
|
plex_log.warning("No lyrics token specified, lyrics disabled")
|
||||||
@ -268,15 +266,6 @@ class Plex(commands.Cog):
|
|||||||
except NotFound:
|
except NotFound:
|
||||||
raise MediaNotFoundError("Playlist cannot be found")
|
raise MediaNotFoundError("Playlist cannot be found")
|
||||||
|
|
||||||
def _get_playlists(self):
|
|
||||||
"""
|
|
||||||
Search the Plex music db for playlist
|
|
||||||
|
|
||||||
Returns:
|
|
||||||
List of plexapi.playlist
|
|
||||||
"""
|
|
||||||
return self.pms.playlists()
|
|
||||||
|
|
||||||
async def _play(self):
|
async def _play(self):
|
||||||
"""
|
"""
|
||||||
Heavy lifting of playing songs
|
Heavy lifting of playing songs
|
||||||
@ -447,7 +436,7 @@ class Plex(commands.Cog):
|
|||||||
return embed, art_file
|
return embed, art_file
|
||||||
|
|
||||||
@staticmethod
|
@staticmethod
|
||||||
def _build_embed_playlist(self, playlist, title, descrip):
|
def _build_embed_playlist(self, playlist):
|
||||||
"""
|
"""
|
||||||
Creates a pretty embed card for playlists
|
Creates a pretty embed card for playlists
|
||||||
|
|
||||||
@ -466,14 +455,13 @@ class Plex(commands.Cog):
|
|||||||
None
|
None
|
||||||
"""
|
"""
|
||||||
# Grab the relevant thumbnail
|
# Grab the relevant thumbnail
|
||||||
try:
|
|
||||||
img_stream = requests.get(self.pms.url(playlist.composite, True), stream=True).raw
|
img_stream = requests.get(self.pms.url(playlist.composite, True), stream=True).raw
|
||||||
img = io.BytesIO(img_stream.read())
|
img = io.BytesIO(img_stream.read())
|
||||||
except:
|
|
||||||
raise MediaNotFoundError("no image available")
|
|
||||||
|
|
||||||
# Attach to discord embed
|
# Attach to discord embed
|
||||||
art_file = discord.File(img, filename="image0.png")
|
art_file = discord.File(img, filename="image0.png")
|
||||||
|
title = "Added playlist to queue"
|
||||||
|
descrip = f"{playlist.title}"
|
||||||
|
|
||||||
embed = discord.Embed(
|
embed = discord.Embed(
|
||||||
title=title, description=descrip, colour=discord.Color.red()
|
title=title, description=descrip, colour=discord.Color.red()
|
||||||
@ -626,52 +614,13 @@ class Plex(commands.Cog):
|
|||||||
except VoiceChannelError:
|
except VoiceChannelError:
|
||||||
pass
|
pass
|
||||||
|
|
||||||
try:
|
bot_log.debug("Added to queue - %s", title)
|
||||||
embed, img = self._build_embed_playlist(self, playlist, "Added playlist to queue", playlist.title)
|
embed, img = self._build_embed_playlist(self, playlist)
|
||||||
await ctx.send(embed=embed, file=img)
|
await ctx.send(embed=embed, file=img)
|
||||||
|
|
||||||
for item in playlist.items():
|
for item in playlist.items():
|
||||||
if (item.TYPE == "track"):
|
if (item.TYPE == "track"):
|
||||||
await self.play_queue.put(item)
|
await self.play_queue.put(item)
|
||||||
bot_log.debug("Added to queue - %s", title)
|
|
||||||
except MediaNotFoundError:
|
|
||||||
await ctx.send(message="Playlist "+title+" seems to be empty!")
|
|
||||||
bot_log.debug("Playlist empty - %s", title)
|
|
||||||
@command()
|
|
||||||
async def show_playlists(self, ctx, *args):
|
|
||||||
"""
|
|
||||||
User command to show playlists
|
|
||||||
|
|
||||||
Searchs plex db and shows playlists matching.
|
|
||||||
|
|
||||||
Args:
|
|
||||||
ctx: discord.ext.commands.Context message context from command
|
|
||||||
*args: String filter for playlist names
|
|
||||||
|
|
||||||
Returns:
|
|
||||||
None
|
|
||||||
|
|
||||||
Raises:
|
|
||||||
None
|
|
||||||
"""
|
|
||||||
# Save the context to use with async callbacks
|
|
||||||
self.ctx = ctx
|
|
||||||
|
|
||||||
playlists = self._get_playlists()
|
|
||||||
|
|
||||||
try:
|
|
||||||
await self._validate(ctx)
|
|
||||||
except VoiceChannelError:
|
|
||||||
pass
|
|
||||||
|
|
||||||
for playlist in playlists:
|
|
||||||
if args and not any(arg in playlist.title for arg in args):
|
|
||||||
continue
|
|
||||||
from datetime import timedelta
|
|
||||||
if playlist.duration:
|
|
||||||
seconds = playlist.duration / 1000
|
|
||||||
embed, img = self._build_embed_playlist(self, playlist, playlist.title, "{:0>8}".format(str(timedelta(seconds=seconds))))
|
|
||||||
await ctx.send(embed=embed, file=img)
|
|
||||||
|
|
||||||
@command()
|
@command()
|
||||||
async def stop(self, ctx):
|
async def stop(self, ctx):
|
||||||
|
Loading…
Reference in New Issue
Block a user