S>{isaddlmZddlmZddlmZddlZddlZddlmZddl m Z ddl m Z m Z mZmZddlmZmZmZdd lmZdd lmZmZdd lmZerqdd lmZdd lmZddlmZddlmZddlm Z ddlm!Z!ddlm"Z"ddlm#Z#ddlm$Z$ddlm%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+ddl,m-Z-ddlm.Z.ddl/m0Z0e$de"defZ1e$dZ2gZ3dZ4dZ5dZ6Gd d!e7Z8y)")copy)deque)chainN) Attachmentwraps)Baggageextract_sentrytrace_datahas_tracing_enablednormalize_incoming_data)BAGGAGE_HEADER_NAMESENTRY_TRACE_HEADER_NAME Transaction) TYPE_CHECKING)loggercapture_internal_exceptions) FALSE_VALUES)Any)Dict)Iterator)Optional)Deque)List)Callable)Tuple)TypeVar) BreadcrumbEventEventProcessorErrorProcessorExcInfoHintType)Profile)Span)SessionF.)boundTc.tj|yN)global_event_processorsappend) processors N/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/sentry_sdk/scope.pyadd_global_event_processorr0:s""9-c0t||jS)N)fsetdoc)property__doc__)fns r/ _attr_setterr8?s  ,,r1c.tfd}|S)Ncl|jsy d|_|g|i|d|_S#d|_wxYw)NFT)_should_capture)selfargskwargsr7s r/wrapperz!_disable_capture..wrapperFsA##  (#(D d,T,V,#'D 4D s* 3r)r7r?s` r/_disable_capturer@Ds  2Y(( Nr1ceZdZdZdZdZdZdZdZdZ d+d Z d Z d Z d Z d ZdZdZedZdZedZedZej.dZd+dZedZdZedZej.dZedZej.dZdZdZdZdZ d Z!d!Z"d"Z# d,d#Z$d$Z% d+d%Z&e' d+d&Z(d'Z) d-d(Z*d)Z+d*Z,y).ScopezaThe scope holds extra information that should be sent with all events that belong to it. )_level_name _fingerprint _transaction_transaction_info_user_tags _contexts_extras _breadcrumbs_event_processors_error_processorsr;_span_session _attachments_force_auto_session_tracking_profile_propagation_contextcg|_g|_d|_d|_|j |j }|j |y)N) incoming_data)rMrNrDrTclear_load_trace_data_from_envgenerate_propagation_context)r<incoming_trace_informations r/__init__zScope.__init__wsK!#!# $(! %)%C%C%E" ))8R)Sr1cd}tjjdxsdj}|tv}|ri}tjjdr*tjjdxsd|t <tjjdr*tjjdxsd|t <|xsdS)z Load Sentry trace id and baggage from environment variables. Can be disabled by setting SENTRY_USE_ENVIRONMENT to "false". NSENTRY_USE_ENVIRONMENT SENTRY_TRACESENTRY_BAGGAGE)osenvirongetlowerrrr )r<rZsentry_use_environmentuse_environments r/rXzScope._load_trace_data_from_envs &*" JJNN3 4 : %' 1 D )+ &zz~~n-JJNN>28b++CDzz~~./JJNN#34:++>?*1T1r1ci}t|}|jt}|r&tj|j |d<|jt }|rt|}||j|d|vxrd|v}|r|j|j|r7|jds$tjjdd|d<|Sy)Ndynamic_sampling_contexttrace_idspan_id) r rcr r from_incoming_headerrhrr update_create_new_propagation_contextuuiduuid4hex)r<datacontextnormalized_databaggage_headersentry_trace_headersentrytrace_dataonly_baggage_no_sentry_traces r/_extract_propagation_contextz"Scope._extract_propagation_contexts1$7(,,-@A 292N2N3&&( . /.112JK 78KL +/0 '' 1 Oj6O % ( NN4??A B ;;y)%)ZZ\%5%5bc%: "Nr1ctjjtjjdddddS)Nrkrirjparent_span_idrh)rorprqr<s r/rnz%Scope._create_new_propagation_contexts9 ((zz|'',"(,   r1cn|j|_tjd|jy)zt Creates a new propagation context and sets it as `_propagation_context`. Overwriting existing one. z,[Tracing] Create new propagation context: %sN)rnrTrdebugr}s r/set_new_propagation_contextz!Scope.set_new_propagation_contexts- %)$H$H$J! :  % % r1Nc|r:|j|}|'||_tjd|j|j|j yy)z Makes sure `_propagation_context` is set. If there is `incoming_data` overwrite existing `_propagation_context`. if there is no `incoming_data` create new `_propagation_context`, but do NOT overwrite if already existing. Nz>[Tracing] Extracted propagation context from incoming data: %s)ryrTrrr)r<rVrss r/rYz"Scope.generate_propagation_contexts\ 77 FG",3) T--  $ $ ,  , , . -r1c|jy|j}||j|jd<|jdS)z Returns the Dynamic Sampling Context from the Propagation Context. If not existing, creates a new one. Nrh)rT get_baggagerh)r<baggages r/get_dynamic_sampling_contextz"Scope.get_dynamic_sampling_contexts\  $ $ ,""$  002  % %* (()CDDr1cb|jy|jdd|jd}|S)zn Returns the Sentry "sentry-trace" header (aka the traceparent) from the Propagation Context. Nri-rj)rT)r< traceparents r/get_traceparentzScope.get_traceparents@  $ $ ,  % %j 1  % %i 0 r1c|jy|jjd}|tj|St|S)Nrh)rTrcr from_options)r<rhs r/rzScope.get_baggagesP  $ $ ,#'#<#<#@#@ &$   $ +''- -34 4r1c|jy|jd|jd|jd|jd}|S)zR Returns the Sentry "trace" context from the Propagation Context. Nrirjr|r{)rTr)r< trace_contexts r/get_trace_contextzScope.get_trace_contexts[  $ $ ,11*=00;"778HI(,(I(I(K  r1c#K|jS|j}| t|f|j}|$t |j }t |fyyyw)zz Creates a generator which returns the `sentry-trace` and `baggage` headers from the Propagation Context. N)rTrrrr serializer )r<rdscrs r/ iter_headerszScope.iter_headers#sm  $ $ 0..0K&. ;;335C!#,002)722 1sA!A#cd|_d|_d|_i|_d|_i|_i|_i|_g|_|jd|_ d|_ d|_ d|_ d|_d|_y)zClears the entire scope.NT)rCrErFrGrHrIrJrKrQclear_breadcrumbsr;rOrPrRrSrTr}s r/rWz Scope.clear2s   !#     #  ,0) $(!r1c||_y)zDWhen set this overrides the level. Deprecated in favor of set_level.NrCr<values r/levelz Scope.levelKs  r1c||_y)zSets the level for the scope.Nrrs r/ set_levelzScope.set_levelQs  r1c||_y)z0When set this overrides the default fingerprint.N)rErs r/ fingerprintzScope.fingerprintVs "r1cv|jy|jjy|jjS)z8Return the transaction (root span) in the scope, if any.N)rOcontaining_transactionr}s r/ transactionzScope.transaction\s8 ::  :: , , 4zz000r1ctjd||_|jr3|jjr||jj_yyy)zrWhen set this forces a specific transaction name to be set. Deprecated: use set_transaction_name instead.z`Assigning to scope.transaction directly is deprecated: use scope.set_transaction_name() instead.N)rwarningrFrOrnamers r/rzScope.transactionnsI$  n " ::$**;;5:DJJ - - 2<:r1c||_|jrN|jjr8||jj_|r||jj_|r||j d<yy)z?Set the transaction name and optionally the transaction source.sourceN)rFrOrrrrG)r<rrs r/set_transaction_namezScope.set_transaction_names^! ::$**;;59DJJ - - 2;A 118 /5D " "8 , r1c&|j|y)zPWhen set a specific user is bound to the scope. Deprecated in favor of set_user.N)set_userrs r/userz Scope.users er1cd||_|j|jj|yy)zSets a user for the scope.N)r)rHrPrmrs r/rzScope.set_users/ == $ MM e , %r1c|jS)z,Get/set current tracing span or transaction.)rOr}s r/spanz Scope.spanszzr1ct||_t|tr!|}|jr|j|_yyyr+)rO isinstancerrrF)r<rrs r/rz Scope.spans=  dK (K$/$4$4!  )r1c|jSr+rSr}s r/profilez Scope.profiles}}r1c||_yr+r)r<rs r/rz Scope.profiles   r1c"||j|<y)z)Sets a tag for a key to a specific value.N)rIr<keyrs r/set_tagz Scope.set_tags  3r1c<|jj|dy)zRemoves a specific tag.N)rIpopr<rs r/ remove_tagzScope.remove_tags sD!r1c"||j|<y)z5Binds a context at a certain key to a specific value.N)rJrs r/ set_contextzScope.set_contexts$sr1c<|jj|dy)zRemoves a context.N)rJrrs r/remove_contextzScope.remove_contexts 3%r1c"||j|<y)z&Sets an extra key to a specific value.N)rKrs r/ set_extrazScope.set_extras" Sr1c<|jj|dy)zRemoves a specific extra key.N)rKrrs r/ remove_extrazScope.remove_extras d#r1c"t|_y)zClears breadcrumb buffer.N)rrLr}s r/rzScope.clear_breadcrumbss"Gr1c V|jjt|||||y)z)Adds an attachment to future events sent.)bytespathfilename content_typeadd_to_transactionsN)rQr-r)r<rrrrrs r/add_attachmentzScope.add_attachments/   !)$7   r1ct|jdkDr/tjd|j|jdd=|jj |y)z}Register a scope local event processor on the scope. :param func: This function behaves like `before_send.` zLToo many event processors on scope! Clearing list to free up some memory: %rN)lenrMrrr-)r<funcs r/add_event_processorzScope.add_event_processorsS t%% & + NN^&& &&q) %%d+r1cV| ||fd}|jj|y)aRegister a scope local error processor on the scope. :param func: A callback that works similar to an event processor but is invoked with the original exception info triple as second argument. :param cls: Optionally, only process exceptions of this type. Nc` t|d}|r ||S|S#t$rd}YwxYw)NF)r Exception)eventexc_infois_instcls_ real_funcs r/rz'Scope.add_error_processor..func'sE$(!d;G$UH55 !$#G$s  --)rNr-)r<rclsrrs @@r/add_error_processorzScope.add_error_processors/ ?DI  %%d+r1czd}|jddk(}|jdxsg}|jD]"}|r |js|j|$||d<|j|j|d<|s;|j dij dgj |j|jd |j|j|d <|jd|j|j|d<|jd |j|j|d <|jd |j|j|d <|jr+|j d ij|j|jr+|j d ij|j|jr+|j dij|j|j di}|jdHt!|r*|j"|j"j%|d<n|j%|d< |ddd} | d| i|d<|jd} | )|j*D]} | || } | || dcS| }t-t.|j0D]/} |} t35| ||} ddd| || dcS| }1|S#t&t(f$rd} YwxYw#1swY3xYw)zBApplies the information contained on the scope to the given event.c2tjd||y)Nz%s (%s) dropped event)rinfo)causetys r/_dropz#Scope.apply_to_event.._drop=s KK/U ;r1typer attachmentsNr breadcrumbsvaluesrtransaction_inforextratagscontextstracerh replay_idreplayrzerror processorzevent processor)rcrQrr-rC setdefaultextendrLrHrFrGrErKrmrIrJr rOrKeyError TypeErrorrNrr,rMr)r<rhintoptionsris_transactionattachments_to_send attachmentrrrerror_processor new_eventevent_processors r/apply_to_eventzScope.apply_to_event3s5  6*m; #hh}5;++ 7J!Z%C%C#**:6 72] ;; "![[E'N   ]B / : :8R H O O!!  99V  $)? JJE&M 99] # +0A0A0M#'#4#4E- 99' ( 0T5K5K5W(,(>(>E$ % 99] # +0A0A0M#'#4#4E- <<   Wb ) 0 0 > ::   VR ( / / ; >>   Z , 3 3DNN C##J3 << ("7+ 0F$(JJ$@$@$B!$($:$:$<!  )*DEkRI  Y"HX 88J'  #'#9#9 "+E8< $ 2CDD!  " %%T>TU OI,. 9+E48  9 _.?@@E   1)$ I $ 9 9s< L5 L1L.-L.1L: c|j|j|_|j|j|_|j|j|_|j%|jj |j|j |j |_|j r%|j j |j |jr%|jj |j|jr%|jj |j|jr%|jj|j|jr|j|_ |jr%|jj|j|jr|j|_ |jr|j|_yy)z+Update the scope with another scope's data.N)rCrErFrGrmrHrIrJrKrLrrOrQrSrT)r<scopes r/update_from_scopezScope.update_from_scopese << #,,DK    ) % 2 2D     ) % 2 2D   " " .  " " ) )%*A*A B ;; "DJ ;; JJ  ekk * ?? NN ! !%// 2 == LL   .       $ $U%7%7 8 ;;DJ       $ $U%7%7 8 >>!NNDM  % %(-(B(BD % &r1c|||_|||_||jj|||jj|||j j||||_yy)zUpdate the scope's attributes.N)rCrHrKrmrJrIrE)r<rrextrasrrrs r/update_from_kwargszScope.update_from_kwargssy  DK  DJ   LL   '   NN ! !( +   JJ  d #  " +D  #r1cZtj|j}|j|_|j|_|j |_|j |_t|j|_|j|_ t|j|_ t|j|_ t|j|_ t|j|_t|j |_t|j"|_|j$|_|j&|_|j(|_|j*|_|j,|_t|j.|_|j0|_|Sr+)object__new__ __class__rCrDrErFdictrGrHrIrJrKrrLlistrMrNrTr;rOrPrRrQrS)r<rvs r/__copy__zScope.__copy__s, ^^DNN +KK ::++++#D$:$:;:: #DNN+ $,,' t001#D$:$:;#D$:$:;"&";";!11::mm *.*K*K't001mm  r1czd|jjdtt|d|jdS)N)r__name__rqidrDr}s r/__repr__zScope.__repr__s- NN # # 4M JJ  r1r+)NNNNF)NNNNNN)-r  __module__ __qualname__r6 __slots__r[rXryrnrrYrrrrrrWr8rrrr5rsetterrrrrrrrrrrrrrrrr@rrrrr r1r/rBrBTsI0 T26>   /(E"  5" 3)2  "" 11";;0 6 -  [[55 ^^   "$&"$$ !  (,( ,8  XXtC@ ,0< r1rB)9r collectionsr itertoolsrrarosentry_sdk.attachmentsrsentry_sdk._functoolsrsentry_sdk.tracing_utilsr r r r sentry_sdk.tracingr rrsentry_sdk._typesrsentry_sdk.utilsrrsentry_sdk.constsrtypingrrrrrrrrrrrrr r!r"r#sentry_sdk.profilerr$r%sentry_sdk.sessionr&r'r)r,r0r8r@rrBrr1r/rs -'  ,@*,'*8CH-.A A. -  T  FT  r1