K ; d dl Z d dlZd dlmZ d dlmZ d dlmZmZ d dl m
Z
d dl m Z m
Z
d dlmZ d dlmZ d d lmZmZ d d
lmZmZmZ d d lmZ d d lm Z m Z m Z m Z m Z m!Z!m"Z"m#Z#m$Z$m%Z% d dl&Z&d d
l'm(Z) d dl'm*Z*m+Z+ d dl,m-Z-m.Z.m/Z/ n# e0$ r e
d w xY wd dl1m2Z2 e2rJd dl3m4Z4 d dl5m6Z6 d dl'm7Z7m8Z8 d dl9m:Z: d dl;mZ> d dl;m?Z? d dl;m@Z@ d dl;mAZA d d lmBZB d d l1mCZC d ZD G d d e ZEd! ZFd" ZGd# ZHd$ZId% ZJdS )& N)continue_trace)reraise)OPSPANDATA)Hub) Integration DidNotEnable)
ignore_logger)auto_session_tracking)_filter_headersrequest_body_within_bounds)BAGGAGE_HEADER_NAMESOURCE_FOR_STYLETRANSACTION_SOURCE_ROUTE)should_propagate_trace)
capture_internal_exceptionsevent_from_exceptionlogger parse_url
parse_versiontransaction_from_functionHAS_REAL_CONTEXTVARSCONTEXTVARS_ERROR_MESSAGESENSITIVE_DATA_SUBSTITUTEAnnotatedValue) __version__)
ClientSession TraceConfig) Application
HTTPException
UrlDispatcherzAIOHTTP not installed)
TYPE_CHECKING)Request)AbstractMatchInfo)TraceRequestStartParamsTraceRequestEndParams)SimpleNamespace)Any)Dict)Optional)Tuple)Callable)Union)ExcInfo)EventProcessor) handler_namemethod_and_path_patternc 0 e Zd ZdZddZed ZdS )AioHttpIntegrationaiohttpr0 c \ |t vrt d|dt d || _ d S )Nz%Invalid value for transaction_style: z
(must be in ))TRANSACTION_STYLE_VALUES
ValueErrortransaction_style)selfr9 s q/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/sentry_sdk/integrations/aiohttp.py__init__zAioHttpIntegration.__init__C sJ $< < < *$$$&>&>&>@
"3 c t t } | 't d t | dk rt d t st dt
z t
d t j fd}|t _ t j
fd}|t _
t j fd}|t _ d S ) Nz Unparsable AIOHTTP version: {}) z AIOHTTP 3.4 or newer required.zSThe aiohttp integration for Sentry requires Python 3.7+ or aiocontextvars package.zaiohttp.serverc @ K t j }| t
| |g|R i | d {V S t j | }t | 5 }t
|d 5 | 5 }| | t | d d d n # 1 swxY w Y t |j t j dt }| |d|i 5
| | d {V }ny# t" $ r } | | j d } ~ wt( j t, f$ r | d t0 $ r t3 t5 | Y nw xY w| |j |cd d d cd d d cd d d S # 1 swxY w Y d d d n # 1 swxY w Y d d d d S # 1 swxY w Y d S )Nrequest) session_modezgeneric AIOHTTP request)opnamesourceaiohttp_request)custom_sampling_context cancelled) r currentget_integrationr3 weakrefrefr configure_scopeclear_breadcrumbsadd_event_processor_make_request_processorr headersr HTTP_SERVERr start_transactionr set_http_status status_codeasyncioCancelledErrorConnectionResetError
set_status Exceptionr _capture_exceptionstatus) r: rB argskwargshub weak_requestscope transactionresponsee
old_handles r; sentry_app_handlez8AioHttpIntegration.setup_once..sentry_app_handled s +C""#566> 'Zg G G G G G GGGGGGGG";w//LS "
(S*3YGGG !( !( ,,.. Y% //111 112I,2W2WXXXY Y Y Y Y Y Y Y Y Y Y Y Y Y Y #1 > 7 7
# # #K ..#1BG0L / ( ( >-7Zg-F-F'F'F'F'F'F'FHH , " " " ' 7 7
F F F ! ' 68L M " " " ' 2 2; ? ? ? ! ( > > > $%7%<%< = = = =>
$33HODDD '%( ( ( ( ( ( ( !( !( !( !( !( !( !("
( "
( "
( "
( "
( "
( "
( "
( ( ( ( ( ( ( ( ( ( !( !( !( !( !( !( !( !( !( !( !( !( !( !( !("
( "
( "
( "
( "
( "
( "
( "
( "
( "
( "
( "
( "
( "
( "
( "
( "
( "
(s H2G;7C
> G;
C G;C AG;G#D*)G#*
F 4E AF G# F G#> G;
H#G' 'G;*G' +G;/ H;G? ?HG? HHHc j K | | d {V }t j }| t }d } |j dk rt |j }nd|j dk rY| }| d p| d }d |j
| }n# t $ r Y nw xY w|]t j 5 }|
|t |j d d d n # 1 swxY w Y |S )Nr0 r1 path formatterz{} {})rF )r rJ rK r3 r9 r handlerget_infogetformatmethodr[ rN set_transaction_namer )
r: rB rvr` integrationrE
route_infopatternrb old_urldispatcher_resolves
r; sentry_urldispatcher_resolvezCAioHttpIntegration.setup_once..sentry_urldispatcher_resolve s 00w????????B+C --.@AAKD
0NBB4RZ@@DD 26OOO!# J (nnV 4 4 S
{8S8SG">>'.'BBD
[0022 e.. / 0M N / Is$ BC
CC4(D((D,/D,c t j }| t | i |S t | d pd }t
}| | ||d< | i |S )N
trace_configs )r rJ rK r3 listrm create_trace_configappend)r^ r_ r` client_trace_configs trace_configold_client_session_inits r; initz+AioHttpIntegration.setup_once..init s +C""#566>..????#'
?(C(C(Ir#J#J .00L ' ' 5 5 5&:F? #**D;F;; ;r= )
r AIOHTTP_VERSIONr rn r r r
r _handler! resolver r< )versionrg rv r r rf ru s @@@r;
setup_oncez AioHttpIntegration.setup_onceL s 00 ? ? F F W WXX X V ?@@ @# .0IJ
&''' (
* ( * ( * ( * ( * (X 0 $1$9! 8 !=
"/"8 < < < < < "&
r= N)r0 )__name__
__module__ __qualname__
identifierr< staticmethodr ry r= r; r3 r3 @ sM J3 3 3 3 t& t& \t& t& t&r= r3 c d } d }t }|j | |j | |S )Nc K t j }| t d S |j }d }t
5 t t |j d }d d d n # 1 swxY w Y |
t j |d|r|j nt }| t j | | d|j | t j |j | t j |j t+ |t |j r| | D ]\ }}t/ j d |||j |t4 k r8|j t4 r|j |xx d|z z
cc< w||j |< ||_ d S ) NF)sanitize )rD descriptionurlzE[Tracing] Adding `{key}` header {value} to outgoing request to {url}.)keyvaluer ,) r rJ rK r3 ro upperr r strr
start_spanr HTTP_CLIENTr set_datar HTTP_METHOD
HTTP_QUERYquery
HTTP_FRAGMENTfragmentr iter_trace_propagation_headersr debugrn r rR rm span) sessiontrace_config_ctxparamsr` ro
parsed_urlr r r s r; on_request_startz-create_trace_config..on_request_start sI k 1 2 2 : F $$&&
(
*
* D D"3vz??UCCCJ D D D D D D D D D D D D D D D ~~~vvRz~~9RRT
h*F333
eZ^,,,
h):+;<<<
h,j.ABBB !#s6: 7 7
0 ! @ @ F F
0
0
U [bb u&* c
---&.2D2D'3 3- N3'''3;6''''*/FN3'' $ s $BB Bc K |j d S |j }| t |j j | d|j j | d S )Nreason)r rU intrd r] r r finish)r r r r s r; on_request_endz+create_trace_config..on_request_end sg ( F $ S !7 8 8999
h 6777
r= )r r r| r )r r r~ s r; r{ r{ sa %% %% %%N ==L!(()9::: &&~666 r= c fd}|S )Nc }|| S t 5 | di }|j d|j |j |d< |j |d< |j |d< d|j i|d< t j }t t |j |d< t || |d < d d d n # 1 swxY w Y | S )
NrB z://r query_stringro REMOTE_ADDRenvrR data)r
setdefaultschemehostri r ro remoter rJ r dictrR get_aiohttp_request_data)eventhintrB request_infor` ra s r; aiohttp_processorz2_make_request_processor..aiohttp_processor s2
,.. ?L
(
*
* J J ++Ir::L #L ,3+?L (%,^L "#0'."AL +C&5d7?6K6K&L&LL #
$r s
) ) ) ) ) ) & & & & & & * * * * * * * * = = = = = = = = 9 9 9 9 9 9 5 5 5 5 5 5
< ; ; ; ; ; 0NNN66666622222222EEEEEEEEEEE 0 0 0
,.
/
//0 , + + + + +
1++++++------FFFFFFFF%%%%%% ((((((000000 G A& A& A& A& A& A& A& A&H8 8 8v" " " J S s ( B B