
    F/j8                        d dl mZ d dlmZmZmZ d dlZd dlmZ d dl	m
Z
 d dlmZ ddlmZ erdd	lmZ  ed
d      Zeeeef   ZdZ G d d      Z ej*                  ddd       G d d             Z ej*                  ddd       G d d             Z ej*                  ddd       G d d             Z ej*                  ddd       G d d             Z ej*                  ddd       G d d             Z ej*                  ddd       G d d             Z ej*                  ddd       G d d             Z ej*                  ddd       G d d              Z ej*                  ddd       G d! d"             Z ej*                  ddd       G d# d$             Z ej*                  ddd       G d% d&             Z  ej*                  ddd       G d' d(             Z! ej*                  ddd       G d) d*             Z" ej*                  ddd       G d+ d,             Z# ej*                  ddd       G d- d.             Z$ ej*                  ddd       G d/ d0             Z% G d1 d2      Z&y)3    )SimpleNamespace)TYPE_CHECKINGAnyTypeVarN)Signal)CIMultiDict)URL   )ClientResponse)ClientSession_ParamT_contraT)contravariant)TraceConfigTraceRequestStartParamsTraceRequestEndParamsTraceRequestExceptionParams TraceConnectionQueuedStartParamsTraceConnectionQueuedEndParams TraceConnectionCreateStartParamsTraceConnectionCreateEndParamsTraceConnectionReuseconnParamsTraceDnsResolveHostStartParamsTraceDnsResolveHostEndParamsTraceDnsCacheHitParamsTraceDnsCacheMissParamsTraceRequestRedirectParamsTraceRequestChunkSentParams TraceResponseChunkReceivedParamsTraceRequestHeadersSentParamsc                      e Zd ZdZefdee   ddfdZddedefdZddZ	e
dd	       Ze
	 	 dd
       Ze
	 	 dd       Ze
dd       Ze
	 	 dd       Ze
	 	 d d       Ze
	 	 d!d       Ze
	 	 d"d       Ze
	 	 d#d       Ze
	 	 d$d       Ze
	 	 d%d       Ze
	 	 d&d       Ze
	 	 d'd       Ze
