Edit File: web_app.cpython-37.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� t|t�s2t|��|d k rJtjdtdd� |dk rbtjdtdd� || _|| _|| _ || _ || _ 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�DeprecationWarning� isinstancer �AssertionErrorr3 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 )rX rD rD rV �__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 rY rP �super� __setattr__)rU r\ r] )� __class__rD rV r` � s zApplication.__setattr__)�otherrK c C s | |kS )NrD )rU rb rD rD rV �__eq__� s zApplication.__eq__)�keyrK c C s | j | S )N)r: )rU rd rD rD rV � __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 )rU rD rD rV � _check_frozen� s zApplication._check_frozen)rd �valuerK c C s | � � || j|< d S )N)rg r: )rU rd rh rD rD rV � __setitem__� s zApplication.__setitem__c C s | � � | j|= d S )N)rg r: )rU rd rD rD rV � __delitem__� s zApplication.__delitem__c C s t | j�S )N)�lenr: )rU rD rD rV �__len__� s zApplication.__len__c C s t | j�S )N)�iterr: )rU rD rD rV �__iter__� s zApplication.__iter__c C s t jdtdd� ttj| j�S )Nzloop property is deprecatedrL )rM )rN rO rP r �asyncio�AbstractEventLoopr5 )rU rD rD rV 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.)ro �get_event_loopr5 � RuntimeErrorr3 � get_debugr= � _set_loop)rU rI �subapprD rD rV rt � s zApplication._set_loopc C s | j S )N)r< )rU rD rD rV � 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)rU ru rD rD rV rz � s zApplication.pre_freezec C s | j S )N)r; )rU rD rD rV �frozen s zApplication.frozenc C s4 | j r d S | �� d| _ x| jD ] }|�� q W d S )NT)r; rz r= rw )rU ru rD rD rV rw s zApplication.freezec C s t jdtdd� | jS )Nz debug property is deprecatedrL )rM )rN rO rP r3 )rU rD rD rV rJ s zApplication.debug)ru 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} )ru �subsigrD rV �handler s zEApplication._reg_subapp_signals.<locals>.reg_handler.<locals>.handler)�getattrrT )r| r� Zappsig)rU ru )r rV � reg_handler s z4Application._reg_subapp_signals.<locals>.reg_handler� on_startup� on_shutdown� on_cleanup)�str)rU ru r� rD )rU ru rV �_reg_subapp_signals s z Application._reg_subapp_signals)�prefixru rK c C s@ t |t�std��|�d�}|s(td��tt||�}| �||�S )NzPrefix must be str�/zPrefix cannot be empty)rQ r� � TypeError�rstrip� ValueErrorr r- � _add_subapp)rU r� ru �factoryrD rD rV � add_subapp* s zApplication.add_subapp)�resource_factoryru 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) r{ rr rE Zregister_resourcer� r= rT rz r5 rt )rU r� ru �resourcerD rD rV r� 3 s zApplication._add_subapp)�domainru rK c C sF t |t�std��nd|kr&t|�}nt|�}tt||�}| �||�S )NzDomain must be str�*)rQ r� r� r+ r* r r, r� )rU r� ru Zruler� rD rD rV � add_domainC s zApplication.add_domain)�routesrK c C s | j �|�S )N)rE � add_routes)rU r� rD rD rV r� M s zApplication.add_routesc C s | j S )N)r> )rU rD rD rV �on_response_prepareP s z Application.on_response_preparec C s | j S )N)r? )rU rD rD rV r� T s zApplication.on_startupc C s | j S )N)r@ )rU rD rD rV r� X s zApplication.on_shutdownc C s | j S )N)rA )rU rD rD rV r� \ s zApplication.on_cleanuprS c C s | j S )N)rC )rU rD rD rV � cleanup_ctx` s zApplication.cleanup_ctxc C s | j S )N)r4 )rU rD rD rV rE d s zApplication.routerc C s | j S )N)r7 )rU rD rD rV 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� rY rt rw r3 r6 �itemsr' �_handle� _make_requestr5 )rU rI r� r� �k�vrD rD rV � _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� )rU rI r� r� rD rD rV � 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~ )rU rD rD rV �startup� s zApplication.startupc � s | j �| �I dH dS )zMCauses on_shutdown signal Should be called before cleanup() N)r� r~ )rU rD rD rV �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� r{ r~ rC rA )rU rD rD rV �cleanup� s zApplication.cleanupzasyncio.Task[None])�message�payload�protocol�writer�task�_clsrK c C s ||||||| j | jd�S )N)rH )r5 rB )rU r� r� r� r� r� r� rD rD rV 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 rY rP r" )rU �mrD rD rV ry � 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� )ro rq rs r4 �resolverQ r r� rY Zadd_apprw Z _match_info�headers�getr ZEXPECTZexpect_handlerr� Zdrainr� r9 Zappsr8 r r ) rU r� rI rJ Z match_infoZrespZexpectr� r} r� Z new_stylerD rD rV r� � s6 zApplication._handlec C s | S )zgunicorn compatibilityrD )rU rD rD rV �__call__� s zApplication.__call__c C s dt | �d�d�S )Nz<Application 0x�x�>)�id)rU rD rD rV �__repr__ s zApplication.__repr__c C s dS )NTrD )rU rD rD rV �__bool__ s zApplication.__bool__)SrZ � __module__� __qualname__� frozensetr^ r �logging�Loggerr r. r � _Middlewarer r� r �intro rp rW r r[ r r` �object�boolrc re rg ri rj rl r rn �propertyrI rt rv rz r{ rw 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 ry r% r� r� r� r� � __classcell__rD rD )ra rV 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)rU rD rD rV � exceptions s zCleanupError.exceptionsN)rZ r� r� r� r r� r� rD rD rD rV r0 s r0 c sB e Zd Zdd�� fdd� Zedd�dd�Zedd�dd �Z� ZS ) rS N)rK c s t � �� g | _d S )N)r_ rW �_exits)rU )ra rD rV rW s zCleanupContext.__init__)r} rK c � s8 x2| D ]*}||�� � }|�� I d H | j�|� qW d S )N)� __aiter__� __anext__r� rT )rU r} �cb�itrD rD rV 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� ExceptionrT rr rk r0 )rU r} �errorsr� �excrD rD rV rA s zCleanupContext._on_cleanup)rZ r� r� rW r/ r? rA r� rD rD )ra rV rS s rS )Qro 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/ rr r0 Z_CleanupContextBaserS rD rD rD rV �<module> s\ L $ 9