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

Sped up sync

Browse source
This commit is contained in:
tomkat83 2015-12-31 11:42:10 +01:00
parent 9ad059e31f
commit 927c8bf36f
1 changed files with 8 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
resources/lib/librarysync.py
View file

@ -468,7 +468,6 @@ class LibrarySync(threading.Thread):
def PlexMovies(self, embycursor, kodicursor, pdialog, compare=False): def PlexMovies(self, embycursor, kodicursor, pdialog, compare=False):
plx = PlexAPI.PlexAPI() plx = PlexAPI.PlexAPI()
# Get movies from Plex server # Get movies from Plex server
emby = self.emby
emby_db = embydb.Embydb_Functions(embycursor) emby_db = embydb.Embydb_Functions(embycursor)
movies = itemtypes.Movies(embycursor, kodicursor) movies = itemtypes.Movies(embycursor, kodicursor)
@ -483,11 +482,10 @@ class LibrarySync(threading.Thread):
all_kodimoviesId = {} all_kodimoviesId = {}
self.logMsg("all_kodimoviesId: %s " % (all_kodimoviesId), 1) self.logMsg("all_kodimoviesId: %s " % (all_kodimoviesId), 1)
all_plexmoviesIds = [] all_plexmoviesIds = []
updatelist = []
plexmovies = []
##### PROCESS MOVIES ##### ##### PROCESS MOVIES #####
for view in views: for view in views:
updatelist = []
if self.shouldStop(): if self.shouldStop():
return False return False
# Get items per view # Get items per view
@ -507,7 +505,7 @@ class LibrarySync(threading.Thread):
heading=self.addonName, heading=self.addonName,
message="Comparing movies from view: %s..." % viewName message="Comparing movies from view: %s..." % viewName
) )
for plexmovie in all_plexmovies[0:10]: for plexmovie in all_plexmovies:
if self.shouldStop(): if self.shouldStop():
return False return False
API = PlexAPI.API(plexmovie) API = PlexAPI.API(plexmovie)
@ -521,34 +519,32 @@ class LibrarySync(threading.Thread):
updatelist.append(itemid) updatelist.append(itemid)
else: else:
# Initial or repair sync: get all Plex movies # Initial or repair sync: get all Plex movies
for plexmovie in all_plexmovies[0:10]: for plexmovie in all_plexmovies:
API = PlexAPI.API(plexmovie) API = PlexAPI.API(plexmovie)
itemid = API.getKey() itemid = API.getKey()
plex_checksum = API.getChecksum() plex_checksum = API.getChecksum()
all_plexmoviesIds.append(plex_checksum) all_plexmoviesIds.append(plex_checksum)
updatelist.append(itemid) updatelist.append(itemid)
self.logMsg("Movies to update for %s: %s" % (viewName, updatelist), 1) self.logMsg("Movies to update for %s: %s" % (viewName, updatelist), 1)
# Get individual metadata for all movies that we need to sync
# This is possibly a huge list!
for itemid in updatelist:
plexmovie = plx.GetPlexMetadata(itemid)
plexmovies.append(plexmovie)
total = len(plexmovies) total = len(updatelist)
if pdialog: if pdialog:
pdialog.update(heading="Processing %s / %s items" % (viewName, total)) pdialog.update(heading="Processing %s / %s items" % (viewName, total))
count = 0 count = 0
for plexmovie in plexmovies: for itemid in updatelist:
# Process individual movies # Process individual movies
if self.shouldStop(): if self.shouldStop():
return False return False
plexmovie = plx.GetPlexMetadata(itemid)
title = plexmovie[0].attrib['title'] title = plexmovie[0].attrib['title']
if pdialog: if pdialog:
percentage = int((float(count) / float(total))*100) percentage = int((float(count) / float(total))*100)
pdialog.update(percentage, message=title) pdialog.update(percentage, message=title)
count += 1 count += 1
# Download individual metadata
movies.add_update(plexmovie, viewName, viewId) movies.add_update(plexmovie, viewName, viewId)
else: else:
self.logMsg("Movies finished.", 2) self.logMsg("Movies finished.", 2)