d(d       Ze
d)d       Ze
	 	 d*d       Zy)+r   zFFirst-class used to trace requests launched via ClientSession objects.trace_config_ctx_factoryreturnNc                    t        |       | _        t        |       | _        t        |       | _        t        |       | _        t        |       | _        t        |       | _        t        |       | _        t        |       | _        t        |       | _	        t        |       | _
        t        |       | _        t        |       | _        t        |       | _        t        |       | _        t        |       | _        t        |       | _        || _        y N)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)selfr!   s     M/var/www/html/maxservice/venv/lib/python3.12/site-packages/aiohttp/tracing.py__init__zTraceConfig.__init__*   s    KQQU,4L 	#
 4L 	( GMTl4L 	" QWQ
!
 4L 	(
 4L 	&
 4L 	(
 4L 	&
 4L 	%
 4L 	& 4L 	$ JPPTKQRV<4L 	% *B&    trace_request_ctxc                 &    | j                  |      S )z&Return a new trace_config_ctx instance)r:   )r5   )r6   r:   s     r7   trace_config_ctxzTraceConfig.trace_config_ctxX   s    --@Q-RRr9   c                 D   | j                   j                          | j                  j                          | j                  j                          | j                  j                          | j
                  j                          | j                  j                          | j                  j                          | j                  j                          | j                  j                          | j                  j                          | j                  j                          | j                  j                          | j                  j                          | j                  j                          | j                  j                          | j                   j                          y r$   )r%   freezer&   r'   r(   r)   r*   r+   r,   r-   r.   r/   r0   r1   r2   r3   r4   r6   s    r7   r>   zTraceConfig.freeze\   s"   %%'##**,((//1##%""))+!!((*((//1&&--/((//1&&--/%%,,.&&--/$$++-%%'&&(%%,,.r9   c                     | j                   S r$   )r%   r?   s    r7   on_request_startzTraceConfig.on_request_startn       %%%r9   c                     | j                   S r$   )r&   r?   s    r7   on_request_chunk_sentz!TraceConfig.on_request_chunk_sentr   s     ***r9   c                     | j                   S r$   )r'   r?   s    r7   on_response_chunk_receivedz&TraceConfig.on_response_chunk_receivedx        ///r9   c                     | j                   S r$   )r(   r?   s    r7   on_request_endzTraceConfig.on_request_end~   s    ###r9   c                     | j                   S r$   )r)   r?   s    r7   on_request_exceptionz TraceConfig.on_request_exception   s     )))r9   c                     | j                   S r$   )r*   r?   s    r7   on_request_redirectzTraceConfig.on_request_redirect   s     (((r9   c                     | j                   S r$   )r+   r?   s    r7   on_connection_queued_startz&TraceConfig.on_connection_queued_start   rG   r9   c                     | j                   S r$   )r,   r?   s    r7   on_connection_queued_endz$TraceConfig.on_connection_queued_end        ---r9   c                     | j                   S r$   )r-   r?   s    r7   on_connection_create_startz&TraceConfig.on_connection_create_start   rG   r9   c                     | j                   S r$   )r.   r?   s    r7   on_connection_create_endz$TraceConfig.on_connection_create_end   rR   r9   c                     | j                   S r$   )r/   r?   s    r7   on_connection_reuseconnz#TraceConfig.on_connection_reuseconn        ,,,r9   c                     | j                   S r$   )r0   r?   s    r7   on_dns_resolvehost_startz$TraceConfig.on_dns_resolvehost_start   rR   r9   c                     | j                   S r$   )r1   r?   s    r7   on_dns_resolvehost_endz"TraceConfig.on_dns_resolvehost_end   s     +++r9   c                     | j                   S r$   )r2   r?   s    r7   on_dns_cache_hitzTraceConfig.on_dns_cache_hit   rB   r9   c                     | j                   S r$   )r3   r?   s    r7   on_dns_cache_misszTraceConfig.on_dns_cache_miss   s    &&&r9   c                     | j                   S r$   )r4   r?   s    r7   on_request_headers_sentz#TraceConfig.on_request_headers_sent   rY   r9   r$   r"   N)r"   z'_TracingSignal[TraceRequestStartParams])r"   z+_TracingSignal[TraceRequestChunkSentParams])r"   z0_TracingSignal[TraceResponseChunkReceivedParams])r"   z%_TracingSignal[TraceRequestEndParams])r"   z+_TracingSignal[TraceRequestExceptionParams])r"   z*_TracingSignal[TraceRequestRedirectParams])r"   z0_TracingSignal[TraceConnectionQueuedStartParams])r"   z._TracingSignal[TraceConnectionQueuedEndParams])r"   z0_TracingSignal[TraceConnectionCreateStartParams])r"   z._TracingSignal[TraceConnectionCreateEndParams])r"   z._TracingSignal[TraceConnectionReuseconnParams])r"   z._TracingSignal[TraceDnsResolveHostStartParams])r"   z,_TracingSignal[TraceDnsResolveHostEndParams])r"   z&_TracingSignal[TraceDnsCacheHitParams])r"   z'_TracingSignal[TraceDnsCacheMissParams])r"   z-_TracingSignal[TraceRequestHeadersSentParams])__name__
