File: //opt/alt/python37/lib64/python3.7/site-packages/aiohttp/__pycache__/web_app.cpython-37.opt-1.pyc
B
�k�atC � @ sh d dl Z d dlZd dlZd dlmZmZ d dlmZmZm Z m
Z
m Z m Z m
Z
mZmZmZmZmZmZmZmZmZmZ d dlmZ d dlmZ ddl m Z ddl m Z m Z m!Z!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�ddlBmCZC ee dge
d f ZDee e2e4ge
d f ZEee e2eCge
e4 f e deCge
eC f f ZFeeF ZGeeeeFeHf ZIed ZJn eZDeZEe ZFeZGee ZIeZJG dd� deeKef �ZLG dd� deM�ZNe�rPee eLge d f ZOneZOG dd � d eO�ZPdS ) � N)�partial�update_wrapper)�
TYPE_CHECKING�Any�
AsyncIterator� Awaitable�Callable�Dict�Iterable�Iterator�List�Mapping�MutableMapping�Optional�Sequence�Tuple�Type�Union�cast)�Signal)�
FrozenList� )�hdrs)�AbstractAccessLogger�AbstractMatchInfo�AbstractRouter�AbstractStreamWriter)�DEBUG)�RawRequestMessage)�
web_logger)� StreamReader)� AccessLogger)�_fix_request_current_app)�RequestHandler)�Request)�StreamResponse)�AbstractRouteDef)�Server)�AbstractResource�
AbstractRoute�Domain�
MaskDomain�MatchedSubAppResource�PrefixedSubAppResource�
UrlDispatcher)� Application� CleanupError)�Handlerr/ 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 .)r2 �router� middlewares� handler_args�client_max_size�loop�debug)r2 rE rF rG rH rI rJ �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�DeprecationWarningr3 r4 r5 r6 r2 r r7 r8 r9 r: r; r< r= r r> r? r@ rA �CleanupContextrC �appendrB )�selfr2 rE rF rG rH rI rJ rD rD �B/opt/alt/python37/lib64/python3.7/site-packages/aiohttp/web_app.py�__init__i s<
zApplication.__init__)�clsrK c C s t jd�| j�tdd� d S )Nz8Inheritance class {} from web.Application is discouragedrL )rM )rN rO �format�__name__rP )rV rD rD rT �__init_subclass__� s
z Application.__init_subclass__)�name�valrK c s2 || j kr tjd�|�tdd� t� �||� d S )Nz:Setting custom web.Application.{} attribute is discouragedrL )rM )�ATTRSrN rO rW rP �super� __setattr__)rS rZ r[ )� __class__rD rT r^ � s
zApplication.__setattr__)�otherrK c C s | |kS )NrD )rS r` rD rD rT �__eq__� s zApplication.__eq__)�keyrK c C s
| j | S )N)r: )rS rb rD rD rT � __getitem__� s zApplication.__getitem__)rK c C s | j rtjdtdd� d S )Nz=Changing state of started or joined application is deprecated� )rM )r; rN rO rP )rS rD rD rT �
_check_frozen� s
zApplication._check_frozen)rb �valuerK c C s | � � || j|< d S )N)re r: )rS rb rf rD rD rT � __setitem__� s zApplication.__setitem__c C s | � � | j|= d S )N)re r: )rS rb rD rD rT � __delitem__� s zApplication.__delitem__c C s
t | j�S )N)�lenr: )rS rD rD rT �__len__� s zApplication.__len__c C s
t | j�S )N)�iterr: )rS rD rD rT �__iter__� s zApplication.__iter__c C s t jdtdd� ttj| j�S )Nzloop property is deprecatedrL )rM )rN rO rP r �asyncio�AbstractEventLoopr5 )rS rD rD rT rI � s zApplication.loop)rI rK c C sd |d krt �� }| jd k r,| j|k r,td��|| _| jdkrF|�� | _x| jD ]}|�|� qNW d S )Nz8web.Application instance initialized with different loop.)rm �get_event_loopr5 � RuntimeErrorr3 � get_debugr= � _set_loop)rS rI �subapprD rD rT rr � s
zApplication._set_loopc C s | j S )N)r< )rS rD rD rT �
pre_frozen� s zApplication.pre_frozenc C s� | j r
d S d| _ | j�� | j�� | j�� | j�� | j�� | j�� | j�� t | �
� �| _ | j rndnd| _
x$| jD ]}|�� | j
p�|j
| _
q|W d S )NTF)r< r7 �freezer4 r> rC r? r@ rA �tuple�_prepare_middlewarer8 rF r9 r= �
pre_freeze)rS rs rD rD rT rx � s
zApplication.pre_freezec C s | j S )N)r; )rS rD rD rT �frozen
s zApplication.frozenc C s4 | j r
d S | �� d| _ x| jD ] }|�� q W d S )NT)r; rx r= ru )rS rs rD rD rT ru s zApplication.freezec C s t jdtdd� | jS )Nz debug property is deprecatedrL )rM )rN rO rP r3 )rS rD rD rT rJ s zApplication.debug)rs rK c s2 t d d�� �fdd� }|d� |d� |d� d S )N)�signamerK c s8 t �| �� dd d��� fdd� }t �| �}|�|� d S )Nr/ )�apprK c � s �� � �I d H d S )N)�send)r{ )rs �subsigrD rT �handler s zEApplication._reg_subapp_signals.<locals>.reg_handler.<locals>.handler)�getattrrR )rz r~ Zappsig)rS rs )r} rT � reg_handler s
z4Application._reg_subapp_signals.<locals>.reg_handler�
on_startup� on_shutdown�
on_cleanup)�str)rS rs r� rD )rS rs rT �_reg_subapp_signals s z Application._reg_subapp_signals)�prefixrs rK 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� rs �factoryrD rD rT �
add_subapp* s
zApplication.add_subapp)�resource_factoryrs rK 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)
ry rp rE Zregister_resourcer� r= rR rx r5 rr )rS r� rs �resourcerD rD rT r� 3 s
zApplication._add_subapp)�domainrs rK 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� rs Zruler� rD rD rT �
add_domainC s
zApplication.add_domain)�routesrK c C s | j �|�S )N)rE �
add_routes)rS r� rD rD rT r� M s zApplication.add_routesc C s | j S )N)r> )rS rD rD rT �on_response_prepareP s z Application.on_response_preparec C s | j S )N)r? )rS rD rD rT r� T s zApplication.on_startupc C s | j S )N)r@ )rS rD rD rT r� X s zApplication.on_shutdownc C s | j S )N)rA )rS rD rD rT r� \ s zApplication.on_cleanuprQ c C s | j S )N)rC )rS rD rD rT � cleanup_ctx` s zApplication.cleanup_ctxc C s | j S )N)r4 )rS rD rD rT rE d s zApplication.routerc C s | j S )N)r7 )rS rD rD rT rF h s zApplication.middlewares)rI �access_log_class)rI r� �kwargsrK c K s~ t |t�std�|���| �|� | �� | j|d< ||d< | jrbx | j�� D ]\}}|||< qNW t | j
f| j | j d�|��S )NzMaccess_log_class must be subclass of aiohttp.abc.AbstractAccessLogger, got {}rJ r� )Zrequest_factoryrI )
�
issubclassr r� rW rr ru r3 r6 �itemsr' �_handle�
_make_requestr5 )rS rI r� r� �k�vrD rD rT �
_make_handlerl s
zApplication._make_handlerc K s& t jdtdd� | jf ||d�|��S )NzFApplication.make_handler(...) is deprecated, use AppRunner API insteadrL )rM )rI r� )rN rO rP r� )rS rI r� r� rD rD 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| )rS rD rD rT �startup� s zApplication.startupc � s | j �| �I dH dS )zMCauses on_shutdown signal
Should be called before cleanup()
N)r� r| )rS rD rD rT �shutdown� s zApplication.shutdownc � s2 | j jr | j �| �I dH n| j�| �I dH dS )zLCauses on_cleanup signal
Should be called after shutdown()
N)r� ry r| rC rA )rS rD rD rT �cleanup� s zApplication.cleanupzasyncio.Task[None])�message�payload�protocol�writer�task�_clsrK c C s ||||||| j | jd�S )N)rH )r5 rB )rS r� r� r� r� r� r� rD rD rT r� � s zApplication._make_requestc c sb xNt | j�D ]@}t|dd �dkr,|dfV q tjd�|�tdd� |dfV q W t| �dfV d S )NZ__middleware_version__r Tz1old-style middleware "{!r}" deprecated, see #2252rL )rM F)�reversedr7 r rN rO rW rP r" )rS �mrD rD rT rw � s z Application._prepare_middleware)�requestrK c � s
t �� }|�� }| j�|�I d H }|r>t|t�s>td�|���|� | � |�
� d }||_ |j �
tj�}|r�|�|�I d H }|j�� I d H |d k�r|j}| jr�xT|jd d d� D ]@}x:|jD ]0\} }
|
r�tt| |d�|�}q�| ||�I d H }q�W q�W ||�I d H }|S )Nz9match_info should be AbstractMatchInfo instance, not {!r}���)r~ )rm ro rq r4 Zresolver� r r� rW Zadd_appru Z _match_infoZheaders�getr ZEXPECTZexpect_handlerr� Zdrainr~ r9 Zappsr8 r r ) rS r� rI rJ Z
match_infoZresp�expectr~ r{ r� Z new_stylerD rD rT r� � s6
zApplication._handlec C s | S )zgunicorn compatibilityrD )rS rD rD rT �__call__� s zApplication.__call__c C s dt | �d�d�S )Nz<Application 0x�x�>)�id)rS rD rD rT �__repr__ s zApplication.__repr__c C s dS )NTrD )rS rD rD rT �__bool__ s zApplication.__bool__)SrX �
__module__� __qualname__� frozensetr\ r �loggingZLoggerr r. r
� _Middlewarer
r� r �intrm rn rU r rY r r^ �object�boolra rc re rg rh rj r rl �propertyrI rr rt rx ry ru rJ r� r( r� r r� r� r& r r) r� �_RespPrepareSignalr� �
_AppSignalr� r� r� r� rE � _MiddlewaresrF r! r r' r� r� r� r� r� r$ r r r# r r� r rw r% r� r� r� r� �
__classcell__rD rD )r_ rT r/ Q s� 0-
&c @ s" e Zd Zeee d�dd��ZdS )r0 )rK c C s t tt | jd �S )Nr )r r �
BaseException�args)rS rD rD rT �
exceptions s zCleanupError.exceptionsN)rX r� r� r� r r� r� rD rD rD rT r0 s r0 c sB e Zd Zdd�� fdd� Zedd�dd�Zedd�dd �Z� ZS )
rQ N)rK c s t � �� g | _d S )N)r] rU �_exits)rS )r_ rD rT rU s
zCleanupContext.__init__)r{ rK c � s8 x2| D ]*}||�� � }|�� I d H | j�|� qW d S )N)� __aiter__� __anext__r� rR )rS r{ �cb�itrD rD rT r? s
zCleanupContext._on_startupc � s� g }xxt | j�D ]j}y|�� I d H W n> tk
r: Y q tk
rd } z|�|� W d d }~X Y qX |�t|�d��� qW |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 rp ri r0 )rS r{ �errorsr� �excrD rD rT rA s
zCleanupContext._on_cleanup)rX r� r� rU r/ r? rA r� rD rD )r_ rT rQ s rQ )Qrm r� rN � functoolsr r �typingr r r r r r r
r r r
r r r r r r r Z aiosignalr Z
frozenlistr � r �abcr r r r Zhelpersr Z http_parserr �logr 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__Ztypedefsr1 r� r� r� r� r� Z_MiddlewaresHandlersZ_Subappsr� r/ rp r0 Z_CleanupContextBaserQ rD rD rD rT �<module> s\ L $
9