o
    RÊÆh0;  ã                   @   s˜  d dl mZ d dlmZmZmZ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rJdd	lmZ ed
dd�ZG dd„ dee ƒZdZG dd„ dƒZe	jdddd�G dd„ dƒƒZe	jdddd�G dd„ dƒƒZe	jdddd�G dd„ dƒƒZe	jdddd�G dd„ dƒƒZe	jdddd�G dd„ dƒƒZe	jdddd�G dd„ dƒƒZe	jdddd�G dd „ d ƒƒZe	jdddd�G d!d"„ d"ƒƒZ e	jdddd�G d#d$„ d$ƒƒZ!e	jdddd�G d%d&„ d&ƒƒZ"e	jdddd�G d'd(„ d(ƒƒZ#e	jdddd�G d)d*„ d*ƒƒZ$e	jdddd�G d+d,„ d,ƒƒZ%e	jdddd�G d-d.„ d.ƒƒZ&e	jdddd�G d/d0„ d0ƒƒZ'e	jdddd�G d1d2„ d2ƒƒZ(G d3d4„ d4ƒZ)dS )5é    )ÚSimpleNamespace)ÚTYPE_CHECKINGÚ	AwaitableÚOptionalÚProtocolÚTypeÚTypeVarN)ÚSignal)ÚCIMultiDict)ÚURLé   )ÚClientResponse)ÚClientSessionÚ_ParamT_contraT)Úcontravariantc                	   @   s*   e Zd Zdedededed fdd„ZdS )Ú_SignalCallbackÚ_SignalCallback__client_sessionÚ!_SignalCallback__trace_config_ctxÚ_SignalCallback__paramsÚreturnNc                 C   s   d S ©N© )Úselfr   r   r   r   r   ú\/var/www/html/HyperOracle/crypto_trader/venv/lib/python3.10/site-packages/aiohttp/tracing.pyÚ__call__   s   z_SignalCallback.__call__)Ú__name__Ú
__module__Ú__qualname__r   r   r   r   r   r   r   r   r   r      s    þýüûr   )ÚTraceConfigÚTraceRequestStartParamsÚTraceRequestEndParamsÚTraceRequestExceptionParamsÚ TraceConnectionQueuedStartParamsÚTraceConnectionQueuedEndParamsÚ TraceConnectionCreateStartParamsÚTraceConnectionCreateEndParamsÚTraceConnectionReuseconnParamsÚTraceDnsResolveHostStartParamsÚTraceDnsResolveHostEndParamsÚTraceDnsCacheHitParamsÚTraceDnsCacheMissParamsÚTraceRequestRedirectParamsÚTraceRequestChunkSentParamsÚ TraceResponseChunkReceivedParamsÚTraceRequestHeadersSentParamsc                   @   s^  e Zd ZdZefdee ddfdd„Z	d<dee defdd	„Zd=d
d„Z	e
d>dd„ƒZe
		d?dd„ƒZe
		d@dd„ƒZe
dAdd„ƒZe
		dBdd„ƒZe
		dCdd„ƒZe
		dDdd „ƒZe
		!dEd"d#„ƒZe
		$dFd%d&„ƒZe
		'dGd(d)„ƒZe
		*dHd+d,„ƒZe
		-dId.d/„ƒZe
		0dJd1d2„ƒZe
dKd4d5„ƒZe
dLd7d8„ƒZe
		9dMd:d;„ƒZdS )Nr   zFFirst-class used to trace requests launched via ClientSession objects.Útrace_config_ctx_factoryr   Nc                 C   sª   t | ƒ| _t | ƒ| _t | ƒ| _t | ƒ| _t | ƒ| _t | ƒ| _t | ƒ| _t | ƒ| _t | ƒ| _	t | ƒ| _
t | ƒ| _t | ƒ| _t | ƒ| _t | ƒ| _t | ƒ| _t | ƒ| _|| _d S r   )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)r   r/   r   r   r   Ú__init__2   sD   þþþÿþþþþþþþþþþþþ
zTraceConfig.__init__Útrace_request_ctxc                 C   s   | j |d�S )z&Return a new trace_config_ctx instance)rB   )r@   )r   rB   r   r   r   Útrace_config_ctxh   s   zTraceConfig.trace_config_ctxc                 C   s¤   | j  ¡  | j ¡  | j ¡  | j ¡  | j ¡  | j ¡  | j ¡  | j ¡  | j	 ¡  | j
 ¡  | j ¡  | j ¡  | j ¡  | j ¡  | j ¡  | j ¡  d S r   )r0   Úfreezer1   r2   r3   r4   r5   r6   r7   r8   r9   r:   r;   r<   r=   r>   r?   ©r   r   r   r   rD   n   s    














