| 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 |