admin/jellycon
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

remove websockets

Browse Source
This commit is contained in:
sfaulds
2017-05-25 18:16:01 +10:00
parent 0eaac876f4
commit e933c859e4
7 changed files with 158 additions and 1203 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
resources/lib/downloadutils.py
View File

@@ -279,7 +279,15 @@ class DownloadUtils():
log.info("HEADERS : " + str(head))
if(postBody != None):
head["Content-Type"] = "application/x-www-form-urlencoded"
if isinstance(postBody, dict):
content_type = "application/json"
postBody = json.dumps(postBody)
else:
content_type = "application/x-www-form-urlencoded"
head["Content-Type"] = content_type
log.info("Content-Type : " + content_type)
log.info("POST DATA : " + postBody)
conn.request(method=type, url=urlPath, body=postBody, headers=head)
else:

14
resources/lib/functions.py
View File

@@ -1132,16 +1132,16 @@ def PLAY(params, handle):
log.info("== ENTER: PLAY ==")
log.info("PLAY ACTION PARAMS : " + str(params))
id = params.get("item_id")
item_id = params.get("item_id")
autoResume = int(params.get("auto_resume", "-1"))
log.info("AUTO_RESUME: " + str(autoResume))
auto_resume = int(params.get("auto_resume", "-1"))
log.info("AUTO_RESUME: " + str(auto_resume))
# set the current playing item id
# set all the playback info, this will be picked up by the service
# the service will then start the playback
WINDOW = xbmcgui.Window(10000)
WINDOW.setProperty("item_id", id)
WINDOW.setProperty("play_item_id", id)
WINDOW.setProperty("play_item_resume", str(autoResume))
home_window = xbmcgui.Window(10000)
home_window.setProperty("item_id", item_id)
home_window.setProperty("play_item_id", item_id)
home_window.setProperty("play_item_resume", str(auto_resume))

10
resources/lib/play_utils.py
View File

@@ -25,6 +25,7 @@ def playFile(id, auto_resume):
settings = xbmcaddon.Addon(id='plugin.video.embycon')
addon_path = settings.getAddonInfo('path')
playback_type = settings.getSetting("playback_type")
port = settings.getSetting('port')
host = settings.getSetting('ipaddress')
@@ -62,6 +63,15 @@ def playFile(id, auto_resume):
playurl = PlayUtils().getPlayUrl(id, result)
log.info("Play URL: " + playurl)
playback_type_string = "DirectPlay"
if playback_type == "1":
playback_type_string = "DirectStream"
elif playback_type == "2":
playback_type_string = "Transcode"
home_window = xbmcgui.Window(10000)
home_window.setProperty("PlaybackType_" + id, playback_type_string)
listItem = xbmcgui.ListItem(label=result.get("Name", __language__(30280)), path=playurl)
listItem = setListItemProps(id, listItem, result, server)

21
resources/lib/server_detect.py
View File

@@ -8,7 +8,6 @@ import xbmcaddon
import xbmcgui
import xbmc
from websocket import WebSocket
from downloadutils import DownloadUtils
from simple_logging import SimpleLogging
@@ -113,14 +112,14 @@ def checkServer(force=False, change_user=False, notify=False):
result = json.loads(jsonData)
names = []
userList = []
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")
userList.append(name)
user_list.append(name)
if (user.get("HasPassword") is True):
secured.append(True)
name = __language__(30060) % name
@@ -128,16 +127,16 @@ def checkServer(force=False, change_user=False, notify=False):
secured.append(False)
names.append(name)
if (len(current_username) > 0) and (not any(n == current_username for n in userList)):
if (len(current_username) > 0) and (not any(n == current_username for n in user_list)):
names.insert(0, __language__(30061) % current_username)
userList.insert(0, current_username)
user_list.insert(0, current_username)
secured.insert(0, True)
names.insert(0, __language__(30062))
userList.insert(0, '')
user_list.insert(0, '')
secured.insert(0, True)
log.debug("User List : " + str(names))
log.debug("User List : " + str(userList))
log.debug("User List : " + str(user_list))
return_value = xbmcgui.Dialog().select(__language__(30180), names)
@@ -152,7 +151,7 @@ def checkServer(force=False, change_user=False, notify=False):
else:
selected_user = None
else:
selected_user = userList[return_value]
selected_user = user_list[return_value]
log.debug("Selected User Name : " + str(selected_user))
@@ -171,8 +170,8 @@ def checkServer(force=False, change_user=False, notify=False):
else:
settings.setSetting('password', '')
WINDOW = xbmcgui.Window(10000)
WINDOW.clearProperty("userid")
WINDOW.clearProperty("AccessToken")
home_window = xbmcgui.Window(10000)
home_window.clearProperty("userid")
home_window.clearProperty("AccessToken")
xbmc.executebuiltin("ActivateWindow(Home)")

895
resources/lib/websocket.py
View File