zTraceConfig.freezeú0Signal[_SignalCallback[TraceRequestStartParams]]c                 C   ó   | j S r   )r0   rE   r   r   r   Úon_request_start€   ó   zTraceConfig.on_request_startú4Signal[_SignalCallback[TraceRequestChunkSentParams]]c                 C   rG   r   )r1   rE   r   r   r   Úon_request_chunk_sent„   ó   z!TraceConfig.on_request_chunk_sentú9Signal[_SignalCallback[TraceResponseChunkReceivedParams]]c                 C   rG   r   )r2   rE   r   r   r   Úon_response_chunk_receivedŠ   rL   z&TraceConfig.on_response_chunk_receivedú.Signal[_SignalCallback[TraceRequestEndParams]]c                 C   rG   r   )r3   rE   r   r   r   Úon_request_end�   rI   zTraceConfig.on_request_endú4Signal[_SignalCallback[TraceRequestExceptionParams]]c                 C   rG   r   )r4   rE   r   r   r   Úon_request_exception”   rL   z TraceConfig.on_request_exceptionú3Signal[_SignalCallback[TraceRequestRedirectParams]]c                 C   rG   r   )r5   rE   r   r   r   Úon_request_redirectš   rL   zTraceConfig.on_request_redirectú9Signal[_SignalCallback[TraceConnectionQueuedStartParams]]c                 C   rG   r   )r6   rE   r   r   r   Úon_connection_queued_start    rL   z&TraceConfig.on_connection_queued_startú7Signal[_SignalCallback[TraceConnectionQueuedEndParams]]c                 C   rG   r   )r7   rE   r   r   r   Úon_connection_queued_end¦   rL   z$TraceConfig.on_connection_queued_endú9Signal[_SignalCallback[TraceConnectionCreateStartParams]]c                 C   rG   r   )r8   rE   r   r   r   Úon_connection_create_start¬   rL   z&TraceConfig.on_connection_create_startú7Signal[_SignalCallback[TraceConnectionCreateEndParams]]c                 C   rG   r   )r9   rE   r   r   r   Úon_connection_create_end²   rL   z$TraceConfig.on_connection_create_endú7Signal[_SignalCallback[TraceConnectionReuseconnParams]]c                 C   rG   r   )r:   rE   r   r   r   Úon_connection_reuseconn¸   rL   z#TraceConfig.on_connection_reuseconnú7Signal[_SignalCallback[TraceDnsResolveHostStartParams]]c                 C   rG   r   )r;   rE   r   r   r   Úon_dns_resolvehost_start¾   rL   z$TraceConfig.on_dns_resolvehost_startú5Signal[_SignalCallback[TraceDnsResolveHostEndParams]]c                 C   rG   r   )r<   rE   r   r   r   Úon_dns_resolvehost_endÄ   rL   z"TraceConfig.on_dns_resolvehost_endú/Signal[_SignalCallback[TraceDnsCacheHitParams]]c                 C   rG   r   )r=   rE   r   r   r   Úon_dns_cache_hitÊ   rI   zTraceConfig.on_dns_cache_hitú0Signal[_SignalCallback[TraceDnsCacheMissParams]]c                 C   rG   r   )r>   rE   r   r   r   Úon_dns_cache_missÎ   rI   zTraceConfig.on_dns_cache_missú6Signal[_SignalCallback[TraceRequestHeadersSentParams]]c                 C   rG   r   )r?   rE   r   r   r   Úon_request_headers_sentÒ   rL   z#TraceConfig.on_request_headers_sentr   ©r   N)r   rF   )r   rJ   )r   rM   )r   rO   )r   rQ   )r   rS   )r   rU   )r   rW   )r   rY   )r   r[   )r   r]   )r   r_   )r   ra   )r   rc   )r   re   )r   rg   )r   r   r   Ú__doc__r   r   rA   r   rC   rD   ÚpropertyrH   rK   rN   rP   rR   rT   rV   rX   rZ   r\   r^   r`   rb   rd   rf   rh   r   r   r   r   r   /   sŽ    ÿÿ
þ7ÿÿ
þ
þþþþþþþþþþþþr   )Úauto_attribsÚfrozenÚslotsc                   @   ó*   e Zd ZU dZeed< eed< ded< dS )r   z0Parameters sent by the `on_request_start` signalÚmethodÚurlúCIMultiDict[str]ÚheadersN©r   r   r   rj   ÚstrÚ__annotations__r   r   r   r   r   r   Ù   ó
   
 r   c                   @   ó*   e Zd ZU dZeed< eed< eed< dS )r,   z5Parameters sent by the `on_request_chunk_sent` signalrp   rq   ÚchunkN©r   r   r   rj   ru   rv   r   Úbytesr   r   r   r   r,   â   rw   r,   c                   @   rx   )r-   z:Parameters sent by the `on_response_chunk_received` signalrp   rq   ry   Nrz   r   r   r   r   r-   ë   rw   r-   c                   @   ó2   e Zd ZU dZeed< eed< ded< eed< dS )r    z.Parameters sent by the `on_request_end` signalrp   rq   rr   rs   ÚresponseN©r   r   r   rj   ru   rv   r   r   r   r   r   r   r    ô   ó   
 r    c                   @   r|   )r!   z4Parameters sent by the `on_request_exception` signalrp   rq   rr   rs   Ú	exceptionN)r   r   r   rj   ru   rv   r   ÚBaseExceptionr   r   r   r   r!   þ   r   r!   c                   @   r|   )r+   z3Parameters sent by the `on_request_redirect` signalrp   rq   rr   rs   r}   Nr~   r   r   r   r   r+     r   r+   c                   @   ó   e Zd ZdZdS )r"   z:Parameters sent by the `on_connection_queued_start` signalN©r   r   r   rj   r   r   r   r   r"     ó    r"   c                   @   r‚   )r#   z8Parameters sent by the `on_connection_queued_end` signalNrƒ   r   r   r   r   r#     r„   r#   c                   @   r‚   )r$   z:Parameters sent by the `on_connection_create_start` signalNrƒ   r   r   r   r   r$     r„   r$   c                   @   r‚   )r%   z8Parameters sent by the `on_connection_create_end` signalNrƒ   r   r   r   r   r%   !  r„   r%   c                   @   r‚   )r&   z7Parameters sent by the `on_connection_reuseconn` signalNrƒ   r   r   r   r   r&   &  r„   r&   c                   @   ó   e Zd ZU dZeed< dS )r'   z8Parameters sent by the `on_dns_resolvehost_start` signalÚhostN©r   r   r   rj   ru   rv   r   r   r   r   r'   +  ó   
 r'   c                   @   r…   )r(   z6Parameters sent by the `on_dns_resolvehost_end` signalr†   Nr‡   r   r   r   r   r(   2  rˆ   r(   c                   @   r…   )r)   z0Parameters sent by the `on_dns_cache_hit` signalr†   Nr‡   r   r   r   r   r)   9  rˆ   r)   c                   @   r…   )r*   z1Parameters sent by the `on_dns_cache_miss` signalr†   Nr‡   r   r   r   r   r*   @  rˆ   r*   c                   @   ro   )r.   z7Parameters sent by the `on_request_headers_sent` signalrp   rq   rr   rs   Nrt   r   r   r   r   r.   G  rw   r.   c                
   @   sf  e Zd ZdZdddededdfdd	„Zd
