codekingpro/portable-devtools
114k
1�
2 p�j� � � � S SK Jr S SKrS SKrS SKrS SKrS SKJr SSKJ r J3r4 SSK J r SSK
Jr SSKJr SS KJr SS5KJr S /rSS jrSS
jr " S S\R0 5 rSS jr SS jrSS jr SSS jjr g)� )� annotationsN)� Generator� )�ClientConnection�connect)� SimpleQueue)�ConnectionClosed)�Close)� StreamReader)�version�mainc � � [ R R SU S35 [ R R 5 g )Nz 76[A[Lz78[B��sys�stdout�write�flush��strings �TD:\code\apps\devtools\python\user_packages\Python313\site-packages\websockets/cli.py�print_during_inputr s< � ��J�J��� � �(� � �� �J�J���� c � � [ R R SU S35 [ R R 5 g )Nz
[K�8r r s r �print_over_inputr ( s9 � ��J�J��� � �(�-� !�� �J�J���r c �P � \ rS rSrS9S jrS S jrS S jrS
S jrS10S jrSS jr Sr11g )� ReadLines�4 c �@ � [ 5 U l [ 5 U l g �N)r �readerr �messages��selfs r �__init__�ReadLines.__init__5 s � �"�n�� �*5�-��
r c # �` # � [ R R S5 [ R R 5 U R R [ R 5 S h v�N nU R R UR 5 R S5 5 M� N>7f)Nz> z
12) r r r r r! � read_line�maxsizer" �put�decode�rstrip)r$ �lines r �parse�ReadLines.parse9 ss � � �� �J�J� � �T� "� �J�J� � � � "�k�k� 3� 3�C�K�K� @�@�D� �M�M� � �d�k�k�m� 2� 2�6� :� ;� � A�s �A+B.�-B,�.?B.c �X � U R 5 U l [ U R 5 g r )r. �parser�next)r$ � transports r �connection_made�ReadLines.connection_made@ s � ��j�j�l�� � �T�[�[�r c �d � U R R U5 [ U R 5 g r )r! � feed_datar2 r1 )r$ �datas r �
data_received�ReadLines.data_receivedD s � � � � � � �d�#� �T�[�[�r c �8 � U R R 5 g r )r! �feed_eofr# s r � eof_received�ReadLines.eof_receivedH s � � � � � � � r c �l � U R R 5 U R R 5 g r )r! �discardr" �abort)r$ �excs r �connection_lost�ReadLines.connection_lostL s" � � � � ��� � �
�
��� r )r" r1 r! N)�return�None)rE zGenerator[None, None, None])r3 zasyncio.BaseTransportrE rF )r8 �bytesrE rF )rB zException | NonerE rF ) �__name__�13__module__� __qualname__�__firstlineno__r% r. r4 r9 r= rC �__static_attributes__� r r r r 4 s � �8�<��� � r r c � � # � U S h v�N n[ U[ 5 ( a [ SU- 5 M. [ SUR 5 - 5 ML NG14 g 7f)Nz< z < (binary) )�15isinstance�strr �hex)� websocket�messages r �print_incoming_messagesrT Q sB � � �"� >�g� �g�s� #� #� �t�g�~� .� �}�w�{�{�}� <� =� >��s& �A�A�A�A�AA�A�Ac � � # � UR 5 I S h v�N n U R U5 I S h v�N M5 N ! [ a g f = f N! [ a g f = f7fr )�get�EOFError�sendr )rR r" rS s r �send_outgoing_messagesrY Y sd � � � � � $�L�L�N�*�G� ��.�.��)� )� )�
�*��� � � ��
*�� � � � �s^ �A �; �9�; �A
�A �A
�A �; �16A�A �A�A � A
�
17A�A �A�A c � � # � [ U 5 I S h v�N n[ SU S35 [18 R " 5 nUR [ [ R 5 I S h v�N u pE[19 R " [ W5 5 n[20 R " [ XR 5 5 n [21 R " Xg/[22 R S9I S h v�N UR# 5 UR# 5 UR% 5 UR% 5 I S h v�N UR& b
UR( c e[+ UR& UR( 5 n[- SU S35 g GN`! [ a3 n[ SU SU S35 [ R " S5 S nAGN�S nAff = f GNS N�! [23 R a N�f = f! UR# 5 UR# 5 UR% 5 f = f N�7f)Nz
Connected to �.zFailed to connect to z: r )� return_whenzConnection closed: )r �print� Exceptionr �exit�asyncio�get_running_loop�connect_read_piper �stdin� create_taskrT rY r" �wait�FIRST_COMPLETED�CancelledError�cancel�close�24close_code� close_reasonr25 r ) �urirR rB �loopr3 �protocol�incoming�outgoing� close_statuss r �interactive_clientrr h s� � � �&�!�#�,�&� �26 �
�c�U�!�$�%� � #� #� %�D� $� 6� 6�y�#�)�)� L�L��I��"�"� � �*��H� �"�"� �y�*;�*;�<��H���l�l�
� � �/�/� 27� 28� 29� ������������30�/�/�31��� � � � +� �0F�0F�0R�R� R���-�-�y�/E�/E�F�L��*�<�.��:�;�I '�� � �
�%�c�U�"�S�E��3�4� ���� � ���� M� 32�� � !� !�
� �
�� ��������������s� �H �E5 �E2�E5 �A H �"F5�#AH �2'F: �F8�F: � AH �!H �"AH �2E5 �533F2�?(F-�'H �-F2�2H �8F: �:G�G �G�G �2H�H c �T � [ R " SSSS9nUR 5 nUR SSS9 UR SS S34S 9 UR U 5 nUR35 ( a [
S [ 35 g UR c& UR 5 [ R " S
5 [ R S:X a [ R " S5 SS Kn [" R$ " [' UR 5 5 g ! [ a N7f = f! [( a g f = f)N�36websocketsz Interactive WebSocket client.F)�prog� description�add_helpz --version�37store_true)�actionrl z<uri>�?)�metavar�nargsz websockets � �win32� r )�argparse�ArgumentParser� add_mutually_exclusive_group� add_argument�38parse_argsr r] �websockets_versionrl � print_usager r_ �platform�os�system�readline� ImportErrorr` �runrr �KeyboardInterrupt)�argvr1 �group�argsr� s r r
r
� s � �
�
$�
$�
�3���F�39
� /� /� 1�E� ���{�<��8� ���u�g�S��9� � � �T� "�D� �|�|�
� � .�/�0�1�� �x�x����� � ���� � �|�|�w� �40� � �"�
�
��41
�� � �&�t�x�x�0�1�� �
� �
�� �
� �
�s$ �D42 � )D �43 44D�D�45D'�&D')r rP rE rF )rR r rE rF )rR r r" zSimpleQueue[str]rE rF )rl rP rE rF r )r� zlist[str] | NonerE rF ) �46__future__r r� r` r� r �typingr �asyncio.clientr r �asyncio.messagesr �47exceptionsr �framesr48 �streamsr r r� �__all__r r �Protocolr rT rY rr r
rM r r �<module>r� s} �� "� � � � 49� � 5� )� (� � !� 2� �(���( � �� � � �:>� � � � � � 50� � &<�R!
r