Team Ai
Datasetpublic

codekingpro/portable-devtools

sourceHugging Faceupdated 5mo agoView on Hugging Face
1likes14kdownloads
tunnel.cpython-313.pyc50 linesDownload Raw Back to __pycache__
1�

2��j� ����SSKrSSKJr SSKJr SSKJr SSKJr SSKJ	r	 SSKJ3r4 SSKJr SS	KJr SS5K
Jr "SS\5r"S
S\R5r"SS5rg)�N)�auto)�Enum)�Union)�6connection)�commands)�context)�events)�layer)�Layerc�L�\rSrSr\"5r\"5r\"5r\"5rSr	g)�TunnelState��N)7�__name__�8__module__�__qualname__�__firstlineno__r�INACTIVE�ESTABLISHING�OPEN�CLOSED�__static_attributes__r��\D:\code\apps\devtools\python\user_packages\Python313\site-packages\mitmproxy/proxy/tunnel.pyr
r
s���v�H��6�L��6�D�
�V�Frr
c�^�\rSrSr%Sr\R\S'\R\S'\R\S'\9Rr\10\S'Sr
\RS-\S'\\R$\S	'S11\R(S\RS\R4U4SjjrSrS
\R$S\R.S4SjrS\S-S\R.S4SjrS\R6S\R.S4SjrS
\R$S\R.S4SjrS\R.S4SjrS\S\R.\ \!\S-44Sjr"S\S\R.S4Sjr#S\S\R.S4Sjr$S\R.S4Sjr%S\S\R.S4Sjr&S\RNS\R.S4Sjr(Sr)U=r*$)�TunnelLayer�z}12A specialized layer that simplifies the implementation of tunneling protocols such as SOCKS, upstream HTTP proxies,13or TLS.14�child_layer�tunnel_connection�conn�tunnel_stateN�command_to_reply_to�_event_queuerc�>�[TU]U5 X lX0l[R15"UR5Ul/Ulg�N)	�super�__init__rr r16�	NextLayerrrr#)�selfrrr �	__class__s    �rr'�TunnelLayer.__init__(s:���	����!�!2���	� �?�?�4�<�<�8�����rc�|�[U5RSURRR	5S3$)N�(�))�typerr!�name�lower�r)s r�__repr__�TunnelLayer.__repr__4s6���t�*�%�%�&�a��(9�(9�(>�(>�(D�(D�(F�'G�q�I�Ir�event�returnc#��# �[U[R5(axURR[17RRLa-[RUl18UR5Shv�N URU5Shv�N g[U[R5(GaUR19UR:XGa�[U[R5(Ga�UR[RLGaCURUR 5Shv�Nup#U(agUR"UR:waM[20RR$UR"l[&R&"5UR"lU(a�UR"UR:waM[21RRUR"l[&R&"5UR"lUR+U5Shv�N U(dU(aUR-U5Shv�N ggUR/UR 5Shv�N g[U[R05(GaUR"UR:wa\UR"=R[22RR2)-sl[&R&"5UR"lUR[R$LaUR75Shv�N OQUR[RLa4SnUR+U5Shv�N UR-U5Shv�N [RUl23g[9SU35eURU5Shv�N gGNZGNDGN�GN�GN�GNpN�NoNXN7f)Nzconnection closedzUnexpected event: )�24isinstancer	�Startr�stater�ConnectionStaterr
rr!�start_handshake�event_to_child�ConnectionEvent�DataReceived�receive_handshake_data�datar r�time�timestamp_start�on_handshake_error�_handshake_finished�receive_data�ConnectionClosed�CAN_READ�
timestamp_end�
receive_close�AssertionError)r)r5�done�errs    r�
_handle_event�TunnelLayer._handle_event7s�����e�V�\�\�*�*��%�%�+�+�:�3M�3M�3T�3T�T�%0�$<�$<��!��/�/�1�1�1��*�*�5�1�1�1��u�f�4�4�5�5�� � �D�$:�$:�:��%��!4�!4�5�5��$�$��(@�(@�@�+/�+F�+F�u�z�z�+R� R�I�D���9�9��(>�(>�>�.8�.H�.H�.M�.M�D�I�I�O�8<�	�	��D�I�I�5���9�9��(>�(>�>�.8�.H�.H�.O�.O�D�I�I�O�8<�	�	��D�I�I�5�#'�#:�#:�3�#?�?�?��s�#'�#;�#;�C�#@�@�@� #� $�0�0����<�<�<��E�6�#:�#:�;�;��9�9�� 6� 6�6��I�I�O�O�25�(B�(B�(K�(K�'K�K�O�.2�i�i�k�D�I�I�+��$�$��(8�(8�8�#�1�1�3�3�3��&�&�+�*B�*B�B�-�C�#�6�6�s�;�;�;�#�7�7��<�<�<�$/�$6�$6��!�$�'9�%��%A�B�B��*�*�5�1�1�1�I2�1�!S�@�@�<�4�<�<�26
2�s��A9O/�;O�<O/�O�BO/�1O�2C6O/�(O�)&O/�O!�$O/�4O$�5CO/�O'�8O/�9O)�:O/�O+�<O/�O-�O/�O/�O/�O/�!O/�$O/�'O/�)O/�+O/�-O/rMc#�# �U(a[RUlO[RUlUR(a@UR[R"URU55Shv�N SUlgURHnURU5Shv�N M URR5 gNSN%7fr%)27r
rr!rr"r=r	�OpenConnectionCompletedr#�clear)r)rM�evts   rrE�TunnelLayer._handshake_finishedds����� +� 2� 2�D�� +� 0� 0�D���#�#��*�*��.�.�t�/G�/G��M��
�
�(,�D�$��(�(���.�.�s�3�3�3�)����#�#�%�
�4�s$�A7C�9C
�:/C�)C�*$C�C�commandc#��# �[U[R5(Ga�URUR:XGa�[U[R285(a$UR
UR5Shv�N g[U[R5(a}URUR:waIUR=R[RR)-sl29URUlURU5Shv�N g[U[R5(a�Xl[ R"Ul[R"UR5v�nU(aCUR'[(R*"X55Shv�N [ R,UlgUR/5Shv�N g[1SU35eUv� gGNtN�NKN7f)NzUnexpected command: )r8r�ConnectionCommandrr �SendData�	send_datarA�CloseConnectionrr:r;�	CAN_WRITE�30send_close�OpenConnectionr"r
rr!r=r	rQrr<rK)r)rUrMs   r�_handle_command�TunnelLayer._handle_commandssr���
�w�� :� :�;�;��"�"�d�i�i�/��'�8�#4�#4�5�5��>�>�'�,�,�7�7�7��G�X�%=�%=�>�>��9�9�� 6� 6�6��I�I�O�O�31�(B�(B�(L�(L�'L�L�O�)-�)?�)?�G�&��?�?�7�3�3�3��G�X�%<�%<�=�=�+2�(�$/�$<�$<��!�$�3�3�D�4J�4J�K�K���#�2�2��6�6�w�D� ���)4�(:�(:�D�%�#�3�3�5�5�5�$�';�G�9�%E�F�F��M�+8�324��336�sJ�A9G8�;G/�<BG8�G2�BG8�(G4�)-G8�G6�G8�2G8�4G8�6G8c#�# �UR[RLa-UR(dURRU5 gURRU5HnURU5Shv�N M gN	7fr%)	r!r
rr"r#�appendr�handle_eventr^)r)r5rUs   rr=�TunnelLayer.event_to_child�sk�������!9�!9�9��,�,����$�$�U�+���'�'�4�4�U�;�G��+�+�G�4�4�4�<�4�s�A=B�?B	�34Bc#�# �UR[R"URS55Shv�N gN7f)Nr)rNr	r?rr2s rr<�TunnelLayer.start_handshake�s-����%�%�f�&9�&9�$�:P�:P�RU�&V�W�W�W���4>�<�>rAc#�$# �SShv�N gN7f)zreturns a (done, err) tuplerN)TNr�r)rAs  rr@�"TunnelLayer.receive_handshake_data�s����
�
��	�s���c#�P# �[R"UR5v� g7f)z`Called if either receive_handshake_data returns an error or we receive a close during handshake.N)rrZr)r)rMs  rrD�TunnelLayer.on_handshake_error�s����&�&�t�'=�'=�>�>�s�$&c#�# �UR[R"URU55Shv�N gN7fr%)r=r	r?r rhs  rrF�TunnelLayer.receive_data�s*����&�&�v�':�':�4�9�9�d�'K�L�L�L�rfc#�~# �UR[R"UR55Shv�N gN7fr%)r=r	rGr r2s rrJ�TunnelLayer.receive_close�s(����&�&�v�'>�'>�t�y�y�'I�J�J�J�s�3=�;�=c#�R# �[R"URU5v� g7fr%)rrXrrhs  rrY�TunnelLayer.send_data�s������� 6� 6��=�=�s�%'c#�# �Uv� g7fr%r)r)rUs  rr\�TunnelLayer.send_close�s����
�s�)r#rr"r rr!)+rrrr�__doc__r35r�__annotations__r�36Connectionr
rr!r"rr]�listr	�Eventr�Contextr'r3�CommandGeneratorrN�strrE�Commandr^r=r<�bytes�tuple�boolr@rDrFrJrYrZr\r�
__classcell__)r*s@rrrs����37����!�,�,�,�G�38�39�40��8� +� 4� 4�L�+�4�:>���0�0�4�7�>��v�|�|�$�$��41 42����43�&�0�0�44��#�#�	45�J�+2�6�<�<�+2�E�4J�4J�4�4P�+2�Z
&�s�T�z�
&�e�6L�6L�T�6R�
&���'�'��	�	�	��	%��>5�F�L�L�5�U�5K�5K�D�5Q�5�X��!7�!7��!=�X����	�	�	��d�C�$�J�&6� 7�	8��?�c�?�e�.D�.D�T�.J�?�M��M�5�+A�+A�$�+G�M�K�u�5�5�d�;�K�>�e�>��(>�(>�t�(D�>���/�/��	�	�	��	%��rrc�L�\rSrSrS46SjrS\S\4SjrS\\S4SS4Sjr	S	r47g)�48LayerStack�r6Nc��/Ulgr%��_stackr2s rr'�LayerStack.__init__�s	��#%��r�itemc�8�URRU5$r%)r��__getitem__)r)r�s  rr��LayerStack.__getitem__�s���{�{�&�&�t�,�,r�otherc�L�[U[5(aAUR(aXRSlURR	U5 U$UR(aUSURSlURRUR5 U$)N�����r)r8rr�rra�extend)r)r�s  r�__truediv__�LayerStack.__truediv__�su���e�U�#�#��{�{�.3���B��+��K�K���u�%�49���{�{�.3�A�h����B��+��K�K���u�|�|�,��rr�)r6N)rrrrr'�intrr�rr�rrrrr�r��s7��&�-��-��-�	��u�l�':�!;�	��	rr�)rB�enumrr�typingr�	mitmproxyr�mitmproxy.proxyrrr	r50�mitmproxy.proxy.layerrr
rr�rrr�<module>r�sL������ �$�#�"�!�'��$��a�%�+�+�a�H�r
codekingpro/portable-devtools · Team Ai