xjf/
d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl m
Z
m Z d dl m
Z
d dlZe
rd dl mZmZmZmZmZ d dlmZ d dlmZmZ d dlmZ ej d Zd Z d
Z G d d Z d d
l m Z d dl!m"Z"m#Z#m$Z$ d dl%m&Z& dZ'dZ(dZ)dZ*dZ+ e,d e e-e+. e+/ D Z0 G d de& Z1n
# e2$ r dZ Y nw xY w d"d Z3d#d!Z4dS )$ N)chainproduct)
TYPE_CHECKING)AnyCallableDictOptionalSelf)Envelope)capture_internal_exceptions env_to_bool)logger spotlightz http://localhost:8969/streamz(sentry_sdk.spotlight.SpotlightMiddlewarec 2 e Zd ZdZdZdZdeddfdZd d
ZdS ) SpotlightClientaY
A client for sending envelopes to Sentry Spotlight.
Implements exponential backoff retry logic per the SDK spec:
- Logs error at least once when server is unreachable
- Does not log for every failed envelope
- Uses exponential backoff to avoid hammering an unavailable server
- Never blocks normal Sentry operation
g ?g N@urlreturnNc j || _ t j | _ | j | _ d| _ d S )N )r urllib3 PoolManagerhttpINITIAL_RETRY_DELAY _retry_delay_last_error_time)selfr s EC:\Projects\Historical\venv\Lib\site-packages\sentry_sdk/spotlight.py__init__zSpotlightClient.__init__0 s2 ')) 4'* enveloper c ` | j dk r(t j | j z
}|| j k rd S t j }| | | j | j | dddi }|
| j | _ d| _ d S # t $ rf}t j | _ t | j dz | j | _ t j d| j || j Y d }~d S d }~ww xY w) Nr POST Content-Typez application/x-sentry-envelope)r bodymethodheadersr zNFailed to send envelope to Spotlight at %s: %s. Will retry after %.1f seconds.)r timer ioBytesIOserialize_intor requestr getvaluecloser ExceptionminMAX_RETRY_DELAY
sentry_loggerwarning)r r time_since_errorr$ reqes r capture_envelopez SpotlightClient.capture_envelope6 sQ 1 $ $ #y{{T-B B $"333z|| %%% )##H]]__ "$C $ C
IIKKK $ 8D $'D ! ! !
$(IKKD ! !$D$5$94;O P PD
!1!
s A B= =
D-AD((D-)r r r N) __name__
__module__ __qualname____doc__r r1 strr r7 r r r r ! sa O+C +D + + + + $ $ $ $ $ $r r )settings) HttpRequest HttpResponseHttpResponseServerError)MiddlewareMixinz/assets/main.jsz
z
zcharset=r$ c # f K | ],}d d | V -dS )z N)formatjoin).0charss r rI m sL ) ) rwwu~~&&) ) ) ) ) )r c e Zd ZU dZded< dZded< d fd
Zedd Z ddZ ddd d
de
d dfdZ xZ S )SpotlightMiddlewareN
Optional[str]_spotlight_script_spotlight_urlr r
get_responseCallable[..., HttpResponse]r c * t | dd l}|j | _ | j j }|t j d d S t j
|j d | _
d S )Nr zPCannot find Spotlight client from SpotlightMiddleware, disabling the middleware.z../)superr sentry_sdk.apiapi
sentry_sdk
get_clientr r2 r3 urllibparseurljoinr rN )r rO rU spotlight_client __class__s r r z SpotlightMiddleware.__init__v s GG \ * * * ! ! ! ! (nDO # 9 9 ; ; E ' %f t"(,"6"67G7KU"S"SD r c | j | j t j | j t
}t j |d }t j | t
| j | | _ n8# t j j $ r!}t j d|| Y d }~nd }~ww xY w| j S )NHEAD)r% )
spotlight_urlspotlight_js_urlzUCannot get Spotlight JS to inject at %s. SpotlightMiddleware will not be very useful.)exc_info)rN rM rW rX rY SPOTLIGHT_JS_ENTRY_PATHr, Requesturlopen SPOTLIGHT_JS_SNIPPET_PATTERNrE errorURLErrorr2 debug)r r_ r5 errs r spotlight_scriptz$SpotlightMiddleware.spotlight_script s ".43I3Q'-|';'; +-D( ($ !.00( % 1 C N**3///-I-P-P&*&9)9 .Q . .D** |, !'o(!$ ) )s BB! !C5CC_requestr? responser@ Optional[HttpResponse]c t d j dd d D }|d }t | dk rC|d t r#|d t t d nd| j j s|dk rt j
}| j }t d fd
t D D | }j
d | |z j
|d z _
d r|t | z j d < S ) Nc 3 > K | ]}| V d S N)strip)rG ps r rI z7SpotlightMiddleware.process_response.. s> ( ( ( ( ( ( ( (r r# rD ;r utf-8z text/htmlc 3 & K | ] }|d k |V
dS )Nr= )rG idxs r rI z7SpotlightMiddleware.process_response.. s8 88
$888
r c 3 r K | ]1}j | V 2d S ro )contentrfindencode)rG body_variantencodingrk s r rI z7SpotlightMiddleware.process_response.. sV $ $ , % , 2 2<3F3Fx3P3P Q Q$ $ $ $ $ $r zContent-Length)tupler& getlowersplitlen
startswithCHARSET_PREFIXri streamingry r{ next BODY_CLOSE_TAG_POSSIBILITIES
has_header) r rj rk content_type_header content_typecontent_length injectioninjection_siter} s ` @r process_responsez$SpotlightMiddleware.process_response s #( ( (!)--nbAAGGIIOOPSTT( ( ( # # /q1L&''!++0CA0F0Q0Q 1 1+ /q1#n2E2E2G2GH" %1 * 2 K//!$X%5!6!6 1 8 8 B B !% $ $ $ $ $0L$ $ $ #
"
" $_n_5 &~78 &&'788 Y9G#i..9XH$%56Or exceptionz!Optional[HttpResponseServerError]c t j r| j sd S t j | j d }| j | }t | dt
| j | S # t j j $ r Y d S w xY w)Nrt z)r^ event_id)r> DEBUGrN rW r, rc readdecoderU capture_exceptionrA replace SPOTLIGHT_ERROR_PAGE_SNIPPETrE re rf )r rj r r r s r process_exceptionz%SpotlightMiddleware.process_exception s >
)<
t
N**4+>??DDFFMMgVV ?<G
0 r rK spotlight_configr r2 r rL c R t j d }d}d}|rt |d }|d}|}n|}| du r|r |j d dS | du r |r|S t
S t
| t r |r|| k r |j d| | | S |
|r|S |rt
S dS )a
Resolve the Spotlight URL based on config and environment variable.
Implements precedence rules per the SDK spec:
https://develop.sentry.dev/sdk/expected-features/spotlight/
Returns the resolved URL string, or None if Spotlight should be disabled.
SENTRY_SPOTLIGHTNT)strictFzhSpotlight is disabled via spotlight=False config option, ignoring SENTRY_SPOTLIGHT environment variable.z`Spotlight URL from config (%s) takes precedence over SENTRY_SPOTLIGHT environment variable (%s).)osenvironr r
r3 DEFAULT_SPOTLIGHT_URL
isinstancer< )r r2 spotlight_env_valuespotlight_from_envspotlight_env_urlparseds r _resolve_spotlight_urlr s0 *..);<< ,0)- ( 0>>> >!% 3 !' 5 !M !B
t T ! ! )$ $( ( $c * * ) #6:J#J#J !M !> #
! )$ $
)( ( 4r optionsDict[str, Any]Optional[SpotlightClient]c t | d t }|d S t j t
j }| t j d t
| t t j || d< t 5 t t j rt! t" j dd rt! t" j dd ret j }t( |vrP t+ | t- |t( f t _ t d d d d n # 1 swxY w Y t1 | }t d| |S )Nr z' [spotlight] %(levelname)s: %(message)sSENTRY_SPOTLIGHT_ON_ERROR1SENTRY_SPOTLIGHT_MIDDLEWAREz(Enabled Spotlight integration for Djangoz%Enabled Spotlight using sidecar at %s)r r r2 logging
StreamHandlersysstderr setFormatter Formatterr
addHandlersetLevelINFOr r> r r
r r
MIDDLEWARE DJANGO_SPOTLIGHT_MIDDLEWARE_PATHtyper infor )r r _handler
middlewareclients r setup_spotlightr ' s
[!9!9=
I
IC
{t $SZ00H '+,UVVWWW
h
OOGL!!! GK $ & & H H
!BJNN+F L LMM
! BJNN+H# N NOO
!
",J/zAA&6d:&6&6*'G&IJJ' '# FGGG H H H H H H H H H H H H H H H S
!
!F
KK7=== Ms CF""F&)F&)r r r2 r r rL )r r r r )5r) r r r r( urllib.errorrW urllib.parseurllib.request itertoolsr r typingr r r r r r r
sentry_sdk.enveloper sentry_sdk.utilsr r
r r2 getLoggerr r r django.confr> django.httpr? r@ rA django.utils.deprecationrB ra rd r r
BODY_TAG_NAMEr~ zipupperr r rK ImportErrorr r r= r r r s
$ $ $ $ $ $ $ $ ;:::::::::::::: ( ( ( ( ( (
; ' ' 7 #M 9 9 9 9 9 9 9 9xH$$$$$$NNNNNNNNNN888888 / Q !
{ ! NM#(5 ) ) Wcc-"5"5"7"7 9L9L9N9N O OP) ) ) $ $
p p p p po p p p pd HHH<<,1<< < < <~ s 9A4C. .C87C8