forked from xuos/xiuos
75 lines
1.6 KiB
Python
75 lines
1.6 KiB
Python
import sys
|
|
try:
|
|
import ubinascii as binascii
|
|
except:
|
|
import binascii
|
|
try:
|
|
import uhashlib as hashlib
|
|
except:
|
|
import hashlib
|
|
|
|
DEBUG = 0
|
|
|
|
def server_handshake(sock):
|
|
clr = sock.makefile("rwb", 0)
|
|
l = clr.readline()
|
|
#sys.stdout.write(repr(l))
|
|
|
|
webkey = None
|
|
|
|
while 1:
|
|
l = clr.readline()
|
|
if not l:
|
|
raise OSError("EOF in headers")
|
|
if l == b"\r\n":
|
|
break
|
|
# sys.stdout.write(l)
|
|
h, v = [x.strip() for x in l.split(b":", 1)]
|
|
if DEBUG:
|
|
print((h, v))
|
|
if h == b'Sec-WebSocket-Key':
|
|
webkey = v
|
|
|
|
if not webkey:
|
|
raise OSError("Not a websocket request")
|
|
|
|
if DEBUG:
|
|
print("Sec-WebSocket-Key:", webkey, len(webkey))
|
|
|
|
d = hashlib.sha1(webkey)
|
|
d.update(b"258EAFA5-E914-47DA-95CA-C5AB0DC85B11")
|
|
respkey = d.digest()
|
|
respkey = binascii.b2a_base64(respkey)[:-1]
|
|
if DEBUG:
|
|
print("respkey:", respkey)
|
|
|
|
sock.send(b"""\
|
|
HTTP/1.1 101 Switching Protocols\r
|
|
Upgrade: websocket\r
|
|
Connection: Upgrade\r
|
|
Sec-WebSocket-Accept: """)
|
|
sock.send(respkey)
|
|
sock.send("\r\n\r\n")
|
|
|
|
|
|
# Very simplified client handshake, works for MicroPython's
|
|
# websocket server implementation, but probably not for other
|
|
# servers.
|
|
def client_handshake(sock):
|
|
cl = sock.makefile("rwb", 0)
|
|
cl.write(b"""\
|
|
GET / HTTP/1.1\r
|
|
Host: echo.websocket.org\r
|
|
Connection: Upgrade\r
|
|
Upgrade: websocket\r
|
|
Sec-WebSocket-Key: foo\r
|
|
\r
|
|
""")
|
|
l = cl.readline()
|
|
# print(l)
|
|
while 1:
|
|
l = cl.readline()
|
|
if l == b"\r\n":
|
|
break
|
|
# sys.stdout.write(l)
|