Edit File: tornado.cpython-37.opt-1.pyc
B Z~�_Y � @ sH d dl Z d dlmZ d dlmZmZ d dlmZmZm Z m Z m Z d dl m Z mZ d dlmZmZmZ d dlmZ d dlmZ y,d d lmZ d d lmZm Z d d l m Z W n e k r� ed ��Y nX d d l m!Z! e!�rd dl"m#Z# d dl"m$Z$ d dl"m%Z% d dl"m&Z& d dl m'Z' G dd� de �Z(dd� Z)dd� Z*G dd� de�Z+dS )� N)�iscoroutinefunction)�Hub�_should_send_default_pii)�HAS_REAL_CONTEXTVARS�CONTEXTVARS_ERROR_MESSAGE�event_from_exception�capture_internal_exceptions�transaction_from_function)� Integration� DidNotEnable)�RequestExtractor�_filter_headers�_is_json_content_type)� ignore_logger)� iteritems)� version_info)�RequestHandler� HTTPError)� coroutinezTornado not installed)�MYPY)�Any)�Optional)�Dict)�Callable)�EventProcessorc @ s e Zd ZdZedd� �ZdS )�TornadoIntegration�tornadoc sz t dk rtd��ts tdt ��td� tj� t� �} | rH� fdd�}nt� fdd��}|t_tj ��fdd �}|t_ d S ) N)� r zTornado 5+ requiredzUThe tornado integration for Sentry requires Python 3.7+ or the aiocontextvars packageztornado.accessc � s� t j}|�t�}|d kr.� | f|�|�I d H S t�| �}t |��F}|�� � }|�� t|�}|� |� W d Q R X � | f|�|�I d H S Q R X d S )N) r �current�get_integrationr �weakref�ref�configure_scope�clear_breadcrumbs�_make_event_processor�add_event_processor)�self�args�kwargs�hub� integration� weak_handler�scope� processor)� old_execute� �P/opt/alt/python37/lib/python3.7/site-packages/sentry_sdk/integrations/tornado.py� sentry_execute_request_handlerA s zETornadoIntegration.setup_once.<locals>.sentry_execute_request_handlerc ? s� t j}|�t�}|d kr(� | f|�|�S t�| �}t |��J}|�� � }|�� t|�}|� |� W d Q R X � | f|�|�E d H }|S Q R X d S )N) r r r r r r! r" r# r$ r% ) r& r' r( r) r* r+ r, r- �result)r. r/ r0 r1 S s c s" t |||� � | |||f|�|�S )N)�_capture_exception)r& �ty�value�tbr' r( )�old_log_exceptionr/ r0 �sentry_log_exceptioni s z;TornadoIntegration.setup_once.<locals>.sentry_log_exception) �TORNADO_VERSIONr r r r r Z_executer r Z log_exception)Z awaitabler1 r8 r/ )r. r7 r0 � setup_once* s z TornadoIntegration.setup_onceN)�__name__� __module__� __qualname__Z identifier� staticmethodr: r/ r/ r/ r0 r ' s r c C s^ t j}|�t�d krd S t|t�r&d S |j}t| ||f|jddd�d�\}}|j ||d� d S )Nr F)�typeZhandled)Zclient_optionsZ mechanism)�hint) r r r r � isinstancer �clientr �optionsZ capture_event)r4 r5 r6 r) rB �eventr@ r/ r/ r0 r3 q s r3 c s � fdd�}|S )Nc s� � � }|d kr| S |j }t� �$ t||j j�� �}t|�| d< W d Q R X t� �l t|�}|�| � | d }d|j|j |j f |d< |j |d< |j|d< d|j i|d< t t|j��|d < W d Q R X t� �& |jr�t� r�| �d i ��d d � W d Q R X | S ) NZ transaction�requestz %s://%s%sZurlZ query_string�methodZ REMOTE_ADDR�env�headers�userZis_authenticatedT)rE r �getattrrF �lowerr �TornadoRequestExtractorZextract_into_eventZprotocol�host�pathZqueryZ remote_ipr �dictrH Z current_userr � setdefault)rD r@ �handlerrE rF Z extractorZ request_info)r+ r/ r0 �tornado_processor� s. z0_make_event_processor.<locals>.tornado_processorr/ )r+ rR r/ )r+ r0 r$ � s #r$ c @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dS )rL c C s | j jd krdS t| j j�S )Nr )rE �body�len)r& r/ r/ r0 �content_length� s z&TornadoRequestExtractor.content_lengthc C s dd� t | jj�D �S )Nc S s i | ]\}}|j |�qS r/ )r5 )�.0�k�vr/ r/ r0 � <dictcomp>� s z3TornadoRequestExtractor.cookies.<locals>.<dictcomp>)r rE �cookies)r& r/ r/ r0 rZ � s z TornadoRequestExtractor.cookiesc C s | j jS )N)rE rS )r& r/ r/ r0 �raw_data� s z TornadoRequestExtractor.raw_datac C s dd� t | jj�D �S )Nc S s i | ]\}}d d� |D �|�qS )c S s g | ]}|� d d��qS )�latin1�replace)�decode)rV rX r/ r/ r0 � <listcomp>� s z;TornadoRequestExtractor.form.<locals>.<dictcomp>.<listcomp>r/ )rV rW Zvsr/ r/ r0 rY � s z0TornadoRequestExtractor.form.<locals>.<dictcomp>)r rE Zbody_arguments)r& r/ r/ r0 �form� s z TornadoRequestExtractor.formc C s t | jj�d��S )Nz content-type)r rE rH �get)r& r/ r/ r0 �is_json� s z TornadoRequestExtractor.is_jsonc C s dd� t | jj�D �S )Nc S s i | ]\}}|r|d |�qS )r r/ )rV rW rX r/ r/ r0 rY � s z1TornadoRequestExtractor.files.<locals>.<dictcomp>)r rE �files)r& r/ r/ r0 rc � s z TornadoRequestExtractor.filesc C s t |jp d�S )Nr/ )rT rS )r& �filer/ r/ r0 � size_of_file� s z$TornadoRequestExtractor.size_of_fileN) r; r< r= rU rZ r[ r` rb rc re r/ r/ r/ r0 rL � s rL ),r �inspectr Zsentry_sdk.hubr r Zsentry_sdk.utilsr r r r r Zsentry_sdk.integrationsr r Z$sentry_sdk.integrations._wsgi_commonr r r Z sentry_sdk.integrations.loggingr Zsentry_sdk._compatr r r r9 Z tornado.webr r Z tornado.genr � ImportErrorZsentry_sdk._typesr �typingr r r r r r r3 r$ rL r/ r/ r/ r0 �<module> s0 J(