codekingpro/portable-devtools
114k
1�
2 q�j� � �� � S SK r S SKrS SKrS SKrS SKJrJrJrJr \( a SSK J3r4 SSK J r SSK
Jr " S S5 r " S S5\5 r " S S \5 r " S
S5 rg)� N)�
TYPE_CHECKING�Callable�Optional�Union� )� WebSocketApp)�_logging��sendc � � \ rS rSrSrSSS\\\\4 SS4S jr S \\\\4 S6\7SS4S jr S \S \8SS4S
jr S\
R S\\\4 S\4S jrSrg)�DispatcherBase� z9DispatcherBase10�appr � ping_timeout�returnNc � � Xl X l g �N�r r )�selfr r s �[D:\code\apps\devtools\python\user_packages\Python313\site-packages\websocket/_dispatcher.py�__init__�DispatcherBase.__init__$ s � � �� (�� �seconds�callbackc �D � Ub [ R " U5 U" 5 g r )�time�sleep)r r r s r �timeout�DispatcherBase.timeout* s � � � � �J�J�w� ��11r � reconnectorc �12 � [ R " SU S[ [ R " 5 5 S35 [13 R " U5 U" SS9 g ! [ a n[ R " SU 35 UeS nAff = f)Nzreconnect() - retrying in z14 seconds [z frames in stack]T)� reconnectingz User exited )r �info�len�inspect�stackr r �KeyboardInterrupt)r r r! �es r � reconnect�DispatcherBase.reconnect/ sp � � � �M�M�,�W�I�Z��G�M�M�O�@T�?U�Uf�g�
�
�J�J�w� � �T� *�� � � �M�M�L���,� -��G�� �s �AA �15B�"A=�=B�sock�datac � � [ X5 $ r r16 �r r, r- s r r �DispatcherBase.send: s
� ��D� � r r )�__name__�17__module__� __qualname__�__firstlineno__�__doc__r r �float�intr r r r* �socket�str�bytesr �__static_attributes__� r r r
r
s� � ��)�!�)�19�%��s�18�:K�1L�)�
�)� �x��e�S�j�(9� :� �h� �SW� �19 �� �8� �� � �� � � �e�C��J�.?� �C� r r
c �F � \ rS rSrSrS\R20 S\S\SS4S jrS rg)21�22Dispatcher�> z 23Dispatcher24r, �
read_callback�check_callbackr Nc �@ � U R R b! U R R R c g [ R " 5 nUR U R R R [ R25 5 U R R ( aQ UR U R 5 ( a
U" 5 ( d O$U" 5 U R R ( a MQ UR 5 g ! UR 5 f = fr )26r r, � selectors�DefaultSelector�register�27EVENT_READ� keep_running�selectr �close�r r, r@ rA �sels r �read�Dispatcher.readC s� � � �8�8�=�=� �D�H�H�M�M�$6�$6�$>� ��'�'�)�� � � �T�X�X�]�]�'�'��)=�)=�>� ��(�(�'�'��:�:�d� /� /�0�0�(�?�?� � � � �(�(�'�'�'�
�I�I�K��C�I�I�K�s
�A*D � D r< ) r1 r2 r3 r4 r5 r8 r rL r; r< r r r> r> > s6 � ����m�m�� �� !� �28 29� r r> c �h � \ rS rSrSrS\R30 S\S\SS4S jrS \R 4S31 jr32S r g) �
SSLDispatcher�W z33SSLDispatcher34r, r@ rA r Nc �0 � U R R b! U R R R c g U R R R n[ R " 5 nUR U[ R35 5 U R R ( aG U R X5 ( a
U" 5 ( d O$U" 5 U R R ( a MG UR 5 g ! UR 5 f = fr ) r r, rC rD rE rF rG rH rI rJ s r rL �SSLDispatcher.read\ s� � � �8�8�=�=� �D�H�H�M�M�$6�$6�$>� ��x�x�}�}�!�!���'�'�)�� � � �T�9�/�/�0� ��(�(�'�'��;�;�t�)�)�(�?�?� � � � �(�(�'�'�'�
�I�I�K��C�I�I�K�s
�A D �DrK c � � U R R c g U R R R nUR 5 ( a U/$ UR U R 5 n[ U5 S:� a US S $ g )Nr )r r, �pendingrH r r% )r r, rK �rs r rH �SSLDispatcher.selectp so � � �8�8�=�=� ���x�x�}�}�!�!�� �<�<�>�>���
�
�J�J�t�(�(� )�� �q�6�A�:��Q�4��7�N�r r< ) r1 r2 r3 r4 r5 r8 r rL rC rD rH r; r< r r rO rO W sH � ����m�m�� �� !� �36 37� �(
� � 9� 9�
r rO c �� � \ rS rSrSrSSS\\\\4 SS4S jr S \38R S39\ S \ SS4S jr S \40R S
\\
\4 S\4S jrS\S\ SS4S jrS\S\ SS4S jrSrg)�WrappedDispatcher� z41WrappedDispatcher42r r r r Nc �l � Xl X l X0l X@l UR SUR43 5 g )N� )r r �44dispatcher�handleDisconnect�signal�abort)r r r r\ r] s r r �WrappedDispatcher.__init__� s0 � � �� (��$�� 0� ����!�Z� -� -�.r r, r@ rA c � � U R R X5 U R ( a U R U R U5 g g r )r\ rL r r )r r, r@ rA s r rL �WrappedDispatcher.read� s8 � �
��� � �T�1� � � � �L�L��*�*�N� ;� r r- c �n � U R R X[ U R 5 [ U5 $ r )r\ � buffwriter r] r% r/ s r r �WrappedDispatcher.send� s( � � ���!�!�$�d�D�4I�4I�J��4�y�r r r c �> � U R R " X/UQ76 g r )r\ r )r r r �argss r r �WrappedDispatcher.timeout� s � � ��� � ��9�D�9r r! c �( � U R XS5 g )NT)r )r r r! s r r* �WrappedDispatcher.reconnect� s � � � � �W�4�0r )r r\ r] r )r1 r2 r3 r4 r5 r r r6 r7 r r8 r rL r9 r: r r r* r; r< r r rX rX � s� � �� /�
� /� �u�U�C�Z� 0�1� /� 45�
/�<��m�m�<� �<� !� <�46 47� <��� � � �e�C��J�.?� �C� �:�u� :�� :�D� :�1�� 1�8� 1�� 1r rX )r r8 r& rC �typingr r r r �_appr � r �_socketr r
r> rO rX r< r r �<module>ro sU �� �
� � � ;� ;��"� � ��& � �>� � �2&�N� &�R$1� $1r