Team Ai
Datasetpublic

codekingpro/portable-devtools

sourceHugging Faceupdated 5mo agoView on Hugging Face
1likes14kdownloads
test_app.cpython-313.pyc83 linesDownload Raw Back to __pycache__
1�

2q�jF7���SSKrSSKrSSKrSSKrSSKrSSKr\RRSS5S:Hr	\RRSS5r3\4S:grSr"SS	\R5r\S5:Xa\R "5 gg)�N�TEST_WITH_INTERNET�0�1�LOCAL_WS_SERVER_PORTz-1Tc���\rSrSr"SS5rSrSrSr\R"\6S5S5r\R"S	S75S5r\R"\8S5S5r
\R"\S
5S5r\R"\S
5S5r\R"\S
5S5r\R"\S
5S5r\R"\S
5S5r\R"\S
5S5r\R"\S
5S5r\R"\9S5S5r\R"\10S5S5r\R"\11S5S5rSrSrSrSrSrg)�WebSocketAppTest�&c��\rSrSrSrSrg)�WebSocketAppTest.NotSetYet�'z?A marker class for signalling that a value hasn't been set yet.�N)�__name__�12__module__�__qualname__�__firstlineno__�__doc__�__static_attributes__r
��^D:\code\apps\devtools\python\user_packages\Python313\site-packages\websocket/tests/test_app.py�	NotSetYetr's��Mrrc� �[R"[5 [R	5[l[R	5[l[R	5[l[R	5[lg�N)	�ws�enableTrace�	TRACEABLErr�keep_running_open�keep_running_close�get_mask_key_id�
on_error_data��selfs r�setUp�WebSocketAppTest.setUp*sV��13���y�!�-=�-G�-G�-I��*�.>�.H�.H�.J��+�+;�+E�+E�+G��(�)9�)C�)C�)E��&rc���[R5[l[R5[l[R5[l[R5[lgr)rrrrrrr s r�tearDown�WebSocketAppTest.tearDown2sJ��-=�-G�-G�-I��*�.>�.H�.H�.J��+�+;�+E�+E�+G��(�)9�)C�)C�)E��&rc��grr
r s r�close�WebSocketAppTest.close8s��rz/Tests using local websocket server are disabledc�z^�SnU4SjnSn[R"S[3UUUS9nUR5 g)�kA WebSocketApp should keep running as long as its self.keep_running14is not False (in the boolean context).15c�^�URS5 UR[lSUlg)zUSet the keep_running flag for later inspection and immediately16close the connection.17�hello!FN)�send�keep_runningrr�r!�args�kwargss   r�on_open�3WebSocketAppTest.test_keep_running.<locals>.on_openCs'��
�I�I�h��15�1B�1B��.� %�D�rc�<>�[U5 TR5 gr��printr(��_�messager!s  �r�18on_message�6WebSocketAppTest.test_keep_running.<locals>.on_messageK�����'�N��J�J�Lrc�.�UR[lg)z.Set the keep_running flag for the test to use.N)r/rrr0s   r�on_close�4WebSocketAppTest.test_keep_running.<locals>.on_closeOs��26�2C�2C��/r�ws://127.0.0.1:)r3r?r;N�r�WebSocketAppr�run_forever)r!r3r;r?�apps`    r�test_keep_running�"WebSocketAppTest.test_keep_running;sD���	&�	�	D��o�o��2�3�4���!�	19��	���rFz$Test disabled for now (requires rel)c�p^�SnU4Sjn[R"S[3UUS9nURSS9 g)r+c�h�URS5 UR5 URS5 g)z*Send a message, receive, and send one morer-zgoodbye!N)r.�recvr0s   rr3�=WebSocketAppTest.test_run_forever_dispatcher.<locals>.on_openbs#���I�I�h���I�I�K��I�I�j�!rc�<>�[U5 TR5 grr6r8s  �rr;�@WebSocketAppTest.test_run_forever_dispatcher.<locals>.on_messagehr=rrA)r3r;�20Dispatcher)�21dispatcherNrB)r!r3r;rEs`   r�test_run_forever_dispatcher�,WebSocketAppTest.test_run_forever_dispatcher\s?���	"�	��o�o��2�3�4��!�22��23	���<��0rc���[R"S[35n[R"SUR24S9R
5 UR5nURUS5 g)zaThe WebSocketApp.run_forever() method should return `False` when the application ends gracefully.rAg�������?)�interval�functionFN)	rrCr�	threading�Timerr(�startrD�assertEqual)r!rE�teardowns   r�$test_run_forever_teardown_clean_exit�5WebSocketAppTest.test_run_forever_teardown_clean_exitvsR��25�o�o��0D�/E�F�G������s�y�y�9�?�?�A��?�?�$������5�)rz%Internet-requiring tests are disabledc��Sn[R"SUS9nUR[UR5[U55 g)zXA WebSocketApp should forward the received mask_key function down26to the actual socket.27c��g)Nzr
r
rr�my_mask_key_func�=WebSocketAppTest.test_sock_mask_key.<locals>.my_mask_key_func�s��%r�wss://api-pub.bitfinex.com/ws/1)�get_mask_keyN)rrCrX�idra)r!r^rEs   r�test_sock_mask_key�#WebSocketAppTest.test_sock_mask_key�s@��	&��o�o�-�<L�28��	
����C�,�,�-�r�2B�/C�Drc��SnSn[R"SXS9nUR[RURSSS[29R0S9 g	)30z7Test exception handling if ping_interval < ping_timeoutc�:�[S5 UR5 g�NzGot a ping!r6�rEr9s  r�on_ping�IWebSocketAppTest.test_invalid_ping_interval_ping_timeout.<locals>.on_ping�����-� ��I�I�Krc�:�[S5 UR5 g�NzGot a pong! No need to respondr6rhs  r�on_pong�IWebSocketAppTest.test_invalid_ping_interval_ping_timeout.<locals>.on_pong�����2�3��I�I�Krr`�rirn���	cert_reqs��
ping_interval�ping_timeout�ssloptN�rrC�assertRaises�WebSocketExceptionrD�ssl�	CERT_NONE�r!rirnrEs    r�'test_invalid_ping_interval_ping_timeout�8WebSocketAppTest.test_invalid_ping_interval_ping_timeout�sX��	�	��o�o�-�w�31��	
����!�!��O�O�������/�	�	32rc�|�SnSn[R"SXS9nURSSS[R0S9 g	)33z+Test WebSocketApp proper ping functionalityc�:�[S5 UR5 grgr6rhs  rri�4WebSocketAppTest.test_ping_interval.<locals>.on_ping�rkrc�:�[S5 UR5 grmr6rhs  rrn�4WebSocketAppTest.test_ping_interval.<locals>.on_pong�rprr`rqrsrrrtruN)rrCrDr|r}r~s    r�test_ping_interval�#WebSocketAppTest.test_ping_interval�sD��	�	��o�o�-�w�34��	����!�[�#�-�-�4P�	�	35rc�R�[R"S5nURSSSS9 g)zTest WebSocketApp close opcode�'wss://tsock.us1.twilio.com/v3/wsconnectrsrrzPing payload)rvrw�ping_payloadN)rrCrD�r!rEs  r�test_opcode_close�"WebSocketAppTest.test_opcode_close�s%���o�o�G�H�����a�a�n��Urc��[R"S5nUR[RURSS[36R0S9 g)z1A WebSocketApp handling of negative ping_intervalr`�����rt)rvrxNryr�s  r�test_bad_ping_interval�'WebSocketAppTest.test_bad_ping_interval�sE���o�o�?�@������!�!��O�O������/�		�	37rc��[R"S5nUR[RURSS[38R0S9 g)z0A WebSocketApp handling of negative ping_timeoutr`�����rt)rwrxNryr�s  r�test_bad_ping_timeout�&WebSocketAppTest.test_bad_ping_timeout�sE���o�o�?�@������!�!��O�O������/�		�	39rc��Sn[R"SUS9n[R"[RRSS9nUR	SS/URU55 [R"[RRSS9nUR	S	S	/URU55 [R"S5n[R"[RRSS9nUR	S	S	/URU55 UR
[RURS40S9 g	)zKTest extraction of close frame status code and close reason in WebSocketAppc��[S5 g)Nzon_close reached)r7)�wsapp�close_status_code�	close_msgs   rr?�9WebSocketAppTest.test_close_status_code.<locals>.on_close�s���$�%rr�)r?s�no-init-from-client)�opcode�datai�zno-init-from-clientrNztest if connection is closed)r�)	rrC�ABNF�OPCODE_CLOSErX�_get_close_argsrz�"WebSocketConnectionClosedExceptionr.)r!r?rE�41closeframe�app2s     r�test_close_status_code�'WebSocketAppTest.test_close_status_code�s��	&��o�o�5��42���W�W��7�7�'�'�.L�43�44�	
���$� 5�6��8K�8K�J�8W�X��W�W�B�G�G�$8�$8�s�C�45����$���s�':�':�:�'F�G����H�I���W�W�B�G�G�$8�$8�s�C�46����$���t�';�';�J�'G�H�����1�1��H�H�/�	�	47rc�^^�SmSmSnUU4SjnSn[R"S[3UUUS9nURSSS	9 UR	TU5 URT[5 UR	[T5S485 g)z)Test callback function exception handlingNc��[S5e�N�Callback failed��RuntimeError)rEs rr3�BWebSocketAppTest.test_callback_function_exception.<locals>.on_opens���0�1�1rc�>�UmUmgrr
)rE�err�exc�49passed_apps  ��r�on_error�CWebSocketAppTest.test_callback_function_exception.<locals>.on_errors
����J��Crc�$�UR5 gr�r(rhs  rrn�BWebSocketAppTest.test_callback_function_exception.<locals>.on_pongs���I�I�KrrA�r3r�rnrsrr�rvrwr�)rrCrrDrX�assertIsInstancer��str)r!r3r�rnrEr�r�s     @@r� test_callback_function_exception�1WebSocketAppTest.test_callback_function_exception�s�������50�	2�	�	��o�o��2�3�4����	51��	���a�a��8�����S�)����c�<�0�����S��#4�5rc���"SS5nU"5nURURUR5 URUR[525 UR[
UR5S5 g)z'Test callback method exception handlingc�,�\rSrSrSrSrSrSrSrg)�BWebSocketAppTest.test_callback_method_exception.<locals>.Callbacksi#c���SUlSUl[R"S[3UR53URURS9UlURRSSS9 g)NrAr�rsrrr�)54r�r�rrCrr3r�rnrErDr s r�__init__�KWebSocketAppTest.test_callback_method_exception.<locals>.Callbacks.__init__$sZ�����"&����?�?�%�&:�%;�<� �L�L�!�]�]� �L�L�	������$�$�1�1�$�Erc��[S5er�r�)r!r9s  rr3�JWebSocketAppTest.test_callback_method_exception.<locals>.Callbacks.on_open/s��"�#4�5�5rc��XlX lgr)r�r�)r!rEr�s   rr��KWebSocketAppTest.test_callback_method_exception.<locals>.Callbacks.on_error2s��"%���rc�$�UR5 grr�)r!rEr9s   rrn�JWebSocketAppTest.test_callback_method_exception.<locals>.Callbacks.on_pong6s���	�	�r)rEr�r�N)	rrrrr�r3r�rnrr
rr�	Callbacksr�#s��	
F�
6�
�
rr�r�N)rXr�rEr�r�r�r�)r!r��	callbackss   r�test_callback_method_exception�/WebSocketAppTest.test_callback_method_exceptions]��	�	�,�K�	�����-�-�y�}�}�=����i�m�m�\�:�����Y�]�]�+�->�?rc�^^�SmSmU4SjnU4Sjn[R"S[3X!S9nURSSS	S559 UR	TS5 URT[R5 UR	[T5S5 g)zTest reconnectrNc�56>�Umgrr
)r9r�r�s  �rr��1WebSocketAppTest.test_reconnect.<locals>.on_errorGs����Crc�~>�TS-
mTS:XaURR5 TS:�aUR5 gg)Nrrrs)�sock�shutdownr()rEr9�57pong_counts  �rrn�0WebSocketAppTest.test_reconnect.<locals>.on_pongKs8����!�O�J��Q�����!�!�#��Q���	�	��rrA)rnr�rsrr�)rvrw�	reconnectzping/pong timed out)rrCrrDrXr��WebSocketTimeoutExceptionr�)r!r�rnrEr�r�s    @@r�test_reconnect�WebSocketAppTest.test_reconnect?s����58�59���	�	��o�o��2�3�4�g�60��	���a�a�1��E�����Q�'����c�2�#?�#?�@�����S��#8�9rc��[R"S5nURSSS9nURU[RR615 g)z!Test default dispatcher selection�ws://example.com�62F�rw�is_sslN)rrC�create_dispatcherr��_dispatcherrN�r!rErOs   r�!test_dispatcher_selection_default�2WebSocketAppTest.test_dispatcher_selection_default^sB���o�o�0�1���*�*��5�*�I�63����j�"�.�.�*C�*C�Drc��[R"S5nURSSS9nURU[RR645 g)zTest SSL dispatcher selectionzwss://example.comr�Tr�N)rrCr�r�r��
SSLDispatcherr�s   r�test_dispatcher_selection_ssl�.WebSocketAppTest.test_dispatcher_selection_sslfsB���o�o�1�2���*�*��4�*�H�65����j�"�.�.�*F�*F�Grc�>�SSKJn [R"S5nU"5nU"5nUR	SUUS9nURU[RR5 URURU5 URURU5 g)z Test custom dispatcher selectionr)�Mockr�r�)rwrO�handleDisconnectN)�
unittest.mockr�rrCr�r�r��WrappedDispatcherrXrOr�)r!r�rE�custom_dispatcher�handle_disconnectrOs      r� test_dispatcher_selection_custom�1WebSocketAppTest.test_dispatcher_selection_customns���&��o�o�0�1�� �F�� �F���*�*��(�.�+�66�67�68	
���j�"�.�.�*J�*J�K�����.�.�0A�B�����4�4�6G�Hrc���[R"S5nURSSS9nURU[RR695 UR
URS5 g)z.Test dispatcher selection without ping timeoutr�NFr�r�)rrCr�r�r�rNrXrwr�s   r�)test_dispatcher_selection_no_ping_timeout�:WebSocketAppTest.test_dispatcher_selection_no_ping_timeout�sX���o�o�0�1���*�*��U�*�K�70����j�"�.�.�*C�*C�D�����0�0�"�5r)r/N)rrrrrr"r%r(�unittest�71skipUnless�TEST_WITH_LOCAL_SERVERrFrPrZrrcrr�r�r�r�r�r�r�r�r�r�r�r�rr
rrrr&s��N�N�F�F�
����� Q�����<���� F�G�1�H�1�2���� Q��*��*����+�-T�U�E�V�E� ���+�-T�U�72�V�73�,���+�-T�U�74�V�75�$���+�-T�U�V�V�V����+�-T�U�76�V�77����+�-T�U�78�V�79����+�-T�U�80�V�81�6���� Q��6��6�<���� Q��@��@�>���� Q��:��:�8E�H�I�$6rr�__main__)�os�os.pathr|rUr��	websocketr�environ�getrrr�r�TestCaserr�mainr
rr�<module>r�s���82��83�����(�Z�Z�^�^�$8�#�>�#�E���z�z�~�~�&<�d�C��-��5���	�a6�x�(�(�a6�H�z���M�M�O�r
codekingpro/portable-devtools · Team Ai