OLD | NEW |
1 import re | 1 import re |
2 from mod_pywebsocket import common | 2 from mod_pywebsocket import common |
3 from mod_pywebsocket import stream | 3 from mod_pywebsocket import stream |
4 from mod_pywebsocket import msgutil | 4 from mod_pywebsocket import msgutil |
5 | 5 |
6 | 6 |
7 def web_socket_do_extra_handshake(request): | 7 def web_socket_do_extra_handshake(request): |
8 pass | 8 pass |
9 | 9 |
10 | 10 |
11 def web_socket_transfer_data(request): | 11 def web_socket_transfer_data(request): |
12 match = re.search(r'\?opcode=(\d+)$', request.ws_resource) | 12 match = re.search(r'\?opcode=(\d+)$', request.ws_resource) |
13 if match is None: | 13 if match is None: |
14 msgutil.send_message(request, 'FAIL: Query value is incorrect or missing
') | 14 msgutil.send_message(request, 'FAIL: Query value is incorrect or missing
') |
15 return | 15 return |
16 | 16 |
17 opcode = int(match.group(1)) | 17 opcode = int(match.group(1)) |
18 payload = 'This text should be ignored. (opcode = %d)' % opcode | 18 payload = 'This text should be ignored. (opcode = %d)' % opcode |
19 request.connection.write(stream.create_header(opcode, len(payload), 1, 0, 0,
0, 0) + payload) | 19 request.connection.write(stream.create_header(opcode, len(payload), 1, 0, 0,
0, 0) + payload) |
OLD | NEW |