]j- d dl mZ d dlZd dlZd dlZd dlZd dlmZmZ d dlm Z m
Z
m Z m Z d dl
mZ d dlmZ d dlmZ erLd dlmZ d d lmZ d d
lmZ d d lmZ d d lmZ d d
lmZ d dlmZ d dlmZ d dl m Z d dl m Z d dlm Z m Z ee! 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( Z* G d de( Z+d Z,dS ) )print_functionN)datetime timedelta)Dsnloggercapture_internal_exceptions
json_dumps)BackgroundWorker)Envelope)MYPY)Any)Callable)Dict)Iterable)Optional)Tuple)Type)Union) PoolManager) ProxyManager)Event EndpointType)
getproxiesc B e Zd ZdZdZ d dZd Zd Z d dZd 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 K/opt/imunify360/venv/lib64/python3.11/site-packages/sentry_sdk/transport.py__init__zTransport.__init__/ 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_event9 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_envelopeC s "###r# c dS )z=Wait `timeout` seconds for the current events to be sent out.N r timeoutcallbacks r! flushzTransport.flushQ s
r# c dS )z Forcefully kills the transport.Nr. r s r! killzTransport.killZ s
r# c R | d S # t $ r Y d S w xY wN)r5 Exceptionr4 s r! __del__zTransport.__del___ s: IIKKKKK DD s
&&r7 ) __name__
__module__ __qualname____doc__r r" r) r, r2 r5 r9 r. 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;r7 )r utcnowsplitstripr int LookupError
ValueError)headernowlimit retry_after
categories_categorys r! _parse_rate_limitsrR g s
{o c"" ). )<)<S!)D)D &KQ #k2B2B C C CCK & @:+;+;C+@+@ KG
,
, +++++
,Z( H
s A.B B32B3c h e Zd ZdZd Zd Z ddZd Zd Zd Z d Z
d
Z d Z d Z
d
Z ddZd ZdS )
HttpTransportzThe default HTTP transport.c ddl m} t | | | j J t | _ | j d|z | _ i | _ t j | _
|| _ | | j |d |d |d | _ ddlm} || _ d S ) Nr )VERSIONzsentry.python/%s
http_proxy https_proxyca_certs)rW rX rY )Hub)sentry_sdk.constsrV r r" r r
_workerto_auth_auth_disabled_untilurllib3utilRetry_retryr
_make_pool_pool
sentry_sdkrZ hub_cls)r r rV rZ s r! r" zHttpTransport.__init__y s .-----4)))***')) _,,-?'-IJJ
! l((** __ O |,
. Z( %
#""""" r# c 6 |j d }|r)| j t | d S |j dk rHt
j t | j
| pd z | j d < d S d S )Nzx-sentry-rate-limits < rB ) headersgetr_ updaterR statusr rE r rc get_retry_after)r responserK s r! _update_rate_limitsz!HttpTransport._update_rate_limits s
!%%&<== ' '(:6(B(B C C C C C
_
#
#)1 ):):Y 33H==C> > > *D & & & $
#r# storec < | t | j j t | j d | j dt | j | || } | | |j dk rn6|j dk s |j dk r t j d|j |j |
d S # |
w xY w)N)z
User-Agentz
X-Sentry-AuthPOST)bodyrk ri i, z%Unexpected status code: %s (body: %s))rm strr^ client to_headerre request get_api_urlrq rn r errordataclose)r ru rk
endpoint_typerp s r!
_send_requestzHttpTransport._send_request s" !$*"3 4 4!$TZ%9%9%;%;!<!<
:%%
&&}55 6 6 &
$ $X . . .#%% C''8?S+@+@ ; O M
NN HNN s
AD Dc : fd} || p
|d S )Nc n j | }|d uo|t j k S r7 )r_ rl r rE )buckettsr s r! _disabledz0HttpTransport._check_disabled.<locals>._disabled s5 %))&11BT><b8?+<+<&< <r# r. )r rQ r s ` r! _check_disabledz HttpTransport._check_disabled s; = = = = =
y""5iioo5r# c P | d rd S t j }t j |d 5 }| t
| d d d n # 1 swxY w Y | j J t j d|
d pdd|
d pdd |
d
pdd | j j d | j j
|
| d
dd d S )Nr| wfileobjmodezSending event, type:typenullz level:levelz
event_id:event_idz project:z host:zapplication/jsongzipz Content-TypezContent-Encoding)rk )r ioBytesIOr GzipFilewriter r r debugrl
project_idhostr getvalue)r r( ru fs r! _send_eventzHttpTransport._send_event s{
( ( 4z||
]4c
2
2
2 'a
GGJu%% & & & ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' *** &!!+V++ '"",f,, *%%///***$$
MMOO%7VTT
ts #A00A47A4c fd|j D |j d d < |j sd S t j }t j |d 5 }| | d d d n # 1 swxY w Y j J t j d|j j j
j j |
dddd d S )
Nc H g | ] } |j | S r. )r
data_category).0xr s r!
<listcomp>z0HttpTransport._send_envelope.<locals>.<listcomp> s>
T-A-A!/-R-R
r# r r z(Sending envelope [%s] project:%s host:%sz application/x-sentry-enveloper r r+ )rk r )itemsr r r r serialize_intor r r descriptionr r r r )r r+ ru r s ` r! _send_envelopez HttpTransport._send_envelope sR
~
qqq ~ 4z||
]4c
2
2
2 'a # #A & & & ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' *** 6 O & O
MMOO ?$* %
ts A33A7:A7c 4 dd|pt j dS )NrA
CERT_REQUIRED) num_pools cert_reqsrY )certifiwhere)r rY 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 )NnoFr? T)r rl rF rG r endswithnetloc)r r no_proxyr s r! _in_no_proxyzHttpTransport._in_no_proxy s <<##D)) 5 NN3'' D::<<D''--
1B1K1KD1Q1Q
tt
ur# c n d }| | }|j dk r,|dk r&|p#| o t d }|s,|dk r&|p#| o t d }| | }|rt j |fi |S t j di |S )Nhttps httpr. )r schemer rl r r` r r )r r rW rX rY proxyr optss r! rd zHttpTransport._make_pool" s $$Z00 ' '[B->-> OL$NZ\\5E5Eg5N5NE N*** Mx<#LJLL4D4DV4L4LE%%h// /'6666 6&.... .r# c f j j fd} j | 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 r7 )r r )r( hubr s r! send_event_wrapperz7HttpTransport.capture_event.<locals>.send_event_wrapperB s
,
,022 , ,$$U+++, , , , , , , , , , , , , , ,
,
,
,
,
,
,
,
,
,
,
,
,
,
,
,
,
,
,, A
5 A
9 A
9 A
AArg currentr\ submit)r r( r r s `` @r! r) zHttpTransport.capture_event< sS l" , , , , , , ,
./////r# c f j j fd} j | 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 r7 )r r )r+ r r s r! send_envelope_wrapperz=HttpTransport.capture_envelope.<locals>.send_envelope_wrapperP s
2
2022 2 2''1112 2 2 2 2 2 2 2 2 2 2 2 2 2 2
2
2
2
2
2
2
2
2
2
2
2
2
2
2
2
2
2
2r r )r r+ r r s `` @r! r, z HttpTransport.capture_envelopeJ sS l" 2 2 2 2 2 2 2
122222r# Nc t t j d |dk r | j || d S d S )NzFlushing HTTP transportr )r r r\ r2 r/ s r! r2 zHttpTransport.flushX sC ./// Q;; L w 1 1 1 1 1 ;r# c ` t j d | j d S )NzKilling HTTP transport)r r r\ r5 r4 s r! r5 zHttpTransport.killb s- -... r# )rr r7 )r: r; r< r= r" rq r r r r r r rd r) r, r2 r5 r. r# r! rT rT v s %% 2 * # # # # J6 6 6 : B
/ / /4 0 0 0 3 3 3" 2 2 2 2 r# rT c e Zd Zd Zd ZdS )_FunctionTransportc H t | || _ d S r7 )r r" _func)r funcs r! r" z_FunctionTransport.__init__i s# 4
r# c 0 | | d S r7 )r r' s r! r) z _FunctionTransport.capture_eventp s
5tr# N)r: r; r< r" r) r. r# r! r r h 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 )rT
isinstancer r
issubclasscallabler )r
ref_transport
transport_clss r! make_transportr x s K(M %
M9 - - 1 M4 ( ( 1Z
y-Q-Q 1%
- 1!-000 u~ & }W%%% 4r# r7 )-
__future__r r r` r r r r sentry_sdk.utilsr r r r sentry_sdk.workerr
sentry_sdk.enveloper sentry_sdk._typesr typingr
r r r r r r r urllib3.poolmanagerr r r r rw DataCategoryurllib.requestr ImportErrorurllibobjectr rR rT r r r. r# r! <module>r s % % % % % % ( ( ( ( ( ( ( ( Q Q Q Q Q Q Q Q Q Q Q Q . . . . . . ( ( ( ( ( ( " " " " " " ! //////00000055555555C=L"))))))) " " "!!!!!!!!"= = = = = = = =@ o o o o o I o o o d
s B B! B!