N3MIS15/websock.html

## websock.html
<!DOCTYPE html>
<html>
  <head>
    <meta charset="UTF-8">
    <script src="http://code.jquery.com/jquery-1.8.3.min.js"></script>
    <title>XBMC Remote</title>
  </head>

  <body>
    <h2>XBMC remote</h2>

    <script>
      var ws = new WebSocket('ws://127.0.0.1:9999');

      ws.onopen = function(){
        console.log('Connected to websocket');
        ws.send('jquery connected');
      };

      ws.onmessage = function(msg){
        console.log(msg);
      };

      ws.onclose = function(){
        console.log('Disconnected from websocket');
      };

      $(document).on('keydown', 'body', function(e){
        e.preventDefault();
        var char = '';
        var keyCodeMap = {8:"backspace", 9:"tab", 13:"return", 16:"shift", 17:"ctrl", 18:"alt", 19:"pausebreak", 20:"capslock", 27:"escape", 32:"space",
            33:"pageup", 34:"pagedown", 35:"end", 36:"home", 37:"left", 38:"up", 39:"right", 40:"down", 43:"plus", 44:"printscreen", 45:"insert", 46:"delete",
            48:"0", 49:"1", 50:"2", 51:"3", 52:"4", 53:"5", 54:"6", 55:"7", 56:"8", 57:"9", 59:"semicolon", 61:"plus", 65:"a", 66:"b", 67:"c", 68:"d", 69:"e",
            70:"f", 71:"g", 72:"h", 73:"i", 74:"j", 75:"k", 76:"l", 77:"m", 78:"n", 79:"o", 80:"p", 81:"q", 82:"r", 83:"s", 84:"t", 85:"u", 86:"v", 87:"w",
            88:"x", 89:"y", 90:"z", 96:"0", 97:"1", 98:"2", 99:"3", 100:"4", 101:"5", 102:"6", 103:"7", 104:"8", 105:"9", 106: "*", 107:"plus", 109:"minus",
            110:"period", 111: "forwardslash", 112:"f1", 113:"f2", 114:"f3", 115:"f4", 116:"f5", 117:"f6", 118:"f7", 119:"f8", 120:"f9", 121:"f10", 122:"f11",
            123:"f12", 144:"numlock", 145:"scrolllock", 186:"semicolon", 187:"plus", 188:"comma", 189:"minus", 190:"period", 191:"forwardslash", 192:"tilde",
            219:"openbracket", 220:"backslash", 221:"closebracket", 222:"singlequote"};
        if (e.which === null){
          char = String.fromCharCode(e.keyCode); // old IE
        } else {
          char = keyCodeMap[e.which];
        }
        console.log('sending '+char);
        ws.send(char);
      });
    </script>
  </body>
</html>

## websock.py
import struct
import SocketServer

from base64 import b64encode
from hashlib import sha1
from mimetools import Message
from StringIO import StringIO

from xbmcclient import XBMCClient
xbmc_host = '127.0.0.1'


class WebSocketsHandler(SocketServer.StreamRequestHandler):
    magic = '258EAFA5-E914-47DA-95CA-C5AB0DC85B11'

    def setup(self):
        SocketServer.StreamRequestHandler.setup(self)
        print "connection established", self.client_address
        self.handshake_done = False

    def handle(self):
        while True:
            if not self.handshake_done:
                self.handshake()
            else:
                self.read_next_message()

    def read_next_message(self):
        length = ord(self.rfile.read(2)[1]) & 127
        if length == 126:
            length = struct.unpack(">H", self.rfile.read(2))[0]
        elif length == 127:
            length = struct.unpack(">Q", self.rfile.read(8))[0]
        masks = [ord(byte) for byte in self.rfile.read(4)]
        decoded = ""
        for char in self.rfile.read(length):
            decoded += chr(ord(char) ^ masks[len(decoded) % 4])
        self.on_message(decoded)

    def send_message(self, message):
        self.request.send(chr(129))
        length = len(message)
        if length <= 125:
            self.request.send(chr(length))
        elif length >= 126 and length <= 65535:
            self.request.send(126)
            self.request.send(struct.pack(">H", length))
        else:
            self.request.send(127)
            self.request.send(struct.pack(">Q", length))
        self.request.send(message)

    def handshake(self):
        data = self.request.recv(1024).strip()
        headers = Message(StringIO(data.split('\r\n', 1)[1]))
        if headers.get("Upgrade", None) != "websocket":
            return
        print 'Handshaking...'
        key = headers['Sec-WebSocket-Key']
        digest = b64encode(sha1(key + self.magic).hexdigest().decode('hex'))
        response = 'HTTP/1.1 101 Switching Protocols\r\n'
        response += 'Upgrade: websocket\r\n'
        response += 'Connection: Upgrade\r\n'
        response += 'Sec-WebSocket-Accept: %s\r\n\r\n' % digest
        self.handshake_done = self.request.send(response)

        ### XBMC ###
        self.xbmc = XBMCClient('Websocket Test', ip=xbmc_host)

    def on_message(self, message):
        print message
        self.xbmc.send_button(map='KB', button=message, amount=1)
        self.xbmc.release_button()


