PlexKodiConnect/resources/lib/kodimonitor.py

269 lines
11 KiB
Python
Raw Normal View History

2015-12-25 07:07:00 +11:00
# -*- coding: utf-8 -*-
2016-02-20 06:03:06 +11:00
###############################################################################
2015-12-25 07:07:00 +11:00
2016-08-31 00:57:47 +10:00
import logging
2015-12-25 07:07:00 +11:00
import json
import xbmc
import xbmcgui
import downloadutils
import embydb_functions as embydb
2016-03-23 02:17:06 +11:00
import kodidb_functions as kodidb
2015-12-25 07:07:00 +11:00
import playbackutils as pbutils
2016-08-31 00:57:47 +10:00
from utils import window, settings, CatchExceptions, tryDecode, tryEncode
2016-03-12 00:42:14 +11:00
from PlexFunctions import scrobble
2016-01-13 00:14:49 +11:00
2016-02-20 06:03:06 +11:00
###############################################################################
2015-12-25 07:07:00 +11:00
2016-08-31 00:57:47 +10:00
log = logging.getLogger("PLEX."+__name__)
###############################################################################
2015-12-25 07:07:00 +11:00
class KodiMonitor(xbmc.Monitor):
2016-08-07 23:33:36 +10:00
def __init__(self):
2015-12-25 07:07:00 +11:00
self.doUtils = downloadutils.DownloadUtils().downloadUrl
2016-08-07 23:33:36 +10:00
self.xbmcplayer = xbmc.Player()
2016-07-22 23:54:03 +10:00
xbmc.Monitor.__init__(self)
2016-08-31 00:57:47 +10:00
log.info("Kodi monitor started.")
2015-12-25 07:07:00 +11:00
def onScanStarted(self, library):
2016-08-31 00:57:47 +10:00
log.debug("Kodi library scan %s running." % library)
2015-12-25 07:07:00 +11:00
if library == "video":
2016-08-31 00:57:47 +10:00
window('plex_kodiScan', value="true")
2016-02-20 06:03:06 +11:00
2015-12-25 07:07:00 +11:00
def onScanFinished(self, library):
2016-08-31 00:57:47 +10:00
log.debug("Kodi library scan %s finished." % library)
2015-12-25 07:07:00 +11:00
if library == "video":
2016-08-31 00:57:47 +10:00
window('plex_kodiScan', clear=True)
2015-12-25 07:07:00 +11:00
def onSettingsChanged(self):
2016-10-23 02:15:10 +11:00
"""
Monitor the PKC settings for changes made by the user
"""
2016-08-31 00:57:47 +10:00
currentLog = settings('logLevel')
if window('plex_logLevel') != currentLog:
# The log level changed, set new prop
2016-08-31 00:57:47 +10:00
log.debug("New log level: %s" % currentLog)
window('plex_logLevel', value=currentLog)
2016-10-23 02:15:10 +11:00
current_context = "true" if settings('enableContext') == "true" else ""
if window('plex_context') != current_context:
log.info("New context setting: %s", current_context)
window('plex_context', value=current_context)
2016-08-31 00:57:47 +10:00
@CatchExceptions(warnuser=False)
2015-12-25 07:07:00 +11:00
def onNotification(self, sender, method, data):
2015-12-25 07:07:00 +11:00
if data:
data = json.loads(data, 'utf-8')
2016-08-31 00:57:47 +10:00
log.debug("Method: %s Data: %s" % (method, data))
2015-12-25 07:07:00 +11:00
if method == "Player.OnPlay":
self.PlayBackStart(data)
2015-12-25 07:07:00 +11:00
2016-04-08 21:51:29 +10:00
elif method == "Player.OnStop":
# Should refresh our video nodes, e.g. on deck
# xbmc.executebuiltin('ReloadSkin()')
pass
2016-04-08 21:51:29 +10:00
2015-12-25 07:07:00 +11:00
elif method == "VideoLibrary.OnUpdate":
# Manually marking as watched/unwatched
playcount = data.get('playcount')
item = data.get('item')
try:
kodiid = item['id']
item_type = item['type']
2015-12-25 07:07:00 +11:00
except (KeyError, TypeError):
2016-08-31 00:57:47 +10:00
log.info("Item is invalid for playstate update.")
2015-12-25 07:07:00 +11:00
else:
# Send notification to the server.
2016-03-16 22:49:55 +11:00
with embydb.GetEmbyDB() as emby_db:
emby_dbitem = emby_db.getItem_byKodiId(kodiid, item_type)
2015-12-25 07:07:00 +11:00
try:
itemid = emby_dbitem[0]
except TypeError:
2016-08-31 00:57:47 +10:00
log.error("Could not find itemid in emby database for a "
"video library update")
2015-12-25 07:07:00 +11:00
else:
# Stop from manually marking as watched unwatched, with actual playback.
2016-08-31 00:57:47 +10:00
if window('emby_skipWatched%s' % itemid) == "true":
2015-12-25 07:07:00 +11:00
# property is set in player.py
2016-08-31 00:57:47 +10:00
window('emby_skipWatched%s' % itemid, clear=True)
2015-12-25 07:07:00 +11:00
else:
# notify the server
if playcount != 0:
2016-03-12 00:42:14 +11:00
scrobble(itemid, 'watched')
2015-12-25 07:07:00 +11:00
else:
2016-03-12 00:42:14 +11:00
scrobble(itemid, 'unwatched')
2015-12-25 07:07:00 +11:00
elif method == "VideoLibrary.OnRemove":
# Removed function, because with plugin paths + clean library, it will wipe
# entire library if user has permissions. Instead, use the emby context menu available
# in Isengard and higher version
pass
'''try:
2015-12-25 07:07:00 +11:00
kodiid = data['id']
type = data['type']
except (KeyError, TypeError):
2016-09-05 00:57:06 +10:00
log.info("Item is invalid for emby deletion.")
2015-12-25 07:07:00 +11:00
else:
# Send the delete action to the server.
embyconn = utils.kodiSQL('emby')
embycursor = embyconn.cursor()
emby_db = embydb.Embydb_Functions(embycursor)
emby_dbitem = emby_db.getItem_byKodiId(kodiid, type)
try:
itemid = emby_dbitem[0]
except TypeError:
2016-09-05 00:57:06 +10:00
log.info("Could not find itemid in emby database.")
else:
2016-08-31 00:57:47 +10:00
if settings('skipContextMenu') != "true":
resp = xbmcgui.Dialog().yesno(
heading="Confirm delete",
line1="Delete file on Emby Server?")
if not resp:
2016-09-05 00:57:06 +10:00
log.info("User skipped deletion.")
embycursor.close()
return
url = "{server}/emby/Items/%s?format=json" % itemid
2016-09-05 00:57:06 +10:00
log.info("Deleting request: %s" % itemid)
doUtils.downloadUrl(url, action_type="DELETE")
finally:
embycursor.close()'''
2015-12-25 07:07:00 +11:00
2016-08-31 00:57:47 +10:00
elif method == "System.OnSleep":
# Connection is going to sleep
log.info("Marking the server as offline. SystemOnSleep activated.")
window('plex_online', value="sleep")
2015-12-25 07:07:00 +11:00
elif method == "System.OnWake":
# Allow network to wake up
xbmc.sleep(10000)
2016-08-31 00:57:47 +10:00
window('plex_onWake', value="true")
window('plex_online', value="false")
2015-12-25 07:07:00 +11:00
elif method == "GUI.OnScreensaverDeactivated":
2016-08-31 00:57:47 +10:00
if settings('dbSyncScreensaver') == "true":
xbmc.sleep(5000)
2016-08-31 00:57:47 +10:00
window('plex_runLibScan', value="full")
2015-12-25 07:07:00 +11:00
elif method == "Playlist.OnClear":
pass
def PlayBackStart(self, data):
"""
Called whenever a playback is started
"""
# Get currently playing file - can take a while. Will be utf-8!
try:
currentFile = self.xbmcplayer.getPlayingFile()
except:
currentFile = None
count = 0
while currentFile is None:
xbmc.sleep(100)
try:
currentFile = self.xbmcplayer.getPlayingFile()
except:
pass
if count == 50:
2016-08-31 00:57:47 +10:00
log.info("No current File, cancel OnPlayBackStart...")
return
else:
count += 1
# Just to be on the safe side
2016-08-31 00:57:47 +10:00
currentFile = tryDecode(currentFile)
log.debug("Currently playing file is: %s" % currentFile)
# Get the type of media we're playing
try:
typus = data['item']['type']
except (TypeError, KeyError):
2016-08-31 00:57:47 +10:00
log.info("Item is invalid for PMS playstate update.")
return
2016-08-31 00:57:47 +10:00
log.debug("Playing itemtype is (or appears to be): %s" % typus)
# Try to get a Kodi ID
# If PKC was used - native paths, not direct paths
2016-08-31 00:57:47 +10:00
plexid = window('emby_%s.itemid' % tryEncode(currentFile))
# Get rid of the '' if the window property was not set
plexid = None if not plexid else plexid
kodiid = None
if plexid is None:
2016-08-31 00:57:47 +10:00
log.debug('Did not get Plex id from window properties')
try:
kodiid = data['item']['id']
except (TypeError, KeyError):
2016-08-31 00:57:47 +10:00
log.debug('Did not get a Kodi id from Kodi, darn')
# For direct paths, if we're not streaming something
# When using Widgets, Kodi doesn't tell us shit so we need this hack
if (kodiid is None and plexid is None and typus != 'song'
and not currentFile.startswith('http')):
try:
filename = currentFile.rsplit('/', 1)[1]
path = currentFile.rsplit('/', 1)[0] + '/'
except IndexError:
filename = currentFile.rsplit('\\', 1)[1]
path = currentFile.rsplit('\\', 1)[0] + '\\'
2016-08-31 00:57:47 +10:00
log.debug('Trying to figure out playing item from filename: %s '
'and path: %s' % (filename, path))
with kodidb.GetKodiDB('video') as kodi_db:
try:
kodiid, typus = kodi_db.getIdFromFilename(filename, path)
except TypeError:
2016-08-31 00:57:47 +10:00
log.info('Abort playback report, could not id kodi item')
return
if plexid is None:
# Get Plex' item id
with embydb.GetEmbyDB() as emby_db:
emby_dbitem = emby_db.getItem_byKodiId(kodiid, typus)
try:
plexid = emby_dbitem[0]
except TypeError:
2016-08-31 00:57:47 +10:00
log.info("No Plex id returned for kodiid %s. Aborting playback"
" report" % kodiid)
return
2016-08-31 00:57:47 +10:00
log.debug("Found Plex id %s for Kodi id %s for type %s"
% (plexid, kodiid, typus))
# Set some stuff if Kodi initiated playback
2016-08-31 00:57:47 +10:00
if ((settings('useDirectPaths') == "1" and not typus == "song")
or
2016-08-31 00:57:47 +10:00
(typus == "song" and settings('enableMusic') == "true")):
if self.StartDirectPath(plexid,
typus,
2016-08-31 00:57:47 +10:00
tryEncode(currentFile)) is False:
log.error('Could not initiate monitoring; aborting')
return
# Save currentFile for cleanup later and to be able to access refs
window('plex_lastPlayedFiled', value=currentFile)
2016-09-18 04:48:37 +10:00
window('plex_currently_playing_itemid', value=plexid)
2016-08-31 00:57:47 +10:00
window("emby_%s.itemid" % tryEncode(currentFile), value=plexid)
log.info('Finish playback startup')
def StartDirectPath(self, plexid, type, currentFile):
"""
Set some additional stuff if playback was initiated by Kodi, not PKC
"""
result = self.doUtils('{server}/library/metadata/%s' % plexid)
try:
result[0].attrib
except:
2016-08-31 00:57:47 +10:00
log.error('Did not receive a valid XML for plexid %s.' % plexid)
return False
# Setup stuff, because playback was started by Kodi, not PKC
pbutils.PlaybackUtils(result[0]).setProperties(
currentFile, xbmcgui.ListItem())
2016-08-31 00:57:47 +10:00
if type == "song" and settings('streamMusic') == "true":
window('emby_%s.playmethod' % currentFile, value="DirectStream")
else:
2016-08-31 00:57:47 +10:00
window('emby_%s.playmethod' % currentFile, value="DirectPlay")
log.debug('Window properties set for direct paths!')