mirror of
https://github.com/FakeTV/pseudo-channel.git
synced 2025-12-19 09:43:31 +00:00
Cleanup / added cli flags for info gathering / debugging.
This commit is contained in:
Justin Emter
@@ -1,3 +1,5 @@
|
||||
#!/usr/bin/env python
|
||||
|
||||
from plexapi.server import PlexServer
|
||||
from datetime import datetime
|
||||
import sqlite3
|
||||
@@ -10,328 +12,328 @@ import logging.handlers
|
||||
|
||||
class PseudoDailyScheduleController():
|
||||
|
||||
def __init__(self, server, token, clients):
|
||||
def __init__(self, server, token, clients):
|
||||
|
||||
self.PLEX = PlexServer(server, token)
|
||||
self.PLEX = PlexServer(server, token)
|
||||
|
||||
self.BASE_URL = server
|
||||
self.BASE_URL = server
|
||||
|
||||
self.TOKEN = token
|
||||
self.TOKEN = token
|
||||
|
||||
self.PLEX_CLIENTS = clients
|
||||
self.PLEX_CLIENTS = clients
|
||||
|
||||
self.my_logger = logging.getLogger('MyLogger')
|
||||
self.my_logger.setLevel(logging.DEBUG)
|
||||
self.my_logger = logging.getLogger('MyLogger')
|
||||
self.my_logger.setLevel(logging.DEBUG)
|
||||
|
||||
self.handler = logging.handlers.SysLogHandler(address = '/dev/log')
|
||||
self.handler = logging.handlers.SysLogHandler(address = '/dev/log')
|
||||
|
||||
self.my_logger.addHandler(self.handler)
|
||||
self.my_logger.addHandler(self.handler)
|
||||
|
||||
'''
|
||||
*
|
||||
* Get the full image url (including plex token) from the local db.
|
||||
* @param seriesTitle: case-unsensitive string of the series title
|
||||
* @return string: full path of to the show image
|
||||
*
|
||||
'''
|
||||
def get_show_photo(self, section, title):
|
||||
'''
|
||||
*
|
||||
* Get the full image url (including plex token) from the local db.
|
||||
* @param seriesTitle: case-unsensitive string of the series title
|
||||
* @return string: full path of to the show image
|
||||
*
|
||||
'''
|
||||
def get_show_photo(self, section, title):
|
||||
|
||||
backgroundImagePath = None
|
||||
backgroundImagePath = None
|
||||
|
||||
backgroundImgURL = ''
|
||||
backgroundImgURL = ''
|
||||
|
||||
try:
|
||||
try:
|
||||
|
||||
backgroundImagePath = self.PLEX.library.section(section).get(title)
|
||||
backgroundImagePath = self.PLEX.library.section(section).get(title)
|
||||
|
||||
except:
|
||||
except:
|
||||
|
||||
return backgroundImgURL
|
||||
return backgroundImgURL
|
||||
|
||||
if backgroundImagePath != None and isinstance(backgroundImagePath.art, str):
|
||||
if backgroundImagePath != None and isinstance(backgroundImagePath.art, str):
|
||||
|
||||
backgroundImgURL = self.BASE_URL+backgroundImagePath.art+"?X-Plex-Token="+self.TOKEN
|
||||
backgroundImgURL = self.BASE_URL+backgroundImagePath.art+"?X-Plex-Token="+self.TOKEN
|
||||
|
||||
return backgroundImgURL
|
||||
return backgroundImgURL
|
||||
|
||||
'''
|
||||
*
|
||||
* Get the generated html for the .html file that is the schedule.
|
||||
* ...This is used whenever a show starts or stops in order to add and remove various styles.
|
||||
* @param currentTime: datetime object
|
||||
* @param bgImageURL: str of the image used for the background
|
||||
* @return string: the generated html content
|
||||
*
|
||||
'''
|
||||
def get_html_from_daily_schedule(self, currentTime, bgImageURL, datalist):
|
||||
'''
|
||||
*
|
||||
* Get the generated html for the .html file that is the schedule.
|
||||
* ...This is used whenever a show starts or stops in order to add and remove various styles.
|
||||
* @param currentTime: datetime object
|
||||
* @param bgImageURL: str of the image used for the background
|
||||
* @return string: the generated html content
|
||||
*
|
||||
'''
|
||||
def get_html_from_daily_schedule(self, currentTime, bgImageURL, datalist):
|
||||
|
||||
now = datetime.now()
|
||||
now = datetime.now()
|
||||
|
||||
time = now.strftime("%B %d, %Y")
|
||||
time = now.strftime("%B %d, %Y")
|
||||
|
||||
doc, tag, text, line = Doc(
|
||||
doc, tag, text, line = Doc(
|
||||
|
||||
).ttl()
|
||||
).ttl()
|
||||
|
||||
doc.asis('<!DOCTYPE html>')
|
||||
doc.asis('<!DOCTYPE html>')
|
||||
|
||||
with tag('html'):
|
||||
with tag('html'):
|
||||
|
||||
with tag('head'):
|
||||
with tag('head'):
|
||||
|
||||
with tag('title'):
|
||||
with tag('title'):
|
||||
|
||||
text(time + " - Daily Pseudo Schedule")
|
||||
text(time + " - Daily Pseudo Schedule")
|
||||
|
||||
doc.asis('<link href="https://maxcdn.bootstrapcdn.com/bootstrap/4.0.0-alpha.6/css/bootstrap.min.css" rel="stylesheet">')
|
||||
doc.asis('<script>setTimeout(function() {location.reload();}, 30000);</script>')
|
||||
doc.asis('<link href="https://maxcdn.bootstrapcdn.com/bootstrap/4.0.0-alpha.6/css/bootstrap.min.css" rel="stylesheet">')
|
||||
doc.asis('<script>setTimeout(function() {location.reload();}, 30000);</script>')
|
||||
|
||||
if bgImageURL != None:
|
||||
doc.asis('<style>body{ background:transparent!important; } html { background: url('+bgImageURL+') no-repeat center center fixed; -webkit-background-size: cover;-moz-background-size: cover;-o-background-size: cover;background-size: cover;}.make-white { padding: 24px; background:rgba(255,255,255, 0.9); }</style>')
|
||||
if bgImageURL != None:
|
||||
doc.asis('<style>body{ background:transparent!important; } html { background: url('+bgImageURL+') no-repeat center center fixed; -webkit-background-size: cover;-moz-background-size: cover;-o-background-size: cover;background-size: cover;}.make-white { padding: 24px; background:rgba(255,255,255, 0.9); }</style>')
|
||||
|
||||
with tag('body'):
|
||||
with tag('body'):
|
||||
|
||||
with tag('div', klass='container mt-3'):
|
||||
with tag('div', klass='container mt-3'):
|
||||
|
||||
with tag('div', klass='row make-white'):
|
||||
with tag('div', klass='row make-white'):
|
||||
|
||||
with tag('div'):
|
||||
with tag('div'):
|
||||
|
||||
with tag('div'):
|
||||
with tag('div'):
|
||||
|
||||
line('h1', "Daily Pseudo Schedule", klass='col-12 pl-0')
|
||||
line('h1', "Daily Pseudo Schedule", klass='col-12 pl-0')
|
||||
|
||||
with tag('div'):
|
||||
with tag('div'):
|
||||
|
||||
line('h3', time, klass='col-12 pl-1')
|
||||
line('h3', time, klass='col-12 pl-1')
|
||||
|
||||
with tag('table', klass='col-12 table table-bordered table-hover'):
|
||||
with tag('table', klass='col-12 table table-bordered table-hover'):
|
||||
|
||||
with tag('thead', klass='table-info'):
|
||||
with tag('tr'):
|
||||
with tag('th'):
|
||||
text('#')
|
||||
with tag('th'):
|
||||
text('Type')
|
||||
with tag('th'):
|
||||
text('Series')
|
||||
with tag('th'):
|
||||
text('Title')
|
||||
with tag('th'):
|
||||
text('Start Time')
|
||||
with tag('thead', klass='table-info'):
|
||||
with tag('tr'):
|
||||
with tag('th'):
|
||||
text('#')
|
||||
with tag('th'):
|
||||
text('Type')
|
||||
with tag('th'):
|
||||
text('Series')
|
||||
with tag('th'):
|
||||
text('Title')
|
||||
with tag('th'):
|
||||
text('Start Time')
|
||||
|
||||
numberIncrease = 0
|
||||
numberIncrease = 0
|
||||
|
||||
for row in datalist:
|
||||
for row in datalist:
|
||||
|
||||
numberIncrease += 1
|
||||
numberIncrease += 1
|
||||
|
||||
with tag('tbody'):
|
||||
with tag('tbody'):
|
||||
|
||||
timeB = datetime.strptime(row[8], '%I:%M %p')
|
||||
timeB = datetime.strptime(row[8], '%I:%M %p')
|
||||
|
||||
if currentTime == None:
|
||||
if currentTime == None:
|
||||
|
||||
with tag('tr'):
|
||||
with tag('th', scope='row'):
|
||||
text(numberIncrease)
|
||||
with tag('td'):
|
||||
text(row[11])
|
||||
with tag('td'):
|
||||
text(row[6])
|
||||
with tag('td'):
|
||||
text(row[3])
|
||||
with tag('td'):
|
||||
text(row[8])
|
||||
with tag('tr'):
|
||||
with tag('th', scope='row'):
|
||||
text(numberIncrease)
|
||||
with tag('td'):
|
||||
text(row[11])
|
||||
with tag('td'):
|
||||
text(row[6])
|
||||
with tag('td'):
|
||||
text(row[3])
|
||||
with tag('td'):
|
||||
text(row[8])
|
||||
|
||||
elif currentTime.hour == timeB.hour and currentTime.minute == timeB.minute:
|
||||
elif currentTime.hour == timeB.hour and currentTime.minute == timeB.minute:
|
||||
|
||||
with tag('tr', klass='bg-info'):
|
||||
with tag('tr', klass='bg-info'):
|
||||
|
||||
with tag('th', scope='row'):
|
||||
text(numberIncrease)
|
||||
with tag('td'):
|
||||
text(row[11])
|
||||
with tag('td'):
|
||||
text(row[6])
|
||||
with tag('td'):
|
||||
text(row[3])
|
||||
with tag('td'):
|
||||
text(row[8])
|
||||
with tag('th', scope='row'):
|
||||
text(numberIncrease)
|
||||
with tag('td'):
|
||||
text(row[11])
|
||||
with tag('td'):
|
||||
text(row[6])
|
||||
with tag('td'):
|
||||
text(row[3])
|
||||
with tag('td'):
|
||||
text(row[8])
|
||||
|
||||
else:
|
||||
else:
|
||||
|
||||
with tag('tr'):
|
||||
with tag('th', scope='row'):
|
||||
text(numberIncrease)
|
||||
with tag('td'):
|
||||
text(row[11])
|
||||
with tag('td'):
|
||||
text(row[6])
|
||||
with tag('td'):
|
||||
text(row[3])
|
||||
with tag('td'):
|
||||
text(row[8])
|
||||
with tag('tr'):
|
||||
with tag('th', scope='row'):
|
||||
text(numberIncrease)
|
||||
with tag('td'):
|
||||
text(row[11])
|
||||
with tag('td'):
|
||||
text(row[6])
|
||||
with tag('td'):
|
||||
text(row[3])
|
||||
with tag('td'):
|
||||
text(row[8])
|
||||
|
||||
|
||||
return doc.getvalue()
|
||||
return doc.getvalue()
|
||||
|
||||
'''
|
||||
*
|
||||
* Create 'schedules' dir & write the generated html to .html file.
|
||||
* @param data: html string
|
||||
* @return null
|
||||
*
|
||||
'''
|
||||
def write_schedule_to_file(self, data):
|
||||
'''
|
||||
*
|
||||
* Create 'schedules' dir & write the generated html to .html file.
|
||||
* @param data: html string
|
||||
* @return null
|
||||
*
|
||||
'''
|
||||
def write_schedule_to_file(self, data):
|
||||
|
||||
now = datetime.now()
|
||||
now = datetime.now()
|
||||
|
||||
fileName = "index.html"
|
||||
fileName = "index.html"
|
||||
|
||||
writepath = './schedules/'
|
||||
writepath = './schedules/'
|
||||
|
||||
if not os.path.exists(writepath):
|
||||
if not os.path.exists(writepath):
|
||||
|
||||
os.makedirs(writepath)
|
||||
os.makedirs(writepath)
|
||||
|
||||
if os.path.exists(writepath+fileName):
|
||||
|
||||
os.remove(writepath+fileName)
|
||||
if os.path.exists(writepath+fileName):
|
||||
|
||||
os.remove(writepath+fileName)
|
||||
|
||||
mode = 'a' if os.path.exists(writepath) else 'w'
|
||||
mode = 'a' if os.path.exists(writepath) else 'w'
|
||||
|
||||
with open(writepath+fileName, mode) as f:
|
||||
with open(writepath+fileName, mode) as f:
|
||||
|
||||
f.write(data)
|
||||
f.write(data)
|
||||
|
||||
'''
|
||||
*
|
||||
* Trigger "playMedia()" on the Python Plex API for specified media.
|
||||
* @param mediaType: str: "TV Shows"
|
||||
* @param mediaParentTitle: str: "Seinfeld"
|
||||
* @param mediaTitle: str: "The Soup Nazi"
|
||||
* @return null
|
||||
*
|
||||
'''
|
||||
def play_media(self, mediaType, mediaParentTitle, mediaTitle):
|
||||
'''
|
||||
*
|
||||
* Trigger "playMedia()" on the Python Plex API for specified media.
|
||||
* @param mediaType: str: "TV Shows"
|
||||
* @param mediaParentTitle: str: "Seinfeld"
|
||||
* @param mediaTitle: str: "The Soup Nazi"
|
||||
* @return null
|
||||
*
|
||||
'''
|
||||
def play_media(self, mediaType, mediaParentTitle, mediaTitle):
|
||||
|
||||
if mediaType == "TV Shows":
|
||||
if mediaType == "TV Shows":
|
||||
|
||||
mediaItems = self.PLEX.library.section(mediaType).get(mediaParentTitle).episodes()
|
||||
mediaItems = self.PLEX.library.section(mediaType).get(mediaParentTitle).episodes()
|
||||
|
||||
for item in mediaItems:
|
||||
for item in mediaItems:
|
||||
|
||||
# print(part.title)
|
||||
# print(part.title)
|
||||
|
||||
if item.title == mediaTitle:
|
||||
if item.title == mediaTitle:
|
||||
|
||||
for client in self.PLEX_CLIENTS:
|
||||
for client in self.PLEX_CLIENTS:
|
||||
|
||||
clientItem = self.PLEX.client(client)
|
||||
clientItem = self.PLEX.client(client)
|
||||
|
||||
clientItem.playMedia(item)
|
||||
|
||||
break
|
||||
clientItem.playMedia(item)
|
||||
|
||||
break
|
||||
|
||||
elif mediaType == "Movies":
|
||||
elif mediaType == "Movies":
|
||||
|
||||
movie = self.PLEX.library.section(mediaType).get(mediaTitle)
|
||||
movie = self.PLEX.library.section(mediaType).get(mediaTitle)
|
||||
|
||||
for client in self.PLEX_CLIENTS:
|
||||
for client in self.PLEX_CLIENTS:
|
||||
|
||||
clientItem = self.PLEX.client(client)
|
||||
clientItem = self.PLEX.client(client)
|
||||
|
||||
clientItem.playMedia(movie)
|
||||
clientItem.playMedia(movie)
|
||||
|
||||
else:
|
||||
else:
|
||||
|
||||
print("Not sure how to play {}".format(mediaType))
|
||||
|
||||
'''
|
||||
*
|
||||
* If tv_controller() does not find a "startTime" for scheduled media, search for an "endTime" match for now time.
|
||||
* ...This is useful for clearing the generated html schedule when media ends and there is a gap before the next media.
|
||||
* @param null
|
||||
* @return null
|
||||
*
|
||||
'''
|
||||
def check_for_end_time(self, datalist):
|
||||
print("Not sure how to play {}".format(mediaType))
|
||||
|
||||
'''
|
||||
*
|
||||
* If tv_controller() does not find a "startTime" for scheduled media, search for an "endTime" match for now time.
|
||||
* ...This is useful for clearing the generated html schedule when media ends and there is a gap before the next media.
|
||||
* @param null
|
||||
* @return null
|
||||
*
|
||||
'''
|
||||
def check_for_end_time(self, datalist):
|
||||
|
||||
currentTime = datetime.now()
|
||||
currentTime = datetime.now()
|
||||
|
||||
"""c.execute("SELECT * FROM daily_schedule")
|
||||
"""c.execute("SELECT * FROM daily_schedule")
|
||||
|
||||
datalist = list(c.fetchall())
|
||||
"""
|
||||
for row in datalist:
|
||||
datalist = list(c.fetchall())
|
||||
"""
|
||||
for row in datalist:
|
||||
|
||||
try:
|
||||
|
||||
endTime = datetime.strptime(row[9], '%Y-%m-%d %H:%M:%S.%f')
|
||||
try:
|
||||
|
||||
endTime = datetime.strptime(row[9], '%Y-%m-%d %H:%M:%S.%f')
|
||||
|
||||
except ValueError:
|
||||
except ValueError:
|
||||
|
||||
endTime = datetime.strptime(row[9], '%Y-%m-%d %H:%M:%S')
|
||||
endTime = datetime.strptime(row[9], '%Y-%m-%d %H:%M:%S')
|
||||
|
||||
if currentTime.hour == endTime.hour:
|
||||
if currentTime.hour == endTime.hour:
|
||||
|
||||
if currentTime.minute == endTime.minute:
|
||||
if currentTime.minute == endTime.minute:
|
||||
|
||||
print("Ok end time found")
|
||||
print("Ok end time found")
|
||||
|
||||
self.write_schedule_to_file(self.get_html_from_daily_schedule(None, None, datalist))
|
||||
self.write_schedule_to_file(self.get_html_from_daily_schedule(None, None, datalist))
|
||||
|
||||
break
|
||||
'''
|
||||
*
|
||||
* Check DB / current time. If that matches a scheduled shows startTime then trigger play via Plex API
|
||||
* @param null
|
||||
* @return null
|
||||
*
|
||||
'''
|
||||
def tv_controller(self, datalist):
|
||||
break
|
||||
'''
|
||||
*
|
||||
* Check DB / current time. If that matches a scheduled shows startTime then trigger play via Plex API
|
||||
* @param null
|
||||
* @return null
|
||||
*
|
||||
'''
|
||||
def tv_controller(self, datalist):
|
||||
|
||||
datalistLengthMonitor = 0;
|
||||
datalistLengthMonitor = 0;
|
||||
|
||||
currentTime = datetime.now()
|
||||
currentTime = datetime.now()
|
||||
|
||||
"""c.execute("SELECT * FROM daily_schedule ORDER BY datetime(startTimeUnix) ASC")
|
||||
"""c.execute("SELECT * FROM daily_schedule ORDER BY datetime(startTimeUnix) ASC")
|
||||
|
||||
datalist = list(c.fetchall())"""
|
||||
datalist = list(c.fetchall())"""
|
||||
|
||||
self.my_logger.debug('TV Controller')
|
||||
self.my_logger.debug('TV Controller')
|
||||
|
||||
for row in datalist:
|
||||
for row in datalist:
|
||||
|
||||
timeB = datetime.strptime(row[8], '%I:%M %p')
|
||||
timeB = datetime.strptime(row[8], '%I:%M %p')
|
||||
|
||||
if currentTime.hour == timeB.hour:
|
||||
if currentTime.hour == timeB.hour:
|
||||
|
||||
if currentTime.minute == timeB.minute:
|
||||
if currentTime.minute == timeB.minute:
|
||||
|
||||
print("Starting Epsisode: " + row[3])
|
||||
print(row)
|
||||
print("Starting Epsisode: " + row[3])
|
||||
print(row)
|
||||
|
||||
self.play_media(row[11], row[6], row[3])
|
||||
self.play_media(row[11], row[6], row[3])
|
||||
|
||||
self.write_schedule_to_file(
|
||||
self.get_html_from_daily_schedule(
|
||||
timeB,
|
||||
self.get_show_photo(
|
||||
row[11],
|
||||
row[6] if row[11] == "TV Shows" else row[3]
|
||||
),
|
||||
datalist
|
||||
)
|
||||
)
|
||||
self.write_schedule_to_file(
|
||||
self.get_html_from_daily_schedule(
|
||||
timeB,
|
||||
self.get_show_photo(
|
||||
row[11],
|
||||
row[6] if row[11] == "TV Shows" else row[3]
|
||||
),
|
||||
datalist
|
||||
)
|
||||
)
|
||||
|
||||
self.my_logger.debug('Trying to play: ' + row[3])
|
||||
self.my_logger.debug('Trying to play: ' + row[3])
|
||||
|
||||
break
|
||||
break
|
||||
|
||||
datalistLengthMonitor += 1
|
||||
datalistLengthMonitor += 1
|
||||
|
||||
if datalistLengthMonitor >= len(datalist):
|
||||
if datalistLengthMonitor >= len(datalist):
|
||||
|
||||
self.check_for_end_time(datalist)
|
||||
self.check_for_end_time(datalist)
|
||||
Reference in New Issue
Block a user