File: //usr/local/lib/python3.10/dist-packages/aiohttp/__pycache__/web_app.cpython-310.pyc
o
���gbL � @ s� d dl Z d dlZd dlZd dlmZmZmZ d dlmZm Z m
Z
m Z m Z m
Z
mZmZmZmZmZmZmZmZmZmZmZmZmZ d dlm Z d dl m Z ddl m Z ddl!m"Z"m#Z#m$Z$m%Z% dd l&m'Z'm(Z( dd
l)m*Z* dd l+m,Z, dd l-m.Z. dd
l/m0Z0m1Z1 ddl2m3Z3 ddl4m5Z5 ddl6m7Z7 ddl8m9Z9 ddl:m;Z; ddl<m=Z= ddl>m?Z? ddl@mAZA ddlBmCZCmDZDmEZEmFZFmGZGmHZHmIZImJZJ dZKer�e e dge d f ZLe e e;e=ge d f ZMe e1 ZNeeee1eOf ZPed ZQn e ZLe ZMe ZNee ZPeZQed�ZRed�ZSedeCd �ZTd e0d ed d e e;ge e= f fd!d"�ZUed#d$�eU�ZVG d%d� deeeWe(e f e f �ZXG d&d'� d'eY�ZZe�rPe e eXge
d f Z[ne Z[G d(d)� d)e[�Z\dS )*� N)� lru_cache�partial�update_wrapper)�
TYPE_CHECKING�Any�
AsyncIterator� Awaitable�Callable�Dict�Iterable�Iterator�List�Mapping�MutableMapping�Optional�Sequence�Tuple�Type�TypeVar�Union�cast�overload)�Signal)�
FrozenList� )�hdrs)�AbstractAccessLogger�AbstractMatchInfo�AbstractRouter�AbstractStreamWriter)�DEBUG�AppKey)�RawRequestMessage)�
web_logger)� StreamReader)�Handler�
Middleware)�NotAppKeyWarning)� AccessLogger)�_fix_request_current_app)�RequestHandler)�Request)�StreamResponse)�AbstractRouteDef)�Server)�AbstractResource�
AbstractRoute�Domain�
MaskDomain�MatchedSubAppResource�PrefixedSubAppResource� SystemRoute�
UrlDispatcher)� Application� CleanupErrorr7 �_T�_U� _Resource)�bound�handler�apps)r7 .�returnc C s: |ddd� D ]}|j D ]
\}}tt|| d�| �} q q| S )z Apply middlewares to handler.N����r= )�_middlewares_handlersr r )r= r> �app�m�_� rF �:/usr/local/lib/python3.10/dist-packages/aiohttp/web_app.py�_build_middlewaresS s
�rH i )�maxsizec s� e Zd Zeg d��Zeddddddd�dejdee d e
e d
ee e
ef d ed eej d
eddfdd�Zded ddfdd�ZerPde
deddf� fdd� Zdedefdd�Zedee de fd d ��Z ede
defd d ��Z de e
ee f defd d �Z d�d d!�Z edee d"e ddfd#d$��Z ede
d"eddfd%d$��Z de e
ee f d"eddfd&d$�Z de e
ee f ddfd'd(�Z!defd)d*�Z"de#e e
ee f fd+d,�Z$defd-d.�Z%ed�dee d/ddee fd0d1��Z&edee d/e'de e e'f fd2d1��Z&ed�de
d/edefd3d1��Z&d�de e
ee f d/edefd4d1�Z&e(dejfd5d6��Z)d eej ddfd7d8�Z*e(defd9d:��Z+d�d;d<�Z,e(defd=d>��Z-d�d?d@�Z.e(defdAdB��Z/d�dDdE�Z0dFe
dCd de1fdGdH�Z2dIe3g e4f dCd de4fdJdK�Z5dLe
dCd de6fdMdN�Z7dOe
e8 de9e: fdPdQ�Z;e(de<fdRdS��Z=e(de>fdTdU��Z?e(de>fdVdW��Z@e(de>fdXdY��ZAe(d�d[d\��ZBe(de fd]d^��ZCe(deDfd_d`��ZEdeFda�d eej dbeeG dcedeHfddde�ZIdeFda�d eej dbeeG dcedeHfdfdg�ZJd�dhdi�ZKd�djdk�ZLd�dldm�ZMeNfdneOdoePdpeQdqeRdrdsdteeN deNfdudv�ZSde#eTe ef fdwdx�ZUdyeNdeVfdzd{�ZWd�d|d}�ZXde
fd~d�ZYdefd�d��ZZ� Z[S )�r7 )�logger�_debug�_router�_loop�
_handler_args� _middlewaresrB �_has_legacy_middlewares�_run_middlewares�_state�_frozen� _pre_frozen�_subapps�_on_response_prepare� _on_startup� _on_shutdown� _on_cleanup�_client_max_size� _cleanup_ctxNrF i .)rJ �router� middlewares� handler_args�client_max_size�loop�debugrJ r\ r] r^ r_ r` ra r? c C s |d u rt � }ntjdtdd� t|t�sJ |��|d ur%tjdtdd� |dur1tjdtdd� || _|| _|| _|| _ || _
t |�| _ d | _
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 deprecatedTF) r6 �warnings�warn�DeprecationWarning�
isinstancer rK rL rM rN rJ r rO rB rQ rP rR rS rT rU r rV rW rX rY �CleanupContextr[ �appendrZ )�selfrJ r\ r] r^ r_ r` ra rF rF rG �__init__y sF ���
zApplication.__init__�clsc C s t jd�| j�tdd� d S )Nz8Inheritance class {} from web.Application is discouraged� rc )re rf �format�__name__rg )rm rF rF rG �__init_subclass__� s
�z Application.__init_subclass__�name�valc s2 || j vrtjd�|�tdd� t� �||� d S )Nz:Setting custom web.Application.{} attribute is discouragedrb rc )�ATTRSre rf ro rg �super� __setattr__)rk rr rs �� __class__rF rG rv � s
�zApplication.__setattr__�otherc C s | |u S �NrF )rk ry rF rF rG �__eq__� � zApplication.__eq__�keyc C � d S rz rF �rk r} rF rF rG � __getitem__� � zApplication.__getitem__c C r~ rz rF r rF rF rG r� � r� c C s
| j | S rz )rR r rF rF rG r� � �
c C s | j r
tjdtdd� d S d S )Nz=Changing state of started or joined application is deprecatedrn rc )rS re rf rg �rk rF rF rG �
_check_frozen� s
��zApplication._check_frozen�valuec C r~ rz rF �rk r} r� rF rF rG � __setitem__� r� zApplication.__setitem__c C r~ rz rF r� rF rF rG r� � r� c C s0 | � � t|t�stjdtdd� || j|< d S )Nz�It is recommended to use web.AppKey instances for keys.
https://docs.aiohttp.org/en/stable/web_advanced.html#application-s-configrb )�categoryrd )r� rh r! re rf r' rR r� rF rF rG r� � s
�c C s | � � | j|= d S rz )r� rR r rF rF rG � __delitem__� s zApplication.__delitem__c C �
t | j�S rz )�lenrR r� rF rF rG �__len__� r� zApplication.__len__c C r� rz )�iterrR r� rF rF rG �__iter__� r� zApplication.__iter__c C s t | �S rz ��idr� rF rF rG �__hash__� r| zApplication.__hash__�defaultc C r~ rz rF �rk r} r� rF rF rG �get� r� zApplication.getc C r~ rz rF r� rF rF rG r� � r� c C r~ rz rF r� rF rF rG r� r� c C s | j �||�S rz )rR r� r� rF rF rG r� s c C s t jdtdd� ttj| j�S )Nzloop property is deprecatedrb rc )re rf rg r �asyncio�AbstractEventLooprM r� rF rF rG r` s zApplication.loopc C s` |d u rt �� }| jd ur| j|urtd��|| _| jdu r#|�� | _| jD ]}|�|� q&d S )Nz8web.Application instance initialized with different loop.)r� �get_event_looprM � RuntimeErrorrK � get_debugrU � _set_loop)rk r` �subapprF rF rG r� s �
�zApplication._set_loopc C � | j S rz )rT r� rF rF rG �
pre_frozen! � zApplication.pre_frozenc C s� | j rd S d| _ | j�� | j�� | j�� | j�� | j�� | j�� | j�� t | �
� �| _ t dd� | j D ��| _
| jrBdnd| _| jD ]
}|�� | jpS|j| _qHd S )NTc s s � | ]\}}| V qd S rz rF )�.0rE � new_stylerF rF rG � <genexpr>2 s �
�z)Application.pre_freeze.<locals>.<genexpr>F)rT rO �freezerL rV r[ rW rX rY �tuple�_prepare_middlewarerB �anyrP r] rQ rU �
pre_freeze�rk r� rF rF rG r� % s&
�
�zApplication.pre_freezec C r� rz )rS r� rF rF rG �frozenA r� zApplication.frozenc C s0 | j rd S | �� d| _ | jD ]}|�� qd S �NT)rS r� rU r� r� rF rF rG r� E s
�zApplication.freezec C s t jdtdd� | jS )Nz debug property is deprecatedrb rc )re rf rg rK r� rF rF rG ra N s zApplication.debugr� c s4 dt dd f� �fdd� }|d� |d� |d� d S )N�signamer? c s2 t �| �� d�� fdd� }t �| �}|�|� d S )NrC r7 r? c � s ��� � �I d H d S rz )�send)rC )r� �subsigrF rG r= W s �zEApplication._reg_subapp_signals.<locals>.reg_handler.<locals>.handler)rC r7 r? N)�getattrrj )r� r= �appsigr� )r� rG � reg_handlerT s
z4Application._reg_subapp_signals.<locals>.reg_handler�
on_startup� on_shutdown�
on_cleanup)�str)rk r� r� rF r� rG �_reg_subapp_signalsS s z Application._reg_subapp_signals�prefixc C s@ t |t�s td��|�d�}|std��tt||�}| �||�S )NzPrefix must be str�/zPrefix cannot be empty)rh r� � TypeError�rstrip�
ValueErrorr r4 � _add_subapp)rk r� r� �factoryrF rF rG �
add_subappa s
zApplication.add_subapp�resource_factoryc C sf | j rtd��|j rtd��|� }| j�|� | �|� | j�|� |�� | jd ur1|� | j� |S )Nz0Cannot add sub application to frozen applicationz Cannot add frozen application)
r� r� r\ �register_resourcer� rU rj r� rM r� )rk r� r� �resourcerF rF rG r� j s
zApplication._add_subapp�domainc C sD t |t�s td��d|v rt|�}nt|�}tt||�}| �||�S )NzDomain must be str�*)rh r� r� r2 r1 r r3 r� )rk r� r� �ruler� rF rF rG �
add_domainz s
zApplication.add_domain�routesc C s | j �|�S rz )r\ �
add_routes)rk r� rF rF rG r� � s zApplication.add_routesc C r� rz )rV r� rF rF rG �on_response_prepare� r� z Application.on_response_preparec C r� rz )rW r� rF rF rG r� � r� zApplication.on_startupc C r� rz )rX r� rF rF rG r� � r� zApplication.on_shutdownc C r� rz )rY r� rF rF rG r� � r� zApplication.on_cleanupri c C r� rz )r[ r� rF rF rG � cleanup_ctx� r� zApplication.cleanup_ctxc C r� rz )rL r� rF rF rG r\ � r� zApplication.routerc C r� rz )rO r� rF rF rG r] � r� zApplication.middlewares�r` �access_log_classr� �kwargsc K sz t |t�s td�|���| �|� | �� | j|d< ||d< | jr/| j�� D ]\}}|||< q&t | j
f| j | j d�|��S )NzMaccess_log_class must be subclass of aiohttp.abc.AbstractAccessLogger, got {}ra r� )�request_factoryr` )
�
issubclassr r� ro r� r� rK rN �itemsr. �_handle�
_make_requestrM )rk r` r� r� �k�vrF rF rG �
_make_handler� s(
�
���zApplication._make_handlerc K s& t jdtdd� | jd||d�|��S )NzFApplication.make_handler(...) is deprecated, use AppRunner API insteadrb rc r� rF )re rf rg r� )rk r` r� r� rF rF rG � make_handler� s ���zApplication.make_handlerc � � �| j �| �I dH dS )zmCauses on_startup signal
Should be called in the event loop along with the request handler.
N)r� r� r� rF rF rG �startup� � �zApplication.startupc � r� )zMCauses on_shutdown signal
Should be called before cleanup()
N)r� r� r� rF rF rG �shutdown� r� zApplication.shutdownc � s6 �| j jr| j �| �I dH dS | j�| �I dH dS )zLCauses on_cleanup signal
Should be called after shutdown()
N)r� r� r� r[ rY r� rF rF rG �cleanup� s �zApplication.cleanup�message�payload�protocol�writer�taskzasyncio.Task[None]�_clsc C s, t r | jd us J �||||||| j| jd�S )N)r_ )r rM rZ )rk r� r� r� r� r� r� rF rF rG r� � s �zApplication._make_requestc c sb � t | j�D ]!}t|dd �dkr|dfV qtjd|�d�tdd� |dfV qt| �dfV d S ) N�__middleware_version__r Tzold-style middleware "z" deprecated, see #2252rb rc F)�reversedrO r� re rf rg r) )rk rD rF rF rG r� s �
� z Application._prepare_middleware�requestc
� s �t �� }|�� }| j�|�I d H }|r t|t�s td�|���|� | � |�
� ||_ |j �
tj�rI|�|�I d H }|j�� I d H |d urI|S |j}| jr�| js_t|jt�s_t||j�}n'|jd d d� D ] }|jD ]\}} | r|tt ||d�|�}ql|||�I d H }qlqg||�I d H S )Nz9match_info should be AbstractMatchInfo instance, not {!r}r@ rA ) r� r� r� rL �resolverh r r� ro �add_appr� � _match_info�headersr� r �EXPECT�expect_handlerr� �drainr= rQ rP �router5 �_cached_build_middlewarer> rB r r )
rk r� r` ra �
match_info�respr= rC rD r� rF rF rG r� sB �
�
� ��zApplication._handlec C s | S )zgunicorn compatibilityrF r� rF rF rG �__call__; s zApplication.__call__c C s dt | �d�d�S )Nz<Application 0x�x�>r� r� rF rF rG �__repr__? s zApplication.__repr__c C s dS r� rF r� rF rF rG �__bool__B r� zApplication.__bool__�r? N).rz )r� r7 r? N)r? ri )r? r7 )\rp �
__module__� __qualname__� frozensetrt r# �logging�Loggerr r6 r r& r r� r �intr� r� rl r rq r rv �object�boolr{ r r! r9 r� r r� r� r� r� r r� r� r� r: �propertyr` r� r� r� r� r� ra r� r4 r� r r; r� r3 r� r- r
r0 r� �_RespPrepareSignalr� �
_AppSignalr� r� r� r� r\ � _Middlewaresr] r( r r. r� r� r� r� r� r+ r" r$ r* r r� r r� r, r� r� r� r� �
__classcell__rF rF rw rG r7 ` s �������� �
�8
" "$$
��
�
����
�!����
�
�������
�
,c @ s" e Zd Zedee fdd��ZdS )r8 r? c C s t tt | jd �S )Nr )r r
�
BaseException�argsr� rF rF rG �
exceptionsG s zCleanupError.exceptionsN)rp r� r� r� r
r r rF rF rF rG r8 F s r8 c sB e Zd Zd
� fdd� Zdeddfdd�Zdeddfdd �Z� ZS ) ri r? Nc s t � �� g | _d S rz )ru rl �_exitsr� rw rF rG rl S s
zCleanupContext.__init__rC c � s6 �| D ]}||�� � }|�� I d H | j�|� qd S rz )� __aiter__� __anext__r rj )rk rC �cb�itrF rF rG rW W s � �zCleanupContext._on_startupc � s� �g }t | j�D ]8}z |�� I d H W n" ty Y q ttjfy5 } z |�|� W Y d }~qd }~ww |�t|�d��� q|rRt |�dkrM|d �t
d|��d S )Nz has more than one 'yield'r r z Multiple errors on cleanup stage) r� r r �StopAsyncIteration� Exceptionr� �CancelledErrorrj r� r� r8 )rk rC �errorsr �excrF rF rG rY ] s" � ��
�zCleanupContext._on_cleanupr� )rp r� r� rl r7 rW rY r� rF rF rw rG ri R s ri )]r� r� re � functoolsr r r �typingr r r r r r
r r r
r r r r r r r r r r � aiosignalr �
frozenlistr � r �abcr r r r �helpersr r! � http_parserr" �logr# �streamsr$ �typedefsr% r& �web_exceptionsr' �web_logr( �web_middlewaresr) � web_protocolr* � web_requestr+ � web_responser, � web_routedefr- �
web_serverr. �web_urldispatcherr/ r0 r1 r2 r3 r4 r5 r6 �__all__r� r� r� r� �_MiddlewaresHandlers�_Subappsr9 r: r; rH r� r� r7 r� r8 �_CleanupContextBaseri rF rF rF rG �<module> sn T (
��
�
$ i