OwlCyberSecurity - MANAGER
Edit File: tornado.cpython-38.pyc
U ��\� � @ s� d dl Z d dlmZ d dlmZmZ d dlmZmZm Z m Z d dl m Z d dl mZmZmZ d dlmZ d dlmZmZ d d lmZ G d d � d e �Z d d � Z dd� Z G dd� de�Z dS )� N)�iscoroutinefunction)�Hub�_should_send_default_pii)�HAS_REAL_CONTEXTVARS�event_from_exception�capture_internal_exceptions�transaction_from_function)� Integration)�RequestExtractor�_filter_headers�_is_json_content_type)� ignore_logger)�RequestHandler� HTTPError)� coroutinec @ s e Zd ZdZedd� �ZdS )�TornadoIntegration�tornadoc s� dd l } t| dd �}|d ks$|dk r,td��ts8td��td� td� tj� t� �}|rh� fdd �}nt� fd d ��}|t_tj ��fd d �}|t_ d S ) Nr � version_info)� r zTornado 5+ requiredzUThe tornado integration for Sentry requires Python 3.6+ or the aiocontextvars packageztornado.applicationztornado.accessc � s� t j}|�t�}|d kr.� | f|�|�I d H S t�| �}t |��N}|�� � }|�� |�t |�� W 5 Q R X � | f|�|�I d H W 5 Q R � S Q R X d S �N) r �current�get_integrationr �weakref�ref�configure_scopeZclear_breadcrumbs�add_event_processor�_make_event_processor)�self�args�kwargs�hub� integration� weak_handler�scope�� old_execute� �P/opt/alt/python38/lib/python3.8/site-packages/sentry_sdk/integrations/tornado.py� sentry_execute_request_handler; s zETornadoIntegration.setup_once.<locals>.sentry_execute_request_handlerc ? s� t j}|�t�}|d kr(� | f|�|�S t�| �}t |��J}|�� �}|�t|�� W 5 Q R X � | f|�|�E d H }|W 5 Q R � S Q R X d S r ) r r r r r r r r r )r r r r r! r" r# �resultr$ r& r' r( L s c s" t |||� � | |||f|�|�S r )�_capture_exception)r �ty�value�tbr r )�old_log_exceptionr& r' �sentry_log_exception_ s z;TornadoIntegration.setup_once.<locals>.sentry_log_exception) r �getattr� RuntimeErrorr r r Z_executer r Z log_exception)r Ztornado_versionZ awaitabler( r/ r& )r% r. r' � setup_once! s( � z TornadoIntegration.setup_onceN)�__name__� __module__� __qualname__� identifier� staticmethodr2 r& r& r& r' r s r c C sZ t j}|�t�d krd S t|t�r&d S t| ||f|jjddd�d�\}}|j ||d� d S )Nr F)�typeZhandled)Zclient_optionsZ mechanism)�hint) r r r r � isinstancer r Zclient�optionsZ capture_event)r+ r, r- r �eventr9 r& r& r' r* g s � r* c s � fdd�}|S )Nc s� � � }|d kr| S |j }t� �$ t||j j�� �}t|�| d< W 5 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 5 Q R X t� �" |jr�t� r�d | �d i �d < W 5 Q R X | S ) NZ transaction�requestz %s://%s%s�urlZ query_string�methodZ REMOTE_ADDR�env�headersT�userZis_authenticated)r= r r0 r? �lowerr �TornadoRequestExtractorZextract_into_eventZprotocol�host�path�queryZ remote_ipr �dictrA Z current_userr � setdefault)r< r9 �handlerr= r? Z extractorZ request_info�r" r& r' �tornado_processorz s0 � z0_make_event_processor.<locals>.tornado_processorr& )r" rL r& rK r' r x s #r c @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dS )rD c C s | j jd krdS t| j j�S )Nr )r= �body�len�r r& r& r' �content_length� s z&TornadoRequestExtractor.content_lengthc C s dd� | j j�� D �S )Nc S s i | ]\}}||j �qS r& )r, ��.0�k�vr& r& r' � <dictcomp>� s z3TornadoRequestExtractor.cookies.<locals>.<dictcomp>)r= �cookies�itemsrO r& r& r' rV � s z TornadoRequestExtractor.cookiesc C s | j jS r )r= rM rO r& r& r' �raw_data� s z TornadoRequestExtractor.raw_datac C s dd� | j j�� D �S )Nc S s i | ]\}}|d d� |D ��qS )c S s g | ]}|� d d��qS )�latin1�replace)�decode)rR rT r& r& r' � <listcomp>� s z;TornadoRequestExtractor.form.<locals>.<dictcomp>.<listcomp>r& )rR rS �vsr& r& r' rU � s � z0TornadoRequestExtractor.form.<locals>.<dictcomp>)r= Zbody_argumentsrW rO r& r& r' �form� s �z TornadoRequestExtractor.formc C s t | jj�d��S )Nz content-type)r r= rA �getrO r& r& r' �is_json� s z TornadoRequestExtractor.is_jsonc C s dd� | j j�� D �S )Nc S s i | ]\}}|r||d �qS )r r& rQ r& r& r' rU � s z1TornadoRequestExtractor.files.<locals>.<dictcomp>)r= �filesrW rO r& r& r' ra � s z TornadoRequestExtractor.filesc C s t |jp d�S )Nr& )rN rM )r �filer& r& r' � size_of_file� s z$TornadoRequestExtractor.size_of_fileN) r3 r4 r5 rP rV rX r^ r` ra rc r& r& r& r' rD � s rD )!r �inspectr Zsentry_sdk.hubr r Zsentry_sdk.utilsr r r r Zsentry_sdk.integrationsr Z$sentry_sdk.integrations._wsgi_commonr r r Z sentry_sdk.integrations.loggingr Z tornado.webr r Z tornado.genr ZAnyZList�Optional�Dict�Callabler r* r rD r& r& r& r' �<module> s I(