Team Ai
Datasetpublic

codekingpro/portable-devtools

sourceHugging Faceupdated 5mo agoView on Hugging Face
1likes15kdownloads
client_ws.cpython-313.pyc100 linesDownload Raw Back to __pycache__
1�

2��j�<��d�SrSSKrSSKrSSKJr SSKJrJrJrJ	r	 SSK3r4SSKJr SSK
JrJrJr SSKJr SS	KJrJr SS5KJrJrJrJrJrJr SSKJrJr SSK J!r! SS
K"J#r#J$r$J%r%J&r& \RNS:�aSSKr(OSSK(r(\6RR"SSS9"SS55r*\*"SSS9r+"SS5r,g)zWebSocket client for asyncio.�N)�
TracebackType)�Any�Optional�Type�cast�)�WebSocketDataQueue)�ClientError�ServerTimeoutError�WSMessageTypeError)�ClientResponse)�calculate_timeout_when�7set_result)�WS_CLOSED_MESSAGE�WS_CLOSING_MESSAGE�WebSocketError�WSCloseCode�	WSMessage�	WSMsgType)�_INTERNAL_RECEIVE_TYPES�WebSocketWriter)�	EofStream)�DEFAULT_JSON_DECODER�DEFAULT_JSON_ENCODER�JSONDecoder�JSONEncoder)��T)�frozen�slotsc�d�\rSrSr\R8"\\SS9r\R9"\\SS9r	Sr10g)�ClientWSTimeout�%N)�type�default�)�__name__�11__module__�__qualname__�__firstlineno__�attr�ibr�float�12ws_receive�ws_close�__static_attributes__r&��WD:\code\apps\devtools\python\user_packages\Python313\site-packages\aiohttp/client_ws.pyr"r"%s*�����h�u�o�t�<�J��w�w�H�U�O�T�:�Hr1r"g$@)r.r/c�X�\rSrSrSSSS.S\S\S\\S	\S13\	S\14S\15S
\RS\\
S\S\16SS4SjjrSDSjrSDSjrSDSjrSDSjrSESjrSDSjrS\SS4SjrSDSjrSDSjr\S\174Sj5r\S\\4Sj5r\S\\4Sj5r\S\4S j5r\S\184S!j5rSFS"\S#\ S\ 4S$jjr!S\\4S%jr"SGS'\#SS4S(jjr$SGS'\#SS4S)jjr%SFS'\#S*\&S\\SS4S+jjr'SFS,\S\\SS4S-jjr(SFS,\#S\\SS4S.jjr)SF\*S/.S,\ S\\S0\+SS4S1jjjr,\-R\S&S2.S3\S'\#S\194S4jjr/SFS20\\
S\04S5jjr1SS6.S21\\
S\4S7jjr2SS6.S22\\
S\#4S8jjr3\4SS9.S:\5S23\\
S\ 4S;jjr6SHS<jr7S\04S=jr8SHS>jr9S?\\:\S@\\SA\\;SS4SBjr<SCr=g)I�ClientWebSocketResponse�.NrF)�	heartbeat�compress�client_notakeover�reader�writer�protocol�response�timeout�	autoclose�autoping�loopr6r7r8�returnc	�p�X@lURUlX lXlX0lSUlSUlSUlXPl	X`l24XplX�lSUl
SUlU	b25U	S-UlSUlX�lSUlSUlSUlX�lX�lSUlUR15 g)NFgg@)�	_response�26connection�_conn�_writer�_reader�	_protocol�_closed�_closing�_close_code�_timeout�27_autoclose�	_autoping�28_heartbeat�
_heartbeat_cb�_heartbeat_when�_pong_heartbeat�_pong_response_cb�_loop�_waiting�_close_wait�29_exception�	_compress�_client_notakeover�30_ping_task�_reset_heartbeat)�selfr9r:r;r<r=r>r?r@r6r7r8s            r2�__init__� ClientWebSocketResponse.__init__/s���"���(�(��31�����!�������
�*.����
�#��!��#��<@���&)���� �#,�s�?�D� �@D����32�#��
�;?���37���!��"3��8<������r1c���UR5 URb!URR5 SUlURb"URR5 SUlgg�N)�_cancel_pong_response_cbrP�cancelrZ�r\s r2�_cancel_heartbeat�)ClientWebSocketResponse._cancel_heartbeatZsZ���%�%�'����)����%�%�'�!%�D���?�?�&��O�O�"�"�$�"�D�O�'r1c�b�URb"URR5 SUlggr`)rSrbrcs r2ra�0ClientWebSocketResponse._cancel_pong_response_cbcs-���!�!�-��"�"�)�)�+�%)�D�"�.r1c�d�URcgUR5 URnUceURnUbURR33OSnUR
5n[X@RU5nXPlURc!URXPR5Ul	gg)N�)rOrarTrE�34_connector�_timeout_ceil_threshold�timerrQrP�call_at�_send_heartbeat)r\r@�conn�timeout_ceil_threshold�now�whens      r2r[�(ClientWebSocketResponse._reset_heartbeaths����?�?�"���%�%�'��z�z�������z�z��7;�7G�D�O�O�3�3�Q�	��i�i�k��%�c�?�?�<R�S��#�����%�"&���d�4H�4H�!I�D��
&r1c���SUlURnUR5nX R:a,UR	URUR355UlgURnUbURROSn[X RU5nUR5 UR	XPR5Ul
URRS[ R"5n[$R&S:�a[(R*"XaSS9nOUR-U5nUR/5(d"XplUR3UR45 gUR5U5 g)Nrir1)r�T)r@�eager_start)rPrTrlrQrmrnrErjrkrrRra�_pong_not_receivedrSrF�36send_framer�PING�sys�version_info�asyncio�Task�create_task�donerZ�add_done_callback�_ping_task_done)r\r@rqrorprr�coro�	ping_tasks        r2rn�'ClientWebSocketResponse._send_heartbeat}s)��!����z�z���i�i�k���%�%�%�!%����$�$�d�&:�&:�"�D��
��z�z��7;�7G�D�O�O�3�3�Q�	�&�c�+?�+?�AW�X���%�%�'�!%���d�4K�4K�!L����|�|�&�&�s�I�N�N�;�����w�&� ���T�$�G�I��(�(��.�I��~�~���'�O��'�'��(<�(<�=�� � ��+r1c��UR5(d(UR5=n(aURU5 SUlg)z*Callback for when the ping task completes.N)�	cancelled�	exception�_handle_ping_pong_exceptionrZ)r\�task�excs   r2r��'ClientWebSocketResponse._ping_task_done�s5���~�~���D�N�N�,<�%<�S�%<��,�,�S�1���r1c�T�UR[SURS355 g)NzNo PONG received after z seconds)r�rrRrcs r2rw�*ClientWebSocketResponse._pong_not_received�s)���(�(��!8��9M�9M�8N�h�W�X�	37r1r�c�d�UR(agUR5 [RUlXlURR5 UR(aHUR(d6URR[[RUS5S5 ggg)z5Handle exceptions raised during ping/pong processing.Nr)rI�_set_closedr�ABNORMAL_CLOSURErKrWrC�closerUrJrG�	feed_datarr�ERROR)r\r�s  r2r��3ClientWebSocketResponse._handle_ping_pong_exception�sp���<�<������&�7�7������������=�=�����L�L�"�"�9�Y�_�_�c�4�#H�!�L�"/�=r1c�2�SUlUR5 g)zTSet the connection to closed.38 39Cancel any heartbeat timers and set the closed flag.40TN)rIrdrcs r2r��#ClientWebSocketResponse._set_closed�s��41������ r1c�2�SUlUR5 g)zVSet the connection to closing.42 43Cancel any heartbeat timers and set the closing flag.44TN)rJrdrcs r2�_set_closing�$ClientWebSocketResponse._set_closing�s��45��
���� r1c��UR$r`)rIrcs r2�closed�ClientWebSocketResponse.closed�s���|�|�r1c��UR$r`)rKrcs r2�46close_code�"ClientWebSocketResponse.close_code�s�����r1c��UR$r`)rHrcs r2r;� ClientWebSocketResponse.protocol�����~�~�r1c��UR$r`)rXrcs r2r7� ClientWebSocketResponse.compress�r�r1c��UR$r`)rYrcs r2r8�)ClientWebSocketResponse.client_notakeover�s���&�&�&r1�namer%c�|�URRnUcU$URnUcU$URX5$)z$extra info from connection transport)rCrD�	transport�get_extra_info)r\r�r%ror�s     r2r��&ClientWebSocketResponse.get_extra_info�s@���~�~�(�(���<��N��N�N�	����N��'�'��6�6r1c��UR$r`)rWrcs r2r��!ClientWebSocketResponse.exception�s�����r1r1�messagec��t# �URRU[R5IShv�N gN7fr`)rFrxrry�r\r�s  r2�ping�ClientWebSocketResponse.ping��#����l�l�%�%�g�y�~�~�>�>�>���.8�6�8c��t# �URRU[R5IShv�N gN7fr`)rFrxr�PONGr�s  r2�pong�ClientWebSocketResponse.pong�r�r��opcodec��X# �URRXU5IShv�N gN7f)z Send a frame over the websocket.N)rFrx)r\r�r�r7s    r2rx�"ClientWebSocketResponse.send_frame�s!����l�l�%�%�g�x�@�@�@�s� *�(�*�datac���# �[U[5(d[S[U5-5eURRUR
S5[RUS9IShv�N gN7f)Nzdata argument must be str (%r)zutf-8�r7)	�47isinstance�str�	TypeErrorr$rFrx�encoder�TEXT�r\r�r7s   r2�send_str� ClientWebSocketResponse.send_str�s\����$��$�$��<�t�D�z�I�J�J��l�l�%�%��K�K�� �)�.�.�8�&�48�	49�	50�s�A(A2�*A0�+A2c���# �[U[[[45(d[	S[U5-5eURRU[RUS9IShv�N gN7f)Nz#data argument must be byte-ish (%r)r�)51r��bytes�	bytearray�52memoryviewr�r$rFrxr�BINARYr�s   r2�53send_bytes�"ClientWebSocketResponse.send_bytes�sS����$��	�:� >�?�?��A�D��J�N�O�O��l�l�%�%�d�I�,<�,<�x�%�P�P�P�s�A$A.�&A,�'A.)�dumpsr�c��L# �URU"U5US9IShv�N gN7f)Nr�)r�)r\r�r7r�s    r2�	send_json�!ClientWebSocketResponse.send_json�s!����m�m�E�$�K�(�m�;�;�;�s�$�"�$)�coder�r�c��# �UR(a�UR(drURceURR5UlUR5 URR[S5 URIShv�N UR(agUR5 URRX5IShv�N UR"(aUR$R5 g[*R,"UR.R05IShv�N URR35IShv�NnSSS5IShv�N WR4[6R8La,UR:UlUR$R5 gM�GN)N�![Ra1 [R UlUR$R5 e[&a?n[R UlX0lUR$R5 SnAgSnAff=fGNN�N�!,IShv�N(df   N�=f![Ra1 [R UlUR$R5 e[&a?n[R UlX0lUR$R5 SnAgSnAff=f7f)NrFT)rUrJrT�
create_futurerVr�rGr�rrIr�rFr�r|�CancelledErrorrr�rKrC�	ExceptionrW�
async_timeoutr=rLr/�readr$r�CLOSEr�)r\r�r�r��msgs     r2r��ClientWebSocketResponse.closes����=�=�����:�:�)�)�)�#�z�z�7�7�9�D�������L�L�"�"�#5�q�9��"�"�"�"��<�<������54	��,�,�$�$�T�3�3�3�����N�N� � �"���
�(�0�0����1G�1G�H�H� $��� 1� 1� 3�3�C�I�H��x�x�9�?�?�*�#&�8�8�� ����$�$�&��#�-
#�
4���%�%�	�*�;�;�D���N�N� � �"���	�*�;�;�D��!�O��N�N� � �"���		��I�3�I�H�H�H���)�)�
�#.�#?�#?�� ����$�$�&���
�#.�#?�#?�� �"%�����$�$�&���	
�s��BK?�F;�&K?�:G�F>�G�-K?�.I0�9I�:I0�=I�I�I� I0�+I�,I0�0AK?�>G�A
I�
5I�K?�I�K?�I0�I�I0�I-�I�I-�)I0�,K?�-I0�0A
K<�=5K7�2K?�7K<�<K?c��	# �U=(d URRnUR(a[S5eUR(a[55$UR(aUR5IShv�N [56$SUlU(aR[R"U5IShv�N URR5IShv�NnSSS5IShv�N O"URR5IShv�NnUR5 SUlUR(a[URS5 WRD[F;aU$URD[0RHLa]URC5 URJUlUR(d)URL(aUR5IShv�N U$URD[0RNLaURC5 U$URD[0RPLa7URR(a&URUURJ5IShv�N GM8URD[0RVLaURR(aGMiU$GNGN�GN�GN�!,IShv�N(df   GN�=fGN�!SUlUR(a[URS5 ff=f![R [R"4a [$R&Ule[*aL [$R,UlUR5IShv�N [/[0R2SS5s$[4a. UR75 [$R&Ul[57s$[8aXnUR:UlURUR:S9IShv�N [/[0R<US5sSnA$SnAf[>ainX@l URC5 [$R&UlUR5IShv�N [/[0R<US5sSnA$SnAff=fGN�GN57f)NTz+Concurrent call to receive() is not allowedF)r�),rLr.rU�RuntimeErrorrIrrJr�r�r=rGr�r[rVrr|r��TimeoutErrorrr�rKr�OKrr�CLOSEDr58r�rr�r�r�rWr�r$rr�r�rM�CLOSINGryrNr�r�)r\r=�receive_timeoutr�r�s     r2�receive�ClientWebSocketResponse.receive8s+���!�=�T�]�]�%=�%=����}�}�"�#P�Q�Q��|�|�(�(�����j�j�l�"�"�(�(�&
=� $��
�;�&�59$1�#8�#8��#I�#I�(,���(9�(9�(;�";�C�$J�#I�#I�%)�L�L�$5�$5�$7�7���)�)�+�$)�D�M��'�'�"�4�#3�#3�T�:�0�x�x�6�6��60��x�x�9�?�?�*��!�!�#�#&�8�8�� ��|�|�����*�*�,�&�&��J����Y�.�.�.��!�!�#��J�
���Y�^�^�+�����i�i����)�)�)�����Y�^�^�+������J�{#�$J�";�$J�#I�#I�#I��8��%*�D�M��'�'�"�4�#3�#3�T�:�(���*�*�G�,@�,@�A�
�#.�#?�#?�� ���
?�#.�>�>�� ��j�j�l�"�"� ��!1�!1�4��>�>��
)�� � �"�#.�#?�#?�� �(�(�!�
=�#&�8�8�� ��j�j�c�h�h�j�/�/�/� ����#�t�<�<���
=�"%���!�!�#�#.�#?�#?�� ��j�j�l�"�"� ����#�t�<�<��
=�� '�*�s5�A8R61�:J
�;62R63�K+�!J7�/J�0J7�3J�J�J�J7�!J�""J7�J4�J7�.K+�B	R64�R�BR65�R�;R66�J7�J�J7�J1�J"� J1�,	J7�71K(�(K+�+A+R�M� R�7R67�94R�-R68�/	R�8-P�%O(�&P�R�R69�
R�>Q<�Q�Q<�6R�7R70�<R�R71�R72�r=c���# �URU5IShv�NnUR[RLa'[	SURSUR73<S35e[
[UR745$Nb7f)N�Received message �:z is not WSMsgType.TEXT)r�r$rr�rr�rr��r\r=r�s   r2�receive_str�#ClientWebSocketResponse.receive_str�sf����L�L��)�)���8�8�9�>�>�)�$�#�C�H�H�:�Q�s�x�x�l�:P�Q��
��C����"�"�*���A<�A:�A#A<c���# �URU5IShv�NnUR[RLa'[	SURSUR75<S35e[
[UR765$Nb7f)Nr�r�z is not WSMsgType.BINARY)r�r$rr�rr�rr�r�s   r2�
receive_bytes�%ClientWebSocketResponse.receive_bytes�sh����L�L��)�)���8�8�9�+�+�+�$�#�C�H�H�:�Q�s�x�x�l�:R�S��
��E�3�8�8�$�$�*�r�)�loadsr=r�c��L# �URUS9IShv�NnU"U5$N7f)Nr�)r�)r\r�r=r�s    r2�receive_json�$ClientWebSocketResponse.receive_json�s,����%�%�g�%�6�6���T�{��7�s�$�"�
$c��U$r`r&rcs r2�	__aiter__�!ClientWebSocketResponse.__aiter__�s���r1c���# �UR5IShv�NnUR[R[R[R774;a[eU$NI7fr`)r�r$rr�r�r��StopAsyncIteration)r\r�s  r2�	__anext__�!ClientWebSocketResponse.__anext__�sF����L�L�N�"���8�8�	����):�):�I�<L�<L�M�M�$�$��78�#�s�A"�A �A79A"c��# �U$7fr`r&rcs r2�80__aenter__�"ClientWebSocketResponse.__aenter__�s81�����s��exc_type�exc_val�exc_tbc��@# �UR5IShv�N gN7fr`)r�)r\r�r�rs    r2�	__aexit__�!ClientWebSocketResponse.__aexit__�s����j�j�l���s���)rMrNrYrKrVrIrJrXrErWrOrPrQrTrZrRrSrHrGrCrLrUrF)rAN)r�zasyncio.Task[None]rANr`)r1)rAr4)>r'r(r)r*r	rrr�r
r"�boolr|�AbstractEventLoopr-�intr]rdrar[rnr�rw�
BaseExceptionr�r�r��propertyr�r�r;r7r8rr�r�r�r�r�rrxr�r�rrr�rr�r�rr�r�r�rrr�r�r�r�rrrr0r&r1r2r4r4.sk��&*��"'�) �"�) � �) ��3�-�	) �82!�) �!�
) ��) ��) ��'�'�) ��E�?�) ��) � �) �83�) �V#�*�84J�* ,�D�85�86	M�}�	M��	M�!�!�������� �H�S�M� �� ���(�3�-������#�����'�4�'��'�7�3�7��7��7��8�M�2��?�%�?�$�?�?�%�?�$�?�LP�A��A�&/�A�;C�C�=�A�	
�A�87�3�88�(�3�-�89�4�90�Q�U�Q�h�s�m�Q�t�Q�#'�<�912�<��<��3�-�<�92�<�93�
<�*5���#�/�3�/�%�/�RV�/�bG�X�e�_�G�	�G�R?C�#�H�U�O�#�s�#�AE�%�h�u�o�%��%�2�#'�	����%��	�9495
���������4�
�.�/���-�(����'�	�9697�r1r4)-�__doc__r|rz�typesr�typingrrrrr+�_websocket.readerr	�client_exceptionsr98rr�
client_reqrepr
�helpersrr�httprrrrrr�http_websocketrr�streamsr�typedefsrrrrr{r��sr"�DEFAULT_WS_CLIENT_TIMEOUTr4r&r1r2�<module>rs���#��99��,�,��1�R�R�)�7���E�������w��#�����t�4� �;�;�!�;�100,�t�d�K��~�~r1
codekingpro/portable-devtools · Team Ai