pn}1 d dl Z d dlZd dlZd dlmZ d dlmZmZmZm Z d dl
m Z m Z d dl
mZ e rd dlmZ d dlmZmZ nd dlmZ d dlmZmZ er"d dlZd dlmZ d d lmZ d d
lmZ d d lmZ d d lmZ e j d
Z dZ G d de Z d Z ej! d Z"d Z#d Z$d Z% G d de& Z'd Z(d Z)d dl*m+Z+ dS ) N)OP)capture_internal_exceptionsDsnmatch_regex_list to_string)PY2 iteritems)
TYPE_CHECKING)Mapping)quoteunquote)Any)Dict) Generator)Optional)Unionz5^[ ]*([0-9a-f]{32})?-?([0-9a-f]{16})?-?([01])?[ ]*$z(([a-zA-Z0-9+/]{4})*([a-zA-Z0-9+/]{2,3})?c * e Zd Z ddZd Zd Zd ZdS )EnvironHeadersHTTP_c " || _ || _ d S N)environprefix)selfr r s j/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/sentry_sdk/tracing_utils.py__init__zEnvironHeaders.__init__5 s c x | j | j | dd z S N-_)r r replaceupper)r keys r __getitem__zEnvironHeaders.__getitem__> s0 |DK#++c3*?*?*E*E*G*G GHHr c N t d t | D S )Nc 3 K | ]}d V dS ) N ).0r! s r z)EnvironHeaders.__len__..D s" ))1))))))r )sumiterr s r __len__zEnvironHeaders.__len__B s% ))d4jj))))))r c # K | j D ]y}t |t s| dd }| | j s[|t | j d V zd S r )r
isinstancestrr" r#
startswithr len)r ks r __iter__zEnvironHeaders.__iter__F s ( (A a%%
#s##))++A<< ,,
C $$&&' ' ' ' ' ( (r N)r )__name__
__module__ __qualname__r r% r/ r6 r) r r r r 4 s] I I I* * *
(
(
(
(
(r r c | dS t | d duo-| d dup| d du S )z}
Returns True if either traces_sample_rate or traces_sampler is
defined and enable_tracing is set and not false.
NFenable_tracingtraces_sample_ratetraces_sampler)boolget)optionss r has_tracing_enabledrA S si u $%%U2
KK, - -T 9
9{{+,,D8 r c # : K | j r:| j j d dd r|r|d gk rd }|dk rd}nd }d }t || }i }|||d< |||d< |rd|d < t 5 | |d
| d d d n # 1 swxY w Y | t j | 5 }| D ]\ }} |
|| |V d d d d S # 1 swxY w Y d S )
N _experimentsrecord_sql_paramsFpyformatformatz db.paramsz
db.paramstyleTzdb.executemanyquery)messagecategorydata)op description) clientr@ r? _format_sqlr add_breadcrumb
start_spanr DBitemsset_data)
hubcursorrG params_list
paramstyle executemanyrJ spanr5 vs
r record_sql_queriesr[ e s z
cj( 8<<U
kdV 3 3 K # #!J
& &E
D '[ *_ &!%
$ & & G G 57FFFG G G G G G G G G G G G G G G
25e 4 4 JJLL DAq MM!Q
s$ =B""B&)B&5DDDc B |j t j k r%| |j dd|j d S |j t j k r | dd|j d S |j dk r%| dd|j |j d S d S )Nredis)rH typerI rJ httphttplib)r^ rI rJ
subprocess)r^ rI rH rJ )rK r DB_REDISrO rL _tags HTTP_CLIENT_data)rT rY s r "maybe_create_breadcrumbs_from_spanrf s w"+ $7W4:
BN " " LLLLL
L !$
! r c | sdS | d r | d r
| dd } t | }|sdS | \ }}}d}|r#d t
|d }|r#d t
|d }|r|d k }|||d
S ) zL
Given a `sentry-trace` header string, return a dictionary of data.
Nz00-z-00 z{:032x} z{:016x}0)trace_idparent_span_idparent_sampled)r3 endswithSENTRY_TRACE_REGEXmatchgroupsrF int)headerrq rl rm sampled_strrn s r extract_sentrytrace_datarv s
t
FOOE$:$: " $ $V , ,E t,1LLNN)HnkN 7 ##C"$5$566 C"))#nb*A*ABB ,$+ (( r c d } t | d rI| | }t |t r | | j j }n# t $ r d }Y nw xY w|pt | S )Nmogrify) hasattrrx r1 bytesdecode
connectionencoding Exceptionr )rU sqlreal_sqls r rN rN s H 69 % % G ~~c**H(E**
G#??6+<+EFF %y~~%s AA A-,A-c e Zd ZdZdZ ej d Z ddZe d Z
e d Z e d Z d
Z
d Zdd
ZdS )Baggage sentry_itemsthird_party_itemsmutablezsentry-z^sentry- Tc 0 || _ || _ || _ d S r r )r r r r s r r zBaggage.__init__ s )!2 r c i }d}d}|r| d D ]}d|vrt 5 | }| d \ }}t j | r=t
| d d }t
| ||< d}n ||rdnd|z z
}ddd n # 1 swxY w Y t ||| S ) zF
freeze if incoming header already has sentry baggage
r T,=r r( FN)splitr stripr SENTRY_PREFIX_REGEXrq r
) clsrt r r r itemr$ val baggage_keys r from_incoming_headerz Baggage.from_incoming_header sV
W S))
W
Wd?? 022 W W ::<U 7 ?<(( (. # 8 *z=P/P/P'::'FL $ ;;} % % A*1-*@L ' ;;y ! ! 9&-i&8L # ;;u H),WU^)<)<)GL & ;;+ , , H*12F*GL '%%+," 88I ;+/ ?L (|%6@@@r c |j pt j j }|j }i }|st | S |j pi }|j r |j j pi }|j |d< |
d r |d |d< |
d r |d |d< |
d r t |d j |d< |j
r|j t vr
|j
|d< |
d r |d |d< |j t# |j |d
< |j |j rd nd |d
< |j r+|j j r | |j j t |d S )z
Populate fresh baggage entry with sentry_items and make it immutable
if this is the head SDK which originates traces.
rl r r r r transactionr r Nr truefalsesampledFr )rT r r r rM r r@ r r rl r? r r namesource LOW_QUALITY_TRANSACTION_SOURCESr r2 r _baggager update)r r rT rM r r@ r s r populate_from_transactionz!Baggage.populate_from_transaction% s o7 !7 )<(( (.&B -cio4"#.#7 Z ;;} % % A*1-*@L ' ;;y ! ! 9&-i&8L # ;;u H),WU^)<)<)GL &
;"*III*5*:L ' 88I ;+/ ?L ( " .*-k.E*F*FL ' *0;0C&PffL #
CK$8$E C 4 A B B B|U3333r c d| _ d S )NFr r. s r freezezBaggage.freezeX s
r c H i }t | j D ]
\ }}|||< |S r )r r )r rt r$ r s r dynamic_sampling_contextz Baggage.dynamic_sampling_context\ s5 "4#455 IC F3KK
r Fc g }t | j D ]|\ }}t 5 t j t | z dz t t
| z }| | d d d n # 1 swxY w Y }|r| | j d | S )Nr r )
r r r r
SENTRY_PREFIXr r2 appendr join)r include_third_partyrR r$ r r s r serializezBaggage.serializee s !$"344 # #HC,..
#
# ,uSzz9C?%C//Q T"""
#
#
#
#
#
#
#
#
#
#
#
#
#
#
# 1 LL/ 0 0 0xx s ABB B N)r T)F)r7 r8 r9 __slots__r recompiler r classmethodr r r r r r r) r r r r s @I M$"*Z00
A A [A4 "A "A ["AH 04 04 [04d r r c | j }|j d }|j r |j j r|j j j }nd}|o||v }|rdS t ||d S )zv
Returns True if url matches trace_propagation_targets configured in the given hub. Otherwise, returns False.
trace_propagation_targetsNFT)substring_matching)rM r@ transport
parsed_dsnnetlocr )rT urlrM r dsn_urlis_request_to_sentrys r should_propagate_tracer t sx
ZF &/J K
F , 7 "-4"5w#~ u C!:t T T TTr c i }| D ]Q\ }}| d r
|dd }| dd }|||< R|S )z
Normalizes incoming data so the keys are all lowercase with dashes instead of underscores and stripped from known prefixes.
r Nr! r )rR r3 r" lower)
incoming_datarJ r$ values r normalize_incoming_datar sx
D#))++
U >>' " " abb'Ckk#s##))++S Kr )r ),r
contextlibr sentry_sdk.constsr sentry_sdk.utilsr r r r sentry_sdk._compatr r sentry_sdk._typesr
collectionsr urllibr r
collections.abc urllib.parsetypingr r r r r r rp base64_strippedr rA contextmanagerr[ rf rv rN objectr r r sentry_sdk.tracingr r) r r r s . - - - - - - - + + + + + + ,######%%%%%%%%%''''''++++++++ MMM RZ ( ( ( ( (W ( ( (> $ ' ' 'T
" @& & &(\ \ \ \ \ f \ \ \ ~U U U(
" ? > > > > > > >r