mirror of
https://github.com/jellyfin/jellyfin-kodi.git
synced 2024-12-25 10:16:11 +00:00
a39784cb81
Make sure the threads are terminated correctly. This time, verify the profile before anything else.
294 lines
No EOL
12 KiB
Python
294 lines
No EOL
12 KiB
Python
# -*- coding: utf-8 -*-
|
|
|
|
#################################################################################################
|
|
|
|
import os
|
|
import sys
|
|
import time
|
|
from datetime import datetime
|
|
|
|
import xbmcaddon
|
|
import xbmc
|
|
import xbmcgui
|
|
import xbmcvfs
|
|
|
|
#################################################################################################
|
|
|
|
_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)
|
|
|
|
#################################################################################################
|
|
|
|
import KodiMonitor
|
|
import Utils as utils
|
|
from ClientInformation import ClientInformation
|
|
from ConnectionManager import ConnectionManager
|
|
from UserClient import UserClient
|
|
from Player import Player
|
|
from WebSocketClient import WebSocketThread
|
|
from LibrarySync import LibrarySync
|
|
from LibraryMonitor import LibraryMonitor
|
|
|
|
#################################################################################################
|
|
|
|
class Service():
|
|
|
|
KodiMonitor = KodiMonitor.Kodi_Monitor()
|
|
clientInfo = ClientInformation()
|
|
|
|
addonName = clientInfo.getAddonName()
|
|
logLevel = UserClient().getLogLevel()
|
|
WINDOW = xbmcgui.Window(10000)
|
|
|
|
newWebSocketThread = None
|
|
newUserClient = None
|
|
newLibraryThread = None
|
|
warn_auth = True
|
|
welcome_msg = True
|
|
server_online = True
|
|
|
|
def __init__(self, *args):
|
|
|
|
addonName = self.addonName
|
|
clientInfo = self.clientInfo
|
|
logLevel = self.logLevel
|
|
|
|
utils.window('getLogLevel', value=str(logLevel))
|
|
utils.window('kodiProfile_emby', value=xbmc.translatePath("special://profile"))
|
|
|
|
# Initial logging
|
|
self.logMsg("Starting Monitor", 0)
|
|
self.logMsg("======== START %s ========" % addonName, 0)
|
|
self.logMsg("Platform: %s" % (clientInfo.getPlatform()), 0)
|
|
self.logMsg("KODI Version: %s" % xbmc.getInfoLabel('System.BuildVersion'), 0)
|
|
self.logMsg("%s Version: %s" % (addonName, clientInfo.getVersion()), 0)
|
|
self.logMsg("Log Level: %s" % logLevel, 0)
|
|
|
|
# Reset window props for profile switch
|
|
utils.window('Server_online', clear=True)
|
|
utils.window('Server_status', clear=True)
|
|
utils.window('startup', clear=True)
|
|
utils.window('OnWakeSync', clear=True)
|
|
utils.window('minDBVersionCheck', clear=True)
|
|
|
|
# Set min DB version
|
|
utils.window('minDBVersion', value="1.1.40")
|
|
|
|
embyProperty = utils.window('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:
|
|
utils.window('Emby.nodes.%s.%s' % (str(i), prop), clear=True)
|
|
|
|
def logMsg(self, msg, lvl=1):
|
|
|
|
className = self.__class__.__name__
|
|
utils.logMsg("%s %s" % (self.addonName, className), msg, int(lvl))
|
|
|
|
def ServiceEntryPoint(self):
|
|
|
|
kodiProfile = xbmc.translatePath("special://profile")
|
|
|
|
# Server auto-detect
|
|
ConnectionManager().checkServer()
|
|
|
|
# Initialize important threads
|
|
user = UserClient()
|
|
player = Player()
|
|
ws = WebSocketThread()
|
|
library = LibrarySync()
|
|
librarymonitor = LibraryMonitor()
|
|
xbmc.log("START LIBRARY MONITOR")
|
|
librarymonitor.start()
|
|
|
|
# Sync and progress report
|
|
lastProgressUpdate = datetime.today()
|
|
|
|
while not self.KodiMonitor.abortRequested():
|
|
|
|
# Before proceeding, need to make sure:
|
|
# 1. Server is online
|
|
# 2. User is set
|
|
# 3. User has access to the server
|
|
|
|
if utils.window("kodiProfile_emby") != kodiProfile:
|
|
# Profile change happened, terminate this thread
|
|
self.logMsg("Kodi profile was: %s and changed to: %s. Terminating old Emby thread." % (kodiProfile, utils.window("kodiProfile_emby")), 1)
|
|
break
|
|
|
|
if utils.window('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()
|
|
|
|
elif utils.window('commandUpdate') == "true":
|
|
# Received a remote control command that
|
|
# requires updating immediately
|
|
utils.window('commandUpdate', clear=True)
|
|
player.reportPlayback()
|
|
lastProgressUpdate = da4tetime.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 utils.settings('supressConnectMsg') == "false":
|
|
if 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("Emby server", "Welcome %s%s!" % (user.currUser, add), 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 utils.window('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.
|
|
while not self.KodiMonitor.abortRequested():
|
|
|
|
if user.getServer() == "":
|
|
# 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:
|
|
self.logMsg("Server is offline.", 1)
|
|
utils.window('Server_online', value="false")
|
|
xbmcgui.Dialog().notification("Error connecting", "%s Server is unreachable." % self.addonName, icon="special://home/addons/plugin.video.emby/icon.png", sound=False)
|
|
self.server_online = False
|
|
|
|
else:
|
|
# Server is online
|
|
if not self.server_online:
|
|
# Server was offline when Kodi started.
|
|
# 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)
|
|
|
|
self.server_online = True
|
|
self.logMsg("Server is online and ready.", 1)
|
|
utils.window('Server_online', value="true")
|
|
|
|
# Start the User client
|
|
if self.newUserClient is None:
|
|
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
|
|
|
|
##### Emby thread is terminating. #####
|
|
|
|
# If music is enabled and direct stream for music is enabled
|
|
# We use Kodi pathsubstitution to allow for music to play outside network
|
|
# The setting needs to be set before Kodi starts.
|
|
if utils.settings('enableMusicSync') == "true" and utils.settings('directstreammusic') == "true":
|
|
# We need to keep track of the settings
|
|
alternate = utils.settings('altip') == "true"
|
|
pathsub = utils.settings('pathsub') == "true"
|
|
|
|
if pathsub and not alternate:
|
|
# Path sub in place, but primary address in use, remove it
|
|
utils.pathsubstitution(False)
|
|
elif not pathsub and alternate:
|
|
# Path sub not in place, but secondary address in use, add it
|
|
utils.pathsubstitution()
|
|
|
|
if (self.newWebSocketThread is not None):
|
|
ws.stopClient()
|
|
|
|
if (self.newUserClient is not None):
|
|
user.stopClient()
|
|
|
|
xbmc.log("STOP LIBRARY MONITOR")
|
|
librarymonitor.stop()
|
|
|
|
self.logMsg("======== STOP %s ========" % self.addonName, 0)
|
|
|
|
# Start the service
|
|
Service().ServiceEntryPoint() |