File: //usr/local/lib/python3.10/dist-packages/aiohttp/__pycache__/web_urldispatcher.cpython-310.pyc
o
���g1� � @ sf U d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
d dl Z d dlm Z d dl
mZ d dlmZ d dlmZmZmZmZmZmZmZmZmZmZm Z m Z m Z m Z m Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z' d dl(m)Z)m*Z+ ddl,m-Z- dd l m.Z.m/Z/m0Z0 dd
l1m2Z2 dd l3m4Z4 dd l5m6Z6m7Z7 dd
l8m9Z9m:Z:m;Z;m<Z<m=Z= ddl>m?Z? ddl@mAZA ddlBmCZCmDZD ddlEmFZF dZGer�ddlHmIZI eeJeJf ZKneLZKe
jMdk r�e
jN�Od�r�ePfn e
jMdk r�eQfndZReSeTeUe+�Vd�dd� ��ZWee#eUdf eXd< e �Yd �ZZee eJ eXd < e �Yd �Z[ee eJ eXd < e �\d �Z]eeJ eXd!< eeAgee eD f Z^e#e d" e!eJ f Z_ej`ej\d#d$�ZaG d%d&� d&e%d'd(�ZbG d)d*� d*e"ed+ �ZcG d,d+� d+e jd�ZeG d-d"� d"eKe.�ZfG d.d/� d/ef�Zgd0eAd1dfd2d3�ZhG d4d5� d5ec�ZiG d6d7� d7ei�ZjG d8d9� d9ei�ZkG d:d;� d;ec�ZlG d<d=� d=el�ZmG d>d?� d?el�ZnG d@dA� dAe jd�ZoG dBdC� dCeo�ZpG dDdE� dEep�ZqG dFdG� dGen�ZrG dHdI� dIee�ZsG dJdK� dKee�ZtG dLdM� dMe0�ZuG dNdO� dOe"eec eec �ZvG dPdQ� dQe"eee eee �ZwG dRdS� dSe/e eJecf �ZxdTeJd1eJfdUdV�ZydTeJd1eJfdWdX�ZzdTeJd1eJfdYdZ�Z{dS )[� N)�wraps)�Path)�MappingProxyType)�
TYPE_CHECKING�Any� Awaitable�Callable� Container�Dict�Final� Generator�Iterable�Iterator�List�Mapping�NoReturn�Optional�Pattern�Set�Sized�Tuple�Type� TypedDict�Union�cast)�URL� __version__� )�hdrs)�AbstractMatchInfo�AbstractRouter� AbstractView)�DEBUG)�
HttpVersion11)�Handler�PathLike)�
HTTPException�HTTPExpectationFailed�
HTTPForbidden�HTTPMethodNotAllowed� HTTPNotFound)� FileResponse)�Request)�Response�StreamResponse)�AbstractRouteDef)
�
UrlDispatcher�UrlMappingMatchInfo�AbstractResource�Resource�
PlainResource�DynamicResource�
AbstractRoute�
ResourceRoute�StaticResource�View)� Application)� �
�win32)r; �
� �.� .� YARL_VERSIONz$^[0-9A-Za-z!#\$%&'\*\+\-\.\^_`\|~]+$�HTTP_METHOD_REz*(\{[_a-zA-Z][^{}]*(?:\{[^{}]*\}[^{}]*)*\})�ROUTE_RE�/�PATH_SEPr1 T)�quotec @ sj e Zd ZU eed< eed< ee ed< eed< eed< eedf ed< ded < eed
< d ed < eed
< dS )� _InfoDict�path� formatter�pattern� directory�prefixr6 �routesr: �app�domain�AbstractRuleMatching�rule�http_exceptionN) �__name__�
__module__� __qualname__�str�__annotations__r r r r& r? r? r? �D/usr/local/lib/python3.10/dist-packages/aiohttp/web_urldispatcher.pyrH h s
rH F)�totalc @ s� e Zd Zdd�dee ddfdd�Zedee fdd��Zeej defd d
���Z
ej d ede fd d
��Z ej de
defdd��Zej deddfdd��Zej defdd��Zddd�Zej dedefdd��ZdS ) r2 N��namer\ �returnc C �
|| _ d S �N��_name��selfr\ r? r? rY �__init__| �
zAbstractResource.__init__c C � | j S r_ r` �rc r? r? rY r\ � zAbstractResource.namec C � dS )zWExposes the resource's canonical path.
For example '/foo/bar/{name}'
Nr? rg r? r? rY � canonical� � zAbstractResource.canonical�kwargsc K ri )z2Construct url for resource with additional params.Nr? )rc rl r? r? rY �url_for� rk zAbstractResource.url_for�requestc � � �dS )zWResolve resource.
Return (UrlMappingMatchInfo, allowed_methods) pair.
Nr? �rc rn r? r? rY �resolve� � zAbstractResource.resolverM c C ri )zWAdd a prefix to processed URLs.
Required for subapplications support.
Nr? �rc rM r? r? rY �
add_prefix� rk zAbstractResource.add_prefixc C ri �z;Return a dict with additional info useful for introspectionNr? rg r? r? rY �get_info� rk zAbstractResource.get_infoc C � d S r_ r? rg r? r? rY �freeze� � zAbstractResource.freezerI c C ri )z Perform a raw match against pathNr? �rc rI r? r? rY � raw_match� rk zAbstractResource.raw_match�r] N)rT rU rV r rW rd �propertyr\ �abc�abstractmethodrj r rm r, �_Resolverq rt rH rv rx �boolr{ r? r? r? rY r2 { s$
r2 r6 c @ s� e Zd Zddd�dedeeee f dee dee
ddf
dd �Z e defd
d ��Z
e defd d
��Ze ejdee fdd���Ze dee
fdd��Zejdefdd��Zejdededefdd��Zdedee fdd�ZdS )r6 N��expect_handler�resource�method�handlerr� r� r] c s� |d u rt }t�|�sJ d|����|�� }t�|�s"t|� d���t|�s*J |��t�|�r0n0t� |�r<t
� dt � n$t
|t�rGt|t�rGnt
� dt � t|�dtdtf� fdd� �}|� |}|| _|| _|| _|| _d S ) NzCoroutine is expected, got z is not allowed HTTP methodz6Bare generators are deprecated, use @coroutine wrapperz-Bare functions are deprecated, use async onesrn r] c � s0 �� | �}t �|�r|I d H }t|t�sJ �|S r_ )�asyncio� iscoroutine�
isinstancer. )rn �result�� old_handlerr? rY �handler_wrapper� s �
z/AbstractRoute.__init__.<locals>.handler_wrapper)�_default_expect_handlerr� �iscoroutinefunction�upperrC �match�
ValueError�callable�inspect�isgeneratorfunction�warnings�warn�DeprecationWarningr� �type�
issubclassr! r r, r. �_method�_handler�_expect_handler� _resource)rc r� r� r� r� r� r? r� rY rd � s> ��
��
zAbstractRoute.__init__c C rf r_ )r� rg r? r? rY r� � rh zAbstractRoute.methodc C rf r_ )r� rg r? r? rY r� � rh zAbstractRoute.handlerc C ri )z8Optional route's name, always equals to resource's name.Nr? rg r? r? rY r\ � rk zAbstractRoute.namec C rf r_ )r� rg r? r? rY r� � rh zAbstractRoute.resourcec C ri ru r? rg r? r? rY rv � rk zAbstractRoute.get_info�argsrl c O ri �z/Construct url for route with additional params.Nr? �rc r� rl r? r? rY rm � rk zAbstractRoute.url_forrn c � s �| � |�I d H S r_ )r� rp r? r? rY �handle_expect_header� � �z"AbstractRoute.handle_expect_header)rT rU rV rW r r$ r r! r �_ExpectHandlerr2 rd r} r� r� r~ r r\ r� rH rv r rm r, r. r� r? r? r? rY r6 � s8 �����
�3c s� e Zd ZdZdeeef deddf� fdd� Zede fdd ��Z
edefd
d ��Z ede fd d
��Z
edee fdd��Zdefdd�Zeded fdd��Zd dd�Zed!dd��Zejd dd��Zd"d d �Zdef� fd d � Z� ZS )#r1 )�_route�_apps� _current_app�_frozen�
match_dict�router] Nc s( t � �|� || _g | _d | _d| _d S �NF)�superrd r� r� r� r� )rc r� r� �� __class__r? rY rd � s
z UrlMappingMatchInfo.__init__c C � | j jS r_ )r� r� rg r? r? rY r� � zUrlMappingMatchInfo.handlerc C rf r_ )r� rg r? r? rY r�
rh zUrlMappingMatchInfo.routec C r� r_ )r� r� rg r? r? rY r� r� z"UrlMappingMatchInfo.expect_handlerc C rw r_ r? rg r? r? rY rS � z"UrlMappingMatchInfo.http_exceptionc C s
| j �� S r_ )r� rv rg r? r? rY rv re z UrlMappingMatchInfo.get_info)r: .c C �
t | j�S r_ )�tupler� rg r? r? rY �apps s
zUrlMappingMatchInfo.appsrO r: c C s0 | j rtd��| jd u r|| _| j�d|� d S )Nz-Cannot change apps stack after .freeze() callr )r� � RuntimeErrorr� r� �insert�rc rO r? r? rY �add_app s
zUrlMappingMatchInfo.add_appc C s | j }|d us J �|S r_ )r� r� r? r? rY � current_app$ s z UrlMappingMatchInfo.current_appc C s* t r|| jvrtd�| j|���|| _d S )Nz1Expected one of the following apps {!r}, got {!r})r" r� r� �formatr� r� r? r? rY r� * s
��
c C s
d| _ d S )NT)r� rg r? r? rY rx 5 re zUrlMappingMatchInfo.freezec s dt � �� � d| j� d�S )Nz <MatchInfo z: �>)r� �__repr__r� rg r� r? rY r� 8 s z UrlMappingMatchInfo.__repr__)rO r: r] N)r] r: r| )rT rU rV � __slots__r
rW r6 rd r} r$ r� r� r� r� r r& rS rH rv r r� r� r� �setterrx r� �
__classcell__r? r? r� rY r1 � s* "
c sJ e Zd ZdZdeddf� fdd� Zedefdd��Zdefd d
�Z � Z
S ) �MatchInfoError��
_exceptionrS r] Nc s || _ t� �i t| j �� d S r_ )r� r� rd � SystemRoute�rc rS r� r? rY rd @ s zMatchInfoError.__init__c C rf r_ r� rg r? r? rY rS D rh z MatchInfoError.http_exceptionc C s d� | jj| jj�S )Nz<MatchInfoError {}: {}>)r� r� �status�reasonrg r? r? rY r� H s �zMatchInfoError.__repr__) rT rU rV r� r& rd r} rS rW r� r� r? r? r� rY r� < s r� rn r] c � sX �| j �tjd�}| jtkr*|�� dkr#| j�d�I dH d| j_ dS t
d| d��dS )z�Default handler for Expect header.
Just send "100 Continue" to client.
raise HTTPExpectationFailed if value of header is not "100-continue"
� z 100-continues HTTP/1.1 100 Continue
Nr zUnknown Expect: %s)�text) �headers�getr �EXPECT�versionr# �lower�writer�write� output_sizer' )rn �expectr? r? rY r� N s �
�r� c s� e Zd Zdd�dee ddf� fdd�Zdd�ded eee e f d
ee
dd fd d
�Z ddd�Z de
defdd�Zejdedeeeef fdd��Zdefdd�Zded fdd�Z� ZS ) r3 Nr[ r\ r] c s& t � j|d� i | _d | _t� | _d S )Nr[ )r� rd �_routes�
_any_route�set�_allowed_methodsrb r� r? rY rd _ s zResource.__init__�r� r� r� r� r7 c C sD | j �|| j� }rtd|j� d���t||| |d�}| �|� |S )Nz+Added route will never be executed, method z is already registeredr� )r� r� r� r� r� r7 �register_route)rc r� r� r� r� � route_objr? r? rY � add_routee s ��
zResource.add_router� c C sH t |t�s J d|����|jtjkr|| _| j�|j� || j|j< d S )Nz)Instance of Route class is required, got ) r� r7 r� r �METH_ANYr� r� �addr� �rc r� r? r? rY r� w s �� zResource.register_routern c � sR �| � |jj� }d u rd t� fS | j�|j| j� }r$t||�| j fS d | j fS r_ )
�_match�rel_url� path_safer� r� r� r� r� r1 r� )rc rn r� r� r? r? rY rq � s �
zResource.resolverI c C rw r_ r? rz r? r? rY r� � r� zResource._matchc C r� r_ ��lenr� rg r? r? rY �__len__� re zResource.__len__c C � t | j�� �S r_ ��iterr� �valuesrg r? r? rY �__iter__� � zResource.__iter__)r� r7 r] N)rT rU rV r rW rd r r r! r$ r� r� r� r, r� rq r~ r r
r� �intr� r r� r� r? r? r� rY r3 ^ s$ ����
�
r3 c s� e Zd Zdd�dedee ddf� fdd�Zedefdd ��Zdd
d �Zd eddfd
d�Z dedee
eef fdd�Z dede fdd�Z
defdd�Zdefdd�Zdefdd�Z� ZS )r4 Nr[ rI r\ r] c s* t � j|d� |r|�d�sJ �|| _d S )Nr[ rE )r� rd �
startswith�_path)rc rI r\ r� r? rY rd � s
zPlainResource.__init__c C rf r_ �r� rg r? r? rY rj � rh zPlainResource.canonicalc C s | j sd| _ d S d S )NrE r� rg r? r? rY rx � s
�zPlainResource.freezerM c C s< |� d�sJ �|�d�rJ �t|�dksJ �|| j | _d S �NrE r )r� �endswithr� r� rs r? r? rY rt � s zPlainResource.add_prefixc C s | j |kri S d S r_ r� rz r? r? rY r� � s
zPlainResource._matchc C �
| j |kS r_ r� rz r? r? rY r{ � re zPlainResource.raw_matchc C �
d| j iS )NrI r� rg r? r? rY rv � re zPlainResource.get_infoc C s t j| jdd�S )NT�rI �encoded)r �buildr� rg r? r? rY rm � � zPlainResource.url_forc C s0 | j d ur d| j d nd}d|� d| j� d�S )N�'�' r� z<PlainResource � r� )r\ r� rb r? r? rY r� � s zPlainResource.__repr__r| )rT rU rV rW r rd r} rj rx rt r
r� r� r{ rH rv r rm r� r� r? r? r� rY r4 � s $
r4 c s� e Zd Ze�d�Ze�d�ZdZdd�dede e ddf� fd d
�Z
e defd d ��Z d
eddfdd�Z
dede eeef fdd�Zdedefdd�Zdefdd�Zdedefdd�Zdefdd�Z� ZS )r5 z#\{(?P<var>[_a-zA-Z][_a-zA-Z0-9]*)\}z.\{(?P<var>[_a-zA-Z][_a-zA-Z0-9]*):(?P<re>.+)\}z[^{}/]+Nr[ rI r\ r] c
s^ t � j|d� || _d}d}t�|�D ]d}| j�|�}|r5|d�|�d�| j �7 }|d|�d� d 7 }q| j
�|�}|rU|djdi |� � ��7 }|d|�d� d 7 }qd|v s]d|v rht d|� d |� d
���t
|�}||7 }|t�|�7 }qzt�|�}W n tjy� } z t d |� d |� ��d �d }~ww |j�t�s�J �|�d
�s�J �|| _|| _d S )Nr[ r� z
(?P<{}>{})�var�{�}z(?P<{var}>{re})zInvalid path 'z'['z']z
Bad pattern 'z': rE r? )r� rd �
_orig_pathrD �split�DYN� fullmatchr� �group�GOOD� DYN_WITH_RE� groupdictr� �
_requote_path�re�escape�compile�errorrK r� rF �_pattern�
_formatter) rc rI r\ rK rJ �partr� �compiled�excr� r? rY rd � s< ��
zDynamicResource.__init__c C rf r_ )r rg r? r? rY rj � rh zDynamicResource.canonicalrM c C sV |� d�sJ �|�d�rJ �t|�dksJ �t�t�|�| jj �| _|| j | _d S r� ) r� r� r� r r r r rK r rs r? r? rY rt � s
zDynamicResource.add_prefixc C s. | j �|�}|d u r d S dd� |�� �� D �S )Nc S � i | ] \}}|t |��qS r? )�_unquote_path_safe)�.0�key�valuer? r? rY �
<dictcomp>� s �z*DynamicResource._match.<locals>.<dictcomp>)r r� r �items)rc rI r� r? r? rY r� � s
�zDynamicResource._matchc C r� r_ )r� rz r? r? rY r{ � re zDynamicResource.raw_matchc C � | j | jd�S )N)rJ rK )r r rg r? r? rY rv � r� zDynamicResource.get_info�partsc K s( | j �dd� |�� D ��}tj|dd�S )Nc S r
r? )� _quote_path)r �k�vr? r? rY r � s z+DynamicResource.url_for.<locals>.<dictcomp>Tr� )r �
format_mapr r r� )rc r �urlr? r? rY rm � s zDynamicResource.url_forc C s, | j d ur d| j d nd}dj|| jd�S )Nr� r� r� z$<DynamicResource {name} {formatter}>)r\ rJ )r\ r� r rb r? r? rY r� s �zDynamicResource.__repr__)rT rU rV r r r� r r rW r rd r} rj rt r
r� r� r{ rH rv r rm r� r� r? r? r� rY r5 � s
$" r5 c sj e Zd Zdd�dedee ddf� fdd�Zedefdd ��Zdeddfd
d �Zdede fd d
�Z
� Z S )�PrefixResourceNr[ rM r\ r] c sX |r |� d�s J |��|dv s|�d�rJ |��t� j|d� t|�| _| jd | _d S )NrE )r� rE r[ )r� r� r� rd r �_prefix�_prefix2)rc rM r\ r� r? rY rd s
zPrefixResource.__init__c C rf r_ )r rg r? r? rY rj rh zPrefixResource.canonicalc C sH |� d�sJ �|�d�rJ �t|�dksJ �|| j | _| jd | _d S r� )r� r� r� r r rs r? r? rY rt s
zPrefixResource.add_prefixc C ri r� r? rs r? r? rY r{ ry zPrefixResource.raw_match) rT rU rV rW r rd r} rj rt r� r{ r� r? r? r� rY r s $r c s* e Zd ZdZddddddd�dededee d ee d
ed e d e d
e ddf� fdd�Z
dd�ded
ee de fdd�Z e
dedefdd��Zdefdd�Zdeddfdd �Zd edefd d �Zdefd d!�Zdee fd"d#�Zd edefd$d%�Z d&e defd'd(�Z d)e defd*d+�Z defd,d-�Z � Z!S ).r8 r N� F�r\ r� �
chunk_size�
show_index�follow_symlinks�append_versionrM rL r\ r� r r! r" r# r] c
s� t � j||d� z t|��� jdd�}W n ty) } z td|� d��| �d } ~ ww |�� s6td|� d���|| _|| _ || _
|| _ || _ || _
td| j| |d�td | j| |d�d
�| _t| j�| _d S ) Nr[ T)�strictr� z' does not existz' is not a directory�GETr� �HEAD)r% r& )r� rd r �
expanduserrq �FileNotFoundErrorr� �is_dir�
_directory� _show_index� _chunk_size�_follow_symlinksr� �_append_versionr7 �_handler� r� r� )
rc rM rL r\ r� r r! r" r# r r� r? rY rd $ s. ��
�
��zStaticResource.__init__)r# �filenamec
C s |d u r| j }t|��d�}tj| jdd�}tdk r#||�dd� }n|| }|r�| j� |�}z"| j
rFt t j
�|��}|�| j� |�� }n
|�� }|�| j� W n
ttfy^ | Y S w |�� r�|�d�� }|�� }W d � n1 sww Y | �|�} |�| j| i�}|S |S )NrE Tr� �r � �%�%25�rb)r. rW �lstripr r� r rB �replacer* �joinpathr- r �osrI �normpath� relative_torq r� r( �is_file�open�read�_get_file_hash�
with_query� VERSION_KEY)
rc r0 r# r �unresolved_path�normalized_path�filepath�f�
file_bytes�hr? r? rY rm H s8
��
�
zStaticResource.url_for�
byte_arrayc C s* t �� }|�| � t�|�� �}|�d�S )N�ascii)�hashlib�sha256�update�base64�urlsafe_b64encode�digest�decode)rH �m�b64r? r? rY r? q s
z StaticResource._get_file_hashc C s | j | j| jd�S )N)rL rM rN )r* r r� rg r? r? rY rv x s �zStaticResource.get_infor� c C s: d| j v r td��td|| | jd�| j d< | j�d� d S )N�OPTIONSz OPTIONS route was set alreadyr� )r� r� r7 r� r� r� )rc r� r? r? rY �set_options_route s
�z StaticResource.set_options_routern c � sx �|j j}|j}|�| j�s|| jkrd t� fS | j}||vr#d |fS dt|t | j�d d � �i}t
|| j | �|fS )Nr0 r ) r� r� r� r� r r r� r� r r� r1 r� )rc rn rI r� �allowed_methodsr� r? r? rY rq � s �
zStaticResource.resolvec C r� r_ r� rg r? r? rY r� � re zStaticResource.__len__c C r� r_ r� rg r? r? rY r� � r� zStaticResource.__iter__c � sJ �|j d }t|�}|jrt� �| j�|�}t�� }|�d | j |�I d H S )Nr0 )
�
match_infor �anchorr( r* r8 r� �get_running_loop�run_in_executor�_resolve_path_to_response)rc rn r� r0 rB �loopr? r? rY r/ � s �
�zStaticResource._handlerB c
C s� z"| j rttj�|��}|�| j� |�� }n
|�� }|�| j� W n tgt �R y6 } zt
� |�d}~ww z|� � rL| j rIt
| �|�dd�W S t� �W n ty] } zt� |�d}~ww t|| jd�S )zFTake the unresolved path and query the file system to form a response.Nz text/html)r� � content_type)r )r- r r9 rI r: r; r* rq r� �CIRCULAR_SYMLINK_ERRORr* r) r+ r- �_directory_as_htmlr( �PermissionErrorr+ r, )rc rB rC � file_pathr r? r? rY rZ � s4
�������z(StaticResource._resolve_path_to_response�dir_pathc C s� |� � sJ �|�| j��� }dt|�� �}d|� d�}g }|�� }t|�D ]0}|�| j��� }t| j� d|� ��} |� � rD|j � d�}
n|j }
|�
d| � dt|
�� d�� q%d� d � |��} d
|� d | � d �} d |� d
�}
d|
� d | � d�}|S )z"returns directory's index as html.z
Index of /z<h1>z</h1>rE z
<li><a href="z">z </a></li>z
<ul>
{}
</ul>�
z<body>
z
</body>z<head>
<title>z</title>
</head>z<html>
z
</html>)
r) r; r* �as_posix� html_escape�iterdir�sortedr r r\ �appendr� �join)rc ra �relative_path_to_dir�index_of�h1�
index_list� dir_index�_file�rel_path�quoted_file_url� file_name�ul�body�head_str�htmlr? r? rY r^ � s( � z!StaticResource._directory_as_htmlc C s0 | j d ur d| j d nd}dj|| j| jd�S )Nr� r� z/<StaticResource {name} {path} -> {directory!r}>)r\ rI rL )r\ r� r r* rb r? r? rY r� � s
�zStaticResource.__repr__)"rT rU rV rA rW r% r r� r� r� rd r rm � staticmethod�bytesr? rH rv r$ rT r, r� rq r� r r6 r� r. r/ r rZ r^ r� r� r? r? r� rY r8 ! s\ ������� �
� �(���
�)
# r8 c s� e Zd Zdeddddf� fdd� Zdeddf� fdd � Zdeddfd
d �Zd ed
edefdd�Zde fdd�Z
de de fdd�Z
defdd�Zdee fdd�Zdefdd�Z� ZS )�PrefixedSubAppResourcerM rO r: r] Nc s t � �|� || _| �|� d S r_ )r� rd �_app�_add_prefix_to_resources)rc rM rO r� r? rY rd � s z PrefixedSubAppResource.__init__c s t � �|� | �|� d S r_ )r� rt rz rs r� r? rY rt � s z!PrefixedSubAppResource.add_prefixc C s8 | j j}|�� D ]}|�|� |�|� |�|� qd S r_ )ry �router� resources�unindex_resourcert �index_resource)rc rM r{ r� r? r? rY rz � s
�z/PrefixedSubAppResource._add_prefix_to_resourcesr� rl c O � t d��)Nz3.url_for() is not supported by sub-application root�r� r� r? r? rY rm � z PrefixedSubAppResource.url_forc C r )N)rO rM )ry r rg r? r? rY rv r� z PrefixedSubAppResource.get_inforn c � sL �| j j�|�I d H }|�| j � t|jt�r |jj}||fS t� }||fS r_ ) ry r{ rq r� r� rS r) rU r� �rc rn rV �methodsr? r? rY rq s � �z PrefixedSubAppResource.resolvec C � t | jj�� �S r_ )r� ry r{ rN rg r? r? rY r� r� z PrefixedSubAppResource.__len__c C r� r_ )r� ry r{ rN rg r? r? rY r� r� z PrefixedSubAppResource.__iter__c C s dj | j| jd�S )Nz,<PrefixedSubAppResource {prefix} -> {app!r}>)rM rO )r� r ry rg r? r? rY r� s �z PrefixedSubAppResource.__repr__)rT rU rV rW rd rt rz r rm rH rv r, r� rq r� r� r r6 r� r� r� r? r? r� rY rx � s rx c @ sP e Zd Zejdedefdd��Zejdefdd��Z e
ejde fdd���Z d S )
rQ rn r] c � ro )z1Return bool if the request satisfies the criteriaNr? rp r? r? rY r� " rr zAbstractRuleMatching.matchc C ri ru r? rg r? r? rY rv & rk z AbstractRuleMatching.get_infoc C ri )z Return a strNr? rg r? r? rY rj * rk z AbstractRuleMatching.canonicalN)
rT rU rV r~ r r, r� r� rH rv r} rW rj r? r? r? rY rQ ! s rQ c s� e Zd Ze�d�Zdeddf� fdd� Zedefdd��Z dedefd d
�Z
d e de fd d
�Z
dede fdd�Zdefdd�Z� ZS )�Domainz(?!-)[a-z\d-]{1,63}(?<!-)rP r] Nc s t � �� | �|�| _d S r_ )r� rd �
validation�_domain)rc rP r� r? rY rd 3 s
zDomain.__init__c C rf r_ �r� rg r? r? rY rj 7 rh zDomain.canonicalc s� t |t�s td��|�d��� }|std��d|v r td��td| �}|jd us+J �t� fdd�|j� d�D ��s>td ��|j
d
krF|jS |j� d |j
� �S ) NzDomain must be strr@ zDomain cannot be emptyz://zScheme not supportedzhttp://c 3 s � | ] }� j �|�V qd S r_ )�re_partr� )r �xrg r? rY � <genexpr>E s � z$Domain.validation.<locals>.<genexpr>zDomain not valid�P �:) r� rW � TypeError�rstripr� r� r �raw_host�allr� �port)rc rP r r? rg rY r� ; s
zDomain.validationrn c � s" �|j �tj�}|s dS | �|�S r� )r� r� r �HOST� match_domain)rc rn �hostr? r? rY r� K s
�
z Domain.matchr� c C s |� � | jkS r_ )r� r� �rc r� r? r? rY r� Q r� zDomain.match_domainc C r� )NrP r� rg r? r? rY rv T re zDomain.get_info)rT rU rV r r r� rW rd r} rj r� r, r� r� r� rH rv r� r? r? r� rY r� 0 s
r� c sT e Zd Ze�d�Zdeddf� fdd� Zedefdd��Z d ede
fd
d �Z � Z S ) �
MaskDomainz(?!-)[a-z\d\*-]{1,63}(?<!-)rP r] Nc s2 t � �|� | j�dd��dd�}t�|�| _d S )Nr@ z\.�*z.*)r� rd r� r7 r r �_mask)rc rP �maskr� r? rY rd [ s zMaskDomain.__init__c C r� r_ )r� rK rg r? r? rY rj ` r� zMaskDomain.canonicalr� c C s | j �|�d uS r_ )r� r� r� r? r? rY r� d r� zMaskDomain.match_domain)
rT rU rV r r r� rW rd r} rj r� r� r� r? r? r� rY r� X s
r� c @ sb e Zd Zdeddddfdd�Zedefdd ��Zdefd
d �Z d e
de fd
d�Z defdd�Z
dS )�MatchedSubAppResourcerR rO r: r] Nc C s t �| � d| _|| _|| _d S )Nr� )r2 rd r ry �_rule)rc rR rO r? r? rY rd i s
z MatchedSubAppResource.__init__c C r� r_ )r� rj rg r? r? rY rj o r� z MatchedSubAppResource.canonicalc C r )N)rO rR )ry r� rg r? r? rY rv s r� z MatchedSubAppResource.get_inforn c � sh �| j �|�I d H sd t� fS | jj�|�I d H }|�| j� t|jt �r-|jj
}||fS t� }||fS r_ ) r� r� r� ry r{ rq r� r� rS r) rU r� r? r? rY rq v s �
�z MatchedSubAppResource.resolvec C s d| j �d�S )Nz<MatchedSubAppResource -> r� )ry rg r? r? rY r� � r� z MatchedSubAppResource.__repr__)rT rU rV rQ rd r} rW rj rH rv r, r� rq r� r? r? r? rY r� h s r� c s� e Zd ZdZdd�dedeeee f de de
e ddf
� fd d
�Z defd d �Z
ede
e fd
d��Zdededefdd�Zdefdd�Z� ZS )r7 zA route with resourceNr� r� r� r� r� r] c s t � j||||d� d S )Nr� )r� rd )rc r� r� r� r� r� r? rY rd � s
�zResourceRoute.__init__c C s dj | j| j| jd�S )Nz3<ResourceRoute [{method}] {resource} -> {handler!r})r� r� r� )r� r� r� r� rg r? r? rY r� � s �zResourceRoute.__repr__c C s | j d u rd S | j jS r_ )r� r\ rg r? r? rY r\ � s
zResourceRoute.namer� rl c O s | j dusJ �| j j|i |��S r� )r� rm r� r? r? rY rm � s zResourceRoute.url_forc C s | j d usJ �| j �� S r_ )r� rv rg r? r? rY rv � s
zResourceRoute.get_info)rT rU rV �__doc__rW r r$ r r! r2 r r� rd r� r} r\ r rm rH rv r� r? r? r� rY r7 � s& ������ r7 c s� e Zd Zdeddf� fdd� Zdededefdd �Zede e fd
d ��Z
de fd d
�Z de
defdd�Zedefdd��Zedefdd��Zdefdd�Z� ZS )r� rS r] Nc s t � �tj| j� || _d S r_ )r� rd r r� r/ �_http_exceptionr� r� r? rY rd � s
zSystemRoute.__init__r� rl c O r )Nz).url_for() is not allowed for SystemRouter� r� r? r? rY rm � r� zSystemRoute.url_forc C rw r_ r? rg r? r? rY r\ � r� zSystemRoute.namec C r� )NrS �r� rg r? r? rY rv � re zSystemRoute.get_inforn c � s �| j �r_ r� rp r? r? rY r/ � s �zSystemRoute._handlec C r� r_ )r� r� rg r? r? rY r� � r� zSystemRoute.statusc C r� r_ )r� r� rg r? r? rY r� � r� zSystemRoute.reasonc C s dj | d�S )Nz*<SystemRoute {self.status}: {self.reason}>rg )r� rg r? r? rY r� � � zSystemRoute.__repr__)rT rU rV r& rd rW r rm r} r r\ rH rv r, r. r/ r� r� r� r� r� r? r? r� rY r� � s r� c @ s@ e Zd Zdefdd�Zdeedef fdd�Zdefdd�Z dS ) r9 r] c � sZ �| j jtjvr | �� t| | j j�� d �}|d u r | �� |� I d H }t|t�s+J �|S r_ ) rn r� r �METH_ALL�_raise_allowed_methods�getattrr� r� r. )rc r� �retr? r? rY �_iter� s � z
View._iterNc C s | � � �� S r_ )r� � __await__rg r? r? rY r� � r� zView.__await__c s" � fdd�t jD �}t� jj|��)Nc s h | ] }t � |�� �r|�qS r? )�hasattrr� )r rQ rg r? rY � <setcomp>� s z.View._raise_allowed_methods.<locals>.<setcomp>)r r� r) rn r� )rc rU r? rg rY r� � s zView._raise_allowed_methods)
rT rU rV r. r� r r r� r r� r? r? r? rY r9 � s r9 c @ sT e Zd Zdee ddfdd�Zdefdd�Zdee fdd �Z d
e
de fd d �Z dS )
�
ResourcesViewr| r] Nc C r^ r_ ��
_resources)rc r| r? r? rY rd � re zResourcesView.__init__c C r� r_ )r� r� rg r? r? rY r� � re zResourcesView.__len__c c � � | j E d H d S r_ r� rg r? r? rY r� � r� zResourcesView.__iter__r� c C �
|| j v S r_ r� �rc r� r? r? rY � __contains__� re zResourcesView.__contains__)
rT rU rV r r2 rd r� r� r r� �objectr� r� r? r? r? rY r� � s
r� c @ sP e Zd Zdee fdd�Zdefdd�Zdee fdd�Z
d e de fd
d �Z
d S )
�
RoutesViewr| c C s* g | _ |D ]
}|D ]}| j �|� q qd S r_ )r� rg )rc r| r� r� r? r? rY rd � s ��zRoutesView.__init__r] c C r� r_ r� rg r? r? rY r� � re zRoutesView.__len__c c r� r_ �r� rg r? r? rY r� � r� zRoutesView.__iter__r� c C r� r_ r� r� r? r? rY r� � re zRoutesView.__contains__N)rT rU rV r r2 rd r� r� r r6 r� r� r� r� r? r? r? rY r� � s
r� c s� e Zd Ze�d�ZdN� fdd� Zdedefdd�Z de
e fd d
�Z de
fd d �Zd
edefdd�Zde defdd�Zdefdd�Zdefdd�Zdee ef fdd�Zd
eddfdd�Zd
ede fdd �Zd
eddfd d �Z d
eddfd d �Z dd!�d"e de e de fd#d$�Z ddd%�d&e d"e d'e!e"e#e$ f de e d(e e% de&f d)d*�Z'ddd+d,d,d,d-�d.e d"e(de e d(e e% d/e
d0ed1ed2edefd3d4�Z)d"e d'e"d5e*de&fd6d7�Z+d"e d'e"d5e*de&fd8d9�Z,dd:d;�d"e d'e"de e d<ed5e*de&f d=d>�Z-d"e d'e"d5e*de&fd?d@�Z.d"e d'e"d5e*de&fdAdB�Z/d"e d'e"d5e*de&fdCdD�Z0d"e d'e"d5e*de&fdEdF�Z1d"e d'e#e$ d5e*de&fdGdH�Z2dN� fdIdJ� Z3dKe4e5 de6e& fdLdM�Z7� Z8S )Or0 z[.:-]r] Nc s& t � �� g | _i | _i | _g | _d S r_ )r� rd r� �_named_resources�_resource_index�_matched_sub_app_resourcesrg r� r? rY rd � s
zUrlDispatcher.__init__rn c � s� �| j }t� }|jj}|r<|�|d�D ]}|�|�I d H \}}|d ur'| S ||O }q|dkr1n |�d�d p9d}|s
| jD ]}|�|�I d H \}}|d urS| S ||O }q?|rbtt |j
|��S tt � �S )Nr? rE r ) r� r� r� r� r� rq �
rpartitionr� r� r) r� r* ) rc rn �resource_indexrU �url_part� candidater� �allowedr� r? r? rY rq s, �
�
zUrlDispatcher.resolvec C r� r_ )r� r� rg r? r? rY r� . re zUrlDispatcher.__iter__c C r� r_ )r� r� rg r? r? rY r� 1 re zUrlDispatcher.__len__r� c C r� r_ �r� r� r? r? rY r� 4 re zUrlDispatcher.__contains__r\ c C s
| j | S r_ r� rb r? r? rY � __getitem__7 re zUrlDispatcher.__getitem__c C r� r_ )r� r� rg r? r? rY r| : re zUrlDispatcher.resourcesc C r� r_ )r� r� rg r? r? rY rN = re zUrlDispatcher.routesc C r� r_ )r r� rg r? r? rY �named_resources@ re z UrlDispatcher.named_resourcesc C s� t |t�s J d|����| jrtd��|j}|d urR| j�|�}|D ]}t�|�r1t d|�d���|�
� s<t d� |���q"|| j v rMt d� || j | ���|| j |< | j
�|� t |t�re| j�|� d S | �|� d S )Nz4Instance of AbstractResource class is required, got z.Cannot register a resource into frozen router.zIncorrect route name z/, python keywords cannot be used for route namezoIncorrect route name {!r}, the name should be a sequence of python identifiers separated by dash, dot or columnz'Duplicate {!r}, already handled by {!r})r� r2 �frozenr� r\ �
NAME_SPLIT_REr� �keyword� iskeywordr� � isidentifierr� r� r� rg r� r� r~ )rc r� r\ r r
r? r? rY �register_resourceC s> ��
���
�
z UrlDispatcher.register_resourcec C s4 d|j }v r|�d�d �d�d }|�d�pdS )z9Return a key to index the resource in the resource index.r� r rE )rj � partitionr� r� )rc r� � index_keyr? r? rY �_get_resource_index_keyj s z%UrlDispatcher._get_resource_index_keyc C s" | � |�}| j�|g ��|� dS )z%Add a resource to the resource index.N)r� r� �
setdefaultrg �rc r� � resource_keyr? r? rY r~ u s
z UrlDispatcher.index_resourcec C s | � |�}| j| �|� dS )z*Remove a resource from the resource index.N)r� r� �remover� r? r? rY r} } s
z UrlDispatcher.unindex_resourcer[ rI c C s� |r |� d�s td��| jr"| jd }|j|kr"|�|�r"tt|�S d|v s<d|v s<t�|�s<t ||d�}| �
|� |S t ||d�}| �
|� |S )NrE z)path should be started with / or be empty���r� r� r[ ) r� r� r� r\ r{ r r3 rD �searchr4 r� r5 )rc rI r\ r� r? r? rY � add_resource� s
zUrlDispatcher.add_resource)r\ r� r� r� r� c C s | j ||d�}|j|||d�S )Nr[ r� )r� r� )rc r� rI r� r\ r� r� r? r? rY r� � s zUrlDispatcher.add_router Fr rM r r! r" r# c
C sJ |� d�sJ �|�d�r|dd� }t||||||||d�} | �| � | S )z^Add static files view.
prefix - url prefix
path - folder with files
rE Nr� r )r� r� r8 r� )
rc rM rI r\ r� r r! r" r# r� r? r? rY �
add_static� s
�
zUrlDispatcher.add_staticrl c K � | j tj||fi |��S )z(Shortcut for add_route with method HEAD.)r� r � METH_HEAD�rc rI r� rl r? r? rY �add_head� � zUrlDispatcher.add_headc K r� )z+Shortcut for add_route with method OPTIONS.)r� r � METH_OPTIONSr� r? r? rY � add_options� r� zUrlDispatcher.add_optionsT)r\ �
allow_headr� c K s> | j ||d�}|r|jtj|fi |�� |jtj|fi |��S )z�Shortcut for add_route with method GET.
If allow_head is true, another
route is added allowing head requests to the same endpoint.
r[ )r� r� r r� �METH_GET)rc rI r� r\ r� rl r� r? r? rY �add_get� s zUrlDispatcher.add_getc K r� )z(Shortcut for add_route with method POST.)r� r � METH_POSTr� r? r? rY �add_post� r� zUrlDispatcher.add_postc K r� )z'Shortcut for add_route with method PUT.)r� r �METH_PUTr� r? r? rY �add_put� r� zUrlDispatcher.add_putc K r� )z)Shortcut for add_route with method PATCH.)r� r �
METH_PATCHr� r? r? rY � add_patch� r� zUrlDispatcher.add_patchc K r� )z*Shortcut for add_route with method DELETE.)r� r � METH_DELETEr� r? r? rY �
add_delete� r� zUrlDispatcher.add_deletec K r� )z?Shortcut for add_route with ANY methods for a class-based view.)r� r r� r� r? r? rY �add_view� s zUrlDispatcher.add_viewc s" t � �� | jD ]}|�� qd S r_ )r� rx r� r� r� r? rY rx � s
�zUrlDispatcher.freezerN c C s" g }|D ]
}|� |�| �� q|S )z�Append routes to route table.
Parameter should be a sequence of RouteDef objects.
Returns a list of registered AbstractRoute instances.
)�extend�register)rc rN �registered_routes� route_defr? r? rY �
add_routes� s zUrlDispatcher.add_routesr| )9rT rU rV r r r� rd r, r1 rq r rW r� r� r� r� r� r� r2 r� r� r| r� rN r r� r� r� r~ r} r r3 r� r r$ r r! r� r6 r� r% r� r r� r� r� r� r� r� r� r� rx r
r/ r r� r� r? r? r� rY r0 � s�
)' ������
�������� �
�
�" ������
����
�"r0 r c C s$ t dk r
| �dd�} tj| dd�jS )Nr1 r3 r4 Fr� )rB r7 r r� �raw_path�r r? r? rY r s r c C s d| vr| S | � dd�� dd�S )Nr3 z%2FrE r4 )r7 r� r? r? rY r s r c C s t | �}d| v r|�dd�}|S )Nr3 r4 )r r7 )r r� r? r? rY r s r )|r~ r� rM � functoolsrJ ru r� r� r9 r �sysr� r �pathlibr �typesr �typingr r r r r r
r r r
r r r r r r r r r r r r r �yarlr r � yarl_versionr� r r r r! �helpersr" �httpr# �typedefsr$ r% �web_exceptionsr& r' r( r) r* �web_fileresponser+ � web_requestr, � web_responser- r. � web_routedefr/ �__all__�web_appr: rW �BaseDict�dict� version_info�platformr� �OSErrorr� r] r� �mapr� r� rB rX r rC rD r rF r� r� �partialrd rH r2 �ABCr6 r1 r� r� r3 r4 r5 r r8 rx rQ r� r� r� r7 r� r9 r� r� r0 r r r r? r? r? rY �<module> s�
` ��0��/QA6(L S.( $