1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
|
# Gnu General Public License - see LICENSE.TXT
import socket
import json
from urlparse import urlparse
import xbmcaddon
import xbmcgui
import xbmc
from kodi_utils import HomeWindow
from downloadutils import DownloadUtils
from simple_logging import SimpleLogging
from translation import i18n
log = SimpleLogging(__name__)
__addon__ = xbmcaddon.Addon(id='plugin.video.embycon')
__addon_name__ = __addon__.getAddonInfo('name')
downloadUtils = DownloadUtils()
def getServerDetails():
log.debug("Getting Server Details from Network")
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, 4) # 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)
sock.sendto(MESSAGE, MULTI_GROUP)
servers = []
# while True:
try:
data, addr = sock.recvfrom(1024) # buffer size
servers.append(json.loads(data))
except Exception as e:
log.error("Read UPD responce: {0}", e)
# break
log.debug("Found Servers: {0}", servers)
return servers
def checkServer(force=False, change_user=False, notify=False):
log.debug("checkServer Called")
settings = xbmcaddon.Addon(id='plugin.video.embycon')
serverUrl = ""
if force is False:
# if not forcing use server details from settings
svr = downloadUtils.getServer()
if svr is not None:
serverUrl = svr
# if the server is not set then try to detect it
if serverUrl == "":
serverInfo = getServerDetails()
serverNames = []
for server in serverInfo:
serverNames.append(server.get("Name", i18n('n/a')))
if serverNames:
return_index = xbmcgui.Dialog().select(i18n('select_server'), serverNames)
else:
xbmcgui.Dialog().ok(__addon_name__, i18n('no_server_detected'))
return_index = -1
if (return_index == -1):
xbmc.executebuiltin("ActivateWindow(Home)")
return
serverUrl = serverInfo[return_index]["Address"]
log.debug("Selected server: {0}", serverUrl)
# parse the url
url_bits = urlparse(serverUrl)
server_address = url_bits.hostname
server_port = str(url_bits.port)
server_protocol = url_bits.scheme
log.debug("Detected server info {0} - {1} - {2}", server_protocol, server_address, server_port)
# save the server info
settings.setSetting("port", server_port)
settings.setSetting("ipaddress", server_address)
if server_protocol == "https":
settings.setSetting("use_https", "true")
else:
settings.setSetting("use_https", "false")
if notify:
xbmcgui.Dialog().ok(i18n('server_detect_succeeded'), i18n('found_server'),
i18n('address:') + server_address, i18n('server_port:') + server_port)
# we need to change the user
current_username = settings.getSetting("username")
current_username = unicode(current_username, "utf-8")
# if asked or we have no current user then show user selection screen
if change_user or len(current_username) == 0:
# get a list of users
log.debug("Getting user list")
jsonData = downloadUtils.downloadUrl(serverUrl + "/emby/Users/Public?format=json", authenticate=False)
log.debug("jsonData: {0}", jsonData)
result = json.loads(jsonData)
if result is None:
xbmcgui.Dialog().ok(i18n('error'),
i18n('unable_connect_server'),
i18n('address:') + serverUrl)
else:
names = []
user_list = []
secured = []
for user in result:
config = user.get("Configuration")
if (config != None):
if (config.get("IsHidden") is None) or (config.get("IsHidden") is False):
name = user.get("Name")
user_list.append(name)
if (user.get("HasPassword") is True):
secured.append(True)
name = i18n('username_secured') % name
else:
secured.append(False)
names.append(name)
if (len(current_username) > 0) and (not any(n == current_username for n in user_list)):
names.insert(0, i18n('username_userdefined') % current_username)
user_list.insert(0, current_username)
secured.insert(0, True)
names.insert(0, i18n('username_userinput'))
user_list.insert(0, '')
secured.insert(0, True)
log.debug("User List: {0}", names)
log.debug("User List: {0}", user_list)
return_value = xbmcgui.Dialog().select(i18n('select_user'), names)
if (return_value > -1):
log.debug("Selected User Index: {0}", return_value)
if return_value == 0:
kb = xbmc.Keyboard()
kb.setHeading(i18n('username:'))
kb.doModal()
if kb.isConfirmed():
selected_user = kb.getText()
else:
selected_user = None
else:
selected_user = user_list[return_value]
log.debug("Selected User Name: {0}", selected_user)
if selected_user:
# we have a user so save it
log.debug("Saving Username: {0}", selected_user)
settings.setSetting("username", selected_user)
if secured[return_value] is True:
kb = xbmc.Keyboard()
kb.setHeading(i18n('password:'))
kb.setHiddenInput(True)
kb.doModal()
if kb.isConfirmed():
log.debug("Saving Password for Username: {0}", selected_user)
settings.setSetting('password', kb.getText())
else:
settings.setSetting('password', '')
home_window = HomeWindow()
home_window.clearProperty("userid")
home_window.clearProperty("AccessToken")
xbmc.executebuiltin("ActivateWindow(Home)")
|
