Troplo/PlexKodiConnect
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Increase episode sync resiliance

Browse source
This commit is contained in:
croneter 2018-11-04 17:26:08 +01:00
parent 2917bc982f
commit 7f431f1923
1 changed files with 41 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

55
resources/lib/itemtypes/tvshows.py
View file

@ -5,7 +5,7 @@ from logging import getLogger
from .common import ItemBase, process_path from .common import ItemBase, process_path
from ..plex_api import API from ..plex_api import API
from .. import state, variables as v from .. import plex_functions as PF, state, variables as v
LOG = getLogger('PLEX.tvshows') LOG = getLogger('PLEX.tvshows')
@ -315,24 +315,23 @@ class Episode(ItemBase, TvShowMixin):
Process single episode Process single episode
""" """
api = API(xml) api = API(xml)
update_item = True
plex_id = api.plex_id() plex_id = api.plex_id()
LOG.debug('Adding episode with plex_id %s', plex_id) LOG.debug('Adding episode with plex_id %s', plex_id)
if not plex_id: if not plex_id:
LOG.error('Error getting plex_id for episode, skipping: %s', LOG.error('Error getting plex_id for episode, skipping: %s',
xml.attrib) xml.attrib)
return return
entry = self.plexdb.item_by_id(plex_id, v.PLEX_TYPE_EPISODE) episode = self.plexdb.episode(plex_id)
try: if not episode:
kodi_id = entry[0]
old_kodi_fileid = entry[1]
kodi_pathid = entry[2]
except TypeError:
update_item = False update_item = False
query = 'SELECT COALESCE(MAX(idEpisode), 0) FROM episode' query = 'SELECT COALESCE(MAX(idEpisode), 0) FROM episode'
self.kodicursor.execute(query) self.kodicursor.execute(query)
kodi_id = self.kodicursor.fetchone()[0] + 1 kodi_id = self.kodicursor.fetchone()[0] + 1
else: else:
update_item = True
kodi_id = episode['kodi_id']
old_kodi_fileid = episode['kodi_fileid']
kodi_pathid = episode['kodi_pathid']
# Verification the item is still in Kodi # Verification the item is still in Kodi
query = 'SELECT * FROM episode WHERE idEpisode = ? LIMIT 1' query = 'SELECT * FROM episode WHERE idEpisode = ? LIMIT 1'
self.kodicursor.execute(query, (kodi_id, )) self.kodicursor.execute(query, (kodi_id, ))
@ -357,13 +356,41 @@ class Episode(ItemBase, TvShowMixin):
airs_before_season = "-1" airs_before_season = "-1"
airs_before_episode = "-1" airs_before_episode = "-1"
# The grandparent TV show
show = self.plexdb.show(show_id) show = self.plexdb.show(show_id)
try: if not show:
grandparent_id = show[3] LOG.warn('Grandparent TV show %s not found in DB, adding it', show_id)
except TypeError: show_xml = PF.GetPlexMetadata(show_id)
LOG.error("Parent tvshow now found, skip item") try:
return False show_xml[0].attrib
parent_id = self.kodi_db.add_season(grandparent_id, season_no) except (TypeError, IndexError, AttributeError):
LOG.error("Grandparent tvshow %s xml download failed", show_id)
return False
Show(self.last_sync, plexdb=self.plexdb, kodi_db=self.kodi_db).add_update(
show_xml[0], section_name, section_id)
show = self.plexdb.show(show_id)
if not show:
LOG.error('Still could not find grandparent tv show %s', show_id)
return
grandparent_id = show['kodi_id']
# The parent Season
season = self.plexdb.season(season_id)
if not season:
LOG.warn('Parent season %s not found in DB, adding it', season_id)
season_xml = PF.GetPlexMetadata(season_id)
try:
season_xml[0].attrib
except (TypeError, IndexError, AttributeError):
LOG.error("Parent season %s xml download failed", season_id)
return False
Season(self.last_sync, plexdb=self.plexdb, kodi_db=self.kodi_db).add_update(
season_xml[0], section_name, section_id)
season = self.plexdb.season(season_id)
if not season:
LOG.error('Still could not find parent season %s', season_id)
return
parent_id = season['kodi_id']
# GET THE FILE AND PATH ##### # GET THE FILE AND PATH #####
do_indirect = not state.DIRECT_PATHS do_indirect = not state.DIRECT_PATHS