__module____qualname____doc__r   typer8   r   r<   r>   propertyrA   rD   rF   rI   rK   rM   rO   rQ   rT   rV   rX   r[   r]   r_   ra   rc    r9   r7   r   r   '   s   P AP,B(,_(=,B	,B\S# S S/$ & & +	6+ +
 0	;0 0
 $ $ *	6* *
 )	5) )
 0	;0 0
 .	9. .
 0	;0 0
 .	9. .
 -	9- -
 .	9. .
 ,	7, ,
 & & ' ' -	8- -r9   r   )auto_attribsfrozenslotsc                   0    e Zd ZU dZeed<   eed<   ded<   y)r   z0Parameters sent by the `on_request_start` signalmethodurlCIMultiDict[str]headersNre   rf   rg   rh   str__annotations__r	   rk   r9   r7   r   r      s    :K	Hr9   r   c                   0    e Zd ZU dZeed<   eed<   eed<   y)r   z5Parameters sent by the `on_request_chunk_sent` signalrp   rq   chunkNre   rf   rg   rh   ru   rv   r	   bytesrk   r9   r7   r   r      s    ?K	HLr9   r   c                   0    e Zd ZU dZeed<   eed<   eed<   y)r   z:Parameters sent by the `on_response_chunk_received` signalrp   rq   rx   Nry   rk   r9   r7   r   r      s    DK	HLr9   r   c                   :    e Zd ZU dZeed<   eed<   ded<   eed<   y)r   z.Parameters sent by the `on_request_end` signalrp   rq   rr   rs   responseNre   rf   rg   rh   ru   rv   r	   r   rk   r9   r7   r   r      s    8K	Hr9   r   c                   :    e Zd ZU dZeed<   eed<   ded<   eed<   y)r   z4Parameters sent by the `on_request_exception` signalrp   rq   rr   rs   	exceptionN)re   rf   rg   rh   ru   rv   r	   BaseExceptionrk   r9   r7   r   r      s    >K	Hr9   r   c                   :    e Zd ZU dZeed<   eed<   ded<   eed<   y)r   z3Parameters sent by the `on_request_redirect` signalrp   rq   rr   rs   r}   Nr~   rk   r9   r7   r   r      s    =K	Hr9   r   c                       e Zd ZdZy)r   z:Parameters sent by the `on_connection_queued_start` signalNre   rf   rg   rh   rk   r9   r7   r   r          Dr9   r   c                       e Zd ZdZy)r   z8Parameters sent by the `on_connection_queued_end` signalNr   rk   r9   r7   r   r         Br9   r   c                       e Zd ZdZy)r   z:Parameters sent by the `on_connection_create_start` signalNr   rk   r9   r7   r   r   
  r   r9   r   c                       e Zd ZdZy)r   z8Parameters sent by the `on_connection_create_end` signalNr   rk   r9   r7   r   r     r   r9   r   c                       e Zd ZdZy)r   z7Parameters sent by the `on_connection_reuseconn` signalNr   rk   r9   r7   r   r     s    Ar9   r   c                       e Zd ZU dZeed<   y)r   z8Parameters sent by the `on_dns_resolvehost_start` signalhostNre   rf   rg   rh   ru   rv   rk   r9   r7   r   r     s
    B
Ir9   r   c                       e Zd ZU dZeed<   y)r   z6Parameters sent by the `on_dns_resolvehost_end` signalr   Nr   rk   r9   r7   r   r      s
    @
Ir9   r   c                       e Zd ZU dZeed<   y)r   z0Parameters sent by the `on_dns_cache_hit` signalr   Nr   rk   r9   r7   r   r   '  s
    :
Ir9   r   c                       e Zd ZU dZeed<   y)r   z1Parameters sent by the `on_dns_cache_miss` signalr   Nr   rk   r9   r7   r   r   .  s
    ;
Ir9   r   c                   0    e Zd ZU dZeed<   eed<   ded<   y)r   z7Parameters sent by the `on_request_headers_sent` signalrp   rq   rr   rs   Nrt   rk   r9   r7   r   r   5  s    AK	Hr9   r   c            
       D   e Zd ZdZdddededdfdZd	ed
eddddfdZ	d	ed
ede
ddfdZd	ed
ede
ddfdZd	ed
edddeddf
dZd	ed
edddeddf
dZd	ed
edddeddf
dZd!dZd!dZd!dZd!dZd!dZdeddfdZdeddfdZdeddfdZdeddfdZd	ed
eddddfd Zy)"TracezInternal dependency holder class.

    Used to keep together the main dependencies used
    at the moment of send a signal.
    sessionr   trace_configr<   r"   Nc                 .    || _         || _        || _        y r$   )_trace_config_trace_config_ctx_session)r6   r   r   r<   s       r7   r8   zTrace.__init__E  s     *!1r9   rp   rq   rs   rr   c           	         K   | j                   j                  j                  | j                  | j                  t        |||             d {   S 7 wr$   )r   rA   sendr   r   r   r6   rp   rq   rs   s       r7   send_request_startzTrace.send_request_startO  sM      ''88==MM""#FC9
 
 	
 
   A
AAArx   c           	         K   | j                   j                  j                  | j                  | j                  t        |||             d {   S 7 wr$   )r   rD   r   r   r   r   r6   rp   rq   rx   s       r7   send_request_chunk_sentzTrace.send_request_chunk_sentX  sM      ''==BBMM""'U;
 
 	
 
r   c           	         K   | j                   j                  j                  | j                  | j                  t        |||             d {   S 7 wr$   )r   rF   r   r   r   r   r   s       r7   send_response_chunk_receivedz"Trace.send_response_chunk_receiveda  sM      ''BBGGMM"",VS%@
 
 	
 