@@ -1,895 +0,0 @@
"""
websocket - WebSocket client library for Python
Copyright (C) 2010 Hiroki Ohtani(liris)
This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Lesser General Public
License as published by the Free Software Foundation; either
version 2.1 of the License, or (at your option) any later version.
This library is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
Lesser General Public License for more details.
You should have received a copy of the GNU Lesser General Public
License along with this library; if not, write to the Free Software
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
"""
import socket
try:
import ssl
from ssl import SSLError
HAVE_SSL = True
except ImportError:
# dummy class of SSLError for ssl none-support environment.
class SSLError(Exception):
pass
HAVE_SSL = False
from urlparse import urlparse
import os
import array
import struct
import uuid
import hashlib
import base64
import threading
import time
import traceback
import sys
from simple_logging import SimpleLogging
"""
websocket python client.
=========================
This version support only hybi-13.
Please see http://tools.ietf.org/html/rfc6455 for protocol.
"""
# websocket supported version.
VERSION = 13
# closing frame status codes.
STATUS_NORMAL = 1000
STATUS_GOING_AWAY = 1001
STATUS_PROTOCOL_ERROR = 1002
STATUS_UNSUPPORTED_DATA_TYPE = 1003
STATUS_STATUS_NOT_AVAILABLE = 1005
STATUS_ABNORMAL_CLOSED = 1006
STATUS_INVALID_PAYLOAD = 1007
STATUS_POLICY_VIOLATION = 1008
STATUS_MESSAGE_TOO_BIG = 1009
STATUS_INVALID_EXTENSION = 1010
STATUS_UNEXPECTED_CONDITION = 1011
STATUS_TLS_HANDSHAKE_ERROR = 1015
logger = SimpleLogging("EmbyCon." + __name__)
class WebSocketException(Exception):
"""
websocket exeception class.
"""
pass
class WebSocketConnectionClosedException(WebSocketException):
"""
If remote host closed the connection or some network error happened,
this exception will be raised.
"""
pass
class WebSocketTimeoutException(WebSocketException):
"""
WebSocketTimeoutException will be raised at socket timeout during read/write data.
"""
pass
default_timeout = None
def setdefaulttimeout(timeout):
"""
Set the global timeout setting to connect.
timeout: default socket timeout time. This value is second.
"""
global default_timeout
default_timeout = timeout
def getdefaulttimeout():
"""
Return the global timeout setting(second) to connect.
"""
return default_timeout
def _parse_url(url):
"""
parse url and the result is tuple of
(hostname, port, resource path and the flag of secure mode)
url: url string.
"""
if ":" not in url:
raise ValueError("url is invalid")
scheme, url = url.split(":", 1)
parsed = urlparse(url, scheme="http")
if parsed.hostname:
hostname = parsed.hostname
else:
raise ValueError("hostname is invalid")
port = 0
if parsed.port:
port = parsed.port
is_secure = False
if scheme == "ws":
if not port:
port = 80
elif scheme == "wss":
is_secure = True
if not port:
port = 443
else:
raise ValueError("scheme %s is invalid" % scheme)
if parsed.path:
resource = parsed.path
else:
resource = "/"
if parsed.query:
resource += "?" + parsed.query
return (hostname, port, resource, is_secure)
def create_connection(url, timeout=None, **options):
"""
connect to url and return websocket object.
Connect to url and return the WebSocket object.
Passing optional timeout parameter will set the timeout on the socket.
If no timeout is supplied, the global default timeout setting returned by getdefauttimeout() is used.
You can customize using 'options'.
If you set "header" list object, you can set your own custom header.
>>> conn = create_connection("ws://echo.websocket.org/",
... header=["User-Agent: MyProgram",
... "x-custom: header"])
timeout: socket timeout time. This value is integer.
if you set None for this value, it means "use default_timeout value"
options: current support option is only "header".
if you set header as dict value, the custom HTTP headers are added.
"""
sockopt = options.get("sockopt", [])
sslopt = options.get("sslopt", {})
websock = WebSocket(sockopt=sockopt, sslopt=sslopt)
websock.settimeout(timeout if timeout is not None else default_timeout)
websock.connect(url, **options)
return websock
_MAX_INTEGER = (1 << 32) -1
_AVAILABLE_KEY_CHARS = range(0x21, 0x2f + 1) + range(0x3a, 0x7e + 1)
_MAX_CHAR_BYTE = (1<<8) -1
# ref. Websocket gets an update, and it breaks stuff.
# http://axod.blogspot.com/2010/06/websocket-gets-update-and-it-breaks.html
def _create_sec_websocket_key():
uid = uuid.uuid4()
return base64.encodestring(uid.bytes).strip()
_HEADERS_TO_CHECK = {
"upgrade": "websocket",
"connection": "upgrade",
}
class ABNF(object):
"""
ABNF frame class.
see http://tools.ietf.org/html/rfc5234
and http://tools.ietf.org/html/rfc6455#section-5.2
"""
# operation code values.
OPCODE_CONT = 0x0
OPCODE_TEXT = 0x1
OPCODE_BINARY = 0x2
OPCODE_CLOSE = 0x8
OPCODE_PING = 0x9
OPCODE_PONG = 0xa
# available operation code value tuple
OPCODES = (OPCODE_CONT, OPCODE_TEXT, OPCODE_BINARY, OPCODE_CLOSE,
OPCODE_PING, OPCODE_PONG)
# opcode human readable string
OPCODE_MAP = {
OPCODE_CONT: "cont",
OPCODE_TEXT: "text",
OPCODE_BINARY: "binary",
OPCODE_CLOSE: "close",
OPCODE_PING: "ping",
OPCODE_PONG: "pong"
}
# data length threashold.
LENGTH_7 = 0x7d
LENGTH_16 = 1 << 16
LENGTH_63 = 1 << 63
def __init__(self, fin=0, rsv1=0, rsv2=0, rsv3=0,
opcode=OPCODE_TEXT, mask=1, data=""):
"""
Constructor for ABNF.
please check RFC for arguments.
"""
self.fin = fin
self.rsv1 = rsv1
self.rsv2 = rsv2
self.rsv3 = rsv3
self.opcode = opcode
self.mask = mask
self.data = data
self.get_mask_key = os.urandom
def __str__(self):
return "fin=" + str(self.fin) \
+ " opcode=" + str(self.opcode) \
+ " data=" + str(self.data)
@staticmethod
def create_frame(data, opcode):
"""
create frame to send text, binary and other data.
data: data to send. This is string value(byte array).
if opcode is OPCODE_TEXT and this value is uniocde,
data value is conveted into unicode string, automatically.
opcode: operation code. please see OPCODE_XXX.
"""
if opcode == ABNF.OPCODE_TEXT and isinstance(data, unicode):
data = data.encode("utf-8")
# mask must be set if send data from client
return ABNF(1, 0, 0, 0, opcode, 1, data)
def format(self):
"""
format this object to string(byte array) to send data to server.
"""
if any(x not in (0, 1) for x in [self.fin, self.rsv1, self.rsv2, self.rsv3]):
raise ValueError("not 0 or 1")
if self.opcode not in ABNF.OPCODES:
raise ValueError("Invalid OPCODE")
length = len(self.data)
if length >= ABNF.LENGTH_63:
raise ValueError("data is too long")
frame_header = chr(self.fin << 7
| self.rsv1 << 6 | self.rsv2 << 5 | self.rsv3 << 4
| self.opcode)
if length < ABNF.LENGTH_7:
frame_header += chr(self.mask << 7 | length)
elif length < ABNF.LENGTH_16:
frame_header += chr(self.mask << 7 | 0x7e)
frame_header += struct.pack("!H", length)
else:
frame_header += chr(self.mask << 7 | 0x7f)
frame_header += struct.pack("!Q", length)
if not self.mask:
return frame_header + self.data
else:
mask_key = self.get_mask_key(4)
return frame_header + self._get_masked(mask_key)
def _get_masked(self, mask_key):
s = ABNF.mask(mask_key, self.data)
return mask_key + "".join(s)
@staticmethod
def mask(mask_key, data):
"""
mask or unmask data. Just do xor for each byte
mask_key: 4 byte string(byte).
data: data to mask/unmask.
"""
_m = array.array("B", mask_key)
_d = array.array("B", data)
for i in xrange(len(_d)):
_d[i] ^= _m[i % 4]
return _d.tostring()
class WebSocket(object):
"""
Low level WebSocket interface.
This class is based on
The WebSocket protocol draft-hixie-thewebsocketprotocol-76
http://tools.ietf.org/html/draft-hixie-thewebsocketprotocol-76
We can connect to the websocket server and send/recieve data.
The following example is a echo client.
>>> import websocket
>>> ws = websocket.WebSocket()
>>> ws.connect("ws://echo.websocket.org")
>>> ws.send("Hello, Server")
>>> ws.recv()
'Hello, Server'
>>> ws.close()
get_mask_key: a callable to produce new mask keys, see the set_mask_key
function's docstring for more details
sockopt: values for socket.setsockopt.
sockopt must be tuple and each element is argument of sock.setscokopt.
sslopt: dict object for ssl socket option.
"""
def __init__(self, get_mask_key=None, sockopt=None, sslopt=None):
"""
Initalize WebSocket object.
"""
if sockopt is None:
sockopt = []
if sslopt is None:
sslopt = {}
self.connected = False
self.sock = socket.socket()
for opts in sockopt:
self.sock.setsockopt(*opts)
self.sslopt = sslopt
self.get_mask_key = get_mask_key
# Buffers over the packets from the layer beneath until desired amount
# bytes of bytes are received.
self._recv_buffer = []
# These buffer over the build-up of a single frame.
self._frame_header = None
self._frame_length = None
self._frame_mask = None
self._cont_data = None
def fileno(self):
return self.sock.fileno()
def set_mask_key(self, func):
"""
set function to create musk key. You can custumize mask key generator.
Mainly, this is for testing purpose.
func: callable object. the fuct must 1 argument as integer.
The argument means length of mask key.
This func must be return string(byte array),
which length is argument specified.
"""
self.get_mask_key = func
def gettimeout(self):
"""
Get the websocket timeout(second).
"""
return self.sock.gettimeout()
def settimeout(self, timeout):
"""
Set the timeout to the websocket.
timeout: timeout time(second).
"""
self.sock.settimeout(timeout)
timeout = property(gettimeout, settimeout)
def connect(self, url, **options):
"""
Connect to url. url is websocket url scheme. ie. ws://host:port/resource
You can customize using 'options'.
If you set "header" dict object, you can set your own custom header.
>>> ws = WebSocket()
>>> ws.connect("ws://echo.websocket.org/",
... header={"User-Agent: MyProgram",
... "x-custom: header"})
timeout: socket timeout time. This value is integer.
if you set None for this value,
it means "use default_timeout value"
options: current support option is only "header".
if you set header as dict value,
the custom HTTP headers are added.
"""
hostname, port, resource, is_secure = _parse_url(url)
# TODO: we need to support proxy
self.sock.connect((hostname, port))
if is_secure:
if HAVE_SSL:
if self.sslopt is None:
sslopt = {}
else:
sslopt = self.sslopt
self.sock = ssl.wrap_socket(self.sock, **sslopt)
else:
raise WebSocketException("SSL not available.")
self._handshake(hostname, port, resource, **options)
def _handshake(self, host, port, resource, **options):
sock = self.sock
headers = []
headers.append("GET %s HTTP/1.1" % resource)
headers.append("Upgrade: websocket")
headers.append("Connection: Upgrade")
if port == 80:
hostport = host
else:
hostport = "%s:%d" % (host, port)
headers.append("Host: %s" % hostport)
if "origin" in options:
headers.append("Origin: %s" % options["origin"])
else:
headers.append("Origin: http://%s" % hostport)
key = _create_sec_websocket_key()
headers.append("Sec-WebSocket-Key: %s" % key)
headers.append("Sec-WebSocket-Version: %s" % VERSION)
if "header" in options:
headers.extend(options["header"])
headers.append("")
headers.append("")
header_str = "\r\n".join(headers)
self._send(header_str)
logger.debug("--- request header ---")
logger.debug(header_str)
logger.debug("-----------------------")
status, resp_headers = self._read_headers()
if status != 101:
self.close()
raise WebSocketException("Handshake Status %d" % status)
success = self._validate_header(resp_headers, key)
if not success:
self.close()
raise WebSocketException("Invalid WebSocket Header")
self.connected = True
def _validate_header(self, headers, key):
for k, v in _HEADERS_TO_CHECK.iteritems():
r = headers.get(k, None)
if not r:
return False
r = r.lower()
if v != r:
return False
result = headers.get("sec-websocket-accept", None)
if not result:
return False
result = result.lower()
value = key + "258EAFA5-E914-47DA-95CA-C5AB0DC85B11"
hashed = base64.encodestring(hashlib.sha1(value).digest()).strip().lower()
return hashed == result
def _read_headers(self):
status = None
headers = {}
logger.debug("--- response header ---")
while True:
line = self._recv_line()
if line == "\r\n":
break
line = line.strip()
logger.debug(line)
if not status:
status_info = line.split(" ", 2)
status = int(status_info[1])
else:
kv = line.split(":", 1)
if len(kv) == 2:
key, value = kv
headers[key.lower()] = value.strip().lower()
else:
raise WebSocketException("Invalid header")
logger.debug("-----------------------")
return status, headers
def send(self, payload, opcode=ABNF.OPCODE_TEXT):
"""
Send the data as string.
payload: Payload must be utf-8 string or unicoce,
if the opcode is OPCODE_TEXT.
Otherwise, it must be string(byte array)
opcode: operation code to send. Please see OPCODE_XXX.
"""
frame = ABNF.create_frame(payload, opcode)
if self.get_mask_key:
frame.get_mask_key = self.get_mask_key
data = frame.format()
length = len(data)
logger.debug("send: " + repr(data))
while data:
l = self._send(data)
data = data[l:]
return length
def send_binary(self, payload):
return self.send(payload, ABNF.OPCODE_BINARY)
def ping(self, payload=""):
"""
send ping data.
payload: data payload to send server.
"""
self.send(payload, ABNF.OPCODE_PING)
def pong(self, payload):
"""
send pong data.
payload: data payload to send server.
"""
self.send(payload, ABNF.OPCODE_PONG)
def recv(self):
"""
Receive string data(byte array) from the server.
return value: string(byte array) value.
"""
opcode, data = self.recv_data()
return data
def recv_data(self):
"""
Recieve data with operation code.
return value: tuple of operation code and string(byte array) value.
"""
while True:
frame = self.recv_frame()
if not frame:
# handle error:
# 'NoneType' object has no attribute 'opcode'
raise WebSocketException("Not a valid frame %s" % frame)
elif frame.opcode in (ABNF.OPCODE_TEXT, ABNF.OPCODE_BINARY, ABNF.OPCODE_CONT):
if frame.opcode == ABNF.OPCODE_CONT and not self._cont_data:
raise WebSocketException("Illegal frame")
if self._cont_data:
self._cont_data[1] += frame.data
else:
self._cont_data = [frame.opcode, frame.data]
if frame.fin:
data = self._cont_data
self._cont_data = None
return data
elif frame.opcode == ABNF.OPCODE_CLOSE:
self.send_close()
return (frame.opcode, None)
elif frame.opcode == ABNF.OPCODE_PING:
self.pong(frame.data)
def recv_frame(self):
"""
recieve data as frame from server.
return value: ABNF frame object.
"""
# Header
if self._frame_header is None:
self._frame_header = self._recv_strict(2)
b1 = ord(self._frame_header[0])
fin = b1 >> 7 & 1
rsv1 = b1 >> 6 & 1
rsv2 = b1 >> 5 & 1
rsv3 = b1 >> 4 & 1
opcode = b1 & 0xf
b2 = ord(self._frame_header[1])
has_mask = b2 >> 7 & 1
# Frame length
if self._frame_length is None:
length_bits = b2 & 0x7f
if length_bits == 0x7e:
length_data = self._recv_strict(2)
self._frame_length = struct.unpack("!H", length_data)[0]
elif length_bits == 0x7f:
length_data = self._recv_strict(8)
self._frame_length = struct.unpack("!Q", length_data)[0]
else:
self._frame_length = length_bits
# Mask
if self._frame_mask is None:
self._frame_mask = self._recv_strict(4) if has_mask else ""
# Payload
payload = self._recv_strict(self._frame_length)
if has_mask:
payload = ABNF.mask(self._frame_mask, payload)
# Reset for next frame
self._frame_header = None
self._frame_length = None
self._frame_mask = None
return ABNF(fin, rsv1, rsv2, rsv3, opcode, has_mask, payload)
def send_close(self, status=STATUS_NORMAL, reason=""):
"""
send close data to the server.
status: status code to send. see STATUS_XXX.
reason: the reason to close. This must be string.
"""
if status < 0 or status >= ABNF.LENGTH_16:
raise ValueError("code is invalid range")
self.send(struct.pack('!H', status) + reason, ABNF.OPCODE_CLOSE)
def close(self, status=STATUS_NORMAL, reason=""):
"""
Close Websocket object
status: status code to send. see STATUS_XXX.
reason: the reason to close. This must be string.
"""
try:
self.sock.shutdown(socket.SHUT_RDWR)
except:
pass
'''
if self.connected:
if status < 0 or status >= ABNF.LENGTH_16:
raise ValueError("code is invalid range")
try:
self.send(struct.pack('!H', status) + reason, ABNF.OPCODE_CLOSE)
timeout = self.sock.gettimeout()
self.sock.settimeout(3)
try:
frame = self.recv_frame()
if logger.isEnabledFor(logging.ERROR):
recv_status = struct.unpack("!H", frame.data)[0]
if recv_status != STATUS_NORMAL:
logger.error("close status: " + repr(recv_status))
except:
pass
self.sock.settimeout(timeout)
print("SHUTDOWN ON SOCKET CALLED")
self.sock.shutdown(socket.SHUT_RDWR)
except:
pass
'''
self._closeInternal()
def _closeInternal(self):
self.connected = False
self.sock.close()
def _send(self, data):
try:
return self.sock.send(data)
except socket.timeout as e:
raise WebSocketTimeoutException(e.args[0])
except Exception as e:
if "timed out" in e.args[0]:
raise WebSocketTimeoutException(e.args[0])
else:
raise e
def _recv(self, bufsize):
try:
bytes = self.sock.recv(bufsize)
except socket.timeout as e:
raise WebSocketTimeoutException(e.args[0])
except SSLError as e:
if e.args[0] == "The read operation timed out":
raise WebSocketTimeoutException(e.args[0])
else:
raise
if not bytes:
raise WebSocketConnectionClosedException()
return bytes
def _recv_strict(self, bufsize):
shortage = bufsize - sum(len(x) for x in self._recv_buffer)
while shortage > 0:
bytes = self._recv(shortage)
self._recv_buffer.append(bytes)
shortage -= len(bytes)
unified = "".join(self._recv_buffer)
if shortage == 0:
self._recv_buffer = []
return unified
else:
self._recv_buffer = [unified[bufsize:]]
return unified[:bufsize]
def _recv_line(self):
line = []
while True:
c = self._recv(1)
line.append(c)
if c == "\n":
break
return "".join(line)
class WebSocketApp(object):
"""
Higher level of APIs are provided.
The interface is like JavaScript WebSocket object.
"""
def __init__(self, url, header=[],
on_open=None, on_message=None, on_error=None,
on_close=None, keep_running=True, get_mask_key=None):
"""
url: websocket url.
header: custom header for websocket handshake.
on_open: callable object which is called at opening websocket.
this function has one argument. The arugment is this class object.
on_message: callbale object which is called when recieved data.
on_message has 2 arguments.
The 1st arugment is this class object.
The passing 2nd arugment is utf-8 string which we get from the server.
on_error: callable object which is called when we get error.
on_error has 2 arguments.
The 1st arugment is this class object.
The passing 2nd arugment is exception object.
on_close: callable object which is called when closed the connection.
this function has one argument. The arugment is this class object.
keep_running: a boolean flag indicating whether the app's main loop should
keep running, defaults to True
get_mask_key: a callable to produce new mask keys, see the WebSocket.set_mask_key's
docstring for more information
"""
self.url = url
self.header = header
self.on_open = on_open
self.on_message = on_message
self.on_error = on_error
self.on_close = on_close
self.keep_running = keep_running
self.get_mask_key = get_mask_key
self.sock = None
self.timout = 30
def setTimeout(self, to):
self.timout = to
def send(self, data, opcode=ABNF.OPCODE_TEXT):
"""
send message.
data: message to send. If you set opcode to OPCODE_TEXT, data must be utf-8 string or unicode.
opcode: operation code of data. default is OPCODE_TEXT.
"""
if self.sock.send(data, opcode) == 0:
raise WebSocketConnectionClosedException()
def close(self):
"""
close websocket connection.
"""
self.keep_running = False
if(self.sock != None):
self.sock.close()
def _send_ping(self, interval):
while True:
for i in range(interval):
time.sleep(1)
if not self.keep_running:
return
self.sock.ping()
def run_forever(self, sockopt=None, sslopt=None, ping_interval=0):
"""
run event loop for WebSocket framework.
This loop is infinite loop and is alive during websocket is available.
sockopt: values for socket.setsockopt.
sockopt must be tuple and each element is argument of sock.setscokopt.
sslopt: ssl socket optional dict.
ping_interval: automatically send "ping" command every specified period(second)
if set to 0, not send automatically.
"""
if sockopt is None:
sockopt = []
if sslopt is None:
sslopt = {}
if self.sock:
raise WebSocketException("socket is already opened")
thread = None
try:
self.sock = WebSocket(self.get_mask_key, sockopt=sockopt, sslopt=sslopt)
self.sock.settimeout(self.timout)
self.sock.connect(self.url, header=self.header)
self._callback(self.on_open)
if ping_interval:
thread = threading.Thread(target=self._send_ping, args=(ping_interval,))
thread.setDaemon(True)
thread.start()
while self.keep_running:
try:
data = self.sock.recv()
if data is None or self.keep_running == False:
break
self._callback(self.on_message, data)
except Exception, e:
#print str(e.args[0])
if "timed out" not in e.args[0]:
raise e
except Exception, e:
self._callback(self.on_error, e)
finally:
if thread:
self.keep_running = False
self.sock.close()
self._callback(self.on_close)
self.sock = None
def _callback(self, callback, *args):
if callback:
try:
callback(self, *args)
except Exception, e:
logger.error(e)
if logger.getLevel() == 2:
_, _, tb = sys.exc_info()
traceback.print_tb(tb)
if __name__ == "__main__":
ws = create_connection("ws://echo.websocket.org/")
print("Sending 'Hello, World'...")
ws.send("Hello, World")
print("Sent")
print("Receiving...")
result = ws.recv()
print("Received '%s'" % result)
ws.close()

