File: //opt/alt/python35/lib/python3.5/site-packages/sentry_sdk/__pycache__/client.cpython-35.pyc
��\�! � @ s� d d l Z d d l Z d d l Z d d l m Z d d l m Z m Z d d l m Z m Z m
Z
m Z m Z m
Z
m Z m Z d d l m Z d d l m Z m Z d d l m Z d d l m Z e d � Z d
d � Z Gd d
� d
e � Z d S)� N)�datetime)� string_types� text_type)�strip_event_mut�flatten_metadata�
convert_types�
handle_in_app�
get_type_name�capture_internal_exceptions�current_stacktrace�logger)�make_transport)�DEFAULT_OPTIONS�SDK_INFO)�setup_integrations)�
ContextVarZclient_init_debugc O sN | rF t | d t � s) | d d k rF | d } | d d � } n d } t t � } t | | � } | d k r� | j d � d k r� | | d <xC | j � D]5 \ } } | | k r� t d | f � � | | | <q� W| d d k r� t j j d � | d <| d d k r$t j j d � | d <| d d k rJt j j d � | d <| S)
Nr � �dsnzUnknown option %rZ
SENTRY_DSN�releaseZSENTRY_RELEASE� environmentZSENTRY_ENVIRONMENT) �
isinstancer �dictr �get�items� TypeError�os�environ)�args�kwargsr �rv�options�key�value� r# �
/client.py� get_options! s& )
!
r% c @ s� e Z d Z d Z d d � Z e d d � � Z d d � Z d d � Z d
d d � Z d
d
d
d � Z
d
d
d d � Z d
d
d d � Z d d � Z
d d � Z d
S)�Clientz�The 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 j d � } z� t | | � | _ } t j | d � t | � | _ d } | d | k rs t d j | � � � t | d d
| d �| _
Wd t j | � Xd S)
NF�debug�always�never�small�medium�request_bodiesz3Invalid value for request_bodies. Must be one of {}� integrationsZ
with_defaultsZdefault_integrations)r( r) r* r+ ) �_client_init_debugr r% r �setr
� transport�
ValueError�formatr 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 )r3 r# r# r$ r \ s z
Client.dsnc C s- | j d � d k r% t j � | d <| d k rS | j | | � } | d k rS d S| j d r� d | k r� d | k r� d | k r� t � �1 d t | j d � d d d d
i g | d <Wd QRXxS d D]K } | j | � d k r� | j | d k r� t | j | � j � | | <q� W| j d � d k r[t t
� } t | j j
� � | d <| | d <| j d � d k rzd | d <t | | j d | j d � } | d k r�t | � } t | � t | � } | j d } | d k r)d } t � � | | | � } Wd QRX| d k r#t j d | � | } | S)NZ timestampZattach_stacktrace� exceptionZ
stacktrace�threadsZ with_localsZcrashedF�currentTr r � server_name�distZsdkr- �platform�pythonZin_app_excludeZin_app_include� before_sendz before send dropped event (%s))r r r8 r9 )r r ZutcnowZapply_to_eventr r
r r �stripr r �sortedr- �keysr r r r r �info)r3 �event�hint�scoper! Zsdk_infor< Z new_eventr# r# r$ �_prepare_eventa sL
(!
zClient._prepare_eventc C s� | j d � } | d k r d St | d � } d | d j | f } xZ | j d D]K } t | t � r� | | k s� | | k r� d SqT t | d | � rT d SqT Wd S)N�exc_infoFr z%s.%s�
ignore_errorsT)r r �
__module__r r r �
issubclass)r3 rA rB rE Z type_nameZ full_nameZerrclsr# r# r$ �_is_ignored_error� s zClient._is_ignored_errorNc C sd | d k r | j r d S| j d d k rJ t j � | j d k rJ d S| j | | � r` d Sd S)NFZ sample_rateg �?T)�_should_capturer �randomrI )r3 rA rB rC r# r# r$ rJ � s zClient._should_capturec C s� | j d k r d S| d k r% i } | j d � } | d k rW t j � j | d <} | j | | | � sp d S| j | | | � } | d k r� d S| j 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)r0 r �uuidZuuid4�hexrJ rD �
capture_event)r3 rA rB rC r r# r# r$ rN � s zClient.capture_eventc C s? | j d k r; | j d | d | � | j j � d | _ d S)z|
Close the client and shut down the transport. Arguments have the same
semantics as `self.flush()`.
N�timeout�callback)r0 �flush�kill)r3 rO rP r# r# r$ �close� s
z Client.closec C sE | j d k rA | d k r( | j d } | j j d | d | � d S)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_timeoutrO rP )r0 r rQ )r3 rO rP r# r# r$ rQ � s
z Client.flushc C s | S)Nr# )r3 r# r# r$ � __enter__� s zClient.__enter__c C s | j � d S)N)rS )r3 �exc_type� exc_value�tbr# r# r$ �__exit__ s zClient.__exit__)�__name__rG � __qualname__�__doc__r4 �propertyr rD rI rJ rN rS rQ rT rX r# r# r# r$ r& ? s ?
r& ) r rL rK 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 r. r% �objectr& r# r# r# r$ �<module> s :