\' @ s) d d l m Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z m Z d d l m
Z
d d l m Z m
Z
m Z d d l m Z y d d l m Z Wn" e k
r d d l m Z Yn XGd d d e Z Gd
d d e Z Gd d
d
e Z d d Z d S) )print_functionN)datetime timedelta)VERSION)Dsnloggercapture_internal_exceptions)BackgroundWorker)
getproxiesc @ s^ e Z d Z d Z d Z d d d Z d d Z d d d Z d d
Z d d Z d S)
TransportzWBaseclass for all transports.
A transport is used to send an event to sentry.
Nc C s< | | _ | r/ | d r/ t | d | _ n d | _ d S)Ndsn)optionsr
parsed_dsn)selfr
r
/transport.py__init__( s zTransport.__init__c C s
t d S)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 d S)z=Wait `timeout` seconds for the current events to be sent out.Nr )r timeoutcallbackr r r flush6 s zTransport.flushc C s d S)z Forcefully kills the transport.Nr )r r r r kill: s zTransport.killc C s' y | j Wn t k
r" Yn Xd S)N)r Exception)r r r r __del__? s
zTransport.__del__)
__name__
__module__ __qualname____doc__r r r r r r r r r r r s r c @ sm e Z d Z d Z d d Z d d Z d d Z d d Z d
d Z d d
d Z d d Z
d S)
HttpTransportzThe default HTTP transport.c C s t j | | t | _ | j j d t | _ d | _ t j
j | _ | | _
| j | j d | d d | d d | d | _ d d l m } | | _ d S)Nzsentry.python/%s
http_proxy https_proxyca_certsr )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 s | j d k r1 t j | j k r( d Sd | _ t j } t j d | d d , } | j t j | d d j
d Wd QRXt j d | j
d p d | d
| j j | j j f | j j d t | j j d | j d
d t | j j d d d d i } z| | j d k rXt j t d | j j | pJd | _ d S| j d k sv| j d k rt j d | j | j Wd | j Xd | _ d S)NfileobjmodewZ allow_nanFzutf-8z&Sending %s event [%s] to %s project:%slevelerrorZevent_idZPOSTbodyZheadersz
X-Sentry-Authz Content-Typezapplication/jsonzContent-Encodinggzipi Zseconds< i, z%Unexpected status code: %s (body: %s)) r' r ZutcnowioBytesIOr4 ZGzipFilewritejsondumpsencoder debuggetr hostZ
project_idr, Zrequeststrr& Z
store_api_urlgetvalueZ to_headerstatusr r* Zget_retry_afterr2 dataclose)r r r3 fresponser r r _send_event^ s@ , zHttpTransport._send_eventc C s" d d d d d | p t j i S)NZ num_pools Z cert_reqsZ
CERT_REQUIREDr# )certifiZwhere)r r# r r r _get_pool_options s z HttpTransport._get_pool_optionsc C sl | j d k r | p | } | s6 t j | j } | j | } | r[ t j | | St j | Sd S)NZhttps)schemer
r> rJ r( Z ProxyManagerZ PoolManager)r r r! r" r# proxyZoptsr r r r+ s zHttpTransport._make_poolc s8 j j f d d } j j | d S)Nc s0 # t j Wd QRXWd QRXd S)N)r rG r )r hubr r r send_event_wrapper s
z7HttpTransport.capture_event.<locals>.send_event_wrapper)r- currentr% submit)r r rN r )r rM r r r s zHttpTransport.capture_eventNc C s0 t j d | d k r, | j j | | d S)NzFlushing HTTP transportr )r r= r% r )r r r r r r r s
zHttpTransport.flushc C s t j d | j j d S)NzKilling HTTP transport)r r= r% r )r r r r r s
zHttpTransport.kill) r r r r r rG rJ r+ r r r r r r r r G s 1 r c @ s( e Z d Z d d Z d d Z d S)_FunctionTransportc C s t j | | | _ d S)N)r r _func)r funcr r r r s
z_FunctionTransport.__init__c C s | j | d S)N)rR )r r r r r r s
z _FunctionTransport.capture_eventN)r r r r r r r r r rQ s rQ c C s} | d } | d k r t } nF y t | t Wn, t k
r^ t | rV t | S| SYn X| } | d ry | | Sd S)NZ transportr )r
issubclasstype TypeErrorcallablerQ )r
Z
ref_transportZ
transport_clsr r r make_transport s
rX )Z
__future__r r: r7 r( rI r4 r r Zsentry_sdk.constsr Zsentry_sdk.utilsr r r Zsentry_sdk.workerr Zurllib.requestr
ImportErrorurllibobjectr r rQ rX r r r r <module> s"
'|