U
\! @ s d dl Z d dlZd dlZd dlmZ d dlmZmZ d dlmZm Z m
Z
m Z m Z m
Z
mZmZ d dlmZ d dlmZmZ d dlmZ d dlmZ ed Z d
d Z G d d
d
e Z dS ) N)datetime) string_types text_type)strip_event_mutflatten_metadata
convert_types
handle_in_app
get_type_namecapture_internal_exceptionscurrent_stacktracelogger)make_transport)DEFAULT_OPTIONSSDK_INFO)setup_integrations)
ContextVarZclient_init_debugc O s | r4t | d ts | d d kr4| d }| dd } nd }tt}t| |}|d k rh|dd krh||d< | D ]&\}}||krtd|f |||< qp|d d krtjd|d< |d d krtjd|d< |d d krtjd |d< |S )
Nr dsnzUnknown option %rZ
SENTRY_DSNreleaseZSENTRY_RELEASE environmentZSENTRY_ENVIRONMENT)
isinstancer dictr getitems TypeErrorosenviron)argskwargsr rvoptionskeyvalue r#
/client.py get_options! s&
r% c @ sl e Zd ZdZdd Zedd Zdd Zdd Zdd d Z dd
dZ
dddZ dddZ dd Z
dd Zd
S )ClientzThe client is internally responsible for capturing the events and
forwarding them to sentry through the configured transport. It takes
the client options as keyword arguments and optionally the DSN as first
argument.
c O s| t d}z`t|| | _}t |d t|| _d}|d |krRtd|t |d |d d| _
W 5 t | X d S ) NFdebug)alwaysneverZsmallZmediumrequest_bodiesz3Invalid value for request_bodies. Must be one of {} integrationsZdefault_integrations)Z
with_defaults) _client_init_debugr setr% r r
transport
ValueErrorformatr r+ )selfr r Z old_debugr r* r# r# r$ __init__F s"
zClient.__init__c C s
| j d S )z%Returns the configured DSN as string.r )r r1 r# r# r$ r \ s z
Client.dsnc C s | dd krt |d< |d k r:|||}|d kr:d S | jd rd|krd|krd|krt " t| jd ddd g|d< W 5 Q R X d
D ]6}| |d kr| j| d k rt| j| ||< q| d d krt t
}t | j
|d < ||d < | d
d krd|d
< t|| jd | jd }|d k rHt|}t| t|}| jd }|d k rd }t |||}W 5 Q R X |d krtd| |}|S )NZ timestampZattach_stacktraceZ exception
stacktraceZthreadsZ with_localsFT)r4 ZcrashedZcurrent)r r Z server_nameZdistZsdkr+ platformpythonZin_app_excludeZin_app_include before_sendz before send dropped event (%s))r r ZutcnowZapply_to_eventr r
r r stripr r sortedr+ keysr r r r r info)r1 eventhintscoper! Zsdk_infor7 Z new_eventr# r# r$ _prepare_eventa s^
zClient._prepare_eventc C s~ | d}|d krdS t|d }d|d j|f }| jd D ]:}t|trd||ks\||krx dS q>t|d |r> dS q>dS )Nexc_infoFr z%s.%s
ignore_errorsT)r r
__module__r r r
issubclass)r1 r< r= r@ Z type_nameZ full_nameZerrclsr# r# r$ _is_ignored_error s
zClient._is_ignored_errorNc C sJ |d k r|j sdS | jd dk r6t | jd kr6dS | ||rFdS dS )NFZ sample_rateg ?T)_should_capturer randomrD )r1 r< r= r> r# r# r$ rE s zClient._should_capturec C sz | j dkrdS |dkri }|d}|dkr>t j |d< }| |||sPdS | |||}|dkrjdS | j | |S )a Captures an event.
This takes the ready made event and an optoinal hint and scope. The
hint is internally used to further customize the representation of the
error. When provided it's a dictionary of optional information such
as exception info.
If the transport is not set nothing happens, otherwise the return
value of this function will be the ID of the captured event.
NZevent_id)r. r uuidZuuid4hexrE r?
capture_event)r1 r< r= r> r r# r# r$ rI s
zClient.capture_eventc C s, | j dk r(| j||d | j d| _ dS )z|
Close the client and shut down the transport. Arguments have the same
semantics as `self.flush()`.
Ntimeoutcallback)r. flushkillr1 rK rL r# r# r$ close s
z Client.closec C s0 | j dk r,|dkr | jd }| j j||d dS )a{
Wait `timeout` seconds for the current events to be sent. If no
`timeout` is provided, the `shutdown_timeout` option value is used.
The `callback` is invoked with two arguments: the number of pending
events and the configured timeout. For instance the default atexit
integration will use this to render out a message on stderr.
NZshutdown_timeoutrJ )r. r rM rO r# r# r$ rM s
z Client.flushc C s | S Nr# r3 r# r# r$ __enter__ s zClient.__enter__c C s | d S rQ )rP )r1 exc_type exc_valuetbr# r# r$ __exit__ s zClient.__exit__)N)NN)NN)NN)__name__rB __qualname____doc__r2 propertyr r? rD rE rI rP rM rR rV r# r# r# r$ r& ? s
?
r& )!r rG rF r Zsentry_sdk._compatr r Zsentry_sdk.utilsr r r r r r
r r Zsentry_sdk.transportr
Zsentry_sdk.constsr r Zsentry_sdk.integrationsr r Z
ClientOptionsZScopeZAnyZDictZOptionalr, r% objectr& r# r# r# r$ <module> s (