Lines Matching refs:ws

12 ws = ApplicationWebsocket()  variable
27 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
34 frame = ws.frame_read(sock)
37 assert frame['opcode'] == ws.OP_CLOSE, 'close opcode'
45 if opcode == ws.OP_BINARY or not decode:
58 resp, sock, key = ws.upgrade()
64 assert resp['headers']['Sec-WebSocket-Accept'] == ws.accept(key), 'key'
72 _, sock, _ = ws.upgrade()
74 ws.frame_write(sock, ws.OP_TEXT, message)
75 frame = ws.frame_read(sock)
79 ws.frame_write(sock, ws.OP_TEXT, message)
80 frame = ws.frame_read(sock)
92 _, sock, _ = ws.upgrade()
94 ws.frame_write(sock, ws.OP_TEXT, message, mask=False)
96 frame = ws.frame_read(sock)
98 assert frame['opcode'] == ws.OP_CLOSE, 'no mask opcode'
109 _, sock, _ = ws.upgrade()
111 ws.frame_write(sock, ws.OP_TEXT, message, fin=False)
112 ws.frame_write(sock, ws.OP_CONT, ' ', fin=False)
113 ws.frame_write(sock, ws.OP_CONT, message)
115 frame = ws.frame_read(sock)
129 _, sock, _ = ws.upgrade()
131 ws.frame_write(sock, ws.OP_PING, message, fin=False)
133 frame = ws.frame_read(sock)
141 'opcode': ws.OP_CLOSE,
156 _, sock1, _ = ws.upgrade()
157 _, sock2, _ = ws.upgrade()
159 ws.frame_write(sock1, ws.OP_TEXT, message1)
160 ws.frame_write(sock2, ws.OP_TEXT, message2)
162 frame1 = ws.frame_read(sock1)
163 frame2 = ws.frame_read(sock2)
181 'Sec-WebSocket-Key': ws.key(),
193 resp, sock, _ = ws.upgrade(
198 'Sec-WebSocket-Key': ws.key(),
216 'Sec-WebSocket-Key': ws.key(),
233 'Sec-WebSocket-Key': ws.key(),
258 key = ws.key()
283 'Sec-WebSocket-Key': ws.key(),
300 'Sec-WebSocket-Key': ws.key(),
318 'Sec-WebSocket-Key': ws.key(),
331 key = ws.key()
332 resp, sock, _ = ws.upgrade(
346 assert resp['headers']['Sec-WebSocket-Accept'] == ws.accept(key), 'key'
359 opcode = ws.OP_TEXT
361 _, sock, _ = ws.upgrade()
366 ws.frame_write(sock, opcode, payload, chopsize=chopsize)
368 frame = ws.message_read(sock)
386 opcode = ws.OP_BINARY
388 _, sock, _ = ws.upgrade()
393 ws.frame_write(sock, opcode, payload, chopsize=chopsize)
395 frame = ws.message_read(sock)
413 op_ping = ws.OP_PING
414 op_pong = ws.OP_PONG
416 _, sock, _ = ws.upgrade()
419 ws.frame_write(sock, op_ping, payload, chopsize=chopsize)
420 frame = ws.frame_read(sock)
434 _, sock, _ = ws.upgrade()
436 ws.frame_write(sock, ws.OP_PING, b'\xfe' * 126)
445 _, sock, _ = ws.upgrade()
447 ws.frame_write(sock, ws.OP_PONG, '')
452 ws.frame_write(sock, ws.OP_PONG, 'unsolicited pong payload')
459 ws.frame_write(sock, ws.OP_PONG, 'unsolicited pong payload')
460 ws.frame_write(sock, ws.OP_PING, payload)
462 frame = ws.frame_read(sock)
463 check_frame(frame, True, ws.OP_PONG, payload)
473 _, sock, _ = ws.upgrade()
476 ws.frame_write(sock, ws.OP_PING, f'payload-{i}')
479 frame = ws.frame_read(sock)
480 check_frame(frame, True, ws.OP_PONG, f'payload-{i}')
485 opcode = ws.OP_PING
486 ws.frame_write(sock, opcode, f'payload-{i}', chopsize=1)
489 frame = ws.frame_read(sock)
490 check_frame(frame, True, ws.OP_PONG, f'payload-{i}')
503 _, sock, _ = ws.upgrade()
505 ws.frame_write(sock, ws.OP_TEXT, payload, rsv1=True)
510 _, sock, _ = ws.upgrade()
512 ws.frame_write(sock, ws.OP_TEXT, payload)
513 ws.frame_write(sock, ws.OP_TEXT, payload, rsv2=True)
514 ws.frame_write(sock, ws.OP_PING, '')
516 frame = ws.frame_read(sock)
517 check_frame(frame, True, ws.OP_TEXT, payload)
526 _, sock, _ = ws.upgrade()
528 ws.frame_write(sock, ws.OP_TEXT, payload)
530 frame = ws.frame_read(sock)
531 check_frame(frame, True, ws.OP_TEXT, payload)
533 ws.frame_write(sock, ws.OP_TEXT, payload, rsv1=True, rsv2=True)
542 _, sock, _ = ws.upgrade()
544 ws.frame_write(sock, ws.OP_TEXT, payload, chopsize=1)
545 ws.frame_write(sock, ws.OP_TEXT, payload, rsv3=True, chopsize=1)
546 ws.frame_write(sock, ws.OP_PING, '')
548 frame = ws.frame_read(sock)
549 check_frame(frame, True, ws.OP_TEXT, payload)
558 _, sock, _ = ws.upgrade()
560 ws.frame_write(
562 ws.OP_BINARY,
572 _, sock, _ = ws.upgrade()
574 ws.frame_write(sock, ws.OP_PING, payload, rsv2=True, rsv3=True)
580 _, sock, _ = ws.upgrade()
582 ws.frame_write(sock, ws.OP_CLOSE, payload, rsv1=True, rsv2=True, rsv3=True)
594 _, sock, _ = ws.upgrade()
596 ws.frame_write(sock, 0x03, '')
601 _, sock, _ = ws.upgrade()
603 ws.frame_write(sock, 0x04, 'reserved opcode payload')
608 _, sock, _ = ws.upgrade()
610 ws.frame_write(sock, ws.OP_TEXT, payload)
612 frame = ws.frame_read(sock)
613 check_frame(frame, True, ws.OP_TEXT, payload)
615 ws.frame_write(sock, 0x05, '')
616 ws.frame_write(sock, ws.OP_PING, '')
622 _, sock, _ = ws.upgrade()
624 ws.frame_write(sock, ws.OP_TEXT, payload)
626 frame = ws.frame_read(sock)
627 check_frame(frame, True, ws.OP_TEXT, payload)
629 ws.frame_write(sock, 0x06, payload)
630 ws.frame_write(sock, ws.OP_PING, '')
636 _, sock, _ = ws.upgrade()
638 ws.frame_write(sock, ws.OP_TEXT, payload, chopsize=1)
640 frame = ws.frame_read(sock)
641 check_frame(frame, True, ws.OP_TEXT, payload)
643 ws.frame_write(sock, 0x07, payload, chopsize=1)
644 ws.frame_write(sock, ws.OP_PING, '')
650 _, sock, _ = ws.upgrade()
652 ws.frame_write(sock, 0x0B, '')
657 _, sock, _ = ws.upgrade()
659 ws.frame_write(sock, 0x0C, 'reserved opcode payload')
664 _, sock, _ = ws.upgrade()
666 ws.frame_write(sock, ws.OP_TEXT, payload)
668 frame = ws.frame_read(sock)
669 check_frame(frame, True, ws.OP_TEXT, payload)
671 ws.frame_write(sock, 0x0D, '')
672 ws.frame_write(sock, ws.OP_PING, '')
678 _, sock, _ = ws.upgrade()
680 ws.frame_write(sock, ws.OP_TEXT, payload)
682 frame = ws.frame_read(sock)
683 check_frame(frame, True, ws.OP_TEXT, payload)
685 ws.frame_write(sock, 0x0E, payload)
686 ws.frame_write(sock, ws.OP_PING, '')
692 _, sock, _ = ws.upgrade()
694 ws.frame_write(sock, ws.OP_TEXT, payload, chopsize=1)
696 frame = ws.frame_read(sock)
697 check_frame(frame, True, ws.OP_TEXT, payload)
699 ws.frame_write(sock, 0x0F, payload, chopsize=1)
700 ws.frame_write(sock, ws.OP_PING, '')
710 _, sock, _ = ws.upgrade()
712 ws.frame_write(sock, ws.OP_PING, 'fragment1', fin=False)
713 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True)
718 _, sock, _ = ws.upgrade()
720 ws.frame_write(sock, ws.OP_PONG, 'fragment1', fin=False)
721 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True)
726 _, sock, _ = ws.upgrade()
728 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
729 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True)
731 frame = ws.frame_read(sock)
732 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
736 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
738 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True)
740 frame = ws.frame_read(sock)
741 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
745 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False, chopsize=1)
746 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True, chopsize=1)
748 frame = ws.frame_read(sock)
749 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
755 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
756 ws.frame_write(sock, ws.OP_PING, ping_payload)
757 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True)
759 frame = ws.frame_read(sock)
760 check_frame(frame, True, ws.OP_PONG, ping_payload)
762 frame = ws.frame_read(sock)
763 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
769 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
772 ws.frame_write(sock, ws.OP_PING, ping_payload)
774 frame = ws.frame_read(sock)
775 check_frame(frame, True, ws.OP_PONG, ping_payload)
777 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True)
779 frame = ws.frame_read(sock)
780 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
786 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False, chopsize=1)
787 ws.frame_write(sock, ws.OP_PING, ping_payload, chopsize=1)
788 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True, chopsize=1)
790 frame = ws.frame_read(sock)
791 check_frame(frame, True, ws.OP_PONG, ping_payload)
793 frame = ws.frame_read(sock)
794 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
798 ws.frame_write(sock, ws.OP_CONT, 'non-continuation payload', fin=True)
799 ws.frame_write(sock, ws.OP_TEXT, 'Hello, world!', fin=True)
804 _, sock, _ = ws.upgrade()
806 ws.frame_write(sock, ws.OP_CONT, 'non-continuation payload', fin=True)
807 ws.frame_write(sock, ws.OP_TEXT, 'Hello, world!', fin=True)
812 _, sock, _ = ws.upgrade()
814 ws.frame_write(
816 ws.OP_CONT,
821 ws.frame_write(sock, ws.OP_TEXT, 'Hello, world!', fin=True, chopsize=1)
826 _, sock, _ = ws.upgrade()
828 ws.frame_write(sock, ws.OP_CONT, 'non-continuation payload', fin=False)
829 ws.frame_write(sock, ws.OP_TEXT, 'Hello, world!', fin=True)
834 _, sock, _ = ws.upgrade()
836 ws.frame_write(sock, ws.OP_CONT, 'non-continuation payload', fin=False)
837 ws.frame_write(sock, ws.OP_TEXT, 'Hello, world!', fin=True)
842 _, sock, _ = ws.upgrade()
844 ws.frame_write(
846 ws.OP_CONT,
851 ws.frame_write(sock, ws.OP_TEXT, 'Hello, world!', fin=True, chopsize=1)
856 _, sock, _ = ws.upgrade()
858 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
859 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True)
860 ws.frame_write(sock, ws.OP_CONT, 'fragment3', fin=False)
861 ws.frame_write(sock, ws.OP_TEXT, 'fragment4', fin=True)
863 frame = ws.frame_read(sock)
865 if frame['opcode'] == ws.OP_TEXT:
866 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
873 _, sock, _ = ws.upgrade()
876 ws.frame_write(sock, ws.OP_CONT, 'fragment1', fin=False)
877 ws.frame_write(sock, ws.OP_TEXT, 'fragment2', fin=False)
878 ws.frame_write(sock, ws.OP_CONT, 'fragment3', fin=True)
883 _, sock, _ = ws.upgrade()
886 ws.frame_write(sock, ws.OP_CONT, 'fragment1', fin=True)
887 ws.frame_write(sock, ws.OP_TEXT, 'fragment2', fin=False)
888 ws.frame_write(sock, ws.OP_CONT, 'fragment3', fin=True)
893 _, sock, _ = ws.upgrade()
895 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
896 ws.frame_write(sock, ws.OP_TEXT, 'fragment2')
901 _, sock, _ = ws.upgrade()
903 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
904 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=False)
905 ws.frame_write(sock, ws.OP_PING, 'pongme 1!')
909 ws.frame_write(sock, ws.OP_CONT, 'fragment3', fin=False)
910 ws.frame_write(sock, ws.OP_CONT, 'fragment4', fin=False)
911 ws.frame_write(sock, ws.OP_PING, 'pongme 2!')
912 ws.frame_write(sock, ws.OP_CONT, 'fragment5')
914 frame = ws.frame_read(sock)
915 check_frame(frame, True, ws.OP_PONG, 'pongme 1!')
917 frame = ws.frame_read(sock)
918 check_frame(frame, True, ws.OP_PONG, 'pongme 2!')
921 ws.frame_read(sock),
923 ws.OP_TEXT,
929 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
930 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=False)
931 ws.frame_write(sock, ws.OP_PING, 'pongme 1!')
933 frame = ws.frame_read(sock)
934 check_frame(frame, True, ws.OP_PONG, 'pongme 1!')
938 ws.frame_write(sock, ws.OP_CONT, 'fragment3', fin=False)
939 ws.frame_write(sock, ws.OP_CONT, 'fragment4', fin=False)
940 ws.frame_write(sock, ws.OP_PING, 'pongme 2!')
942 frame = ws.frame_read(sock)
943 check_frame(frame, True, ws.OP_PONG, 'pongme 2!')
946 ws.frame_write(sock, ws.OP_CONT, 'fragment5')
949 ws.frame_read(sock),
951 ws.OP_TEXT,
963 _, sock, _ = ws.upgrade()
965 ws.frame_write(sock, ws.OP_TEXT, '')
966 frame = ws.frame_read(sock, read_timeout=3)
967 check_frame(frame, True, ws.OP_TEXT, '')
971 ws.frame_write(sock, ws.OP_TEXT, '', fin=False)
972 ws.frame_write(sock, ws.OP_CONT, '', fin=False)
973 ws.frame_write(sock, ws.OP_CONT, '')
975 frame = ws.frame_read(sock, read_timeout=3)
976 check_frame(frame, True, ws.OP_TEXT, '')
982 ws.frame_write(sock, ws.OP_TEXT, '', fin=False)
983 ws.frame_write(sock, ws.OP_CONT, payload, fin=False)
984 ws.frame_write(sock, ws.OP_CONT, '')
986 frame = ws.frame_read(sock)
987 check_frame(frame, True, ws.OP_TEXT, payload)
993 ws.frame_write(sock, ws.OP_TEXT, payload)
995 frame = ws.frame_read(sock)
996 check_frame(frame, True, ws.OP_TEXT, payload)
1000 ws.frame_write(sock, ws.OP_TEXT, payload[:12], fin=False)
1001 ws.frame_write(sock, ws.OP_CONT, payload[12:])
1003 frame = ws.frame_read(sock)
1004 check_frame(frame, True, ws.OP_TEXT, payload)
1008 ws.message(sock, ws.OP_TEXT, payload, fragmention_size=1)
1010 frame = ws.frame_read(sock)
1011 check_frame(frame, True, ws.OP_TEXT, payload)
1017 ws.message(sock, ws.OP_TEXT, payload, fragmention_size=1)
1019 frame = ws.frame_read(sock)
1020 check_frame(frame, True, ws.OP_TEXT, payload)
1053 _, sock, _ = ws.upgrade()
1057 ws.frame_write(sock, ws.OP_TEXT, payload)
1059 frame = ws.frame_read(sock)
1060 check_frame(frame, True, ws.OP_TEXT, payload)
1066 _, sock, _ = ws.upgrade()
1068 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
1069 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
1075 _, sock, _ = ws.upgrade()
1077 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
1080 ws.frame_write(sock, ws.OP_PING, '')
1087 _, sock, _ = ws.upgrade()
1089 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
1092 ws.frame_write(sock, ws.OP_TEXT, payload)
1099 _, sock, _ = ws.upgrade()
1101 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
1102 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
1105 ws.frame_write(sock, ws.OP_CONT, 'fragment2')
1112 _, sock, _ = ws.upgrade()
1114 ws.frame_write(sock, ws.OP_TEXT, 'BAsd7&jh23' * 26 * 2**10)
1115 ws.frame_write(sock, ws.OP_TEXT, payload)
1116 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
1120 ws.frame_write(sock, ws.OP_PING, '')
1127 _, sock, _ = ws.upgrade()
1129 ws.frame_write(sock, ws.OP_CLOSE, '')
1134 _, sock, _ = ws.upgrade()
1136 ws.frame_write(sock, ws.OP_CLOSE, 'a')
1141 _, sock, _ = ws.upgrade()
1143 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
1148 _, sock, _ = ws.upgrade()
1150 payload = ws.serialize_close(reason='Hello World!')
1152 ws.frame_write(sock, ws.OP_CLOSE, payload)
1157 _, sock, _ = ws.upgrade()
1159 payload = ws.serialize_close(reason='*' * 123)
1161 ws.frame_write(sock, ws.OP_CLOSE, payload)
1166 _, sock, _ = ws.upgrade()
1168 payload = ws.serialize_close(reason='*' * 124)
1170 ws.frame_write(sock, ws.OP_CLOSE, payload)
1207 _, sock, _ = ws.upgrade()
1209 payload = ws.serialize_close(code=code)
1211 ws.frame_write(sock, ws.OP_CLOSE, payload)
1215 _, sock, _ = ws.upgrade()
1217 payload = ws.serialize_close(code=code)
1219 ws.frame_write(sock, ws.OP_CLOSE, payload)
1228 _, sock, _ = ws.upgrade()
1230 payload = ws.serialize_close(code=5000)
1232 ws.frame_write(sock, ws.OP_CLOSE, payload)
1237 _, sock, _ = ws.upgrade()
1241 ws.frame_write(sock, ws.OP_CLOSE, payload)
1263 _, sock, _ = ws.upgrade()
1265 op_text = ws.OP_TEXT
1266 op_binary = ws.OP_BINARY
1269 if opcode == ws.OP_TEXT:
1274 ws.frame_write(sock, opcode, payload, chopsize=chopsize)
1275 frame = ws.frame_read(sock)
1279 if opcode == ws.OP_TEXT:
1284 ws.message(sock, opcode, payload, fragmention_size=f_size)
1285 frame = ws.frame_read(sock, read_timeout=5)
1343 _, sock, _ = ws.upgrade()
1347 ws.message(sock, ws.OP_TEXT, payload, fragmention_size=1300)
1349 frame = ws.message_read(sock)
1350 check_frame(frame, True, ws.OP_TEXT, payload)
1365 _, sock, _ = ws.upgrade()
1368 opcode = ws.OP_TEXT
1370 ws.frame_write(sock, opcode, payload) # frame length is 100
1372 frame = ws.frame_read(sock)
1377 ws.frame_write(sock, opcode, payload) # frame length is 101
1388 _, sock, _ = ws.upgrade()
1390 frame = ws.frame_to_send(ws.OP_TEXT, 'blah')
1405 _, sock, _ = ws.upgrade()
1407 frame = ws.frame_to_send(ws.OP_TEXT, 'blah')
1412 frame = ws.frame_read(sock)
1413 check_frame(frame, True, ws.OP_PING, '') # PING frame