ededdddfdd„Z	d
edede
ddfdd„Zd
edede
ddfdd„Zd
ededddeddf
dd„Zd
ededddeddf
dd„Zd
ededddeddf
dd„Zd2dd„Zd2dd „Zd2d!d"„Zd2d#d$„Zd2d%d&„Zd'eddfd(d)„Zd'eddfd*d+„Zd'eddfd,d-„Zd'eddfd.d/„Zd
ededdddfd0d1„ZdS )3ÚTracez€Internal dependency holder class.

    Used to keep together the main dependencies used
    at the moment of send a signal.
    Úsessionr   Útrace_configrC   r   Nc                 C   s   || _ || _|| _d S r   )Ú_trace_configÚ_trace_config_ctxÚ_session)r   rŠ   r‹   rC   r   r   r   rA   W  s   
zTrace.__init__rp   rq   rs   rr   c                 Ã   ó&   �| j j | j| jt|||ƒ¡I d H S r   )rŒ   rH   ÚsendrŽ   r�   r   ©r   rp   rq   rs   r   r   r   Úsend_request_starta  ó   €

ýzTrace.send_request_startry   c                 Ã   r�   r   )rŒ   rK   r�   rŽ   r�   r,   ©r   rp   rq   ry   r   r   r   Úsend_request_chunk_sentj  r“   zTrace.send_request_chunk_sentc                 Ã   r�   r   )rŒ   rN   r�   rŽ   r�   r-   r”   r   r   r   Úsend_response_chunk_receiveds  r“   z"Trace.send_response_chunk_receivedr}   c              	   Ã   ó(   �| j j | j| jt||||ƒ¡I d H S r   )rŒ   rP   r�   rŽ   r�   r    ©r   rp   rq   rs   r}   r   r   r   Úsend_request_end|  ó   €
ýzTrace.send_request_endr€   c              	   Ã   r—   r   )rŒ   rR   r�   rŽ   r�   r!   )r   rp   rq   rs   r€   r   r   r   Úsend_request_exception‰  rš   zTrace.send_request_exceptionc              	   Ã   r—   r   )rŒ   r5   r�   rŽ   r�   r+   r˜   r   r   r   Úsend_request_redirect–  rš   zTrace.send_request_redirectc                 Ã   ó    �| j j | j| jtƒ ¡I d H S r   )rŒ   rV   r�   rŽ   r�   r"   rE   r   r   r   Úsend_connection_queued_start£  ó   €
ÿz"Trace.send_connection_queued_startc                 Ã   r�   r   )rŒ   rX   r�   rŽ   r�   r#   rE   r   r   r   Úsend_connection_queued_end¨  rŸ   z Trace.send_connection_queued_endc                 Ã   r�   r   )rŒ   rZ   r�   rŽ   r�   r$   rE   r   r   r   Úsend_connection_create_start­  rŸ   z"Trace.send_connection_create_startc                 Ã   r�   r   )rŒ   r\   r�   rŽ   r�   r%   rE   r   r   r   Úsend_connection_create_end²  rŸ   z Trace.send_connection_create_endc                 Ã   r�   r   )rŒ   r^   r�   rŽ   r�   r&   rE   r   r   r   Úsend_connection_reuseconn·  rŸ   zTrace.send_connection_reuseconnr†   c                 Ã   ó"   �| j j | j| jt|ƒ¡I d H S r   )rŒ   r`   r�   rŽ   r�   r'   ©r   r†   r   r   r   Úsend_dns_resolvehost_start¼  ó   €
ÿz Trace.send_dns_resolvehost_startc                 Ã   r¤   r   )rŒ   rb   r�   rŽ   r�   r(   r¥   r   r   r   Úsend_dns_resolvehost_endÁ  r§   zTrace.send_dns_resolvehost_endc                 Ã   r¤   r   )rŒ   rd   r�   rŽ   r�   r)   r¥   r   r   r   Úsend_dns_cache_hitÆ  r§   zTrace.send_dns_cache_hitc                 Ã   r¤   r   )rŒ   rf   r�   rŽ   r�   r*   r¥   r   r   r   Úsend_dns_cache_missË  r§   zTrace.send_dns_cache_missc                 Ã   r�   r   )rŒ   r?   r�   rŽ   r�   r.   r‘   r   r   r   Úsend_request_headersÐ  r“   zTrace.send_request_headersri   )r   r   r   rj   r   r   rA   ru   r   r’   r{   r•   r–   r   r™   r�   r›   rœ   rž   r    r¡   r¢   r£   r¦   r¨   r©   rª   r«   r   r   r   r   r‰   P  s²    þýü
û
ÿÿÿ
þ	ÿÿÿ
þ	ÿÿÿ
þ	þýüû
úþýüû
úþýüû
ú




ÿÿÿþr‰   )*Útypesr   Útypingr   r   r   r   r   r   ÚattrÚ	aiosignalr	   Ú	multidictr
   Úyarlr   Úclient_reqrepr   Úclientr   r   r   Ú__all__r   Úsr   r,   r-   r    r!   r+   r"   r#   r$   r%   r&   r'   r(   r)   r*   r.   r‰   r   r   r   r   Ú<module>   s^     
 +			