.mock_recvO*S[(J'F !OJMr0 frame_bufferTskip_utf8_validationr1N)ranger"appendwebsocket._abnfr; recv_strictr# assertGreater) r% large_payload chunk_sizeir8r;fbr5r6r7s @@r*test_recv_large_payload_chunkedz0LargePayloadTest.test_recv_large_payload_chunkedAsu  q#m,j9 =A MM-A N; < =   1 )$ ?M 23 / :q)r0cd}gfd}ddlm}||d}|j|}|jt |||j t dD|jt dy ) z&Simulate SSL BAD_LENGTH error scenariorcdj||dkDr tddt|dzS)Nrz[SSL: BAD_LENGTH] unknown errorC)r?r min)r4 recv_callss r*mock_recv_with_ssl_limitzTLargePayloadTest.test_ssl_large_payload_simulation..mock_recv_with_ssl_limitks6   g &@AA#gu-- -r0rr:Tr<c3&K|] }|dk yw)rN).0calls r* zELargePayloadTest.test_ssl_large_payload_simulation..|sAdDEMAsr1N)r@r;rAr#r"r!allrB)r% payload_sizerMr;rFr5rLs @r*!test_ssl_large_payload_simulationz2LargePayloadTest.test_ssl_large_payload_simulationcsw   . 1 2 N - Vl3 AjAAB 3z?A.r0cgd}|D]}|j|5d|z}tj|tj}|j }|j |t |jt|j|d}|tjkrd|z}n|tjkrd|z}nd|z}|jt|||zdddy#1swYxYw)z6Test frame formatting with various large payload sizes)i?rrrrr)sizeD N) rrrrrrr r#r"r$LENGTH_7 LENGTH_16)r% test_sizesrWr'r(r) mask_sizeexpected_header_sizes r* test_frame_format_large_payloadsz1LargePayloadTest.test_frame_format_large_payloadss@  ND4( N+))'43E3EF"LLN %%i7  UZZ$7 $--'I )DNN*I ) Y)  Y1E1LM= N N N N Ns C C33C< c(t}gfd}||_d|j_t }||_d|_ddz}td5}d|_|j|}|j|dd d d y #1swYy xYw) z?Test that large payloads are sent in chunks to avoid SSL issuescNjt|t|SN)r?r")r$ sent_chunkss r* mock_sendzDLargePayloadTest.test_send_large_payload_chunking..mock_sends   s4y )t9 r0g>@TErzwebsocket._core.sendct|Srdr2)sockr$s r*zCLargePayloadTest.test_send_large_payload_chunking..s CIr0rN) rsend gettimeout return_valuerri connectedr side_effect send_binaryrB)r% mock_sockrfwsrCmock_send_funcr5res @r* test_send_large_payload_chunkingz1LargePayloadTest.test_send_large_payload_chunkingsF   # ,0 )[ u ) * *n)EN &^^M2F   vq ) * * *s ,BBc ddz}tj|tj}|j}|j |t t jdddz}tddddtjd|}|jt5|jd d d d y #1swYy xYw) z.Test UTF-8 validation with large text payloadsuHello 世界! iz!His invalid utf8r1rFr<N) rr OPCODE_TEXTrrr structpack OPCODE_CLOSE assertRaisesrvalidate)r% large_textr(r)invalid_utf8_close_datas r*test_utf8_validation_large_textz0LargePayloadTest.test_utf8_validation_large_texts&, !!*d.>.>?LLN  i/#)++dD"9.mock_recvr9r0r:Tr<rYN)r>r"r@r;rAr#) r% payload_16krEr8r;rFr5r6r7s @@r*test_frame_buffer_edge_casesz-LargePayloadTest.test_frame_buffer_edge_casessUl 6;1c+>NPT5UV+a!d(+V   1 )$ ?& - Q''WsBcd}d|z}tj|tj}|j}|j |t |j t|j|y)z4Test behavior at WebSocket maximum frame size limitsiGN) rrrrrr r#r"r$)r% large_sizer'r(r)s r*test_max_frame_size_limitsz+LargePayloadTest.test_max_frame_size_limitssd! #!!'4+=+=>LLN  i/ UZZ*5r0N) __name__ __module__ __qualname__r+rGrUrartr~rrrOr0r*r r s/ :D *D/:%NN*B7.(86r0r __main__)unittestrw unittest.mockrrrr@rwebsocket._corerwebsocket._exceptionsrr websocket._ssl_compatr TestCaser rmainrOr0r*rsQ 00 %W*&o6x((o6d zHMMOr0