Edit File: transport.cpython-37.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)�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� 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)rD rE rF )�Hub)Zsentry_sdk.constsrC r r r �AssertionErrorr �_workerZto_auth�_auth�_disabled_until�urllib3�utilZRetry�_retryr � _make_pool�_pool� sentry_sdkrG �hub_cls)r r rC rG 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�getrK �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�� | 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)�bodyrT i� i, �� z%Unexpected status code: %s (body: %s))rV �strrJ ZclientZ to_headerrP �requestZ get_api_urlrY rW r �error�data�close)r r[ rT � endpoint_typerX r r r � _send_request� s$ zHttpTransport._send_requestc s � fdd�}||�p|d �S )Nc s � j �| �}|d k o |t�� kS )N)rK rU r r5 )Zbucket�ts)r r r � _disabled� s z0HttpTransport._check_disabled.<locals>._disabledr )r r@ re 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)rT )rf �io�BytesIOrl �GzipFile�writer r rH r �debugrU � project_id�hostrc �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 )rf Z data_category)�.0�x)r r r � <listcomp>� s z0HttpTransport._send_envelope.<locals>.<listcomp>rg )rh ri z(Sending envelope [%s] project:%s host:%sz application/x-sentry-enveloperl )z Content-TypezContent-Encodingr$ )rT rb )�itemsrm rn rl ro Zserialize_intor rH r rq � descriptionrr rs rc rt )r r$ r[ ru 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 rs �endswith�netloc)r r �no_proxyrs 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 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" �hubr r r �send_event_wrapperB s z7HttpTransport.capture_event.<locals>.send_event_wrapper)rR �currentrI �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 r| r )r$ r� r r r �send_envelope_wrapperP s z=HttpTransport.capture_envelope.<locals>.send_envelope_wrapper)rR r� rI 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 rq rI r( )r r& r' r r r r( X s zHttpTransport.flushc C s t �d� | j�� d S )NzKilling HTTP transport)r rq rI r) )r r r r r) b s zHttpTransport.kill)rZ )N)r, r- r. r/ r rY rc rf rv 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 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 )rB � isinstancer rj � issubclass�callabler� )r Z ref_transportZ transport_clsr r r �make_transportx s r� )N)-� __future__r rm rL r} rl 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> s@ @ s