]j
i d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZ d dlZd dl m
Z
m Z m Z m
Z
d dlmZ erVd dlmZ d dlmZ d dlmZ d dlmZ d d lmZ d d
lmZ d d lmZ d d lmZ d d
lmZ d dlmZ d dlm Z d dlm Z d dlm Z d dlm Z m Z eddd Z! ej" d Z#dZ$dZ%d Z&d Z'd Z( dSdZ) G d d e* Z+ e+ Z,d Z-d Z.d Z/d! Z0dSd"Z1 G d# d$e2 Z3e G d% d&e* Z4 G d' d(e* Z5 G d) d*e* Z6erd d+lm7Z7 e7d, Z8e e6e8f Z9d- Z:d. Z;d/ Z<d0 Z= dTd1Z>d2 Z?d3 Z@e
rd4 ZAnd5 ZAd6 ZBdUd8ZCdVd9ZDd: ZE dTd;ZF eGeHd< ZIeIrd= ZJnd> ZJ dTd?ZKd@ ZLdA ZMdB ZNdTdCZOdD ZPdE ZQ dTdFZRdG ZSdSdHZTdI ZUdJ ZVdK ZW eW \ ZXZYdLZZdM Z[ eYdN Z\ G dO dPeH Z] G dQ dRej^ Z_dS )W N)datetime)urlparse text_typeimplements_strPY2)MYPY) FrameType)
TracebackType)Any)Callable)Dict)ContextManager)Iterator)List)Optional)Set)Tuple)Union)Type)ExcInfo EndpointTypei zsentry_sdk.errorsi c V t j | dd d S )zCSerialize data into a compact JSON representation encoded as UTF-8.F),:) allow_nan
separatorsutf-8)jsondumpsencode)datas G/opt/imunify360/venv/lib64/python3.11/site-packages/sentry_sdk/utils.py
json_dumpsr% , s) :de
C C C J J7 S SS c d S N r) r& r$ _get_debug_hubr* 2 s Dr& c $ t j d } | r| S t t j j d 5 } t
j g dt j || d
d } n# t t f$ r Y nw xY w| r| cddd S ddd n # 1 swxY w Y dD ]'}t j | } | r| c S (dS ) z Try to guess a default release.SENTRY_RELEASEzw+)gitz rev-parsez--shortHEAD)stdoutstderrstdinr r N)HEROKU_SLUG_COMMITSOURCE_VERSION!CODEBUILD_RESOLVED_SOURCE_VERSION CIRCLE_SHA1GAE_DEPLOYMENT_ID)osenvirongetopenpathdevnull
subprocessPopenPIPE communicatestripdecodeOSErrorIOError)releasenullvars r$ get_default_releaserH 8 s jnn -..G
bgot $ $
;;;%? q
"
G ! D # ! & *..%% NNN 4s7 CA!B'&C'B;8C:B;;CC "C c T t j d }|r|S | dS d S )NSENTRY_ENVIRONMENT
production)r7 r8 r9 )rE rvs r$ get_default_environmentrM _ s5
, - -B | 4r& c e Zd ZdZd Zd ZdS )CaptureInternalExceptionr) c | S r( r) selfs r$ __enter__z"CaptureInternalException.__enter__n s r& c 2 ||t |||f dS NT)capture_internal_exception)rR tyvaluetbs r$ __exit__z!CaptureInternalException.__exit__r s%
>e / &E2 7 7 7tr& N)__name__
__module__ __qualname__ __slots__rS rZ r) r& r$ rO rO k s7 I r& rO c t S r( )_CAPTURE_INTERNAL_EXCEPTIONr) r& r$ capture_internal_exceptionsra } s &&r& c T t }|| | d S d S r( )r* _capture_internal_exception)exc_infohubs r$ rV rV s3
C
''11111 r& c : | t z
S r( )epoch
total_secondsrX s r$ to_timestamprj s EM ( ( * **r& c , | d S )Nz%Y-%m-%dT%H:%M:%S.%fZ)strftimeri s r$ format_timestamprm s >>1 2 22r& c h | t j } nt | } | d d} d| iS )z+Creates a hint with the exc info filled in.Nr rd )sysrd exc_info_from_errorrd s r$ event_hint_with_exc_inforr s> <>>&x00{ !!r& c e Zd ZdZdS )BadDsnzRaised on invalid DSNs.Nr[ r\ r] __doc__r) r& r$ rt rt s !!!!r& rt c < e Zd ZdZd Zed ZddZd ZdS )DsnzRepresents a DSN.c 6 t |t rt |j | _ d S t j t
| }|j dvrt d|j z |j | _ |j t d |j | _
|j | j dk rdpd| _ n |j | _ |j st d |j | _
|j | _ |j dd } t
t% | | _ n6# t* t, f$ r" t d
|j pd d d z w xY wd | dz | _ d S ) N)httphttpszUnsupported scheme %rzMissing hostnamer{ P zMissing public key/r zInvalid project in DSN (%r) )
isinstancerx dict__dict__r urlsplitr schemert hostnamehostportusername
public_keypassword
secret_keyr; rsplitintpop
project_id
ValueError TypeErrorjoin)rR rX partsr; s r$ __init__z Dsn.__init__ s eS ! ! 0 0DM F!)E"2"233 < 2 2 205<?@@ @l > !+,, ,N : w.63<"DII
DI~ /-.. . . .z a(( Q 'DHHJJ 8 8DOOI& Q Q Q6%*:JABB9OOPP P Q HHTNNS( s 3E 3E9c L | j }| j | j fdvr |d| j }|S )zThe netloc part of a DSN.))rz r} )r{ r| r )r r r )rR rL s r$ netlocz
Dsn.netloc s7 Y K #+I I I BB *B r& Nc j t | j | j | j | j | j | j | S )z*Returns the auth info object for this dsn.)r r r; r r r client)Authr r r; r r r )rR r s r$ to_authz Dsn.to_auth s< ;
r& c v | j d| j | j r
d| j z pdd| j | j | j S )N://@r )r r r r r; r rQ s r$ __str__z Dsn.__str__ sO
KKK OO O 5do 5 ; ; ; KK II OO
r& r( ) r[ r\ r] rv r propertyr r r r) r& r$ rx rx sh ") ") ")H X
r& rx c J e Zd ZdZ d
dZed Z d dZd d ZdS )
r z,Helper object that represents the auth info.N r~ c v || _ || _ || _ || _ || _ || _ || _ || _ d S r( )r r r; r r r versionr ) rR r r r r r r r r; s r$ r z
Auth.__init__ s@ $$$ r& c . | d S )z^Returns the API url for storing events.
Deprecated: use get_api_url instead.
store)type) get_api_urlrQ s r$
store_api_urlzAuth.store_api_url s W ---r& r c J | j d| j | j d| j d|d S )z'Returns the API url for storing events.r zapi/r~ )r r r; r )rR r s r$ r zAuth.get_api_url s7
KKK II III OOO DD
r& c \ d| j fd| j fg}|1| dt t | f | j | d| j f | j | d| j f dd d |D z S )
z!Returns the auth header a string.
sentry_keysentry_versionNsentry_timestamp
sentry_client
sentry_secretzSentry z, c 3 * K | ]\ }}|d |V dS )=Nr) ).0keyrX s r$ <genexpr>z!Auth.to_header.<locals>.<genexpr>% s1 &S&S*#u###uu'=&S&S&S&S&S&Sr& )r r appendstrrj r r r )rR timestamprL s r$ to_headerzAuth.to_header s T_-0@$,/O
P II)3|I/F/F+G+GH I I I ; " II 4 5 5 5 ? & II8 9 9 9EJJ&S&SPR&S&S&S S SSSr& )Nr Nr~ )r r( ) r[ r\ r] rv r r r r r r) r& r$ r r s 66
* . . X.
T
T
T
T
T
Tr& r c e Zd ZdZd ZdS )AnnotatedValuerX metadatac " || _ || _ d S r( r )rR rX r s r$ r zAnnotatedValue.__init__+ s
r& N)r[ r\ r] r^ r r) r& r$ r r ( s( %I! ! ! ! !r& r )TypeVarTc F t | dd pt | dd S )Nr] r[ getattr)clss r$
get_type_namer 8 s% 3 - - Oj$1O1OOr& c 4 t | dd }|dvr|S d S )Nr\ )Nbuiltins __builtins__r )r mods r$ get_type_moduler = s)
#|T
*
*C
444
4r& c | j d }| d rdS n# t t f$ r Y nw xY wdD ]#} | j | r dS # t
$ r Y w xY wdS )Nr[ z sentry_sdk.T)__traceback_hide____tracebackhide__F) f_globals
startswithAttributeErrorKeyErrorf_locals Exception)framer flag_names r$ should_hide_framer E s
oj) >>- ( ( 4 H %
? ~i(
tt
D 5s "' ;;
A
A! A!c # X K | }|#t |j s|V |j }|!d S d S r( )r tb_frametb_next)rY tb_s r$ iter_stacksr X sA
C
/ .. IIIk /////r& c x d}d }|Vt |d rF | | }n# t t f$ r d }Y nw xY w|| }|2 t j | }n # t t f$ r g d g fcY S w xY w|sg d g fS t d||z
}t |dz |z t | } d ||| D } t || d }
d ||dz | D } | |
| fS # t $ r g d g fcY S w xY w)N
get_sourcer r c R g | ]$}t | d %S
strip_stringrA r lines r$
<listcomp>z'get_lines_from_file.<locals>.<listcomp> s9
15LF++ , ,
r& r c R g | ]$}t | d %S r r r s r$ r z'get_lines_from_file.<locals>.<listcomp> s<
F++ , ,
r& )hasattrr ImportErrorrD
splitlines linecachegetlinesrC maxminlenr rA
IndexError) filenamelinenoloadermodule
context_linessource
source_str lower_bound upper_bound pre_context context_line post_contexts r$ get_lines_from_filer a s M
F
gfl ; ; **622JJW% JJJ ! **,,F
~ '11FF! tR< 4|a-/00Kfqj=0#f++>>K
9? F@R9S
$F6N$8$8$@$@AA
k 9:
L,66 4| s4 . AA A5 5B
BAD' 'D98D9c | j j }n# t $ r d }Y nw xY w | j d }n# t $ r g d g fcY S w xY w | j d }n# t $ r d }Y nw xY w|dz
}||rt |||| S g d g fS )Nr[
__loader__r )f_code co_filenamer r r )r tb_linenoabs_pathr r r s r$ get_source_contextr s
<+ , 4| .
]F
h"8VVVDDD
tR<s-
0 AA
A A#"A#c ` t | S # t $ r t | cY S w xY wr( )r r safe_reprri s r$ safe_strr sD s --c t | dd } | d d S # t $ r |cY S w xY w# t $ r Y dS w xY w)Nr replacelatin1zunicode-escape
<broken repr>)reprrB r" r )rX rL s r$ r r s $e##GY77B
yy**112BCCC
$ $ $### $s. #A 'A A A A A
A.-A.c D t | S # t $ r Y dS w xY w)Nr
)r r ri s r$ r r s5 #;; # # #"?? #s
c |r| s|S | d r
|d d }| dd d }|| k r t j | S t
j | j }| | t j d d d d
t j S # t $ r |cY S w xY w)Nz.pyc.r r ) endswithsplitr7 r; basenamero modules__file__r seplstripr )r r base_modulebase_module_paths r$ filename_for_moduler s 6
V $ $ % }H ll3**1- & 7##H-- - ;{3<~~ . 5 5bfa @ @ CQGGKRR F
s A C (A3C C+*C+Tc v t | dd }|sd }d }n| j j }| j j } | j d }n# t
$ r d }Y nw xY w|| j }t | | \ }}} t || pd |r t j
| nd |pd||||| d}
|r
| j |
d< |
S )Nr r[ z <unknown>)r r functionr r r r r vars)
r r r co_namer r f_linenor r r7 r; abspathr ) r r with_localsr r r r r r r rL s r$ serialize_framer" s
UHd
+
+F (<+<' , N .@ .R.R+K | (99AT19CBGOOH---t + "$$
B $^6
Is
A AAc d}g }t j }|<t | s$| t || |j }|<| d|iS )NT)r! frames)ro _getframer r r" f_backreverse)r! r r$ fs r$ current_stacktracer)
sx
F
A
- ## G MM/!EEE F F F
H -
NN f r& c $ t | dd S )Nerrnor ) exc_values r$ get_errnor- s 9gt , ,,r& c z |t | }nd }|D|pddi}| di di d| |dn|d fdt | D }t | t | t | |d }|rd
|i|d < |S ) Nr genericmetar+ numberTr! c H g | ] }t |j |j S ))r r! )r" r r )r rY r! s r$ r z5single_exception_from_error_tuple.<locals>.<listcomp>7 s< r|UUU r& )r r rX mechanismr$
stacktrace)r-
setdefaultr r r r ) exc_typer, rY client_optionsr3 r+ r$ rL r! s @r$ !single_exception_from_error_tupler8 s )$$ 4&)!4 VR((33GR@@KK e
$]3 b// F "(++ h'')$$
B . $f-<
Ir& __suppress_context__c # K | \ }}}g }t }||t | |vr|||fV | | | t | |j r|j }n|j }|d S t | }|}t |dd }||t | |vd S d S d S d S d S d S )N
__traceback__) setidr addr9 __cause__ __context__r r )rd r6 r, rY seen_exceptionsseen_exception_idscauses r$ walk_exception_chainrD M s "* )R UU
%9
%777Ir) ) ) )
" "9 - - - " "2i== 1 1 1-
.!+!-}E{{H I66B)
%9
%77777
! %%77
! %%r& c # K | V d S r( r) rq s r$ rD rD n s r& c
| \ }}}g }t | D ],\ }}}| t ||||| -| |S r( )rD r r8 r' )rd r7 r3 r6 r, rY rL s r$ exceptions_from_error_tuplerG s sz 'Hi B#7#A#A
)R
-)R
JJLLL
Ir& c p t | S # t $ r t | dd cY S w xY w)Nr r )r UnicodeDecodeErrorr ri s r$ to_stringrJ sK ! ! ! !E{{1R4 !s !55c # K d| v r
| d V d| v r.| d d pdD ]}d|v r
|d V d| v r.| d d pdD ]}d|v r
|d V d S d S )Nr4 threadsvaluesr) exception)r9 )eventthreadrN s r$ iter_event_stacktracesrQ s u L!!!!EI&**844: + +Fv%% \****e {+//99?R . .Iy(( ---- . .r& c # j K t | D ] }| d pdD ]}|V !d S )Nr$ r) )rQ r9 )rO r4 r s r$ iter_event_framesrS sW ,U33
^^H--3 EKKKK r& c t t | D ]'}t | d || (| S )Nr$ )in_app_excludein_app_include)rQ handle_in_app_implr9 )rO rU rV r4 s r$
handle_in_apprX sQ ,U33
NN8 $ $))
Lr& c | sd S d}| D ]c}| d }||rd} | d }|s6t || rd|d< d}Nt || rd|d< d|s | D ] }| d d|d< | S )NFin_appTr )r9 _module_in_set)r$ rU rV
any_in_appr rZ r s r$ rW rW s tJ $ $8$$
" !
8$$ $
FN
3
3 $ "E(O JJ
FN
3
3 $ #E(O ' ' 'Eyy""*"&h Mr& c z t | t rt | dk r| \ }}}nt | t rTt | dd }|t | }| }nNt
j \ }}}|| urd }| }t | }n t dt | z |||fS )N r; z,Expected Exception object to report, got %s!) r tupler
BaseExceptionr r ro rd r )errorr6 r, rY s r$ rp rp s % WCJJ!OO"' )RR E= ) )
W
UOT
2
2
>E{{H II&)lnn #Hi%% ! ;; G$u++UVVV Y ""r& c n t | } t | }ddt | || id|fS )Nra rM )levelrN )rp rr rG )rd r7 r3 hints r$ event_from_exceptionre sX #8,,H #H - -D 5 ni
r& c ^ |sdS |pdD ]#}|| k s| |dz r dS $dS )NFr) r T)r )namer< items r$ r[ r[ sP u r 4<<4??4#:66<44 5r& c | s| S |t }t | }||k r*t | d |dz
dz |dd|dz
|ggd S | S )Nr^ z...z!limitx)r remr )MAX_STRING_LENGTHr r )rX
max_lengthlengths r$ r r s &
ZZF
(*q.()F2 !3
Q
CD
Lr& c ddl m} | dd r | dd rdS dS n# t $ r Y nw xY w dd lm} |d
rdS n# t $ r Y nw xY wdS ) z
Returns whether gevent/eventlet have patched the stdlib in a way where thread locals are now more "correct" than contextvars.
r )is_object_patched threadinglocal contextvars
ContextVarFT)is_monkey_patchedrP )
gevent.monkeyrp r eventlet.patcherru )rp ru s r$ _is_contextvars_brokenrx s
333333 [' 2 2 ! ==
u4
666666 X & & 4
5s %
22A
AAc 2 G fddt }|S )Nc & e Zd Z fdZd Zd ZdS )1_make_threadlocal_contextvars.<locals>.ContextVarc 4 || _ | _ d S r( )_name_local)rR rg rr s r$ r z:_make_threadlocal_contextvars.<locals>.ContextVar.__init__< s DJ %''DKKKr& c . t | j d| S )NrX )r r~ )rR defaults r$ r9 z5_make_threadlocal_contextvars.<locals>.ContextVar.getA s 4;99 9r& c || j _ d S r( )r~ rX )rR rX s r$ r< z5_make_threadlocal_contextvars.<locals>.ContextVar.setE s %DK r& N)r[ r\ r] r r9 r< rr s r$ rt r{ 9 sL " " " " "
: : : & & & & &r& rt )object)rr rt s ` r$ _make_threadlocal_contextvarsr 7 s? & & & & & & &V & & & r& c t sFt j dk r ddlm} d| fS # t
$ r Y n w xY w ddlm} d| fS # t
$ r Y nw xY wddlm} dt | fS )z
Figure out the "right" contextvars installation to use. Returns a
`contextvars.ContextVar`-like class with a limited API.
See https://docs.sentry.io/platforms/python/contextvars/ for more information.
)r^ r r )rt Tr F)
rx ro version_infoaiocontextvarsrt r rs rq rr r )rt rr s r$ _get_contextvarsr L s " # #
f $ $
555555Z''
222222Z''
/66 66s *
77 A
AAz
With asyncio/ASGI applications, the Sentry SDK requires a functional
installation of `contextvars` to avoid leaking scope/context data across
requests.
Please refer to https://docs.sentry.io/platforms/python/contextvars/ for more information.
c | j j d| j j d| j S # t $ r Y nw xY wt | dd pt | dd pd }|sd S | j d|S # t $ r Y nw xY w|S )Nr r] r[ )im_classr\ r[ r r )func
func_qualnames r$ transaction_from_functionr ~ s
M $ $ $ M " " " MM
nd++VwtZ/N/NVRV t
///==99
s "%
22 A* *
A76A7disable_capture_eventc e Zd ZdZdS )ServerlessTimeoutWarningz>Raised when a serverless method is about to reach its timeout.Nru r) r& r$ r r s HHDr& r c $ e Zd ZdZd Zd Zd ZdS )
TimeoutThreadzCreates a Thread which runs (sleeps) for a time duration equal to
waiting_time and raises a custom ServerlessTimeout exception.
c t j | || _ || _ t j | _ d S r( )rq Threadr waiting_timeconfigured_timeoutEvent _stop_event)rR r r s r$ r zTimeoutThread.__init__ s? !!$''' ("4 $?,,r& c 8 | j d S r( )r r< rQ s r$ stopzTimeoutThread.stop s r& c | j | j | j rd S t | j }|| j k r|dz }t
d | )Nr zZWARNING : Function is expected to get timed out. Configured timeout duration = {} seconds.)r waitr is_setr r r format)rR integer_configured_timeouts r$ runzTimeoutThread.run s
d /000 " " $ $ F%()@%A%A" &(? ? ?)Ca)G & ' h o o*
r& N)r[ r\ r] rv r r r r) r& r$ r r sK - - -
r& r r( )NNrU )T)`r r loggingr7 ro rq r= r
sentry_sdksentry_sdk._compatr r r r sentry_sdk._typesr typesr r
typingr r r
r r r r r r r r r r rg getLoggerloggerrl MAX_FORMAT_PARAM_LENGTHr% r* rH rM r rO r` ra rV rj rm rr r rt rx r r r r Annotatedr r r r r r r r r r" r) r- r8 r r HAS_CHAINED_EXCEPTIONSrD rG rJ rQ rS rX rW rp re r[ r rx r r HAS_REAL_CONTEXTVARSrt CONTEXTVARS_ERROR_MESSAGEr r r r r r) r& r$ <module>r s
G G G G G G G G G G G G " " " " " " 8 ###### %%%%%% 77777777 q!
. / / T T T $ $ $P
v 7 6 8 8 ' ' '
2 2 2+ + +
3 3 3
" " " "" " " " "Z " " " F
F
F
F
F
& F
F
F
R8T 8T 8T 8T 8T6 8T 8T 8Tv! ! ! ! !V ! ! ! ) Ana'(IP P P
& ) ) ) ) X . ##$ $ $ $8# # # * F
- - - ' ' ' 'T !,BCC % 7 7 7 7B (! ! ! . . . <# # #0 * . : *#7 #7 #7L $4#3#5#5 j @ #
#:;; y #
#
#
#
#
I$ #
#
#
#
#
r&