1074 lines
No EOL
51 KiB
Python
1074 lines
No EOL
51 KiB
Python
#################################################################################################
|
|
# WriteKodiDB
|
|
#################################################################################################
|
|
|
|
|
|
import xbmc
|
|
import xbmcgui
|
|
import xbmcaddon
|
|
import xbmcvfs
|
|
import json
|
|
import urllib
|
|
import sqlite3
|
|
import os
|
|
|
|
from DownloadUtils import DownloadUtils
|
|
from PlayUtils import PlayUtils
|
|
from CreateFiles import CreateFiles
|
|
from ReadKodiDB import ReadKodiDB
|
|
from ReadEmbyDB import ReadEmbyDB
|
|
from API import API
|
|
import Utils as utils
|
|
|
|
addon = xbmcaddon.Addon(id='plugin.video.emby')
|
|
addondir = xbmc.translatePath(addon.getAddonInfo('profile'))
|
|
dataPath = os.path.join(addondir,"library")
|
|
movieLibrary = os.path.join(dataPath,'movies')
|
|
tvLibrary = os.path.join(dataPath,'tvshows')
|
|
musicvideoLibrary = os.path.join(dataPath,'musicvideos')
|
|
|
|
sleepVal = 20
|
|
|
|
class WriteKodiDB():
|
|
|
|
def updatePlayCountFromKodi(self, id, type, playcount=0):
|
|
#when user marks item watched from kodi interface update this in MB3
|
|
xbmc.sleep(sleepVal)
|
|
utils.logMsg("MB3 Sync", "updatePlayCountFromKodi Called")
|
|
|
|
mb3Id = ReadKodiDB().getEmbyIdByKodiId(id, type)
|
|
|
|
if(mb3Id != None):
|
|
addon = xbmcaddon.Addon(id='plugin.video.emby')
|
|
port = addon.getSetting('port')
|
|
host = addon.getSetting('ipaddress')
|
|
server = host + ":" + port
|
|
downloadUtils = DownloadUtils()
|
|
userid = downloadUtils.getUserId()
|
|
|
|
watchedurl = 'http://' + server + '/mediabrowser/Users/' + userid + '/PlayedItems/' + mb3Id
|
|
utils.logMsg("MB3 Sync","watchedurl -->" + watchedurl)
|
|
if playcount != 0:
|
|
downloadUtils.downloadUrl(watchedurl, postBody="", type="POST")
|
|
else:
|
|
downloadUtils.downloadUrl(watchedurl, type="DELETE")
|
|
|
|
def updateMovieToKodiLibrary_Batched(self, MBitem, KodiItem):
|
|
addon = xbmcaddon.Addon(id='plugin.video.emby')
|
|
port = addon.getSetting('port')
|
|
host = addon.getSetting('ipaddress')
|
|
server = host + ":" + port
|
|
downloadUtils = DownloadUtils()
|
|
userid = downloadUtils.getUserId()
|
|
|
|
timeInfo = API().getTimeInfo(MBitem)
|
|
userData=API().getUserData(MBitem)
|
|
people = API().getPeople(MBitem)
|
|
genre = API().getGenre(MBitem)
|
|
studios = API().getStudios(MBitem)
|
|
mediaStreams=API().getMediaStreams(MBitem)
|
|
|
|
thumbPath = API().getArtwork(MBitem, "Primary")
|
|
|
|
params = list()
|
|
|
|
self.getArtworkParam_Batched(KodiItem, MBitem, params)
|
|
|
|
#set Filename
|
|
playurl = PlayUtils().getPlayUrl(server, MBitem["Id"], MBitem)
|
|
self.setKodiFilename(KodiItem["movieid"], KodiItem["file"], playurl, "movie")
|
|
|
|
#update common properties
|
|
duration = (int(timeInfo.get('Duration'))*60)
|
|
self.getPropertyParam_Batched(KodiItem, "runtime", duration, params)
|
|
self.getPropertyParam_Batched(KodiItem, "year", MBitem.get("ProductionYear"), params)
|
|
self.getPropertyParam_Batched(KodiItem, "mpaa", MBitem.get("OfficialRating"), params)
|
|
self.getPropertyParam_Batched(KodiItem, "lastplayed", userData.get("LastPlayedDate"), params)
|
|
|
|
self.getPropertyParamArray_Batched(KodiItem, "tag", MBitem.get("Tag"), params)
|
|
|
|
if MBitem.get("CriticRating") != None:
|
|
self.getPropertyParam_Batched(KodiItem, "rating", int(MBitem.get("CriticRating"))/10, params)
|
|
|
|
self.getPropertyParam_Batched(KodiItem, "plotoutline", MBitem.get("ShortOverview"), params)
|
|
self.getPropertyParam_Batched(KodiItem, "set", MBitem.get("TmdbCollectionName"), params)
|
|
self.getPropertyParam_Batched(KodiItem, "sorttitle", MBitem.get("SortName"), params)
|
|
|
|
if MBitem.get("ProviderIds") != None:
|
|
if MBitem.get("ProviderIds").get("Imdb") != None:
|
|
self.getPropertyParam_Batched(KodiItem, "imdbnumber", MBitem.get("ProviderIds").get("Imdb"), params)
|
|
|
|
# FIXME --> Taglines not returned by MB3 server !?
|
|
if MBitem.get("TagLines") != None:
|
|
self.getPropertyParam_Batched(KodiItem, "tagline", MBitem.get("TagLines")[0], params)
|
|
|
|
self.getPropertyParamArray_Batched(KodiItem, "writer", people.get("Writer"), params)
|
|
self.getPropertyParamArray_Batched(KodiItem, "director", people.get("Director"), params)
|
|
self.getPropertyParamArray_Batched(KodiItem, "genre", MBitem.get("Genres"), params)
|
|
|
|
if(studios != None):
|
|
for x in range(0, len(studios)):
|
|
studios[x] = studios[x].replace("/", "&")
|
|
self.getPropertyParamArray_Batched(KodiItem, "studio", studios, params)
|
|
|
|
# FIXME --> ProductionLocations not returned by MB3 server !?
|
|
self.getPropertyParamArray_Batched(KodiItem, "country", MBitem.get("ProductionLocations"), params)
|
|
|
|
#trailer link
|
|
trailerUrl = None
|
|
if MBitem.get("LocalTrailerCount") != None and MBitem.get("LocalTrailerCount") > 0:
|
|
itemTrailerUrl = "http://" + server + "/mediabrowser/Users/" + userid + "/Items/" + MBitem.get("Id") + "/LocalTrailers?format=json"
|
|
jsonData = downloadUtils.downloadUrl(itemTrailerUrl, suppress=False, popup=0 )
|
|
if(jsonData != ""):
|
|
trailerItem = json.loads(jsonData)
|
|
if trailerItem[0].get("LocationType") == "FileSystem":
|
|
trailerUrl = "plugin://plugin.video.emby/?id=" + trailerItem[0].get("Id") + '&mode=play'
|
|
self.getPropertyParam_Batched(KodiItem, "trailer", trailerUrl, params)
|
|
|
|
|
|
changes = False
|
|
# if there were movies changes then send the update via JSONRPC
|
|
if(len(params) > 0):
|
|
changes |= True
|
|
utils.logMsg("UpdateMovieParams", str(params), level = 2)
|
|
jsoncommand = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetMovieDetails", "params": { "movieid": %i, %s}, "id": 1 }'
|
|
paramString = ""
|
|
paramLen = len(params)
|
|
for x in range(0, paramLen):
|
|
param = params[x]
|
|
paramString += param
|
|
if(x < paramLen-1):
|
|
paramString += ", "
|
|
jsoncommand = jsoncommand %(KodiItem['movieid'], paramString)
|
|
utils.logMsg("executeJSONRPC : ", jsoncommand, level = 2)
|
|
xbmc.sleep(sleepVal)
|
|
result = xbmc.executeJSONRPC(jsoncommand)
|
|
|
|
#add actors
|
|
changes |= self.AddActorsToMedia(KodiItem,MBitem.get("People"), "movie")
|
|
|
|
#add theme music
|
|
if addon.getSetting("syncThemeMusic") == "true":
|
|
CreateFiles().copyThemeMusic(MBitem)
|
|
|
|
#add extra fanart
|
|
if addon.getSetting("syncExtraFanart") == "true":
|
|
CreateFiles().copyExtraFanart(MBitem)
|
|
|
|
if(changes):
|
|
utils.logMsg("Updated item to Kodi Library", MBitem["Id"] + " - " + MBitem["Name"], level=0)
|
|
|
|
return changes
|
|
|
|
def updateMusicVideoToKodiLibrary_Batched(self, MBitem, KodiItem):
|
|
addon = xbmcaddon.Addon(id='plugin.video.emby')
|
|
port = addon.getSetting('port')
|
|
host = addon.getSetting('ipaddress')
|
|
server = host + ":" + port
|
|
downloadUtils = DownloadUtils()
|
|
userid = downloadUtils.getUserId()
|
|
|
|
timeInfo = API().getTimeInfo(MBitem)
|
|
userData=API().getUserData(MBitem)
|
|
people = API().getPeople(MBitem)
|
|
genre = API().getGenre(MBitem)
|
|
studios = API().getStudios(MBitem)
|
|
mediaStreams=API().getMediaStreams(MBitem)
|
|
|
|
thumbPath = API().getArtwork(MBitem, "Primary")
|
|
|
|
params = list()
|
|
|
|
self.getArtworkParam_Batched(KodiItem, MBitem, params)
|
|
|
|
#update common properties
|
|
duration = (int(timeInfo.get('Duration'))*60)
|
|
self.getPropertyParam_Batched(KodiItem, "runtime", duration, params)
|
|
self.getPropertyParam_Batched(KodiItem, "year", MBitem.get("ProductionYear"), params)
|
|
self.getPropertyParamArray_Batched(KodiItem, "director", people.get("Director"), params)
|
|
self.getPropertyParamArray_Batched(KodiItem, "genre", MBitem.get("Genres"), params)
|
|
self.getPropertyParamArray_Batched(KodiItem, "artist", MBitem.get("Artist"), params)
|
|
self.getPropertyParamArray_Batched(KodiItem, "album", MBitem.get("Album"), params)
|
|
self.getPropertyParam_Batched(KodiItem, "lastplayed", userData.get("LastPlayedDate"), params)
|
|
|
|
if(studios != None):
|
|
for x in range(0, len(studios)):
|
|
studios[x] = studios[x].replace("/", "&")
|
|
self.getPropertyParamArray_Batched(KodiItem, "studio", studios, params)
|
|
|
|
changes = False
|
|
# if there were movies changes then send the update via JSONRPC
|
|
if(len(params) > 0):
|
|
changes |= True
|
|
utils.logMsg("UpdateMovieParams", str(params), level = 2)
|
|
jsoncommand = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetMusicVideoDetails", "params": { "musicvideoid": %i, %s}, "id": 1 }'
|
|
paramString = ""
|
|
paramLen = len(params)
|
|
for x in range(0, paramLen):
|
|
param = params[x]
|
|
paramString += param
|
|
if(x < paramLen-1):
|
|
paramString += ", "
|
|
jsoncommand = jsoncommand %(KodiItem['musicvideoid'], paramString)
|
|
utils.logMsg("executeJSONRPC : ", jsoncommand, level = 2)
|
|
xbmc.sleep(sleepVal)
|
|
result = xbmc.executeJSONRPC(jsoncommand)
|
|
|
|
CreateFiles().createSTRM(MBitem)
|
|
CreateFiles().createNFO(MBitem)
|
|
|
|
if(changes):
|
|
utils.logMsg("Updated musicvideo to Kodi Library", MBitem["Id"] + " - " + MBitem["Name"], level=0)
|
|
|
|
def updateMovieToKodiLibrary(self, MBitem, KodiItem):
|
|
|
|
addon = xbmcaddon.Addon(id='plugin.video.emby')
|
|
port = addon.getSetting('port')
|
|
host = addon.getSetting('ipaddress')
|
|
server = host + ":" + port
|
|
downloadUtils = DownloadUtils()
|
|
userid = downloadUtils.getUserId()
|
|
|
|
timeInfo = API().getTimeInfo(MBitem)
|
|
userData=API().getUserData(MBitem)
|
|
people = API().getPeople(MBitem)
|
|
genre = API().getGenre(MBitem)
|
|
studios = API().getStudios(MBitem)
|
|
mediaStreams=API().getMediaStreams(MBitem)
|
|
|
|
thumbPath = API().getArtwork(MBitem, "Primary")
|
|
|
|
changes = False
|
|
|
|
#update/check all artwork
|
|
changes |= self.updateArtWork(KodiItem,MBitem)
|
|
|
|
#update common properties
|
|
duration = (int(timeInfo.get('Duration'))*60)
|
|
changes |= self.updateProperty(KodiItem,"runtime",duration,"movie")
|
|
changes |= self.updateProperty(KodiItem,"year",MBitem.get("ProductionYear"),"movie")
|
|
changes |= self.updateProperty(KodiItem,"mpaa",MBitem.get("OfficialRating"),"movie")
|
|
changes |= self.updateProperty(KodiItem,"lastplayed",MBitem.get("LastPlayedDate"),"movie")
|
|
changes |= self.updatePropertyArray(KodiItem,"tag",MBitem.get("Tag"),"movie")
|
|
|
|
if MBitem.get("CriticRating") != None:
|
|
changes |= self.updateProperty(KodiItem,"rating",int(MBitem.get("CriticRating"))/10,"movie")
|
|
|
|
changes |= self.updateProperty(KodiItem,"plotoutline",MBitem.get("ShortOverview"),"movie")
|
|
changes |= self.updateProperty(KodiItem,"set",MBitem.get("TmdbCollectionName"),"movie")
|
|
changes |= self.updateProperty(KodiItem,"sorttitle",MBitem.get("SortName"),"movie")
|
|
|
|
if MBitem.get("ProviderIds") != None:
|
|
if MBitem.get("ProviderIds").get("Imdb") != None:
|
|
changes |= self.updateProperty(KodiItem,"imdbnumber",MBitem.get("ProviderIds").get("Imdb"),"movie")
|
|
|
|
# FIXME --> Taglines not returned by MB3 server !?
|
|
if MBitem.get("TagLines") != None:
|
|
changes |= self.updateProperty(KodiItem,"tagline",MBitem.get("TagLines")[0],"movie")
|
|
|
|
changes |= self.updatePropertyArray(KodiItem,"writer",people.get("Writer"),"movie")
|
|
changes |= self.updatePropertyArray(KodiItem,"director",people.get("Director"),"movie")
|
|
changes |= self.updatePropertyArray(KodiItem,"genre",MBitem.get("Genres"),"movie")
|
|
|
|
if(studios != None):
|
|
for x in range(0, len(studios)):
|
|
studios[x] = studios[x].replace("/", "&")
|
|
changes |= self.updatePropertyArray(KodiItem,"studio",studios,"movie")
|
|
|
|
# FIXME --> ProductionLocations not returned by MB3 server !?
|
|
changes |= self.updatePropertyArray(KodiItem,"country",MBitem.get("ProductionLocations"),"movie")
|
|
|
|
#trailer link
|
|
trailerUrl = None
|
|
if MBitem.get("LocalTrailerCount") != None and MBitem.get("LocalTrailerCount") > 0:
|
|
itemTrailerUrl = "http://" + server + "/mediabrowser/Users/" + userid + "/Items/" + MBitem.get("Id") + "/LocalTrailers?format=json"
|
|
jsonData = downloadUtils.downloadUrl(itemTrailerUrl, suppress=False, popup=0 )
|
|
if(jsonData != ""):
|
|
trailerItem = json.loads(jsonData)
|
|
trailerUrl = "plugin://plugin.video.emby/?id=" + trailerItem[0].get("Id") + '&mode=play'
|
|
changes |= self.updateProperty(KodiItem,"trailer",trailerUrl,"movie")
|
|
|
|
#add actors
|
|
changes |= self.AddActorsToMedia(KodiItem,MBitem.get("People"),"movie")
|
|
|
|
#set Filename
|
|
playurl = PlayUtils().getPlayUrl(server, MBitem["Id"], MBitem)
|
|
self.setKodiFilename(KodiItem["movieid"], KodiItem["file"], playurl, "movie")
|
|
|
|
|
|
#add theme music
|
|
if addon.getSetting("syncThemeMusic") == "true":
|
|
CreateFiles().copyThemeMusic(MBitem)
|
|
|
|
#add extra fanart
|
|
if addon.getSetting("syncExtraFanart") == "true":
|
|
CreateFiles().copyExtraFanart(MBitem)
|
|
|
|
if changes:
|
|
utils.logMsg("Updated item to Kodi Library", MBitem["Id"] + " - " + MBitem["Name"])
|
|
|
|
def updateTVShowToKodiLibrary( self, MBitem, KodiItem ):
|
|
|
|
addon = xbmcaddon.Addon(id='plugin.video.emby')
|
|
port = addon.getSetting('port')
|
|
host = addon.getSetting('ipaddress')
|
|
server = host + ":" + port
|
|
downloadUtils = DownloadUtils()
|
|
|
|
timeInfo = API().getTimeInfo(MBitem)
|
|
userData=API().getUserData(MBitem)
|
|
people = API().getPeople(MBitem)
|
|
genre = API().getGenre(MBitem)
|
|
studios = API().getStudios(MBitem)
|
|
mediaStreams=API().getMediaStreams(MBitem)
|
|
|
|
thumbPath = API().getArtwork(MBitem, "Primary")
|
|
|
|
changes = False
|
|
|
|
#set Filename
|
|
playurl = PlayUtils().getPlayUrl(server, MBitem["Id"], MBitem)
|
|
#make sure that the path always ends with a slash
|
|
playurl = playurl + "/"
|
|
self.setKodiFilename(KodiItem["tvshowid"], KodiItem["file"], playurl, "tvshow")
|
|
|
|
#update/check all artwork
|
|
changes |= self.updateArtWork(KodiItem,MBitem)
|
|
|
|
#update common properties
|
|
if MBitem.get("PremiereDate") != None:
|
|
premieredatelist = (MBitem.get("PremiereDate")).split("T")
|
|
premieredate = premieredatelist[0]
|
|
changes |= self.updateProperty(KodiItem,"premiered",premieredate,"tvshow")
|
|
|
|
changes |= self.updateProperty(KodiItem,"mpaa",MBitem.get("OfficialRating"),"tvshow")
|
|
changes |= self.updateProperty(KodiItem,"lastplayed",MBitem.get("LastPlayedDate"),"tvshow")
|
|
|
|
if MBitem.get("CriticRating") != None:
|
|
changes |= self.updateProperty(KodiItem,"rating",int(MBitem.get("CriticRating"))/10,"tvshow")
|
|
|
|
changes |= self.updateProperty(KodiItem,"sorttitle",MBitem.get("SortName"),"tvshow")
|
|
|
|
if MBitem.get("ProviderIds") != None:
|
|
if MBitem.get("ProviderIds").get("Imdb") != None:
|
|
changes |= self.updateProperty(KodiItem,"imdbnumber",MBitem.get("ProviderIds").get("Imdb"),"tvshow")
|
|
|
|
changes |= self.updatePropertyArray(KodiItem,"genre",MBitem.get("Genres"),"tvshow")
|
|
|
|
if(studios != None):
|
|
for x in range(0, len(studios)):
|
|
studios[x] = studios[x].replace("/", "&")
|
|
changes |= self.updatePropertyArray(KodiItem,"studio",studios,"tvshow")
|
|
|
|
# FIXME --> ProductionLocations not returned by MB3 server !?
|
|
changes |= self.updatePropertyArray(KodiItem,"country",MBitem.get("ProductionLocations"),"tvshow")
|
|
|
|
#add actors
|
|
changes |= self.AddActorsToMedia(KodiItem,MBitem.get("People"),"tvshow")
|
|
|
|
#update season artwork
|
|
self.updateSeasonArtwork(MBitem, KodiItem)
|
|
|
|
CreateFiles().createNFO(MBitem)
|
|
|
|
#add theme music
|
|
if addon.getSetting("syncThemeMusic") == "true":
|
|
CreateFiles().copyThemeMusic(MBitem)
|
|
|
|
#add extra fanart
|
|
if addon.getSetting("syncExtraFanart") == "true":
|
|
CreateFiles().copyExtraFanart(MBitem)
|
|
|
|
if changes:
|
|
utils.logMsg("Updated item to Kodi Library", MBitem["Id"] + " - " + MBitem["Name"])
|
|
|
|
return changes
|
|
|
|
def updateEpisodeToKodiLibrary( self, MBitem, KodiItem ):
|
|
|
|
addon = xbmcaddon.Addon(id='plugin.video.emby')
|
|
port = addon.getSetting('port')
|
|
host = addon.getSetting('ipaddress')
|
|
server = host + ":" + port
|
|
downloadUtils = DownloadUtils()
|
|
userid = downloadUtils.getUserId()
|
|
|
|
timeInfo = API().getTimeInfo(MBitem)
|
|
people = API().getPeople(MBitem)
|
|
genre = API().getGenre(MBitem)
|
|
studios = API().getStudios(MBitem)
|
|
mediaStreams=API().getMediaStreams(MBitem)
|
|
userData=API().getUserData(MBitem)
|
|
|
|
thumbPath = API().getArtwork(MBitem, "Primary")
|
|
|
|
changes = False
|
|
|
|
#update/check all artwork
|
|
changes |= self.updateArtWork(KodiItem,MBitem)
|
|
|
|
#set Filename
|
|
playurl = PlayUtils().getPlayUrl(server, MBitem["Id"], MBitem)
|
|
self.setKodiFilename(KodiItem["episodeid"], KodiItem["file"], playurl, "episode")
|
|
|
|
#update common properties
|
|
duration = (int(timeInfo.get('Duration'))*60)
|
|
changes |= self.updateProperty(KodiItem,"runtime",duration,"episode")
|
|
changes |= self.updateProperty(KodiItem,"lastplayed",userData.get("LastPlayedDate"),"episode")
|
|
|
|
if MBitem.get("PremiereDate") != None:
|
|
premieredatelist = (MBitem.get("PremiereDate")).split("T")
|
|
premieredate = premieredatelist[0]
|
|
premieretime = premieredatelist[1].split(".")[0]
|
|
firstaired = premieredate + " " + premieretime
|
|
# for Helix we use the whole time string, for kodi 15 we have to change to only the datestring
|
|
# see: http://forum.kodi.tv/showthread.php?tid=218743
|
|
if KodiItem["firstaired"] != premieredate:
|
|
self.updateProperty(KodiItem,"firstaired",firstaired,"episode")
|
|
|
|
if MBitem.get("CriticRating") != None:
|
|
changes |= self.updateProperty(KodiItem,"rating",int(MBitem.get("CriticRating"))/10,"episode")
|
|
|
|
changes |= self.updatePropertyArray(KodiItem,"writer",people.get("Writer"),"episode")
|
|
|
|
#add actors
|
|
changes |= self.AddActorsToMedia(KodiItem,MBitem.get("People"),"episode")
|
|
|
|
if changes:
|
|
utils.logMsg("Updated item to Kodi Library", MBitem["Id"] + " - " + MBitem["Name"])
|
|
|
|
return changes
|
|
|
|
def getArtworkParam_Batched(self, KodiItem, MBitem, params):
|
|
|
|
'''
|
|
item_type=str(MBitem.get("Type"))
|
|
if item_type == "Series":
|
|
id = KodiItem['tvshowid']
|
|
jsoncommand = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetTVShowDetails", "params": { "tvshowid": %i, "art": %s}, "id": 1 }'
|
|
elif item_type == "Episode":
|
|
# episodes don't have any artwork - they derrive this from the tv show
|
|
return False
|
|
elif item_type == "MusicVideo":
|
|
id = KodiItem['musicvideoid']
|
|
jsoncommand = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetMusicVideoDetails", "params": { musicvideoid": %i, "art": %s}, "id": 1 }'
|
|
elif item_type == "Movie":
|
|
id = KodiItem['movieid']
|
|
jsoncommand = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetMovieDetails", "params": { "movieid": %i, "art": %s}, "id": 1 }'
|
|
'''
|
|
|
|
#update artwork
|
|
changes = False
|
|
|
|
artwork = {}
|
|
artwork["poster"] = API().getArtwork(MBitem, "Primary")
|
|
artwork["banner"] = API().getArtwork(MBitem, "Banner")
|
|
artwork["clearlogo"] = API().getArtwork(MBitem, "Logo")
|
|
artwork["clearart"] = API().getArtwork(MBitem, "Art")
|
|
artwork["landscape"] = API().getArtwork(MBitem, "Thumb")
|
|
artwork["discart"] = API().getArtwork(MBitem, "Disc")
|
|
artwork["fanart"] = API().getArtwork(MBitem, "Backdrop")
|
|
|
|
for art in artwork:
|
|
if artwork.get(art) != "":
|
|
if KodiItem["art"].has_key(art):
|
|
curValue = urllib.unquote(KodiItem['art'][art]).decode('utf8')
|
|
if not artwork.get(art) in curValue:
|
|
KodiItem["art"][art] = artwork.get(art)
|
|
changes = True
|
|
else:
|
|
KodiItem["art"][art] = artwork.get(art)
|
|
changes = True
|
|
|
|
if len(KodiItem["art"]) == 0:
|
|
changes = False
|
|
|
|
if changes:
|
|
json_array = json.dumps(KodiItem["art"])
|
|
params.append("\"art\": " + json_array)
|
|
#result = xbmc.executeJSONRPC(jsoncommand %(id, json_array))
|
|
return changes
|
|
|
|
# adds or updates artwork to the given Kodi file in database
|
|
def updateArtWork(self,KodiItem,MBitem):
|
|
|
|
item_type=str(MBitem.get("Type"))
|
|
|
|
if item_type == "Series":
|
|
id = KodiItem['tvshowid']
|
|
jsoncommand = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetTVShowDetails", "params": { "tvshowid": %i, "art": %s}, "id": 1 }'
|
|
elif item_type == "Episode":
|
|
# episodes don't have any artwork - they derrive this from the tv show
|
|
return False
|
|
elif item_type == "MusicVideo":
|
|
id = KodiItem['musicvideoid']
|
|
jsoncommand = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetMusicVideoDetails", "params": { musicvideoid": %i, "art": %s}, "id": 1 }'
|
|
elif item_type == "Movie":
|
|
id = KodiItem['movieid']
|
|
jsoncommand = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetMovieDetails", "params": { "movieid": %i, "art": %s}, "id": 1 }'
|
|
|
|
#update artwork
|
|
changes = False
|
|
|
|
artwork = {}
|
|
artwork["poster"] = API().getArtwork(MBitem, "Primary")
|
|
artwork["banner"] = API().getArtwork(MBitem, "Banner")
|
|
artwork["clearlogo"] = API().getArtwork(MBitem, "Logo")
|
|
artwork["clearart"] = API().getArtwork(MBitem, "Art")
|
|
artwork["landscape"] = API().getArtwork(MBitem, "Thumb")
|
|
artwork["discart"] = API().getArtwork(MBitem, "Disc")
|
|
artwork["fanart"] = API().getArtwork(MBitem, "Backdrop")
|
|
|
|
for art in artwork:
|
|
if artwork.get(art) != "":
|
|
if KodiItem["art"].has_key(art):
|
|
curValue = urllib.unquote(KodiItem['art'][art]).decode('utf8')
|
|
if not artwork.get(art) in curValue:
|
|
KodiItem["art"][art] = artwork.get(art)
|
|
changes = True
|
|
else:
|
|
KodiItem["art"][art] = artwork.get(art)
|
|
changes = True
|
|
|
|
if len(KodiItem["art"]) == 0:
|
|
changes = False
|
|
|
|
if changes:
|
|
json_array = json.dumps(KodiItem["art"])
|
|
result = xbmc.executeJSONRPC(jsoncommand %(id, json_array))
|
|
return changes
|
|
|
|
def getPropertyParam_Batched(self,KodiItem, propertyName, propertyValue, params, forced = False):
|
|
|
|
'''
|
|
if fileType == "tvshow":
|
|
id = KodiItem['tvshowid']
|
|
jsoncommand_i = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetTVShowDetails", "params": { "tvshowid": %i, "%s": %i}, "id": 1 }'
|
|
jsoncommand_s = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetTVShowDetails", "params": { "tvshowid": %i, "%s": "%s"}, "id": 1 }'
|
|
elif fileType == "episode":
|
|
id = KodiItem['episodeid']
|
|
jsoncommand_i = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetEpisodeDetails", "params": { "episodeid": %i, "%s": %i}, "id": 1 }'
|
|
jsoncommand_s = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetEpisodeDetails", "params": { "episodeid": %i, "%s": "%s"}, "id": 1 }'
|
|
elif fileType == "musicvideo":
|
|
id = KodiItem['musicvideoid']
|
|
jsoncommand_i = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetMusicVideoDetails", "params": { "musicvideoid": %i, "%s": %i}, "id": 1 }'
|
|
jsoncommand_s = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetMusicVideoDetails", "params": { "musicvideoid": %i, "%s": "%s"}, "id": 1 }'
|
|
elif fileType == "movie":
|
|
id = KodiItem['movieid']
|
|
jsoncommand_i = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetMovieDetails", "params": { "movieid": %i, "%s": %i}, "id": 1 }'
|
|
jsoncommand_s = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetMovieDetails", "params": { "movieid": %i, "%s": "%s"}, "id": 1 }'
|
|
'''
|
|
|
|
changes = False
|
|
if ((propertyValue != KodiItem[propertyName]) or forced):
|
|
if propertyValue != None:
|
|
if type(propertyValue) is int:
|
|
#xbmc.sleep(sleepVal)
|
|
utils.logMsg("MB3 Sync","updating property..." + str(propertyName))
|
|
utils.logMsg("MB3 Sync","kodi value:" + str(KodiItem[propertyName]) + " MB value: " + str(propertyValue))
|
|
params.append("\"" + propertyName + "\": " + str(propertyValue))
|
|
#xbmc.executeJSONRPC(jsoncommand_i %(id, propertyName, propertyValue))
|
|
changes = True
|
|
else:
|
|
#xbmc.sleep(sleepVal)
|
|
utils.logMsg("MB3 Sync","updating property..." + str(propertyName))
|
|
utils.logMsg("MB3 Sync","kodi value:" + KodiItem[propertyName] + " MB value: " + propertyValue)
|
|
params.append("\"" + propertyName + "\": \"" + str(propertyValue) + "\"")
|
|
#xbmc.executeJSONRPC(jsoncommand_s %(id, propertyName, propertyValue.encode('utf-8')))
|
|
changes = True
|
|
|
|
return changes
|
|
|
|
# adds or updates the given property on the videofile in Kodi database
|
|
def updateProperty(self,KodiItem,propertyName,propertyValue,fileType,forced=False):
|
|
if fileType == "tvshow":
|
|
id = KodiItem['tvshowid']
|
|
jsoncommand_i = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetTVShowDetails", "params": { "tvshowid": %i, "%s": %i}, "id": 1 }'
|
|
jsoncommand_s = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetTVShowDetails", "params": { "tvshowid": %i, "%s": "%s"}, "id": 1 }'
|
|
elif fileType == "episode":
|
|
id = KodiItem['episodeid']
|
|
jsoncommand_i = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetEpisodeDetails", "params": { "episodeid": %i, "%s": %i}, "id": 1 }'
|
|
jsoncommand_s = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetEpisodeDetails", "params": { "episodeid": %i, "%s": "%s"}, "id": 1 }'
|
|
elif fileType == "musicvideo":
|
|
id = KodiItem['musicvideoid']
|
|
jsoncommand_i = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetMusicVideoDetails", "params": { "musicvideoid": %i, "%s": %i}, "id": 1 }'
|
|
jsoncommand_s = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetMusicVideoDetails", "params": { "musicvideoid": %i, "%s": "%s"}, "id": 1 }'
|
|
elif fileType == "movie":
|
|
id = KodiItem['movieid']
|
|
jsoncommand_i = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetMovieDetails", "params": { "movieid": %i, "%s": %i}, "id": 1 }'
|
|
jsoncommand_s = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetMovieDetails", "params": { "movieid": %i, "%s": "%s"}, "id": 1 }'
|
|
|
|
changes = False
|
|
if ((propertyValue != KodiItem[propertyName]) or forced):
|
|
if propertyValue != None:
|
|
if type(propertyValue) is int:
|
|
xbmc.sleep(sleepVal)
|
|
utils.logMsg("MB3 Sync","updating property..." + str(propertyName))
|
|
utils.logMsg("MB3 Sync","kodi value:" + str(KodiItem[propertyName]) + " MB value: " + str(propertyValue))
|
|
xbmc.executeJSONRPC(jsoncommand_i %(id, propertyName, propertyValue))
|
|
changes = True
|
|
else:
|
|
xbmc.sleep(sleepVal)
|
|
utils.logMsg("MB3 Sync","updating property..." + str(propertyName))
|
|
utils.logMsg("MB3 Sync","kodi value:" + KodiItem[propertyName] + " MB value: " + propertyValue)
|
|
xbmc.executeJSONRPC(jsoncommand_s %(id, propertyName, propertyValue.encode('utf-8')))
|
|
changes = True
|
|
|
|
return changes
|
|
|
|
def getPropertyParamArray_Batched(self, KodiItem, propertyName, propertyCollection, params):
|
|
'''
|
|
if fileType == "tvshow":
|
|
id = KodiItem['tvshowid']
|
|
jsoncommand = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetTVShowDetails", "params": { "tvshowid": %i, "%s": %s}, "id": 1 }'
|
|
elif fileType == "episode":
|
|
id = KodiItem['episodeid']
|
|
jsoncommand = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetEpisodeDetails", "params": { "episodeid": %i, "%s": %s}, "id": 1 }'
|
|
elif fileType == "musicvideo":
|
|
id = KodiItem['musicvideoid']
|
|
jsoncommand = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetMusicVideoDetails", "params": { "musicvideoid": %i, "%s": %s}, "id": 1 }'
|
|
elif fileType == "movie":
|
|
id = KodiItem['movieid']
|
|
jsoncommand = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetMovieDetails", "params": { "movieid": %i, "%s": %s}, "id": 1 }'
|
|
'''
|
|
|
|
pendingChanges = False
|
|
if propertyCollection != None:
|
|
currentvalues = set(KodiItem[propertyName])
|
|
for item in propertyCollection:
|
|
if not item in currentvalues:
|
|
pendingChanges = True
|
|
json_array = json.dumps(propertyCollection)
|
|
|
|
if pendingChanges:
|
|
#xbmc.sleep(sleepVal)
|
|
utils.logMsg("MB3 Sync","updating propertyarray... Name:" + str(propertyName) + " Current:" + str(currentvalues) + " New:" + str(json_array))
|
|
params.append("\"" + propertyName + "\": " + json_array)
|
|
#xbmc.executeJSONRPC(jsoncommand %(id,propertyName,json_array))
|
|
|
|
return pendingChanges
|
|
|
|
# adds or updates the property-array on the videofile in Kodi database
|
|
def updatePropertyArray(self,KodiItem,propertyName,propertyCollection,fileType):
|
|
if fileType == "tvshow":
|
|
id = KodiItem['tvshowid']
|
|
jsoncommand = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetTVShowDetails", "params": { "tvshowid": %i, "%s": %s}, "id": 1 }'
|
|
elif fileType == "episode":
|
|
id = KodiItem['episodeid']
|
|
jsoncommand = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetEpisodeDetails", "params": { "episodeid": %i, "%s": %s}, "id": 1 }'
|
|
elif fileType == "musicvideo":
|
|
id = KodiItem['musicvideoid']
|
|
jsoncommand = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetMusicVideoDetails", "params": { "musicvideoid": %i, "%s": %s}, "id": 1 }'
|
|
elif fileType == "movie":
|
|
id = KodiItem['movieid']
|
|
jsoncommand = '{"jsonrpc": "2.0", "method": "VideoLibrary.SetMovieDetails", "params": { "movieid": %i, "%s": %s}, "id": 1 }'
|
|
|
|
pendingChanges = False
|
|
if propertyCollection != None:
|
|
currentvalues = set(KodiItem[propertyName])
|
|
for item in propertyCollection:
|
|
if not item in currentvalues:
|
|
pendingChanges = True
|
|
json_array = json.dumps(propertyCollection)
|
|
|
|
if pendingChanges:
|
|
xbmc.sleep(sleepVal)
|
|
utils.logMsg("MB3 Sync","updating propertyarray... Name:" + str(propertyName) + " Current:" + str(currentvalues) + " New:" + str(json_array))
|
|
xbmc.executeJSONRPC(jsoncommand %(id,propertyName,json_array))
|
|
|
|
return pendingChanges
|
|
|
|
def addMovieToKodiLibrary( self, item ):
|
|
itemPath = os.path.join(movieLibrary,item["Id"])
|
|
strmFile = os.path.join(itemPath,item["Id"] + ".strm")
|
|
|
|
changes = False
|
|
|
|
#create path if not exists
|
|
if not xbmcvfs.exists(itemPath + os.sep):
|
|
xbmcvfs.mkdir(itemPath)
|
|
|
|
#create nfo file
|
|
changes = CreateFiles().createNFO(item)
|
|
|
|
# create strm file
|
|
changes |= CreateFiles().createSTRM(item)
|
|
|
|
if changes:
|
|
utils.logMsg("MB3 Sync","Added movie to Kodi Library",item["Id"] + " - " + item["Name"])
|
|
|
|
def addMusicVideoToKodiLibrary( self, item ):
|
|
itemPath = os.path.join(musicvideoLibrary,item["Id"])
|
|
strmFile = os.path.join(itemPath,item["Id"] + ".strm")
|
|
|
|
changes = False
|
|
|
|
#create path if not exists
|
|
if not xbmcvfs.exists(itemPath + os.sep):
|
|
xbmcvfs.mkdir(itemPath)
|
|
|
|
#create nfo file
|
|
changes = CreateFiles().createNFO(item)
|
|
|
|
# create strm file
|
|
changes |= CreateFiles().createSTRM(item)
|
|
|
|
if changes:
|
|
utils.logMsg("MB3 Sync","Added musicvideo to Kodi Library",item["Id"] + " - " + item["Name"])
|
|
|
|
def addEpisodeToKodiLibrary(self, item):
|
|
|
|
changes = False
|
|
|
|
#create nfo file
|
|
changes = CreateFiles().createNFO(item)
|
|
|
|
# create strm file
|
|
changes |= CreateFiles().createSTRM(item)
|
|
|
|
if changes:
|
|
utils.logMsg("MB3 Sync","Added episode to Kodi Library",item["Id"] + " - " + item["Name"])
|
|
|
|
def deleteMovieFromKodiLibrary(self, id ):
|
|
kodiItem = ReadKodiDB().getKodiMovie(id)
|
|
utils.logMsg("deleting movie from Kodi library",id)
|
|
if kodiItem != None:
|
|
xbmc.executeJSONRPC('{"jsonrpc": "2.0", "method": "VideoLibrary.RemoveMovie", "params": { "movieid": %i}, "id": 1 }' %(kodiItem["movieid"]))
|
|
|
|
path = os.path.join(movieLibrary,id)
|
|
allDirs, allFiles = xbmcvfs.listdir(path)
|
|
for dir in allDirs:
|
|
xbmcvfs.rmdir(os.path.join(path,dir))
|
|
for file in allFiles:
|
|
xbmcvfs.delete(os.path.join(path,file))
|
|
xbmcvfs.rmdir(path)
|
|
|
|
def deleteMusicVideoFromKodiLibrary(self, id ):
|
|
utils.logMsg("deleting musicvideo from Kodi library",id)
|
|
kodiItem = ReadKodiDB().getKodiMusicVideo(id)
|
|
if kodiItem != None:
|
|
xbmc.executeJSONRPC('{"jsonrpc": "2.0", "method": "VideoLibrary.RemoveMusicVideo", "params": { "musicvideoid": %i}, "id": 1 }' %(kodiItem["musicvideoid"]))
|
|
|
|
path = os.path.join(musicvideoLibrary,id)
|
|
allDirs, allFiles = xbmcvfs.listdir(path)
|
|
for dir in allDirs:
|
|
xbmcvfs.rmdir(os.path.join(path,dir))
|
|
for file in allFiles:
|
|
xbmcvfs.delete(os.path.join(path,file))
|
|
xbmcvfs.rmdir(path)
|
|
|
|
def deleteEpisodeFromKodiLibrary(self, episodeid, tvshowid ):
|
|
utils.logMsg("deleting episode from Kodi library",episodeid)
|
|
episode = ReadKodiDB().getKodiEpisodeByMbItem(episodeid, tvshowid)
|
|
if episode != None:
|
|
WINDOW = xbmcgui.Window( 10000 )
|
|
WINDOW.setProperty("suspendDeletes", "True")
|
|
xbmc.executeJSONRPC('{"jsonrpc": "2.0", "method": "VideoLibrary.RemoveEpisode", "params": { "episodeid": %i}, "id": 1 }' %(episode["episodeid"]))
|
|
|
|
itemPath = os.path.join(tvLibrary,tvshowid)
|
|
allDirs, allFiles = xbmcvfs.listdir(itemPath)
|
|
for file in allFiles:
|
|
if episodeid in file:
|
|
xbmcvfs.delete(file)
|
|
|
|
while WINDOW.getProperty("suspendDeletes") == "True":
|
|
xbmc.sleep(100)
|
|
utils.logMsg("episode deleted succesfully!",episodeid)
|
|
else:
|
|
utils.logMsg("episode not found in kodi DB",episodeid)
|
|
|
|
|
|
def addTVShowToKodiLibrary( self, item ):
|
|
itemPath = os.path.join(tvLibrary,item["Id"])
|
|
|
|
changes = False
|
|
|
|
#create path if not exists
|
|
if not xbmcvfs.exists(itemPath + os.sep):
|
|
xbmcvfs.mkdir(itemPath)
|
|
|
|
#create nfo file
|
|
changes = CreateFiles().createNFO(item)
|
|
|
|
if changes:
|
|
utils.logMsg("Added TV Show to Kodi Library ",item["Id"] + " - " + item["Name"])
|
|
|
|
def deleteTVShowFromKodiLibrary(self, id ):
|
|
xbmc.sleep(sleepVal)
|
|
kodiItem = ReadKodiDB().getKodiTVShow(id)
|
|
utils.logMsg("deleting tvshow from Kodi library",id)
|
|
|
|
if kodiItem != None:
|
|
xbmc.executeJSONRPC('{"jsonrpc": "2.0", "method": "VideoLibrary.RemoveTVShow", "params": { "tvshowid": %i}, "id": 1 }' %(kodiItem["tvshowid"]))
|
|
|
|
path = os.path.join(tvLibrary,id)
|
|
allDirs, allFiles = xbmcvfs.listdir(path)
|
|
for dir in allDirs:
|
|
xbmcvfs.rmdir(os.path.join(path,dir))
|
|
for file in allFiles:
|
|
xbmcvfs.delete(os.path.join(path,file))
|
|
succes = xbmcvfs.rmdir(path)
|
|
if not succes:
|
|
utils.logMsg("Error deleting TV show with ID ",id)
|
|
|
|
def updateSeasonArtwork(self,MBitem, KodiItem):
|
|
#use sqlite to set the season artwork because no method in API available for this
|
|
#season poster and banner are set by the nfo. landscape image is filled by this method
|
|
#if wanted this feature can be extended to also update the other artwork
|
|
tvshowid = KodiItem["tvshowid"]
|
|
|
|
connection = utils.KodiSQL()
|
|
cursor = connection.cursor( )
|
|
|
|
seasonData = ReadEmbyDB().getTVShowSeasons(MBitem["Id"])
|
|
if seasonData != None:
|
|
for season in seasonData:
|
|
if season.has_key("IndexNumber"):
|
|
MB3landscape = API().getArtwork(season, "Thumb")
|
|
if MB3landscape != "":
|
|
cursor.execute("SELECT idSeason as seasonid FROM seasons WHERE idShow = ? and season = ?",(tvshowid,season["IndexNumber"]))
|
|
result = cursor.fetchone()
|
|
if result != None:
|
|
seasonid = result[0]
|
|
cursor.execute("SELECT art_id as art_id FROM art WHERE media_id = ? and media_type = ? and type = ?",(seasonid,"season","landscape"))
|
|
result = cursor.fetchone()
|
|
if result == None:
|
|
sql="INSERT into art(media_id, media_type, type, url) values(?, ?, ?, ?)"
|
|
cursor.execute(sql, (seasonid,"season","landscape",MB3landscape))
|
|
|
|
connection.commit()
|
|
cursor.close()
|
|
|
|
def setKodiResumePoint(self, id, resume_seconds, total_seconds, fileType):
|
|
#use sqlite to set the resume point while json api doesn't support this yet
|
|
#todo --> submit PR to kodi team to get this added to the jsonrpc api
|
|
|
|
utils.logMsg("MB3 Sync","setting resume point in kodi db..." + fileType + ": " + str(id))
|
|
xbmc.sleep(sleepVal)
|
|
connection = utils.KodiSQL()
|
|
cursor = connection.cursor( )
|
|
|
|
if fileType == "episode":
|
|
cursor.execute("SELECT idFile as fileidid FROM episode WHERE idEpisode = ?",(id,))
|
|
result = cursor.fetchone()
|
|
fileid = result[0]
|
|
if fileType == "movie":
|
|
cursor.execute("SELECT idFile as fileidid FROM movie WHERE idMovie = ?",(id,))
|
|
result = cursor.fetchone()
|
|
fileid = result[0]
|
|
|
|
cursor.execute("delete FROM bookmark WHERE idFile = ?", (fileid,))
|
|
cursor.execute("select coalesce(max(idBookmark),0) as bookmarkId from bookmark")
|
|
bookmarkId = cursor.fetchone()[0]
|
|
bookmarkId = bookmarkId + 1
|
|
bookmarksql="insert into bookmark(idBookmark, idFile, timeInSeconds, totalTimeInSeconds, thumbNailImage, player, playerState, type) values(?, ?, ?, ?, ?, ?, ?, ?)"
|
|
cursor.execute(bookmarksql, (bookmarkId,fileid,resume_seconds,total_seconds,None,"DVDPlayer",None,1))
|
|
connection.commit()
|
|
cursor.close()
|
|
|
|
|
|
def setKodiFilename(self, id, oldFileName, newFileName, fileType):
|
|
#use sqlite to set the filename in DB -- needed to avoid problems with resumepoints etc
|
|
#todo --> submit PR to kodi team to get this added to the jsonrpc api
|
|
#todo --> extend support for musicvideos
|
|
|
|
oldFileName = utils.convertEncoding(oldFileName)
|
|
newFileName = utils.convertEncoding(newFileName)
|
|
|
|
# only perform changes if the path actually differs
|
|
if oldFileName != newFileName:
|
|
|
|
# play from stream is not supported, that has to use the old method of playing through the addon itself
|
|
# TODO --> if you change from stream to local you have to rescan, this can be fixed here ?
|
|
if not newFileName.startswith("http"):
|
|
|
|
xbmc.sleep(sleepVal)
|
|
connection = utils.KodiSQL()
|
|
cursor = connection.cursor( )
|
|
|
|
utils.logMsg("MB3 Sync","setting filename in kodi db..." + fileType + ": " + str(id))
|
|
|
|
if fileType == "tvshow":
|
|
#for tvshows we only store the path in DB
|
|
|
|
cursor.execute("SELECT idPath as pathid FROM tvshowlinkpath WHERE idShow = ?",(id,))
|
|
result = cursor.fetchone()
|
|
if result != None:
|
|
pathid = result[0]
|
|
cursor.execute("UPDATE path SET strPath = ? WHERE idPath = ?", (newFileName,pathid))
|
|
cursor.execute("UPDATE path SET noUpdate = ? WHERE idPath = ?", (1,pathid))
|
|
cursor.execute("UPDATE path SET idParentPath = ? WHERE idPath = ?", (None,pathid))
|
|
else:
|
|
#process movies and episodes
|
|
if "\\" in newFileName:
|
|
filename = newFileName.rsplit("\\",1)[-1]
|
|
path = newFileName.replace(filename,"")
|
|
elif "/" in newFileName:
|
|
filename = newFileName.rsplit("/",1)[-1]
|
|
path = newFileName.replace(filename,"")
|
|
|
|
if fileType == "movie":
|
|
strContent = "movies"
|
|
strScraper = "metadata.local"
|
|
elif fileType == "episode":
|
|
strContent = None
|
|
strScraper = None
|
|
|
|
# we need to store both the path and the filename seperately in the kodi db
|
|
cursor.execute("SELECT idPath as pathid FROM path WHERE strPath = ?",(path,))
|
|
result = cursor.fetchone()
|
|
if result != None:
|
|
pathid = result[0]
|
|
if result == None:
|
|
cursor.execute("select coalesce(max(idPath),0) as pathid from path")
|
|
pathid = cursor.fetchone()[0]
|
|
pathid = pathid + 1
|
|
pathsql="insert into path(idPath, strPath, strContent, strScraper, noUpdate) values(?, ?, ?, ?, ?)"
|
|
cursor.execute(pathsql, (pathid,path,strContent,strScraper,1))
|
|
|
|
if fileType == "episode":
|
|
cursor.execute("SELECT idFile as fileid FROM episode WHERE idEpisode = ?",(id,))
|
|
result = cursor.fetchone()
|
|
fileid = result[0]
|
|
if fileType == "movie":
|
|
cursor.execute("SELECT idFile as fileid FROM movie WHERE idMovie = ?",(id,))
|
|
result = cursor.fetchone()
|
|
fileid = result[0]
|
|
|
|
cursor.execute("UPDATE files SET strFilename = ? WHERE idFile = ?", (filename,fileid))
|
|
cursor.execute("UPDATE files SET idPath = ? WHERE idFile = ?", (pathid,fileid))
|
|
try:
|
|
connection.commit()
|
|
finally:
|
|
cursor.close()
|
|
|
|
#rename the old strmfile to prevent Kodi from scanning it again
|
|
if oldFileName.endswith(".strm"):
|
|
if xbmcvfs.exists(oldFileName):
|
|
oldFileName_renamed = oldFileName.replace(".strm",".emby")
|
|
xbmcvfs.rename(oldFileName,oldFileName_renamed)
|
|
|
|
|
|
def AddActorsToMedia(self, KodiItem, people, mediatype):
|
|
#use sqlite to set add the actors while json api doesn't support this yet
|
|
#todo --> submit PR to kodi team to get this added to the jsonrpc api
|
|
|
|
downloadUtils = DownloadUtils()
|
|
if mediatype == "movie":
|
|
id = KodiItem["movieid"]
|
|
if mediatype == "tvshow":
|
|
id = KodiItem["tvshowid"]
|
|
if mediatype == "episode":
|
|
id = KodiItem["episodeid"]
|
|
|
|
currentcast = list()
|
|
if KodiItem["cast"] != None:
|
|
for cast in KodiItem["cast"]:
|
|
currentcast.append(cast["name"])
|
|
|
|
needsUpdate = False
|
|
if(people != None):
|
|
for person in people:
|
|
if(person.get("Type") == "Actor"):
|
|
if person.get("Name") not in currentcast:
|
|
needsUpdate = True
|
|
break
|
|
|
|
if(needsUpdate == False):
|
|
return False
|
|
|
|
utils.logMsg("AddActorsToMedia", "List needs updating")
|
|
|
|
xbmc.sleep(sleepVal)
|
|
connection = utils.KodiSQL()
|
|
cursor = connection.cursor()
|
|
|
|
if(people != None):
|
|
for person in people:
|
|
if(person.get("Type") == "Actor"):
|
|
if person.get("Name") not in currentcast:
|
|
utils.logMsg("AddActorsToMedia", "Processing : " + person.get("Name"))
|
|
Name = person.get("Name")
|
|
Role = person.get("Role")
|
|
actorid = None
|
|
Thumb = downloadUtils.imageUrl(person.get("Id"), "Primary", 0, 400, 400)
|
|
cursor.execute("SELECT idActor as actorid FROM actors WHERE strActor = ?",(Name,))
|
|
result = cursor.fetchone()
|
|
if result != None:
|
|
actorid = result[0]
|
|
if actorid == None:
|
|
cursor.execute("select coalesce(max(idActor),0) as actorid from actors")
|
|
actorid = cursor.fetchone()[0]
|
|
actorid = actorid + 1
|
|
peoplesql="insert into actors(idActor, strActor, strThumb) values(?, ?, ?)"
|
|
cursor.execute(peoplesql, (actorid,Name,Thumb))
|
|
|
|
if mediatype == "movie":
|
|
peoplesql="INSERT OR REPLACE into actorlinkmovie(idActor, idMovie, strRole, iOrder) values(?, ?, ?, ?)"
|
|
if mediatype == "tvshow":
|
|
peoplesql="INSERT OR REPLACE into actorlinktvshow(idActor, idShow, strRole, iOrder) values(?, ?, ?, ?)"
|
|
if mediatype == "episode":
|
|
peoplesql="INSERT OR REPLACE into actorlinkepisode(idActor, idEpisode, strRole, iOrder) values(?, ?, ?, ?)"
|
|
cursor.execute(peoplesql, (actorid,id,Role,None))
|
|
|
|
connection.commit()
|
|
cursor.close()
|
|
|
|
return True
|
|
|
|
def addBoxsetToKodiLibrary(self, boxset):
|
|
#use sqlite to set add the set
|
|
connection = utils.KodiSQL()
|
|
cursor = connection.cursor()
|
|
|
|
strSet = boxset["Name"]
|
|
# check if exists
|
|
cursor.execute("SELECT idSet FROM sets WHERE strSet = ?", (strSet,))
|
|
result = cursor.fetchone()
|
|
setid = None
|
|
if result != None:
|
|
setid = result[0]
|
|
currentsetartsql = "SELECT type, url FROM art where media_type = ? and media_id = ? and url != ''"
|
|
cursor.execute(currentsetartsql, ("set", setid))
|
|
existing_type_map = {}
|
|
rows = cursor.fetchall()
|
|
for row in rows:
|
|
existing_type_map[row[0] ] = row[1]
|
|
|
|
artwork = {}
|
|
artwork["poster"] = API().getArtwork(boxset, "Primary")
|
|
artwork["banner"] = API().getArtwork(boxset, "Banner")
|
|
artwork["clearlogo"] = API().getArtwork(boxset, "Logo")
|
|
artwork["clearart"] = API().getArtwork(boxset, "Art")
|
|
artwork["landscape"] = API().getArtwork(boxset, "Thumb")
|
|
artwork["discart"] = API().getArtwork(boxset, "Disc")
|
|
artwork["fanart"] = API().getArtwork(boxset, "Backdrop")
|
|
|
|
art_types = ['poster','fanart','landscape','clearlogo','clearart','banner','discart']
|
|
for update_type in art_types:
|
|
if ( update_type in existing_type_map ):
|
|
if ( existing_type_map[update_type] != artwork[update_type] ) and artwork[update_type] != '':
|
|
setupdateartsql = "UPDATE art SET url = ? where media_type = ? and media_id = ? and type = ?"
|
|
cursor.execute(setupdateartsql,(artwork[update_type],"set",setid,update_type))
|
|
elif artwork[update_type] != '':
|
|
setartsql = "INSERT INTO art(media_id, media_type, type, url) VALUES(?,?,?,?)"
|
|
cursor.execute(setartsql,(setid,"set",update_type,artwork[update_type]))
|
|
|
|
if setid == None:
|
|
# insert not exists
|
|
setssql="INSERT INTO sets (idSet, strSet) values(?, ?)"
|
|
cursor.execute(setssql, (None,strSet))
|
|
#if OK:
|
|
result = cursor.fetchone()
|
|
if result != None:
|
|
setid = result[0]
|
|
connection.commit()
|
|
cursor.close()
|
|
|
|
return True
|
|
|
|
def updateBoxsetToKodiLibrary(self, boxsetmovie, boxset):
|
|
strSet = boxset["Name"]
|
|
kodiMovie = ReadKodiDB().getKodiMovie(boxsetmovie["Id"])
|
|
if kodiMovie != None:
|
|
WriteKodiDB().updateProperty(kodiMovie,"set",strSet,"movie",True) |