��\�2 � @ sj d d l Z d d l Z d d l Z d d l m Z d d l m Z d d l m Z d d l m Z d d l
m Z d d l m
Z
d d l m Z m Z m Z m Z d d
� Z e d � Z d a d d
� Z Gd d � d e � Z d d � Z Gd d � d e � Z Gd d � d e � Z Gd d � d e � Z Gd d � d e e � � Z e � Z e j e � d S)� N)�datetime)�contextmanager)�warn)�with_metaclass)�Scope)�Client)�exc_info_from_error�event_from_exception�logger�
ContextVarc C s | S)N� )�xr r �/hub.py�overload s r Zsentry_current_hubc C s! t j j } | s d S| j d S)NFZsend_default_pii)�Hub�current�client�options)r r r r �_should_send_default_pii( s r c @ s4 e Z d Z d d � Z d d � Z d d � Z d S)�
_InitGuardc C s
| | _ d S)N)�_client)�selfr r r r �__init__1 s z_InitGuard.__init__c C s | S)Nr )r r r r � __enter__4 s z_InitGuard.__enter__c C s# | j } | d k r | j � d S)N)r �close)r �exc_type� exc_value�tb�cr r r �__exit__7 s z_InitGuard.__exit__N)�__name__�
__module__� __qualname__r r r r r r r r 0 s r c O sJ t | | � } t j j | � t | � } | d k rF t j | � a | S)zsInitializes the SDK and optionally integrations.
This takes the same arguments as the client constructor.
N)r r r � bind_clientr �weakref�ref�_initial_client)�args�kwargsr �rvr r r �init= s r* c @ s4 e Z d Z e d d � � Z e d d � � Z d S)�HubMetac C s8 t j d � } | d k r4 t t � } t j | � | S)z(Returns the current instance of the hub.N)�_local�getr �
GLOBAL_HUB�set)r r) r r r r L s
zHubMeta.currentc C s t S)z%Returns the main instance of the hub.)r. )r r r r �mainV s z HubMeta.mainN)r r! r" �propertyr r0 r r r r r+ K s
r+ c @ s( e Z d Z d d � Z d d � Z d S)� _HubManagerc C s t j | _ t j | � d S)N)r r �_oldr, r/ )r �hubr r r r ] s z_HubManager.__init__c C s t j | j � d S)N)r, r/ r3 )r r r r r r r r a s z_HubManager.__exit__N)r r! r" r r r r r r r2 \ s r2 c @ s4 e Z d Z d d � Z d d � Z d d � Z d S)�
_ScopeManagerc C s/ | | _ t | j � | _ | j d | _ d S)N� ���)�_hub�len�_stack�
_original_len�_layer)r r4 r r r r f s z_ScopeManager.__init__c C s# | j d } | d k s t � | S)Nr6 )r< �AssertionError)r �scoper r r r k s
z_ScopeManager.__enter__c C s t | j j � } | | j k r< t j d | j | � d S| | j k rx t j d | | j | j j | j d � � | j j | j d } | j j | j d d � =| d | j d k r� t j d | d | j d � n* | d | j d k r d } t j | � d S)Nz1Scope popped too soon. Popped %s scopes too many.zLeaked %s scopes: %sr6 z2Wrong scope found. Meant to pop %s, but popped %s.r z�init() called inside of pushed scope. This might be entirely legitimate but usually occurs when initializing the SDK inside a request handler or task/job function. Try to initialize the SDK as early as possible instead.)r9 r8 r: r; r
�error�warningr< )r r r r Z current_lenZlayerr@ r r r r q s*
z_ScopeManager.__exit__N)r r! r" r r r r r r r r5 e s r5 c @ s] e Z d Z d Z d Z d d d d � Z d d � Z d d � Z d d
� Z d d � Z e
d
d � � Z d d � Z d d � Z
d d d � Z d d d � Z d d d � Z d d � Z d d d d � Z e d d � � Z e d d � � Z d d d � Z e Z d! d" � Z e d# d$ � � Z e d% d$ � � Z d d& d$ � Z d d d' d( � Z d S))r z�The hub wraps the concurrency management of the SDK. Each thread has
its own hub but the hub might transfer with the flow of execution if
context vars are available.
If the hub is used with a with statement it's temporarily activated.
Nc C s� t | t � rF | } | j d \ } } | d k rL t j | � } n | } | d k ra t � } | | f g | _ d | _ g | _ d S)Nr6 r7 )�
isinstancer r: �copyr �_last_event_id� _old_hubs)r Z
client_or_hubr> r4 r Z other_scoper r r r � s z Hub.__init__c C s$ | j j t j � t j | � | S)N)rD �appendr r r, r/ )r r r r r � s
z
Hub.__enter__c C s | j j � } t j | � d S)N)rD �popr, r/ )r r r r �oldr r r r � s z Hub.__exit__c C s | � | � SWd QRXd S)z~Runs a callback in the context of the hub. Alternatively the
with statement can be used on the hub directly.
Nr )r �callbackr r r �run� s zHub.runc C s� t | t � r | } n' | j d k r3 | j } n t d � � | j d d } | d k r~ | j j | � } | d k r~ | St } | d k r� | � } | d k r� | | k r� | j j | � d k r� d | f } t t | � d d �t
j | � d S) a Returns the integration for this hub by name or class. If there
is no client bound or the client does not have that integration
then `None` is returned.
If the return value is not `None` the hub is guaranteed to have a
client attached.
NzIntegration has no namer6 r z�Integration %r attempted to run but it was only enabled on init() but not the client that was bound to the current flow. Earlier versions of the SDK would consider these integrations enabled but this is no longer the case.�
stacklevel� r7 ) rA �strZ
identifier�
ValueErrorr: Z integrationsr- r& r �Warningr
r@ )r Z
name_or_classZintegration_namer r) Zinitial_clientr@ r r r �get_integration� s(
zHub.get_integrationc C s | j d d S)z&Returns the current client on the hub.r6 r r7 )r: )r r r r r � s z
Hub.clientc C s | j S)zReturns the last event ID.)rC )r r r r �
last_event_id� s zHub.last_event_idc C s( | j d } | | d f | j d <d S)z Binds a new client to the hub.r6 Nr7 r7 )r: )r �new�topr r r r# � s
zHub.bind_clientc C sQ | j d \ } } | d k rM | j | | | � } | d k rI | | _ | Sd S)ak Captures an event. The return value is the ID of the event.
The event is a dictionary following the Sentry v7/v8 protocol
specification. Optionally an event hint dict can be passed that
is used by processors to extract additional information from it.
Typically the event hint object would contain exception information.
r6 Nr7 )r: �
capture_eventrC )r �event�hintr r> r) r r r rS � s zHub.capture_eventc C s> | j d k r d S| d k r% d } | j d | d | i � S)zyCaptures a message. The message is just a string. If no level
is provided the default level is `info`.
N�info�message�level)r rS )r rW rX r r r �capture_message s
zHub.capture_messagec C s� | j } | d k r d S| d k r4 t j � } n t | � } t | d | j �\ } } y | j | d | �SWn% t k
r� | j t j � � Yn Xd S)z�Captures an exception.
The argument passed can be `None` in which case the last exception
will be reported, otherwise an exception object or an `exc_info`
tuple.
NZclient_optionsrU ) r �sys�exc_infor r r rS � Exception�_capture_internal_exception)r r? r r[ rT rU r r r �capture_exception s
zHub.capture_exceptionc C s t j d d | �d S)zNCapture an exception that is likely caused by a bug in the SDK
itself.z Internal error in sentry_sdkr[ N)r
r? )r r[ r r r r] 1 s z Hub._capture_internal_exceptionc K sG | j d
\ } } | d k r0 t j d � d St | p< f � } | j | � | sY d St | pe f � } | j d � d k r� t j � | d <| j d � d k r� d | d <| } | j d d k r� | j d | | � } | d k r� | j j
| � n t j d | � | j d } x& t | j � | k rB| j j � q Wd S) z�Adds a breadcrumb. The breadcrumbs are a dictionary with the
data as the sentry v7/v8 protocol expects. `hint` is an optional
value that can be used by `before_breadcrumb` to customize the
breadcrumbs that are emitted.
r6 Nz*Dropped breadcrumb because no client boundZ timestamp�type�defaultZbefore_breadcrumbz)before breadcrumb dropped breadcrumb (%s)�max_breadcrumbsr7 )
r: r
rV �dict�updater- r Zutcnowr Z _breadcrumbsrE r9 �popleft)r ZcrumbrU r( r r> Zoriginal_crumbra r r r �add_breadcrumb6 s,
zHub.add_breadcrumbc C s d S)Nr )r r r r �
push_scope[ s zHub.push_scopec C s d S)Nr )r rH r r r rf ` s c
C sr | d k r0 | j � � } | | � Wd QRXd S| j d \ } } | t j | � f } | j j | � t | � S)z�Pushes a new layer on the scope stack. Returns a context manager
that should be used to pop the scope again. Alternatively a callback
can be provided that is executed in the context of the scope.
Nr6 r7 )rf r: rB rE r5 )r rH r> r Z new_layerr r r rf e s c C s( | j j � } | j s$ t d � � | S)zaPops a scope layer from the stack. Try to use the context manager
`push_scope()` instead.z"stack must have at least one layer)r: rF r= )r r) r r r �pop_scope_unsafex s zHub.pop_scope_unsafec C s d S)Nr )r r r r �configure_scope s zHub.configure_scopec C s d S)Nr )r rH r r r rh � s c s[ | j d \ � � | d k r9 � d k r5 | � � d St � � f d d � � } | � S)zReconfigures the scope.r6 Nc 3 s � d k r � Vn t � Vd S)N)r r )r r> r r �inner� s z"Hub.configure_scope.<locals>.innerr7 )r: r )r rH ri r )r r> r rh � s
c C s9 | j d \ } } | d k r5 | j d | d | � Sd S)zAlias for self.client.flushr6 N�timeoutrH r7 )r: �flush)r rj rH r r> r r r rk � s z Hub.flush)r r! r" �__doc__r: r r r rI rO r1 r rP r# rS rY r^ r] re r rf r> rg rh rk r r r r r � s0
) % r )!rZ rB r$ r �
contextlibr �warningsr Zsentry_sdk._compatr Zsentry_sdk.scoper Zsentry_sdk.clientr Zsentry_sdk.utilsr r r
r r r, r& r �objectr r* r_ r+ r2 r5 r r. r/ r r r r �<module> s, "
. � | Name | Type | Size | Permission | Actions |
|---|---|---|---|---|
| __init__.cpython-35.opt-1.pyc | File | 1.47 KB | 0644 |
|
| __init__.cpython-35.pyc | File | 1.47 KB | 0644 |
|
| _compat.cpython-35.opt-1.pyc | File | 2.54 KB | 0644 |
|
| _compat.cpython-35.pyc | File | 2.57 KB | 0644 |
|
| api.cpython-35.opt-1.pyc | File | 2.91 KB | 0644 |
|
| api.cpython-35.pyc | File | 2.91 KB | 0644 |
|
| client.cpython-35.opt-1.pyc | File | 6.53 KB | 0644 |
|
| client.cpython-35.pyc | File | 6.53 KB | 0644 |
|
| consts.cpython-35.opt-1.pyc | File | 911 B | 0644 |
|
| consts.cpython-35.pyc | File | 911 B | 0644 |
|
| debug.cpython-35.opt-1.pyc | File | 1.59 KB | 0644 |
|
| debug.cpython-35.pyc | File | 1.59 KB | 0644 |
|
| hub.cpython-35.opt-1.pyc | File | 12.04 KB | 0644 |
|
| hub.cpython-35.pyc | File | 12.14 KB | 0644 |
|
| scope.cpython-35.opt-1.pyc | File | 6.78 KB | 0644 |
|
| scope.cpython-35.pyc | File | 6.78 KB | 0644 |
|
| transport.cpython-35.opt-1.pyc | File | 5.86 KB | 0644 |
|
| transport.cpython-35.pyc | File | 5.86 KB | 0644 |
|
| utils.cpython-35.opt-1.pyc | File | 22.01 KB | 0644 |
|
| utils.cpython-35.pyc | File | 22.13 KB | 0644 |
|
| worker.cpython-35.opt-1.pyc | File | 3.34 KB | 0644 |
|
| worker.cpython-35.pyc | File | 3.34 KB | 0644 |
|