codekingpro/portable-devtools
115k
1�
2 ��j� � �� � % S r SSKrSSKrSSKJr SSKJr SSKJr SSKJr SSKJr SSK J3r4 SS K J r SS5K
Jr " S S 5 r " S
S\5 r\ " S S\5 5 r\ " S S\5 5 r " S S\5 r " S S\5 r0 r\\R. \\ 4 \S' \" SS9 " S S\5 5 r\" SS9 " S S \5 5 r\" S 5 r \ " S S \\\ 5 5 r \ " S! S"\5 5 r g)#z�6When IO actions occur at the proxy server, they are passed down to layers as events.7Events represent the only way for layers to receive new data from sockets.8The counterpart to events are commands.9� N)� dataclass)� is_dataclass)�Any)�Generic)�TypeVar)�flow)�10Connection)�commandsc � � \ rS rSrSrS rSrg)�Event� z 11Base class for all events.12c �N � [ U 5 R SU R < S3$ )N�(�))�type�__name__�__dict__��selfs �\D:\code\apps\devtools\python\user_packages\Python313\site-packages\mitmproxy/proxy/events.py�__repr__�Event.__repr__ s% � ��t�*�%�%�&�a��
�
�'8��:�:� � N)r �13__module__� __qualname__�__firstlineno__�__doc__r �__static_attributes__r r r r r s � ��;r r c � � \ rS rSrSrSrg)�Start� zY14Every layer initially receives a start event.15This is useful to emit events on startup.16r N�r r r r r r r r r r! r! s � �r r! c �$ � \ rS rSr% Sr\\S' Srg)�ConnectionEvent�$ z%17All events involving connection IO.18�19connectionr N)r r r r r r �__annotations__r r r r r% r% $ s � �� �r r% c �* � \ rS rSr% Sr\\S' S rSrg)� DataReceived�- z 20Remote has sent some data.21�datac � � [ U R 5 R R 5 nSU SU R < S3$ )Nz
DataReceived(�, r )r r' r �lowerr, )r �targets r r �DataReceived.__repr__5 s8 � ��d�o�o�&�/�/�5�5�7�� �v�h�b����
�Q�7�7r r N) r r r r r �bytesr( r r r r r r* r* - s � �� �K�8r r* c � � \ rS rSrSrSrg)�ConnectionClosed�: z!22Remote has closed a connection.23r Nr# r r r r4 r4 : s � �r r4 c �b ^ � \ rS rSr% Sr\R \S' \\S' U 4S jr S r24S r Sr U =r
$ ) �CommandCompleted�@ z}25Emitted when a command has been finished, e.g.26when the master has replied or when we have established a server connection.27�command�replyc �n >� U [ L a [ S5 e[ U 5 ( d e[ TU ] U 5 $ )Nz2CommandCompleted may not be instantiated directly.)r7 � TypeErrorr �super�__new__)�cls�args�kwargs� __class__s �r r> �CommandCompleted.__new__I s8 �� � �"� "�� P�Q� Q��C� � � � ��w��s�#�#r c � � [ R " U 5 R SS 5 n[ U[ 5 =( a3 [ U[ R 5 =( a U[ R LnU( d [ R " U S3[ 5 U[ ; a- [ U n[ R " SU SU SU 3[ 5 U [ U' g )Nr9 z. needs a properly annotated command attribute.z Two conflicting subclasses for z: z and ) �typing�get_type_hints�get�28isinstancer �29issubclassr30 �Command�warnings�warn�RuntimeWarning�command_reply_subclasses)r? rA � command_cls�valid_command_subclass�others r �__init_subclass__�"CommandCompleted.__init_subclass__O s� � � �+�+�C�0�4�4�Y��E� � �{�D� )�
4��;��(8�(8�9�
4��8�#3�#3�3� �31 &� �M�M��%�E�F� �
� �2� 2�,�[�9�E� �M�M�1�+� �b���U�5�'�R� �
� 14� ��-r c �@ � SU R < SU R < S3$ )NzReply(r. r )r9 r: r s r r �CommandCompleted.__repr__c s � ��� � �'�r�$�*�*� �q�9�9r r )r r r r r r32 rJ r( r r> rR r r �
__classcell__)rB s @r r7 r7 @ s/ �� ��33 �
�
� � �J�$� 4�(:� :r r7 rN F)�reprc �D � \ rS rSr% \R34 \S' \S- \S' Srg)�OpenConnectionCompleted�j r9 Nr: r ) r r r r r35 �OpenConnectionr( �strr r r r rY rY j s � �
�
$�
$�$� ��:��r rY c �B � \ rS rSr% \R36 \S' SrS\S' Srg)�
HookCompleted�q r9 Nr: r ) r r r r r37 � StartHookr( r: r r r r r^ r^ q s � �
�
�
� ��E�4�r r^ �Tc �B � \ rS rSr% Sr\R \S' \\S' Sr g)�MessageInjected�z z;38The user has injected a custom WebSocket/TCP/... message.39r �messager N)40r r r r r r �Flowr( ra r r r r rc rc z s � �� �)�)�O�
�Jr rc c �8 � \ rS rSr% Sr\R \S' Srg)�Wakeup� zC41Event sent to layers that requested a wakeup using RequestWakeup.42r9 r N) r r r r r r43 �
RequestWakeupr( r r r r rh rh � s � �� �
#�
#�#r rh ) r rE rK � dataclassesr r r r r � mitmproxyr �mitmproxy.connectionr �mitmproxy.proxyr44 r r! r% r* r4 r7 rN �dictrJ r r( rY r^ ra rc rh r r r �<module>rp s> ��� � � !� $� � � � � +� $�;� ;��E� � ��e� � �� � 8�?� 8� � 8��� � $:�u� $:�N LN� �$�x� /� /��6F�1G� G�H� M� ���� .� � �� ����$� � ��45 �C�L�� ��e�W�Q�Z� � �� �$�
� $� �$r