Supremicus
10 years ago
13 changed files with 888 additions and 8 deletions
|
After Width: | Height: | Size: 1.7 KiB |
@ -0,0 +1,376 @@ |
|||
# URL: http://code.google.com/p/sickbeard/ |
|||
# |
|||
# This file is part of SickGear. |
|||
# |
|||
# SickGear is free software: you can redistribute it and/or modify |
|||
# it under the terms of the GNU General Public License as published by |
|||
# the Free Software Foundation, either version 3 of the License, or |
|||
# (at your option) any later version. |
|||
# |
|||
# SickGear is distributed in the hope that it will be useful, |
|||
# but WITHOUT ANY WARRANTY; without even the implied warranty of |
|||
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|||
# GNU General Public License for more details. |
|||
# |
|||
# You should have received a copy of the GNU General Public License |
|||
# along with SickGear. If not, see <http://www.gnu.org/licenses/>. |
|||
|
|||
import generic |
|||
import datetime |
|||
|
|||
import sickbeard |
|||
|
|||
from sickbeard import logger, exceptions, helpers |
|||
from sickbeard.exceptions import ex |
|||
|
|||
import xml.etree.cElementTree as etree |
|||
|
|||
|
|||
class KODIMetadata(generic.GenericMetadata): |
|||
""" |
|||
Metadata generation class for Kodi. |
|||
|
|||
The following file structure is used: |
|||
|
|||
show_root/tvshow.nfo (show metadata) |
|||
show_root/fanart.jpg (fanart) |
|||
show_root/poster.jpg (poster) |
|||
show_root/banner.jpg (banner) |
|||
show_root/Season ##/filename.ext (*) |
|||
show_root/Season ##/filename.nfo (episode metadata) |
|||
show_root/Season ##/filename-thumb.jpg (episode thumb) |
|||
show_root/season##-poster.jpg (season posters) |
|||
show_root/season##-banner.jpg (season banners) |
|||
show_root/season-all-poster.jpg (season all poster) |
|||
show_root/season-all-banner.jpg (season all banner) |
|||
""" |
|||
|
|||
def __init__(self, |
|||
show_metadata=False, |
|||
episode_metadata=False, |
|||
fanart=False, |
|||
poster=False, |
|||
banner=False, |
|||
episode_thumbnails=False, |
|||
season_posters=False, |
|||
season_banners=False, |
|||
season_all_poster=False, |
|||
season_all_banner=False): |
|||
|
|||
generic.GenericMetadata.__init__(self, |
|||
show_metadata, |
|||
episode_metadata, |
|||
fanart, |
|||
poster, |
|||
banner, |
|||
episode_thumbnails, |
|||
season_posters, |
|||
season_banners, |
|||
season_all_poster, |
|||
season_all_banner) |
|||
|
|||
self.name = 'Kodi' |
|||
|
|||
self.poster_name = 'poster.jpg' |
|||
self.season_all_poster_name = 'season-all-poster.jpg' |
|||
|
|||
# web-ui metadata template |
|||
self.eg_show_metadata = 'tvshow.nfo' |
|||
self.eg_episode_metadata = 'Season##\\<i>filename</i>.nfo' |
|||
self.eg_fanart = 'fanart.jpg' |
|||
self.eg_poster = 'poster.jpg' |
|||
self.eg_banner = 'banner.jpg' |
|||
self.eg_episode_thumbnails = 'Season##\\<i>filename</i>-thumb.jpg' |
|||
self.eg_season_posters = 'season##-poster.jpg' |
|||
self.eg_season_banners = 'season##-banner.jpg' |
|||
self.eg_season_all_poster = 'season-all-poster.jpg' |
|||
self.eg_season_all_banner = 'season-all-banner.jpg' |
|||
|
|||
def _show_data(self, show_obj): |
|||
""" |
|||
Creates an elementTree XML structure for a Kodi-style tvshow.nfo and |
|||
returns the resulting data object. |
|||
|
|||
show_obj: a TVShow instance to create the NFO for |
|||
""" |
|||
|
|||
show_ID = show_obj.indexerid |
|||
|
|||
indexer_lang = show_obj.lang |
|||
lINDEXER_API_PARMS = sickbeard.indexerApi(show_obj.indexer).api_params.copy() |
|||
|
|||
lINDEXER_API_PARMS['actors'] = True |
|||
|
|||
if indexer_lang and not indexer_lang == 'en': |
|||
lINDEXER_API_PARMS['language'] = indexer_lang |
|||
|
|||
if show_obj.dvdorder != 0: |
|||
lINDEXER_API_PARMS['dvdorder'] = True |
|||
|
|||
t = sickbeard.indexerApi(show_obj.indexer).indexer(**lINDEXER_API_PARMS) |
|||
|
|||
tv_node = etree.Element('tvshow') |
|||
|
|||
try: |
|||
myShow = t[int(show_ID)] |
|||
except sickbeard.indexer_shownotfound: |
|||
logger.log(u'Unable to find show with id ' + str(show_ID) + ' on ' + sickbeard.indexerApi( |
|||
show_obj.indexer).name + ', skipping it', logger.ERROR) |
|||
raise |
|||
|
|||
except sickbeard.indexer_error: |
|||
logger.log( |
|||
u'' + sickbeard.indexerApi(show_obj.indexer).name + ' is down, can\'t use its data to add this show', |
|||
logger.ERROR) |
|||
raise |
|||
|
|||
# check for title and id |
|||
if getattr(myShow, 'seriesname', None) is None or getattr(myShow, 'id', None) is None: |
|||
logger.log(u'Incomplete info for show with id ' + str(show_ID) + ' on ' + sickbeard.indexerApi( |
|||
show_obj.indexer).name + ', skipping it', logger.ERROR) |
|||
return False |
|||
|
|||
title = etree.SubElement(tv_node, 'title') |
|||
if getattr(myShow, 'seriesname', None) is not None: |
|||
title.text = myShow['seriesname'] |
|||
|
|||
rating = etree.SubElement(tv_node, 'rating') |
|||
if getattr(myShow, 'rating', None) is not None: |
|||
rating.text = myShow['rating'] |
|||
|
|||
year = etree.SubElement(tv_node, 'year') |
|||
if getattr(myShow, 'firstaired', None) is not None: |
|||
try: |
|||
year_text = str(datetime.datetime.strptime(myShow['firstaired'], '%Y-%m-%d').year) |
|||
if year_text: |
|||
year.text = year_text |
|||
except: |
|||
pass |
|||
|
|||
plot = etree.SubElement(tv_node, 'plot') |
|||
if getattr(myShow, 'overview', None) is not None: |
|||
plot.text = myShow['overview'] |
|||
|
|||
episodeguide = etree.SubElement(tv_node, 'episodeguide') |
|||
episodeguideurl = etree.SubElement(episodeguide, 'url') |
|||
episodeguideurl2 = etree.SubElement(tv_node, 'episodeguideurl') |
|||
if getattr(myShow, 'id', None) is not None: |
|||
showurl = sickbeard.indexerApi(show_obj.indexer).config['base_url'] + str(myShow['id']) + '/all/en.zip' |
|||
episodeguideurl.text = showurl |
|||
episodeguideurl2.text = showurl |
|||
|
|||
mpaa = etree.SubElement(tv_node, 'mpaa') |
|||
if getattr(myShow, 'contentrating', None) is not None: |
|||
mpaa.text = myShow['contentrating'] |
|||
|
|||
indexerid = etree.SubElement(tv_node, 'id') |
|||
if getattr(myShow, 'id', None) is not None: |
|||
indexerid.text = str(myShow['id']) |
|||
|
|||
indexer = etree.SubElement(tv_node, 'indexer') |
|||
if show_obj.indexer is not None: |
|||
indexer.text = str(show_obj.indexer) |
|||
|
|||
genre = etree.SubElement(tv_node, 'genre') |
|||
if getattr(myShow, 'genre', None) is not None: |
|||
if isinstance(myShow['genre'], basestring): |
|||
genre.text = ' / '.join(x.strip() for x in myShow['genre'].split('|') if x.strip()) |
|||
|
|||
premiered = etree.SubElement(tv_node, 'premiered') |
|||
if getattr(myShow, 'firstaired', None) is not None: |
|||
premiered.text = myShow['firstaired'] |
|||
|
|||
studio = etree.SubElement(tv_node, 'studio') |
|||
if getattr(myShow, 'network', None) is not None: |
|||
studio.text = myShow['network'] |
|||
|
|||
if getattr(myShow, '_actors', None) is not None: |
|||
for actor in myShow['_actors']: |
|||
cur_actor = etree.SubElement(tv_node, 'actor') |
|||
|
|||
cur_actor_name = etree.SubElement(cur_actor, 'name') |
|||
cur_actor_name_text = actor['name'] |
|||
if isinstance(cur_actor_name_text, basestring): |
|||
cur_actor_name.text = cur_actor_name_text.strip() |
|||
|
|||
cur_actor_role = etree.SubElement(cur_actor, 'role') |
|||
cur_actor_role_text = actor['role'] |
|||
if cur_actor_role_text != None: |
|||
cur_actor_role.text = cur_actor_role_text |
|||
|
|||
cur_actor_thumb = etree.SubElement(cur_actor, 'thumb') |
|||
cur_actor_thumb_text = actor['image'] |
|||
if cur_actor_thumb_text != None: |
|||
cur_actor_thumb.text = cur_actor_thumb_text |
|||
|
|||
# Make it purdy |
|||
helpers.indentXML(tv_node) |
|||
|
|||
data = etree.ElementTree(tv_node) |
|||
|
|||
return data |
|||
|
|||
def _ep_data(self, ep_obj): |
|||
""" |
|||
Creates an elementTree XML structure for a Kodi-style episode.nfo and |
|||
returns the resulting data object. |
|||
show_obj: a TVEpisode instance to create the NFO for |
|||
""" |
|||
|
|||
eps_to_write = [ep_obj] + ep_obj.relatedEps |
|||
|
|||
indexer_lang = ep_obj.show.lang |
|||
|
|||
lINDEXER_API_PARMS = sickbeard.indexerApi(ep_obj.show.indexer).api_params.copy() |
|||
|
|||
lINDEXER_API_PARMS['actors'] = True |
|||
|
|||
if indexer_lang and not indexer_lang == 'en': |
|||
lINDEXER_API_PARMS['language'] = indexer_lang |
|||
|
|||
if ep_obj.show.dvdorder != 0: |
|||
lINDEXER_API_PARMS['dvdorder'] = True |
|||
|
|||
try: |
|||
t = sickbeard.indexerApi(ep_obj.show.indexer).indexer(**lINDEXER_API_PARMS) |
|||
myShow = t[ep_obj.show.indexerid] |
|||
except sickbeard.indexer_shownotfound, e: |
|||
raise exceptions.ShowNotFoundException(e.message) |
|||
except sickbeard.indexer_error, e: |
|||
logger.log(u'Unable to connect to ' + sickbeard.indexerApi( |
|||
ep_obj.show.indexer).name + ' while creating meta files - skipping - ' + ex(e), logger.ERROR) |
|||
return |
|||
|
|||
if len(eps_to_write) > 1: |
|||
rootNode = etree.Element('xbmcmultiepisode') |
|||
else: |
|||
rootNode = etree.Element('episodedetails') |
|||
|
|||
# write an NFO containing info for all matching episodes |
|||
for curEpToWrite in eps_to_write: |
|||
|
|||
try: |
|||
myEp = myShow[curEpToWrite.season][curEpToWrite.episode] |
|||
except (sickbeard.indexer_episodenotfound, sickbeard.indexer_seasonnotfound): |
|||
logger.log(u'Unable to find episode ' + str(curEpToWrite.season) + 'x' + str( |
|||
curEpToWrite.episode) + ' on ' + sickbeard.indexerApi( |
|||
ep_obj.show.indexer).name + '.. has it been removed? Should I delete from db?') |
|||
return None |
|||
|
|||
if getattr(myEp, 'firstaired', None) is None: |
|||
myEp['firstaired'] = str(datetime.date.fromordinal(1)) |
|||
|
|||
if getattr(myEp, 'episodename', None) is None: |
|||
logger.log(u'Not generating nfo because the ep has no title', logger.DEBUG) |
|||
return None |
|||
|
|||
logger.log(u'Creating metadata for episode ' + str(ep_obj.season) + 'x' + str(ep_obj.episode), logger.DEBUG) |
|||
|
|||
if len(eps_to_write) > 1: |
|||
episode = etree.SubElement(rootNode, 'episodedetails') |
|||
else: |
|||
episode = rootNode |
|||
|
|||
title = etree.SubElement(episode, 'title') |
|||
if curEpToWrite.name != None: |
|||
title.text = curEpToWrite.name |
|||
|
|||
showtitle = etree.SubElement(episode, 'showtitle') |
|||
if curEpToWrite.show.name != None: |
|||
showtitle.text = curEpToWrite.show.name |
|||
|
|||
season = etree.SubElement(episode, 'season') |
|||
season.text = str(curEpToWrite.season) |
|||
|
|||
episodenum = etree.SubElement(episode, 'episode') |
|||
episodenum.text = str(curEpToWrite.episode) |
|||
|
|||
uniqueid = etree.SubElement(episode, 'uniqueid') |
|||
uniqueid.text = str(curEpToWrite.indexerid) |
|||
|
|||
aired = etree.SubElement(episode, 'aired') |
|||
if curEpToWrite.airdate != datetime.date.fromordinal(1): |
|||
aired.text = str(curEpToWrite.airdate) |
|||
else: |
|||
aired.text = '' |
|||
|
|||
plot = etree.SubElement(episode, 'plot') |
|||
if curEpToWrite.description != None: |
|||
plot.text = curEpToWrite.description |
|||
|
|||
runtime = etree.SubElement(episode, 'runtime') |
|||
if curEpToWrite.season != 0: |
|||
if getattr(myShow, 'runtime', None) is not None: |
|||
runtime.text = myShow['runtime'] |
|||
|
|||
displayseason = etree.SubElement(episode, 'displayseason') |
|||
if getattr(myEp, 'airsbefore_season', None) is not None: |
|||
displayseason_text = myEp['airsbefore_season'] |
|||
if displayseason_text != None: |
|||
displayseason.text = displayseason_text |
|||
|
|||
displayepisode = etree.SubElement(episode, 'displayepisode') |
|||
if getattr(myEp, 'airsbefore_episode', None) is not None: |
|||
displayepisode_text = myEp['airsbefore_episode'] |
|||
if displayepisode_text != None: |
|||
displayepisode.text = displayepisode_text |
|||
|
|||
thumb = etree.SubElement(episode, 'thumb') |
|||
thumb_text = getattr(myEp, 'filename', None) |
|||
if thumb_text != None: |
|||
thumb.text = thumb_text |
|||
|
|||
watched = etree.SubElement(episode, 'watched') |
|||
watched.text = 'false' |
|||
|
|||
credits = etree.SubElement(episode, 'credits') |
|||
credits_text = getattr(myEp, 'writer', None) |
|||
if credits_text != None: |
|||
credits.text = credits_text |
|||
|
|||
director = etree.SubElement(episode, 'director') |
|||
director_text = getattr(myEp, 'director', None) |
|||
if director_text is not None: |
|||
director.text = director_text |
|||
|
|||
rating = etree.SubElement(episode, 'rating') |
|||
rating_text = getattr(myEp, 'rating', None) |
|||
if rating_text != None: |
|||
rating.text = rating_text |
|||
|
|||
gueststar_text = getattr(myEp, 'gueststars', None) |
|||
if isinstance(gueststar_text, basestring): |
|||
for actor in (x.strip() for x in gueststar_text.split('|') if x.strip()): |
|||
cur_actor = etree.SubElement(episode, 'actor') |
|||
cur_actor_name = etree.SubElement(cur_actor, 'name') |
|||
cur_actor_name.text = actor |
|||
|
|||
if getattr(myEp, '_actors', None) is not None: |
|||
for actor in myShow['_actors']: |
|||
cur_actor = etree.SubElement(episode, 'actor') |
|||
|
|||
cur_actor_name = etree.SubElement(cur_actor, 'name') |
|||
cur_actor_name_text = actor['name'] |
|||
if isinstance(cur_actor_name_text, basestring): |
|||
cur_actor_name.text = cur_actor_name_text.strip() |
|||
|
|||
cur_actor_role = etree.SubElement(cur_actor, 'role') |
|||
cur_actor_role_text = actor['role'] |
|||
if cur_actor_role_text != None: |
|||
cur_actor_role.text = cur_actor_role_text |
|||
|
|||
cur_actor_thumb = etree.SubElement(cur_actor, 'thumb') |
|||
cur_actor_thumb_text = actor['image'] |
|||
if cur_actor_thumb_text != None: |
|||
cur_actor_thumb.text = cur_actor_thumb_text |
|||
|
|||
# Make it purdy |
|||
helpers.indentXML(rootNode) |
|||
|
|||
data = etree.ElementTree(rootNode) |
|||
|
|||
return data |
|||
|
|||
|
|||
# present a standard "interface" from the module |
|||
metadata_class = KODIMetadata |
|||
@ -0,0 +1,241 @@ |
|||
# Author: Nic Wolfe <nic@wolfeden.ca> |
|||
# URL: http://code.google.com/p/sickbeard/ |
|||
# |
|||
# This file is part of SickGear. |
|||
# |
|||
# SickGear is free software: you can redistribute it and/or modify |
|||
# it under the terms of the GNU General Public License as published by |
|||
# the Free Software Foundation, either version 3 of the License, or |
|||
# (at your option) any later version. |
|||
# |
|||
# SickGear is distributed in the hope that it will be useful, |
|||
# but WITHOUT ANY WARRANTY; without even the implied warranty of |
|||
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|||
# GNU General Public License for more details. |
|||
# |
|||
# You should have received a copy of the GNU General Public License |
|||
# along with SickGear. If not, see <http://www.gnu.org/licenses/>. |
|||
|
|||
import urllib |
|||
import urllib2 |
|||
import socket |
|||
import base64 |
|||
import time |
|||
|
|||
import sickbeard |
|||
|
|||
from sickbeard import logger |
|||
from sickbeard import common |
|||
from sickbeard.exceptions import ex |
|||
from sickbeard.encodingKludge import fixStupidEncodings |
|||
|
|||
try: |
|||
import xml.etree.cElementTree as etree |
|||
except ImportError: |
|||
import xml.etree.ElementTree as etree |
|||
|
|||
try: |
|||
import json |
|||
except ImportError: |
|||
from lib import simplejson as json |
|||
|
|||
|
|||
class KODINotifier: |
|||
sg_logo_url = 'https://raw.githubusercontent.com/SickGear/SickGear/master/gui/slick/images/ico/apple-touch-icon-precomposed.png' |
|||
|
|||
def _notify_kodi(self, message, title='SickGear', host=None, username=None, password=None, force=False): |
|||
|
|||
# fill in omitted parameters |
|||
if not host: |
|||
host = sickbeard.KODI_HOST |
|||
if not username: |
|||
username = sickbeard.KODI_USERNAME |
|||
if not password: |
|||
password = sickbeard.KODI_PASSWORD |
|||
|
|||
# suppress notifications if the notifier is disabled but the notify options are checked |
|||
if not sickbeard.USE_KODI and not force: |
|||
logger.log(u'KODI: Notifications are not enabled, skipping this notification', logger.DEBUG) |
|||
return False |
|||
|
|||
result = '' |
|||
for curHost in [x.strip() for x in host.split(',')]: |
|||
logger.log(u'KODI: Sending Kodi notification to \'%s\' - %s' % (curHost, message), logger.MESSAGE) |
|||
|
|||
command = '{"jsonrpc":"2.0","method":"GUI.ShowNotification","params":{"title":"%s","message":"%s", "image": "%s"},"id":1}' % (title.encode('utf-8'), message.encode('utf-8'), self.sg_logo_url) |
|||
notifyResult = self._send_to_kodi(command, curHost, username, password) |
|||
if notifyResult: |
|||
result += curHost + ':' + notifyResult['result'].decode(sickbeard.SYS_ENCODING) |
|||
else: |
|||
if sickbeard.KODI_ALWAYS_ON or force: |
|||
result += curHost + ':False' |
|||
|
|||
return result |
|||
|
|||
def _send_to_kodi(self, command, host=None, username=None, password=None): |
|||
|
|||
# fill in omitted parameters |
|||
if not username: |
|||
username = sickbeard.KODI_USERNAME |
|||
if not password: |
|||
password = sickbeard.KODI_PASSWORD |
|||
|
|||
if not host: |
|||
logger.log(u'KODI: No host specified, check your settings', logger.ERROR) |
|||
return False |
|||
|
|||
command = command.encode('utf-8') |
|||
logger.log(u'KODI: JSON command: ' + command, logger.DEBUG) |
|||
|
|||
url = 'http://%s/jsonrpc' % (host) |
|||
try: |
|||
req = urllib2.Request(url, command) |
|||
req.add_header('Content-type', 'application/json') |
|||
# if we have a password, use authentication |
|||
if password: |
|||
base64string = base64.encodestring('%s:%s' % (username, password))[:-1] |
|||
authheader = 'Basic %s' % base64string |
|||
req.add_header('Authorization', authheader) |
|||
logger.log(u'KODI: Contacting (with auth header) via url: ' + fixStupidEncodings(url), logger.DEBUG) |
|||
else: |
|||
logger.log(u'KODI: Contacting via url: ' + fixStupidEncodings(url), logger.DEBUG) |
|||
|
|||
try: |
|||
response = urllib2.urlopen(req) |
|||
except urllib2.URLError, e: |
|||
logger.log(u'KODI: Warning: Couldn\'t contact Kodi at ' + host + '- ' + ex(e), logger.WARNING) |
|||
return False |
|||
|
|||
# parse the json result |
|||
try: |
|||
result = json.load(response) |
|||
response.close() |
|||
logger.log(u'KODI: JSON response: ' + str(result), logger.DEBUG) |
|||
return result # need to return response for parsing |
|||
except ValueError, e: |
|||
logger.log(u'KODI: Unable to decode JSON response: ' + response, logger.WARNING) |
|||
return False |
|||
|
|||
except IOError, e: |
|||
logger.log(u'KODI: Warning: Couldn\'t contact Kodi at ' + host + ' - ' + ex(e), logger.WARNING) |
|||
return False |
|||
|
|||
def _update_library(self, host=None, showName=None): |
|||
|
|||
if not host: |
|||
logger.log(u'KODI: No host specified, check your settings', logger.DEBUG) |
|||
return False |
|||
|
|||
logger.log(u'KODI: Updating library on host: ' + host, logger.MESSAGE) |
|||
|
|||
# if we're doing per-show |
|||
if showName: |
|||
tvshowid = -1 |
|||
logger.log(u'KODI: Updating library for show ' + showName, logger.DEBUG) |
|||
|
|||
# get tvshowid by showName |
|||
showsCommand = '{"jsonrpc":"2.0","method":"VideoLibrary.GetTVShows","id":1}' |
|||
showsResponse = self._send_to_kodi(showsCommand, host) |
|||
|
|||
if showsResponse and 'result' in showsResponse and 'tvshows' in showsResponse['result']: |
|||
shows = showsResponse['result']['tvshows'] |
|||
else: |
|||
logger.log(u'KODI: No TV shows in Kodi TV show list', logger.DEBUG) |
|||
return False |
|||
|
|||
for show in shows: |
|||
if (show['label'] == showName): |
|||
tvshowid = show['tvshowid'] |
|||
break # exit out of loop otherwise the label and showname will not match up |
|||
|
|||
# this can be big, so free some memory |
|||
del shows |
|||
|
|||
# we didn't find the show (exact match), thus revert to just doing a full update if enabled |
|||
if (tvshowid == -1): |
|||
logger.log(u'KODI: Exact show name not matched in KODI TV show list', logger.DEBUG) |
|||
return False |
|||
|
|||
# lookup tv-show path |
|||
pathCommand = '{"jsonrpc":"2.0","method":"VideoLibrary.GetTVShowDetails","params":{"tvshowid":%d, "properties": ["file"]},"id":1}' % (tvshowid) |
|||
pathResponse = self._send_to_kodi(pathCommand, host) |
|||
|
|||
path = pathResponse['result']['tvshowdetails']['file'] |
|||
logger.log(u'KODI: Received Show: ' + showName + ' with ID: ' + str(tvshowid) + ' Path: ' + path, logger.DEBUG) |
|||
|
|||
if (len(path) < 1): |
|||
logger.log(u'KODI: No valid path found for ' + showName + ' with ID: ' + str(tvshowid) + ' on ' + host, logger.WARNING) |
|||
return False |
|||
|
|||
logger.log(u'KODI: Updating ' + showName + ' on ' + host + ' at ' + path, logger.DEBUG) |
|||
updateCommand = '{"jsonrpc":"2.0","method":"VideoLibrary.Scan","params":{"directory":%s},"id":1}' % (json.dumps(path)) |
|||
request = self._send_to_kodi(updateCommand, host) |
|||
if not request: |
|||
logger.log(u'KODI: Update of show directory failed on ' + showName + ' on ' + host + ' at ' + path, logger.ERROR) |
|||
return False |
|||
|
|||
# catch if there was an error in the returned request |
|||
for r in request: |
|||
if 'error' in r: |
|||
logger.log(u'KODI: Error while attempting to update show directory for ' + showName + ' on ' + host + ' at ' + path, logger.ERROR) |
|||
return False |
|||
|
|||
# do a full update if requested |
|||
else: |
|||
logger.log(u'KODI: Performing full library update on host: ' + host, logger.DEBUG) |
|||
updateCommand = '{"jsonrpc":"2.0","method":"VideoLibrary.Scan","id":1}' |
|||
request = self._send_to_kodi(updateCommand, host, sickbeard.KODI_USERNAME, sickbeard.KODI_PASSWORD) |
|||
|
|||
if not request: |
|||
logger.log(u'KODI: Full library update failed on host: ' + host, logger.ERROR) |
|||
return False |
|||
|
|||
return True |
|||
|
|||
def notify_snatch(self, ep_name): |
|||
if sickbeard.KODI_NOTIFY_ONSNATCH: |
|||
self._notify_kodi(ep_name, common.notifyStrings[common.NOTIFY_SNATCH]) |
|||
|
|||
def notify_download(self, ep_name): |
|||
if sickbeard.KODI_NOTIFY_ONDOWNLOAD: |
|||
self._notify_kodi(ep_name, common.notifyStrings[common.NOTIFY_DOWNLOAD]) |
|||
|
|||
def notify_subtitle_download(self, ep_name, lang): |
|||
if sickbeard.KODI_NOTIFY_ONSUBTITLEDOWNLOAD: |
|||
self._notify_kodi(ep_name + ': ' + lang, common.notifyStrings[common.NOTIFY_SUBTITLE_DOWNLOAD]) |
|||
|
|||
def notify_git_update(self, new_version = '??'): |
|||
if sickbeard.USE_KODI: |
|||
update_text=common.notifyStrings[common.NOTIFY_GIT_UPDATE_TEXT] |
|||
title=common.notifyStrings[common.NOTIFY_GIT_UPDATE] |
|||
self._notify_kodi(update_text + new_version, title) |
|||
|
|||
def test_notify(self, host, username, password): |
|||
return self._notify_kodi('Testing Kodi notifications from SickGear', 'Test', host, username, password, force=True) |
|||
|
|||
def update_library(self, showName=None): |
|||
|
|||
if sickbeard.USE_KODI and sickbeard.KODI_UPDATE_LIBRARY: |
|||
if not sickbeard.KODI_HOST: |
|||
logger.log(u'KODI: No host specified, check your settings', logger.DEBUG) |
|||
return False |
|||
|
|||
# either update each host, or only attempt to update first only |
|||
result = 0 |
|||
for host in [x.strip() for x in sickbeard.KODI_HOST.split(',')]: |
|||
if self._update_library(host, showName): |
|||
if sickbeard.KODI_UPDATE_ONLYFIRST: |
|||
logger.log(u'KODI: Update first host successful on host ' + host + ', stopped sending library update commands', logger.DEBUG) |
|||
return True |
|||
else: |
|||
if sickbeard.KODI_ALWAYS_ON: |
|||
result = result + 1 |
|||
|
|||
# needed for the 'update kodi' submenu command |
|||
# as it only cares of the final result vs the individual ones |
|||
if result == 0: |
|||
return True |
|||
else: |
|||
return False |
|||
|
|||
notifier = KODINotifier |
|||
Loading…
Reference in new issue