� D�g!;���ddlmZddlmZmZmZmZmZmZm Z ddl Z ddl m Z ddl mZddlmZddlmZer'dd lmZe d d � ��ZGd �dee��ZdZGd�d��Ze jd d d ���Gd�d����Ze jd d d ���Gd�d����Ze jd d d ���Gd�d����Ze jd d d ���Gd�d����Ze jd d d ���Gd�d����Ze jd d d ���Gd�d����Ze jd d d ���Gd�d ����Z e jd d d ���Gd!�d"����Z!e jd d d ���Gd#�d$����Z"e jd d d ���Gd%�d&����Z#e jd d d ���Gd'�d(����Z$e jd d d ���Gd)�d*����Z%e jd d d ���Gd+�d,����Z&e jd d d ���Gd-�d.����Z'e jd d d ���Gd/�d0����Z(e jd d d ���Gd1�d2����Z)Gd3�d4��Z*dS)5�)�SimpleNamespace)� TYPE_CHECKING� Awaitable�Mapping�Optional�Protocol�Type�TypeVarN)�Signal)� CIMultiDict)�URL�)�ClientResponse)� ClientSession�_ParamT_contraT)� contravariantc �2�eZdZdededededfd�ZdS)�_SignalCallback�_SignalCallback__client_session�!_SignalCallback__trace_config_ctx�_SignalCallback__params�returnNc��dS�N�)�selfrrrs �_/home/asafur/pinokio/api/open-webui.git/app/env/lib/python3.11/site-packages/aiohttp/tracing.py�__call__z_SignalCallback.__call__s �� "�c�)�__name__� __module__� __qualname__rrrrrrrrrrsR������ "�+� "�!0� "�%�  "� �t�_�  "� "� "� "� "� "rr)� TraceConfig�TraceRequestStartParams�TraceRequestEndParams�TraceRequestExceptionParams� TraceConnectionQueuedStartParams�TraceConnectionQueuedEndParams� TraceConnectionCreateStartParams�TraceConnectionCreateEndParams�TraceConnectionReuseconnParams�TraceDnsResolveHostStartParams�TraceDnsResolveHostEndParams�TraceDnsCacheHitParams�TraceDnsCacheMissParams�TraceRequestRedirectParams�TraceRequestChunkSentParams� TraceResponseChunkReceivedParams�TraceRequestHeadersSentParamsc��eZdZdZefdeeddfd�Z d)deee e fdefd�Z d*d�Z e d+d ���Z e d,d ���Ze d-d���Ze d.d���Ze d/d���Ze d0d���Ze d1d���Ze d2d���Ze d3d���Ze d4d���Ze d5d���Ze d6d ���Ze d7d"���Ze d8d$���Ze d9d&���Ze d:d(���ZdS);r#zFFirst-class used to trace requests launched via ClientSession objects.�trace_config_ctx_factoryrNc��t|��|_t|��|_t|��|_t|��|_t|��|_t|��|_t|��|_t|��|_t|��|_ t|��|_ t|��|_ t|��|_ t|��|_ t|��|_t|��|_t|��|_||_dSr)r �_on_request_start�_on_request_chunk_sent�_on_response_chunk_received�_on_request_end�_on_request_exception�_on_request_redirect�_on_connection_queued_start�_on_connection_queued_end�_on_connection_create_start�_on_connection_create_end�_on_connection_reuseconn�_on_dns_resolvehost_start�_on_dns_resolvehost_end�_on_dns_cache_hit�_on_dns_cache_miss�_on_request_headers_sent�_trace_config_ctx_factory)rr5s r�__init__zTraceConfig.__init__1sK�� �4�L�L� �� �4�L�L� �#� �4�L�L� �(�PV� �P �P ��� �4�L�L� �"� �4�L�L� �!� �4�L�L� �(� �4�L�L� �&� �4�L�L� �(� �4�L�L� �&� �4�L�L� �%� �4�L�L� �&� �4�L�L� �$� �4�L�L� �� �4�L�L� �� �4�L�L� �%�*B��&�&�&r�trace_request_ctxc�.�|�|���S)z&Return a new trace_config_ctx instance)rI)rG)rrIs r�trace_config_ctxzTraceConfig.trace_config_ctxgs���-�-�@Q�-�R�R�Rrc�&�|j���|j���|j���|j���|j���|j���|j���|j���|j ���|j ���|j ���|j ���|j ���|j���|j���|j���dSr)r7�freezer8r9r:r;r<r=r>r?r@rArBrCrDrErF�rs rrMzTraceConfig.freezemsX�� ��%�%�'�'�'� �#�*�*�,�,�,� �(�/�/�1�1�1� ��#�#�%�%�%� �"�)�)�+�+�+� �!�(�(�*�*�*� �(�/�/�1�1�1� �&�-�-�/�/�/� �(�/�/�1�1�1� �&�-�-�/�/�/� �%�,�,�.�.�.� �&�-�-�/�/�/� �$�+�+�-�-�-� ��%�%�'�'�'� ��&�&�(�(�(� �%�,�,�.�.�.�.�.r�0Signal[_SignalCallback[TraceRequestStartParams]]c��|jSr)r7rNs r�on_request_startzTraceConfig.on_request_start� ���%�%r�4Signal[_SignalCallback[TraceRequestChunkSentParams]]c��|jSr)r8rNs r�on_request_chunk_sentz!TraceConfig.on_request_chunk_sent�s ���*�*r�9Signal[_SignalCallback[TraceResponseChunkReceivedParams]]c��|jSr)r9rNs r�on_response_chunk_receivedz&TraceConfig.on_response_chunk_received�� ���/�/r�.Signal[_SignalCallback[TraceRequestEndParams]]c��|jSr)r:rNs r�on_request_endzTraceConfig.on_request_end�s ���#�#r�4Signal[_SignalCallback[TraceRequestExceptionParams]]c��|jSr)r;rNs r�on_request_exceptionz TraceConfig.on_request_exception�s ���)�)r�3Signal[_SignalCallback[TraceRequestRedirectParams]]c��|jSr)r<rNs r�on_request_redirectzTraceConfig.on_request_redirect�s ���(�(r�9Signal[_SignalCallback[TraceConnectionQueuedStartParams]]c��|jSr)r=rNs r�on_connection_queued_startz&TraceConfig.on_connection_queued_start�rYr�7Signal[_SignalCallback[TraceConnectionQueuedEndParams]]c��|jSr)r>rNs r�on_connection_queued_endz$TraceConfig.on_connection_queued_end�� ���-�-r�9Signal[_SignalCallback[TraceConnectionCreateStartParams]]c��|jSr)r?rNs r�on_connection_create_startz&TraceConfig.on_connection_create_start�rYr�7Signal[_SignalCallback[TraceConnectionCreateEndParams]]c��|jSr)r@rNs r�on_connection_create_endz$TraceConfig.on_connection_create_end�rir�7Signal[_SignalCallback[TraceConnectionReuseconnParams]]c��|jSr)rArNs r�on_connection_reuseconnz#TraceConfig.on_connection_reuseconn�� ���,�,r�7Signal[_SignalCallback[TraceDnsResolveHostStartParams]]c��|jSr)rBrNs r�on_dns_resolvehost_startz$TraceConfig.on_dns_resolvehost_start�rir�5Signal[_SignalCallback[TraceDnsResolveHostEndParams]]c��|jSr)rCrNs r�on_dns_resolvehost_endz"TraceConfig.on_dns_resolvehost_end�s ���+�+r�/Signal[_SignalCallback[TraceDnsCacheHitParams]]c��|jSr)rDrNs r�on_dns_cache_hitzTraceConfig.on_dns_cache_hit�rRr�0Signal[_SignalCallback[TraceDnsCacheMissParams]]c��|jSr)rErNs r�on_dns_cache_misszTraceConfig.on_dns_cache_miss�s ���&�&r�6Signal[_SignalCallback[TraceRequestHeadersSentParams]]c��|jSr)rFrNs r�on_request_headers_sentz#TraceConfig.on_request_headers_sent�rsrr�rN)rrO)rrS)rrV)rrZ)rr])rr`)rrc)rrf)rrj)rrm)rrp)rrt)rrw)rrz)rr})rr�)r r!r"�__doc__rr rHrr�strrKrM�propertyrQrUrXr\r_rbrerhrlrorrrvryr|rr�rrrr#r#.s������P�P�AP�4B�4B�(,�_�(=�4B� �4B�4B�4B�4B�n@D�S�S�!)�'�#�s�(�*;�!<�S� �S�S�S�S� /�/�/�/�$�&�&�&��X�&��+� ?�+�+�+��X�+� �0� D�0�0�0��X�0� �$�$�$��X�$��*� ?�*�*�*��X�*� �)� >�)�)�)��X�)� �0� D�0�0�0��X�0� �.� B�.�.�.��X�.� �0� D�0�0�0��X�0� �.� B�.�.�.��X�.� �-� B�-�-�-��X�-� �.� B�.�.�.��X�.� �,� @�,�,�,��X�,� �&�&�&��X�&��'�'�'��X�'��-� A�-�-�-��X�-�-�-rr#)� auto_attribs�frozen�slotsc�2�eZdZUdZeed<eed<ded<dS)r$z0Parameters sent by the `on_request_start` signal�method�url�CIMultiDict[str]�headersN�r r!r"r�r��__annotations__r rrrr$r$�s6�������:�:� �K�K�K� �H�H�H� �����rr$c�2�eZdZUdZeed<eed<eed<dS)r1z5Parameters sent by the `on_request_chunk_sent` signalr�r��chunkN�r r!r"r�r�r�r �bytesrrrr1r1�s1�������?�?� �K�K�K� �H�H�H� �L�L�L�L�Lrr1c�2�eZdZUdZeed<eed<eed<dS)r2z:Parameters sent by the `on_response_chunk_received` signalr�r�r�Nr�rrrr2r2�s1�������D�D� �K�K�K� �H�H�H� �L�L�L�L�Lrr2c�<�eZdZUdZeed<eed<ded<eed<dS)r%z.Parameters sent by the `on_request_end` signalr�r�r�r��responseN�r r!r"r�r�r�r rrrrr%r%�sB�������8�8� �K�K�K� �H�H�H� ���������rr%c�<�eZdZUdZeed<eed<ded<eed<dS)r&z4Parameters sent by the `on_request_exception` signalr�r�r�r�� exceptionN)r r!r"r�r�r�r � BaseExceptionrrrr&r&�sB�������>�>� �K�K�K� �H�H�H� ���������rr&c�<�eZdZUdZeed<eed<ded<eed<dS)r0z3Parameters sent by the `on_request_redirect` signalr�r�r�r�r�Nr�rrrr0r0sB�������=�=� �K�K�K� �H�H�H� ���������rr0c��eZdZdZdS)r'z:Parameters sent by the `on_connection_queued_start` signalN�r r!r"r�rrrr'r'�������D�D�D�Drr'c��eZdZdZdS)r(z8Parameters sent by the `on_connection_queued_end` signalNr�rrrr(r(�������B�B�B�Brr(c��eZdZdZdS)r)z:Parameters sent by the `on_connection_create_start` signalNr�rrrr)r)r�rr)c��eZdZdZdS)r*z8Parameters sent by the `on_connection_create_end` signalNr�rrrr*r* r�rr*c��eZdZdZdS)r+z7Parameters sent by the `on_connection_reuseconn` signalNr�rrrr+r+%s������A�A�A�Arr+c��eZdZUdZeed<dS)r,z8Parameters sent by the `on_dns_resolvehost_start` signal�hostN�r r!r"r�r�r�rrrr,r,*s�������B�B� �I�I�I�I�Irr,c��eZdZUdZeed<dS)r-z6Parameters sent by the `on_dns_resolvehost_end` signalr�Nr�rrrr-r-1s�������@�@� �I�I�I�I�Irr-c��eZdZUdZeed<dS)r.z0Parameters sent by the `on_dns_cache_hit` signalr�Nr�rrrr.r.8s�������:�:� �I�I�I�I�Irr.c��eZdZUdZeed<dS)r/z1Parameters sent by the `on_dns_cache_miss` signalr�Nr�rrrr/r/?s�������;�;� �I�I�I�I�Irr/c�2�eZdZUdZeed<eed<ded<dS)r3z7Parameters sent by the `on_request_headers_sent` signalr�r�r�r�Nr�rrrr3r3Fs6�������A�A� �K�K�K� �H�H�H� �����rr3c �F�eZdZdZdddededdfd�Zd ed ed d ddfd �Z d ed ede ddfd�Z d ed ede ddfd�Z d ed ed d de ddf d�Zd ed ed d deddf d�Zd ed ed d de ddf d�Zd!d�Zd!d�Zd!d�Zd!d�Zd!d�Zdeddfd�Zdeddfd�Zdeddfd�Zdeddfd�Zd ed ed d ddfd �ZdS)"�Tracez�Internal dependency holder class. Used to keep together the main dependencies used at the moment of send a signal. �sessionr� trace_configrKrNc�0�||_||_||_dSr)� _trace_config�_trace_config_ctx�_session)rr�r�rKs rrHzTrace.__init__Vs�� *���!1����� � � rr�r�r�r�c ��K�|jj�|j|jt |||�����d{V��Sr)r�rQ�sendr�r�r$�rr�r�r�s r�send_request_startzTrace.send_request_start`s^�����'�8�=�=� �M� � "� #�F�C�� 9� 9� � � � � � � � � rr�c ��K�|jj�|j|jt |||�����d{V��Sr)r�rUr�r�r�r1�rr�r�r�s r�send_request_chunk_sentzTrace.send_request_chunk_sentis^�����'�=�B�B� �M� � "� '���U� ;� ;� � � � � � � � � rc ��K�|jj�|j|jt |||�����d{V��Sr)r�rXr�r�r�r2r�s r�send_response_chunk_receivedz"Trace.send_response_chunk_receivedrs^�����'�B�G�G� �M� � "� ,�V�S�%� @� @� � � � � � � � � rr�c ��K�|jj�|j|jt ||||�����d{V��Sr)r�r\r�r�r�r%�rr�r�r�r�s r�send_request_endzTrace.send_request_end{s`�����'�6�;�;� �M� � "� !�&�#�w�� A� A� � � � � � � � � rr�c ��K�|jj�|j|jt ||||�����d{V��Sr)r�r_r�r�r�r&)rr�r�r�r�s r�send_request_exceptionzTrace.send_request_exception�s`�����'�<�A�A� �M� � "� '���W�i� H� H� � � � � � � � � rc ��K�|jj�|j|jt ||||�����d{V��Sr)r�r<r�r�r�r0r�s r�send_request_redirectzTrace.send_request_redirect�s`�����'�<�A�A� �M� � "� &�v�s�G�X� F� F� � � � � � � � � rc��K�|jj�|j|jt �����d{V��Sr)r�rer�r�r�r'rNs r�send_connection_queued_startz"Trace.send_connection_queued_start��U�����'�B�G�G� �M�4�1�3S�3U�3U� � � � � � � � � rc��K�|jj�|j|jt �����d{V��Sr)r�rhr�r�r�r(rNs r�send_connection_queued_endz Trace.send_connection_queued_end��U�����'�@�E�E� �M�4�1�3Q�3S�3S� � � � � � � � � rc��K�|jj�|j|jt �����d{V��Sr)r�rlr�r�r�r)rNs r�send_connection_create_startz"Trace.send_connection_create_start�r�rc��K�|jj�|j|jt �����d{V��Sr)r�ror�r�r�r*rNs r�send_connection_create_endz Trace.send_connection_create_end�r�rc��K�|jj�|j|jt �����d{V��Sr)r�rrr�r�r�r+rNs r�send_connection_reuseconnzTrace.send_connection_reuseconn�sU�����'�?�D�D� �M�4�1�3Q�3S�3S� � � � � � � � � rr�c��K�|jj�|j|jt |�����d{V��Sr)r�rvr�r�r�r,�rr�s r�send_dns_resolvehost_startz Trace.send_dns_resolvehost_start�sX�����'�@�E�E� �M�4�1�3Q�RV�3W�3W� � � � � � � � � rc��K�|jj�|j|jt |�����d{V��Sr)r�ryr�r�r�r-r�s r�send_dns_resolvehost_endzTrace.send_dns_resolvehost_end�sX�����'�>�C�C� �M�4�1�3O�PT�3U�3U� � � � � � � � � rc��K�|jj�|j|jt |�����d{V��Sr)r�r|r�r�r�r.r�s r�send_dns_cache_hitzTrace.send_dns_cache_hit�sW�����'�8�=�=� �M�4�1�3I�$�3O�3O� � � � � � � � � rc��K�|jj�|j|jt |�����d{V��Sr)r�rr�r�r�r/r�s r�send_dns_cache_misszTrace.send_dns_cache_miss�sW�����'�9�>�>� �M�4�1�3J�4�3P�3P� � � � � � � � � rc ��K�|jj�|j|jt |||�����d{V��Sr)r�rFr�r�r�r3r�s r�send_request_headerszTrace.send_request_headers�s^�����'�@�E�E� �M� � "� )�&�#�w� ?� ?� � � � � � � � � rr�)r r!r"r�r#rrHr�r r�r�r�r�rr�r�r�r�r�r�r�r�r�r�r�r�r�r�rrrr�r�Os���������  � � �"� �*�  � �  � � � � �� � #� �.@� � � � � � � �� � #� �,1� � � � � � � �� � #� �,1� � � � � � �  ��  ��  �$�  � !�  � �  �  �  �  �  ��  ��  �$�  � !�  � �  �  �  �  �  ��  ��  �$�  � !�  � �  �  �  �  � � � � �  � � � �  � � � �  � � � �  � � � �  �S� �T� � � � �  �3� �4� � � � �  �S� �T� � � � �  �c� �d� � � � �  �� � #� �.@� � � � � � � � rr�)+�typesr�typingrrrrrr r �attr� aiosignalr � multidictr �yarlr � client_reqrepr�clientrrr�__all__r#�sr$r1r2r%r&r0r'r(r)r*r+r,r-r.r/r3r�rrr�<module>r�s��!�!�!�!�!�!�W�W�W�W�W�W�W�W�W�W�W�W�W�W�W�W�W�W� � � � �������!�!�!�!�!�!�������)�)�)�)�)�)�� "�%�%�%�%�%�%��W�-�T�B�B�B�N�"�"�"�"�"�(�>�2�"�"�"� ��*g-�g-�g-�g-�g-�g-�g-�g-�T���T�$�d�3�3�3� � � � � � � �4�3� ����T�$�d�3�3�3��������4�3�����T�$�d�3�3�3��������4�3�����T�$�d�3�3�3��������4�3�����T�$�d�3�3�3��������4�3�����T�$�d�3�3�3��������4�3�����T�$�d�3�3�3�E�E�E�E�E�E�E�4�3�E����T�$�d�3�3�3�C�C�C�C�C�C�C�4�3�C����T�$�d�3�3�3�E�E�E�E�E�E�E�4�3�E����T�$�d�3�3�3�C�C�C�C�C�C�C�4�3�C����T�$�d�3�3�3�B�B�B�B�B�B�B�4�3�B����T�$�d�3�3�3��������4�3�� ���T�$�d�3�3�3��������4�3�� ���T�$�d�3�3�3��������4�3�� ���T�$�d�3�3�3��������4�3�� ���T�$�d�3�3�3� � � � � � � �4�3� �G �G �G �G �G �G �G �G �G �G r
Memory