codekingpro/portable-devtools
115k
1�
2 ��j* � �� � S SK r S SKrSSKJr SSKJr SSKJr SSK J3r4 S SK J r S SK J
r
S S K Jr S S5K Jr S S K Jr S S K Jr S S
K Jr \R& " \5 r " S S5 rg)� N� )�ctx)�termlog)� ReverseMode)�
asyncio_utils)� addonmanager)�command)�
eventsequence)�hooks)�http)�log)�optionsc �� � \ rS rSr% Sr\R \S' Sr\ R S- \S' SS\ R S- S\R S- S\
4S jjrSS jrS6 rSS jrSS jrSS
jrS rSrg)�Master� z17The master handles mitmproxy's main event loop.8�9event_loopN�_termlog_addon�opts� with_termlogc �� � U=( d [ R " 5 U l [ R " U 5 U l [10 R " U 5 U l U( a? [ R " 5 U l11 U R R U R 5 [ R " U 5 U l [ R " U 5 U l U R R! 5 U=( d [" R$ " 5 U l [" R( " 5 U l U [, l U R [, l U R [, l g �N)r �Optionsr �CommandManager�commandsr � AddonManager�addonsr �TermLogr �addr
�Log�LegacyLogEvents�_legacy_log_events�install�asyncio�get_running_loopr �Event� should_exit�
mitmproxy_ctx�master)�selfr r r s �VD:\code\apps\devtools\python\user_packages\Python313\site-packages\mitmproxy/master.py�__init__�Master.__init__ s� � � )-�(A����0A�� � �.�.�t�4��
�"�/�/��5�� � �")�/�/�"3�D� � �K�K�O�O�D� /� /� 0��7�7�4�=���"%�"5�"5�d�";�� � � � �'�'�)�12 %�B��(@�(@�(B���"�=�=�?��� #�
� � �H�H�
�� $� � �
� � c � �. # � [ R " U R 5 [ R " 5 U R R 5 U R R S5 =n( a UR 5 I S h v�N U R R S5 =n( a� [ R " [ R " UR 5 SSS9[ R " U R R 5 SSS9/[ R S9I S h v�N U R R 5 ( a S S S 5 S S S 5 g U R R S5 =n( a UR 5 I S h v�N U R 5 I S h v�N U R R S5 =n( a( UR 5 I S h v�N UR! 5 U R R 5 I S h v�N U R# 5 I S h v�N S S S 5 S S S 5 g GN� GN" N� N� Nj N: N$! U R# 5 I S h v�N f = f! , ( d f NE= f! , ( d f g = f7f)N�13errorcheck� proxyserver�
setup_serversF)�name�keep_refr& )� return_when)r �install_exception_handler�_asyncio_exception_handler�set_eager_task_factoryr& �clearr �get�shutdown_if_erroredr# �wait� create_taskr1 �FIRST_COMPLETED�is_set�running�finish�done)r) �ec�pss r* �run�14Master.run6 s� � � � � 3� 3�D�4S�4S� T� � 0� 0� 2� � � � "� "� $� �[�[�_�_�\�2�2�r�2��,�,�.�.�.��[�[�_�_�]�3�3�r�3� �l�l�%�1�1� � ,� ,� .�_�u�� &�1�1� � ,� ,� 1� 1� 3�-�RW�� � !(� 7� 7�15� 16� 17� �#�#�*�*�,�,��+
3�
U� T�0 ��� � � �6�6�2�6� �0�0�2�2�2�
"��l�l�n�$�$� ��� � � �6�6�2�6� �0�0�2�2�2��I�I�K��&�&�+�+�-�-�-� �i�i�k�!�!�K
3�
U� T� /�18� 3� %� 3� .� "��d�i�i�k�!�!��K
3� 2��
U� T�s� �!J�J�AI3� I�19B I3�&I�'$I3� J� J� 5I3�I �I3�I�*I
�+9I�$I�%1I�I�I�I3�.I�/I3�4J�< J�I3�I3� I3�
I�I�I�I3�I0�)I, �*I0�0I3�320J �=J�21J�Jc �b � U R R U R R 5 g)z222Shut down the proxy. This method is thread-safe.23N)r �call_soon_threadsafer& �set�r) s r* �shutdown�Master.shutdown` s" � �24
���,�,�T�-=�-=�-A�-A�Br- c � �| # � U R R [ R " 5 5 I S h v�N g N7fr )r �
trigger_eventr � RunningHookrI s r* r? �Master.runningg s& � � ��k�k�'�'��(9�(9�(;�<�<�<�s �2<�:�<c � � # � U R R [ R " 5 5 I S h v�N U R R 5 U R b U R R 5 g g NG7fr )r rM r �DoneHookr! � uninstallr rI s r* rA � Master.donej s^ � � ��k�k�'�'����(8�9�9�9� � � �)�)�+� � � � *� � � � )� )� +� +� :�s �2A>�A<�AA>c �� � US n[ U[ 5 ( a UR S:X a g [ R S[ U5 X3R 4S9 g ! [ a [ R SU 35 g f = f)N� exceptioni6' zUnhandled error in task.)�exc_infozUnhandled asyncio error: )�25isinstance�OSError�errno�logger�error�type�
__traceback__�KeyError)r) �loop�context�excs r* r6 �!Master._asyncio_exception_handlerp s{ � �26 � $�[� 1�C� �#�w�'�'�C�I�I��,>�� �L�L�*� �s�)�S�*;�*;�<�
�
�� � @� �L�L�4�W�I�>� ?� @�s �A �"A<�;A<c � � # � [ U[ R 5 ( a� [ U R R27 5 S:X a� U R R28 S R
S5 ( a� [ R " U R R29 S 5 n[ U[ 5 ( d eUR tUR l UR l nUR UR l
[ R " U5 H& nU R R# U5 I Sh v�N M( g N 7f)z30Loads a flow31r r zreverse:N)rW r �HTTPFlow�lenr �mode�32startswithr �parse�address�request�host�port�schemer33 �iterater �handle_lifecycle)r) �frf �_�es r* � load_flow�Master.load_flow} s� � � �
�q�$�-�-� (� (��D�L�L�%�%�&�!�+�� � �!�!�!�$�/�/�34�;�;� �$�$�T�\�\�%6�%6�q�%9�:�D� �d�K�0�0� 0�0�15� � � .�A�I�I�N�A�I�I�N�Q� #�{�{�A�I�I� � �&�&�q�)�A��+�+�.�.�q�1� 1� 1� *� 1�s �D3E�5D?�635E)r! r r r r r
r r& )NF)�returnN)�__name__�36__module__� __qualname__�__firstlineno__�__doc__r# �AbstractEventLoop�__annotations__r r r r r �boolr+ rD rJ r? rA r6 rs �__static_attributes__� r- r* r r s� � �� �)�)�)�-1�N�G�O�O�d�*�1�37 8<� "� -��o�o��$�-� �-�-��4�-� � -�6("�TC�=�,� �2r- r )r# �logging� r r' r r �proxy.mode_specsr �utilsr � mitmproxyr r r38 r r r
r � getLoggerrv rZ r r r- r* �<module>r� sH �� � � "� � )� � "� � #� � � � � � � �8� $��~2� ~2r-