U
��\' � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlZd dlmZmZ d dl m
Z
d dl m Z m
Z
mZ d dlmZ zd dlmZ W n e k
r� d dl mZ Y nX G dd � d e �Z G d
d � d e �Z G d d
� d
e �Z!dd� Z"dS )� )�print_functionN)�datetime� timedelta)�VERSION)�Dsn�logger�capture_internal_exceptions)�BackgroundWorker)�
getproxiesc @ s@ e Zd ZdZdZd
dd�Zdd� Zddd�Zd d
� Zd d � Z dS )� TransportzWBaseclass for all transports.
A transport is used to send an event to sentry.
Nc C s, || _ |r"|d r"t|d �| _nd | _d S )N�dsn)�optionsr �
parsed_dsn)�selfr
� r �
/transport.py�__init__( s zTransport.__init__c C s
t � �dS )zdThis gets invoked with the event dictionary when an event should
be sent to sentry.
N)�NotImplementedError�r �eventr r r �
capture_event0 s zTransport.capture_eventc C s dS )z=Wait `timeout` seconds for the current events to be sent out.Nr �r Ztimeout�callbackr r r �flush6 s zTransport.flushc C s dS )z Forcefully kills the transport.Nr �r r r r �kill: s zTransport.killc C s& z | � � W n tk
r Y nX d S �N)r � Exceptionr r r r �__del__? s zTransport.__del__)N)N)
�__name__�
__module__� __qualname__�__doc__r r r r r r r r r r r s
r c @ sJ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zdd
d�Z dd� Z
d S )�
HttpTransportzThe default HTTP transport.c C sv t �| |� t� | _| j�dt �| _d | _t j
� � | _ || _
| j| j|d |d |d d�| _ddlm} || _d S )Nzsentry.python/%s�
http_proxy� https_proxy�ca_certs)r$ r% r& r )�Hub)r r r �_workerr Zto_authr �_auth�_disabled_until�urllib3�utilZRetry�_retryr
�
_make_pool�_poolZ
sentry_sdkr' �hub_cls)r r
r' r r r r J s � zHttpTransport.__init__c C s2 | j d k r"t�� | j k r d S d | _ t�� }tj|dd�� }|�tj |dd��
d�� W 5 Q R X t � d|�
d�ppd|d | jj| jjf � | jjd
t| jj�|�� t| j�� �d d d
�d�}z`|jdkr�t�� t| j� |�p�dd� | _ W �2d S |jdk�s|jdk �rt � d|j|j � W 5 |�� X d | _ d S )N�w)Zfileobj�modeF)Z allow_nanzutf-8z&Sending %s event [%s] to %s project:%s�level�errorZevent_idZPOSTzapplication/json�gzip)z
X-Sentry-Authz Content-TypezContent-Encoding)�bodyZheadersi� �< )Zsecondsi, �� z%Unexpected status code: %s (body: %s)) r* r Zutcnow�io�BytesIOr5 ZGzipFile�write�json�dumps�encoder �debug�getr ZhostZ
project_idr/ Zrequest�strr) Z
store_api_url�getvalueZ to_header�closeZstatusr r- Zget_retry_afterr4 �data)r r r6 �fZresponser r r � _send_event^ sN
$ ���
��
�
�
zHttpTransport._send_eventc C s dd|pt �� d�S )N� Z
CERT_REQUIRED)Z num_poolsZ cert_reqsr& )�certifi�where)r r& r r r �_get_pool_options� s
�z HttpTransport._get_pool_optionsc C sP |j dkr|p|}|s$t� �|j �}| �|�}|r@tj|f|�S tjf |�S d S )NZhttps)Zschemer
r@ rJ r+ � ProxyManager� PoolManager)r r r$ r% r& �proxyZoptsr r r r. � s
zHttpTransport._make_poolc s( �j j�� ��fdd�}�j�|� d S )Nc
s0 ��" t � � ��� � W 5 Q R X W 5 Q R X d S r )r rF r �r Zhubr r r �send_event_wrapper� s z7HttpTransport.capture_event.<locals>.send_event_wrapper)r0 Zcurrentr( Zsubmit)r r rO r rN r r � s zHttpTransport.capture_eventNc C s$ t �d� |dkr | j�||� d S )NzFlushing HTTP transportr )r r? r( r r r r r r � s
zHttpTransport.flushc C s t �d� | j�� d S )NzKilling HTTP transport)r r? r( r r r r r r � s
zHttpTransport.kill)N) r r r! r" r rF rJ r. r r r r r r r r# G s 1
r# c @ s e Zd Zdd� Zdd� ZdS )�_FunctionTransportc C s t �| � || _d S r )r r �_func)r �funcr r r r � s
z_FunctionTransport.__init__c C s | � |� d S r )rQ r r r r r � s
z _FunctionTransport.capture_eventN)r r r! r r r r r r rP � s rP c C sj | d }|d krt }n@zt|t� W n, tk
rP t|�rHt|� Y S | Y S X |}| d rf|| �S d S )NZ transportr )r# �
issubclass�type� TypeError�callablerP )r
Z
ref_transportZ
transport_clsr r r �make_transport� s
rW )#Z
__future__r r< r9 r+ rH r5 r r Zsentry_sdk.constsr Zsentry_sdk.utilsr r r Zsentry_sdk.workerr Z
ClientOptionsZTypeZAnyZOptionalZDictZUnion�CallablerL rK Zurllib.requestr
� ImportErrorZurllib�objectr r# rP rW r r r r �<module> s"
'| | Name | Type | Size | Permission | Actions |
|---|---|---|---|---|
| __init__.cpython-38.opt-1.pyc | File | 1.43 KB | 0644 |
|
| __init__.cpython-38.pyc | File | 1.43 KB | 0644 |
|
| _compat.cpython-38.opt-1.pyc | File | 2.43 KB | 0644 |
|
| _compat.cpython-38.pyc | File | 2.46 KB | 0644 |
|
| api.cpython-38.opt-1.pyc | File | 2.83 KB | 0644 |
|
| api.cpython-38.pyc | File | 2.83 KB | 0644 |
|
| client.cpython-38.opt-1.pyc | File | 6.07 KB | 0644 |
|
| client.cpython-38.pyc | File | 6.07 KB | 0644 |
|
| consts.cpython-38.opt-1.pyc | File | 912 B | 0644 |
|
| consts.cpython-38.pyc | File | 912 B | 0644 |
|
| debug.cpython-38.opt-1.pyc | File | 1.52 KB | 0644 |
|
| debug.cpython-38.pyc | File | 1.52 KB | 0644 |
|
| hub.cpython-38.opt-1.pyc | File | 11.45 KB | 0644 |
|
| hub.cpython-38.pyc | File | 11.53 KB | 0644 |
|
| scope.cpython-38.opt-1.pyc | File | 6.3 KB | 0644 |
|
| scope.cpython-38.pyc | File | 6.3 KB | 0644 |
|
| transport.cpython-38.opt-1.pyc | File | 5.6 KB | 0644 |
|
| transport.cpython-38.pyc | File | 5.6 KB | 0644 |
|
| utils.cpython-38.opt-1.pyc | File | 20.28 KB | 0644 |
|
| utils.cpython-38.pyc | File | 20.39 KB | 0644 |
|
| worker.cpython-38.opt-1.pyc | File | 3.17 KB | 0644 |
|
| worker.cpython-38.pyc | File | 3.17 KB | 0644 |
|