xjG xddlZddlmZddlmZddlZddlmZmZddl m Z ddl m Z m Z ddlmZddlmZmZdd lmZmZmZdd lmZdd lmZmZdd lmZmZdd lm Z ddl!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'erUddlm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1ddl2m3Z3m4Z4ddl!m5Z5e0dZ6e0dZ7e0dZ8Gdde.Z9e"dZ:dZ;d;deded0ZBd?d2ZCd@d4ZDGd5d6ZEd!d"d#e>dd7fd8ZF ddd9fd:ZGdS)AN)partial) TYPE_CHECKING) _get_headersget_host)continue_trace)OPSPANDATA)0_apply_data_collection_filtering_to_query_string)DEFAULT_HTTP_METHODS_TO_CAPTURE_filter_headers)Scopeshould_send_default_piiuse_isolation_scope) track_session)SegmentNameSource StreamedSpan)SpanTransactionSource)has_span_streaming_enabled) ContextVarcapture_internal_exceptionsevent_from_exceptionhas_data_collection_enabled nullcontextreraise) AnyCallableContextManagerDictIteratorOptionalProtocolTupleTypeVarUnion)EventEventProcessor)ExcInfoWsgiResponseIterWsgiResponseHeaders WsgiExcInfoc *eZdZ d deddddddfd ZdS) StartResponseNstatusresponse_headersr*exc_infoOptional[WsgiExcInfo]returnr)cdSN)selfr.r/r0s MC:\Projects\Historical\venv\Lib\site-packages\sentry_sdk/integrations/wsgi.py__call__zStartResponse.__call__2s Dr4)__name__ __module__ __qualname__strr8r5r9r7r-r-1sX 15    4 .          r9r-sentry_wsgi_middleware_appliedzgeneric WSGI requestutf-8replacescharseterrorsr2cT|d||S)Nlatin1)encodedecode)rArBrCs r7wsgi_decoding_dancerH?s$ 88H   $ $Wf 5 55r9FenvironDict[str, str]use_x_forwarded_forc~|ddd}|ddd}|d|}|d}|r|d|}|dt||dt |dS)zPReturn the absolute URL without query string for the given WSGI environment. SCRIPT_NAME/ PATH_INFOwsgi.url_schemeHTTP_X_FORWARDED_PROTOz://)getrstriplstriprrH)rIrK script_name path_infopathschemes r7get_request_urlrZCs ++mR0077<> -....D!!((--- r9c JeZdZdZddefdddededd d d f d Z ddZd S)SentryWsgiMiddlewareapprK span_originhttp_methods_to_captureFmanualr^z3Callable[[Dict[str, str], Callable[..., Any]], Any]rKr_r`zTuple[str, ...]r2Nc>||_||_||_||_dSr4r])r6r^rKr_r`s r7__init__zSentryWsgiMiddleware.__init___s)#6 &'>$$$r9rIrJstart_responseCallable[..., Any]rc tdr|||Stj}t |j}td tj5}t|d5t5| d|_ | t||jdddn #1swxYwY|dd}d}||jvr|rEtjt)t+|t-jd|it1|jrE|jd d r1t3|}|r |t6j|n?t;r1t3|}|r |t6j|tjt>t@j!|j"tFj$d d }||%_&nJt'|tFj$t>tNj!|j" } tj(| d|i}|p tS}|5} tU| tVrjt5tY||j-D]\} } | | |  dddn #1swxYwY ||t]t^|| } n%#t`$rtcteYnwxYwdddn #1swxYwYdddn #1swxYwYdddn #1swxYwYtdn#tdwxYw|drtg| dd| Sti|| S)NFTrequest) session_modewsgiREQUEST_METHODrN wsgi_environdata_collection user_info)zsentry.segment.name.sourcez sentry.originz sentry.op)name attributes parent_span)oprnsourceorigin)custom_sampling_contextzwsgi.file_wrapperfileno)5_wsgi_middleware_appliedrSr^ sentry_sdk get_clientroptionssetisolation_scoperrclear_breadcrumbs_nameadd_event_processor_make_wsgi_event_processorrKupperr`tracesrdictrr set_custom_sampling_contextr get_client_ip set_attributer USER_IP_ADDRESSr start_span_DEFAULT_TRANSACTION_NAMErROUTEr_r HTTP_SERVERget_current_scope_server_segment_spanrstart_transactionr isinstancer_get_request_attributesitemsr_sentry_start_response BaseExceptionr_capture_exceptiongetattr_ScopedResponse)r6rIrdclientspan_streamingscopemethodspan_ctx client_ip transactionspanattrvalueresponses r7r8zSentryWsgiMiddleware.__call__ks $ ' ' . . 588G^44 4&((3FNCC $$T***N 0+--K ;"5yAAAJ;J;466//111&, 116 ')A%[[)92>>DDFFF\`H!===)*&-<< $\'%:%: ; ;"=~w>WXXX:6>JJ &#)>2C#D[#Q!*0=g0F0FI'0%*(-(;(;,4,Di)*)*)*"9!:!:&,9',B,B #,!&$)$7$7(0(@)%&%&%&(2'8'C'C%>BSBY595E13,"," -1(D((HNVE3355JJ*8 '#%>%>'8'>'+'7 +++K(2'C +9G8Q(((H (8;==H!;T%dL99D!!>DD3J$+T-E4"4""'%''!D!DKD%%)$6$6tU$C$C$C$C!DDDDDDDDDDDDDDDD ;'+xx ' '(>PT U U((HH -;;;#%7%9%9::::;;;;;;;;;;;;;;;;yJ;J;J;J;J;J;J;J;J;J;J;J;J;J;J;K ;K ;K ;K ;K ;K ;K ;K ;K ;K ;K ;K ;K ;K ;K ;Z % ( ( / / / / $ ( ( / / / /( KK+ , , (D11=Ouh///s3P O%O'AC7+ O7C; ;O>C; ?GO$N7>AM  N7M N7M N7*NN7N( %N7'N( (N7+ O7N; ;O>N; ?O O%O O%O O% P %O))P ,O)-P P')rIrJrdrer2r) r:r;r< __slots__r boolr=rcr8r5r9r7r\r\WsI%*#5T ? ? B ?" ? ? "3 ?  ? ? ? ?q0'q09Mq0 q0q0q0q0q0q0r9r\old_start_responserz#Optional[Union[Span, StreamedSpan]]r.r/r0r1czt5t|ddd}|Pt|tr&|dkrdnd|_|d|n||dddn #1swxYwY| |||S||||S)N rierrorokzhttp.response.status_code)rintsplitrrr.rset_http_status)rrr.r/r0 status_ints r7rrs % & &11c1--a011  $ -- 1)3s):):gg ""#> KKKK$$Z000111111111111111"!&*:;;;!!&*:HEEEsA22 + ,[ 9 $ ]O #D " "  $$ '>>ws|# # # #$$r9 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 IndexErrorrS)rIs r7rr s  -.44S99!<BBDDD j !      '((       ;;} % %%s!25A A  A A"!A"r(ctj}|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)rNriF)typehandled)r mechanism)hint) sysr0r SystemExitcoderrwrxry capture_event)r0eshould_skip_captureeventrs r7rr s |~~H A%Q 33K)8K 3* %022:%%88   t  T2222 Or9c:eZdZdZdZ d d Zd d Zdd ZdS)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_scopersentry_sdk.scope.ScoperIterator[bytes]r2Nc"||_||_dSr4)rr)r6rrs r7rcz_ScopedResponse.__init__Bs !r9c#,Kt|j} t|j5 t |}n<#t $rYddddSt $rttYnwxYwdddn #1swxYwY|V~r4) iterrrrnext StopIterationrrr)r6iteratorchunks r7__iter__z_ScopedResponse.__iter__Hs'' $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#1swxYwYdSr4)rrrcloseAttributeErrorrrr)r6s r7rz_ScopedResponse.closeVs  - - / / /$$&&&&!     / / /+--.... /  / / / / / / / / / / / / / / / / / /s;A.1A. AA.AA.AA..A25A2)rrrrr2N)r2r)r2N)r:r;r<__doc__rrcrrr5r9r7rr5sy(I"-"9J" """"    //////r9rr'cx t|t|| |d|dtt |t tt |tjj d  fd }|S) N QUERY_STRINGrjrr&rDict[str, Any]r2c.t5|di}tr=ddr.|di}r|dn.event_processorws ( * * < < ++Ir::L*>:: B!"34[AF % 0 0 < :: <C"R%1"01B"CDV"W###K#C7B ^40< ^,; < < < < < < < < < < < < < < <> sC.D  DD)rr&rrr2r&) rrZrSrrr rrwrxry) rIrKrrrrrrrrs @@@@@@@r7rr`sg&&I!'+>??K;;~..L [[) * *F |G$$ % %Cd<#8#899::G*,,4N            D r9rci}|d}|r||d<ttt |d}|D]\}}||d|< |d}|r||d<|d}|r||d <|d } | r$ t| |d <n#t$rYnwxYwtj j } t| r|d } d } | r$t| | dd} | r| |d<|dd} | r| |d<t|||d<| |dxxd| z cc<| ddrt|}|r||d<n|t!rnt|}|r||d<|d } | r| |d<|dd} | r| |d<t||}| r|d| zz }||d<|S)zS Return span attributes related to the HTTP request from the WSGI environ. rjzhttp.request.methodF)use_annotated_valuezhttp.request.header.rQznetwork.protocol.namerzserver.addressrz server.portrNrlrrz http.queryrPrNzurl.pathzurl.full?rmzclient.address)rSrr rrrlowerr ValueErrorrwrxryrr rZrr)rIrKrorrheaderr url_scheme server_name server_portrrrrXrurl_fulls r7rrs$&J [[) * *F ;,2LLNN ()d<#8#899uUUUG DD >C :&,,..::;;.//J9.8 *+++m,,K3'2 #$++m,,K (+K(8(8J} % %    D  *,,4N">22)*{{>22   7J)():;22  4'3J| ${{;++  *%)Jz ""7,?@@  + l* *H!) : s C33 D?D)r?r@)Fr4)rIrJr2r)rIrJr2r)r2r()Hr functoolsrtypingrrwsentry_sdk._werkzeugrrsentry_sdk.apirsentry_sdk.constsrr sentry_sdk.data_collectionr $sentry_sdk.integrations._wsgi_commonr r sentry_sdk.scoper rrsentry_sdk.sessionsrsentry_sdk.tracesrrsentry_sdk.tracingrrsentry_sdk.tracing_utilsrsentry_sdk.utilsrrrrrrrrrrr r!r"r#r$r%sentry_sdk._typesr&r'r(r)r*r+r-rvrr=rHrrZr\rrrrrrrr5r9r7rs~  77777777))))))********WWWWWWQPPPPPPPPP------========66666666??????                        87777777((((((w122!'"788'-((K&:&FGG2663666TW6666