codekingpro/portable-devtools
114k
1�
2 ��j� � �� � S SK Jr S SKrS SKrS SKrS SKrSSKJrJr SSK J3r4 SSK J r \R ( a S SKJr S S KJr \R$ " S55 rS /rSS jr " S
S\65 r " S S \ 5 rg)� )� annotationsN� )�Request�Response)�SyncByteStream� )�
BaseTransport)�7OptExcInfo)�WSGIApplication�_T�
WSGITransportc �p � [ U 5 n U H$ nU( d M [ R " U/U 5 s $ / $ �N)�iter� itertools�chain)�body�chunks �HD:\code\apps\devtools\python\Lib\site-packages\httpx/_transports/wsgi.py�_skip_leading_empty_chunksr s4 � � ��:�D��� �5� �?�?�E�7�D�1� 1� � �I� c �2 � \ rS rSrSS jrSS jrS S jrSrg)8�WSGIByteStream� c �H � [ USS 5 U l [ U5 U l g )N�close)�getattr�_closer �_result)�self�results r �__init__�WSGIByteStream.__init__ s � � �f�g�t�4�� �1�&�9�� r c # �: # � U R H nUv � M g 7fr )r )r �parts r �__iter__�WSGIByteStream.__iter__# s � � ��L�L�D��J� !�s �c �@ � U R b U R 5 g g r )r )r s r r �WSGIByteStream.close' s � � �;�;� "� �K�K�M� #r )r r N)r! ztyping.Iterable[bytes]�return�None)r* ztyping.Iterator[bytes])r* r+ )�__name__�9__module__� __qualname__�__firstlineno__r" r& r �__static_attributes__� r r r r s � �:��r r c �N � \ rS rSrSr S SS jjrS S jrSrg)10r
�, a� 11A custom transport that handles sending requests directly to an WSGI app.12The simplest way to use this functionality is to use the `app` argument.13 14```15client = httpx.Client(app=app)16```17 18Alternatively, you can setup the transport instance explicitly.19This allows you to include any additional configuration arguments specific20to the WSGITransport class:21 22```23transport = httpx.WSGITransport(24 app=app,25 script_name="/submount",26 remote_addr="1.2.3.4"27)28client = httpx.Client(transport=transport)29```30 31Arguments:32 33* `app` - The WSGI application.34* `raise_app_exceptions` - Boolean indicating if exceptions in the application35 should be raised. Default to `True`. Can be set to `False` for use cases36 such as testing the content of a client 500 response.37* `script_name` - The root path on which the WSGI application should be mounted.38* `remote_addr` - A string indicating the client IP of incoming requests.39```40Nc �@ � Xl X l X0l X@l XPl g r )�app�raise_app_exceptions� script_name� remote_addr� wsgi_errors)r r5 r6 r7 r8 r9 s r r" �WSGITransport.__init__M s! � � ��$8�!�&��&��&�r c � ^^^� UR 5 [ R " UR 5 nUR R41 =( d SSS.UR R nSUR R UU R =( d [ R SSSUR U R UR R UR R R S5 UR R [! U5 SU R" S .nUR$ R& HR u pVUR S5 R) 5 R+ S42S 5 nUS ; a S
U- nUR S5 XG' MT S mS mS m S SUUU4S jjjnU R- XH5 n [/ U 5 n43Tc eTc eT( a TS ( a U R0 ( a TS e[3 TR5 5 S 5 n T VV s/ s H' u p|UR7 S5 U R7 S5 4PM) n
nn [9 X�U44S9$ s sn nf )N�P i� )�http�https)r r TF�asciizHTTP/1.1)z wsgi.versionzwsgi.url_schemez45wsgi.inputz wsgi.errorszwsgi.multithreadzwsgi.multiprocessz
wsgi.run_once�REQUEST_METHOD� SCRIPT_NAME� PATH_INFO� QUERY_STRING� SERVER_NAME� SERVER_PORT�SERVER_PROTOCOL� REMOTE_ADDR�-�_)� CONTENT_TYPE�CONTENT_LENGTH�HTTP_c � >� U mUmUmS $ )Nc � � g r r1 )rI s r �<lambda>�FWSGITransport.handle_request.<locals>.start_response.<locals>.<lambda>� s � �Tr r1 )�status�response_headers�exc_info�
seen_exc_info�seen_response_headers� seen_statuss ���r �start_response�4WSGITransport.handle_request.<locals>.start_response{ s �� � !�K�$4� !� $�M�!� !r r r )�headers�streamr )rQ �strrR zlist[tuple[str, str]]rS zOptExcInfo | Noner* z$typing.Callable[[bytes], typing.Any]) �read�io�BytesIO�content�url�port�schemer9 �sys�stderr�methodr7 �path�query�decode�hostr[ r8 rY �raw�upper�replacer5 r r6 �int�split�encoder )r �request�46wsgi_inputra �environ�47header_key� header_value�keyrW r! rZ � status_code�valuerY rT rU rV s @@@r �handle_request� WSGITransport.handle_request[ s. �� �� � ���Z�Z����0�48��{�{� � �Q�B��#=�g�k�k�>P�>P�#Q�� "� &�{�{� 1� 1�$� �+�+�9�s�z�z� $�!&� "� %�n�n� �+�+� ���)�)� #�K�K� -� -� 4� 4�W� =�"�;�;�+�+� �t�9� )� �+�+� 49��" )0���(;�(;� $�J� �#�#�G�,�2�2�4�<�<�S�#�F�C��<�<� ��m��'�.�.�w�7�G�L� )<� � � $� � �
�50 +/� "�� "� 3� "� (� "� 2� "� "� ���'�2�� ��'���&�&�&�$�0�0�0� �]�1� -�$�2K�2K� ��"� "��+�+�+�-�a�0�1� � 4�51� 3�52�� �Z�Z��
�%�,�,�w�"7� 8� 3� � 53�54 � �V�D�D�� 55s �.I)r5 r6 r8 r7 r9 )T� z 127.0.0.1N) r5 r r6 �boolr7 r[ r8 r[ r9 ztyping.TextIO | Noner* r+ )rp r r* r )r, r- r. r/ �__doc__r" rx r0 r1 r r r
r
, s[ � � �F &*� �&�,0�
'�
� '� #� '� � '�56 � '� *�
'� 57� '� :Er )r �typing.Iterable[_T]r* r} )�58__future__r r] r rc �typing�_modelsr r �_typesr �baser �
TYPE_CHECKING� _typeshedr59 �_typeshed.wsgir �TypeVarr �__all__r r r
r1 r r �<module>r� se �� "� � � 60�
� '� #� � ���$�.� �^�^�D��� �61��� �^� � iE�M� iEr