관리-도구
편집 파일: utils.cpython-38.pyc
U �Mg�� � @ s| d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl Z d dl Z d dl m Z d dlmZmZ d dlmZ d dlmZmZmZ d dlmZ d dlmZmZmZm Z m Z zd dl m Z W n e k r� dZ Y nX d dl!Z!d d l"m#Z# d d l$m%Z%m&Z& d d l'm(Z( e(�r�d d l)m*Z*m+Z+ d d l'm,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z; d dl<m=Z= d dl>m?Z?m@Z@ e6d�ZAe:d�ZBeddd�ZCe�Dd�ZEdaFe�Gd�ZHdZIeJd�ZKeJd�ZLdd�dd �ZMd d � ZNd d � ZOd!d"� ZPd#d$� ZQG d%d&� d&�ZReR� ZSd'd(� ZTd)d*� ZUd+d,� ZVd-d.� ZWeJd/�ZXd0d1� ZYd�d2d3�ZZG d4d5� d5e[�Z\G d6d7� d7�Z]G d8d9� d9�Z^G d:d;� d;�Z_e(�r�d d<l'm:Z: e:d=�Z`e;e_e`f Zad>d?� Zbd@dA� ZcdBdC� ZddDdE� Zed�dFdG�Zfd�dHdI�ZgdJdK� ZhdLdM� ZidNdO� Zjd�dQdR�Zkd�dSdT�ZldUdV� ZmdWdX� Znd�dYdZ�Zoepeqd[�Zrer�rPd\d]� Zsnd^d]� Zsd�d_d`�Ztd�dadb�Zudcdd� Zvdedf� Zwdgdh� Zxd�didj�Zyd�dkdl�Zzdmdn� Z{d�dodp�Z|dqdr� Z}dsdt� Z~dudv� Zdwdx� Z�dydz� Z�d�d{d|�Z�d}d~� Z�dd�� Z�d�d�� Z�d�d�� Z�e�� \Z�Z�d�Z�d�d�� Z�d�d�� Z�e�d��Z�G d�d�� d�eq�Z�G d�d�� d�e j��Z�d�d�� Z�d�d�� Z�e d�d�d�d�d�d�g�Z�d�d�d��Z�e d�d�d�d�g�Z�d�d�d��Z�d�d�� Z�d�d�d��Z�d�d�� Z�d�d�� Z�d�d�� Z�d�d�� Z�d�d�� Z�d�d�d��Z�d�d�� Z�e(�r�e5d�d�� �Z�e5d�d�� �Z�e�fd�d��Z�e#�rd�d�� Z�nd�d�� Z�d�d�� Z�z d d�l�m�Z� d d�l�m�Z� W n& e k �rd d�d�� Z�d�d�� Z�Y nX d�d�� Z�d�d�dÄZ�dS )�� N)� namedtuple)�datetime�timezone)�Decimal)�partial� partialmethod�wraps)�Real)�parse_qs�unquote� urlencode�urlsplit� urlunsplit)�BaseExceptionGroup)�PY37)�DEFAULT_MAX_VALUE_LENGTH� EndpointType)� TYPE_CHECKING)� FrameType� TracebackType)�Any�Callable�cast�ContextManager�Dict�Iterator�List�NoReturn�Optional�overload� ParamSpec�Set�Tuple�Type�TypeVar�Union)�Hub)�Event�ExcInfo�P�Ri� � zsentry_sdk.errorsz^[a-zA-Z0-9/+=]*$z [Filtered])�false�f�n�no�off�0)�true�t�y�yes�on�1F)�strictc C s@ | dk rt | ��� nd}|tkr$dS |tkr0dS |r8dS t| �S )z�Casts an ENV variable value to boolean using the constants defined above. In strict mode, it may return None if the value doesn't match any of the predefined values. NFT)�str�lower�FALSY_ENV_VALUES�TRUTHY_ENV_VALUES�bool)�valuer8 � normalized� r@ �>/opt/hc_python/lib/python3.8/site-packages/sentry_sdk/utils.py� env_to_boolM s rB c C s t j| ddd��d�S )zCSerialize data into a compact JSON representation encoded as UTF-8.F)�,�:)� allow_nan� separators�utf-8)�json�dumps�encode)�datar@ r@ rA � json_dumps] s rL c C s� z|t tjjd��d} d }tjdks*tjdkrBt�� }| jtj O _tj dddg|tj | | d�� � d � � �d �}W 5 Q R X W n tttfk r� Y d S X |S ) Nzw+�win32�cygwin�gitz rev-parse�HEAD)� startupinfo�stdout�stderr�stdinr rG )�open�os�path�devnull�sys�platform� subprocessZ STARTUPINFOZdwFlagsZSTARTF_USESHOWWINDOW�Popen�PIPE� communicate�strip�decode�OSError�IOError�FileNotFoundError)�nullrQ �revisionr@ r@ rA �get_git_revisionc s* �� �� rf c C sH t j�d�} | r| S t� } | r"| S dD ] }t j�|�} | r&| S q&dS )z Try to guess a default release.ZSENTRY_RELEASE)ZHEROKU_SLUG_COMMITZSOURCE_VERSIONZ!CODEBUILD_RESOLVED_SOURCE_VERSIONZ CIRCLE_SHA1ZGAE_DEPLOYMENT_IDN)rV �environ�getrf )�release�varr@ r@ rA �get_default_release s rk c C sP ddddddddd d d d d dddddddg}|D ]}|| kr0d� |� S q0dS )zAReturn the SDK name including the name of the used web framework.�djangoZflaskZfastapiZbottleZfalconZquartZsanicZ starletteZlitestarZstarliteZchaliceZ serverlessZpyramid�tornadoZaiohttpZ aws_lambdaZgcpZbeamZasgiZwsgizsentry.python.{}z sentry.python)�format)Zinstalled_integrationsZframework_integrations� integrationr@ r@ rA � get_sdk_name� s2 �rp c @ s e Zd ZdZdd� Zdd� ZdS )�CaptureInternalExceptionr@ c C s | S �Nr@ ��selfr@ r@ rA � __enter__� s z"CaptureInternalException.__enter__c C s" |d k r |d k r t |||f� dS )NT)�capture_internal_exception)rt �tyr> �tbr@ r@ rA �__exit__� s z!CaptureInternalException.__exit__N)�__name__� __module__� __qualname__� __slots__ru ry r@ r@ r@ rA rq � s rq c C s t S rr )�_CAPTURE_INTERNAL_EXCEPTIONr@ r@ r@ rA �capture_internal_exceptions� s r c C s t �� �� rtjd| d� dS )z� Capture an exception that is likely caused by a bug in the SDK itself. These exceptions do not end up in Sentry and are just logged instead. z Internal error in sentry_sdk��exc_infoN)� sentry_sdk� get_clientZ is_active�logger�errorr� r@ r@ rA rv � s rv c C s | t �� S rr )�epoch� total_seconds�r> r@ r@ rA � to_timestamp� s r� c C s | � tj�}|�d�S )z�Formats a timestamp in RFC 3339 format. Any datetime objects with a non-UTC timezone are converted to UTC, so that all timestamps are formatted in UTC. z%Y-%m-%dT%H:%M:%S.%fZ)� astimezoner �utc�strftime)r> Zutctimer@ r@ rA �format_timestamp� s r� )�+�-c C s� zt �| �}W n� ttfk r� d| kr.dnd}| �d�rL| d d� d } | d tkrz|d7 }| d d � | d d � } n| d tkr�|d7 }t �| |�}Y nX |�tj �S ) N�.z%Y-%m-%dT%H:%M:%S.%fz%Y-%m-%dT%H:%M:%S�Z���z+0000i����z%z���������) r � fromisoformat�AttributeError� ValueError�endswith�ISO_TZ_SEPARATORS�strptimer� r r� )r> �resultZtimestamp_formatr@ r@ rA �datetime_from_isoformat� s � r� c C s2 | dkrt �� } nt| �} | d dkr*d} d| iS )z+Creates a hint with the exc info filled in.Nr r� )rY r� �exc_info_from_errorr� r@ r@ rA �event_hint_with_exc_info s r� c @ s e Zd ZdZdS )�BadDsnzRaised on invalid DSNs.N�rz r{ r| �__doc__r@ r@ r@ rA r� s r� c @ s6 e Zd ZdZdd� Zedd� �Zd dd�Zd d � ZdS ) �DsnzRepresents a DSN.c C s t |t�rt|j�| _d S tt|��}|jdkr>td|j ��|j| _|jd krXtd��|j| _ |j d kr�| jdkrxdpzd| _ n|j | _ |j s�td��|j | _ |j | _|j�dd �}ztt|�� ��| _W n2 ttfk r� td |jp�d d d � ��Y nX d�|�d | _d S ) N)�http�httpszUnsupported scheme %rzMissing hostnamer� � �P zMissing public key�/r+ zInvalid project in DSN (%r)� )� isinstancer� �dict�__dict__r r9 �schemer� �hostname�host�port�username� public_key�password� secret_keyrW �rsplit�int�pop� project_idr� � TypeError�join)rt r> �partsrW r@ r@ rA �__init__ s. z Dsn.__init__c C s( | j }| j| jfdkr$d|| jf }|S )zThe netloc part of a DSN.))r� r� )r� r� z%s:%s)r� r� r� �rt �rvr@ r@ rA �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� rW r� r� r� �client)�Authr� r� rW r� r� r� )rt r� r@ r@ rA �to_authI 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�@r� )r� r� r� r� rW r� rs r@ r@ rA �__str__V s �z Dsn.__str__)N) rz r{ r| r� r� �propertyr� r� r� r@ r@ r@ rA r� s $ r� c @ s0 e Zd ZdZd dd�Zejfdd�Zd d � ZdS ) r� z,Helper object that represents the auth info.N� r� c C s4 || _ || _|| _|| _|| _|| _|| _|| _d S rr )r� r� rW r� r� r� �versionr� ) rt r� r� r� r� r� r� r� rW r@ r@ rA r� e s z Auth.__init__c C s d| j | j| j| j|jf S )z'Returns the API url for storing events.z%s://%s%sapi/%s/%s/)r� r� rW r� r> )rt �typer@ r@ rA � get_api_urlz s �zAuth.get_api_urlc C s` d| j fd| jfg}| jdk r.|�d| jf� | jdk rH|�d| jf� dd�dd � |D �� S ) z!Returns the auth header a string.Z sentry_keyZsentry_versionNZ sentry_clientZ sentry_secretzSentry z, c s s | ]\}}d ||f V qdS )z%s=%sNr@ )�.0�keyr> r@ r@ rA � <genexpr>� s z!Auth.to_header.<locals>.<genexpr>)r� r� r� �appendr� r� r� r@ r@ rA � to_header� s zAuth.to_header)Nr� Nr� ) rz r{ r| r� r� r ZENVELOPEr� r� r@ r@ r@ rA r� b s � � r� c @ sH e Zd ZdZdZdd� Zdd� Zedd� �Zed d � �Z ed d � �Z d S )�AnnotatedValuea Meta information for a data field in the event payload. This is to tell Relay that we have tampered with the fields value. See: https://github.com/getsentry/relay/blob/be12cd49a0f06ea932ed9b9f93a655de5d6ad6d1/relay-general/src/types/meta.rs#L407-L423 �r> �metadatac C s || _ || _d S rr r� )rt r> r� r@ r@ rA r� � s zAnnotatedValue.__init__c C s& t |t�sdS | j|jko$| j|jkS �NF)r� r� r> r� )rt �otherr@ r@ rA �__eq__� s zAnnotatedValue.__eq__c C s t ddddggid�S )zxThe value was removed because it could not be parsed. This is done for request body values that are not json nor a form.r� �remz!raw�xr� �r� ��clsr@ r@ rA �removed_because_raw_data� s ����z'AnnotatedValue.removed_because_raw_datac C s t ddddggid�S )z�The actual value was removed because the size of the field exceeded the configured maximum size (specified with the max_request_body_size sdk option)r� r� �!configr� r� r� r� r@ r@ rA � removed_because_over_size_limit� s ����z.AnnotatedValue.removed_because_over_size_limitc C s t tdddggid�S )zHThe actual value was removed because it contained sensitive information.r� r� �sr� )r� �SENSITIVE_DATA_SUBSTITUTEr� r@ r@ rA �+substituted_because_contains_sensitive_data� s ����z:AnnotatedValue.substituted_because_contains_sensitive_dataN) rz r{ r| r� r} r� r� � classmethodr� r� r� r@ r@ r@ rA r� � s r� )r$ �Tc C s t | dd �pt | dd �S )Nr| rz ��getattrr� r@ r@ rA � get_type_name� s r� c C s t | dd �}|dkr|S d S )Nr{ )N�builtins� __builtins__r� )r� �modr@ r@ rA �get_type_module� s r� c C sr z | j d }|�d�r W dS W n ttfk r6 Y nX dD ]0}z| j| rTW dS W q< tk rj Y q<X q<dS )Nrz z sentry_sdk.T)Z__traceback_hide__�__tracebackhide__F)� f_globals� startswithr� �KeyError�f_locals� Exception)�framer� Z flag_namer@ r@ rA �should_hide_frame� s r� c c s( | }|d k r$t |j�s |V |j}qd S rr )r� �tb_frame�tb_next)rx Ztb_r@ r@ rA � iter_stacks s r� c sB d}d }|d k rVt |d�rVz|�|�}W n ttfk rD d }Y nX |d k rV|�� }|d kr�zt�| �}W n" ttfk r� g d g f Y S X |s�g d g fS td|| �}t |d | t |��} zZ� fdd�|||� D �} t || � d�� d�} � fd d�||d | � D �} | | | fW S t k �r< g d g f Y S X d S ) N� � get_sourcer r+ c s g | ]}t |�d �� d��qS �� �� max_length�� strip_stringr_ �r� �liner� r@ rA � <listcomp>( s �z'get_lines_from_file.<locals>.<listcomp>r� r� c s g | ]}t |�d �� d��qS r� r� r� r� r@ rA r� - s �)�hasattrr� � ImportErrorrb � splitlines� linecache�getlinesra �max�min�lenr� r_ � IndexError) �filename�linenor� �loader�moduleZ context_lines�sourceZ source_str� lower_bound� upper_bound� pre_context� context_line� post_contextr@ r� rA �get_lines_from_file s: � � r c C s� z | j j}W n tk r$ d }Y nX z| jd }W n tk rR g d g f Y S X z| jd }W n tk rz d }Y nX |d }|d k r�|r�t|||||d�S g d g fS )Nrz � __loader__r+ )r r )�f_code� co_filenamer� r� r )r� � tb_lineno�max_value_length�abs_pathr r r r@ r@ rA �get_source_context7 s, �r c C s, z t | �W S tk r& t| � Y S X d S rr )r9 r� � safe_reprr� r@ r@ rA �safe_strQ s r c C s& z t | �W S tk r Y dS X d S )Nz <broken repr>)�reprr� r� r@ r@ rA r Y s r c C s� |r| s |S zz|� d�r$|d d� }| �dd�d }|| krJtj�|�W S tj| j}|s`|W S |�|�tj d�d d�d � tj �W S t k r� | Y S X d S )Nz.pycr� r� r+ r � ) r� �splitrV rW �basenamerY �modules�__file__r� �sep�lstripr� )r r � base_moduleZbase_module_pathr@ r@ rA �filename_for_modulea s �r% Tc C s� t | dd �}|sd }d }n| jj}| jj}z| jd } W n tk rP d } Y nX |d kr`| j}t| |�pld |r|tj � |�nd |p�d| |d�} |r�t | ||�\| d< | d< | d< |r�dd l m } | t| j�d |d �| d < | S ) Nr rz z <unknown>)r r �functionr r r r r r )� serializeT)Zis_vars� custom_repr�vars)r� r r �co_namer� r� �f_linenor% rV rW �abspathr Zsentry_sdk.serializerr' r� r� ) r� r �include_local_variables�include_source_contextr r( r r r& r r� r' r@ r@ rA �serialize_framey s@ � � � r/ c C sN d}g }t �� }|d k r>t|�s6|�t|| ||d�� |j}q|�� d|iS )NT)r- r. r �frames)rY � _getframer� r� r/ �f_back�reverse)r- r. r r� r0 r- r@ r@ rA �current_stacktrace� s ��r4 c C s t | dd �S )N�errnor� )� exc_valuer@ r@ rA � get_errno� s r7 c C sb t | dd�p t | dd�p t| �}t | dd �}t|t�r^t|�dkr^|dd�dd� |D �� 7 }|S ) N�messager� �detail� __notes__r � c s s | ]}t |t�r|V qd S rr )r� r9 )r� Znoter@ r@ rA r� � s z$get_error_message.<locals>.<genexpr>)r� r r� �listr r� )r6 r8 �notesr@ r@ rA �get_error_message� s �� r> c s� i }|r|� � nddd�|d< |dk r2||d d< |dk rDt|�} nd} | dk rp|d �di ��di ��d | � |dk r�||d d < |d k} | s�|dk r�||d d < d |d d< | r�d|d kr�d|d d< tdk o�t|t�} | r�d|d d< t| �|d< t| �|d< t|�|d< |dk�r.d�d�t�d� n"|d �|d �|d �|� d�� � ���fdd�t |�D �} | �r~d| i|d< |S )z� Creates a dict that goes into the events `exception.values` list and is ingestible by Sentry. See the Exception Interface documentation for more details: https://develop.sentry.dev/sdk/event-payloads/exception/ ZgenericT)r� Zhandled� mechanismN� exception_id�metar5 �numberr r � parent_idZchainedr� �is_exception_groupr r> r- r. r r( c s$ g | ] }t |j|j���� d ��qS ))r r- r. r r( )r/ r� r )r� rx �r( r- r. r r@ rA r� s ��z5single_exception_from_error_tuple.<locals>.<listcomp>r0 � stacktrace) �copyr7 � setdefaultr r� r� r� r> r rh r� ) �exc_typer6 rx �client_optionsr? r@ rC r Zexception_valuer5 Zis_root_exceptionrD r0 r@ rE rA �!single_exception_from_error_tuple� s` � � � � � rK �__suppress_context__c c s� | \}}}g }t � }|d k r�|d k r�t|�|kr�|||fV |�|� |�t|�� |jrb|j}n|j}|d krrq�t|�}|}t|dd �}qd S )N� __traceback__) �set�idr� �addrL � __cause__� __context__r� r� )r� rI r6 rx Zseen_exceptionsZseen_exception_ids�causer@ r@ rA �walk_exception_chain3 s( �� � rT c c s | V d S rr r@ r� r@ r@ rA rT S s c C sL t | |||||||d�}|g} |}|d7 }t|d�o8|j} | r�|oTt|d�oT|jdk } | r�|j} tt| �| t| dd�|||dd�\}} | �| � nR|o�t|d�o�|jdk }|r�|j}tt|�|t|dd�|||dd�\}} | �| � |o�t|d �}|�rDt |j �D ]@\}}tt|�|t|dd�||||d | d�\}} | �| � �q|| fS ) z� Creates the list of exceptions. This can include chained exceptions and exceptions from an ExceptionGroup. See the Exception Interface documentation for more details: https://develop.sentry.dev/sdk/event-payloads/exception/ )rI r6 rx rJ r? r@ rC r r+ rL rQ NrM )rI r6 rx rJ r? r@ r rR � exceptionszexceptions[%s]) rK r� rL rQ �exceptions_from_errorr� r� �extendrR � enumeraterU )rI r6 rx rJ r? r@ rC r �parentrU Zshould_supress_contextZexception_has_causerS Zchild_exceptionsZexception_has_content�contextrD �idx�er@ r@ rA rV X s� � �� � �� � � rV c C sv | \}}}t d k ot|t �}|r<t|||||ddd�\}}n.g }t| �D ] \}}}|�t|||||�� qH|�� |S )Nr )rI r6 rx rJ r? r@ rC )r r� rV rT r� rK r3 ) r� rJ r? rI r6 rx rD �_rU r@ r@ rA �exceptions_from_error_tuple� s8 �� ��r^ c C s4 z t | �W S tk r. t| �dd� Y S X d S )Nr+ r� )r9 �UnicodeDecodeErrorr r� r@ r@ rA � to_string� s r` c c sz d| kr| d V d| krD| d � d�p*dD ]}d|kr,|d V q,d| krv| d � d�p\dD ]}d|kr^|d V q^d S )NrF �threads�valuesr@ � exception)rh )�event�threadrc r@ r@ rA �iter_event_stacktraces� s rf c c s, t | �D ] }|�d�pdD ] }|V qqd S )Nr0 r@ )rf rh )rd rF r� r@ r@ rA �iter_event_frames� s rg c C s( t | �D ]}t|�d�|||d� q| S )Nr0 )�in_app_exclude�in_app_include� project_root)rf �set_in_app_in_framesrh )rd rh ri rj rF r@ r@ rA � handle_in_app� s �rl c C s� | sd S | D ]�}|� d�}|d k r$q |� d�}t||�rBd|d< q t||�rVd|d< q |� d�}|d krjq t|�r|d|d< q t||�r d|d< q q | S )NZin_appr TFr )rh �_module_in_list�_is_external_source�_is_in_project_root)r0 rh ri rj r� Zcurrent_in_appr r r@ r@ rA rk s. rk c C s� t | t�r"t| �dkr"| \}}}ndt | t�rvt| dd �}|d k rNt| �}| }q�t�� \}}}|| k r�d }| }t| �}ntdt| � ��|||f}t r�t t |�}|S )N� rM z,Expected Exception object to report, got %s!) r� �tupler � BaseExceptionr� r� rY r� r� r r r( )r� rI r6 rx r� r@ r@ rA r� . s" r� c C s* t | �} t| �}ddt| ||�id�|fS )Nr� rb )�levelrc )r� r� r^ )r� rJ r? �hintr@ r@ rA �event_from_exceptionK s ����ru c C s> | d kr dS |sdS |D ] }|| ks2| � |d �r dS qdS )NFr� T�r� )�name�items�itemr@ r@ rA rm ` s rm c C s | d kr dS t �d| �d k }|S )NFz [\\/](?:dist|site)-packages[\\/]��re�search)r Zexternal_sourcer@ r@ rA rn o s �rn c C s& | d ks|d krdS | � |�r"dS dS )NFTrv )r rj r@ r@ rA ro { s ro c C s( | � d�d|d � jddd�}|d S )zd Truncate a UTF-8-encodable string to the last full codepoint so that it fits in max_bytes. rG Nrp �ignore)�errors�...)rJ r` )�stringZ max_bytes� truncatedr@ r@ rA �_truncate_by_bytes� s r� c C s0 zt | �d��W S ttfk r* Y d S X d S )NrG )r rJ �UnicodeEncodeErrorr_ r� r@ r@ rA �_get_size_in_bytes� s r� c C s� | s| S |d krt }t| �}t| �}|d k r@||kr@t| |�}n*|d k rf||krf| d |d � d }n| S t||pt|dd|d |ggd�d�S )Nrp r z!limitr� )r r� r� )r r� r r� r� )r> r� Z byte_sizeZ text_sizeZtruncated_valuer@ r@ rA r� � s" ��r� c C st d}t �d| d t jt jB �}z2|�| ��� d }ttt|� d�dd� ��}W n t t t fk rn Y dS X |S )z� Parses a version string into a tuple of integers. This uses the parsing loging from PEP 440: https://peps.python.org/pep-0440/#appendix-b-parsing-version-strings-with-regular-expressions a # noqa: N806 v? (?: (?:(?P<epoch>[0-9]+)!)? # epoch (?P<release>[0-9]+(?:\.[0-9]+)*) # release segment (?P<pre> # pre-release [-_\.]? (?P<pre_l>(a|b|c|rc|alpha|beta|pre|preview)) [-_\.]? (?P<pre_n>[0-9]+)? )? (?P<post> # post release (?:-(?P<post_n1>[0-9]+)) | (?: [-_\.]? (?P<post_l>post|rev|r) [-_\.]? (?P<post_n2>[0-9]+)? ) )? (?P<dev> # dev release [-_\.]? (?P<dev_l>dev) [-_\.]? (?P<dev_n>[0-9]+)? )? ) (?:\+(?P<local>[a-z0-9]+(?:[-_\.][a-z0-9]+)*))? # local version z^\s*z\s*$ri r� Nrp ) r{ �compile�VERBOSE� IGNORECASE�match� groupdictrq �mapr� r r� r� r� )r� �VERSION_PATTERN�patternri Z release_tupler@ r@ rA � parse_version� s � r� c C s� znddl } ddlm} tdd� t�d| j�dd� D ��}|dd �rltjd krV|d ks`|d d �rfW dS W dS W n t k r� Y nX zPddl }ddl m } t |j�}|dkr�t�d� W dS |d�r�|dk r�W dS W n t k r� 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 N)�is_object_patchedc S s g | ] }t |��qS r@ )r� )r� �partr@ r@ rA r� � s z*_is_contextvars_broken.<locals>.<listcomp>z a|b|rc|\.r � threading�local�rp r� )� � � contextvars� ContextVarFT)�is_monkey_patchedzYInternal error in Sentry SDK: Could not parse Greenlet version from greenlet.__version__.re )r r� )�gevent� gevent.monkeyr� rq r{ r � __version__rY � version_infor �greenletZeventlet.patcherr� r� r� r� )r� r� � version_tupler� r� Zgreenlet_versionr@ r@ rA �_is_contextvars_broken� s> � ��� � r� c s G � fdd�d�}|S )Nc s4 e Zd Zd � fdd� Zd dd�Zdd� Zdd � ZdS ) z1_make_threadlocal_contextvars.<locals>.ContextVarNc s || _ || _� � | _� � | _d S rr )�_name�_default�_local�_original_local)rt rw �default�r� r@ rA r� # s z:_make_threadlocal_contextvars.<locals>.ContextVar.__init__c S s t | jd|p| j�S )Nr> )r� r� r� )rt r� r@ r@ rA rh * s z5_make_threadlocal_contextvars.<locals>.ContextVar.getc S s0 t t�d��}| �� }t| j||� || j_|S )N�@ )r9 �random� getrandbitsrh �setattrr� r� r> )rt r> �token�original_valuer@ r@ rA rN . s z5_make_threadlocal_contextvars.<locals>.ContextVar.setc S s t | j|�| j_| jj|= d S rr )r� r� r� r> r� )rt r� r@ r@ rA �reset6 s z7_make_threadlocal_contextvars.<locals>.ContextVar.reset)N)N)rz r{ r| r� rh rN r� r@ r� r@ rA r� s r� r@ )r� r� r@ r� rA � _make_threadlocal_contextvars s r� c C s� t � sjtjdk r>zddlm} d| fW S tk r: Y qjX n,zddlm} d| fW S tk rh 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� r )r� Tr� F) r� rY r� Zaiocontextvarsr� r r� r� r� r� )r� r� r@ r@ rA �_get_contextvars? 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 s� d}zd| j j| j j| jf W S tk r2 Y nX d\}}t| t�rbt| jd�rbd\}}| j} n0t| dd�pxt| dd�}t|t �r�d\}}|j} t| d �r�| j }nt| d�r�| j}|dk r�t| d �r�| jd | }|| | }|S ) zbReturn the qualified name of func. Works with regular function, lambda, partial and partialmethod.Nz%s.%s.%s)r� r� rz )zpartial(<function �>)�_partialmethodZ__partialmethod__)zpartialmethod(<function r� r| r{ r� ) Zim_classr{ rz r� r� r r� �funcr� r r| )r� Z func_qualname�prefix�suffixZpartial_methodr@ r@ rA �qualname_from_functionq s< � � r� c C s t | �S rr )r� )r� r@ r@ rA �transaction_from_function� s r� �disable_capture_eventc @ s e Zd ZdZdS )�ServerlessTimeoutWarningz>Raised when a serverless method is about to reach its timeout.Nr� r@ r@ r@ rA 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 rr )r� �Threadr� � waiting_time�configured_timeoutr' � _stop_event)rt r� r� r@ r@ rA r� � s zTimeoutThread.__init__c C s | j �� d S rr )r� rN rs r@ r@ rA �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_setr� r� r� rn )rt Zinteger_configured_timeoutr@ r@ rA �run� s ��zTimeoutThread.runN)rz r{ r| r� r� r� r� r@ r@ r@ rA r� � s r� c C sb d}z"| � d�}t�|�}|�d�}W n6 tk r\ } zt�dj| d�|� W 5 d}~X Y nX |S )zO Convert a string to base64, via UTF-8. Returns None on invalid input. N�UTF-8z"Unable to encode {orig} to base64:)�orig)rJ �base64� b64encoder` r� r� �warningrn )�original� base64_string� utf8_bytes� base64_bytes�errr@ r@ rA � to_base64� s &r� c C st d}z4t �| �}|st�| �d�}t�|�}|�d�}W n6 tk rn } zt� dj | d�|� W 5 d}~X Y nX |S )zQ Convert a string from base64, via UTF-8. Returns None on invalid input. Nr� z#Unable to decode {b64} from base64:)Zb64) �BASE64_ALPHABETr� �AssertionErrorrJ r� � b64decoder` r� r� r� rn )r� Z utf8_stringZonly_valid_charsr� r� r� r@ r@ rA � from_base64� s �r� � Componentsr� r� rW �query�fragmentc C s� t | �}t|jdd�}|rN|j�d�}t|�dkrFdtt|d f }qT|j}n|j}|rpttdd� |D ���}n|j}t |j |||j |j d �} |r�| S t | �S d S ) zL Removes the authority and query parameter values from a given URL. T)�keep_blank_valuesr� r+ z%s:%s@%sr� c S s i | ] }|t �qS r@ )r� )r� r� r@ r@ rA � <dictcomp> s z sanitize_url.<locals>.<dictcomp>�r� r� r� rW r� N)r r r� r� r r r� r r r� r� rW r� r ) �url�remove_authority�remove_query_valuesr � parsed_urlZ query_paramsZ netloc_partsr� Z query_string� componentsr@ r@ rA � sanitize_url� s6 ���r� � ParsedUrlr� c C s> t | d|dd�}tt|j|jd|jdd��}t||j|jd�S )z� Splits a URL into a url (including path), query and fragment. If sanitize is True, the query parameters will be sanitized to remove sensitive data. The autority (username and password) in the URL will always be removed. T)r� r� r r� r� )r� r� r� ) r� r r� r� r� rW r� r� r� )r� �sanitizer� �base_urlr@ r@ rA � parse_url* s( ��� �r� c C sj t | ttf�rt�| �r6t�dj|| t| �d�� dS t | �} | dk sN| dkrft�dj|| d�� dS dS ) z� Checks the given sample rate to make sure it is valid type and value (a boolean or a number between 0 and 1, inclusive). z|{source} Given sample rate is invalid. Sample rate must be a boolean or a number between 0 and 1. Got {rate} of type {type}.)r �rater� Fr r+ zW{source} Given sample rate is invalid. Sample rate must be between 0 and 1. Got {rate}.)r r� T) r� r r �math�isnanr� r� rn r� �float)r� r r@ r@ rA �is_valid_sample_rateF s& �� ��r� c C sH |d kr dS |D ]2}|s,|d dkr,|d7 }t �|| �}|r dS qdS )NFr� �$Trz )ry Z regex_listZsubstring_matchingZ item_matcherZmatchedr@ r@ rA �match_regex_liste s r� c C s, | dk o*| j dk o*| j jdk o*| j jj|kS )zB Determines whether the given URL matches the Sentry DSN. N)� transportZ parsed_dsnr� )r� r� r@ r@ rA � is_sentry_urlu s � � �r� c c s� zfddl m} t� }| �� D ]F}|jd }|d k r t|�}|jd k r ||kr ||jfV |�|� q W nX tk r� z dd l}W n tk r� Y Y d S X |j D ]}t|j �|jfV q�Y nX d S )Nr )r� �Name) � importlibr� rN � distributions�_normalize_module_namer� rP r � pkg_resources� working_setr� )r� �yielded�distrw �normalized_namer� �infor@ r@ rA �_generate_installed_modules� s" r� c C s | � � S rr )r: )rw r@ r@ rA r� � s r� c C s t d krtt� �a t S rr )�_installed_modulesr� r� r@ r@ r@ rA �_get_installed_modules� s r� c C s$ t � }|�| �}|d kr d S t|�S rr )r� rh r� )�packageZinstalled_packagesr� r@ r@ rA �package_version� s r� c C s( |d k s t �|j|k r |�|��|�d S rr )r� rM �with_traceback)�tpr> rx r@ r@ rA �reraise� s r� c O s dS )z.No-op function for ensure_integration_enabled.Nr@ )Z_aZ_kr@ r@ rA �_no_op� s r� c C s d S rr r@ �ro �original_functionr@ r@ rA �ensure_integration_enabled� s r� c C s d S rr r@ )ro r@ r@ rA r� � s c s( t rttttf ���� �fdd�}|S )a� Ensures a given integration is enabled prior to calling a Sentry-patched function. The function takes as its parameters the integration that must be enabled and the original function that the SDK is patching. The function returns a function that takes the decorated (Sentry-patched) function as its parameter, and returns a function that, when called, checks whether the given integration is enabled. If the integration is enabled, the function calls the decorated, Sentry-patched function. If the integration is not enabled, the original function is called. The function also takes care of preserving the original function's signature and docstring. Example usage: ```python @ensure_integration_enabled(MyIntegration, my_function) def patch_my_function(): with sentry_sdk.start_transaction(...): return my_function() ``` c s8 ddd���� fdd� }�t kr,t� �|�S t��|�S )NzP.argszP.kwargs��args�kwargsc s& t �� �� �d kr �| |�S �| |�S rr )r� r� Zget_integrationr� )ro r� �sentry_patched_functionr@ rA �runner� s z;ensure_integration_enabled.<locals>.patcher.<locals>.runner)r� r )r r r� )r rA �patcher� s z+ensure_integration_enabled.<locals>.patcher)r r r r) r* )ro r� r r@ r� rA r� � s c C s t �� S rr )�time�perf_counter_nsr@ r@ r@ rA �nanosecond_time s r c C s t t�� d �S )Ng e��A)r� r � perf_counterr@ r@ r@ rA r s c C s t �� S rr )r r r@ r@ r@ rA �now s r )�get_hub��is_module_patchedc C s d S rr r@ r@ r@ r@ rA �get_gevent_hub s r c C s dS r� r@ )�mod_namer@ r@ rA r # s r c C s t d�pt d�S )Nr� �_threadr r@ r@ r@ rA � is_gevent) s r c C s� | dk r@z"| j }| j}|dk r(||fW S W n tk r> Y nX t� rvt� }|dk rvz |jdfW S tk rt Y nX z*t�� } | j }| j}|dk r�||fW S W n tk r� Y nX z*t�� } | j }| j}|dk r�||fW S W n tk r� Y nX dS )zK Try to get the id of the current thread, with various fall backs. N)NN) �identrw r� r r Z thread_identr� �current_thread� main_thread)re Z thread_idZ thread_nameZ gevent_hubr@ r@ rA �get_current_thread_meta. s@ r )N)NNN)N)NTTNN)TTN)NNNNN)NNr r N)NN)NNN)N)NN)N)TTF)T)NF)N)N)�r� rH r �loggingr� rV r� r{ r[ rY r� r � collectionsr r r �decimalr � functoolsr r r �numbersr � urllib.parser r r r r r� r r r� Zsentry_sdk._compatr Zsentry_sdk.constsr r �typingr �typesr r r r r r r r r r r r r r! r" r# r$ r% Z gevent.hubr& Zsentry_sdk._typesr' r( r) r* r� � getLoggerr� r� r� r� r� � frozensetr; r< rB rL rf rk rp rq r~ r rv r� r� r� r� r� r� r� r� r� r� r� � Annotatedr� r� r� r� r r r r r% r/ r4 r7 r> rK r� r� ZHAS_CHAINED_EXCEPTIONSrT rV r^ r` rf rg rl rk r� ru rm rn ro r� r� r� r� r� r� r� ZHAS_REAL_CONTEXTVARSr� ZCONTEXTVARS_ERROR_MESSAGEr� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r� r r r� r r r r@ r@ r@ rA �<module> sJ H $ I0G � 1 � � 0 � � T � b � % ' � 44!& ,& , � 0