if __name__ == "__main__":
    server = SocketServer.TCPServer(("127.0.0.1", 9999), WebSocketsHandler)
    server.serve_forever()
	<!DOCTYPE html>
	<html>
	<head>
	<meta charset="UTF-8">
	<script src="http://code.jquery.com/jquery-1.8.3.min.js"></script>
	<title>XBMC Remote</title>
	</head>

	<body>
	<h2>XBMC remote</h2>

	<script>
	var ws = new WebSocket('ws://127.0.0.1:9999');

	ws.onopen = function(){
	console.log('Connected to websocket');
	ws.send('jquery connected');
	};

	ws.onmessage = function(msg){
	console.log(msg);
	};

	ws.onclose = function(){
	console.log('Disconnected from websocket');
	};

	$(document).on('keydown', 'body', function(e){
	e.preventDefault();
	var char = '';
	var keyCodeMap = {8:"backspace", 9:"tab", 13:"return", 16:"shift", 17:"ctrl", 18:"alt", 19:"pausebreak", 20:"capslock", 27:"escape", 32:"space",
	33:"pageup", 34:"pagedown", 35:"end", 36:"home", 37:"left", 38:"up", 39:"right", 40:"down", 43:"plus", 44:"printscreen", 45:"insert", 46:"delete",
	48:"0", 49:"1", 50:"2", 51:"3", 52:"4", 53:"5", 54:"6", 55:"7", 56:"8", 57:"9", 59:"semicolon", 61:"plus", 65:"a", 66:"b", 67:"c", 68:"d", 69:"e",
	70:"f", 71:"g", 72:"h", 73:"i", 74:"j", 75:"k", 76:"l", 77:"m", 78:"n", 79:"o", 80:"p", 81:"q", 82:"r", 83:"s", 84:"t", 85:"u", 86:"v", 87:"w",
	88:"x", 89:"y", 90:"z", 96:"0", 97:"1", 98:"2", 99:"3", 100:"4", 101:"5", 102:"6", 103:"7", 104:"8", 105:"9", 106: "*", 107:"plus", 109:"minus",
	110:"period", 111: "forwardslash", 112:"f1", 113:"f2", 114:"f3", 115:"f4", 116:"f5", 117:"f6", 118:"f7", 119:"f8", 120:"f9", 121:"f10", 122:"f11",
	123:"f12", 144:"numlock", 145:"scrolllock", 186:"semicolon", 187:"plus", 188:"comma", 189:"minus", 190:"period", 191:"forwardslash", 192:"tilde",
	219:"openbracket", 220:"backslash", 221:"closebracket", 222:"singlequote"};
	if (e.which === null){
	char = String.fromCharCode(e.keyCode); // old IE
	} else {
	char = keyCodeMap[e.which];
	}
	console.log('sending '+char);
	ws.send(char);
	});
	</script>
	</body>
	</html>
	import struct
	import SocketServer

	from base64 import b64encode
	from hashlib import sha1
	from mimetools import Message
	from StringIO import StringIO

	from xbmcclient import XBMCClient
	xbmc_host = '127.0.0.1'


	class WebSocketsHandler(SocketServer.StreamRequestHandler):
	magic = '258EAFA5-E914-47DA-95CA-C5AB0DC85B11'

	def setup(self):
	SocketServer.StreamRequestHandler.setup(self)
	print "connection established", self.client_address
	self.handshake_done = False

	def handle(self):
	while True:
	if not self.handshake_done:
	self.handshake()
	else:
	self.read_next_message()

	def read_next_message(self):
	length = ord(self.rfile.read(2)[1]) & 127
	if length == 126:
	length = struct.unpack(">H", self.rfile.read(2))[0]
	elif length == 127:
	length = struct.unpack(">Q", self.rfile.read(8))[0]
	masks = [ord(byte) for byte in self.rfile.read(4)]
	decoded = ""
	for char in self.rfile.read(length):
	decoded += chr(ord(char) ^ masks[len(decoded) % 4])
	self.on_message(decoded)

	def send_message(self, message):
	self.request.send(chr(129))
	length = len(message)
	if length <= 125:
	self.request.send(chr(length))
	elif length >= 126 and length <= 65535:
	self.request.send(126)
	self.request.send(struct.pack(">H", length))
	else:
	self.request.send(127)
	self.request.send(struct.pack(">Q", length))
	self.request.send(message)

	def handshake(self):
	data = self.request.recv(1024).strip()
	headers = Message(StringIO(data.split('\r\n', 1)[1]))
	if headers.get("Upgrade", None) != "websocket":
	return
	print 'Handshaking...'
	key = headers['Sec-WebSocket-Key']
	digest = b64encode(sha1(key + self.magic).hexdigest().decode('hex'))
	response = 'HTTP/1.1 101 Switching Protocols\r\n'
	response += 'Upgrade: websocket\r\n'
	response += 'Connection: Upgrade\r\n'
	response += 'Sec-WebSocket-Accept: %s\r\n\r\n' % digest
	self.handshake_done = self.request.send(response)

	### XBMC ###
	self.xbmc = XBMCClient('Websocket Test', ip=xbmc_host)

	def on_message(self, message):
	print message
	self.xbmc.send_button(map='KB', button=message, amount=1)
	self.xbmc.release_button()


	if __name__ == "__main__":
	server = SocketServer.TCPServer(("127.0.0.1", 9999), WebSocketsHandler)
	server.serve_forever()