xj-] <UddlZddlZddlZddlZddlmZmZddlmZddl Z ddl m Z m Z m Z ddlmZddlmZddlmZddlmZmZdd lmZmZmZmZmZmZdd lmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'erdd lm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.dd l/m0Z0m1Z1ej2d ej3ddzej4dZ5de6d< ddl7m8Z8m9Z9n#e:$rdZ8dZ9YnwxYwGddeZ;d/dZ< d0dZ= d1dZ> d2dZ?d3d Z@d3d!ZA d4d"d#d$d%d&eBd'eCd(d)dd*f d+ZDd3d,ZEd5d.ZFdS)6N)HTTPConnection HTTPResponse) TYPE_CHECKING)_SENTRY_HEADER_NAMESOPSPANDATA) Integration)add_global_event_processor) StreamedSpan)SENTRY_TRACE_HEADER_NAMESpan)EnvironHeadersadd_http_breadcrumbadd_http_request_sourceget_url_attributeshas_span_streaming_enabledshould_propagate_trace) SENSITIVE_DATA_SUBSTITUTE7_get_aws_sigv4_signed_headers_from_authorization_header3_get_aws_sigv4_signed_headers_from_url_query_stringcapture_internal_exceptionsensure_integration_enabled is_sentry_urllogger parse_url safe_repr)AnyCallableDictListOptionalSetUnion)EventHintz%s.%s.%s)nameversionbuildzdict[str, object]_RUNTIME_CONTEXT)AWSHTTPConnectionAWSHTTPSConnectionc*eZdZdZeddZdS)StdlibIntegrationstdlibreturnNclttt dd}dS) Neventr$hintr%r0Optional[Event]ctj}|t9|di}t |t rd|vr t|d<|S)Ncontextsruntime) sentry_sdk get_clientget_integrationr. setdefault isinstancedictr*)r2r3clientr6s OC:\Projects\Historical\venv\Lib\site-packages\sentry_sdk/integrations/stdlib.pyadd_python_runtime_contextz@StdlibIntegration.setup_once..add_python_runtime_context<sg *,,F%%&788D ++J;;h--;)82K2K*:HY'L)r2r$r3r%r0r4)_install_httplib_install_subprocessr )r@s r? setup_oncezStdlibIntegration.setup_once7s[ #  "(      $ #   rAr0N)__name__ __module__ __qualname__ identifier staticmethodrDrAr?r.r.4s7J\rAr.spanUnion[Span, StreamedSpan]r0cZt|trKt5t|dddn #1swxYwY|dS|t5t|ddddS#1swxYwYdSN)r<r rrendfinishrLs r?_complete_spanrSIs$ %%* ( * * * * #D ) ) ) * * * * * * * * * * * * * * *   ( * * * * #D ) ) ) * * * * * * * * * * * * * * * * * *s#AAAB  B$'B$original_putheaderCallable[..., Any]cdfd }|S) zLRecord existing `sentry-trace` and SigV4-signed propagation headers to skip.selfrheaderrvaluesr0c||g|R}t|dd}||St|tr)|dd}n,t|t r|}n|S|t kr|||dkr|rt5|d}t|tr|d}t|}| tj |dddn #1swxYwY|S)N_sentrysdk_headers_to_skipasciiignore authorizationrzlatin-1) getattrr<bytesdecodelowerstrr addrrupdater intersection) rWrXrYrvheaders_to_skipnormalized_headerr^signed_headersrTs r? putheaderz)_get_wrapped_putheader..putheaderYs  f 6v 6 6 607 .1 1   "I fe $ $  & gx @ @ F F H H    $ $  &   I  8 8 8    1 2 2 2  / /F /,..   &q mU33D$1$8$8$C$CML%  &&(5nEE                sA)D66D:=D:)rWrrXrrYrr0rrK)rTrks` r?_get_wrapped_putheaderrlTs* $$$$$$L rAoriginal_endheaderscdfd }|S) a~ Add unsigned propagation headers immediately before sending. `sentry-trace`: add if missing; leave an existing or signed value as-is. `baggage`: add if missing; append if unsigned since multiple fields are allowed and combined (https://www.w3.org/TR/baggage/#baggage-http-header-format); leave a signed value as-is since it is part of the SigV4 signature. rWrargsrkwargsr0c rt|dd}t|dd} |t5t|dd}|t|}|t j|t j|D]\\}}| |vrtj d |||| ||]dddn #1swxYwY |g|Ri|d|_S#d|_wxYw)N_sentrysdk_real_url_sentrysdk_spanr[rRJ[Tracing] Adding `{key}` header {value} to outgoing request to {real_url}.keyvaluereal_url)r_rrrerrfr8get_current_scopeiter_trace_propagation_headersrbrdebugformatrkrr) rWrorprxrLrhquery_signed_headers header_name header_valuerms r? endheadersz+_get_wrapped_endheaders..endheaderss4!6==t.55$ ,#022FF&-d4PRV&W&WO&2P (- (..0=>RSS(9;;ZZ!%[FF'( +0022oEE ("L l s s(3*6-5!t!"!"!NN; EEEE?FFFFFFFFFFFFFFF@'&t=d===f=='+D $ $tD $ + + + +s/D-CD D-DD-DD-- D6rWrrorrprr0rrK)rmrs` r?_get_wrapped_endheadersrs*(,(,(,(,(,(,T rAoriginal_putrequestc @dddtdtddddddf fd }|S) z3Start `headers_to_skip` before headers are written.rWrmethodurlrorrpr0czt|_ |||g|Ri|}n#t$r d|_wxYw|SrO)setr[ BaseException)rWrrrorprgrs r? putrequestz+_get_wrapped_putrequest..putrequestsk+.%%' $$T63HHHHHHBB   /3D +     s%8)rc)rrs` r?_get_wrapped_putrequestrsY (+25>COT  rActittjt_ttjt_t tjt_tkttjt_ttjt_t tjt_dSdS)a. Patch AWS connection classes so trace propagation does not break SigV4. Botocore signs the request before headers reach HTTPConnection. Wait until `endheaders()` to add unsigned propagation headers, after `putheader()` has recorded existing `sentry-trace` and signed field names. N)r+rlrkrrrrr,rKrAr?_patch_aws_connectionrs$&<  '' ' #(?  (( ( $(?  (( ( $%'=  (( ( $)@  )) ) %)@  )) ) %%%&%rAc Ftjtjtjtjdddt dt ddddddf fd }dfd }dfd }dfd }t|t_|t_|t_|t_dS)NrWrrrrorrpr0c ^|j}t|dd}|r|}t|d|}n|j}|j}t j} | tt| |r|||g|Ri|S|} | | ds|dkrdpdd|||krd|zpd |} d} t5t| d } dddn #1swxYwYt| j } d} i}| rt| | }||tj<||tjtj|d | r| jnt,d ddt.jtj|i} |D]\}}| ||| j}nt jt.j|d | r| jnt,d} | tj|||tj<| | tj| j| d| j| tj| j |tj| jd| jtj| j i| j}|ro| r6|tj!|j|tj"|j|tj!|jtj"|ji|||g|Ri|}tG| | r~tI|dsnt j%&| D]E\}}tOj(d)||| |*||FntG| | r| |_+| |_,||_-|S)N _tunnel_host _tunnel_port)zhttp://zhttps://ihttpshttpz://z:%sF)sanitize sentry.originzauto.http.stdlib.httplib sentry.opr' attributesopr'originrr[rRrtru). default_portr_hostportr8r9r:r.r startswithrrroptionsrrHTTP_REQUEST_METHODretracesget_current_span start_spanrrr HTTP_CLIENTitems set_attributeset_data HTTP_METHOD HTTP_FRAGMENTfragment HTTP_QUERYqueryNETWORK_PEER_ADDRESSNETWORK_PEER_PORTrhasattrryrzrr{r|rkrrrs_sentrysdk_breadcrumb)rWrrrorpr tunnel_hostrrr>rx parsed_urlspan_streamingrL breadcrumburl_attributesrvrw set_on_spanrgreal_putrequests r?rz$_install_httplib..putrequests( dND99  D4>>DD9D9D&((  ! !"3 4 4 < DA A <#?4FtFFFvFF F  8#6#67N#O#O #/9699 $5;; H ( * * = ="8e<<66ZV:>>=VVX1 D MM(. 7 7 7/5Jx+ ,% h4j6IJJJ eZ^444 h1:3CDDD!! . 0Cz~ +Z-=-K   C H949EEE H6 BBB   149.    _T63 @ @ @ @ @ @ "&( 3 3 0G .= =  0 -//NNO + + `gguxh sE**** +$FH 5 5 0'/D $#%/" sC..C25C2c$t|dd}t|dd}  |g|Ri|}nG#t$r:}|rt||r!dt|vrt d|d}~wwxYwt |j}|r||tj<||rt |||St|tr0|dkrdnd|_| tj|nQt|tr<| ||d|j|r |j|d<|jp|jduo |jdk}|r||_nt||rt |||S) Nrsrz.getresponsexst.55T#:DAA  !!$888888BB    %t$$$ 6R2ww$D*555  ")nn  @4?Jx0 1 < =#K<<<I dL ) ) 1%0C%7%7''TDK   x8+ F F F F d # # 1   - - - MM(BI . . . 1')y 8$ :J")4"7"IBIM  !!%B   4  9 Z 8 8 8 s 2 A65A11A6rc  |g|Ri|t|dd}|r%|j|jrd|_t |SSS#t|dd}|r%|j|jrd|_t |wwwxYwNrs)r_fpclosedrsrS)rWrorprL real_reads r?readz_install_httplib..reads %9T3D333F334!2D99D %DK'+$t$$$$ % 4!2D99D %DK'+$t$$$$ %s A;Bc |t|dd}|d|_t|dSdS#t|dd}|d|_t|wwxYwr)r_rsrS)rWrL real_closes r?closez_install_httplib..closes % Jt   4!2D99D'+$t$$$$$ 4!2D99D'+$t$$$$ s ;,A'r)rWrrorrprr0r)rWrr0N)rrrrrrrcr)rrrrrrrrs @@@@r?rBrBs$/O%1!I#J~~(+~25~>C~OT~ ~~~~~~@333333j % % % % % % % % % % % % *N!,NLLrAroz List[Any]rpzDict[Any, Any]r'positionsetdefault_callbackzOptional[Callable[[Any], Any]]rc||vr||}| ||}||||<nD|t|kr||}| ||}||||<n|o |d}||||<|S)a? given (*args, **kwargs) of a function call, retrieve (and optionally set a default for) an argument by either name or position. This is useful for wrapping functions with complex type signatures and extracting a few arguments without needing to redefine that function's entire type signature. N)len)rorpr'rrrgs r?_init_argumentrs  v~~ D\  *$$R((B >F4L CII   (^  *$$R((B >DN >%8%8%>%> >F4L IrActjjtt d fd }|tj_tjjtt d fd }|tj_tjjtt d fd }|tj_dS) NrWsubprocess.Popen[Any]arkwr0c Lt|}t||ddpg}t||dd}d}t|ttfrat |dkrNt 5dtt|}dddn #1swxYwY|t|}d}tj dd||rd|ini ttj j}|rYtj  |g|Ri|Stj|t$jd d  }n!tjt$j|d }|5tj|D]I\} } |t||ddd}| |d| ddz<J|r+t|t0r|d| |g|Ri|} t|t4r&|t8j|jn|d|j| cdddS#1swxYwYdS)Nrorcwd dr subprocesszsubprocess.cwd)typecategorymessagedata!auto.subprocess.stdlib.subprocessrrrrrRenv c<t||n tjSrO)r=osenviron)xs r?zH_install_subprocess..sentry_patched_popen_init..4s$AMqqrz"J"JrA SUBPROCESS_-_subprocess.pid) listrr<tuplerrjoinmaprcrr8add_breadcrumbrr9rrrrr SUBPROCESSryrzupperreplacer rr rr PROCESS_PIDpidset_tag) rWrrror descriptionrrrLkvrgold_popen_inits r?sentry_patched_popen_initz6_install_subprocess..sentry_patched_popen_initsn GGaVQ//52QE1-- dT5M * * 7s4yy3,.. 7 7!hhs3~~66  7 7 7 7 7 7 7 7 7 7 7 7 7 7 7  #D//K!!,/7"C((R     4J4I4K4K4STT   1133;%~d5Q555"555$// !#%H0DD(= :D   "466UUV E E1;(JJ CDEMAGGII$5$5c3$?$??@@ 5z$-- 5 .444/q///B//B$ -- 9""8#7BBBB -tx8881                  s%6)B++B/2B/ DJJ Jcnttjj}|rtj |g|Ri|Stjtjtjdd5}| tj |j |g|Ri|cdddS#1swxYwYdStjtjd5}| d|j |g|Ri|cdddS#1swxYwYdSNrrr)rrr)rr8r9rrrrrSUBPROCESS_WAITrrrrr)rWrrrrLold_popen_waits r?sentry_patched_popen_waitz6_install_subprocess..sentry_patched_popen_waitHs4J4I4K4K4STT  6 1133;%~d5Q555"555"--'!#!3%H. 6 ""8#7BBB%~d5Q555"55 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6&%: 6 -tx888%~d5Q555"55  6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6$ 1C  C C 6'D**D.1D.cnttjj}|rtj |g|Ri|Stjtjtjdd5}| tj |j |g|Ri|cdddS#1swxYwYdStjtjd5}| d|j |g|Ri|cdddS#1swxYwYdSr)rr8r9rrrrrSUBPROCESS_COMMUNICATErrrrr)rWrrrrLold_popen_communicates r? sentry_patched_popen_communicatez=_install_subprocess..sentry_patched_popen_communicatees4J4I4K4K4STT  = 1133;,,TBBN%N+0N8=N NNNNNCBN`!:J%*N 1>BB6%6+068=6 66666CB606J&,8 13HII=%=+0=8== =====JI=0$DJ   rArc8ttjdS)Nr)prefix)rrrrKrAr?"get_subprocess_traceparent_headersrs "*] ; ; ;;rA)rLrMr0N)rTrUr0rU)rmrUr0rU)rrUr0rUrErO)r0r)Grplatformrsys http.clientrrtypingrr8sentry_sdk.constsrrrsentry_sdk.integrationsr sentry_sdk.scoper sentry_sdk.tracesr sentry_sdk.tracingr r sentry_sdk.tracing_utilsrrrrrrsentry_sdk.utilsrrrrrrrrrrrrr r!r"r#sentry_sdk._typesr$r%python_implementation version_infor(r*__annotations__botocore.awsrequestr+r, ImportErrorr.rSrlrrrrBrcrrrCrrKrAr?r$s  44444444 @@@@@@@@@@//////777777******========                      .FFFFFFFFFFFFFFFFFF-------- +H * , ,S-bqb12 [))% IIIIIIIII  *****+,+++++\6-66666r-0    >WWWW~=A !! ! ! ! ! : !  !!!!HNDNDNDNDb<<<<<