codekingpro/portable-devtools
114k
1�
2 ��j� � �� � S SK r S SKrS SKrS SKrS SKrS SKJr S SKJ r \R " \ 5 r " S S5 r
" S S\
5 rSS S3S .rS \ R S
\4S jrS \ R 4S jrg)� N)�ctx)�httpc � � \ rS rSrSrS\S\S- 4S jr\S\4S j5 r S \4R S\ 4S5 jr
S \6R SS4S jrS rg)
�ASGIApp� aL 7An addon that hosts an ASGI/WSGI HTTP app within mitmproxy, at a specified hostname and port.8 9Some important caveats:10 - This implementation will block and wait until the entire HTTP response is completed before sending out data.11 - It currently only implements the HTTP protocol (Lifespan and WebSocket are unimplemented).12�host�portNc �l � [ R R U5 nXUsU l U l U l g �N)�asgiref�
compatibility�guarantee_single_callable�asgi_appr r )�selfr r r s �^D:\code\apps\devtools\python\user_packages\Python313\site-packages\mitmproxy/addons/asgiapp.py�__init__�ASGIApp.__init__ s, � ��(�(�B�B�8�L��.6�d�+��
�t�y�$�)� �returnc �: � SU R SU R 3$ )Nzasgiapp:�:)r r )r s r �name� ASGIApp.name s � ��$�)�)��A�d�i�i�[�1�1r �flowc �^ � [ UR R U R :H =( a{ U R S L =( d# UR R U R :H =( a< UR13 =( a) UR ( + =( a UR ( + 5 $ r )�bool�request� pretty_hostr r �live�error�response�r r s r � should_serve�ASGIApp.should_serve s{ � �� �L�L� $� $�� � � 1�
"����d�"�D�d�l�l�&7�&7�4�9�9�&D�
"�� � �
"� �J�J��
"� �M�M�!� 14� 15r c � �z # � U R U5 ( a [ U R U5 I S h v�N g g N7fr )r# �server r" s r r �ASGIApp.request( s2 � � � � � �T� "� "���
�
�t�,� ,� ,� #� ,�s �0;�9�;)r r r )�__name__�16__module__� __qualname__�__firstlineno__�__doc__�str�intr �propertyr r �HTTPFlowr r# r �__static_attributes__� r r r r sj � ��C�s� C�#��*� C� �2�c� 2� �2�17�� � � 18�4� 19�-�$�-�-� -�D� -r r c �: ^ � \ rS rSrS\S\S- 4U 4S jjrSrU =r$ )�WSGIApp�- r r Nc �d >� [ R R U5 n[ TU ] XBU5 g r )r �wsgi�20WsgiToAsgi�superr )r �wsgi_appr r r � __class__s �r r �WSGIApp.__init__. s& �� ��<�<�*�*�8�4��
�����.r r2 ) r( r) r* r+ r- r. r r1 �
__classcell__)r; s @r r4 r4 - s �� �/�s� /�#��*� /� /r r4 z1.0�1.1�2)zHTTP/1.0zHTTP/1.1zHTTP/2.0r r c � � [ R R U R R R21 5 R
SSS9nUS n[ U5 S:� a1 [ R R US 5 R 5 nOSnSSSS .[ R U R R S225 U R R U R R R 5 UU R R23 UU R R R" VVs/ s H u pEUR% 5 U4PM snnU R& R( S [* R, 0S . $ s snnf )
Nz%3F� )�maxsplitr r r z3.0z2.1)�version� spec_versionr> zmitmproxy.master) �type�asgi� http_version�method�scheme�path�raw_path� query_string�headers�client�24extensions)�urllib�parse�quote_from_bytesr �datarJ �split�len�unquote�encode�HTTP_VERSION_MAP�getrG rH rI �upperrM �fields�lower� client_conn�peernamer �master)r � quoted_pathrJ rL r �values r �25make_scoperb : sA � ��,�,�/�/�� � �0A�0A�0F�0F�G�M�M�
�� N� �K� �q�>�D� �;��!�� �|�|�+�+�K��N�;�B�B�D� �� � � � !�26� )�,�,�T�\�\�-F�-F��N��,�,�%�%��,�,�%�%�+�+�-���L�L�%�%�$�7;�|�|�7K�7K�7R�7R�27�7R�m�t�T�Z�Z�\�5� !�7R�28� �"�"�+�+� ��29�30�31�! � ��32s �3 E=c � � ^^^^# � [ T5 n[ R " 5 mSmSmUUU4S jnUU4S jn U " X#U5 I Sh v�N T( d [ S5 e TR 5 g N(! [ aG n[33 R
SU 35 [ R R SS5 Tl34 SnAN_SnAff = f! TR 5 f = f7f) z35Serves app on flow.36Fc � � ># � T( d SmSTR R S.$ T R 5 I S h v�N SS0$ N7f)NTz http.request)rE �bodyrE zhttp.disconnect)r � raw_content�wait)�doner �
received_bodys ���r �receive�serve.<locals>.receivek sJ �� � � � �M�&� � � �0�0��
� �)�)�+� � �� -�.� .�
�s �6A�A� Ac � � ># � U S S:X aT [ R R U S SU R S/ 5 5 Tl TR R 5 g U S S:X a] TR ( d eTR =R U R SS5 -
sl U R SS 5 ( d S37mg g [ S U S 35 e7f) NrE zhttp.response.start�statusr rM zhttp.response.bodyre � more_bodyFTzUnexpected event: )r �Response�makerY r! �decode�content�AssertionError)�eventr �
sent_responses ��r �send�serve.<locals>.sendy s� �� � � ��=� 1� 1� �M�M� .� .��h���e�i�i� �2�&>� �D�M�
�M�M� � � "�
�6�]� 2�
2��=�=� �=� �M�M� !� !�U�Y�Y�v�s�%;� ;� !��9�9�[�%�0�0� $�
� 1� !�#5�e�F�m�_�!E�F� F�s �CCNzno response sent.zError in asgi app: i� s ASGI Error.) rb �asyncio�Event� RuntimeError� Exception�logger� exceptionr ro rp r! �set) �appr �scoperj rv �erh ri ru s ` @@@r r& r& a s� �� � �38
�t� �E� �=�=�?�D��M��M� /�
G� ��%�$�'�'�'� � �!2�4� 4� �
���39� (�� � @����.�q�c�2�3� �
�
�*�*�3��?��
�
��@��
���40�sR �4C� A2 �A0�A2 � C � C�0A2 �241C�<=B>�9C �>C�C �C�C)rx �logging� urllib.parserP �asgiref.compatibilityr � asgiref.wsgi� mitmproxyr r � getLoggerr( r| r r4 rX r0 �dictrb r& r2 r r �<module>r� s{ �� � � � � � � � � � �8� $�� -� -�>/�g� /� ���� �$�T�]�]� $�t� $�N/�4�=�=� /r