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)Dsnloggercapture_internal_exceptions)BackgroundWorker)
getproxiesc @ s@ e Zd ZdZdZd
ddZdd ZdddZd 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 )Ndsn)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)NotImplementedErrorr 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 Ztimeoutcallbackr 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
dZ dd Z
d S )
HttpTransportzThe default HTTP transport.c C sv t | | t | _| jdt | _d | _t j
| _ || _
| j| j|d |d |d d| _ddlm} || _d S )Nzsentry.python/%s
http_proxy https_proxyca_certs)r$ r% r& r )Hub)r r r _workerr Zto_authr _auth_disabled_untilurllib3utilZRetry_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|
dppd|d | jj| jjf | jjd
t| jj| t| j d d d
d}z`|jdkrt t| j |pdd | _ W 2d S |jdks|jdk rt d|j|j W 5 | X d | _ d S )Nw)ZfileobjmodeF)Z allow_nanzutf-8z&Sending %s event [%s] to %s project:%slevelerrorZevent_idZPOSTzapplication/jsongzip)z
X-Sentry-Authz Content-TypezContent-Encoding)bodyZheadersi < )Zsecondsi, z%Unexpected status code: %s (body: %s)) r* r ZutcnowioBytesIOr5 ZGzipFilewritejsondumpsencoder debuggetr ZhostZ
project_idr/ Zrequeststrr) Z
store_api_urlgetvalueZ to_headercloseZstatusr r- Zget_retry_afterr4 data)r r r6 fZresponser r r _send_event^ sN
$
zHttpTransport._send_eventc C s dd|pt dS )N Z
CERT_REQUIRED)Z num_poolsZ cert_reqsr& )certifiwhere)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#
issubclasstype TypeErrorcallablerP )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
ClientOptionsZTypeZAnyZOptionalZDictZUnionCallablerL rK Zurllib.requestr
ImportErrorZurllibobjectr r# rP rW r r r r <module> s"
'|