J <
d dl mZ d dlZd dlZd dlZd dlZd dlZd dlmZmZ d dl m
Z
d dl m Z m
Z
mZmZ d dlmZ d dlmZmZmZ d dlmZ erRd d lmZ d d
lmZ d d lmZ d d lm Z d d
lm Z d dlm Z d dlm Z d dlm Z d dlm!Z! d dl"m#Z# d dl"m$Z$ d dlm%Z%m&Z& e e' Z( d dl)m*Z* n# e+$ r d dl,m*Z* Y nw xY w G d de- Z.d dZ/ G d de. Z0 G d d e. Z1d Z2dS ) )print_functionN)datetime timedelta) defaultdict)Dsnloggercapture_internal_exceptions
json_dumps)BackgroundWorker)EnvelopeItem
PayloadRef)
TYPE_CHECKING)Any)Callable)Dict)Iterable)Optional)Tuple)Type)Union) DefaultDict) PoolManager) ProxyManager)Event EndpointType)
getproxiesc T e Zd ZdZdZ d dZd Zd Z d dZd Z d dZ
d Z d
Z dS )
TransportzWBaseclass for all transports.
A transport is used to send an event to sentry.
Nc ~ || _ |r,|d $|d r t |d | _ d S d | _ d S )Ndsn)optionsr
parsed_dsn)selfr" s f/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/sentry_sdk/transport.py__init__zTransport.__init__2 sG #wu~1gen1 !'%. 1 1DOOO "DOOO c t )zm
This gets invoked with the event dictionary when an event should
be sent to sentry.
NotImplementedErrorr$ events r%
capture_eventzTransport.capture_event< s "###r' c t )a$
Send an envelope to Sentry.
Envelopes are a data container format that can hold any type of data
submitted to Sentry. We use it for transactions and sessions, but
regular "error" events should go through `capture_event` for backwards
compat.
r) )r$ envelopes r% capture_envelopezTransport.capture_envelopeF s "###r' c dS )z=Wait `timeout` seconds for the current events to be sent out.N r$ timeoutcallbacks r% flushzTransport.flushT s
r' c dS )z Forcefully kills the transport.Nr2 r$ s r% killzTransport.kill] s
r' c dS )zVThis increments a counter for event loss by reason and
data category.
Nr2 )r$ reason
data_categoryitems r% record_lost_eventzTransport.record_lost_eventb s tr' c dS )NTr2 r8 s r%
is_healthyzTransport.is_healthyn tr' c R | d S # t $ r Y d S w xY wN)r9 Exceptionr8 s r% __del__zTransport.__del__r s: IIKKKKK DD s
&&rC NN)
__name__
__module__ __qualname____doc__r# r& r- r0 r6 r9 r> r@ rE r2 r' r% r r * s
J # # # #$ $ $ $ $ $"
r' r c # p K |t j }| d D ]} | dd \ }}}|t t | z }|r| d pdD ]}||fV r# t t f$ r Y w xY wd S )N,: seconds;rC )r utcnowsplitstripr int LookupError
ValueError)headernowlimit retry_after
categories_categorys r% _parse_rate_limitsr_ z s
{o c"" ). )<) z HttpTransport.record_lost_event s | 12 F .M ,, t~~ / /005A
" 899 9 }f 4555A55555r' c |j d }|r=t j d | j t
| d S |j dk r\t j d t j t | j | pd z | j d < d S d S )Nzx-sentry-rate-limitsz%Rate-limited via x-sentry-rate-limits zRate-limited via 429< rO )
headersgetr warningro updater_ statusr rR r rs get_retry_after)r$ responserX s r% _update_rate_limitsz!HttpTransport._update_rate_limits s
!%%&<== NB C C C ' '(:6(B(B C C C C C
_
#
# N1 2 2 2)1 ):):Y 33H==C> > > *D & & & $
#r' storec H fd}| t j j t j d j dt j | || }n/# t $ r" d |d w xY w
| |j dk r d nn|j d k s |j d
k rXt j
d |j |j d |j |d | d S # | w xY w)
Nc | d d S j D ]} | | d S )Nerrorr< r= )r> items)r; r= r/ r$ s r% record_lossz0HttpTransport._send_request..record_loss s_ &&vW&EEEEE $N > >D**6*====> >r' )z
User-Agentz
X-Sentry-AuthPOST)bodyr network
network_errorr
status_429i, z%Unexpected status code: %s (body: %s)z status_{})r strrn client to_headerrx request get_api_urlrD on_dropped_eventr r r r dataformatclose)r$ r r
endpoint_typer/ r r s ` ` r%
_send_requestzHttpTransport._send_request s > > > > > > !$*"3 4 4!$TZ%9%9%;%;!z>HttpTransport._fetch_pending_client_report..# s> ) ) ) .Xv $ $*xXVV) ) )r' ) timestampdiscarded_events)json
client_report)type) r" rv ru rt r rU r
r r )r$ forceintervalr s r% _fetch_pending_client_reportz*HttpTransport._fetch_pending_client_report s | 12 4 6x9OOO4 1!,S!1!1 (, % 4 !%) )
. 3 3 5 5 ) ) )
!
r' c | |d }|&| t |g d S d S )Nr )r r )r )r r0 r )r$ r r s r% _flush_client_reportsz#HttpTransport._flush_client_reports/ sP 99PR9SS
$ ! !(- "A"A"A B B B B B % $r' c : fd} || p
|d S )Nc n j | }|d uo|t j k S rC )ro r r rR )buckettsr$ s r% _disabledz0HttpTransport._check_disabled.._disabled7 s5 %))&11BT>z1HttpTransport._is_rate_limited..@ s/ RRb2)))RRRRRRr' )anyro valuesr8 s r% _is_rate_limitedz HttpTransport._is_rate_limited> s. RRD4H4O4O4Q4QRRRRRRr' c 4 | j S rC )rl fullr8 s r% _is_worker_fullz HttpTransport._is_worker_fullB s | """r' c T | p| S rC )r r r8 s r% r@ zHttpTransport.is_healthyF s( ((**Ed.C.C.E.EFFr' c | d r.| d | dd d S t j }t j |d 5 }| t | d d d n # 1 swxY w Y | j J t j d| d pd d
| d pd d | d
pd d| j j
d| j j
| | ddd d S )Nr self_rate_limitsratelimit_backoffr wfileobjmodezSending event, type:r nullz level:levelz
event_id:event_idz project:z host:zapplication/jsongzipz Content-TypezContent-Encoding)r )r r r> ioBytesIOr GzipFilewriter
r# r debugr
project_idhostr getvalue)r$ r, r fs r% _send_eventzHttpTransport._send_eventJ s
( ( ! !"4 5 5 5 " "#6g " N N N4z||
]4c
2
2
2 'a
GGJu%% & & & ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' *** &!!+V++ '"",f,, *%%///***$$
MMOO%7VTT
ts -#B B #B c g }|j D ]g}| |j r6|j dv r| d | d| R| | ht
|j | }|j sd S | d }||j | t j
}t j |d 5 }|
| d d d n # 1 swxY w Y | j J t j d
|j | j j | j j | | d d d
d| d S )N) transactionr defaultr r r )r r )r r r z(Sending envelope [%s] project:%s host:%sz application/x-sentry-enveloper r r/ )r r r/ )r r r< r r> appendr r r r r r r serialize_intor# r r descriptionr r r r )r$ r/ new_itemsr= client_report_itemr r s r% _send_envelopez HttpTransport._send_envelopei s N ' 'D##D$677
'%)LLL))*<===&&':&FFFF &&&& H$4IFFF~ 4 " > > > K K ) N ! !"4 5 5 5z||
]4c
2
2
2 'a # #A & & & ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' *** 6 O & O
MMOO ?$* %
ts ,DDDc 4 dd|pt j dS )NrN
CERT_REQUIRED) num_pools cert_reqsrh )certifiwhere)r$ rh s r% _get_pool_optionsz HttpTransport._get_pool_options s' ( 3GMOO
r' c t d }|sdS | d D ]M}| }|j | s|j | r dS NdS )NnoFrL T)r r rS rT r endswithnetloc)r$ r# no_proxyr s r% _in_no_proxyzHttpTransport._in_no_proxy s <<##D)) 5 NN3'' D::<-> OL$NZ\\5E5Eg5N5NE N*** Mx<#LJLL4D4DV4L4LE%%h// /
6(5_% ((
;"&GGGGGGG" &+ON ] # 7,,U;;d;;;".66666 +E::T:::&.... .s 3B: :!C C c j j fd} j | s. d dd d S d S )Nc 5 t 5 d d d n # 1 swxY w Y d d d d S # 1 swxY w Y d S rC )r r r )r, hubr$ s r% send_event_wrapperz7HttpTransport.capture_event..send_event_wrapper s
1
1022 1 1$$U+++..0001 1 1 1 1 1 1 1 1 1 1 1 1 1 1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
13 A!*A A! A
A!A
A!!A%(A%
full_queuequeue_overflowr r )rz currentrl submitr r> )r$ r, r r s `` @r% r- zHttpTransport.capture_event s l" 1 1 1 1 1 1 1 |""#566 L ! !, / / / " "#37 " K K K K K L Lr' c j j fd} j | s6 d j D ]} d| d S d S )Nc 5 t 5 d d d n # 1 swxY w Y d d d d S # 1 swxY w Y d S rC )r r r )r/ r r$ s r% send_envelope_wrapperz=HttpTransport.capture_envelope..send_envelope_wrapper s
1
1022 1 1''111..0001 1 1 1 1 1 1 1 1 1 1 1 1 1 1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1r r r r )rz r rl r r r r> )r$ r/ r r= r s `` @r% r0 z HttpTransport.capture_envelope s l" 1 1 1 1 1 1 1 |""#899 D ! !, / / /
D
D&&'7d&CCCC D D
D
Dr' c t j d |dk r: j fd j || d S d S )NzFlushing HTTP transportr c 0 d S )NT)r )r r8 s r% z%HttpTransport.flush..
s (B(B(B(N(N r' )r r rl r r6 r3 s ` r% r6 zHttpTransport.flush sd ./// Q;; L N N N N O O O L w 1 1 1 1 1 ;r' c ` t j d | j d S )NzKilling HTTP transport)r r rl r9 r8 s r% r9 zHttpTransport.kill s- -... r' rF )r N)Fr )FrC )rG rH rI rJ r& r> r r r r r r r r r@ r r r r rw r- r0 r6 r9 r2 r' r% ra ra s %% B
B B B B, . 7 7 7 7 r
>C C C C 6 6 6S S S# # #G G G >4 4 4l
-/ -/ -/^L L L"D D D*
2
2
2
2 r' ra c e Zd Zd Zd ZdS )_FunctionTransportc H t | || _ d S rC )r r& _func)r$ funcs r% r& z_FunctionTransport.__init__ s# 4
r' c 0 | | d S rC )r r+ s r% r- z _FunctionTransport.capture_event s
5tr' N)rG rH rI r& r- r2 r' r% r r s2 r' r c | d }|t }nbt |t r|S t |t rt |t r|}n t | rt
| S | d r || S d S )N transportr! )ra
isinstancer r
issubclasscallabler )r"
ref_transport
transport_clss r% make_transportr & s K(M %
M9 - - 1 M4 ( ( 1Z
y-Q-Q 1%
- 1!-000 u~ & }W%%% 4r' rC )3
__future__r r rp r r ru r r collectionsr sentry_sdk.utilsr r r r
sentry_sdk.workerr sentry_sdk.enveloper r
r sentry_sdk._typesr typingr r r r r r r r r urllib3.poolmanagerr r r r r DataCategoryurllib.requestr r urllibobjectr r_ ra r r r2 r' r% r* s % % % % % % ( ( ( ( ( ( ( ( # # # # # # Q Q Q Q Q Q Q Q Q Q Q Q . . . . . . : : : : : : : : : : + + + + + + ! """"""//////00000055555555C=L"))))))) " " "!!!!!!!!"M M M M M M M M` J J J J J I J J J Z
s B' ' B54B5