관리-도구
편집 파일: sanic.cpython-38.pyc
U �Mg-3 � @ sT d dl Z d dlZd dlmZ d dlmZ d dlZd dlmZ d dlm Z d dl m Z m Z d dl mZmZ d dlmZ d d lmZmZ d d lmZmZmZmZmZmZm Z d d l m Z e �rBd d l m Z d d l m!Z! d dl m"Z" d dl m#Z# d dl m$Z$ d dl m%Z% d dl&m'Z'm(Z( d dl)m*Z* d dl+m,Z,m-Z-m.Z.m/Z/ d dl0m1Z1 z8d dl2m3Z3m4Z5 d dl6m7Z7 d dl0m8Z8 d dl9m:Z: W n e;k �r� e d��Y nX e:j<Z=e3j>Z?e8j@ZAz e3jBZCW n eDk �r� Y nX G dd � d e �ZEG d d � d e�ZFd d � ZGd!d"� ZHd#d$� ZBd%d&� ZId5d'd(�ZJd)d*� ZKd+d,� ZLd-d.� ZMd/d0� ZNeeE�d1d2� �ZOd3d4� ZPdS )6� N)� isawaitable)�urlsplit)�continue_trace)�OP)� Integration� DidNotEnable)�RequestExtractor�_filter_headers)� ignore_logger)� TRANSACTION_SOURCE_COMPONENT�TRANSACTION_SOURCE_URL)�capture_internal_exceptions�ensure_integration_enabled�event_from_exception�HAS_REAL_CONTEXTVARS�CONTEXTVARS_ERROR_MESSAGE� parse_version�reraise)� TYPE_CHECKING)� Container)�Any)�Callable)�Optional)�Union)�Dict)�Request�RequestParameters)�BaseHTTPResponse)�Event�EventProcessor�ExcInfo�Hint)�Route)�Sanic� __version__)�SanicException)�Router)� ErrorHandlerzSanic not installedc @ s< e Zd ZdZde� �ZdZedh�fdd�Zedd� �Z dS ) �SanicIntegration�sanicz auto.http.Ni� c C s |pt � | _dS )aG The unsampled_statuses parameter can be used to specify for which HTTP statuses the transactions should not be sent to Sentry. By default, transactions are sent for all HTTP statuses, except 404. Set unsampled_statuses to None to send transactions for all HTTP statuses, including 404. N)�set�_unsampled_statuses)�selfZunsampled_statuses� r- �K/opt/hc_python/lib/python3.8/site-packages/sentry_sdk/integrations/sanic.py�__init__? s zSanicIntegration.__init__c C st t t�t_tjd kr"td�t���tjdk r4td��tsDtdt ��t�d�rVt d� tjdk rjt � d S t � d S )Nz Unparsable Sanic version: {})r � z Sanic 0.8 or newer required.zUThe sanic integration for Sentry requires Python 3.7+ or the aiocontextvars package.z0.8.�root�� � ) r � SANIC_VERSIONr( �versionr �formatr r � startswithr �_setup_legacy_sanic� _setup_sanicr- r- r- r. � setup_onceI s" �� zSanicIntegration.setup_once) �__name__� __module__� __qualname__� identifier�originr6 � frozensetr/ � staticmethodr; r- r- r- r. r( : s r( c @ sL e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dS )�SanicRequestExtractorc C s | j jd krdS t| j j�S )Nr )�request�body�len�r, r- r- r. �content_lengthq s z$SanicRequestExtractor.content_lengthc C s t | jj�S �N)�dictrD �cookiesrG r- r- r. rK w s z SanicRequestExtractor.cookiesc C s | j jS rI )rD rE rG r- r- r. �raw_data{ s z SanicRequestExtractor.raw_datac C s | j jS rI )rD �formrG r- r- r. rM s zSanicRequestExtractor.formc C s t � �d S rI )�NotImplementedErrorrG r- r- r. �is_json� s z SanicRequestExtractor.is_jsonc C s | j jS rI )rD �jsonrG r- r- r. rP � s zSanicRequestExtractor.jsonc C s | j jS rI )rD �filesrG r- r- r. rQ � s zSanicRequestExtractor.filesc C s t |jp d�S )Nr- )rF rE )r, �filer- r- r. � size_of_file� s z"SanicRequestExtractor.size_of_fileN) r< r= r> rH rK rL rM rO rP rQ rS r- r- r- r. rC p s rC c C s t t_ tt_d S rI )�_startupr# � _sentry_error_handler_lookupr' �lookupr- r- r- r. r: � s r: c C s t t_tt_tt_d S rI ) �_legacy_handle_requestr# �handle_request�_legacy_router_getr& �getrU r' rV r- r- r- r. r9 � s r9 c � s< | � d�t� | � d�t� | � d�t� t| �I d H d S )Nzhttp.lifecycle.requestzhttp.lifecycle.responsezhttp.routing.after)�signal�_context_enter� _context_exit�_set_transaction� old_startuprG r- r- r. rT � s rT c � s� t �� �t�d k | j_| jjs"d S t�| �}t �� | j_ | jj � � }|� � |� t |�� tt| j�tj| jttjd�}t �|�� � | j_d S )N)�op�name�sourcer@ )� sentry_sdk� get_client�get_integrationr( �ctx�_sentry_do_integration�weakref�ref�isolation_scope� _sentry_scope� __enter__�clear_breadcrumbs�add_event_processor�_make_request_processorr rJ �headersr Z HTTP_SERVER�pathr r@ Zstart_transaction�_sentry_transaction)rD � weak_request�scopeZ transactionr- r- r. r\ � s& � ��r\ c � s� t � �� | jjs W 5 Q R � d S t�� �t�}|d kr8d n|j}t � �H | jj� |� | jj j t |t�op||j kM _ | jj� d d d � W 5 Q R X | jj� d d d � W 5 Q R X d S rI )r rf rg rc rd re r( �statusrr Zset_http_statusZsampled� isinstancer+ �__exit__rk )rD �responseZ integrationZresponse_statusr- r- r. r] � s � r] c � sL | j jrHt� �4 t�� }|j�| jjd��d�}|j |t d� W 5 Q R X d S )N� �.�rb ) rf rg r rc Zget_current_scopera �replace�app�strip�set_transaction_namer )rD Zroute�_rt Z route_namer- r- r. r^ � s r^ c sL t |� t| |f|�|�� � d kr&d S t�� �t�d kr<� S � fdd�}|S )Nc � s~ zXz&� | |�}t|�r |I d H }|W W �2S tk rT t�� }t|� t|� Y nX W 5 t jrxt jdkrxt| �I d H X d S )Nr2 ) r( r6 r] r � Exception�sys�exc_info�_capture_exceptionr )rD � exceptionrx r� �Zold_error_handlerr- r. � sentry_wrapped_error_handler� s zB_sentry_error_handler_lookup.<locals>.sentry_wrapped_error_handler)r� �old_error_handler_lookuprc rd re r( )r, r� �args�kwargsr� r- r� r. rU � s rU c � s� t �� �t�d kr*t| |f|�|�I d H S t�|�}t �� �L}|�� |� t |�� t| |f|�|�}t |�rx|I d H }|W 5 Q R � S Q R X d S rI ) rc rd re r( �old_handle_requestrh ri rj rm rn ro r )r, rD r� r� rs rt rx r- r- r. rW s rW c G s� t | f|�� }t�� �t�d k r�t� �x t�� }tjr�tjdkr�| jj j }|d j }|� d| �rv|t |�d d � }|j |td� n|j |d jtd� W 5 Q R X |S )N)r3 � r z%s.� r{ )�old_router_getrc rd re r( r Zget_isolation_scoper6 rf r} ra r8 rF r r r< )r, r� �rvrt Zsanic_app_nameZ sanic_router- r- r. rY % s$ � �rY c C st t � �d t| t�� jddd�d�\}}|rXt|d d d�rX|d d jrXW 5 Q R � d S tj||d� W 5 Q R X d S ) Nr) F)�typeZhandled)Zclient_optionsZ mechanismr� r �quiet)�hint)r r rc rd �options�hasattrr� Z capture_event)r� �eventr� r- r- r. r� C s � $r� c s � fdd�}|S )Nc s� z |r t |d d t�r W d S W n tk r4 Y nX � � }|d krH| S t� �v t|�}|�| � | d }t|j�}d|j|j |j f |d< |j |d< |j |d< d|j i|d < tt|j��|d < W 5 Q R X | S ) Nr� r rD z %s://%s%s�urlZ query_string�methodZ REMOTE_ADDR�envrp )� issubclassr% �KeyErrorr rC Zextract_into_eventr r� �scheme�netlocrq �queryr� Z remote_addrr rJ rp )r� r� rD Z extractorZ request_info�urlparts�rs r- r. �sanic_processorU s. � z0_make_request_processor.<locals>.sanic_processorr- )rs r� r- r� r. ro S s !ro )N)Qr� rh �inspectr � urllib.parser rc r Zsentry_sdk.constsr Zsentry_sdk.integrationsr r Z$sentry_sdk.integrations._wsgi_commonr r Z sentry_sdk.integrations.loggingr Zsentry_sdk.tracingr r Zsentry_sdk.utilsr r r r r r r �typingr �collections.abcr r r r r r Z sanic.requestr r Zsanic.responser Zsentry_sdk._typesr r r r! Z sanic.routerr" r) r# r$ r5 Zsanic.exceptionsr% r& Zsanic.handlersr' � ImportErrorrV r� rX r� rZ r� rT r_ �AttributeErrorr( rC r: r9 r\ r] r^ rU rW rY r� ro r- r- r- r. �<module> sf $ 6$ "