Edit File: transport.cpython-37.opt-1.pyc
B Z~�_�- � @ 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)�headerZnow�limitZ retry_afterZ categories�_�categoryr r r �_parse_rate_limitsg s r? c @ s| e Zd ZdZdd� Zdd� Zd dd�Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dd� Zd dd�Zd d � ZdS ) � HttpTransportzThe default HTTP transport.c C s� ddl m} t�| |� | jd k s&t�t� | _| j�d| �| _ i | _ t j � � | _|| _| j| j|d |d |d d�| _ddlm} || _d S ) Nr )�VERSIONzsentry.python/%s� http_proxy� https_proxy�ca_certs)rB rC rD )�Hub)Zsentry_sdk.constsrA r r r �AssertionErrorr �_workerZto_auth�_auth�_disabled_until�urllib3�utilZRetry�_retryr � _make_pool�_poolZ sentry_sdkrE �hub_cls)r r rA rE r r r r y s zHttpTransport.__init__c C sT |j �d�}|r"| j�t|�� n.|jdkrPt�� t| j � |�pBdd� | jd < d S )Nzx-sentry-rate-limitsi� �< )r3 ) �headers�getrI �updater? �statusr r5 r rL 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�� | jjdt| j�|��||d�}z@| �|� |j dkrZn&|j dksn|j dk r�t � d|j |j � W d |� � X d S )N)z User-Agentz X-Sentry-AuthZPOST)�bodyrQ i� i, �� z%Unexpected status code: %s (body: %s))rS �strrH ZclientZ to_headerrN ZrequestZ get_api_urlrV rT r �error�data�close)r rX rQ � endpoint_typerU r r r � _send_request� s$ zHttpTransport._send_requestc s � fdd�}||�p|d �S )Nc s � j �| �}|d k o |t�� kS )N)rI rR r r5 )ZbucketZts)r r r � _disabled� s z0HttpTransport._check_disabled.<locals>._disabledr )r r> r` r )r r �_check_disabled� s z HttpTransport._check_disabledc C s� | � d�rd S t�� }tj|dd��}|�t|�� W d Q R X | jd k sLt�t � d|� d�p^d|� d�pjd|� d�pvd| jj | jj f � | j|�� d d d �d � d S ) Nr[ �w)�fileobj�modez>Sending event, type:%s level:%s event_id:%s project:%s host:%s�typeZnull�levelZevent_idzapplication/json�gzip)z Content-TypezContent-Encoding)rQ )ra �io�BytesIOrg �GzipFile�writer r rF r �debugrR � project_id�hostr_ �getvalue)r r" rX �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 )ra Z data_category)�.0�x)r r r � <listcomp>� s z0HttpTransport._send_envelope.<locals>.<listcomp>rb )rc rd z(Sending envelope [%s] project:%s host:%sz application/x-sentry-enveloperg )z Content-TypezContent-Encodingr$ )rQ r^ )�itemsrh ri rg rj Zserialize_intor rF r rl Z descriptionrm rn r_ ro )r r$ rX rp r )r r �_send_envelope� s$ z HttpTransport._send_envelopec C s dd|pt �� d�S )Nr2 Z CERT_REQUIRED)Z num_poolsZ cert_reqsrD )�certifi�where)r rD 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 rR r6 r7 rn �endswithZnetloc)r r �no_proxyrn 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 )NZhttps� Zhttp)r} Zschemer rR ry rJ r r )r r rB rC rD �proxyr| Zoptsr r r rM " s zHttpTransport._make_poolc s( �j j�� ��fdd�}�j�|� d S )Nc s0 ��" t � � ��� � W d Q R X W d Q R X d S )N)r rq r )r" �hubr r r �send_event_wrapperB s z7HttpTransport.capture_event.<locals>.send_event_wrapper)rO �currentrG �submit)r r" r� r )r" r� r r r# < s zHttpTransport.capture_eventc s( �j j�� ��fdd�}�j�|� d S )Nc s0 ��" t � � ��� � W d Q R X W d Q R X d S )N)r rv r )r$ r� r r r �send_envelope_wrapperP s z=HttpTransport.capture_envelope.<locals>.send_envelope_wrapper)rO r� rG r� )r r$ r� r )r$ r� r r r% J s z HttpTransport.capture_envelopeNc C s$ t �d� |dkr | j�||� d S )NzFlushing HTTP transportr )r rl rG r( )r r& r' r r r r( X s zHttpTransport.flushc C s t �d� | j�� d S )NzKilling HTTP transport)r rl rG r) )r r r r r) b s zHttpTransport.kill)rW )N)r, r- r. r/ r rV r_ ra rq rv ry r} rM r# r% r( r) r r r r r@ v s ! ! r@ c @ s e Zd Zdd� Zdd� ZdS )�_FunctionTransportc C s t �| � || _d S )N)r r �_func)r �funcr r r r i s z_FunctionTransport.__init__c C s | � |� d S )N)r� )r r" r r r r# p s z _FunctionTransport.capture_eventN)r, r- r. r r# r r r r r� h 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 )r@ � isinstancer re � issubclass�callabler� )r Z ref_transportZ transport_clsr r r �make_transportx s r� )N)-Z __future__r rh rJ rw rg 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 rZ Z DataCategoryZurllib.requestr � ImportErrorZurllib�objectr r? r@ r� r� r r r r �<module> s@ @ s