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,
155 _, sock, _ = ws.upgrade()
157 ws.frame_write(sock, ws.OP_TEXT, message)
159 frame = ws.frame_read(sock)
162 frame = ws.frame_read(sock)
176 _, sock1, _ = ws.upgrade()
177 _, sock2, _ = ws.upgrade()
179 ws.frame_write(sock1, ws.OP_TEXT, message1)
180 ws.frame_write(sock2, ws.OP_TEXT, message2)
182 frame1 = ws.frame_read(sock1)
183 frame2 = ws.frame_read(sock2)
201 'Sec-WebSocket-Key': ws.key(),
213 resp, sock, _ = ws.upgrade(
218 'Sec-WebSocket-Key': ws.key(),
236 'Sec-WebSocket-Key': ws.key(),
253 'Sec-WebSocket-Key': ws.key(),
278 key = ws.key()
303 'Sec-WebSocket-Key': ws.key(),
320 'Sec-WebSocket-Key': ws.key(),
338 'Sec-WebSocket-Key': ws.key(),
351 key = ws.key()
352 resp, sock, _ = ws.upgrade(
366 assert resp['headers']['Sec-WebSocket-Accept'] == ws.accept(key), 'key'
379 opcode = ws.OP_TEXT
381 _, sock, _ = ws.upgrade()
386 ws.frame_write(sock, opcode, payload, chopsize=chopsize)
388 frame = ws.frame_read(sock)
406 opcode = ws.OP_BINARY
408 _, sock, _ = ws.upgrade()
413 ws.frame_write(sock, opcode, payload, chopsize=chopsize)
414 frame = ws.frame_read(sock)
433 op_ping = ws.OP_PING
434 op_pong = ws.OP_PONG
436 _, sock, _ = ws.upgrade()
439 ws.frame_write(sock, op_ping, payload, chopsize=chopsize)
440 frame = ws.frame_read(sock)
454 _, sock, _ = ws.upgrade()
456 ws.frame_write(sock, ws.OP_PING, b'\xfe' * 126)
465 _, sock, _ = ws.upgrade()
467 ws.frame_write(sock, ws.OP_PONG, '')
472 ws.frame_write(sock, ws.OP_PONG, 'unsolicited pong payload')
479 ws.frame_write(sock, ws.OP_PONG, 'unsolicited pong payload')
480 ws.frame_write(sock, ws.OP_PING, payload)
482 frame = ws.frame_read(sock)
483 check_frame(frame, True, ws.OP_PONG, payload)
493 _, sock, _ = ws.upgrade()
496 ws.frame_write(sock, ws.OP_PING, f'payload-{i}')
499 frame = ws.frame_read(sock)
500 check_frame(frame, True, ws.OP_PONG, f'payload-{i}')
505 opcode = ws.OP_PING
506 ws.frame_write(sock, opcode, f'payload-{i}', chopsize=1)
509 frame = ws.frame_read(sock)
510 check_frame(frame, True, ws.OP_PONG, f'payload-{i}')
523 _, sock, _ = ws.upgrade()
525 ws.frame_write(sock, ws.OP_TEXT, payload, rsv1=True)
530 _, sock, _ = ws.upgrade()
532 ws.frame_write(sock, ws.OP_TEXT, payload)
533 ws.frame_write(sock, ws.OP_TEXT, payload, rsv2=True)
534 ws.frame_write(sock, ws.OP_PING, '')
536 frame = ws.frame_read(sock)
537 check_frame(frame, True, ws.OP_TEXT, payload)
546 _, sock, _ = ws.upgrade()
548 ws.frame_write(sock, ws.OP_TEXT, payload)
550 frame = ws.frame_read(sock)
551 check_frame(frame, True, ws.OP_TEXT, payload)
553 ws.frame_write(sock, ws.OP_TEXT, payload, rsv1=True, rsv2=True)
562 _, sock, _ = ws.upgrade()
564 ws.frame_write(sock, ws.OP_TEXT, payload, chopsize=1)
565 ws.frame_write(sock, ws.OP_TEXT, payload, rsv3=True, chopsize=1)
566 ws.frame_write(sock, ws.OP_PING, '')
568 frame = ws.frame_read(sock)
569 check_frame(frame, True, ws.OP_TEXT, payload)
578 _, sock, _ = ws.upgrade()
580 ws.frame_write(
582 ws.OP_BINARY,
592 _, sock, _ = ws.upgrade()
594 ws.frame_write(sock, ws.OP_PING, payload, rsv2=True, rsv3=True)
600 _, sock, _ = ws.upgrade()
602 ws.frame_write(sock, ws.OP_CLOSE, payload, rsv1=True, rsv2=True, rsv3=True)
614 _, sock, _ = ws.upgrade()
616 ws.frame_write(sock, 0x03, '')
621 _, sock, _ = ws.upgrade()
623 ws.frame_write(sock, 0x04, 'reserved opcode payload')
628 _, sock, _ = ws.upgrade()
630 ws.frame_write(sock, ws.OP_TEXT, payload)
632 frame = ws.frame_read(sock)
633 check_frame(frame, True, ws.OP_TEXT, payload)
635 ws.frame_write(sock, 0x05, '')
636 ws.frame_write(sock, ws.OP_PING, '')
642 _, sock, _ = ws.upgrade()
644 ws.frame_write(sock, ws.OP_TEXT, payload)
646 frame = ws.frame_read(sock)
647 check_frame(frame, True, ws.OP_TEXT, payload)
649 ws.frame_write(sock, 0x06, payload)
650 ws.frame_write(sock, ws.OP_PING, '')
656 _, sock, _ = ws.upgrade()
658 ws.frame_write(sock, ws.OP_TEXT, payload, chopsize=1)
660 frame = ws.frame_read(sock)
661 check_frame(frame, True, ws.OP_TEXT, payload)
663 ws.frame_write(sock, 0x07, payload, chopsize=1)
664 ws.frame_write(sock, ws.OP_PING, '')
670 _, sock, _ = ws.upgrade()
672 ws.frame_write(sock, 0x0B, '')
677 _, sock, _ = ws.upgrade()
679 ws.frame_write(sock, 0x0C, 'reserved opcode payload')
684 _, sock, _ = ws.upgrade()
686 ws.frame_write(sock, ws.OP_TEXT, payload)
688 frame = ws.frame_read(sock)
689 check_frame(frame, True, ws.OP_TEXT, payload)
691 ws.frame_write(sock, 0x0D, '')
692 ws.frame_write(sock, ws.OP_PING, '')
698 _, sock, _ = ws.upgrade()
700 ws.frame_write(sock, ws.OP_TEXT, payload)
702 frame = ws.frame_read(sock)
703 check_frame(frame, True, ws.OP_TEXT, payload)
705 ws.frame_write(sock, 0x0E, payload)
706 ws.frame_write(sock, ws.OP_PING, '')
712 _, sock, _ = ws.upgrade()
714 ws.frame_write(sock, ws.OP_TEXT, payload, chopsize=1)
716 frame = ws.frame_read(sock)
717 check_frame(frame, True, ws.OP_TEXT, payload)
719 ws.frame_write(sock, 0x0F, payload, chopsize=1)
720 ws.frame_write(sock, ws.OP_PING, '')
730 _, sock, _ = ws.upgrade()
732 ws.frame_write(sock, ws.OP_PING, 'fragment1', fin=False)
733 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True)
738 _, sock, _ = ws.upgrade()
740 ws.frame_write(sock, ws.OP_PONG, 'fragment1', fin=False)
741 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True)
746 _, sock, _ = ws.upgrade()
748 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
749 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True)
751 frame = ws.frame_read(sock)
752 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
756 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
758 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True)
760 frame = ws.frame_read(sock)
761 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
765 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False, chopsize=1)
766 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True, chopsize=1)
768 frame = ws.frame_read(sock)
769 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
775 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
776 ws.frame_write(sock, ws.OP_PING, 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_PONG, ping_payload)
782 frame = ws.frame_read(sock)
783 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
789 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
792 ws.frame_write(sock, ws.OP_PING, ping_payload)
794 frame = ws.frame_read(sock)
795 check_frame(frame, True, ws.OP_PONG, ping_payload)
797 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True)
799 frame = ws.frame_read(sock)
800 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
806 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False, chopsize=1)
807 ws.frame_write(sock, ws.OP_PING, ping_payload, chopsize=1)
808 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True, chopsize=1)
810 frame = ws.frame_read(sock)
811 check_frame(frame, True, ws.OP_PONG, ping_payload)
813 frame = ws.frame_read(sock)
814 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
818 ws.frame_write(sock, ws.OP_CONT, 'non-continuation payload', fin=True)
819 ws.frame_write(sock, ws.OP_TEXT, 'Hello, world!', fin=True)
824 _, sock, _ = ws.upgrade()
826 ws.frame_write(sock, ws.OP_CONT, 'non-continuation payload', fin=True)
827 ws.frame_write(sock, ws.OP_TEXT, 'Hello, world!', fin=True)
832 _, sock, _ = ws.upgrade()
834 ws.frame_write(
836 ws.OP_CONT,
841 ws.frame_write(sock, ws.OP_TEXT, 'Hello, world!', fin=True, chopsize=1)
846 _, sock, _ = ws.upgrade()
848 ws.frame_write(sock, ws.OP_CONT, 'non-continuation payload', fin=False)
849 ws.frame_write(sock, ws.OP_TEXT, 'Hello, world!', fin=True)
854 _, sock, _ = ws.upgrade()
856 ws.frame_write(sock, ws.OP_CONT, 'non-continuation payload', fin=False)
857 ws.frame_write(sock, ws.OP_TEXT, 'Hello, world!', fin=True)
862 _, sock, _ = ws.upgrade()
864 ws.frame_write(
866 ws.OP_CONT,
871 ws.frame_write(sock, ws.OP_TEXT, 'Hello, world!', fin=True, chopsize=1)
876 _, sock, _ = ws.upgrade()
878 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
879 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True)
880 ws.frame_write(sock, ws.OP_CONT, 'fragment3', fin=False)
881 ws.frame_write(sock, ws.OP_TEXT, 'fragment4', fin=True)
883 frame = ws.frame_read(sock)
885 if frame['opcode'] == ws.OP_TEXT:
886 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
893 _, sock, _ = ws.upgrade()
896 ws.frame_write(sock, ws.OP_CONT, 'fragment1', fin=False)
897 ws.frame_write(sock, ws.OP_TEXT, 'fragment2', fin=False)
898 ws.frame_write(sock, ws.OP_CONT, 'fragment3', fin=True)
903 _, sock, _ = ws.upgrade()
906 ws.frame_write(sock, ws.OP_CONT, 'fragment1', fin=True)
907 ws.frame_write(sock, ws.OP_TEXT, 'fragment2', fin=False)
908 ws.frame_write(sock, ws.OP_CONT, 'fragment3', fin=True)
913 _, sock, _ = ws.upgrade()
915 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
916 ws.frame_write(sock, ws.OP_TEXT, 'fragment2')
921 _, sock, _ = ws.upgrade()
923 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
924 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=False)
925 ws.frame_write(sock, ws.OP_PING, 'pongme 1!')
929 ws.frame_write(sock, ws.OP_CONT, 'fragment3', fin=False)
930 ws.frame_write(sock, ws.OP_CONT, 'fragment4', fin=False)
931 ws.frame_write(sock, ws.OP_PING, 'pongme 2!')
932 ws.frame_write(sock, ws.OP_CONT, 'fragment5')
934 frame = ws.frame_read(sock)
935 check_frame(frame, True, ws.OP_PONG, 'pongme 1!')
937 frame = ws.frame_read(sock)
938 check_frame(frame, True, ws.OP_PONG, 'pongme 2!')
941 ws.frame_read(sock),
943 ws.OP_TEXT,
949 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
950 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=False)
951 ws.frame_write(sock, ws.OP_PING, 'pongme 1!')
953 frame = ws.frame_read(sock)
954 check_frame(frame, True, ws.OP_PONG, 'pongme 1!')
958 ws.frame_write(sock, ws.OP_CONT, 'fragment3', fin=False)
959 ws.frame_write(sock, ws.OP_CONT, 'fragment4', fin=False)
960 ws.frame_write(sock, ws.OP_PING, 'pongme 2!')
962 frame = ws.frame_read(sock)
963 check_frame(frame, True, ws.OP_PONG, 'pongme 2!')
966 ws.frame_write(sock, ws.OP_CONT, 'fragment5')
969 ws.frame_read(sock),
971 ws.OP_TEXT,
983 _, sock, _ = ws.upgrade()
985 ws.frame_write(sock, ws.OP_TEXT, '')
986 frame = ws.frame_read(sock)
987 check_frame(frame, True, ws.OP_TEXT, '')
991 ws.frame_write(sock, ws.OP_TEXT, '', fin=False)
992 ws.frame_write(sock, ws.OP_CONT, '', fin=False)
993 ws.frame_write(sock, ws.OP_CONT, '')
995 frame = ws.frame_read(sock)
996 check_frame(frame, True, ws.OP_TEXT, '')
1002 ws.frame_write(sock, ws.OP_TEXT, '', fin=False)
1003 ws.frame_write(sock, ws.OP_CONT, payload, fin=False)
1004 ws.frame_write(sock, ws.OP_CONT, '')
1006 frame = ws.frame_read(sock)
1007 check_frame(frame, True, ws.OP_TEXT, payload)
1013 ws.frame_write(sock, ws.OP_TEXT, payload)
1015 frame = ws.frame_read(sock)
1016 check_frame(frame, True, ws.OP_TEXT, payload)
1020 ws.frame_write(sock, ws.OP_TEXT, payload[:12], fin=False)
1021 ws.frame_write(sock, ws.OP_CONT, payload[12:])
1023 frame = ws.frame_read(sock)
1024 check_frame(frame, True, ws.OP_TEXT, payload)
1028 ws.message(sock, ws.OP_TEXT, payload, fragmention_size=1)
1030 frame = ws.frame_read(sock)
1031 check_frame(frame, True, ws.OP_TEXT, payload)
1037 ws.message(sock, ws.OP_TEXT, payload, fragmention_size=1)
1039 frame = ws.frame_read(sock)
1040 check_frame(frame, True, ws.OP_TEXT, payload)
1073 _, sock, _ = ws.upgrade()
1077 ws.frame_write(sock, ws.OP_TEXT, payload)
1079 frame = ws.frame_read(sock)
1080 check_frame(frame, True, ws.OP_TEXT, payload)
1086 _, sock, _ = ws.upgrade()
1088 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
1089 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
1095 _, sock, _ = ws.upgrade()
1097 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
1100 ws.frame_write(sock, ws.OP_PING, '')
1107 _, sock, _ = ws.upgrade()
1109 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
1112 ws.frame_write(sock, ws.OP_TEXT, payload)
1119 _, sock, _ = ws.upgrade()
1121 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
1122 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
1125 ws.frame_write(sock, ws.OP_CONT, 'fragment2')
1132 _, sock, _ = ws.upgrade()
1134 ws.frame_write(sock, ws.OP_TEXT, 'BAsd7&jh23' * 26 * 2**10)
1135 ws.frame_write(sock, ws.OP_TEXT, payload)
1136 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
1140 ws.frame_write(sock, ws.OP_PING, '')
1147 _, sock, _ = ws.upgrade()
1149 ws.frame_write(sock, ws.OP_CLOSE, '')
1154 _, sock, _ = ws.upgrade()
1156 ws.frame_write(sock, ws.OP_CLOSE, 'a')
1161 _, sock, _ = ws.upgrade()
1163 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
1168 _, sock, _ = ws.upgrade()
1170 payload = ws.serialize_close(reason='Hello World!')
1172 ws.frame_write(sock, ws.OP_CLOSE, payload)
1177 _, sock, _ = ws.upgrade()
1179 payload = ws.serialize_close(reason='*' * 123)
1181 ws.frame_write(sock, ws.OP_CLOSE, payload)
1186 _, sock, _ = ws.upgrade()
1188 payload = ws.serialize_close(reason='*' * 124)
1190 ws.frame_write(sock, ws.OP_CLOSE, payload)
1227 _, sock, _ = ws.upgrade()
1229 payload = ws.serialize_close(code=code)
1231 ws.frame_write(sock, ws.OP_CLOSE, payload)
1235 _, sock, _ = ws.upgrade()
1237 payload = ws.serialize_close(code=code)
1239 ws.frame_write(sock, ws.OP_CLOSE, payload)
1248 _, sock, _ = ws.upgrade()
1250 payload = ws.serialize_close(code=5000)
1252 ws.frame_write(sock, ws.OP_CLOSE, payload)
1257 _, sock, _ = ws.upgrade()
1261 ws.frame_write(sock, ws.OP_CLOSE, payload)
1283 _, sock, _ = ws.upgrade()
1285 op_text = ws.OP_TEXT
1286 op_binary = ws.OP_BINARY
1289 if opcode == ws.OP_TEXT:
1294 ws.frame_write(sock, opcode, payload, chopsize=chopsize)
1295 frame = ws.frame_read(sock, read_timeout=5)
1299 if opcode == ws.OP_TEXT:
1304 ws.message(sock, opcode, payload, fragmention_size=f_size)
1305 frame = ws.frame_read(sock, read_timeout=5)
1363 _, sock, _ = ws.upgrade()
1367 ws.message(sock, ws.OP_TEXT, payload, fragmention_size=1300)
1369 frame = ws.frame_read(sock)
1370 check_frame(frame, True, ws.OP_TEXT, payload)
1385 _, sock, _ = ws.upgrade()
1388 opcode = ws.OP_TEXT
1390 ws.frame_write(sock, opcode, payload) # frame length is 100
1392 frame = ws.frame_read(sock)
1397 ws.frame_write(sock, opcode, payload) # frame length is 101
1408 _, sock, _ = ws.upgrade()
1410 frame = ws.frame_to_send(ws.OP_TEXT, 'blah')
1425 _, sock, _ = ws.upgrade()
1427 frame = ws.frame_to_send(ws.OP_TEXT, 'blah')
1432 frame = ws.frame_read(sock)
1433 check_frame(frame, True, ws.OP_PING, '') # PING frame