tni) ddlZddlmZddlmZddlZddlmZmZddl m Z ddl m Z ddl mZmZmZddlmZmZdd lmZdd lmZmZdd lmZmZmZmZerQdd lmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%dd l&m'Z'm(Z(ddlm)Z)e%dZ*e%dZ+e%dZ,Gdde#Z-edZ.d5de/de/de/de/fdZ0 d6ddde1de/fd Z2Gd!d"Z3 d7d#dd$d%d&e/d'dd(d)ddf d*Z4d8d,Z5d9d.Z6d:d0Z7Gd1d2Z8ddde1dd3fd4Z9dS);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) TransactionTransactionSource) ContextVarcapture_internal_exceptionsevent_from_exceptionreraise)AnyCallableDictIteratorOptionalProtocolTupleTypeVar)EventEventProcessor)ExcInfoWsgiResponseIterWsgiResponseHeaders WsgiExcInfoc *eZdZ d deddddddfd ZdS) StartResponseNstatusresponse_headersr!exc_infoOptional[WsgiExcInfo]returnr cdSN)selfr%r&r's Y/var/www/html/gpu-tools/venv/lib/python3.11/site-packages/sentry_sdk/integrations/wsgi.py__call__zStartResponse.__call__#s Dr+)__name__ __module__ __qualname__strr/r,r0r.r$r$"sX 15    4 .          r0r$sentry_wsgi_middleware_appliedutf-8replacescharseterrorsr)cT|d||S)Nlatin1)encodedecode)r8r9r:s r.wsgi_decoding_dancer?/s$ 88H   $ $Wf 5 55r0FenvironDict[str, str]use_x_forwarded_forcJ|ddd}|ddd}|d|}|ddt||dt |dS)zPReturn the absolute URL without query string for the given WSGI environment. SCRIPT_NAME/ PATH_INFOzwsgi.url_schemez://)getrstriplstriprr?)r@rB script_name path_infopaths r.get_request_urlrN3s ++mR0077<||_||_||_||_dSr+rQ)r-rRrBrSrTs r.__init__zSentryWsgiMiddleware.__init__Ks)#6 &'>$$$r0r@rAstart_responseCallable[..., Any]_ScopedResponsec tdr|||Std t j5}t |d5t5|d|_ | t||j dddn #1swxYwY|dd }d}||jvr-t|t jdt$j|j }|t j|d |i n t-}|5 ||t/t0||}n%#t2$rt5t7YnwxYwdddn #1swxYwYdddn #1swxYwYdddn #1swxYwYtdn#tdwxYwt9||S) NFTrequest) session_modewsgiREQUEST_METHODrEzgeneric WSGI request)opnamesourceorigin wsgi_environ)custom_sampling_context)_wsgi_middleware_appliedrHrRset sentry_sdkisolation_scoperrclear_breadcrumbs_nameadd_event_processor_make_wsgi_event_processorrBupperrTrr HTTP_SERVERrROUTErSstart_transactionr r_sentry_start_response BaseExceptionr_capture_exceptionrZ)r-r@rXscopemethod transactiontransaction_contextresponses r.r/zSentryWsgiMiddleware.__call__Ws\ $ ' ' . . 588G^44 4 $$T**** 0+--' ;"5yAAA&;&;466//111&, 116 ')A%[[)92>>DDFFF"&K!===&4#!~!7#4#:#'#3 ''' '2 #4'5CW4M )]] (- ; ;;'+xx ' '$:NK!"!"((HH -;;;#%7%9%9::::; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ;;&;&;&;&;&;&;&;&;&;&;&;&;&;&;&;' ;' ;' ;' ;' ;' ;' ;' ;' ;' ;' ;' ;' ;' ;' ;R % ( ( / / / / $ ( ( / / / /uh///s HG11GAC GC GC B G%G'*FGF4 1G3F4 4G7 GG G G G G1G G1!G "G1% H1G55H8G59HH3)r@rArXrYr)rZ) r1r2r3 __slots__r boolr4rWr/r,r0r.rPrPCsI%*#5T ? ? B ?" ? ? "3 ?  ? ? ? ?30'309M30 303030303030r0rPold_start_responserwzOptional[Transaction]r%r&r'r(ct5t|ddd}|||dddn #1swxYwY| |||S||||S)N r)rintsplitset_http_status)r|rwr%r&r' status_ints r.rrrrs % & &44c1--a011  "  ' ' 3 3 3444444444444444 "!&*:;;;!!&*:HEEEsAAA #A Iterator[Tuple[str, str]]c#dKddg}tr|dgz }|D]}||vr |||fVdS)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 )r@keyskeys r. _get_environrsf = )D    $$ '>>ws|# # # #$$r0 Optional[Any]c |dddS#ttf$rYnwxYw |dS#t$rYnwxYw|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 IndexErrorrH)r@s r. get_client_iprs  -.44S99!<BBDDD j !      '((       ;;} % %%s!25A A  A A"!A"rctj}|d}t|to|jdv}|sDt |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)rNr^F)typehandled)client_options mechanism)hint) sysr' isinstance SystemExitcoderrh get_clientoptions capture_event)r'eshould_skip_captureeventrs r.rtrts |~~H A%Q 33K)8K 3* %022:%%88   t  T2222 Or0c:eZdZdZdZ d d Zd d Zdd ZdS)rZaY 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_scoperusentry_sdk.scope.ScoperyIterator[bytes]r)Nc"||_||_dSr+)rr)r-rurys r.rWz_ScopedResponse.__init__s !r0c#,Kt|j} t|j5 t |}n<#t $rYddddSt $rttYnwxYwdddn #1swxYwY|V~r+) iterrr rnext StopIterationrsrrt)r-iteratorchunks r.__iter__z_ScopedResponse.__iter__s'' $T[11 3 33 NNEE$  3 3 3 3 3 3 3 3 %333/1122223  3 3 3 3 3 3 3 3 3 3 3 3 3 3 3KKK s=B>B A7BA74B6A77BB  B ct|j5 |jn0#t$rYn$t $rt tYnwxYwddddS#1swxYwYdSr+)r rrcloseAttributeErrorrsrrt)r-s r.rz_ScopedResponse.closes  - - / / /$$&&&&!     / / /+--.... /  / / / / / / / / / / / / / / / / / /s;A.1A. AA.AA.AA..A25A2)rurryrr)N)r)r)r)N)r1r2r3__doc__rzrWrrr,r0r.rZrZsy(I"-"9J" """"    //////r0rZrcDt|t|||d|dtt |t tt |d fd }|S) N QUERY_STRINGr_rrrDict[str, Any]r)c*t5|di}tr.|di}r|d |d<|d<|d<|d<|d<dddn #1swxYwY|S) Nr\user ip_addressurl query_stringrvenvheaders)r setdefaultr ) rr request_info user_info client_iprrrvr request_urls r.event_processorz3_make_wsgi_event_processor..event_processors ( * * . . ++Ir::L&(( B!,,VR88 B((yAAA"-L +7L (%+L ""%L &-L # . . . . . . . . . . . . . . . sA,BB B )rrrrr)r)rrNrHdictrr r) r@rBrrrrrvrrs @@@@@@r.rmrmsg&&I!'+>??K;;~..L [[) * *F |G$$ % %Cd<#8#899::G$ r0)r6r7)Fr+)r@rAr)r)r@rAr)r)r)r):r functoolsrtypingrrhsentry_sdk._werkzeugrrsentry_sdk.apirsentry_sdk.constsr$sentry_sdk.integrations._wsgi_commonr r r sentry_sdk.scoper r sentry_sdk.sessionsrsentry_sdk.tracingrrsentry_sdk.utilsrrrrrrrrrrrrsentry_sdk._typesrrrr r!r"r$rfr4r?r{rNrPrrrrrtrZrmr,r0r.rs  77777777))))))  JIIIIIII------========XXXXXXXXXXXXXXXXXXXX77777777((((((w122!'"788'-((K&:&FGG663666TW6666