File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/__pycache__/helpers.cpython-310.pyc
Back
o ;j�� � @ sx U d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlmZ ddlmZmZmZmZmZ ddlmZ ddlmZ ddl m Z ddl m Z dd l m!Z! dd l"m#Z# dd l$m%Z% dd l&m'Z'm(Z( dd l)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1 ddl2m3Z3 ddl4m5Z5m6Z6 ddl7Z7ddl8m9Z9m:Z:m;Z; ddl<m=Z> ddl?m@Z@ ddlAmBZB ddlCmDZD e jEdkr�ddlZFnddlFZFdZGe �H� dkZIe �H� dkZJe jEdkZKdZLe/d�ZMe/d �ZNe�Od d �ZPePjQZQeRe jS�Td ��ZUeVd d!geWd"d#��R �ZXeBjYZZe j[j\�p.e j[j] �o.eRe jS�Td$��Z^d%d&� eWdd'�D �Z_d(d&� eWdd)�D �e`d*�hB Zad+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;d<e`d=�hZbe_eaA ebA ZcG d>d?� d?�Zdd�dBeedCeedDeedEeefdFdG�ZfG dHdI� dIedIg dJ���Zg Kd�dBeedCeedDeedEegfdLdM�ZhdNe@dEeie@egdB f fdOdP�ZjdEe j dB fdQdR�Zke7jldSdSdSdT�G dUdV� dV��ZmdWe j dB dXeedEegfdYdZ�ZndEeoeeemf fd[d\�ZpdNe@dEeie@egdB f fd]d^�Zqe7jldSdSdSdT�G d_d`� d`��Zrejsdadb�dceedEerfddde��ZtG dfdg� dge�Zuejsdadb�dheedEeieee'eeeef f fdidj��Zvd�dke*dleedB dEeedB fdmdn�Zwe �xdo�Zydpd&� eWd)d*�D �dqhB ZzdreedEeefdsdt�Z{ Ad�dueedveRdweedxeedEeef dydz�Z|dXeedB dEeRfd{d|�Z}dXeedEeRfd}d~�Z~dae�dB e�d< d@a�dEeefd�d��Z�d�d�d��Z� �d�d�e�d�eed�e�d�ej�d�e�dEej�dB f d�d��Z� �d�d�eg e*f d�e�d�ej�d�e�dEej�dB f d�d��Z�d�e�d�e�d�e�dEe�fd�d��Z�G d�d�� d��Z�G d�d�� d�e+d� �Z�G d�d�� d�e��Z�G d�d�� d�e��Z� �d�d�e�dB d�e�dEeFj�fd�d��Z�G d�d�� d��Z�d�d�d�eMdEdfd�d��Z�e�� Z�G d�d�� d�e.�Z�e�fd�d�d�e�d�e�dEdfd�d��Z�ej�G d�d�� d�e,eM ��Z�G d�d�� d�e�eM �Z�G d�d�� d�e�eM �Z�G d�d�� d�e�eM �Z�G d�d�� d�eeee�e* B e*f �Z�d�Z�e �xe��Z�d�e�� d��Z�e �xe��Z�e �xd+e�� d���Z�d�Z�e7jldSdSdSdT�G d�d�� d���Z�d�eedEdfd�dZ�d�eedB dEejdB fd�dńZ�ejsd�eed�e�dEeRfd�dɄ�Z�d�eed�e�dEeRfd�d˄Z�dS )�zVarious helper functions� N)� namedtuple)�Callable� Generator�Iterable�Iterator�Mapping)�suppress)� EmailMessage)� HeaderParser)�HTTP)� parsedate��ceil)�Path)�MappingProxyType� TracebackType)�Any�ContextManager�Generic�Optional�Protocol�TypeVar�get_args�overload)�quote)� getproxies� proxy_bypass)� MultiDict�MultiDictProxy� MultiMapping)�under_cached_property��URL� )�hdrs)� client_logger�� � )� BasicAuth� ChainMapProxy�ETag�reify�Darwin�Windowsi �_T�_S� _SENTINEL�sentinelZAIOHTTP_NO_EXTENSIONS�� i0 �d �� ZPYTHONASYNCIODEBUGc C � h | ]}t |��qS � ��chr��.0�ir7 r7 �C/opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/helpers.py� <setcomp>V � r> � c C r6 r7 r8 r: r7 r7 r= r> W r? � � �(�)�<�>�@�,�;�:�\�"�/�[�]�?�=�{�}� � c @ s e Zd Zded fdd�ZdS )�noop�return)NNNc c s � d V d S �Nr7 ��selfr7 r7 r= � __await__s s � znoop.__await__N)�__name__� __module__� __qualname__r r[ r7 r7 r7 r= rV r s rV � �utf-8�login�password�encodingrW c C s8 d| v rt d��| � d|� ��|�}dt�|��|� S )z�Encode HTTP Basic Authentication credentials as an Authorization header value. Returns a string of the form ``"Basic <base64>"`` suitable for use as the value of the ``Authorization`` (or ``Proxy-Authorization``) header. rJ z2A ":" is not allowed in login (RFC 7617#section-2)zBasic )� ValueError�encode�base64� b64encode�decode)ra rb rc Zcredsr7 r7 r= �encode_basic_authw s ri c s� e Zd ZdZ ddedededd f� fdd � Zedd ededd fd d ��Zedd �dedede d fdd��Z defdd�Z � Z S )r) z!Http basic authentication helper.r_ �latin1ra rb rc rW c sR |d u rt d��|d u rt d��d|v rt d��tjdtdd� t� �| |||�S )Nz"None is not allowed as login valuez%None is not allowed as password valuerJ z5A ":" is not allowed in login (RFC 1945#section-11.1)z�BasicAuth is deprecated and will be removed in aiohttp 4.0; use aiohttp.encode_basic_auth() with headers={'Authorization': ...} instead� )� stacklevel)rd �warnings�warn�DeprecationWarning�super�__new__)�clsra rb rc �� __class__r7 r= rq � s �zBasicAuth.__new__� auth_headerc C s� z |� dd�\}}W n ty td��w |�� dkr"td| ��ztj|�d�dd��|�}W n tjy= td ��w z |� d d�\}}W n tyS td ��w t |||�S ) z<Create a BasicAuth object from an Authorization HTTP header.rT r# z%Could not parse authorization header.Zbasicz Unknown authorization method %s�asciiT)�validatezInvalid base64 encoding.rJ zInvalid credentials.) �splitrd �lowerrf � b64decodere rh �binascii�Error�_basic_auth_no_warn)rr ru rc Z auth_typeZencoded_credentials�decoded�usernamerb r7 r7 r= rh � s, � ��� � zBasicAuth.decode�rc �urlc C sB t |t�s td��|jdu r|jdu rdS t|jpd|jp d|�S )zCreate BasicAuth from url.z url should be yarl.URL instanceNr_ )� isinstancer" � TypeError�raw_user� raw_passwordr} �userrb )rr r� rc r7 r7 r= �from_url� s zBasicAuth.from_urlc C s t | j| j| j�S )zEncode credentials.)ri ra rb rc rY r7 r7 r= re � � zBasicAuth.encode�r_ rj )rj ) r\ r] r^ �__doc__�strrq � classmethodrh r" r r� re � __classcell__r7 r7 rs r= r) � s" ����� " r) �ra rb rc rj c C s t �t| ||f�S )z�Construct a BasicAuth without emitting the deprecation warning. For internal use only. Bypasses BasicAuth.__new__ so that aiohttp's own machinery doesn't trigger deprecation warnings in user code. )�tuplerq r) r� r7 r7 r= r} � s r} r� c C s< | j du r| jdu r| dfS | �d�t| jpd| jpd�fS )zIRemove user and password from URL if present and return BasicAuth object.Nr_ )r� r� Z with_userr} r� rb )r� r7 r7 r= �strip_auth_from_url� s r� c C s0 t j�d�} | durt| �}n(zt�� }W n ty. } z t�d|� W Y d}~dS d}~ww |tr4dnd }zt � t |��W S t j yY } z t� d|� W Y d}~dS d}~w t y� } z3d}t�t �� |�� }W d � n1 svw Y | s|r�t� d|� W Y d}~dS W Y d}~dS d}~ww ) z�Load netrc from file. Attempt to load it from the path specified by the env-var NETRC or in the default location in the user's home directory. Returns None if it couldn't be found or fails to parse. ZNETRCNzHCould not resolve home directory when trying to look for .netrc file: %sZ_netrcz.netrcz Could not parse .netrc file: %sFz Could not read .netrc file: %s)�os�environ�getr �home� RuntimeErrorr% �debug� IS_WINDOWS�netrcr� ZNetrcParseError�warning�OSError� contextlibr �is_file)Z netrc_envZ netrc_pathZhome_dir�eZ netrc_existsr7 r7 r= �netrc_from_env� s@ ��� �� � ���r� T)Z auto_attribs�frozen�slotsc @ s" e Zd ZU eed< edB ed< dS )� ProxyInfo�proxyN� proxy_auth)r\ r] r^ r" �__annotations__r) r7 r7 r7 r= r� � r� � netrc_obj�hostc C sf | du rt d��| �|�}|du rt d|�d���|\}}}|s$|du r&|n|}|du r.d}t||�S )z� Return :py:class:`~aiohttp.BasicAuth` credentials for ``host`` from ``netrc_obj``. :raises LookupError: if ``netrc_obj`` is :py:data:`None` or if no entry is found for the ``host``. NzNo .netrc file foundz No entry for z found in the `.netrc` file.r_ )� LookupErrorZauthenticatorsr} )r� r� Zauth_from_netrcra Zaccountrb r r7 r7 r= �basicauth_from_netrc s r� c C s� dd� t � �� D �} t� }dd� | �� D �}i }|�� D ]>\}}|\}}|jdv r4t�d|j�� |� q |rS|d u rS|jd urSzt||j�}W n t yR d }Y nw t ||�||< q |S )Nc S s" i | ] \}}|d v r|t |��qS ))�http�https�ws�wssr! �r; �k�vr7 r7 r= � <dictcomp>+ s �z$proxies_from_env.<locals>.<dictcomp>c S s i | ] \}}|t |��qS r7 )r� r� r7 r7 r= r� 1 s )r� r� z)%s proxies %s are not supported, ignoring) r �itemsr� �schemer% r� �upperr� r� r� r� )Z proxy_urlsr� �stripped�ret�proto�valr� Zauthr7 r7 r= �proxies_from_env* s, � � �r� c C sf | j durt| j �rtd| j �d���t� }z|| j }W n ty, td| �d���w |j|jfS )z5Get a permitted proxy for the given URL from the env.Nz Proxying is disallowed for `�`zNo proxies found for `z ` in the env)r� r r� r� r� �KeyErrorr� r� )r� Zproxies_in_envZ proxy_infor7 r7 r= �get_env_proxy_for_urlD s � r� c @ s. e Zd ZU eed< eed< eed< ded< dS )�MimeType�type�subtype�suffixzMultiDictProxy[str]� parametersN)r\ r] r^ r� r� r7 r7 r7 r= r� R s r� �8 )�maxsize�mimetypec C s� | s t dddtt� �d�S | �d�}t� }|dd� D ]}|s q|�d�\}}}|�|�� �� |�d�� q|d �� �� }|d krDd }|�d �\}}} | �d �\} }} t || | t|�d�S ) a Parses a MIME type into its components. mimetype is a MIME type string. Returns a MimeType object. Example: >>> parse_mimetype('text/html; charset=utf-8') MimeType(type='text', subtype='html', suffix='', parameters={'charset': 'utf-8'}) r_ )r� r� r� r� rI r# NrQ z "r �*z*/*rM �+)r� r r rx � partition�addry �strip) r� �parts�params�item�key�_�valueZfulltypeZmtype�styper� r7 r7 r= �parse_mimetypeZ s& � �r� c s, e Zd Zd� fdd� Zdefdd�Z� ZS )�EnsureOctetStreamrW Nc s t � �� | �d� d S �Nzapplication/octet-stream)rp �__init__�set_default_typerY rs r7 r= r� � s zEnsureOctetStream.__init__c C sB | � dd��� }|�d�\}}}|�� }|�d�dkr | �� S |S )a Re-implementation from Message Returns application/octet-stream in place of plain/text when value is wrong. The way this class is used guarantees that content-type will be present so simplify the checks wrt to the base implementation. z content-typer_ rI rM r# )r� ry r� r� �count�get_default_type)rZ r� �ctyper� r7 r7 r= �get_content_type� s z"EnsureOctetStream.get_content_type�rW N)r\ r] r^ r� r� r� r� r7 r7 rs r= r� � s r� �rawc C sF t ttd��d| � ��}|�� }|�d�}t|dd� �}|t|�fS )z�Parse Content-Type header. Returns a tuple of the parsed content type and a MappingProxyType of parameters. The default returned value is `application/octet-stream` )�policyzContent-Type: r7 r# N)r r� r �parsestrr� � get_params�dictr )r� �msg� content_typer� Z content_dictr7 r7 r= �parse_content_type� s r� �obj�defaultc C s@ t | dd �}|r t|t�r |d dkr |d dkr t|�jS |S )N�namer rE ���rF )�getattrr� r� r r� )r� r� r� r7 r7 r= �guess_filename� s & r� z[^\041\043-\133\135-\176]c C r6 r7 r8 r: r7 r7 r= r> � r? � �contentc C s* t t| �ks td| ����t�dd� | �S )a Return 7-bit content as quoted-string. Format content into a quoted-string as defined in RFC5322 for Internet Message Format. Notice that this is not the 8-bit HTTP format, but the 7-bit email format. Content must be in usascii or a ValueError is raised. z bad content for quoted-string c S s d| � d� S )NrK r )�group)�xr7 r7 r= �<lambda>� s z quoted_string.<locals>.<lambda>)�QCONTENT�setrd � not_qtext_re�sub)r� r7 r7 r= � quoted_string� s r� �disptype� quote_fields�_charsetr� c K s> | rt t| �kstd| ����| }|r�g }|�� D ]r\}}|r%t t|�ks/td|�d|����|rx|�� dkrHt|d|d�}|�|d| f� qzt|�}W n tym d�|dt|d|d�f�}|�|d |f� Y qw |�|d| f� q|� d d �� d d �}|�|d| f� qd�dd� |D ��} d�|| f�}|S )ak Sets ``Content-Disposition`` header for MIME. This is the MIME payload Content-Disposition header from RFC 2183 and RFC 7579 section 4.2, not the HTTP Content-Disposition from RFC 6266. disptype is a disposition type: inline, attachment, form-data. Should be valid extension token (see RFC 2183) quote_fields performs value quoting to 7-bit MIME headers according to RFC 7578. Set to quote_fields to False if recipient can take 8-bit file names and field values. _charset specifies the charset to use when quote_fields is True. params is a dict with disposition params. z bad content disposition type z"bad content disposition parameter rQ �filenamer_ r� z"%s"z''r� rK z\\rL z\"z; c s s � | ]}d � |�V qdS )rQ N)�join)r; �pairr7 r7 r= � <genexpr>� s � z-content_disposition_header.<locals>.<genexpr>) �TOKENr� rd r� ry r �appendr� r� �replace) r� r� r� r� r� Zlparamsr� r� ZqvalZsparamsr7 r7 r= �content_disposition_header� s4 ��r� c C s | sdS d| v p| � dd��� S )z�Check if host looks like an IP Address. This check is only meant as a heuristic to ensure that a host is not a domain name. FrJ �.r_ )r� �isdigit)r� r7 r7 r= � is_ip_address� s r c C s� | � d�}t|�dkr dS |D ]5}dt|� kr dkr)n dS |�� r)|�� s, dS |d dkr;t|�dkr; dS t|�dkrD dS qd S ) z�Check if host is a canonical dotted-quad IPv4 address. Rejects the legacy numeric forms that ``socket`` still accepts and maps onto an address, e.g. ``2130706433``, ``017700000001``, ``127.1``. r� � Fr# r' r �0� T)rx �len�isasciir� �int)r� r� �partr7 r7 r= �is_canonical_ipv4_address s � �r �_cached_current_datetimec C s\ t t�� �} | tkr,d}d}t�| �^}}}}}}} } d|| ||| ||||f a| atS )N)�Mon�Tue�Wed�Thu�Fri�Sat�Sun) r_ �Jan�Feb�Mar�Apr�May�Jun�Jul�Aug�Sep�Oct�Nov�Decz#%s, %02d %3s %4d %02d:%02d:%02d GMT)r �timer �gmtime�_cached_formatted_datetime) �nowZ _weekdaynameZ _monthname�year�month�dayZhh�mm�ss�wd�tailr7 r7 r= �rfc822_formatted_time s � r( �info� tuple[weakref.ref[object], str]c C sT | \}}|� }|d ur(t t�� t||�� W d � d S 1 s!w Y d S d S rX )r � Exceptionr� )r) �refr� �obr7 r7 r= �_weakref_handleD s "��r. � r- r� �timeout�loop�timeout_ceil_thresholdc C sH |d ur"|dkr"|� � | }||krt|�}|�|tt�| �|f�S d S �Nr )r r �call_atr. �weakrefr, )r- r� r0 r1 r2 �whenr7 r7 r= �weakref_handleL s r7 �cbc C s4 |d u s|dkr d S |� � }t|||�}|�|| �S r3 )r �calculate_timeout_whenr4 )r8 r0 r1 r2 r r6 r7 r7 r= � call_later\ s r: � loop_time�timeout_ceiling_thresholdc C s | | }||kr t |�S |S )z$Calculate when to execute a timeout.r )r; r0 r< r6 r7 r7 r= r9 i s r9 c @ s� e Zd ZdZdZ ddejdedB deddfd d �Zd e d d e de ddfdd�Z ddd�Z dej dB fdd�Zd dd�Zddd�ZdS ) � TimeoutHandlezTimeout handle��_timeout�_loop�_ceil_threshold� _callbacksr/ r1 r0 N�ceil_thresholdrW c C s || _ || _|| _g | _d S rX r> )rZ r1 r0 rC r7 r7 r= r� z s �zTimeoutHandle.__init__�callback).N�args�kwargsc O s | j �|||f� d S rX )rB r� )rZ rD rE rF r7 r7 r= �register� s zTimeoutHandle.registerc C s | j �� d S rX )rB �clearrY r7 r7 r= �close� � zTimeoutHandle.closec C sJ | j }|d ur#|dkr#| j�� | }|| jkrt|�}| j�|| j�S d S r3 )r? r@ r rA r r4 �__call__)rZ r0 r6 r7 r7 r= �start� s zTimeoutHandle.start�BaseTimerContextc C s4 | j d ur| j dkrt| j�}| �|j� |S t� S r3 )r? � TimerContextr@ rG r0 � TimerNoop)rZ �timerr7 r7 r= rP � s zTimeoutHandle.timerc C sV | j D ] \}}}tt�� ||i |�� W d � n1 s w Y q| j �� d S rX )rB r r+ rH )rZ r8 rE rF r7 r7 r= rK � s ��zTimeoutHandle.__call__�r/ r� )rW rM )r\ r] r^ r� � __slots__�asyncio�AbstractEventLoop�floatr� r r rG rI � TimerHandlerL rP rK r7 r7 r7 r= r= u s4 ���� � ��� � r= c @ s e Zd ZdZddd�ZdS )rM r7 rW Nc C s dS )z0Raise TimeoutError if timeout has been exceeded.Nr7 rY r7 r7 r= �assert_timeout� s z BaseTimerContext.assert_timeoutr� )r\ r] r^ rR rW r7 r7 r7 r= rM � s rM c @ sH e Zd ZdZdefdd�Zdee dB dedB dedB ddfd d �Z dS ) rO r7 rW c C s | S rX r7 rY r7 r7 r= � __enter__� � zTimerNoop.__enter__�exc_typeN�exc_val�exc_tbc C � d S rX r7 )rZ rZ r[ r\ r7 r7 r= �__exit__� s zTimerNoop.__exit__) r\ r] r^ rR rM rX r� � BaseExceptionr r^ r7 r7 r7 r= rO � s ����rO c @ sx e Zd ZdZdZdejddfdd�Zddd �Zde fd d �Z d e e dB d e dB de dB dedB fdd�Zddd�ZdS )rN z&Low resolution timeout context manager�r@ �_tasks� _cancelled� _cancellingr1 rW Nc C s || _ g | _d| _d| _d S )NFr r` )rZ r1 r7 r7 r= r� � s zTimerContext.__init__c C s | j rtjd�dS )z7Raise TimeoutError if timer has already been cancelled.N)rb rS � TimeoutErrorrY r7 r7 r= rW � s �zTimerContext.assert_timeoutc C sP t j| jd�}|d u rtd��tjdkr|�� | _| jr t j d �| j � |� | S )N)r1 z4Timeout context manager should be used inside a taskr& ) rS Z current_taskr@ r� �sys� version_infoZ cancellingrc rb rd ra r� �rZ Ztaskr7 r7 r= rX � s zTimerContext.__enter__rZ r[ r\ c C sX d }| j r | j �� }|tju r*| jr*|d usJ �tjdkr&|�� | jkr&d S tj |�d S )Nr& ) ra �poprS ZCancelledErrorrb re rf Zuncancelrc rd )rZ rZ r[ r\ Z enter_taskr7 r7 r= r^ � s zTimerContext.__exit__c C s, | j st| j�D ]}|�� qd| _ d S d S �NT)rb r� ra �cancelrg r7 r7 r= r0 � s �zTimerContext.timeoutr� )r\ r] r^ r� rR rS rT r� rW rM rX r� r_ r �boolr^ r0 r7 r7 r7 r= rN � s ��� �rN �delayrC c C sL | d u s| dkr t �d �S t�� }|�� }|| }| |kr!t|�}t �|�S r3 )� async_timeoutr0 rS Zget_running_loopr r Z timeout_at)rl rC r1 r r6 r7 r7 r= � ceil_timeout s rn c @ s� e Zd ZU dZeg d��Zee ed< dZ edB ed< dZ e eef dB ed< e Z edB eB ed< dedB d dfd d �Zed efd d ��Zed edB fdd��Zed edB fdd��ZdS )� HeadersMixinzMixin for handling headers.)� _content_type� _content_dict�_stored_content_type�_headersNrp rq rr r� rW c C s> || _ |d u rd| _i | _d S t|�\}}|| _|�� | _d S r� )rr rp rq r� �copy)rZ r� r� Zcontent_mapping_proxyr7 r7 r= �_parse_content_type s z HeadersMixin._parse_content_typec C s6 | j �tj�}| j|kr| �|� | jdusJ �| jS )z7The value of content part for Content-Type HTTP header.N)rs r� r$ � CONTENT_TYPErr ru rp �rZ r� r7 r7 r= r� & s zHeadersMixin.content_typec C s< | j �tj�}| j|kr| �|� | jdusJ �| j�d�S )z7The value of charset part for Content-Type HTTP header.N�charset)rs r� r$ rv rr ru rq rw r7 r7 r= rx / s zHeadersMixin.charsetc C s" | j �tj�}|du r dS t|�S )z(The value of Content-Length HTTP header.N)rs r� r$ ZCONTENT_LENGTHr )rZ �content_lengthr7 r7 r= ry 8 s zHeadersMixin.content_length)r\ r] r^ r� � frozensetZATTRSr r� r� rp rq r� r2 rr r1 ru �propertyr� rx r ry r7 r7 r7 r= ro s ro �futzasyncio.Future[_T]�resultc C s | � � s | �|� d S d S rX )�done� set_result)r| r} r7 r7 r= r ? s �r c @ s& e Zd Z ddededdfdd�ZdS ) �ErrorableProtocol.�exc� exc_causerW Nc C r] rX r7 )rZ r� r� r7 r7 r= � set_exceptionH s z ErrorableProtocol.set_exception�.)r\ r] r^ r_ r� r7 r7 r7 r= r� G s ����r� z&asyncio.Future[_T] | ErrorableProtocolr� r� c C sB t �| �r | �� r dS |tu }||u }|s|s||_| �|� dS )z�Set future exception. If the future is marked as complete, this function is a no-op. :param exc_cause: An exception that is a direct cause of ``exc``. Only set if provided. N)rS Zisfuturer~ � _EXC_SENTINEL� __cause__r� )r| r� r� Zexc_is_sentinelZexc_causes_itselfr7 r7 r= r� O s r� c @ s^ e Zd ZU dZdZee ed< ddedee dB fdd�Z d ed e fd d �Z d efd d�Z dS )�BaseKeyz�Base for concrete context storage key classes. Each storage is provided with its own sub-class for the sake of some additional type safety. )�_name�_t�__orig_class__r� Nr� �tc C sF t �� }|r|jjdkr|jd }n|j}|s|d | | _|| _d S )Nz<module>r\ r� )�inspect� currentframe�f_code�co_name� f_globals�f_backr� r� )rZ r� r� �frame�moduler7 r7 r= r� t s � zBaseKey.__init__�otherrW c C s t |t�r | j|jk S dS ri )r� r� r� )rZ r� r7 r7 r= �__lt__� s zBaseKey.__lt__c C s� | j }|d u r"tt�� t| j�d }W d � n1 s w Y |d u r)d}n t|t�rA|jdkr7|j}n|j� d|j� �}nt |�}d| j j � d| j � d|� d�S ) Nr z <<Unknown>>�builtinsr� rE rC z, type=z)>) r� r �AttributeErrorr r� r� r� r] r^ �reprrt r\ r� )rZ r� Zt_reprr7 r7 r= �__repr__� s � zBaseKey.__repr__rX )r\ r] r^ r� rR r� �objectr� r� r/ r� rk r� r� r7 r7 r7 r= r� f s r� c @ � e Zd ZdZdS )�AppKeyz.Keys for static typing support in Application.N�r\ r] r^ r� r7 r7 r7 r= r� � � r� c @ r� )� RequestKeyz*Keys for static typing support in Request.Nr� r7 r7 r7 r= r� � r� r� c @ r� )� ResponseKeyz+Keys for static typing support in Response.Nr� r7 r7 r7 r= r� � r� r� c @ sb e Zd ZdZdeeeee B ef ddfdd�Z d dd�Z e d ee de fd d ��Z e d edefd d ��Z d eee B defd d �Z e d ee dede eB fdd��Ze d d ee ddde dB fdd��Ze d d ededefdd��Zd!d eee B dedefdd�Zdefdd�Zdeeee B fdd�Zd edefdd�Zdefdd �Zdefd d �ZdS )"r* )�_maps�mapsrW Nc C s t |�| _d S rX )r� r� )rZ r� r7 r7 r= r� � rJ zChainMapProxy.__init__c C s t d| j� d���)NzInheritance class z from ChainMapProxy is forbidden)r� r\ )rr r7 r7 r= �__init_subclass__� s �z ChainMapProxy.__init_subclass__r� c C r] rX r7 �rZ r� r7 r7 r= � __getitem__� rY zChainMapProxy.__getitem__c C r] rX r7 r� r7 r7 r= r� � rY c C s4 | j D ]}z|| W S ty Y qw t|��rX )r� r� )rZ r� �mappingr7 r7 r= r� � s �r� c C r] rX r7 �rZ r� r� r7 r7 r= r� � rY zChainMapProxy.get.c C r] rX r7 r� r7 r7 r= r� � rY c C r] rX r7 r� r7 r7 r= r� � rY c C s" z| | W S t y | Y S w rX )r� r� r7 r7 r= r� � s �c C s t t� j| j� �S rX )r r� �unionr� rY r7 r7 r= �__len__� r� zChainMapProxy.__len__c C s& i }t | j�D ]}|�|� qt|�S rX )�reversedr� �update�iter)rZ �dr� r7 r7 r= �__iter__� s zChainMapProxy.__iter__c s t � fdd�| jD ��S )Nc 3 s � | ]}� |v V qd S rX r7 )r; �m�r� r7 r= r� � s � z-ChainMapProxy.__contains__.<locals>.<genexpr>��anyr� r� r7 r� r= � __contains__� s zChainMapProxy.__contains__c C s t | j�S rX r� rY r7 r7 r= �__bool__� s zChainMapProxy.__bool__c C s d� tt| j��}d|� d�S )Nz, zChainMapProxy(rD )r� �mapr� r� )rZ r� r7 r7 r= r� � s zChainMapProxy.__repr__r� r� rX )r\ r] r^ rR r r r� r� r r� r� r r/ r� r0 r� r r� r r� r� rk r� r� r� r7 r7 r7 r= r* � s* & " r* z[!\x23-\x7E\x80-\xff]+z(W/)?"(z)"z)(?:\s*,\s*|$)|(.)r� c @ s" e Zd ZU eed< dZeed< dS )r+ r� F�is_weakN)r\ r] r^ r� r� r� rk r7 r7 r7 r= r+ � r� r+ r� c C s* | t krt�| �std| �d���d S d S )NzValue z, is not a valid etag. Maybe it contains '"'?)�ETAG_ANY� _ETAGC_RE� fullmatchrd )r� r7 r7 r= �validate_etag_value� s ��r� �date_strc C s` | dur.t | �}|dur.tt�� tj|dd� dtjji�W d � S 1 s)w Y dS )z/Process a date string, return a datetime objectN� �tzinfo)r r rd �datetime�timezone�utc)r� � timetupler7 r7 r= �parse_http_date� s �r� �method�codec C s2 |t v p| tv pd| kodk n o| tjv S )z-Check if a request must return an empty body.r5 �, )�EMPTY_BODY_STATUS_CODES�EMPTY_BODY_METHODSr$ �METH_CONNECT_ALL�r� r� r7 r7 r= �must_be_empty_body s � �r� c C s* |t v pd| ko dk n o| tjv S )zrCheck if a Content-Length header should be removed. This should always be a subset of must_be_empty_body r5 r� )r� r$ r� r� r7 r7 r= � should_remove_content_length s �r� )r_ r` r� rX )Tr` )r) r* rW NrQ )�r� rS rf r{ r� r� �enum� functoolsr� r� r� �platform�rere r rm r5 � collectionsr �collections.abcr r r r r r � email.messager � email.parserr � email.policyr � email.utilsr �mathr �pathlibr �typesr r �typingr r r r r r r r � urllib.parser �urllib.requestr r �attrZ multidictr r r Z propcache.apir r, Zyarlr" r_ r$ �logr% rf rm �__all__�systemZIS_MACOSr� ZPY_311ZDEFAULT_CHUNK_SIZEr/ r0 �Enumr1 r2 rk r� r� Z NO_EXTENSIONSrz �ranger� Z METH_HEAD_ALLr� �flags�dev_mode�ignore_environment�DEBUGZCHARr9 ZCTLZ SEPARATORSr� rV r� ri r) r} r� r� r� �sr� r� r� r� r� r� � lru_cacher� r� r� r� �compiler� r� r� r� r r r r r� r r( r. r� rU rT rV r7 r: r9 r= rM rO rN ZTimeoutrn ro r r_ r� r� r� �total_orderingr� r� r� r� r* Z_ETAGCr� Z _QUOTED_ETAGZQUOTED_ETAG_REZLIST_QUOTED_ETAG_REr� r+ r� r� r� r� r7 r7 r7 r= �<module> s� ( ��� F���� � + ' $ ����� �3 ( ������ �� ���� � ��� � 4B��� �/ ���� �1 ?
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings