Edit File: breadcrumbs.cpython-37.pyc
B ��Y- � @ s* d dl mZ d dlZd dlZd dlZd dlmZ d dlmZm Z m Z m Z d dl m Z g Zi Ze�d�Zdd� ZG d d � d e�ZG d d � d e�Zd,dd�Zdd� Zd-dd�Zdd� Zd.dd�Zdd� 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)� iteritems�get_code� text_type� string_types)�once�ravenc C sP | d |d koN| d |d koN| d |d koN| d |d koN| d |d kS )N�type�level�message�category�data� )�a�br r �B/opt/alt/python37/lib/python3.7/site-packages/raven/breadcrumbs.py� event_payload_considered_equal s r c @ s0 e Zd Zd dd�Zd dd�Zdd� Zd d � ZdS ) �BreadcrumbBuffer�d c C s g | _ || _d S )N)�buffer�limit)�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 )� ValueError�timer �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 }x�t | j�D ]v\}\}}|d k rby ||� W n" tk rR t�d� d }Y nX |d f| j|< |d k r|r|t|d |�s|�|� qW |S )Nz&Failed to process breadcrumbs. Ignored���)� enumerater � Exception�logger� exceptionr r )r �rv�idx�payloadr 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 �args�kwargsr 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 )z�Records 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 t��j�}|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 )N�exc_info)r r r r )r r$ �pop�update�name�logging� getLevelName�lower)r Z formatted_msg)r/ r0 r r% �msgr r r q s z)_record_log_breadcrumb.<locals>.processor)r )�special_logging_handlers�special_logger_handlers�getr9 r )r% r r= r/ r0 �handlerr' r r )r/ r0 r r% r= r �_record_log_breadcrumbe s rB c C s� t | t�s| j}n| }t|dd�r&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|�jks�t�|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 �exec�factoryT)� isinstancer Zim_func�getattrr r: �_srcfile�os�path�normpath� currentframe�__code__� co_filename�eval�compile�co_firstlinenor+ �join�__dict__rB �__doc__�AssertionErrorr, rC ) �methr �funcr/ rG �codeZlogging_srcfile�ns�new_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)�debug�info�warning�warn�errorr& �critical�fatal)r: �Logger�DEBUG�INFO�WARNING�WARN�ERROR�CRITICAL�FATALr r_ rK �setattr�log)�cls�methods� 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 )z�Ignores 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.<locals>.handlerN)� register_special_log_handler)�name_or_loggerrv rA r )rv r � ignore_logger� s ry c C s" t | t�r| }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.<locals>.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 d�d� d S )N�httpr� )�url�method� status_code�reason)r r r )r r� r� r� r� )�response)�requestr r �_record_request( s z5_hook_requests.<locals>.send.<locals>._record_request)r$ )r r� r/ r0 r� Zresp)� real_send)r� r �send' s z _hook_requests.<locals>.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 �}|� d�s:d� dkr dp d��� kr0d� p2d�f }|�d�| d < | d ��� | S ) N)zhttp://zhttps://z %s://%s%s%si� �httpsr� z:%s� )r� r� r )� startswithr8 )r Zreal_url)� default_port�hostr� �port�statusr� r r r N s z7_install_httplib.<locals>.putrequest.<locals>.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.<locals>.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.<locals>.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)� libraries�libr[ 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 �<module> s: * & F .