246
resources/lib/websocketclient.py
View File

@@ -1,246 +0,0 @@
# Gnu General Public License - see LICENSE.TXT
import xbmc
import xbmcgui
import xbmcaddon
import json
import threading
import websocket
import time
from clientinfo import ClientInformation
from downloadutils import DownloadUtils
from simple_logging import SimpleLogging
from utils import PlayUtils
downloadUtils = DownloadUtils()
log = SimpleLogging("EmbyCon." + __name__)
class WebSocketThread(threading.Thread):
client = None
keepRunning = True
def __init__(self, *args):
log.info("EmbyCon WebSocketThread")
threading.Thread.__init__(self, *args)
def playbackStarted(self, itemId):
if(self.client != None):
try:
log.info("Sending Playback Started")
messageData = {}
messageData["MessageType"] = "PlaybackStart"
messageData["Data"] = itemId + "|true|audio,video"
messageString = json.dumps(messageData)
log.info("Message Data : " + messageString)
self.client.send(messageString)
except Exception, e:
log.debug("Exception : " + str(e))
else:
log.info("Sending Playback Started NO Object ERROR")
def playbackStopped(self, itemId, ticks):
if(self.client != None):
try:
log.info("Sending Playback Stopped : " + str(ticks))
messageData = {}
messageData["MessageType"] = "PlaybackStopped"
messageData["Data"] = itemId + "|" + str(ticks)
messageString = json.dumps(messageData)
self.client.send(messageString)
except Exception, e:
log.error("Exception : " + str(e))
else:
log.info("Sending Playback Stopped NO Object ERROR")
def sendProgressUpdate(self, itemId, ticks):
if(self.client != None):
try:
log.info("Sending Progress Update : " + str(ticks))
messageData = {}
messageData["MessageType"] = "PlaybackProgress"
messageData["Data"] = itemId + "|" + str(ticks) + "|false|false"
messageString = json.dumps(messageData)
log.info("Message Data : " + messageString)
self.client.send(messageString)
except Exception, e:
log.error("Exception : " + str(e))
else:
log.info("Sending Progress Update NO Object ERROR")
def stopClient(self):
# stopping the client is tricky, first set keep_running to false and then trigger one
# more message by requesting one SessionsStart message, this causes the
# client to receive the message and then exit
if(self.client != None):
log.info("Stopping Client")
self.keepRunning = False
self.client.keep_running = False
self.client.close()
log.info("Stopping Client : KeepRunning set to False")
'''
try:
self.keepRunning = False
self.client.keep_running = False
log.debug("Stopping Client")
log.debug("Calling Ping")
self.client.sock.ping()
log.debug("Calling Socket Shutdown()")
self.client.sock.sock.shutdown(socket.SHUT_RDWR)
log.debug("Calling Socket Close()")
self.client.sock.sock.close()
log.debug("Stopping Client Done")
log.debug("Calling Ping")
self.client.sock.ping()
except Exception, e:
log.debug("Exception : " + str(e))
'''
else:
log.info("Stopping Client NO Object ERROR")
def on_message(self, ws, message):
log.info("Message : " + str(message))
result = json.loads(message)
messageType = result.get("MessageType")
data = result.get("Data")
if(messageType != None and messageType == "Play" and data != None):
itemIds = data.get("ItemIds")
playCommand = data.get("PlayCommand")
if(playCommand != None and playCommand == "PlayNow"):
startPositionTicks = data.get("StartPositionTicks")
log.info("Playing Media With ID : " + itemIds[0])
log.info("StartPositionTicks : " + str(startPositionTicks))
item_id = itemIds[0]
auto_resume = "0"
if (startPositionTicks is not None):
auto_resume = str(startPositionTicks)
playUrl = "plugin://plugin.video.embycon/?item_id=" + item_id + "&auto_resume=" + auto_resume + "&mode=PLAY"
xbmc.Player().play(playUrl)
elif(messageType != None and messageType == "Playstate"):
command = data.get("Command")
if(command != None and command == "Stop"):
log.info("Playback Stopped")
xbmc.executebuiltin('xbmc.activatewindow(10000)')
xbmc.Player().stop()
if(command != None and command == "Seek"):
seekPositionTicks = data.get("SeekPositionTicks")
log.info("Playback Seek : " + str(seekPositionTicks))
seekTime = (seekPositionTicks / 1000) / 10000
xbmc.Player().seekTime(seekTime)
def on_error(self, ws, error):
log.info("Error : " + str(error))
def on_close(self, ws):
log.info("Closed")
def on_open(self, ws):
try:
clientInfo = ClientInformation()
machineId = clientInfo.getDeviceId()
version = clientInfo.getVersion()
client = clientInfo.getClient()
messageData = {}
messageData["MessageType"] = "Identity"
addonSettings = xbmcaddon.Addon(id='plugin.video.embycon')
deviceName = addonSettings.getSetting('deviceName')
deviceName = deviceName.replace("\"", "_")
messageData["Data"] = client + "|" + machineId + "|" + version + "|" + deviceName
messageString = json.dumps(messageData)
log.info("Opened : " + str(messageString))
ws.send(messageString)
downloadUtils = DownloadUtils()
# get session ID
addonSettings = xbmcaddon.Addon(id='plugin.video.embycon')
mb3Host = addonSettings.getSetting('ipaddress')
mb3Port = addonSettings.getSetting('port')
url = "http://" + mb3Host + ":" + mb3Port + "/emby/Sessions?DeviceId=" + machineId + "&format=json"
log.info("Session URL : " + url)
jsonData = downloadUtils.downloadUrl(url)
log.info("Session JsonData : " + jsonData)
result = json.loads(jsonData)
log.info("Session JsonData : " + str(result))
sessionId = result[0].get("Id")
log.info("Session Id : " + str(sessionId))
url = "http://" + mb3Host + ":" + mb3Port + "/emby/Sessions/Capabilities?Id=" + sessionId + "&PlayableMediaTypes=Video&SupportedCommands=Play&SupportsMediaControl=True"
postData = {}
postData["Id"] = sessionId
postData["PlayableMediaTypes"] = "Video"
stringdata = json.dumps(postData)
log.info("Capabilities URL : " + url)
log.info("Capabilities Data : " + stringdata)
downloadUtils.downloadUrl(url, postBody=stringdata, type="POST")
except Exception, e:
log.error("Exception : " + str(e))
def run(self):
while(self.keepRunning and xbmc.abortRequested == False):
addonSettings = xbmcaddon.Addon(id='plugin.video.embycon')
mb3Host = addonSettings.getSetting('ipaddress')
mb3Port = addonSettings.getSetting('port')
if(mb3Host != None and len(mb3Host) > 0):
try:
wsPort = mb3Port
log.info("WebSocketPortNumber = " + str(wsPort))
downloadUtils = DownloadUtils()
authHeaders = downloadUtils.getAuthHeader()
flatHeaders = []
for header in authHeaders:
flatHeaders.append(header + ": " + authHeaders[header])
log.info("Flat Header : " + str(flatHeaders))
# Make a call to /System/Info. WebSocketPortNumber is the port hosting the web socket.
webSocketUrl = "ws://" + mb3Host + ":" + str(wsPort)
log.info("WebSocket URL : " + webSocketUrl)
self.client = websocket.WebSocketApp(webSocketUrl,
header = flatHeaders,
on_message = self.on_message,
on_error = self.on_error,
on_close = self.on_close)
self.client.on_open = self.on_open
self.client.setTimeout(10)
log.info("Client Starting")
if(self.keepRunning):
self.client.run_forever(ping_interval=10)
except:
log.info("Error thrown in Web Socket Setup")
if(self.keepRunning and xbmc.abortRequested == False):
log.info("Client Needs To Restart")
xbmc.sleep(5000)
log.info("Thread Exited")

