codekingpro/portable-devtools
114k
1�
2 ��j} � �X � S SK Jr S SKrSSKJrJr SSKJr SSKJ r \R ( a- S SK r S SK r \R \ R \ R 4 r\R \\R" 4 r\R& / \R( \ 4 r\R& \R \\R" 4 /\R( S 4 r\R& \R \\R" 4 \\/\R( S 4 rS/rSS jrSS3 jr " S S \5 r " S
S\ 5 r g)� )� annotationsN� )�Request�Response)�AsyncByteStream� )�AsyncBaseTransport�
ASGITransportc �Z � SS K n U R 5 S:X a g g! [ a gf = f)Nr �trioTF)�sniffio�current_async_library� ImportError)r
s �HD:\code\apps\devtools\python\Lib\site-packages\httpx/_transports/asgi.py�is_running_trior sA � �
� � � (� (� *�f� 4�� 5�4 �� �
� � �
�s � �5*�*c �t � [ 5 ( a SS Kn U R " 5 $ SS KnUR " 5 $ )Nr )r r �Event�asyncio)r r s r � create_eventr , s) � ������z�z�|��� �=�=�?�� c �( � \ rS rSrSS jrSS jrSrg)�ASGIResponseStream�7 c � � Xl g �N��_body)�self�bodys r �__init__�ASGIResponseStream.__init__8 s � ��6r c �H # � SR U R 5 7v � g 7f)Nr )�joinr )r s r � __aiter__� ASGIResponseStream.__aiter__; s � � ��h�h�t�z�z�"�"�s � "r N)r z list[bytes]�return�None)r& ztyping.AsyncIterator[bytes])�__name__�7__module__� __qualname__�__firstlineno__r r$ �__static_attributes__� r r r r 7 s � ��#r r c �P � \ rS rSrSr S SS jjr S S jrSrg)8r9 �? a� 10A custom AsyncTransport that handles sending requests directly to an ASGI app.11 12```python13transport = httpx.ASGITransport(14 app=app,15 root_path="/submount",16 client=("1.2.3.4", 123)17)18client = httpx.AsyncClient(transport=transport)19```20 21Arguments:22 23* `app` - The ASGI application.24* `raise_app_exceptions` - Boolean indicating if exceptions in the application25 should be raised. Default to `True`. Can be set to `False` for use cases26 such as testing the content of a client 500 response.27* `root_path` - The root path on which the ASGI application should be mounted.28* `client` - A two-tuple indicating the client IP and port of incoming requests.29```30c �4 � Xl X l X0l X@l g r )�app�raise_app_exceptions� root_path�client)r r1 r2 r3 r4 s r r �ASGITransport.__init__W s � � ��$8�!�"�� � r c
� �� ^^^ ^31^ ^ ^
^# � [ TR [ 5 ( d eSSS0STR TR R32 VVs/ s H u p#UR
5 U4PM snnTR R TR R TR R R S5 S TR R TR R TR R 4U R U R S. nTR R# 5 m Sm33S mS m / mSm
[% 5 m S
U U34U 4S jjnSUUU U U
U4S35 jjn U R' XEU5 I S h v�N T R/ 5 ( d eTc eT c e[1 T5 n[3 TT US 9$ s snnf NA! [( a/ U R* ( a e T R- 5 Tc S mT c 0 m Nwf = f7f)N�http�versionz3.0z1.1� ?r ) �type�asgi� http_version�method�headers�scheme�path�raw_path� query_string�serverr4 r3 Fc � �� ># � T( a TR 5 I S h v�N SS0$ TR 5 I S h v�N n SU SS.$ N' N ! [ a SmSSSS.s $ f = f7f)Nr: zhttp.disconnectTz http.requestr F)r: r � more_body)�wait� __anext__�StopAsyncIteration)r �request_body_chunks�request_complete�response_completes ���r �receive�3ASGITransport.handle_async_request.<locals>.receive� s| �� � � �'�,�,�.�.�.� � 1�2�2�
Q� 0� :� :� <�<�� +�D�t�L� L� /� =��%�
Q�#'� � .��%�P�P�
Q�sB �A"�A�A"�A36 �A�A37 � A"�A38 �39A � A"� A � A"c � �p ># � U S S:X a# T( a eU S mU R S/ 5 mSmg U S S:X a| TR 5 ( a eU R SS5 nU R S S405 nU( a! TR S :w a TR U5 U( d TR 5 g g g 7f) Nr: zhttp.response.start�statusr> Tzhttp.response.bodyr r rE F�HEAD)�get�is_setr= �append�set) �messager rE �41body_parts�requestrK �response_headers�response_started� status_codes ������r �send�0ASGITransport.handle_async_request.<locals>.send� s� �� � � �v��"7�7�+�+�+� %�h� /� �#*�;�;�y�"�#=� �#'� ��� �$8�8�,�3�3�5�5�5�5� �{�{�6�3�/�� #�K�K� �U� ;� ��G�N�N�f� 4� �%�%�d�+� �%�)�)�+� !� 9�s �B3B6i� )r> �stream)r& zdict[str, typing.Any])rU z&typing.MutableMapping[str, typing.Any]r& r' )�42isinstancer] r r= r> �raw�lower�urlr? r@ rA �split�query�host�portr4 r3 r$ r r1 � Exceptionr2 rT rR r r )r rW �k�v�scoperL r[ r] rV rI rJ rK rX rY rZ s ` @@@@@@@r �handle_async_request�"ASGITransport.handle_async_requestc s� �� � � �'�.�.�/�:�:�:�:� � ��&� !� �n�n�5<�_�_�5H�5H�I�5H�6�A�����A��5H�I� �k�k�(�(��K�K�$�$� � � �,�,�2�2�4�8��;� #�K�K� -� -� �{�{�'�'����)9�)9�:��k�k� � � �
43�� &�n�n� 6� 6� 8�� �� � � ���44� �� (�N�� M� M� ,� ,�*45 &��(�(�5�4�0� 0� 0� !�'�'�)�)�)�)��&�&�&� �+�+�+�#�J�/��� �-=�f�M�M��Y J�v
1��� &��(�(�� � !� !� #��"� !� � �'�#%� �� &�sI �A G;� F7�3C2G;�&F? �;F=�<F? � =G;�=F? �?6G8�5G;�7G8�8G;)r1 r4 r2 r3 N)T� )z 127.0.0.1�{ )46r1 �_ASGIAppr2 �boolr3 �strr4 ztuple[str, int]r& r' )rW r r& r )r( r) r* r+ �__doc__r rj r, r- r r r47 r48 ? sd � ��4 &*��"4� 49 �
�50 � #�51 � � 52 �53 � 54 � 55�
56 �XN��XN� 57�XNr )r& ro )r& r ) �58__future__r �typing�_modelsr r �_typesr �baser �
TYPE_CHECKINGr r �Unionr �MutableMappingrp �Any�_Message�Callable� Awaitable�_Receive�_Sendrn �__all__r r r r59 r- r r �<module>r� s �� "�
� '� $� $� ����� �L�L�� � ��60�61�2� 3�E� � � ��f�j�j� � 1�� �?�?�2�v� /� /�� 9�9� :����� ���3��62�63�?�+�,�f�.>�.>�t�.D�D� �� �?�?� ���3��64�65�?�+�X�u�=�v�?O�?O�PT�?U�U� �� �66�� � �#� � #�|N�&� |Nr