379 lines
15 KiB
Python
379 lines
15 KiB
Python
# Gnu General Public License - see LICENSE.TXT
|
|
|
|
import socket
|
|
import json
|
|
from urlparse import urlparse
|
|
import time
|
|
import hashlib
|
|
from datetime import datetime
|
|
|
|
import xbmcaddon
|
|
import xbmcgui
|
|
import xbmc
|
|
|
|
from .kodi_utils import HomeWindow
|
|
from .downloadutils import DownloadUtils, save_user_details, load_user_details
|
|
from .simple_logging import SimpleLogging
|
|
from .translation import string_load
|
|
from .utils import datetime_from_string
|
|
|
|
log = SimpleLogging(__name__)
|
|
|
|
__addon__ = xbmcaddon.Addon()
|
|
__addon_name__ = __addon__.getAddonInfo('name')
|
|
|
|
|
|
def getServerDetails():
|
|
log.debug("Getting Server Details from Network")
|
|
servers = []
|
|
|
|
MESSAGE = "who is EmbyServer?"
|
|
MULTI_GROUP = ("<broadcast>", 7359)
|
|
#MULTI_GROUP = ("127.0.0.1", 7359)
|
|
|
|
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
|
|
sock.settimeout(4.0)
|
|
|
|
sock.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_TTL, 3) # timeout
|
|
sock.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
|
|
sock.setsockopt(socket.SOL_IP, socket.IP_MULTICAST_LOOP, 1)
|
|
sock.setsockopt(socket.IPPROTO_IP, socket.SO_REUSEADDR, 1)
|
|
|
|
log.debug("MutliGroup: {0}", MULTI_GROUP)
|
|
log.debug("Sending UDP Data: {0}", MESSAGE)
|
|
|
|
progress = xbmcgui.DialogProgress()
|
|
progress.create(__addon_name__ + " : " + string_load(30373))
|
|
progress.update(0, string_load(30374))
|
|
xbmc.sleep(1000)
|
|
server_count = 0
|
|
|
|
# while True:
|
|
try:
|
|
sock.sendto(MESSAGE, MULTI_GROUP)
|
|
while True:
|
|
try:
|
|
server_count += 1
|
|
progress.update(server_count * 10, string_load(30375) % server_count)
|
|
xbmc.sleep(1000)
|
|
data, addr = sock.recvfrom(1024)
|
|
servers.append(json.loads(data))
|
|
except:
|
|
break
|
|
except Exception as e:
|
|
log.error("UPD Discovery Error: {0}", e)
|
|
|
|
progress.close()
|
|
|
|
log.debug("Found Servers: {0}", servers)
|
|
return servers
|
|
|
|
|
|
def checkServer(force=False, change_user=False, notify=False):
|
|
log.debug("checkServer Called")
|
|
|
|
settings = xbmcaddon.Addon()
|
|
server_url = ""
|
|
something_changed = False
|
|
du = DownloadUtils()
|
|
|
|
if force is False:
|
|
# if not forcing use server details from settings
|
|
svr = du.getServer()
|
|
if svr is not None:
|
|
server_url = svr
|
|
|
|
# if the server is not set then try to detect it
|
|
if server_url == "":
|
|
|
|
# scan for local server
|
|
server_info = getServerDetails()
|
|
|
|
addon = xbmcaddon.Addon()
|
|
server_icon = addon.getAddonInfo('icon')
|
|
|
|
server_list = []
|
|
for server in server_info:
|
|
server_item = xbmcgui.ListItem(server.get("Name", string_load(30063)))
|
|
sub_line = server.get("Address")
|
|
server_item.setLabel2(sub_line)
|
|
server_item.setProperty("address", server.get("Address"))
|
|
art = {"Thumb": server_icon}
|
|
server_item.setArt(art)
|
|
server_list.append(server_item)
|
|
|
|
if len(server_list) > 0:
|
|
return_index = xbmcgui.Dialog().select(__addon_name__ + " : " + string_load(30166),
|
|
server_list,
|
|
useDetails=True)
|
|
if return_index != -1:
|
|
server_url = server_info[return_index]["Address"]
|
|
|
|
if not server_url:
|
|
return_index = xbmcgui.Dialog().yesno(__addon_name__, string_load(30282), string_load(30370))
|
|
if not return_index:
|
|
xbmc.executebuiltin("ActivateWindow(Home)")
|
|
return
|
|
|
|
while True:
|
|
kb = xbmc.Keyboard()
|
|
kb.setHeading(string_load(30372))
|
|
if server_url:
|
|
kb.setDefault(server_url)
|
|
else:
|
|
kb.setDefault("http://<server address>:8096")
|
|
kb.doModal()
|
|
if kb.isConfirmed():
|
|
server_url = kb.getText()
|
|
else:
|
|
xbmc.executebuiltin("ActivateWindow(Home)")
|
|
return
|
|
|
|
url_bits = urlparse(server_url)
|
|
server_address = url_bits.hostname
|
|
server_port = str(url_bits.port)
|
|
server_protocol = url_bits.scheme
|
|
user_name = url_bits.username
|
|
user_password = url_bits.password
|
|
|
|
if user_name and user_password:
|
|
temp_url = "%s://%s:%s@%s:%s/emby/Users/Public?format=json" % (server_protocol, user_name, user_password, server_address, server_port)
|
|
else:
|
|
temp_url = "%s://%s:%s/emby/Users/Public?format=json" % (server_protocol, server_address, server_port)
|
|
|
|
log.debug("Testing_Url: {0}", temp_url)
|
|
progress = xbmcgui.DialogProgress()
|
|
progress.create(__addon_name__ + " : " + string_load(30376))
|
|
progress.update(0, string_load(30377))
|
|
json_data = du.downloadUrl(temp_url, authenticate=False)
|
|
progress.close()
|
|
|
|
result = json.loads(json_data)
|
|
if result is not None:
|
|
xbmcgui.Dialog().ok(__addon_name__ + " : " + string_load(30167),
|
|
"%s://%s:%s/" % (server_protocol, server_address, server_port))
|
|
break
|
|
else:
|
|
return_index = xbmcgui.Dialog().yesno(__addon_name__ + " : " + string_load(30135),
|
|
server_url,
|
|
string_load(30371))
|
|
if not return_index:
|
|
xbmc.executebuiltin("ActivateWindow(Home)")
|
|
return
|
|
|
|
log.debug("Selected server: {0}", server_url)
|
|
|
|
# parse the url
|
|
url_bits = urlparse(server_url)
|
|
server_address = url_bits.hostname
|
|
server_port = str(url_bits.port)
|
|
server_protocol = url_bits.scheme
|
|
user_name = url_bits.username
|
|
user_password = url_bits.password
|
|
log.debug("Detected server info {0} - {1} - {2}", server_protocol, server_address, server_port)
|
|
|
|
# save the server info
|
|
settings.setSetting("port", server_port)
|
|
|
|
if user_name and user_password:
|
|
server_address = "%s:%s@%s" % (url_bits.username, url_bits.password, server_address)
|
|
|
|
settings.setSetting("ipaddress", server_address)
|
|
|
|
if server_protocol == "https":
|
|
settings.setSetting("protocol", "1")
|
|
else:
|
|
settings.setSetting("protocol", "0")
|
|
|
|
something_changed = True
|
|
|
|
# do we need to change the user
|
|
user_details = load_user_details(settings)
|
|
current_username = user_details.get("username", "")
|
|
current_username = unicode(current_username, "utf-8")
|
|
|
|
# if asked or we have no current user then show user selection screen
|
|
if something_changed or change_user or len(current_username) == 0:
|
|
|
|
# stop playback when switching users
|
|
xbmc.Player().stop()
|
|
du = DownloadUtils()
|
|
|
|
# get a list of users
|
|
log.debug("Getting user list")
|
|
json_data = du.downloadUrl(server_url + "/emby/Users/Public?format=json", authenticate=False)
|
|
|
|
log.debug("jsonData: {0}", json_data)
|
|
try:
|
|
result = json.loads(json_data)
|
|
except:
|
|
result = None
|
|
|
|
if result is None:
|
|
xbmcgui.Dialog().ok(string_load(30135),
|
|
string_load(30201),
|
|
string_load(30169) + server_url)
|
|
|
|
else:
|
|
selected_id = -1
|
|
users = []
|
|
for user in result:
|
|
config = user.get("Configuration")
|
|
if config is not None:
|
|
if config.get("IsHidden", False) is False:
|
|
name = user.get("Name")
|
|
admin = user.get("Policy", {}).get("IsAdministrator", False)
|
|
|
|
time_ago = ""
|
|
last_active = user.get("LastActivityDate")
|
|
if last_active:
|
|
last_active_date = datetime_from_string(last_active)
|
|
log.debug("LastActivityDate: {0}", last_active_date)
|
|
ago = datetime.now() - last_active_date
|
|
log.debug("LastActivityDate: {0}", ago)
|
|
days = divmod(ago.seconds, 86400)
|
|
hours = divmod(days[1], 3600)
|
|
minutes = divmod(hours[1], 60)
|
|
log.debug("LastActivityDate: {0} {1} {2}", days[0], hours[0], minutes[0])
|
|
if days[0]:
|
|
time_ago += " %sd" % days[0]
|
|
if hours[0]:
|
|
time_ago += " %sh" % hours[0]
|
|
if minutes[0]:
|
|
time_ago += " %sm" % minutes[0]
|
|
time_ago = time_ago.strip()
|
|
if not time_ago:
|
|
time_ago = "Active: now"
|
|
else:
|
|
time_ago = "Active: %s ago" % time_ago
|
|
log.debug("LastActivityDate: {0}", time_ago)
|
|
|
|
user_item = xbmcgui.ListItem(name)
|
|
user_image = du.get_user_artwork(user, 'Primary')
|
|
if not user_image:
|
|
user_image = "DefaultUser.png"
|
|
art = {"Thumb": user_image}
|
|
user_item.setArt(art)
|
|
user_item.setLabel2("TEST")
|
|
|
|
sub_line = time_ago
|
|
|
|
if user.get("HasPassword", False) is True:
|
|
sub_line += ", Password"
|
|
user_item.setProperty("secure", "true")
|
|
|
|
m = hashlib.md5()
|
|
m.update(name)
|
|
hashed_username = m.hexdigest()
|
|
saved_password = settings.getSetting("saved_user_password_" + hashed_username)
|
|
if saved_password:
|
|
sub_line += ": Saved"
|
|
|
|
else:
|
|
user_item.setProperty("secure", "false")
|
|
|
|
if admin:
|
|
sub_line += ", Admin"
|
|
else:
|
|
sub_line += ", User"
|
|
|
|
user_item.setProperty("manual", "false")
|
|
user_item.setLabel2(sub_line)
|
|
users.append(user_item)
|
|
|
|
if current_username == name:
|
|
selected_id = len(users) - 1
|
|
|
|
if current_username:
|
|
selection_title = string_load(30180) + " (" + current_username + ")"
|
|
else:
|
|
selection_title = string_load(30180)
|
|
|
|
# add manual login
|
|
user_item = xbmcgui.ListItem(string_load(30365))
|
|
art = {"Thumb": "DefaultUser.png"}
|
|
user_item.setArt(art)
|
|
user_item.setLabel2(string_load(30366))
|
|
user_item.setProperty("secure", "true")
|
|
user_item.setProperty("manual", "true")
|
|
users.append(user_item)
|
|
|
|
return_value = xbmcgui.Dialog().select(selection_title,
|
|
users,
|
|
preselect=selected_id,
|
|
autoclose=20000,
|
|
useDetails=True)
|
|
|
|
if return_value > -1 and return_value != selected_id:
|
|
|
|
something_changed = True
|
|
selected_user = users[return_value]
|
|
secured = selected_user.getProperty("secure") == "true"
|
|
manual = selected_user.getProperty("manual") == "true"
|
|
selected_user_name = selected_user.getLabel()
|
|
|
|
log.debug("Selected User Name: {0} : {1}", return_value, selected_user_name)
|
|
|
|
if manual:
|
|
kb = xbmc.Keyboard()
|
|
kb.setHeading(string_load(30005))
|
|
if current_username:
|
|
kb.setDefault(current_username)
|
|
kb.doModal()
|
|
if kb.isConfirmed():
|
|
selected_user_name = kb.getText()
|
|
log.debug("Manual entered username: {0}", selected_user_name)
|
|
else:
|
|
return
|
|
|
|
if secured:
|
|
# we need a password, check the settings first
|
|
m = hashlib.md5()
|
|
m.update(selected_user_name)
|
|
hashed_username = m.hexdigest()
|
|
saved_password = settings.getSetting("saved_user_password_" + hashed_username)
|
|
allow_password_saving = settings.getSetting("allow_password_saving") == "true"
|
|
|
|
# if not saving passwords but have a saved ask to clear it
|
|
if not allow_password_saving and saved_password:
|
|
clear_password = xbmcgui.Dialog().yesno(string_load(30368), string_load(30369))
|
|
if clear_password:
|
|
settings.setSetting("saved_user_password_" + hashed_username, "")
|
|
|
|
if saved_password:
|
|
log.debug("Saving username and password: {0}", selected_user_name)
|
|
log.debug("Using stored password for user: {0}", hashed_username)
|
|
save_user_details(settings, selected_user_name, saved_password)
|
|
|
|
else:
|
|
kb = xbmc.Keyboard()
|
|
kb.setHeading(string_load(30006))
|
|
kb.setHiddenInput(True)
|
|
kb.doModal()
|
|
if kb.isConfirmed():
|
|
log.debug("Saving username and password: {0}", selected_user_name)
|
|
save_user_details(settings, selected_user_name, kb.getText())
|
|
|
|
# should we save the password
|
|
if allow_password_saving:
|
|
save_password = xbmcgui.Dialog().yesno(string_load(30363), string_load(30364))
|
|
if save_password:
|
|
log.debug("Saving password for fast user switching: {0}", hashed_username)
|
|
settings.setSetting("saved_user_password_" + hashed_username, kb.getText())
|
|
else:
|
|
log.debug("Saving username with no password: {0}", selected_user_name)
|
|
save_user_details(settings, selected_user_name, "")
|
|
|
|
if something_changed:
|
|
home_window = HomeWindow()
|
|
home_window.clearProperty("userid")
|
|
home_window.clearProperty("AccessToken")
|
|
home_window.clearProperty("userimage")
|
|
home_window.setProperty("embycon_widget_reload", str(time.time()))
|
|
du = DownloadUtils()
|
|
du.authenticate()
|
|
du.getUserId()
|
|
xbmc.executebuiltin("ActivateWindow(Home)")
|
|
xbmc.executebuiltin("SetFocus(9000, 0, absolute)")
|
|
xbmc.executebuiltin("ReloadSkin()")
|