\j> 4ddlZddlmZddlmZddlZddlmZmZddl m Z ddl m Z ddl mZmZmZddlmZmZdd lmZdd lmZmZdd lmZmZdd lmZdd lmZm Z m!Z!m"Z"erIddlm#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,ddl-m.Z.m/Z/ddlm0Z0e+dZ1e+dZ2e+dZ3Gdde)Z4edZ5dZ6d4de7de7de7de7fdZ8 d5ddde9de7fd Z:Gd!d"Z; d6d#dd$d%d&e7d'dd(d)ddf d*Zd9d-Z?Gd.d/Z@ddde9dd0fd1ZA d5ddde9dd2fd3ZBy):N)partial) TYPE_CHECKING) _get_headersget_host)continue_trace)OP)DEFAULT_HTTP_METHODS_TO_CAPTURE_filter_headers nullcontext)should_send_default_piiuse_isolation_scope) track_session) StreamedSpan SegmentSource)SpanTransactionSource)has_span_streaming_enabled) ContextVarcapture_internal_exceptionsevent_from_exceptionreraise) AnyCallableContextManagerDictIteratorOptionalProtocolTupleTypeVarUnion)EventEventProcessor)ExcInfoWsgiResponseIterWsgiResponseHeaders WsgiExcInfoc (eZdZ d deddddddfd Zy) StartResponseNstatusresponse_headersr&exc_infoOptional[WsgiExcInfo]returnr%cyN)selfr*r+r,s F/root/env/lib/python3.12/site-packages/sentry_sdk/integrations/wsgi.py__call__zStartResponse.__call__0s r0)__name__ __module__ __qualname__strr4r1r5r3r)r)/s2 15   4 .     r5r)sentry_wsgi_middleware_appliedzgeneric WSGI requestscharseterrorsr.cD|jdj||S)Nlatin1)encodedecode)r;r<r=s r3wsgi_decoding_dancerB=s 88H  $ $Wf 55r5environDict[str, str]use_x_forwarded_forc6|jddjd}|jddjd}|d|}|jd}|r|jd|}|dt||dt |jdS)zPReturn the absolute URL without query string for the given WSGI environment. SCRIPT_NAME/ PATH_INFOwsgi.url_schemeHTTP_X_FORWARDED_PROTOz://)getrstriplstriprrB)rCrE script_name path_infopathschemes r3get_request_urlrTAs ++mR077 -.D!((- r5c HeZdZdZddefdddededd d d f d Z dd Zy )SentryWsgiMiddlewareapprE span_originhttp_methods_to_captureFmanualrXz3Callable[[Dict[str, str], Callable[..., Any]], Any]rErYrZzTuple[str, ...]r.Nc<||_||_||_||_yr0rW)r2rXrErYrZs r3__init__zSentryWsgiMiddleware.__init__]s##6 &'>$r5c ` tjdr|j||Stj}t |j }tjd tj5}t|d5t5|jd|_ |jt||jddd|jddj!}d}||j"vr|rtj$j't)t+||j-d|itj$j/t0t2j4|j6t8j:d  }nSt'|t8j:t0t<j4|j6 }tj>|d|i }|xs tA}|5} tC| tDrRt5tG||jjID]\} } | jK| |  ddd |j|tMtN|| } tC| tDr| jVt0k7xrl| jYjd t2jZj\t2j4j\t2j^j\fv} | sHt5t0| _+| jKd t2j4j\ddddddddddddtjd|jdrta dd| Stc S#1swYxYw#1swYmxYw#tP$rtStUYjwxYw#1swYxYw#tC| tDr| jVt0k7xrl| jYjd t2jZj\t2j4j\t2j^j\fv} | sUt5t0| _+| jKd t2j4j\dddw#1swYwxYwwwxYw#1swYxYw#1swYxYw#1swYxYw#tjdwxYw)NFTrequest) session_modewsgiREQUEST_METHODrH wsgi_environ)sentry.span.sourcez sentry.originz sentry.op)name attributes)opresourceorigin)custom_sampling_contextrdzwsgi.file_wrapperfileno)2_wsgi_middleware_appliedrMrX sentry_sdk get_clientroptionssetisolation_scoperrclear_breadcrumbs_nameadd_event_processor_make_wsgi_event_processorrEupperrZtracesrdictrset_custom_sampling_context start_span_DEFAULT_TRANSACTION_NAMErROUTErYr HTTP_SERVERrstart_transactionr isinstancer_get_request_attributesitems set_attributer_sentry_start_response BaseExceptionr_capture_exceptionreget_attributes COMPONENTvalueCUSTOMgetattr_ScopedResponse)r2rCstart_responseclientspan_streamingscopemethodspan_ctx transactionspanattrrresponse already_sets r3r4zSentryWsgiMiddleware.__call__is| $ ' ' .88G^4 4&&(3FNNC $$T*P 0++-M *"5yAL*46//1&, 116 ')A)A%[[)92>DDFF\`H!=!==)&--<< $\'%: ;"==~w>WX'1'8'8'C'C%>:G:M:M595E5E13,"(D(H+9 '#%>>%>'8'>'>'+'7'7 +K(2'C'C +9G8Q(H (8;=H! *T%dL9!D3J$+T-E-E4""'%'!DKD%%)$6$6tU$C!DD *'+xx ' '(>PT U(H *$ =$(II1J$J%&(,(;(;(=(A(ABV(W(5(?(?(E(E(5(;(;(A(A(5(<(<(B(B(&)&!,(3)D)F%*4M (,(:(:,@,9,?,?,E,E)*%*7 *YL*M *^ % ( ( /( KK+ ,(D1=Ouh//MZDD -;#%7%9:;%*%* *$ =$(II1J$J%&(,(;(;(=(A(ABV(W(5(?(?(E(E(5(;(;(A(A(5(<(<(B(B(&)&!,(3)D)F%*4M (,(:(:,@,9,?,?,E,E)*%*%*%*(3 >! * *YL*L*M *M *^ % ( ( /s'T;T  S<=N;D1S<S/?O S/&!OBS/$6O5 S/"S<*T 2T;O S<O S/O2 .P1O2 2P5O> :S/BS, 6S  S, S'# S, ,S//S9 4S<<T T  TTT-)rCrDrzCallable[..., Any]r.r) r6r7r8 __slots__r boolr9r]r4r1r5r3rVrVUsjI%*#5T ? B ?" ? ? "3 ?  ?s0's09Ms0 s0r5rVold_start_responserz#Optional[Union[Span, StreamedSpan]]r*r+r,r-c.t5t|jddd}|Bt|tr!|dk\rdnd|_|j d|n|j|ddd| |||S||||S#1swYxYw)N rierrorokzhttp.response.status_code)rintsplitrrr*rset_http_status)rrr*r+r, status_ints r3rrs % &1c1-a01  $ -)3s):g ""#> K$$Z01"&*:;;!&*:HEE11s A#B  Bc#^Kddg}tr|dgz }|D]}||vs|||fyw)z Returns our explicitly included environment variables we want to capture (server name, port and remote addr if pii is enabled). SERVER_NAME SERVER_PORT REMOTE_ADDRN)r )rCkeyskeys r3 _get_environrsK = )D  $ '>ws|# #$s- -c |djddjS#ttf$rYnwxYw |dS#t$rYnwxYw|j dS)z Infer the user IP address from various headers. This cannot be used in security sensitive situations since the value may be forged from a client, but it's good enough for the event payload. HTTP_X_FORWARDED_FOR,rHTTP_X_REAL_IPr)rstripKeyError IndexErrorrM)rCs r3 get_client_iprsw  -.44S9!<BBDD j !    '((     ;;} %%s$'99A A Ac tj}|d}t|txr|jdv}|sGt |t jjddd\}}t j|||S)z Captures the current exception and sends it to Sentry. Returns the ExcInfo tuple to it can be reraised afterwards. r)rNraF)typehandled)client_options mechanism)hint) sysr,r SystemExitcoderrmrnro capture_event)r,eshould_skip_captureeventrs r3rrsz ||~H A%Q 3K)8K * %002::%%8 t   T2 Or5c8eZdZdZdZ ddZddZd dZy) raY Users a separate scope for each response chunk. This will make WSGI apps more tolerant against: - WSGI servers streaming responses from a different thread/from different threads than the one that called start_response - close() not being called - WSGI servers streaming responses interleaved from the same thread ) _response_scopeNc ||_||_yr0)rr)r2rrs r3r]z_ScopedResponse.__init__=s !r5c#Kt|j} t|j5 t |}ddd/#t $r Ydddyt $rttY:wxYw#1swY?xYwwr0) iterrr rnext StopIterationrrr)r2iteratorchunks r3__iter__z_ScopedResponse.__iter__Cs'$T[[1 33 NE 3K%  3 3 %3/123  3 3sJ,BA9 A B A6A9 BA63A95A66A99B>Bct|j5 |jjdddy#t$rYt $rt tY.wxYw#1swYyxYwr0)r rrcloseAttributeErrorrrr)r2s r3rz_ScopedResponse.closeQse  - / /$$& / /"   /+-. /  / /s2A$; A!A$A!A$ A!!A$$A-)rzsentry_sdk.scope.ScoperIterator[bytes]r.N)r.r)r.N)r6r7r8__doc__rr]rrr1r5r3rr0s5(I"-"9J" " /r5rr#ct|t|||jd|jdtt |t tt |dfd }|S)N QUERY_STRINGrbct5|jdi}tr&|jdi}r|jd |d<|d<|d<|d<|d<ddd|S#1swY|SxYw) Nr_user ip_addressurl query_stringrenvheaders)r setdefaultr ) rr request_info user_info client_iprrrr request_urls r3event_processorz3_make_wsgi_event_processor..event_processorqs ( * . ++Ir:L&(!,,VR8 ((yA"-L +7L (%+L ""%L &-L # .  . s AA22A<)rr"rDict[str, Any]r.r")rrTrMrxrr r) rCrErrrrrrrs @@@@@@r3ruru[sng&I!'+>?K;;~.L [[) *F |G$ %Cd<#89:G$ r5rcBi}|jd}|r|j|d<ttt |d}|j D]\}}||d|j <|jd}|r||d<t|||d<|jd }|r||d <|jd } | r| |d <|jd } | r t| |d<trt|} | r | |d<| |d<|S#t$rY.wxYw)zS Return span attributes related to the HTTP request from the WSGI environ. rbzhttp.request.methodF)use_annotated_valuezhttp.request.header.rz http.queryzurl.fullrKznetwork.protocol.namerzserver.addressrz server.portzclient.addresszuser.ip_address) rMrvr rxrrlowerrTr ValueErrorr r) rCrErfrrheaderrr url_scheme server_name server_portrs r3rrsH$&J [[) *F ,2LLN ()d<#89uUG D >C )&,,.)9:;D;;~.L#/ < ,W6IJJz./J.8 *+++m,K'2 #$++m,K (+K(8J} % !'* +4J' (,5J( )    s!D DD)zutf-8replace)Fr0)rCrDr.zIterator[Tuple[str, str]])rCrDr.z Optional[Any])r.r$)Cr functoolsrtypingrrmsentry_sdk._werkzeugrrsentry_sdk.apirsentry_sdk.constsr$sentry_sdk.integrations._wsgi_commonr r r sentry_sdk.scoper r sentry_sdk.sessionsrsentry_sdk.tracesrrsentry_sdk.tracingrrsentry_sdk.tracing_utilsrsentry_sdk.utilsrrrrrrrrrrrrr r!sentry_sdk._typesr"r#r$r%r&r'r)rlr{r9rBrrTrVrrrrrrurr1r5r3rs  7)  J-96?   8(12!"78-(K&&FG263666TW6