r   r}   c           
         K   | j                   j                  j                  | j                  | j                  t        ||||             d {   S 7 wr$   )r   rI   r   r   r   r   r6   rp   rq   rs   r}   s        r7   send_request_endzTrace.send_request_endj  sO      ''66;;MM""!&#wA
 
 	
 
   AAAAr   c           
         K   | j                   j                  j                  | j                  | j                  t        ||||             d {   S 7 wr$   )r   rK   r   r   r   r   )r6   rp   rq   rs   r   s        r7   send_request_exceptionzTrace.send_request_exceptionw  sO      ''<<AAMM""'WiH
 
 	
 
r   c           
         K   | j                   j                  j                  | j                  | j                  t        ||||             d {   S 7 wr$   )r   r*   r   r   r   r   r   s        r7   send_request_redirectzTrace.send_request_redirect  sO      ''<<AAMM""&vsGXF
 
 	
 
r   c                    K   | j                   j                  j                  | j                  | j                  t                      d {   S 7 wr$   )r   rO   r   r   r   r   r?   s    r7   send_connection_queued_startz"Trace.send_connection_queued_start  D     ''BBGGMM4113S3U
 
 	
 
   AA	A
Ac                    K   | j                   j                  j                  | j                  | j                  t                      d {   S 7 wr$   )r   rQ   r   r   r   r   r?   s    r7   send_connection_queued_endz Trace.send_connection_queued_end  D     ''@@EEMM4113Q3S
 
 	
 
r   c                    K   | j                   j                  j                  | j                  | j                  t                      d {   S 7 wr$   )r   rT   r   r   r   r   r?   s    r7   send_connection_create_startz"Trace.send_connection_create_start  r   r   c                    K   | j                   j                  j                  | j                  | j                  t                      d {   S 7 wr$   )r   rV   r   r   r   r   r?   s    r7   send_connection_create_endz Trace.send_connection_create_end  r   r   c                    K   | j                   j                  j                  | j                  | j                  t                      d {   S 7 wr$   )r   rX   r   r   r   r   r?   s    r7   send_connection_reuseconnzTrace.send_connection_reuseconn  sD     ''??DDMM4113Q3S
 
 	
 
r   r   c                    K   | j                   j                  j                  | j                  | j                  t        |             d {   S 7 wr$   )r   r[   r   r   r   r   r6   r   s     r7   send_dns_resolvehost_startz Trace.send_dns_resolvehost_start  sG     ''@@EEMM4113QRV3W
 
 	
 
   AA
AAc                    K   | j                   j                  j                  | j                  | j                  t        |             d {   S 7 wr$   )r   r]   r   r   r   r   r   s     r7   send_dns_resolvehost_endzTrace.send_dns_resolvehost_end  sG     ''>>CCMM4113OPT3U
 
 	
 
r   c                    K   | j                   j                  j                  | j                  | j                  t        |             d {   S 7 wr$   )r   r_   r   r   r   r   r   s     r7   send_dns_cache_hitzTrace.send_dns_cache_hit  sF     ''88==MM4113I$3O
 
 	
 
r   c                    K   | j                   j                  j                  | j                  | j                  t        |             d {   S 7 wr$   )r   ra   r   r   r   r   r   s     r7   send_dns_cache_misszTrace.send_dns_cache_miss  sF     ''99>>MM4113J43P
 
 	
 
r   c           	         K   | j                   j                  j                  | j                  | j                  t        |||             d {   S 7 wr$   )r   r4   r   r   r   r   r   s       r7   send_request_headerszTrace.send_request_headers  sM      ''@@EEMM"")&#w?
 
 	
 
r   rd   )re   rf   rg   rh   r   r   r8   ru   r	   r   rz   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   rk   r9   r7   r   r   >  s       "  *	 
 
 

 #
.@
	


 #
,1
	


 #
,1
	


 
 $	

 !
 



 
 $	

 !
 



 
 $	

 !
 












S 
T 


3 
4 


S 
T 


c 
d 



 #
.@
	
r9   r   )'typesr   typingr   r   r   attr	aiosignalr   	multidictr   yarlr	   client_reqrepr   clientr   r   _TracingSignal__all__r   sr   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   rk   r9   r7   <module>r      s   ! . .   !  )%-TBNM?NJKN*]- ]-@ T$d3    4  T$d3  4 T$d3  4 T$d3  4 T$d3  4 T$d3  4 T$d3E E 4E T$d3C C 4C T$d3E E 4E T$d3C C 4C T$d3B B 4B T$d3  4 T$d3  4 T$d3  4 T$d3  4 T$d3    4 G
 G
r9   