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

work on tv shows section

Browse source
This commit is contained in:
Marcel van der Veldt 2015-03-15 02:18:29 +01:00
parent 3439a599e9
commit 42220765dd
1 changed files with 21 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

33
resources/lib/LibrarySync.py
View file

@ -206,6 +206,7 @@ class LibrarySync():
host = addon.getSetting('ipaddress') host = addon.getSetting('ipaddress')
server = host + ":" + port server = host + ":" + port
downloadUtils = DownloadUtils() downloadUtils = DownloadUtils()
userid = downloadUtils.getUserId()
timeInfo = API().getTimeInfo(MBitem) timeInfo = API().getTimeInfo(MBitem)
userData=API().getUserData(MBitem) userData=API().getUserData(MBitem)
@ -430,14 +431,24 @@ class LibrarySync():
userData=API().getUserData(item) userData=API().getUserData(item)
people = API().getPeople(item) people = API().getPeople(item)
mediaStreams=API().getMediaStreams(item) mediaStreams=API().getMediaStreams(item)
item_type=str(item.get("Type")).encode('utf-8')
#todo: change path if type is not movie if item_type == "Movie":
itemPath = os.path.join(movieLibrary,item["Id"]) itemPath = os.path.join(movieLibrary,item["Id"])
nfoFile = os.path.join(itemPath,item["Id"] + ".nfo") nfoFile = os.path.join(itemPath,item["Id"] + ".nfo")
rootelement = "movie"
if item_type == "Series":
itemPath = os.path.join(tvLibrary,item["Id"])
nfoFile = os.path.join(itemPath,"tvshow.nfo")
rootelement = "tvshow"
if item_type == "Episode":
itemPath = os.path.join(tvLibrary,item["Id"])
nfoFile = os.path.join(itemPath,item["Id"] + ".nfo")
rootelement = "episodedetails"
root = Element("movie") root = Element(rootelement)
SubElement(root, "id").text = item["Id"] SubElement(root, "id").text = item["Id"]
SubElement(root, "tag").text = "all mediabrowser movies" # TODO --> use tags to assign user view #SubElement(root, "tag").text = # TODO --> use tags to assign user view
SubElement(root, "thumb").text = API().getArtwork(item, "poster") SubElement(root, "thumb").text = API().getArtwork(item, "poster")
SubElement(root, "fanart").text = API().getArtwork(item, "Backdrop") SubElement(root, "fanart").text = API().getArtwork(item, "Backdrop")
SubElement(root, "title").text = item["Name"].encode('utf-8').decode('utf-8') SubElement(root, "title").text = item["Name"].encode('utf-8').decode('utf-8')
@ -477,7 +488,7 @@ class LibrarySync():
utils.logMsg("Adding item to Kodi Library",item["Id"] + " - " + item["Name"]) utils.logMsg("Adding item to Kodi Library",item["Id"] + " - " + item["Name"])
#create path if not exists #create path if not exists
if not xbmcvfs.exists(itemPath): if not xbmcvfs.exists(itemPath + os.sep):
xbmcvfs.mkdir(itemPath) xbmcvfs.mkdir(itemPath)
#create nfo file #create nfo file
@ -497,19 +508,14 @@ class LibrarySync():
def addTVShowToKodiLibrary( self, item ): def addTVShowToKodiLibrary( self, item ):
itemPath = os.path.join(tvLibrary,item["Id"]) itemPath = os.path.join(tvLibrary,item["Id"])
strmFile = os.path.join(itemPath,item["Id"] + ".strm")
utils.logMsg("Adding item to Kodi Library",item["Id"] + " - " + item["Name"]) utils.logMsg("Adding item to Kodi Library",item["Id"] + " - " + item["Name"])
#create path if not exists #create path if not exists
if not xbmcvfs.exists(itemPath): if not xbmcvfs.exists(itemPath + os.sep):
xbmcvfs.mkdir(itemPath) xbmcvfs.mkdir(itemPath)
#create nfo file #create nfo file
self.createTVNFO(item) self.createNFO(item)
# create strm file
self.createSTRM(item["Id"])
def deleteTVShowFromKodiLibrary(self, id ): def deleteTVShowFromKodiLibrary(self, id ):
kodiItem = self.getKodiTVShow(id) kodiItem = self.getKodiTVShow(id)
@ -527,11 +533,6 @@ class LibrarySync():
connection = sqlite3.connect(dbPath) connection = sqlite3.connect(dbPath)
cursor = connection.cursor( ) cursor = connection.cursor( )
#cursor.execute("SELECT idBookmark FROM bookmark WHERE idFile = ?", (id,))
#bmid=cursor.fetchone()[0]
#if bmid != None:
#cursor.execute("delete FROM bookmark WHERE idBookmark = ?", (bmid,))
cursor.execute("delete FROM bookmark WHERE idFile = ?", (id,)) cursor.execute("delete FROM bookmark WHERE idFile = ?", (id,))
cursor.execute("select coalesce(max(idBookmark),0) as bookmarkId from bookmark") cursor.execute("select coalesce(max(idBookmark),0) as bookmarkId from bookmark")
bookmarkId = cursor.fetchone()[0] bookmarkId = cursor.fetchone()[0]