File: //opt/alt/python37/lib/python3.7/site-packages/sentry_sdk/__pycache__/transport.cpython-37.pyc
B
T a�0 � @ s� 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 e�rd 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"yd dl#m$Z$ W n" e%k
�r@ d dl&m$Z$ Y nX G dd� de'�Z(d dd�Z)G dd� de(�Z*G dd� de(�Z+d d � Z,dS ) � )�print_functionN)�datetime� timedelta)�Dsn�logger�capture_internal_exceptions�
json_dumps)�BackgroundWorker)�Envelope)�MYPY)�Any)�Callable)�Dict)�Iterable)�Optional)�Tuple)�Type)�Union)� PoolManager)� ProxyManager)�Event� EndpointType)�
getproxiesc @ sH e Zd ZdZdZddd�Zdd� Zdd� Zdd d
�Zd d � Z d
d� Z
dS )� TransportzWBaseclass for all transports.
A transport is used to send an event to sentry.
Nc C s8 || _ |r.|d d k r.|d r.t|d �| _nd | _d S )N�dsn)�optionsr �
parsed_dsn)�selfr � r �E/opt/alt/python37/lib/python3.7/site-packages/sentry_sdk/transport.py�__init__/ s zTransport.__init__c C s
t � �dS )zm
This gets invoked with the event dictionary when an event should
be sent to sentry.
N)�NotImplementedError)r �eventr r r �
capture_event9 s zTransport.capture_eventc C s
t � �dS )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.
N)r! )r �enveloper r r �capture_envelopeC s zTransport.capture_envelopec C s dS )z=Wait `timeout` seconds for the current events to be sent out.Nr )r �timeout�callbackr r r �flushQ s zTransport.flushc C s dS )z Forcefully kills the transport.Nr )r r r r �killZ s zTransport.killc C s& y | � � W n tk
r Y nX d S )N)r) � Exception)r r r r �__del___ s zTransport.__del__)N)N) �__name__�
__module__� __qualname__�__doc__r r r# r% r( r) r+ r r r r r ' s
r c
c s� |d krt �� }x�| �d�D ]r}yR|�� �dd�\}}}|tt|�d� }x$|rZ|�d�p\dD ]}||fV q^W W q ttfk
r� w Y q X q W d S )N�,�:� )�seconds�;)N)r �utcnow�split�stripr �int� LookupError�
ValueError)�header�now�limitZ retry_after�
categories�_�categoryr r r �_parse_rate_limitsg s rA c @ s� e Zd ZdZdd� Zdd� Zd dd�Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zd!d d �Zd d � ZdS )"�
HttpTransportzThe default HTTP transport.c C s� ddl m} t�| |� | jd k s&t�|| _t|d d�| _| j� d| �| _
i | _ t j
�� | _| j| j|d |d |d d �| _dd
lm} || _d S ) Nr )�VERSIONZtransport_queue_size)Z
queue_sizezsentry.python/%s�
http_proxy� https_proxy�ca_certs)rD rE rF )�Hub)Zsentry_sdk.constsrC r r r �AssertionErrorr r �_workerZto_auth�_auth�_disabled_until�urllib3�utilZRetry�_retry�
_make_pool�_pool�
sentry_sdkrG �hub_cls)r r rC rG r r r r y s zHttpTransport.__init__c C sh |j �d�}|r,t�d� | j�t|�� n8|jdkrdt�d� t� � t
| j � |�pVdd� | jd < d S )Nzx-sentry-rate-limitsz%Rate-limited via x-sentry-rate-limitsi� zRate-limited via 429�< )r3 )
�headers�getr �warningrK �updaterA �statusr r5 r rN Zget_retry_after)r �responser; r r r �_update_rate_limits� s
z!HttpTransport._update_rate_limits�storec C s� |� t| jj�t| j�� �d�� y$| jjdt| j�|��||d�}W n tk
rf | � d� � Y nX z\| �
|� |j dkr�| � d� n8|j dks�|j dk r�t �
d |j |j� | � d
�|j �� W d |�� X d S ) N)z
User-Agentz
X-Sentry-AuthZPOST)�bodyrT Znetworki� Z
status_429i, �� z%Unexpected status code: %s (body: %s)z status_{})rW �strrJ ZclientZ to_headerrP ZrequestZ get_api_urlr* �on_dropped_eventrZ rX r �error�data�format�close)r r\ rT �
endpoint_typerY r r r �
_send_request� s0
zHttpTransport._send_requestc C s d S )Nr )r �reasonr r r r_ � s z HttpTransport.on_dropped_eventc s � fdd�}||�p|d �S )Nc s � j �| �}|d k o |t�� kS )N)rK rU r r5 )�bucket�ts)r r r � _disabled� s z0HttpTransport._check_disabled.<locals>._disabledr )r r@ ri r )r r �_check_disabled� s z HttpTransport._check_disabledc C s� | � d�r| �d� d S t�� }tj|dd��}|�t|�� W d Q R X | jd k sVt �t
� d|� d�phd|� d�ptd|� d �p�d| jj
| jjf � | j|�� d
d d �d
� d S )Nr` Zself_rate_limits�w)�fileobj�modez>Sending event, type:%s level:%s event_id:%s project:%s host:%s�type�null�levelZevent_idzapplication/json�gzip)z Content-TypezContent-Encoding)rT )rj r_ �io�BytesIOrq �GzipFile�writer r rH r �debugrU �
project_id�hostre �getvalue)r r" r\ �fr r r � _send_event� s$
zHttpTransport._send_eventc s� � fdd�|j D �|j d d �< |j s(d S t�� }tj|dd��}|�|� W d Q R X � jd k sbt�t� d|j
� jj � jj � � j
|�� ddd�d d
� d S ) Nc s g | ]}� � |j�s|�qS r )rj Z
data_category)�.0�x)r r r �
<listcomp> s z0HttpTransport._send_envelope.<locals>.<listcomp>rk )rl rm z(Sending envelope [%s] project:%s host:%sz application/x-sentry-enveloperq )z Content-TypezContent-Encodingr$ )rT rd )�itemsrr rs rq rt Zserialize_intor rH r rv � descriptionrw rx re ry )r r$ r\ rz r )r r �_send_envelope� s$
z HttpTransport._send_envelopec C s dd|pt �� d�S )Nr2 Z
CERT_REQUIRED)Z num_poolsZ cert_reqsrF )�certifi�where)r rF r r r �_get_pool_options s z HttpTransport._get_pool_optionsc C sP t � �d�}|sdS x6|�d�D ](}|�� }|j�|�sD|j�|�r dS q W dS )N�noFr0 T)r rU r6 r7 rx �endswith�netloc)r r �no_proxyrx r r r � _in_no_proxy$ s zHttpTransport._in_no_proxyc C s� d }| � |�}|jdkr6|dkr6|p4| o4t� �d�}|sX|dkrX|pV| oVt� �d�}| �|�}|rttj|f|�S tjf |�S d S )N�https� �http)r� �schemer rU r� rL r r )r r rD rE rF �proxyr� �optsr r r rO / s
zHttpTransport._make_poolc s2 �j j�� ��fdd�}�j�|�s.��d� d S )Nc
s0 ��" t � � ��� � W d Q R X W d Q R X d S )N)r r{ r )r" �hubr r r �send_event_wrapperO s z7HttpTransport.capture_event.<locals>.send_event_wrapper�
full_queue)rR �currentrI �submitr_ )r r" r� r )r" r� r r r# I s zHttpTransport.capture_eventc s2 �j j�� ��fdd�}�j�|�s.��d� d S )Nc
s0 ��" t � � ��� � W d Q R X W d Q R X d S )N)r r� r )r$ r� r r r �send_envelope_wrapper^ s z=HttpTransport.capture_envelope.<locals>.send_envelope_wrapperr� )rR r� rI r� r_ )r r$ r� r )r$ r� r r r% X s z HttpTransport.capture_envelopeNc C s$ t �d� |dkr | j�||� d S )NzFlushing HTTP transportr )r rv rI r( )r r& r' r r r r( g s
zHttpTransport.flushc C s t �d� | j�� d S )NzKilling HTTP transport)r rv rI r) )r r r r r) q s
zHttpTransport.kill)r[ )N)r, r- r. r/ r rZ re r_ rj r{ r� r� r� rO r# r% r( r) r r r r rB v s
' !
rB c @ s e Zd Zdd� Zdd� ZdS )�_FunctionTransportc C s t �| � || _d S )N)r r �_func)r �funcr r r r x s
z_FunctionTransport.__init__c C s | � |� d S )N)r� )r r" r r r r# s
z _FunctionTransport.capture_eventN)r, r- r. r r# r r r r r� w s r� c C sb | d }|d krt }n8t|t�r$|S t|t�r>t|t�r>|}nt|�rNt|�S | d r^|| �S d S )NZ transportr )rB �
isinstancer rn �
issubclass�callabler� )r Z
ref_transportZ
transport_clsr r r �make_transport� s
r� )N)-�
__future__r rr rL r� rq r r Zsentry_sdk.utilsr r r r Zsentry_sdk.workerr Zsentry_sdk.enveloper
Zsentry_sdk._typesr �typingr r
r r r r r r Zurllib3.poolmanagerr r r r r^ Z DataCategoryZurllib.requestr � ImportError�urllib�objectr rA rB r� r� r r r r �<module> sB @