# -*- coding: utf-8 -*- ################################################################################################# import logging import os import sys import time import _strptime # Workaround for threads using datetime: _striptime is locked from datetime import datetime import xbmc import xbmcaddon import xbmcgui import xbmcvfs ################################################################################################# _addon = xbmcaddon.Addon(id='plugin.video.emby') _addon_path = _addon.getAddonInfo('path').decode('utf-8') _base_resource = xbmc.translatePath(os.path.join(_addon_path, 'resources', 'lib')).decode('utf-8') sys.path.append(_base_resource) ################################################################################################# import userclient import clientinfo import initialsetup import kodimonitor import librarysync import player import videonodes import websocket_client as wsc from utils import window, settings, language as lang ################################################################################################# import loghandler loghandler.config() log = logging.getLogger("EMBY.service") ################################################################################################# class Service(): welcome_msg = True server_online = True warn_auth = True userclient_running = False websocket_running = False library_running = False kodimonitor_running = False def __init__(self): self.clientInfo = clientinfo.ClientInfo() self.addonName = self.clientInfo.getAddonName() logLevel = userclient.UserClient().getLogLevel() self.monitor = xbmc.Monitor() window('emby_logLevel', value=str(logLevel)) window('emby_kodiProfile', value=xbmc.translatePath('special://profile')) # Initial logging log.warn("======== START %s ========" % self.addonName) log.warn("Platform: %s" % (self.clientInfo.getPlatform())) log.warn("KODI Version: %s" % xbmc.getInfoLabel('System.BuildVersion')) log.warn("%s Version: %s" % (self.addonName, self.clientInfo.getVersion())) log.warn("Using plugin paths: %s" % (settings('useDirectPaths') == "0")) log.warn("Log Level: %s" % logLevel) # Reset window props for profile switch properties = [ "emby_online", "emby_serverStatus", "emby_onWake", "emby_syncRunning", "emby_dbCheck", "emby_kodiScan", "emby_shouldStop", "emby_currUser", "emby_dbScan", "emby_sessionId", "emby_initialScan", "emby_customplaylist", "emby_playbackProps" ] for prop in properties: window(prop, clear=True) # Clear video nodes properties videonodes.VideoNodes().clearProperties() # Set the minimum database version window('emby_minDBVersion', value="1.1.63") def ServiceEntryPoint(self): # Important: Threads depending on abortRequest will not trigger # if profile switch happens more than once. monitor = self.monitor kodiProfile = xbmc.translatePath('special://profile') # Server auto-detect initialsetup.InitialSetup().setup() # Initialize important threads user = userclient.UserClient() ws = wsc.WebSocket_Client() library = librarysync.LibrarySync() kplayer = player.Player() # Sync and progress report lastProgressUpdate = datetime.today() while not monitor.abortRequested(): if window('emby_kodiProfile') != kodiProfile: # Profile change happened, terminate this thread and others log.info("Kodi profile was: %s and changed to: %s. Terminating old Emby thread." % (kodiProfile, window('emby_kodiProfile'))) break # Before proceeding, need to make sure: # 1. Server is online # 2. User is set # 3. User has access to the server if window('emby_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 = kplayer.currentFile # Update positionticks if kplayer.played_info.get(currentFile) is not None: kplayer.played_info[currentFile]['currentPosition'] = playtime td = datetime.today() - lastProgressUpdate secDiff = td.seconds # Report progress to Emby server if (secDiff > 3): kplayer.reportPlayback() lastProgressUpdate = datetime.today() elif window('emby_command') == "true": # Received a remote control command that # requires updating immediately window('emby_command', clear=True) kplayer.reportPlayback() lastProgressUpdate = datetime.today() except Exception: log.exception("Exception in Playback Monitor Service") else: # Start up events self.warn_auth = True if settings('connectMsg') == "true" and self.welcome_msg: # Reset authentication warnings self.welcome_msg = False # Get additional users additionalUsers = user.AdditionalUser if additionalUsers: add = ", %s" % ", ".join(additionalUsers) else: add = "" xbmcgui.Dialog().notification( heading=lang(29999), message=("%s %s%s!" % (lang(33000), user.currUser.decode('utf-8'), add.decode('utf-8'))), icon="special://home/addons/plugin.video.emby/icon.png", time=2000, sound=False) # Start monitoring kodi events if not self.kodimonitor_running: self.kodimonitor_running = kodimonitor.KodiMonitor() # Start the Websocket Client if not self.websocket_running: self.websocket_running = True ws.start() # Start the syncing thread if not self.library_running: self.library_running = True 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 log.info("Not authenticated yet.") # 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('emby_online') != "true": # Server went offline break if monitor.waitForAbort(5): # Abort was requested while waiting. We should exit break else: # Wait until Emby server is online # or Kodi is shut down. while not monitor.abortRequested(): if user.getServer() == False: # No server info set in add-on settings pass elif user.getPublicUsers() == False: # Server is offline. # Alert the user and suppress future warning if self.server_online: log.info("Server is offline.") window('emby_online', value="false") xbmcgui.Dialog().notification( heading=lang(33001), message="%s %s" % (self.addonName, lang(33002)), icon="special://home/addons/plugin.video.emby/icon.png", sound=False) self.server_online = False elif window('emby_online') == "sleep": # device going to sleep if self.websocket_running: ws.stopClient() ws = wsc.WebSocket_Client() self.websocket_running = False if self.library_running: library.stopThread() library = librarysync.LibrarySync() self.library_running = False else: # Server is online if not self.server_online: # Server was offline when Kodi started. # Wait for server to be fully established. if monitor.waitForAbort(5): # Abort was requested while waiting. break # Alert the user that server is online. xbmcgui.Dialog().notification( heading=lang(29999), message=lang(33003), icon="special://home/addons/plugin.video.emby/icon.png", time=2000, sound=False) self.server_online = True log.info("Server is online and ready.") window('emby_online', value="true") # Start the userclient thread if not self.userclient_running: self.userclient_running = True user.start() break if monitor.waitForAbort(1): # Abort was requested while waiting. break if monitor.waitForAbort(1): # Abort was requested while waiting. We should exit break ##### Emby thread is terminating. ##### if self.userclient_running: user.stopClient() if self.library_running: library.stopThread() if self.websocket_running: ws.stopClient() log.warn("======== STOP %s ========" % self.addonName) # Delay option delay = int(settings('startupDelay')) log.info("Delaying emby startup by: %s sec..." % delay) if delay and xbmc.Monitor().waitForAbort(delay): # Start the service log.warn("Abort requested while waiting. Emby for kodi not started.") else: Service().ServiceEntryPoint()