U
'�7`�B � @ sr d dl Z d dlZd dlZd dlmZmZ d dlmZmZm Z m
Z
m Z m Z m
Z
mZmZmZmZmZmZmZmZmZmZ ddlmZ ddlmZm Z m Z m Z ddl m Z ddl!m"Z" dd l#m$Z$ dd
l%m&Z& dd l'm(Z( dd l)m*Z* dd
l+m,Z, ddl-m.Z. ddl/m0Z0 ddl1m2Z2 ddl3m4Z4 ddl5m6Z6 ddl7m8Z8 ddl9m:Z:m;Z;m<Z<m=Z=m>Z>m?Z?m@Z@ dZAe�r�e(e dge
d f ZBe(e e2e4ge
d f ZCe e2ge
e4 f ZDee e2eDge
e4 f e deDge
eD f f ZEe eE ZFeeeeEeGf ZHed ZIn e(ZBe(ZCe ZDe ZEe ZFee ZHeZIG dd� deeJef �ZKG dd� deL�ZMe�rZe e eKge d f ZNne ZNG dd� deN�ZOdS ) � N)�partial�update_wrapper)�
TYPE_CHECKING�Any�
AsyncIterator� Awaitable�Callable�Dict�Iterable�Iterator�List�Mapping�MutableMapping�Optional�Sequence�Tuple�Type�Union�cast� )�hdrs)�AbstractAccessLogger�AbstractMatchInfo�AbstractRouter�AbstractStreamWriter)�
FrozenList)�DEBUG)�RawRequestMessage)�
web_logger)�Signal)� StreamReader)� AccessLogger)�_fix_request_current_app)�RequestHandler)�Request)�StreamResponse)�AbstractRouteDef)�Server)�AbstractResource�
AbstractRoute�Domain�
MaskDomain�MatchedSubAppResource�PrefixedSubAppResource�
UrlDispatcher)� Application� CleanupErrorr/ c sp e Zd Zeddddddddd d
d d d
dddddg�Zeddddddd�ejee e
e ee e
ef eeej edd�dd�Zed dd�d d �Zer�e
edd �� fd d � Zeed!�d"d#�Ze
ed$�d%d&�Zdd'�d(d)�Ze
edd*�d+d,�Z e
dd$�d-d.�Z ed'�d/d0�Z e e
d'�d1d2�Z e!ejd'�d3d4��Z"eej dd5�d6d7�Z#e!ed'�d8d9��Z$dd'�d:d;�Z%e!ed'�d<d=��Z&dd'�d>d?�Z'e!ed'�d@dA��Z(d ddB�dCdD�Z)e
d e*dE�dFdG�Z+e,g e*f d e*dH�dIdJ�Z-e
d e*dK�dLdM�Z.e
e/ e0e1 dN�dOdP�Z2e!e3d'�dQdR��Z4e!e5d'�dSdT��Z6e!e5d'�dUdV��Z7e!e5d'�dWdX��Z8e!dYd'�dZd[��Z9e!e d'�d\d]��Z:e!e;d'�d^d_��Z<de=d`�eej ee> ee?da�dbdc�Z@de=d`�eej ee> ee?da�ddde�ZAdd'�dfdg�ZBdd'�dhdi�ZCdd'�djdk�ZDeEfeFeGeHeIdleeE eEdm�dndo�ZJe eKe ef d'�dpdq�ZLeEeMdr�dsdt�ZNd d'�dudv�ZOe
d'�dwdx�ZPed'�dydz�ZQ� ZRS ){r/ �logger�_debug�_router�_loop�
_handler_args� _middlewares�_middlewares_handlers�_run_middlewares�_state�_frozen� _pre_frozen�_subapps�_on_response_prepare� _on_startup� _on_shutdown� _on_cleanup�_client_max_size� _cleanup_ctxN� i .)r1 �router� middlewares� handler_args�client_max_size�loop�debug)r1 rD rE rF rG rH rI �returnc C s� |d krt � }ntjdtdd� |d k r8tjdtdd� |dk rPtjdtdd� || _|| _|| _|| _|| _t |�| _
d | _ d | _ i | _
d| _d| _g | _t| �| _t| �| _t| �| _t| �| _t� | _| j�| jj� | j�| jj� || _d S )Nz router argument is deprecated� ��
stacklevelzloop argument is deprecated.z debug argument is deprecatedF)r. �warnings�warn�DeprecationWarningr2 r3 r4 r5 r1 r r6 r7 r8 r9 r: r; r< r r= r> r? r@ �CleanupContextrB �appendrA )�selfr1 rD rE rF rG rH rI rC rC �B/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/web_app.py�__init__h sN � � �
zApplication.__init__)�clsrJ c C s t jd�| j�tdd� d S )Nz8Inheritance class {} from web.Application is discouragedrK rL )rN rO �format�__name__rP )rV rC rC rT �__init_subclass__� s ��z Application.__init_subclass__)�name�valrJ c s2 || j kr tjd�|�tdd� t� �||� d S )Nz:Setting custom web.Application.{} attribute is discouragedrK rL )�ATTRSrN rO rW rP �super� __setattr__)rS rZ r[ �� __class__rC rT r^ � s
��zApplication.__setattr__)�otherrJ c C s | |kS �NrC )rS ra rC rC rT �__eq__� s zApplication.__eq__)�keyrJ c C s
| j | S rb )r9 �rS rd rC rC rT � __getitem__� s zApplication.__getitem__�rJ c C s | j rtjdtdd� d S )Nz=Changing state of started or joined application is deprecated� rL )r: rN rO rP �rS rC rC rT �
_check_frozen� s �zApplication._check_frozen)rd �valuerJ c C s | � � || j|< d S rb �rj r9 )rS rd rk rC rC rT � __setitem__� s zApplication.__setitem__c C s | � � | j|= d S rb rl re rC rC rT � __delitem__� s zApplication.__delitem__c C s
t | j�S rb )�lenr9 ri rC rC rT �__len__� s zApplication.__len__c C s
t | j�S rb )�iterr9 ri rC rC rT �__iter__� s zApplication.__iter__c C s t jdtdd� ttj| j�S )Nzloop property is deprecatedrK rL )rN rO rP r �asyncio�AbstractEventLoopr4 ri rC rC rT rH � s zApplication.loop)rH rJ c C s` |d krt �� }| jd k r,| j|k r,td��|| _| jdkrF|�� | _| jD ]}|�|� qLd S )Nz8web.Application instance initialized with different loop.)rs �get_event_loopr4 � RuntimeErrorr2 � get_debugr< � _set_loop)rS rH �subapprC rC rT rx � s �
zApplication._set_loopc C s | j S rb )r; ri rC rC rT �
pre_frozen� s zApplication.pre_frozenc C s� | j r
d S d| _ | j�� | j�� | j�� | j�� | j�� | j�� | j�� t | �
� �| _ | j rndnd| _
| jD ]}|�� | j
p�|j
| _
qzd S )NTF)r; r6 �freezer3 r= rB r> r? r@ �tuple�_prepare_middlewarer7 rE r8 r< �
pre_freeze�rS ry rC rC rT r~ � s
zApplication.pre_freezec C s | j S rb )r: ri rC rC rT �frozen s zApplication.frozenc C s0 | j r
d S | �� d| _ | jD ] }|�� q d S �NT)r: r~ r< r{ r rC rC rT r{
s
zApplication.freezec C s t jdtdd� | jS )Nz debug property is deprecatedrK rL )rN rO rP r2 ri rC rC rT rI s zApplication.debug)ry rJ c s2 t d d�� �fdd� }|d� |d� |d� d S )N)�signamerJ c s8 t �| �� dd d��� fdd� }t �| �}|�|� d S )Nr/ ��apprJ c � s �� � �I d H d S rb )�send)r� )ry �subsigrC rT �handler s zEApplication._reg_subapp_signals.<locals>.reg_handler.<locals>.handler)�getattrrR )r� r� Zappsigr )r� rT � reg_handler s
z4Application._reg_subapp_signals.<locals>.reg_handler�
on_startup� on_shutdown�
on_cleanup)�str)rS ry r� rC r rT �_reg_subapp_signals s z Application._reg_subapp_signals)�prefixry rJ c C s@ t |t�std��|�d�}|s(td��tt||�}| �||�S )NzPrefix must be str�/zPrefix cannot be empty)�
isinstancer� � TypeError�rstrip�
ValueErrorr r- � _add_subapp)rS r� ry �factoryrC rC rT �
add_subapp) s
zApplication.add_subapp)�resource_factoryry rJ c C sf | j rtd��|j r td��|� }| j�|� | �|� | j�|� |�� | jd k rb|� | j� |S )Nz0Cannot add sub application to frozen applicationz Cannot add frozen application)
r� rv rD Zregister_resourcer� r< rR r~ r4 rx )rS r� ry �resourcerC rC rT r� 2 s
zApplication._add_subapp)�domainry rJ c C sF t |t�std��nd|kr&t|�}nt|�}tt||�}| �||�S )NzDomain must be str�*)r� r� r� r+ r* r r, r� )rS r� ry Zruler� rC rC rT �
add_domainB s
zApplication.add_domain)�routesrJ c C s | j �|�S rb )rD �
add_routes)rS r� rC rC rT r� L s zApplication.add_routesc C s | j S rb )r= ri rC rC rT �on_response_prepareO s z Application.on_response_preparec C s | j S rb )r> ri rC rC rT r� S s zApplication.on_startupc C s | j S rb )r? ri rC rC rT r� W s zApplication.on_shutdownc C s | j S rb )r@ ri rC rC rT r� [ s zApplication.on_cleanuprQ c C s | j S rb )rB ri rC rC rT � cleanup_ctx_ s zApplication.cleanup_ctxc C s | j S rb )r3 ri rC rC rT rD c s zApplication.routerc C s | j S rb )r6 ri rC rC rT rE g s zApplication.middlewares�rH �access_log_class)rH r� �kwargsrJ c K sz t |t�std�|���| �|� | �� | j|d< ||d< | jr^| j�� D ]\}}|||< qLt | j
f| j | j d�|��S )NzMaccess_log_class must be subclass of aiohttp.abc.AbstractAccessLogger, got {}rI r� )Zrequest_factoryrH )
�
issubclassr r� rW rx r{ r2 r5 �itemsr' �_handle�
_make_requestr4 )rS rH r� r� �k�vrC rC rT �
_make_handlerk s*
��
���zApplication._make_handlerc K s& t jdtdd� | jf ||d�|��S )NzFApplication.make_handler(...) is deprecated, use AppRunner API insteadrK rL r� )rN rO rP r� )rS rH r� r� rC rC rT � make_handler� s � ��zApplication.make_handlerc � s | j �| �I dH dS )zmCauses on_startup signal
Should be called in the event loop along with the request handler.
N)r� r� ri rC rC rT �startup� s zApplication.startupc � s | j �| �I dH dS )zMCauses on_shutdown signal
Should be called before cleanup()
N)r� r� ri rC rC rT �shutdown� s zApplication.shutdownc � s | j �| �I dH dS )zLCauses on_cleanup signal
Should be called after shutdown()
N)r� r� ri rC rC rT �cleanup� s zApplication.cleanupzasyncio.Task[None])�message�payload�protocol�writer�task�_clsrJ c C s ||||||| j | jd�S )N)rG )r4 rA )rS r� r� r� r� r� r� rC rC rT r� � s �zApplication._make_requestc c s^ t | j�D ]@}t|dd �dkr*|dfV q
tjd�|�tdd� |dfV q
t| �dfV d S )NZ__middleware_version__r Tz1old-style middleware "{!r}" deprecated, see #2252rK rL F)�reversedr6 r� rN rO rW rP r" )rS �mrC rC rT r} � s � z Application._prepare_middleware)�requestrJ c � s t �� }|�� }| j�|�I d H }|r>t|t�s>td�|���|� | � |�
� d }||_ |j �
tj�}|r�|�|�I d H }|j�� I d H |d kr�|j}| jr�|jd d d� D ]<}|jD ]0\} }
|
r�tt| |d�|�}q�| ||�I d H }q�q�||�I d H }|S )Nz9match_info should be AbstractMatchInfo instance, not {!r}���)r� )rs ru rw r3 Zresolver� r r� rW Zadd_appr{ Z _match_infoZheaders�getr ZEXPECTZexpect_handlerr� Zdrainr� r8 Zappsr7 r r ) rS r� rH rI Z
match_infoZresp�expectr� r� r� Z new_stylerC rC rT r� � s>
��
�zApplication._handlec C s | S )zgunicorn compatibilityrC ri rC rC rT �__call__� s zApplication.__call__c C s d� t| ��S )Nz<Application 0x{:x}>)rW �idri rC rC rT �__repr__� s zApplication.__repr__c C s dS r� rC ri rC rC rT �__bool__� s zApplication.__bool__)SrX �
__module__� __qualname__� frozensetr\ r �loggingZLoggerr r. r
� _Middlewarer
r� r �intrs rt rU r rY r r^ �object�boolrc rf rj rm rn rp r rr �propertyrH rx rz r~ r� r{ rI r� r( r� r r� r� r& r r) r� �_RespPrepareSignalr� �
_AppSignalr� r� r� r� rD � _MiddlewaresrE r! r r' r� r� r� r� r� r$ r r r# r r� r r} r% r� r� r� r� �
__classcell__rC rC r_ rT r/ P s� ���� 7
�
�� !�� �� &c @ s" e Zd Zeee d�dd��ZdS )r0 rg c C s
| j d S )Nr )�argsri rC rC rT �
exceptions s zCleanupError.exceptionsN)rX r� r� r� r �
BaseExceptionr� rC rC rC rT r0 s r0 c sB e Zd Zdd�� fdd� Zedd�dd�Zedd�dd �Z� ZS )
rQ Nrg c s t � �� g | _d S rb )r] rU �_exitsri r_ rC rT rU s
zCleanupContext.__init__r� c � s4 | D ]*}||�� � }|�� I d H | j�|� qd S rb )� __aiter__� __anext__r� rR )rS r� �cb�itrC rC rT r> s zCleanupContext._on_startupc � s� g }t | j�D ]j}z|�� I d H W n> tk
r8 Y q tk
rb } z|�|� W 5 d }~X Y qX |�t|�d��� q|r�t|�dkr�|d �n
td|��d S )Nz has more than one 'yield'r r z Multiple errors on cleanup stage) r� r� r� �StopAsyncIteration� ExceptionrR rv ro r0 )rS r� �errorsr� �excrC rC rT r@ s
zCleanupContext._on_cleanup)rX r� r� rU r/ r> r@ r� rC rC r_ rT rQ s rQ )Prs r� rN � functoolsr r �typingr r r r r r r
r r r
r r r r r r r � r �abcr r r r Z
frozenlistr Zhelpersr Z http_parserr �logr Zsignalsr Zstreamsr Zweb_logr! Zweb_middlewaresr" Z web_protocolr# Z web_requestr$ Z web_responser% Z web_routedefr& Z
web_serverr' Zweb_urldispatcherr( r) r* r+ r, r- r. �__all__r� r� Z_Handlerr� r� r� Z_MiddlewaresHandlersZ_Subappsr� r/ rv r0 Z_CleanupContextBaserQ rC rC rC rT �<module> sb L $
��
5