PlexKodiConnect/service.py

226 lines
9.9 KiB
Python
Raw Normal View History

2015-03-14 08:24:59 +11:00
import xbmcaddon
import xbmc
import xbmcgui
import os
import threading
import json
from datetime import datetime
import time
2015-03-14 08:24:59 +11:00
2015-03-26 04:37:21 +11:00
cwd = xbmcaddon.Addon(id='plugin.video.emby').getAddonInfo('path')
2015-03-14 08:24:59 +11:00
BASE_RESOURCE_PATH = xbmc.translatePath( os.path.join( cwd, 'resources', 'lib' ) )
sys.path.append(BASE_RESOURCE_PATH)
import KodiMonitor
import Utils as utils
from LibrarySync import LibrarySync
from Player import Player
from DownloadUtils import DownloadUtils
from ConnectionManager import ConnectionManager
2015-04-03 21:13:01 +11:00
from ClientInformation import ClientInformation
from WebSocketClient import WebSocketThread
2015-04-03 21:13:01 +11:00
from UserClient import UserClient
2015-05-02 02:32:13 +10:00
from PlaybackUtils import PlaybackUtils
librarySync = LibrarySync()
2015-03-14 08:24:59 +11:00
2015-04-07 03:17:32 +10:00
2015-03-14 08:24:59 +11:00
class Service():
2015-04-07 03:17:32 +10:00
newWebSocketThread = None
2015-04-03 21:13:01 +11:00
newUserClient = None
clientInfo = ClientInformation()
2015-04-07 03:17:32 +10:00
addonName = clientInfo.getAddonName()
2015-05-03 15:27:43 +10:00
WINDOW = xbmcgui.Window(10000)
warn_auth = True
server_online = True
2015-03-14 08:24:59 +11:00
def __init__(self, *args ):
self.KodiMonitor = KodiMonitor.Kodi_Monitor()
2015-04-27 06:41:39 +10:00
addonName = self.addonName
2015-03-14 08:24:59 +11:00
2015-04-07 03:17:32 +10:00
self.logMsg("Starting Monitor", 0)
self.logMsg("======== START %s ========" % addonName, 0)
self.logMsg("KODI Version: %s" % xbmc.getInfoLabel("System.BuildVersion"), 0)
self.logMsg("%s Version: %s" % (addonName, self.clientInfo.getVersion()), 0)
2015-05-03 15:27:43 +10:00
self.logMsg("Platform: %s" % (self.clientInfo.getPlatform()), 0)
#reset all window props on startup for user profile switches
self.WINDOW.clearProperty("startup")
embyProperty = self.WINDOW.getProperty("Emby.nodes.total")
propNames = ["index","path","title","content","inprogress.content","inprogress.title","inprogress.content","inprogress.path","nextepisodes.title","nextepisodes.content","nextepisodes.path","unwatched.title","unwatched.content","unwatched.path","recent.title","recent.content","recent.path","recentepisodes.title","recentepisodes.content","recentepisodes.path","inprogressepisodes.title","inprogressepisodes.content","inprogressepisodes.path"]
if embyProperty:
totalNodes = int(embyProperty)
for i in range(totalNodes):
for prop in propNames:
self.WINDOW.clearProperty("Emby.nodes.%s.%s" %(str(i),prop))
2015-04-07 03:17:32 +10:00
def logMsg(self, msg, lvl=1):
2015-05-03 15:27:43 +10:00
className = self.__class__.__name__
utils.logMsg("%s %s" % (self.addonName, className), str(msg), int(lvl))
2015-03-14 08:24:59 +11:00
def ServiceEntryPoint(self):
2015-05-03 15:27:43 +10:00
WINDOW = self.WINDOW
WINDOW.setProperty("Server_online", "")
2015-05-12 17:46:35 +10:00
self.WINDOW.setProperty("Server_status", "")
WINDOW.setProperty("Emby_Service_Timestamp", str(int(time.time())))
ConnectionManager().checkServer()
lastProgressUpdate = datetime.today()
startupComplete = False
2015-03-14 08:24:59 +11:00
2015-04-03 21:13:01 +11:00
user = UserClient()
player = Player()
ws = WebSocketThread()
lastFile = None
while not self.KodiMonitor.abortRequested():
WINDOW.setProperty("Emby_Service_Timestamp", str(int(time.time())))
if self.KodiMonitor.waitForAbort(1):
# Abort was requested while waiting. We should exit
break
2015-05-03 15:27:43 +10:00
if WINDOW.getProperty('Server_online') == "true":
# Server is online
if (user.currUser != None) and (user.HasAccess == True):
self.warn_auth = True
# Correctly launch the websocket, if user manually launches the add-on
if (self.newWebSocketThread == None):
self.newWebSocketThread = "Started"
ws.start()
if xbmc.Player().isPlaying():
WINDOW.setProperty("Emby_Service_Timestamp", str(int(time.time())))
try:
playTime = xbmc.Player().getTime()
totalTime = xbmc.Player().getTotalTime()
currentFile = xbmc.Player().getPlayingFile()
if(player.played_information.get(currentFile) != None):
player.played_information[currentFile]["currentPosition"] = playTime
# send update
td = datetime.today() - lastProgressUpdate
secDiff = td.seconds
if(secDiff > 3):
try:
player.reportPlayback()
except Exception, msg:
self.logMsg("Exception reporting progress: %s" % msg)
pass
lastProgressUpdate = datetime.today()
2015-05-16 18:00:46 +10:00
elif WINDOW.getProperty('commandUpdate') == "true":
try:
WINDOW.clearProperty('commandUpdate')
player.reportPlayback()
except: pass
lastProgressUpdate = datetime.today()
# only try autoplay when there's 20 seconds or less remaining and only once!
addonSettings = xbmcaddon.Addon(id='plugin.video.emby')
# if its an episode see if autoplay is enabled
if addonSettings.getSetting("autoPlaySeason")=="true":
notificationtime = addonSettings.getSetting("autoPlaySeasonTime")
if (totalTime - playTime <= int(notificationtime) and (lastFile==None or lastFile!=currentFile)):
lastFile = currentFile
player.autoPlayPlayback()
except Exception, e:
self.logMsg("Exception in Playback Monitor Service: %s" % e)
pass
else:
WINDOW.setProperty("Emby_Service_Timestamp", str(int(time.time())))
2015-05-03 15:27:43 +10:00
#full sync
if (startupComplete == False):
self.logMsg("Doing_Db_Sync: syncDatabase (Started)")
libSync = librarySync.FullLibrarySync()
self.logMsg("Doing_Db_Sync: syncDatabase (Finished) " + str(libSync))
if (libSync):
startupComplete = True
else:
if self.KodiMonitor.waitForAbort(1):
# Abort was requested while waiting. We should exit
break
else:
if self.warn_auth:
self.logMsg("Not authenticated yet.", 1)
self.warn_auth = False
while user.HasAccess == False:
WINDOW.setProperty("Emby_Service_Timestamp", str(int(time.time())))
user.hasAccess()
if WINDOW.getProperty('Server_online') != "true":
# Server went offline
break
if self.KodiMonitor.waitForAbort(5):
# Abort was requested while waiting. We should exit
break
else:
2015-05-03 15:27:43 +10:00
# Wait until server becomes online or shut down is requested
while not self.KodiMonitor.abortRequested():
WINDOW.setProperty("Emby_Service_Timestamp", str(int(time.time())))
2015-05-03 15:27:43 +10:00
if user.getServer() == "":
pass
2015-05-07 08:58:31 +10:00
elif user.getPublicUsers() == False:
2015-05-03 15:27:43 +10:00
# Server is not online, suppress future warning
if self.server_online:
WINDOW.setProperty("Server_online", "false")
self.logMsg("Server is offline.", 1)
xbmcgui.Dialog().notification("Error connecting", "%s Server is unreachable." % self.addonName)
self.server_online = False
2015-03-14 08:24:59 +11:00
else:
2015-05-03 15:27:43 +10:00
# Server is online
if not self.server_online:
# Server was not online when Kodi started.
# Wait for server to be fully established.
if self.KodiMonitor.waitForAbort(5):
# Abort was requested while waiting.
break
self.server_online = True
self.logMsg("Server is online and ready.", 1)
xbmcgui.Dialog().notification("Connection successful", "%s Server is online." % self.addonName, time=2000)
WINDOW.setProperty("Server_online", "true")
# Server is online, proceed.
if (self.newUserClient == None):
self.newUserClient = "Started"
user.start()
break
if self.KodiMonitor.waitForAbort(1):
# Abort was requested while waiting.
break
# If user reset library database.
if WINDOW.getProperty("SyncInstallRunDone") == "false":
addon = xbmcaddon.Addon('plugin.video.emby')
addon.setSetting("SyncInstallRunDone", "false")
if (self.newWebSocketThread != None):
2015-04-03 21:13:01 +11:00
ws.stopClient()
if (self.newUserClient != None):
2015-05-03 15:27:43 +10:00
user.stopClient()
self.logMsg("======== STOP %s ========" % self.addonName, 0)
2015-03-14 08:24:59 +11:00
#start the service
Service().ServiceEntryPoint()