B
Y- @ s* d dl mZ d dlZd dlZd dlZd dlmZ d dlmZm Z m
Z
m Z d dl m
Z
g Zi ZedZdd ZG d d
d
eZG d d d eZd,ddZdd Zd-ddZdd Zd.ddZdd Ze
dd Z d/d d Z d d Z d d! Z i Z d"d# Z!e!d$d%d& Z"e!d'd(d) Z#d*d+ Z$d dl%Z&dS )0 )absolute_importN) FunctionType) iteritemsget_code text_type string_types)onceravenc C sP | d |d koN| d |d koN| d |d koN| d |d koN| d |d kS )Ntypelevelmessagecategorydata )abr r B/opt/alt/python37/lib/python3.7/site-packages/raven/breadcrumbs.py event_payload_considered_equal s
r c @ s0 e Zd Zd ddZd ddZdd Zd d
ZdS )
BreadcrumbBufferd c C s g | _ || _d S )N)bufferlimit)selfr r r r __init__ s zBreadcrumbBuffer.__init__Nc C sZ |s|s|st d|d kr$t }| j|p0d|||||d|f | jd | j = d S )Nz6You must pass either `message`, `data`, or `processor`default)r
timestampr r r
r )
ValueErrortimer appendr )r r r r r
r r
processorr r r record# s zBreadcrumbBuffer.recordc C s | j d d = d S )N)r )r r r r clear4 s zBreadcrumbBuffer.clearc C s g }xt | jD ]v\}\}}|d k rby || W n" tk
rR td d }Y nX |d f| j|< |d k r|r|t|d |s|| qW |S )Nz&Failed to process breadcrumbs. Ignored) enumerater Exceptionlogger exceptionr r )r rvidxpayloadr r r r
get_buffer7 s
zBreadcrumbBuffer.get_buffer)r )NNNNNNN)__name__
__module__ __qualname__r r r! r* r r r r r s
r c @ s e Zd Zdd ZdS )BlackholeBreadcrumbBufferc O s d S )Nr )r argskwargsr r r r H s z BlackholeBreadcrumbBuffer.recordN)r+ r, r- r r r r r r. G s r. Tc C s | r
t S t S )N)r r. )enabledr r r make_bufferL s r2 c O s | |d< t ||S )Nr
)r )r
r/ r0 r r r record_breadcrumbR s r3 c
C s@ |dkrt }x*tj D ] }|j||| |||| q W dS )zRecords a breadcrumb for all active clients. This is what integration
code should use rather than invoking the `captureBreadcrumb` method
on a specific client.
N)r r contextZget_active_contextsZ breadcrumbsr )r r r r
r r
r ctxr r r r X s
r c st x$t D ] }| }|rd S qW tj}|d k rR| }|rRd S fdd}t|d d S )Nc sb }yt } r }W n tk
r0 Y nX dd | |jt d d S )Nexc_info)r r
r r )r r$ popupdatenamelogging getLevelNamelower)r Z
formatted_msg)r/ r0 r r% msgr r r q s z)_record_log_breadcrumb..processor)r )special_logging_handlersspecial_logger_handlersgetr9 r )r% r r= r/ r0 handlerr' r r )r/ r0 r r% r= r _record_log_breadcrumbe s
rB c C s t | ts| j}n| }t|ddr&d S |d kr8d}d}n d}d| }t|}tj}|d krltj tj
j j }i }t
tdd|jd |jd
|||d |d tj| |d
| t}|j|_|jt|jkst|j|jk |j|jk d|_|S )N__patched_for_raven__F)r r= z
level, msg)r= z%d, msga %(offset)sif 1:
def factory(original, record_crumb):
def %(name)s(self, %(args)s, *args, **kwargs):
record_crumb(self, %(fwd)s, *args, **kwargs)
return original(self, %(args)s, *args, **kwargs)
return %(name)s
z, )offsetr9 r/ fwdr execfactoryT)
isinstancer Zim_funcgetattrr r: _srcfileospathnormpath currentframe__code__ co_filenameevalcompileco_firstlinenor+ join__dict__rB __doc__AssertionErrorr, rC ) methr funcr/ rG codeZlogging_srcfilensnew_funcr r r _wrap_logging_method s>
r_ c C st t j} t jt jt jt jt jt jt jt jd}x2t |D ]&\}}t
t | ||}t t j|| q6W t
t jj
t j_
d S )N)debuginfowarningwarnerrorr& criticalfatal)r: LoggerDEBUGINFOWARNINGWARNERRORCRITICALFATALr r_ rK setattrlog)clsmethods method_namer r^ r r r
_patch_logger s
rt c C s
t dS )zXInstalls the logging hook if it was not installed yet. Otherwise
does nothing.
N)rt r r r r install_logging_hook s ru c s fdd}t | | dS )zIgnores a logger for the regular breadcrumb code. This is useful
for framework integration code where some log messages should be
specially handled.
c s d k r| krdS dS )NFTr )r% r r= r/ r0 ) allow_levelr r rA s z ignore_logger..handlerN) register_special_log_handler)name_or_loggerrv rA r )rv r
ignore_logger s ry c C s" t | tr| }n| j}|t|< dS )a Registers a callback for log handling. The callback is invoked
with give arguments: `logger`, `level`, `msg`, `args` and `kwargs`
which are the values passed to the logging system. If the callback
returns `True` the default handling is disabled.
N)rJ r r9 r? )rx callbackr9 r r r rw s
rw c C s t | dS )a Registers a callback for log handling. The callback is invoked
with give arguments: `logger`, `level`, `msg`, `args` and `kwargs`
which are the values passed to the logging system. If the callback
returns `True` the default handling is disabled.
N)r> r )rz r r r register_logging_handler
s r{ c s fdd}|S )Nc s t | } | t < | S )N)r hooked_libraries)f)r9 r r decorator s z libraryhook..decoratorr )r9 r~ r )r9 r libraryhook s r requestsc sP yddl m} W n tk
r$ d S X | j fdd}|| _tdtjd d S )Nr )Sessionc sN fdd}y| f||}W n t k
r@ |d Y n
X || |S )Nc s4 t dd j j| r| jpd | r$| jp&d dd d S )Nhttpr )urlmethod status_codereason)r
r
r )r r r r r )response)requestr r _record_request( s
z5_hook_requests..send.._record_request)r$ )r r r/ r0 r Zresp) real_send)r r send' s z _hook_requests..sendz(requests.packages.urllib3.connectionpool)rv )Zrequests.sessionsr ImportErrorr ry r: rj )r r r )r r _hook_requests s r httplibc sf yddl m} W n tk
r0 ddlm} Y nX | j| j fdd} fdd}|| _|| _d S )Nr )HTTPConnectionc sT i | _ | j| j| j fdd}tdd|d | f||S )Nc sZ }| ds:d dkr dp d kr0d p2df }|d| d < | d | S )
N)zhttp://zhttps://z %s://%s%s%si httpsr z:%s )r r r )
startswithr8 )r Zreal_url) default_porthostr portstatusr r r r N s
z7_install_httplib..putrequest..processorr r )r
r
r )_raven_status_dictr r r r )r r r r/ r0 r )real_putrequest)r r r r r r r
putrequestH s
z$_install_httplib..putrequestc sD | f||}t | dd }|d k r@d|kr@|j|d< |j|d< |S )Nr r r )rK r r )r r/ r0 r' r )real_getresponser r getresponse` s
z%_install_httplib..getresponse)r r r Z http.clientr r )r r r r )r r r _install_httplib> s r c C sF | d krt } x0| D ](}t |}|d kr8td| | qW d S )Nz Unknown library %r for hooking)r| keysr@ RuntimeError) librarieslibr[ r r r hook_librariesl s
r )T)NNNNNNN)N)N)'
__future__r rM r r: typesr Zraven.utils.compatr r r r Z raven.utilsr r> r? getLoggerr% r objectr r. r2 r3 r rB r_ rt ru ry rw r{ r| r r r r Z
raven.contextr r r r r s:
*
&
F
.