165
service.py
View File

@@ -3,19 +3,19 @@
import xbmc
import xbmcgui
import xbmcaddon
import time
from datetime import datetime
from resources.lib.websocketclient import WebSocketThread
from resources.lib.downloadutils import DownloadUtils
from resources.lib.simple_logging import SimpleLogging
from resources.lib.play_utils import playFile
# clear user and token when logging in
WINDOW = xbmcgui.Window(10000)
WINDOW.clearProperty("userid")
WINDOW.clearProperty("AccessToken")
WINDOW.clearProperty("EmbyConParams")
home_window = xbmcgui.Window(10000)
home_window.clearProperty("userid")
home_window.clearProperty("AccessToken")
home_window.clearProperty("EmbyConParams")
log = SimpleLogging("EmbyCon.service")
download_utils = DownloadUtils()
@@ -26,17 +26,54 @@ try:
except Exception, e:
pass
websocket_thread = WebSocketThread()
websocket_thread.setDaemon(True)
websocket_thread.start()
def hasData(data):
if data is None or len(data) == 0 or data == "None":
return False
else:
return True
def sendProgress():
playing_file = xbmc.Player().getPlayingFile()
play_data = monitor.played_information.get(playing_file)
if play_data is None:
return
log.info("Sending Progress Update")
play_time = xbmc.Player().getTime()
play_data["currentPossition"] = play_time
item_id = play_data.get("item_id")
if item_id is None:
return
ticks = int(play_time * 10000000)
paused = play_data.get("paused", False)
playback_type = play_data.get("playback_type")
postdata = {
'QueueableMediaTypes': "Video",
'CanSeek': True,
'ItemId': item_id,
'MediaSourceId': item_id,
'PositionTicks': ticks,
'IsPaused': paused,
'IsMuted': False,
'PlayMethod': playback_type
}
log.debug("Sending POST progress started: %s." % postdata)
settings = xbmcaddon.Addon(id='plugin.video.embycon')
port = settings.getSetting('port')
host = settings.getSetting('ipaddress')
server = host + ":" + port
url = "http://" + server + "/emby/Sessions/Playing/Progress"
download_utils.downloadUrl(url, postBody=postdata, type="POST")
def stopAll(played_information):
@@ -56,8 +93,20 @@ def stopAll(played_information):
if hasData(emby_item_id):
log.info("Playback Stopped at: " + str(int(current_possition * 10000000)))
websocket_thread.playbackStopped(emby_item_id, str(int(current_possition * 10000000)))
settings = xbmcaddon.Addon(id='plugin.video.embycon')
port = settings.getSetting('port')
host = settings.getSetting('ipaddress')
server = host + ":" + port
url = "http://" + server + "/emby/Sessions/Playing/Stopped"
postdata = {
'ItemId': emby_item_id,
'MediaSourceId': emby_item_id,
'PositionTicks': int(current_possition * 10000000)
}
download_utils.downloadUrl(url, postBody=postdata, type="POST")
played_information.clear()
@@ -79,57 +128,90 @@ class Service(xbmc.Player):
window_handle = xbmcgui.Window(10000)
emby_item_id = window_handle.getProperty("item_id")
playback_type = window_handle.getProperty("PlaybackType_" + emby_item_id)
# if we could not find the ID of the current item then return
if emby_item_id is None or len(emby_item_id) == 0:
return
websocket_thread.playbackStarted(emby_item_id)
log.info("Sending Playback Started")
postdata = {
'QueueableMediaTypes': "Video",
'CanSeek': True,
'ItemId': emby_item_id,
'MediaSourceId': emby_item_id,
'PlayMethod': playback_type
}
log.debug("Sending POST play started: %s." % postdata)
settings = xbmcaddon.Addon(id='plugin.video.embycon')
port = settings.getSetting('port')
host = settings.getSetting('ipaddress')
server = host + ":" + port
url = "http://" + server + "/emby/Sessions/Playing"
download_utils.downloadUrl(url, postBody=postdata, type="POST")
data = {}
data["item_id"] = emby_item_id
data["paused"] = False
data["playback_type"] = playback_type
self.played_information[current_playing_file] = data
log.info("ADDING_FILE : " + current_playing_file)
log.info("ADDING_FILE : " + str(self.played_information))
def onPlayBackEnded(self):
# Will be called when xbmc stops playing a file
# Will be called when kodi stops playing a file
log.info("EmbyCon Service -> onPlayBackEnded")
stopAll(self.played_information)
def onPlayBackStopped(self):
# Will be called when user stops xbmc playing a file
# Will be called when user stops kodi playing a file
log.info("onPlayBackStopped")
stopAll(self.played_information)
def onPlayBackPaused(self):
# Will be called when kodi pauses the video
log.info("onPlayBackPaused")
current_file = xbmc.Player().getPlayingFile()
play_data = monitor.played_information.get(current_file)
if play_data is not None:
play_data['paused'] = True
sendProgress()
def onPlayBackResumed(self):
# Will be called when kodi resumes the video
log.info("onPlayBackResumed")
current_file = xbmc.Player().getPlayingFile()
play_data = monitor.played_information.get(current_file)
if play_data is not None:
play_data['paused'] = False
sendProgress()
def onPlayBackSeek(self, time, seekOffset):
# Will be called when kodi seeks in video
log.info("onPlayBackSeek")
sendProgress()
monitor = Service()
last_progress_update = datetime.today()
while not xbmc.abortRequested:
window_handle = xbmcgui.Window(10000)
home_window = xbmcgui.Window(10000)
if xbmc.Player().isPlaying():
try:
# send update
td = datetime.today() - last_progress_update
sec_diff = td.seconds
if sec_diff > 5:
play_time = xbmc.Player().getTime()
current_file = xbmc.Player().getPlayingFile()
if monitor.played_information.get(current_file) is not None:
monitor.played_information[current_file]["currentPossition"] = play_time
if (monitor.played_information.get(current_file) is not None and
monitor.played_information.get(current_file).get("item_id") is not None):
item_id = monitor.played_information.get(current_file).get("item_id")
websocket_thread.sendProgressUpdate(item_id, str(int(play_time * 10000000)))
if sec_diff > 10:
sendProgress()
last_progress_update = datetime.today()
except Exception, e:
@@ -137,23 +219,20 @@ while not xbmc.abortRequested:
pass
else:
emby_item_id = window_handle.getProperty("play_item_id")
emby_item_resume = window_handle.getProperty("play_item_resume")
emby_item_id = home_window.getProperty("play_item_id")
emby_item_resume = home_window.getProperty("play_item_resume")
if emby_item_id and emby_item_resume:
window_handle.clearProperty("play_item_id")
window_handle.clearProperty("play_item_resume")
home_window.clearProperty("play_item_id")
home_window.clearProperty("play_item_resume")
playFile(emby_item_id, emby_item_resume)
xbmc.sleep(1000)
xbmcgui.Window(10000).setProperty("EmbyCon_Service_Timestamp", str(int(time.time())))
# clear user and token when loggin off
WINDOW = xbmcgui.Window(10000)
WINDOW.clearProperty("userid")
WINDOW.clearProperty("AccessToken")
WINDOW.clearProperty("EmbyConParams")
# stop the WebSocket client
websocket_thread.stopClient()
home_window = xbmcgui.Window(10000)
home_window.clearProperty("userid")
home_window.clearProperty("AccessToken")
home_window.clearProperty("EmbyConParams")
log.info("Service shutting down")