Edit File: utils.cpython-37.pyc
B Z~�_ i � @ sb d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZ d dlZd dl m Z m Z m Z m Z d dlmZ e�r"d dlmZ d dlmZ d dlmZ d dlmZ d d lmZ d d lmZ d d lmZ d d lmZ d d lmZ d dlmZ d dlm Z d dlm Z d dlm Z d dlm Z m Z eddd�Z!e�"d�Z#dZ$dZ%dd� Z&dd� Z'd d � Z(dxd d �Z)G d d!� d!e*�Z+e+� Z,d"d#� Z-d$d%� Z.d&d'� Z/d(d)� Z0dyd*d+�Z1G d,d-� d-e2�Z3e G d.d/� d/e*��Z4G d0d1� d1e*�Z5G d2d3� d3e*�Z6e�r d d4lm7Z7 e7d5�Z8e e6e8f Z9d6d7� Z:d8d9� Z;d:d;� Z<d<d=� Z=dzd>d?�Z>d@dA� Z?dBdC� Z@e �rVdDdE� ZAndFdE� ZAdGdH� ZBd{dJdK�ZCd|dLdM�ZDdNdO� ZEd}dPdQ�ZFeGeHdR�ZIeI�r�dSdT� ZJndUdT� ZJd~dVdW�ZKdXdY� ZLdZd[� ZMd\d]� ZNdd^d_�ZOd`da� ZPdbdc� ZQd�ddde�ZRdfdg� ZSd�dhdi�ZTdjdk� ZUdldm� ZVdndo� ZWeW� \ZXZYdpZZdqdr� Z[eYds�Z\G dtdu� dueH�Z]G dvdw� dwej^�Z_dS )�� N)�datetime)�urlparse� text_type�implements_str�PY2)�MYPY)� FrameType)� TracebackType)�Any)�Callable)�Dict)�ContextManager)�Iterator)�List)�Optional)�Set)�Tuple)�Union)�Type)�ExcInfo� EndpointTypei� � zsentry_sdk.errorsi � c C s t j| ddd��d�S )zCSerialize data into a compact JSON representation encoded as UTF-8.F)�,�:)Z allow_nanZ separatorszutf-8)�json�dumps�encode)�data� r �A/opt/alt/python37/lib/python3.7/site-packages/sentry_sdk/utils.py� json_dumps, s r! c C s d S )Nr r r r r �_get_debug_hub2 s r" c C s� t j�d�} | r| S tt jjd��Z}y2tjddddgtj||d�� � d � � � d �} W n t t fk rn Y nX | rx| S W d Q R X x d D ]}t j�|�} | r�| S q�W d S ) z Try to guess a default release.ZSENTRY_RELEASEzw+�gitz rev-parsez--shortZHEAD)�stdout�stderr�stdinr zutf-8N)ZHEROKU_SLUG_COMMITZSOURCE_VERSIONZ!CODEBUILD_RESOLVED_SOURCE_VERSIONZ CIRCLE_SHA1ZGAE_DEPLOYMENT_ID)�os�environ�get�open�path�devnull� subprocess�Popen�PIPE� communicate�strip�decode�OSError�IOError)�releaseZnull�varr r r �get_default_release8 s, r7 c C s$ t j�d�}|r|S | d k r dS d S )NZSENTRY_ENVIRONMENTZ production)r' r( r) )r5 �rvr r r �get_default_environment_ s r9 c @ s e Zd ZdZdd� Zdd� ZdS )�CaptureInternalExceptionr c C s | S )Nr )�selfr r r � __enter__n s z"CaptureInternalException.__enter__c C s" |d k r |d k r t |||f� dS )NT)�capture_internal_exception)r; �ty�value�tbr r r �__exit__r s z!CaptureInternalException.__exit__N)�__name__� __module__� __qualname__� __slots__r< rA r r r r r: k s r: c C s t S )N)�_CAPTURE_INTERNAL_EXCEPTIONr r r r �capture_internal_exceptions} s rG c C s t � }|d k r|�| � d S )N)r" Z_capture_internal_exception)�exc_infoZhubr r r r= � s r= c C s | t �� S )N)�epoch� total_seconds)r? r r r � to_timestamp� s rK c C s | � d�S )Nz%Y-%m-%dT%H:%M:%S.%fZ)�strftime)r? r r r �format_timestamp� s rM c C s2 | dkrt �� } nt| �} | d dkr*d} d| iS )z+Creates a hint with the exc info filled in.Nr rH )�sysrH �exc_info_from_error)rH r r r �event_hint_with_exc_info� s rP c @ s e Zd ZdZdS )�BadDsnzRaised on invalid DSNs.N)rB rC rD �__doc__r r r r rQ � s rQ c @ s6 e Zd ZdZdd� Zedd� �Zd dd�Zd d � ZdS ) �DsnzRepresents a DSN.c C s t |t�rt|j�| _d S t�t|��}|jdkr@td|j ��|j| _|j d krZtd��|j | _ |j d kr�| jdkrzdp|d| _ n|j | _ |j s�td��|j | _ |j| _|j�dd �}ytt|�� ��| _W n2 ttfk r� td |jp�d d d � ��Y nX d�|�d | _d S ) N)�http�httpszUnsupported scheme %rzMissing hostnamerU i� �P zMissing public key�/r zInvalid project in DSN (%r)� )� isinstancerS �dict�__dict__r �urlsplitr �schemerQ �hostname�host�port�username� public_key�password� secret_keyr+ �rsplit�int�pop� project_id� ValueError� TypeError�join)r; r? �partsr+ r r r �__init__� s. z Dsn.__init__c C s( | j }| j| jfdkr$d|| jf }|S )zThe netloc part of a DSN.))rT rV )rU i� z%s:%s)r_ r] r` )r; r8 r r r �netloc� s z Dsn.netlocNc C s" t | j| j| j| j| j| j|d�S )z*Returns the auth info object for this dsn.)r] r_ r+ rh rb rd �client)�Authr] rn r+ rh rb rd )r; ro r r r �to_auth� s z Dsn.to_authc C s. d| j | j| jrd| j p d| j| j| jf S )Nz%s://%s%s@%s%s%s�@rX )r] rb rd rn r+ rh )r; r r r �__str__� s z Dsn.__str__)N) rB rC rD rR rm �propertyrn rq rs r r r r rS � s $ rS c @ s: e Zd ZdZddd�Zedd� �Zdd d �Zdd d �ZdS )rp z,Helper object that represents the auth info.N� rW c C s4 || _ || _|| _|| _|| _|| _|| _|| _d S )N)r] r_ r+ rh rb rd �versionro ) r; r] r_ rh rb rd rv ro r+ r r r rm � s z Auth.__init__c C s | j dd�S )z^Returns the API url for storing events. Deprecated: use get_api_url instead. �store)�type)� get_api_url)r; r r r � store_api_url s zAuth.store_api_urlrw c C s d| j | j| j| j|f S )z'Returns the API url for storing events.z%s://%s%sapi/%s/%s/)r] r_ r+ rh )r; rx r r r ry s zAuth.get_api_urlc C s~ d| j fd| jfg}|dk r2|�dtt|��f� | jdk rL|�d| jf� | jdk rf|�d| jf� dd�d d � |D �� S ) z!Returns the auth header a string.Z sentry_keyZsentry_versionNZsentry_timestampZ sentry_clientZ sentry_secretzSentry z, c s s | ]\}}d ||f V qdS )z%s=%sNr )�.0�keyr? r r r � <genexpr>% s z!Auth.to_header.<locals>.<genexpr>)rb rv �append�strrK ro rd rk )r; � timestampr8 r r r � to_header s zAuth.to_header)Nru NrW )rw )N) rB rC rD rR rm rt rz ry r� r r r r rp � s rp c @ s e Zd ZdZdd� ZdS )�AnnotatedValue)r? �metadatac C s || _ || _d S )N)r? r� )r; r? r� r r r rm + s zAnnotatedValue.__init__N)rB rC rD rE rm r r r r r� ( s r� )�TypeVar�Tc C s t | dd �pt | dd �S )NrD rB )�getattr)�clsr r r � get_type_name8 s r� c C s t | dd �}|dkr|S d S )NrC )N�builtins� __builtins__)r� )r� �modr r r �get_type_module= s r� c C sp y | j d }|�d�rdS W n ttfk r4 Y nX x4dD ],}y| j| rPdS W q< tk rf Y q<X q<W dS )NrB z sentry_sdk.T)Z__traceback_hide__�__tracebackhide__F)� f_globals� startswith�AttributeError�KeyError�f_locals� Exception)�framer� Z flag_namer r r �should_hide_frameE s r� c c s, | }x"|d k r&t |j�s |V |j}qW d S )N)r� �tb_frame�tb_next)r@ Ztb_r r r � iter_stacksX s r� c C s, d}d }|d k rVt |d�rVy|�|�}W n ttfk rD d }Y nX |d k rV|�� }|d kr�yt�| �}W n ttfk r� g d g fS X |s�g d g fS td|| �}t |d | t |��}yLdd� |||� D �} t || � d��} dd� ||d |� D �} | | | fS t k �r& g d g fS X d S ) N� � get_sourcer r c S s g | ]}t |�d ���qS )z )� strip_stringr1 )r{ �liner r r � <listcomp>� s z'get_lines_from_file.<locals>.<listcomp>z c S s g | ]}t |�d ���qS )z )r� r1 )r{ r� r r r r� � s )�hasattrr� � ImportErrorr4 � splitlines� linecache�getlinesr3 �max�min�lenr� r1 � IndexError) �filename�lineno�loader�moduleZ context_lines�sourceZ source_strZ lower_boundZ upper_bound� pre_context� context_line� post_contextr r r �get_lines_from_filea s4 r� c C s� y | j j}W n tk r$ d }Y nX y| jd }W n tk rN g d g fS X y| jd }W n tk rv d }Y nX |d }|d k r�|r�t||||�S g d g fS )NrB � __loader__r )�f_code� co_filenamer� r� r� )r� � tb_lineno�abs_pathr� r� r� r r r �get_source_context� s r� c C s& yt | �S tk r t| �S X d S )N)r r� � safe_repr)r? r r r �safe_str� s r� c C sT y:t | ��dd�}y|�d��d�S tk r6 |S X W n tk rN dS X d S )Nzutf-8�replace�latin1zunicode-escapez <broken repr>)�reprr2 r r� )r? r8 r r r r� � s r� c C s" yt | �S tk r dS X d S )Nz <broken repr>)r� r� )r? r r r r� � s c C s� |r| s |S yl|� d�r$|d d� }| �dd�d }|| krHtj�|�S tj| j}|�|�tj d�d d�d � tj �S t k r� |S X d S )Nz.pyc����.r r � ) �endswith�splitr' r+ �basenamerN �modules�__file__re �sep�lstripr� )r� r� � base_moduleZbase_module_pathr r r �filename_for_module� s r� Tc C s� t | dd �}|sd }d }n| jj}| jj}y| jd }W n tk rP d }Y nX |d kr`| j}t| |�\}}} t||�p|d |r�t j � |�nd |p�d||||| d�} |r�| j | d< | S )Nr� rB z <unknown>)r� r� �functionr� r� r� r� r� �vars) r� r� r� �co_namer� r� �f_linenor� r� r' r+ �abspathr� ) r� r� � with_localsr� r� r� r� r� r� r� r8 r r r �serialize_frame� s0 r� c C sN d}g }t �� }x,|d k r<t|�s4|�t|| d�� |j}qW |�� d|iS )NT)r� �frames)rN � _getframer� r~ r� �f_back�reverse)r� r� r� �fr r r �current_stacktrace s r� c C s t | dd �S )N�errno)r� )� exc_valuer r r � get_errno s r� c s� |d k rt |�}nd }|d k rF|p(ddi}|�di ��di ��d|� |d krTd� n|d � � fdd �t|�D �}t| �t| �t|�|d �}|r�d |i|d < |S ) Nrx Zgeneric�metar� �numberTr� c s g | ]}t |j|j� d ��qS ))r� r� )r� r� r� )r{ r@ )r� r r r� 8 s z5single_exception_from_error_tuple.<locals>.<listcomp>)r� rx r? � mechanismr� � stacktrace)r� � setdefaultr� r� r� r� )�exc_typer� r@ �client_optionsr� r� r� r8 r )r� r �!single_exception_from_error_tuple s& r� �__suppress_context__c c s� | \}}}g }t � }xz|d k r�|d k r�t|�|kr�|||fV |�|� |�t|�� |jrd|j}n|j}|d krtP t|�}|}t|dd �}qW d S )N� __traceback__) �set�idr~ �addr� � __cause__� __context__rx r� )rH r� r� r@ Zseen_exceptionsZseen_exception_ids�causer r r �walk_exception_chainM s$ r� c c s | V d S )Nr )rH r r r r� n s c C sH | \}}}g }x,t | �D ] \}}}|�t|||||�� qW |�� |S )N)r� r~ r� r� )rH r� r� r� r� r@ r8 r r r �exceptions_from_error_tuples s r� c C s. yt | �S tk r( t| �dd� S X d S )Nr r� )r �UnicodeDecodeErrorr� )r? r r r � to_string� s r� c c s� d| kr| d V d| krHx,| d � d�p,dD ]}d|kr.|d V q.W d| kr~x,| d � d�pbdD ]}d|krd|d V qdW d S )Nr� �threads�valuesr � exception)r) )�event�threadr� r r r �iter_event_stacktraces� s r� c c s4 x.t | �D ]"}x |�d�p dD ] }|V q W q W d S )Nr� r )r� r) )r� r� r� r r r �iter_event_frames� s r� c C s* x$t | �D ]}t|�d�||d� q W | S )Nr� )�in_app_exclude�in_app_include)r� �handle_in_app_implr) )r� r� r� r� r r r � handle_in_app� s r� c C s� | sd S d}xd| D ]\}|� d�}|d k r2|rd}q|� d�}|sDqqt||�r\d|d< d}qt||�rd|d< qW |s�x"| D ]}|� d�d kr|d|d< q|W | S )NF�in_appTr� )r) �_module_in_set)r� r� r� Z any_in_appr� r� r� r r r r� � s, r� c C s� t | t�r"t| �dkr"| \}}}ndt | t�rvt| dd �}|d k rNt| �}| }q�t�� \}}}|| k r�d }| }t| �}ntdt| � ��|||fS )N� r� z,Expected Exception object to report, got %s!) rY �tupler� � BaseExceptionr� rx rN rH ri )�errorr� r� r@ r r r rO � s rO c C s* t | �} t| �}ddt| ||�id�|fS )Nr� r� )�levelr� )rO rP r� )rH r� r� Zhintr r r �event_from_exception� s r� c C s8 |sdS x*|pdD ] }|| ks,| � |d �rdS qW dS )NFr r� T)r� )�namer� �itemr r r r� � s r� c C sX | s| S |d krt }t| �}||krTt| d |d � d |dd|d |ggd�d�S | S )Nr� z...z!limit�x)r� �rem)r? r� )�MAX_STRING_LENGTHr� r� )r? � max_length�lengthr r r r� s r� c C sx y,ddl m} | dd�r*| dd�r&dS dS W n tk r@ Y nX y dd lm} |d �r\dS W n tk rr Y nX dS ) z� Returns whether gevent/eventlet have patched the stdlib in a way where thread locals are now more "correct" than contextvars. r )�is_object_patched� threading�local� contextvars� ContextVarFT)�is_monkey_patchedr� )Z gevent.monkeyr r� Zeventlet.patcherr )r r r r r �_is_contextvars_broken s r c s G � fdd�dt �}|S )Nc s( e Zd Z� fdd�Zdd� Zdd� ZdS )z1_make_threadlocal_contextvars.<locals>.ContextVarc s || _ � � | _d S )N)�_name�_local)r; r� )r r r rm < s z:_make_threadlocal_contextvars.<locals>.ContextVar.__init__c S s t | jd|�S )Nr? )r� r )r; �defaultr r r r) A s z5_make_threadlocal_contextvars.<locals>.ContextVar.getc S s || j _d S )N)r r? )r; r? r r r r� E s z5_make_threadlocal_contextvars.<locals>.ContextVar.setN)rB rC rD rm r) r� r )r r r r 9 s r )�object)r r r )r r � _make_threadlocal_contextvars7 s r c C s~ t � sftjdk r<yddlm} d| fS tk r8 Y qfX n*yddlm} d| fS tk rd Y nX ddlm} dt |�fS )z� Figure out the "right" contextvars installation to use. Returns a `contextvars.ContextVar`-like class with a limited API. See https://docs.sentry.io/platforms/python/contextvars/ for more information. )r� ru r )r T)r F) r rN � version_infoZaiocontextvarsr r� r r r r )r r r r r �_get_contextvarsL s r z� With asyncio/ASGI applications, the Sentry SDK requires a functional installation of `contextvars` to avoid leaking scope/context data across requests. Please refer to https://docs.sentry.io/platforms/python/contextvars/ for more information. c C sz yd| j j| j j| jf S tk r, Y nX t| dd �pHt| dd �pHd }|sRd S yd| j|f S tk rt Y nX |S )Nz%s.%s.%srD rB z%s.%s)Zim_classrC rB r� r� )�funcZ func_qualnamer r r �transaction_from_function~ s r �disable_capture_eventc @ s e Zd ZdZdS )�ServerlessTimeoutWarningz>Raised when a serverless method is about to reach its timeout.N)rB rC rD rR r r r r r � s r c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) � TimeoutThreadz�Creates a Thread which runs (sleeps) for a time duration equal to waiting_time and raises a custom ServerlessTimeout exception. c C s& t j�| � || _|| _t �� | _d S )N)r �Threadrm � waiting_time�configured_timeout�Event� _stop_event)r; r r r r r rm � s zTimeoutThread.__init__c C s | j �� d S )N)r r� )r; r r r �stop� s zTimeoutThread.stopc C sJ | j �| j� | j �� r d S t| j�}|| jk r8|d }td�|���d S )Nr zZWARNING : Function is expected to get timed out. Configured timeout duration = {} seconds.)r �waitr �is_setrf r r �format)r; Zinteger_configured_timeoutr r r �run� s zTimeoutThread.runN)rB rC rD rR rm r r! r r r r r � s r )N)N)NN)NT)T)NN)NN)NN)NN)N)`r r� Zloggingr' rN r r- r � sentry_sdkZsentry_sdk._compatr r r r Zsentry_sdk._typesr �typesr r �typingr r r r r r r r r r r r r rI Z getLogger�loggerr ZMAX_FORMAT_PARAM_LENGTHr! r" r7 r9 r r: rF rG r= rK rM rP ri rQ rS rp r� r� r� Z Annotatedr� r� r� r� r� r� r� r� r� r� r� r� r� r� r� ZHAS_CHAINED_EXCEPTIONSr� r� r� r� r� r� r� rO r� r� r� r r r ZHAS_REAL_CONTEXTVARSr ZCONTEXTVARS_ERROR_MESSAGEr r r r r r r r r �<module> s� ( I; ( # % ! &