U ��\'�@s�ddlmZddlZddlZddlZddlZddlZddlmZmZddl m Z ddlmZm Z mZddlmZzddlmZWn ek r�ddlmZYnXGdd �d e�ZGd d�de�Z Gdd �d e�Z!dd�Z"dS)�)�print_functionN)�datetime� timedelta)�VERSION)�Dsn�logger�capture_internal_exceptions)�BackgroundWorker)� getproxiesc@s@eZdZdZdZd dd�Zdd�Zddd�Zd d �Zdd�Z dS)� TransportzWBaseclass for all transports. A transport is used to send an event to sentry. NcCs,||_|r"|dr"t|d�|_nd|_dS)N�dsn)�optionsr� parsed_dsn)�selfr �r�E/opt/alt/python38/lib/python3.8/site-packages/sentry_sdk/transport.py�__init__(szTransport.__init__cCs t��dS)zdThis gets invoked with the event dictionary when an event should be sent to sentry. N)�NotImplementedError�r�eventrrr� capture_event0szTransport.capture_eventcCsdS)z=Wait `timeout` seconds for the current events to be sent out.Nr�r�timeout�callbackrrr�flush6szTransport.flushcCsdS)zForcefully kills the transport.Nr�rrrr�kill:szTransport.killcCs&z|��Wntk r YnXdS�N)r� Exceptionrrrr�__del__?szTransport.__del__)N)N) �__name__� __module__�__qualname__�__doc__rrrrrrrrrrr s rc@sJeZdZdZdd�Zdd�Zdd�Zdd �Zd d�Zdd d�Z dd�Z dS)� HttpTransportzThe default HTTP transport.cCsvt�||�t�|_|j�dt�|_d|_t j ��|_||_ |j|j|d|d|dd�|_ddlm}||_dS)Nzsentry.python/%s� http_proxy�https_proxy�ca_certs)r%r&r'r)�Hub)rrr �_workerrZto_authr�_auth�_disabled_until�urllib3�utilZRetry�_retryr � _make_pool�_poolZ sentry_sdkr(�hub_cls)rr r(rrrrJs�zHttpTransport.__init__c Cs2|jdk r"t��|jkrdSd|_t��}tj|dd�� }|�tj |dd�� d��W5QRXt�d|� d�ppd|d |jj|jjf�|jjd t|jj�|��t|j��ddd �d�}z`|jdkr�t��t|j�|�p�dd�|_W�2dS|jdk�s|jdk�rt�d|j|j�W5|��Xd|_dS)N�w)�fileobj�modeF)� allow_nanzutf-8z&Sending %s event [%s] to %s project:%s�level�errorZevent_idZPOSTzapplication/json�gzip)z X-Sentry-AuthzContent-TypezContent-Encoding)�body�headersi��<)�secondsi,��z%Unexpected status code: %s (body: %s))r+r�utcnow�io�BytesIOr8ZGzipFile�write�json�dumps�encoder�debug�getr�hostZ project_idr0�request�strr*Z store_api_url�getvalueZ to_header�close�statusrr.Zget_retry_afterr7�data)rrr9�f�responserrr�_send_event^sN $�� zHttpTransport._send_eventcCsdd|pt��d�S)N�Z CERT_REQUIRED)Z num_poolsZ cert_reqsr')�certifi�where)rr'rrr�_get_pool_options�s �zHttpTransport._get_pool_optionscCsP|jdkr|p|}|s$t��|j�}|�|�}|r@tj|f|�Stjf|�SdS)N�https)�schemer rFrTr,�ProxyManager�PoolManager)rrr%r&r'�proxy�optsrrrr/�s zHttpTransport._make_poolcs(�jj��fdd�}�j�|�dS)Nc s0��"t��W5QRXW5QRXdSr)rrPr�rZhubrrr�send_event_wrapper�sz7HttpTransport.capture_event..send_event_wrapper)r1�currentr)Zsubmit)rrr\rr[rr�szHttpTransport.capture_eventNcCs$t�d�|dkr |j�||�dS)NzFlushing HTTP transportr)rrEr)rrrrrr�s zHttpTransport.flushcCst�d�|j��dS)NzKilling HTTP transport)rrEr)rrrrrr�s zHttpTransport.kill)N)r r!r"r#rrPrTr/rrrrrrrr$Gs1 r$c@seZdZdd�Zdd�ZdS)�_FunctionTransportcCst�|�||_dSr)rr�_func)r�funcrrrr�s z_FunctionTransport.__init__cCs|�|�dSr)r_rrrrr�s z _FunctionTransport.capture_eventN)r r!r"rrrrrrr^�sr^cCsj|d}|dkrt}n@zt|t�Wn,tk rPt|�rHt|�YS|YSX|}|drf||�SdS)NZ transportr)r$� issubclass�type� TypeError�callabler^)r Z ref_transportZ transport_clsrrr�make_transport�s re)#� __future__rrBr?r,rRr8rrZsentry_sdk.constsrZsentry_sdk.utilsrrrZsentry_sdk.workerr Z ClientOptionsZTypeZAny�Optional�Dict�Union�CallablerXrWZurllib.requestr �ImportError�urllib�objectrr$r^rerrrr�s" '|