jellyfin-kodi/service.py

259 lines
10 KiB
Python
Raw Normal View History

# -*- coding: utf-8 -*-
import os
import sys
import time
from datetime import datetime
2015-03-13 21:24:59 +00:00
import xbmcaddon
import xbmc
import xbmcgui
import xbmcvfs
2015-03-13 21:24:59 +00:00
addon_ = xbmcaddon.Addon(id='plugin.video.emby')
addon_path = addon_.getAddonInfo('path').decode('utf-8')
base_resource_path = xbmc.translatePath(os.path.join(addon_path, 'resources', 'lib')).decode('utf-8')
sys.path.append(base_resource_path)
2015-03-13 21:24:59 +00:00
import KodiMonitor
import Utils as utils
2015-04-03 10:13:01 +00:00
from ClientInformation import ClientInformation
from ConnectionManager import ConnectionManager
2015-04-03 10:13:01 +00:00
from UserClient import UserClient
from Player import Player
from WebSocketClient import WebSocketThread
from LibrarySync import LibrarySync
2015-03-13 21:24:59 +00:00
2015-04-06 17:17:32 +00:00
2015-03-13 21:24:59 +00:00
class Service():
2015-04-03 10:13:01 +00:00
2015-05-17 12:11:50 +00:00
KodiMonitor = KodiMonitor.Kodi_Monitor()
clientInfo = ClientInformation()
2015-04-06 17:17:32 +00:00
addonName = clientInfo.getAddonName()
logLevel = UserClient().getLogLevel()
2015-05-03 05:27:43 +00:00
WINDOW = xbmcgui.Window(10000)
newWebSocketThread = None
newUserClient = None
newLibraryThread = None
2015-05-03 05:27:43 +00:00
warn_auth = True
welcome_msg = True
2015-05-03 05:27:43 +00:00
server_online = True
def __init__(self, *args):
2015-04-26 20:41:39 +00:00
addonName = self.addonName
WINDOW = self.WINDOW
WINDOW.setProperty('getLogLevel', str(self.logLevel))
2015-03-13 21:24:59 +00:00
# Initial logging
2015-04-06 17:17:32 +00:00
self.logMsg("Starting Monitor", 0)
self.logMsg("======== START %s ========" % addonName, 0)
2015-05-03 05:27:43 +00:00
self.logMsg("Platform: %s" % (self.clientInfo.getPlatform()), 0)
self.logMsg("KODI Version: %s" % xbmc.getInfoLabel('System.BuildVersion'), 0)
self.logMsg("%s Version: %s" % (addonName, self.clientInfo.getVersion()), 0)
2015-06-16 01:23:19 +00:00
self.logMsg("Log Level: %s" % self.logLevel, 1)
# Reset window props for profile switch
WINDOW.clearProperty('Server_online')
WINDOW.clearProperty('Server_status')
WINDOW.clearProperty('startup')
WINDOW.clearProperty('OnWakeSync')
embyProperty = 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:
WINDOW.clearProperty('Emby.nodes.%s.%s' % (str(i), prop))
2015-04-06 17:17:32 +00:00
def logMsg(self, msg, lvl=1):
2015-05-03 05:27:43 +00:00
className = self.__class__.__name__
utils.logMsg("%s %s" % (self.addonName, className), msg, int(lvl))
2015-03-13 21:24:59 +00:00
def ServiceEntryPoint(self):
2015-05-03 05:27:43 +00:00
WINDOW = self.WINDOW
2015-06-16 01:23:19 +00:00
addon = xbmcaddon.Addon()
# Server auto-detect
ConnectionManager().checkServer()
# Initialize important threads
2015-04-03 10:13:01 +00:00
user = UserClient()
player = Player()
ws = WebSocketThread()
library = LibrarySync()
# Sync and progress report
lastProgressUpdate = datetime.today()
while not self.KodiMonitor.abortRequested():
2015-05-03 05:27:43 +00:00
# Refresh with the latest addon settings
addon = xbmcaddon.Addon()
# Before proceeding, need to make sure:
# 1. Server is online
# 2. User is set
# 3. User has access to the server
2015-05-03 05:27:43 +00:00
if WINDOW.getProperty('Server_online') == "true":
# Emby server is online
# Verify if user is set and has access to the server
if (user.currUser is not None) and user.HasAccess:
# If an item is playing
if xbmc.Player().isPlaying():
try:
# Update and report progress
playTime = xbmc.Player().getTime()
totalTime = xbmc.Player().getTotalTime()
currentFile = xbmc.Player().getPlayingFile()
# Update positionticks
if player.played_information.get(currentFile) is not None:
player.played_information[currentFile]["currentPosition"] = playTime
td = datetime.today() - lastProgressUpdate
secDiff = td.seconds
# Report progress to Emby server
if (secDiff > 3):
player.reportPlayback()
lastProgressUpdate = datetime.today()
2015-05-16 08:00:46 +00:00
elif WINDOW.getProperty('commandUpdate') == "true":
# Received a remote control command that
# requires updating immediately
WINDOW.clearProperty('commandUpdate')
player.reportPlayback()
2015-05-16 08:00:46 +00:00
lastProgressUpdate = datetime.today()
except Exception as e:
self.logMsg("Exception in Playback Monitor Service: %s" % e, 1)
pass
else:
# Start up events
self.warn_auth = True
if addon.getSetting('supressConnectMsg') == "false":
if self.welcome_msg:
# Reset authentication warnings
self.welcome_msg = False
xbmcgui.Dialog().notification("Emby server", "Welcome %s!" % user.currUser, icon="special://home/addons/plugin.video.emby/icon.png", time=2000, sound=False)
# Start the Websocket Client
if (self.newWebSocketThread is None):
self.newWebSocketThread = "Started"
ws.start()
# Start the Library Sync Thread
if (self.newLibraryThread is None):
self.newLibraryThread = "Started"
library.start()
else:
if (user.currUser is None) and self.warn_auth:
# Alert user is not authenticated and suppress future warning
self.warn_auth = False
self.logMsg("Not authenticated yet.", 1)
# User access is restricted.
# Keep verifying until access is granted
# unless server goes offline or Kodi is shut down.
while user.HasAccess == False:
# Verify access with an API call
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:
# Wait until Emby server is online
# or Kodi is shut down.
2015-05-03 05:27:43 +00:00
while not self.KodiMonitor.abortRequested():
2015-05-03 05:27:43 +00:00
if user.getServer() == "":
# No server info set in add-on settings
2015-05-03 05:27:43 +00:00
pass
2015-05-06 22:58:31 +00:00
elif user.getPublicUsers() == False:
# Server is offline.
# Alert the user and suppress future warning
2015-05-03 05:27:43 +00:00
if self.server_online:
self.logMsg("Server is offline.", 1)
WINDOW.setProperty('Server_online', "false")
xbmcgui.Dialog().notification("Error connecting", "%s Server is unreachable." % self.addonName, icon="special://home/addons/plugin.video.emby/icon.png", sound=False)
2015-05-03 05:27:43 +00:00
self.server_online = False
2015-03-13 21:24:59 +00:00
else:
2015-05-03 05:27:43 +00:00
# Server is online
if not self.server_online:
# Server was offline when Kodi started.
2015-05-03 05:27:43 +00:00
# Wait for server to be fully established.
if self.KodiMonitor.waitForAbort(5):
# Abort was requested while waiting.
break
# Alert the user that server is online.
xbmcgui.Dialog().notification("Emby server", "Welcome %s!" % user.currUser, icon="special://home/addons/plugin.video.emby/icon.png", time=2000, sound=False)
2015-05-03 05:27:43 +00:00
self.server_online = True
self.logMsg("Server is online and ready.", 1)
WINDOW.setProperty('Server_online', "true")
2015-05-03 05:27:43 +00:00
# Start the User client
if self.newUserClient is None:
2015-05-03 05:27:43 +00:00
self.newUserClient = "Started"
user.start()
break
if self.KodiMonitor.waitForAbort(1):
# Abort was requested while waiting.
break
if self.KodiMonitor.waitForAbort(1):
# Abort was requested while waiting. We should exit
break
2015-05-17 12:11:50 +00:00
# If user reset library database.
if WINDOW.getProperty('SyncInstallRunDone') == "false":
addon.setSetting('SyncInstallRunDone', "false")
# If user delete Emby settings
if WINDOW.getProperty('deletesettings') == "true":
addondir = xbmc.translatePath(addon.getAddonInfo('profile')).decode('utf-8')
dataPath = "%ssettings.xml" % addondir
xbmcvfs.delete(dataPath)
self.logMsg("Deleting: settings.xml", 1)
if (self.newWebSocketThread is not None):
2015-04-03 10:13:01 +00:00
ws.stopClient()
if (self.newUserClient is not None):
2015-05-03 05:27:43 +00:00
user.stopClient()
self.logMsg("======== STOP %s ========" % self.addonName, 0)
2015-05-17 12:11:50 +00:00
#start the service
Service().ServiceEntryPoint()