type fix
This commit is contained in:
parent
d436c8415d
commit
398bd1644f
1 changed files with 23 additions and 23 deletions
|
@ -44,11 +44,11 @@ class UserClient(threading.Thread):
|
||||||
|
|
||||||
self.addonName = clientinfo.ClientInfo().getAddonName()
|
self.addonName = clientinfo.ClientInfo().getAddonName()
|
||||||
self.doUtils = downloadutils.DownloadUtils()
|
self.doUtils = downloadutils.DownloadUtils()
|
||||||
|
|
||||||
threading.Thread.__init__(self)
|
threading.Thread.__init__(self)
|
||||||
|
|
||||||
def logMsg(self, msg, lvl=1):
|
def logMsg(self, msg, lvl=1):
|
||||||
|
|
||||||
className = self.__class__.__name__
|
className = self.__class__.__name__
|
||||||
utils.logMsg("%s %s" % (self.addonName, className), msg, lvl)
|
utils.logMsg("%s %s" % (self.addonName, className), msg, lvl)
|
||||||
|
|
||||||
|
@ -56,7 +56,7 @@ class UserClient(threading.Thread):
|
||||||
def getAdditionalUsers(self):
|
def getAdditionalUsers(self):
|
||||||
|
|
||||||
additionalUsers = utils.settings('additionalUsers')
|
additionalUsers = utils.settings('additionalUsers')
|
||||||
|
|
||||||
if additionalUsers:
|
if additionalUsers:
|
||||||
self.AdditionalUser = additionalUsers.split(',')
|
self.AdditionalUser = additionalUsers.split(',')
|
||||||
|
|
||||||
|
@ -76,7 +76,7 @@ class UserClient(threading.Thread):
|
||||||
logLevel = int(utils.settings('logLevel'))
|
logLevel = int(utils.settings('logLevel'))
|
||||||
except ValueError:
|
except ValueError:
|
||||||
logLevel = 0
|
logLevel = 0
|
||||||
|
|
||||||
return logLevel
|
return logLevel
|
||||||
|
|
||||||
def getUserId(self):
|
def getUserId(self):
|
||||||
|
@ -122,7 +122,7 @@ class UserClient(threading.Thread):
|
||||||
port = settings('port')
|
port = settings('port')
|
||||||
|
|
||||||
server = host + ":" + port
|
server = host + ":" + port
|
||||||
|
|
||||||
if not host:
|
if not host:
|
||||||
self.logMsg("No server information saved.", 2)
|
self.logMsg("No server information saved.", 2)
|
||||||
return False
|
return False
|
||||||
|
@ -148,7 +148,7 @@ class UserClient(threading.Thread):
|
||||||
userId = self.getUserId()
|
userId = self.getUserId()
|
||||||
w_token = window('emby_accessToken%s' % userId)
|
w_token = window('emby_accessToken%s' % userId)
|
||||||
s_token = settings('accessToken')
|
s_token = settings('accessToken')
|
||||||
|
|
||||||
# Verify the window property
|
# Verify the window property
|
||||||
if w_token:
|
if w_token:
|
||||||
if not s_token:
|
if not s_token:
|
||||||
|
@ -223,12 +223,12 @@ class UserClient(threading.Thread):
|
||||||
window = utils.window
|
window = utils.window
|
||||||
|
|
||||||
result = self.doUtils.downloadUrl("{server}/emby/Users?format=json")
|
result = self.doUtils.downloadUrl("{server}/emby/Users?format=json")
|
||||||
|
|
||||||
if result == False:
|
if result == False:
|
||||||
# Access is restricted, set in downloadutils.py via exception
|
# Access is restricted, set in downloadutils.py via exception
|
||||||
self.logMsg("Access is restricted.", 1)
|
self.logMsg("Access is restricted.", 1)
|
||||||
self.HasAccess = False
|
self.HasAccess = False
|
||||||
|
|
||||||
elif window('emby_online') != "true":
|
elif window('emby_online') != "true":
|
||||||
# Server connection failed
|
# Server connection failed
|
||||||
pass
|
pass
|
||||||
|
@ -246,7 +246,7 @@ class UserClient(threading.Thread):
|
||||||
doUtils = self.doUtils
|
doUtils = self.doUtils
|
||||||
username = self.getUsername()
|
username = self.getUsername()
|
||||||
userId = self.getUserId()
|
userId = self.getUserId()
|
||||||
|
|
||||||
# Only to be used if token exists
|
# Only to be used if token exists
|
||||||
self.currUserId = userId
|
self.currUserId = userId
|
||||||
self.currServer = self.getServer()
|
self.currServer = self.getServer()
|
||||||
|
@ -286,10 +286,10 @@ class UserClient(threading.Thread):
|
||||||
# Set user preferences in settings
|
# Set user preferences in settings
|
||||||
self.currUser = username
|
self.currUser = username
|
||||||
self.setUserPref()
|
self.setUserPref()
|
||||||
|
|
||||||
|
|
||||||
def authenticate(self):
|
def authenticate(self):
|
||||||
|
|
||||||
lang = utils.language
|
lang = utils.language
|
||||||
window = utils.window
|
window = utils.window
|
||||||
settings = utils.settings
|
settings = utils.settings
|
||||||
|
@ -323,12 +323,12 @@ class UserClient(threading.Thread):
|
||||||
self.logMsg("Current userId: %s" % self.currUserId, 1)
|
self.logMsg("Current userId: %s" % self.currUserId, 1)
|
||||||
self.logMsg("Current accessToken: %s" % self.currToken, 2)
|
self.logMsg("Current accessToken: %s" % self.currToken, 2)
|
||||||
return
|
return
|
||||||
|
|
||||||
##### AUTHENTICATE USER #####
|
##### AUTHENTICATE USER #####
|
||||||
|
|
||||||
users = self.getPublicUsers()
|
users = self.getPublicUsers()
|
||||||
password = ""
|
password = ""
|
||||||
|
|
||||||
# Find user in list
|
# Find user in list
|
||||||
for user in users:
|
for user in users:
|
||||||
name = user['Name']
|
name = user['Name']
|
||||||
|
@ -352,18 +352,18 @@ class UserClient(threading.Thread):
|
||||||
heading="%s %s" % (lang(33008), username),
|
heading="%s %s" % (lang(33008), username),
|
||||||
option=xbmcgui.ALPHANUM_HIDE_INPUT)
|
option=xbmcgui.ALPHANUM_HIDE_INPUT)
|
||||||
sha1 = hashlib.sha1(password)
|
sha1 = hashlib.sha1(password)
|
||||||
sha1 = sha1.hexdigest()
|
sha1 = sha1.hexdigest()
|
||||||
|
|
||||||
# Authenticate username and password
|
# Authenticate username and password
|
||||||
data = {'username': username, 'password': sha1}
|
data = {'username': username, 'password': sha1}
|
||||||
self.logMsg(data, 2)
|
self.logMsg(data, 2)
|
||||||
|
|
||||||
result = self.doUtils.downloadUrl("%s/emby/Users/AuthenticateByName?format=json" % server, postBody=data, type="POST", authenticate=False)
|
result = self.doUtils.downloadUrl("%s/emby/Users/AuthenticateByName?format=json" % server, postBody=data, action_type="POST", authenticate=False)
|
||||||
|
|
||||||
try:
|
try:
|
||||||
self.logMsg("Auth response: %s" % result, 1)
|
self.logMsg("Auth response: %s" % result, 1)
|
||||||
accessToken = result['AccessToken']
|
accessToken = result['AccessToken']
|
||||||
|
|
||||||
except (KeyError, TypeError):
|
except (KeyError, TypeError):
|
||||||
self.logMsg("Failed to retrieve the api key.", 1)
|
self.logMsg("Failed to retrieve the api key.", 1)
|
||||||
accessToken = None
|
accessToken = None
|
||||||
|
@ -383,7 +383,7 @@ class UserClient(threading.Thread):
|
||||||
settings('accessToken', value="")
|
settings('accessToken', value="")
|
||||||
settings('userId%s' % username, value="")
|
settings('userId%s' % username, value="")
|
||||||
dialog.ok(lang(33001), lang(33009))
|
dialog.ok(lang(33001), lang(33009))
|
||||||
|
|
||||||
# Give two attempts at entering password
|
# Give two attempts at entering password
|
||||||
if self.retry == 2:
|
if self.retry == 2:
|
||||||
self.logMsg("Too many retries. "
|
self.logMsg("Too many retries. "
|
||||||
|
@ -403,10 +403,10 @@ class UserClient(threading.Thread):
|
||||||
utils.window('emby_accessToken%s' % self.getUserId(), clear=True)
|
utils.window('emby_accessToken%s' % self.getUserId(), clear=True)
|
||||||
self.currToken = None
|
self.currToken = None
|
||||||
self.logMsg("User token has been removed.", 1)
|
self.logMsg("User token has been removed.", 1)
|
||||||
|
|
||||||
self.auth = True
|
self.auth = True
|
||||||
self.currUser = None
|
self.currUser = None
|
||||||
|
|
||||||
def run(self):
|
def run(self):
|
||||||
|
|
||||||
window = utils.window
|
window = utils.window
|
||||||
|
@ -436,14 +436,14 @@ class UserClient(threading.Thread):
|
||||||
# to authenticate the user
|
# to authenticate the user
|
||||||
self.auth = False
|
self.auth = False
|
||||||
self.authenticate()
|
self.authenticate()
|
||||||
|
|
||||||
|
|
||||||
if not self.auth and (self.currUser is None):
|
if not self.auth and (self.currUser is None):
|
||||||
# If authenticate failed.
|
# If authenticate failed.
|
||||||
server = self.getServer()
|
server = self.getServer()
|
||||||
username = self.getUsername()
|
username = self.getUsername()
|
||||||
status = window('emby_serverStatus')
|
status = window('emby_serverStatus')
|
||||||
|
|
||||||
# The status Stop is for when user cancelled password dialog.
|
# The status Stop is for when user cancelled password dialog.
|
||||||
if server and username and status != "Stop":
|
if server and username and status != "Stop":
|
||||||
# Only if there's information found to login
|
# Only if there's information found to login
|
||||||
|
@ -455,11 +455,11 @@ class UserClient(threading.Thread):
|
||||||
if self.stopClient == True:
|
if self.stopClient == True:
|
||||||
# If stopping the client didn't work
|
# If stopping the client didn't work
|
||||||
break
|
break
|
||||||
|
|
||||||
if monitor.waitForAbort(1):
|
if monitor.waitForAbort(1):
|
||||||
# Abort was requested while waiting. We should exit
|
# Abort was requested while waiting. We should exit
|
||||||
break
|
break
|
||||||
|
|
||||||
self.doUtils.stopSession()
|
self.doUtils.stopSession()
|
||||||
self.logMsg("##===---- UserClient Stopped ----===##", 0)
|
self.logMsg("##===---- UserClient Stopped ----===##", 0)
|
||||||
|
|
||||||
|
|
Loading…
Add table
Reference in a new issue