35ۧ ` d dl mZ d dlZd dlZd dlmZ d dlmZ d dlm Z d dl
m Z d dl m
Z
mZ d dlmZmZ d d lmZmZ d d
lmZ d d lmZmZ d d lmZm Z m Z m Z m Z e rd d
l m!Z!m"Z"m#Z#m$Z$m%Z% d dl&m'Z( d dl)Z)d dl)m*Z+ d dl,m-Z- d dl.m/Z/ d dl0m1Z1 d dl2m3Z3 d dl4m5Z5 d dl6m7Z7 d dl8m9Z9m:Z:m'Z;mm?Z? n# e=$ r d dl@m?Z? Y nw xY w d dlAZAn
# e=$ r dZAY nw xY wdZBdZC G d d e ZDd ZEd+d ZFd ZGd! ZHd" ZId# ZJd$ ZKd% ZLd& ZMd' ZN G d( d) ZOd* ZPdS ), )absolute_importN)deepcopy) iteritems)
TYPE_CHECKING)OP)Hub_should_send_default_pii) DidNotEnable Integration)_is_json_content_typerequest_body_within_bounds)SentryAsgiMiddleware)SOURCE_FOR_STYLETRANSACTION_SOURCE_ROUTE)AnnotatedValuecapture_internal_exceptionsevent_from_exception
parse_versiontransaction_from_function)Any AwaitableCallableDictOptional)Scope) __version__) Starlette)
UploadFile)
Middleware)AuthenticationMiddleware)Request)Match)ASGIAppReceiver SendzStarlette is not installed)ExceptionMiddlewarezgeneric Starlette request)endpointurlc 4 e Zd ZdZdZddZed ZdS )StarletteIntegration starlette r( c \ |t vrt d|dt d || _ d S )Nz%Invalid value for transaction_style: z
(must be in ))TRANSACTION_STYLE_VALUES
ValueErrortransaction_style)selfr1 s s/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/sentry_sdk/integrations/starlette.py__init__z StarletteIntegration.__init__F sJ $< < < *$$$&>&>&>@
"3 c t t } | 't d t t t t
| dk rt d S d S )Nz Unparsable Starlette version: {})r )r STARLETTE_VERSIONr
formatpatch_middlewarespatch_asgi_apppatch_request_responsepatch_templates)versions r3
setup_oncez StarletteIntegration.setup_onceO s 122 ? 299:KLL
g r5 N)r( )__name__
__module__ __qualname__
identifierr1 r4 staticmethodr? r5 r3 r* r* A sN J3 3 3 3 \ r5 r* c D | j fd}j dv}|r|| _ | S )Nc K t j }| t }|| j j | t j 5 }| d fd}t dt } | dk }
|
s|n} fd} t dt }
|
dk }|s| n} | || |fi | d {V cd d d S # 1 swxY w Y d S | |fi | d {V S )Nop descriptionstarlette.middleware_namec
K t j }| t j t dt
5 }| d | i | d {V cd d d S # 1 swxY w Y d S NrB rH rK )r current
start_spanr MIDDLEWARE_STARLETTE_RECEIVEgetattrstrset_tag)argskwargshubspanmiddleware_namereceives r3 _sentry_receivezO_enable_span_for_middleware.._create_span_call.._sentry_receiver s +C :$+G^S\\$R$R ( > %@/RRR%,Wd%=f%=%= = = = = = = > > > > > > > > > > > > > > > > > >
$A>>BBr@ rZ c
K t j }| t j t dt
5 }| d | i | d {V cd d d S # 1 swxY w Y d S rM )r rN rO r MIDDLEWARE_STARLETTE_SENDrQ rR rS )rT rU rV rW rX sends r3 _sentry_sendzL_enable_span_for_middleware.._create_span_call.._sentry_send s +C 7$+D.#d))$L$L ( ; %@/RRR%)T4%:6%:%: : : : : : : ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ;r[ r_ ) r rN get_integrationr* __class__r@ rO r MIDDLEWARE_STARLETTErS rQ rR )appscoperY r^ rU rV integrationmiddleware_spanrZ receive_namereceive_patched new_receiver_ send_name send_patchednew_sendrX old_calls `` @r3 _create_span_callz6_enable_span_for_middleware.._create_span_calle s k))*>?? " !m 4O * #
S ''(C_UUU> > > > > > 'w
CLL I I ".2C"C5D Qoo' ; ; ; ; ; ; $D*c$ii @ @ (N : /;E<< %Xc5+x R R6 R RRRRRRRG#
S #
S #
S #
S #
S #
S #
S #
S #
S #
S #
S #
S #
S #
S #
S #
S #
S #
SL "#ugtFFvFFFFFFFF Fs BC11C58C5)rn %_sentry_authenticationmiddleware_call _sentry_exceptionmiddleware_call)__call__r@ )middleware_classrn not_yet_patchedrm s @r3 _enable_span_for_middlewarert a sW (H-G -G -G -G -G^ ' 0 O 6$5! r5 Fc t j }| t d S t | |j r |j j nd t j |d \ }}| || d S )N)typehandled)client_options mechanism)hint) r rN r` r* r clientoptionsrC
capture_event) exceptionrw rV eventrz s r3 _capture_exceptionr s
+C
/008&-0ZAsz))T/:wOO KE4 e$'''''r5 c | j dt v}|r!fd}|| _ | j fd}|| _ dS dS )zX
Capture all exceptions in Starlette app and
also extract user information.
_sentry_middleware_initc | g|R i | | j fd}| j D ] }|| j |<
d S )Nc X K |d }t |d o$t |j t o
|j dk }|rt |d d }t | j D ]}|v r
| } n|d S t | r || g|R i | d {V S || g|R i |S )Nr status_codei T)rw )hasattr
isinstancer intr rv __mro___is_async_callable)r2 rT rU expis_http_server_error old_handlercls old_handlerss r3 !_sentry_patched_exception_handlerzfpatch_exception_middleware.._sentry_middleware_init.._sentry_patched_exception_handler s 1g C // /"3?C88/3. %
( :&sD9999 # 99, Cl**&23&7 + &F%k22 >!,T!CD!C!C!CF!C!CCCCCCCC&;t=d===f===r5 )_exception_handlerscopykeys)r2 rT rU r keyr old_middleware_inits @r3 r z;patch_exception_middleware.._sentry_middleware_init s 6t 6 6 6v 6 6 6 388::L
>
>
>
>
>6 /4466
R
R0Q(--
R
Rr5 c R K t | | ||| d {V d S N_add_user_to_sentry_scoper2 rd rY r^ rm s r3 rp zDpatch_exception_middleware.._sentry_exceptionmiddleware_call sE
&e , , ,(466 6 6 6 6 6 6 6 6 6r5 N)r4 rR rq )rr rs r rp rm r s @@r3 patch_exception_middlewarer s +3/s;N7O7OOO ;E# R # R # R # R # RJ %<!#, 7 7 7 7 7 %E!!!w;E ;Er5 c d| vrdS t sdS t j }| t dS | 5 }i }| d }t
|dd }|r| d|j t
|dd }|r| d|j t
|dd }|r| d|j
||_ ddd dS # 1 swxY w Y dS )zZ
Extracts user information from the ASGI scope and
adds it to Sentry's scope.
userNusernameidemail) r r rN r` r* configure_scoperQ
setdefaultr r r r )rd rV sentry_scope user_infostarlette_userr user_idr s r3 r r si U # % %
+C
/008 &, v >:t<< F ^-D E E E.$55 : ~'8 9 9 966 @ .*> ? ? ? % !& & & & & & & & & & & & & & & & & &s B C<<D D c X | j dt v}|rfd}|| _ dS dS )z/
Add user information to Sentry scope.
ro c R K | ||| d {V t | d S r r r s r3 ro zNpatch_authentication_middleware.._sentry_authenticationmiddleware_call% sC (466 6 6 6 6 6 6 6 %e , , , , ,r5 N)rq rR )rr rs ro rm s @r3 patch_authentication_middlewarer s]
(H=S]]RO J - - - - -
%J!!!J Jr5 c l t j dt v} | rfd}|t _ dS dS )za
Patches Starlettes `Middleware` class to record
spans for every middleware invoked.
r c |t k r
| |fi |S t | } | |fi | |t k rt | |t k rt | d S d S r )r rt r r r& r )r2 r r| span_enabled_clsr s r3 r z2patch_middlewares.._sentry_middleware_init9 s *****4@@@@@ :3 ? ? &6 B B' B B B.../444)))*3///// *)r5 N)r r4 rR )rs r r s @r3 r: r: - s\ %-/s;N7O7OOO 6 0 0 0 0 0 6
!6 6r5 c B t j fd} | t _ dS )zG
Instrument Starlette ASGI app using the SentryAsgiMiddleware.
c K t j t ||| d {V S t fdt j }|j |_ |||| d {V S )Nc g| R i |S r rE )akwold_appr2 s r3 zBpatch_asgi_app.._sentry_patched_asgi_app..W s! WWT 4A 4 4 4 4 4 r5 )mechanism_type)r rN r` r* r rC
_run_asgi3rq )r2 rd rY r^
middlewarer s ` r3 _sentry_patched_asgi_appz0patch_asgi_app.._sentry_patched_asgi_appQ s ; & &'; < < D ugt<<<<<<<< <) 4 4 4 4 4/:
) 3
Zw555555555r5 N)r rq )r r s @r3 r; r; J s6
G 6 6 6 6 6 2Ir5 c t | t j r!| j } t | t j !t j | p't
| ot j | j S r )r functoolspartialfuncasyncioiscoroutinefunctioncallablerq )objs r3 r r c sj
S)+
,
, h S)+
,
, &s + +
C'5clCCr5 c V t j j fd} | t j _ d S )Nc ` | t }|rfd}|} nfd}|} | S )Nc K t j }| t }| | i | d {V S | 5 }| d }t ||j | t | }| d {V fd}d d d n # 1 swxY w Y t j |_
| ||| | i | d {V S )Nr c fd}|S )Nc | di }r dv r d |d< dv r d |d< t | | d< | S )Nrequestcookiesdatagetr )r rz request_infoinfos r3 event_processorzpatch_request_response.._sentry_request_response.._sentry_async_func.._make_request_event_processor..event_processor sh ,199Y+C+CL # H#,#4#4>B9oL$;#)T>>;?._sentry_request_response.._sentry_async_func.._make_request_event_processor s$ ) ) ) ) ) /.r5 ) r rN r` r* r _set_transaction_name_and_sourcer1 StarletteRequestExtractorextract_request_inforC _nameadd_event_processor)
rT rU rV re r r extractorr r old_funcs
@r3 _sentry_async_funczTpatch_request_response.._sentry_request_response.._sentry_async_funcx s k ! 1 12F G G &!)4!:6!:!::::::::((** /l "1gG4$k&CW !:' B BI!*!?!?!A!AAAAAAAD/ / / / // / / / / / / / / / / / / / /8 &:%D " 0011';GG &Xt 6v 6 66666666s A
B((B,/B,c t j }| t }| | i |S | 5 }|j |j | d }t ||j | t | }|
fd}d d d n # 1 swxY w Y t j |_ |
||| | i |S )Nr c fd}|S )Nc f | di }r|d< t | | d< | S )Nr r r )r rz r r s r3 r zpatch_request_response.._sentry_request_response.._sentry_sync_func.._make_request_event_processor..event_processor sB ,199Y+C+CL & B:A Y 7/7 /E/EE) ,#(Lr5 rE )r re r r s r3 r zzpatch_request_response.._sentry_request_response.._sentry_sync_func.._make_request_event_processor s$
)
)
)
)
) /.r5 )r rN r` r* r profileupdate_active_thread_idr r1 r extract_cookies_from_requestrC r r )
rT rU rV re r r r r r r s
@r3 _sentry_sync_funczSpatch_request_response.._sentry_request_response.._sentry_sync_func sf k ! 1 12F G G T4V444((** /l#+7$,DDFFF "1gG4$k&CW !:' B BI ' D D F FG/ / / / // / / / / / / / / / / / / / /: &:%D " 0011';GG x0000s A'B::B>B>)r )r is_coroutiner r r old_request_responses @r3 _sentry_request_responsez8patch_request_response.._sentry_request_responseq st )(33 Z %(
7 (
7 (
7 (
7 (
7T &DD)
1 )
1 )
1 )
1 )
1V %D##D)))r5 )r+ routingrequest_response)r r s @r3 r< r< m sB $,=a* a* a* a* a*F *BI&&&r5 c ddl m n# t $ r Y d S w xY wddlm} | j dt
v}|rfd}|| _ d S d S )Nr )Markup)Jinja2Templates _sentry_jinja2templates_initc fd}| dg ||d vr|d | | g|R i |S )Nc ^ t j } | }d|iS )Nsentry_trace_meta)r rN trace_propagation_meta)r rV
trace_metar s r3 add_sentry_trace_metazTpatch_templates.._sentry_jinja2templates_init..add_sentry_trace_meta s4 k #VC$>$>$@$@ A A
' r5 context_processors)r append)r2 rT rU r r old_jinja2templates_inits r3 r z5patch_templates.._sentry_jinja2templates_init s
2B 7 7 7$F3G,HHH+,334IJJJ++DB4BBB6BB Br5 )
markupsafer ImportErrorstarlette.templatingr r4 rR )r rs r r r s @@r3 r= r= s %%%%%%% 544444 . 7 4C = = O @ C C C C C C" $@ '@ @s
c F e Zd ZdZdZd Zd Zd Zd Zd Z d Z
d Z d
Z dS ) r z
Extracts useful information from the Starlette request
(like form data or cookies) and adds it to the Sentry event.
Nc || _ d S r )r )r2 r s r3 r4 z"StarletteRequestExtractor.__init__ s
r5 c x t j j }|d S d }t r| }|S r )r rN r{ r r )r2 r{ r s r3 r z6StarletteRequestExtractor.extract_cookies_from_request s; # >4 # % % %llnnGr5 c K t j j }|d S i }t 5 t r| |d< | d {V }|s|cd d d S |r4t || s$t j |d< |cd d d S |
d {V }|r||d< |cd d d S | d {V }|rYi }t | D ]4\ }}t |t } | s|nt j ||< 5||d< |cd d d S t j |d< |cd d d S # 1 swxY w Y d S )Nr r )r rN r{ r r r content_lengthr
r removed_because_over_size_limitjsonformr r r removed_because_raw_data)
r2 r{ r r r r form_datar valis_files
r3 r z.StarletteRequestExtractor.extract_request_info s # >4
(
*
* ( ( '))
9*.,,.. Y' $(#6#6#8#8 8 8 8 8 8 8N!
$#( ( ( ( ( ( ( (
$&@' '
$ (6'U'W'W V$# ( ( ( ( ( ( ( ( $ $$$$$$D
$'+ V$#+( ( ( ( ( ( ( ( 0 $$$$$$D
$ )$ HC (j 9 9G 'G + D F F cNN (1 V$#I( ( ( ( ( ( ( ( N $2#J#L#LL Q( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( s+ AE68)E6."E6 A(E6E66E:=E:c d K d| j j v r t | j j d S d S )Nzcontent-length)r headersr r2 s r3 r z(StarletteRequestExtractor.content_lengthJ s4 t| 3 3 3t|+,<=>> >tr5 c | j j S r )r r r s r3 r z!StarletteRequestExtractor.cookiesQ s
|##r5 c K t d S | j d {V | j d {V S r ) multipartr bodyr r s r3 r z StarletteRequestExtractor.formU s_ 4 l !!!!!!!!!\&&(((((((((r5 c Z t | j j d S )Nz content-type)r r r r r s r3 is_jsonz!StarletteRequestExtractor.is_jsonb s# $T\%9%=%=n%M%MNNNr5 c p K | sd S | j d {V S r )r r r r s r3 r z StarletteRequestExtractor.jsonf sA ||~~ 4\&&(((((((((r5 )
r@ rA rB __doc__r r4 r r r r r r r rE r5 r3 r r s
G
0 0 0 d $ $ $ ) ) )O O O) ) ) ) )r5 r c d}|dk r.|j d }|rt | pd}n|dk r{|j d }|j D ]f}| |j }|d t
j k r4|dk r t |d d pd} n|dk r |j } ng|st }t }n
t | }| || d S )Nr, r' r( routerr )source) rd r r routesmatchesr" FULLpath_DEFAULT_TRANSACTION_NAMEr r set_transaction_name) rd r1 r namer' r routematchr
s r3 r r n s
DJ&&=$$Z00 =,X66<"D e # # x(] EMM'-00EQx5:%%$
224U1Xj5IJJPbDE&%// :DE 5()!"34 tF 33333r5 )F)Q
__future__r r r r r sentry_sdk._compatr sentry_sdk._typesr sentry_sdk.constsr sentry_sdk.hubr r sentry_sdk.integrationsr
r $sentry_sdk.integrations._wsgi_commonr r
sentry_sdk.integrations.asgir sentry_sdk.tracingr r sentry_sdk.utilsr r r r r typingr r r r r sentry_sdk.scoper SentryScoper+ r r8 starlette.applicationsr starlette.datastructuresr starlette.middlewarer #starlette.middleware.authenticationr starlette.requestsr! starlette.routingr" starlette.typesr# r$ StarletteScoper% r starlette.middleware.exceptionsr& starlette.exceptionsr r r/ r* rt r r r r r: r; r r< r= r r rE r5 r3 r. s. & & & & & & ( ( ( ( ( ( + + + + + + 8 8 8 8 8 8 8 8 = = = = = = = = > = = = = = I I I I I I I I 6??????????????555555
5::::::000000333333////// +*****''''''OOOOOOOOOOOOO 5 5 5
,3
4
4459CCCCCCC 9 9 9888888889 III 8 . ; @< < < ~ ( ( ( ( EE EE EEP & & &FJ J J&6 6 6:2 2 22 gB gB gBT&@ &@ &@Rk) k) k) k) k) k) k) k)\ 4 4 4 4 4s0 2:B- -B>C CCC C*)C*