bg!-ddlZddlZddlmZddlmZddlmZmZddl m Z ddl m Z m Z ddlmZddlmZdd lmZmZdd lmZmZmZdd lmZdd lmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z% ddl&Z&dd l'm(Z)ddl'm*Z*m+Z+ddl,m-Z-m.Z.m/Z/n#e0$r e dwxYwddl1m2Z2e2rJddl3m4Z4ddl5m6Z6ddl'm7Z7m8Z8ddl9m:Z:ddl;mZ>ddl;m?Z?ddl;m@Z@ddl;mAZAddlmBZBddl1mCZCdZDGdd 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_patternc0eZdZdZddZedZdS)AioHttpIntegrationaiohttpr0c\|tvrtd|dtd||_dS)Nz%Invalid value for transaction_style: z (must be in ))TRANSACTION_STYLE_VALUES ValueErrortransaction_style)selfr9s V/opt/cloudlinux/venv/lib64/python3.11/site-packages/sentry_sdk/integrations/aiohttp.py__init__zAioHttpIntegration.__init__CsJ $< < <*$$$&>&>&>@ "3ctt}|'tdt|dkrtdtstdt zt dtjfd}|t_tj fd}|t_ tj fd}|t_ dS) NzUnparsable AIOHTTP version: {})zAIOHTTP 3.4 or newer required.zSThe aiohttp integration for Sentry requires Python 3.7+ or aiocontextvars package.zaiohttp.serverc @Ktj}|t ||g|Ri|d{VSt j|}t|5}t |d5|5}|| t|dddn #1swxYwYt|j tjdt}||d|i5  ||d{V}ny#t"$r } || jd} ~ wt(jt,f$r|dt0$rt3t5|YnwxYw||j|cdddcdddcdddS#1swxYwY dddn #1swxYwYddddS#1swxYwYdS)Nrequest) session_modezgeneric AIOHTTP request)opnamesourceaiohttp_request)custom_sampling_context cancelled)rcurrentget_integrationr3weakrefrefr configure_scopeclear_breadcrumbsadd_event_processor_make_request_processorrheadersr HTTP_SERVERrstart_transactionr set_http_status status_codeasyncioCancelledErrorConnectionResetError set_status Exceptionr_capture_exceptionstatus) r:rBargskwargshub weak_requestscope transactionresponsee old_handles r;sentry_app_handlez8AioHttpIntegration.setup_once..sentry_app_handleds+C""#566>'ZgGGGGGGGGGGGGG";w//LS" (S*3YGGG!(!(,,..Y%//111112I,2W2WXXXYYYYYYYYYYYYYYY#1>77 ###K..#1BG0L/(( >-7Zg-F-F'F'F'F'F'F'FHH,"""'77 FFF! ' 68LM"""'22;???!(>>>$%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? HHHcjK ||d{V}tj}|t}d} |jdkrt |j}nd|jdkrY|}|dp|d}d |j |}n#t$rYnwxYw|]tj 5}| |t|jdddn #1swxYwY|S)Nr0r1path formatterz{} {})rF)rrJrKr3r9rhandlerget_infogetformatmethodr[rNset_transaction_namer) r:rBrvr` integrationrE route_infopatternrbold_urldispatcher_resolves r;sentry_urldispatcher_resolvezCAioHttpIntegration.setup_once..sentry_urldispatcher_resolves00w????????B+C--.@AAKD 0NBB4RZ@@DD 26OOO!#J(nnV44S {8S8SG">>'.'BBD    [0022e../ 0MN/ Is$BC CC4(D((D,/D,ctj}|t|i|St |dpd}t }||||d<|i|S)N trace_configs)rrJrKr3listrmcreate_trace_configappend)r^r_r`client_trace_configs trace_configold_client_session_inits r;initz+AioHttpIntegration.setup_once..inits+C""#566>..????#' ?(C(C(Ir#J#J .00L ' ' 5 5 5&:F? #**D;F;; ;r=) rAIOHTTP_VERSIONr rnrrr r_handler!resolverr<)versionrgrvrrrfrus @@@r; setup_oncezAioHttpIntegration.setup_onceLs 00 ??FFWWXX X V  ?@@ @# .0IJ  &''' ( * (* (* (* (* (X0 $1$9!     8!= "/"8 < < < < <"& r=N)r0)__name__ __module__ __qualname__ identifierr< staticmethodrryr=r;r3r3@sMJ3333t&t&\t&t&t&r=r3cd}d}t}|j||j||S)NcKtj}|tdS|j}d}t 5tt|j d}dddn #1swxYwY| tj |d|r|j nt}|tj||d|j |tj|j|tj|jt+|t|j r||D]\}}t/jd|||j |t4kr8|jt4r|j|xxd|zz cc<w||j|<||_dS) NF)sanitize )rD descriptionurlzE[Tracing] Adding `{key}` header {value} to outgoing request to {url}.)keyvaluer,)rrJrKr3roupperrrstrr start_spanr HTTP_CLIENTrset_datar HTTP_METHOD HTTP_QUERYquery HTTP_FRAGMENTfragmentriter_trace_propagation_headersrdebugrnrrRrmspan) sessiontrace_config_ctxparamsr`ro parsed_urlrrrs r;on_request_startz-create_trace_config..on_request_startsIk   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!@@FF 0 0 U [bbu&*c ---&.2D2D'33-N3'''3;6''''*/FN3'' $s$BB BcK|jdS|j}|t|jj|d|jj|dS)Nreason)rrUintrdr]rrfinish)rrrrs r;on_request_endz+create_trace_config..on_request_endsg  ( F$ S!788999 h 6777 r=)rrr|r)rrr~s r;r{r{sa%%%%%%N==L!(()9:::&&~666 r=cfd}|S)Nc}||St5|di}|jd|j|j|d<|j|d<|j|d<d|ji|d<tj }tt|j |d<t|||d <dddn #1swxYwY|S) NrBz://r query_stringro REMOTE_ADDRenvrRdata)r setdefaultschemehostrirroremoterrJr dictrRget_aiohttp_request_data)eventhintrB request_infor`ras r;aiohttp_processorz2_make_request_processor..aiohttp_processors2 ,.. ?L ( * * J J ++Ir::L  #L  ,3+?L (%,^L "#0'."AL +C&5d7?6K6K&L&LL # $rs ))))))&&&&&&********========999999555555 <;;;;;                        0NNN66666622222222EEEEEEEEEEE000 ,. / //0,+++++ 1++++++------FFFFFFFF%%%%%%((((((000000GA&A&A&A&A&A&A&A&H888v"""J   Ss (BB