File: //home/arjun/projects/env/lib/python3.10/site-packages/aiohttp/__pycache__/web_app.cpython-310.pyc
o
+we�G � @ sj d dl Z d dlZd dlZd dlmZmZ d dlmZmZm Z m
Z
m Z m Z m
Z
mZmZmZmZmZmZmZmZmZmZmZmZ d dlmZ 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.m/Z/ ddl0m1Z1 ddl2m3Z3 ddl4m5Z5 ddl6m7Z7 ddl8m9Z9 ddl:m;Z; ddl<m=Z= ddl>m?Z? ddl@mAZAmBZBmCZCmDZDmEZEmFZFmGZG dZHer�ee dge
d f ZIee e9e;ge
d f ZJe e/ ZKeeee/eLf ZMed ZNn eZIeZJe ZKee ZMeZNed�ZOed�ZPG dd� deeeQe'e f ef �ZRG d d � d eS�ZTe�r)e e eRge d f ZUne ZUG d d � d eU�ZVdS ) � N)�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)�
Middleware)�NotAppKeyWarning)� AccessLogger)�_fix_request_current_app)�RequestHandler)�Request)�StreamResponse)�AbstractRouteDef)�Server)�AbstractResource�
AbstractRoute�Domain�
MaskDomain�MatchedSubAppResource�PrefixedSubAppResource�
UrlDispatcher)� Application� CleanupErrorr4 �_T�_Uc 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$ed�dee d-ddee fd.d/��Z%edee d-e&de e e&f fd0d/��Z%ed�de
d-edefd1d/��Z%d�de e
ee f d-edefd2d/�Z%e'dejfd3d4��Z(d eej ddfd5d6�Z)e'defd7d8��Z*d�d9d:�Z+e'defd;d<��Z,d�d=d>�Z-e'defd?d@��Z.d�dBdC�Z/dDe
dAd de0fdEdF�Z1dGe2g e0f dAd de0fdHdI�Z3dJe
dAd de0fdKdL�Z4dMe
e5 de6e7 fdNdO�Z8e'de9fdPdQ��Z:e'de;fdRdS��Z<e'de;fdTdU��Z=e'de;fdVdW��Z>e'd�dYdZ��Z?e'de fd[d\��Z@e'deAfd]d^��ZBdeCd_�d eej d`eeD daedeEfdbdc�ZFdeCd_�d eej d`eeD daedeEfddde�ZGd�dfdg�ZHd�dhdi�ZId�djdk�ZJeKfdleLdmeMdneNdoeOdpdqdreeK deKfdsdt�ZPde#eQe ef fdudv�ZRdweKdeSfdxdy�ZTd�dzd{�ZUde
fd|d}�ZVdefd~d�ZW� ZXS )�r4 )�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 .)r8 �router� middlewares� handler_args�client_max_size�loop�debugr8 rK rL rM rN rO rP �returnc C s |d u rt � }ntjdtdd� t|t�sJ |��|d ur%tjdtdd� |dur1tjdtdd� || _|| _|| _|| _ || _
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) r3 �warnings�warn�DeprecationWarning�
isinstancer r9 r: r; r< r8 r r= r> r? r@ rA rB rC r rD rE rF rG �CleanupContextrI �appendrH )�selfr8 rK rL rM rN rO rP rJ rJ �H/home/arjun/projects/env/lib/python3.10/site-packages/aiohttp/web_app.py�__init__i sD ���
zApplication.__init__�clsc C s t jd�| j�tdd� d S )Nz8Inheritance class {} from web.Application is discouraged� rS )rU rV �format�__name__rW )r^ rJ rJ r\ �__init_subclass__� s
�z Application.__init_subclass__�name�valc s2 || j vrtjd�|�tdd� t� �||� d S )Nz:Setting custom web.Application.{} attribute is discouragedrR rS )�ATTRSrU rV r` rW �super� __setattr__)r[ rc rd �� __class__rJ r\ rg � s
�zApplication.__setattr__�otherc C s | |u S �NrJ )r[ rj rJ rJ r\ �__eq__� s zApplication.__eq__�keyc C � d S rk rJ �r[ rm rJ rJ r\ � __getitem__� � zApplication.__getitem__c C rn rk rJ ro rJ rJ r\ rp � rq c C s
| j | S rk )r@ ro rJ rJ r\ rp � �
c C s | j r
tjdtdd� d S d S )Nz=Changing state of started or joined application is deprecatedr_ rS )rA rU rV rW �r[ rJ rJ r\ �
_check_frozen� s
��zApplication._check_frozen�valuec C rn rk rJ �r[ rm ru rJ rJ r\ � __setitem__� rq zApplication.__setitem__c C rn rk rJ rv rJ rJ r\ rw � rq 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-configrR )�categoryrT )rt rX r rU rV r% r@ rv rJ rJ r\ rw � s
�c C s | � � | j|= d S rk )rt r@ ro rJ rJ r\ � __delitem__� s zApplication.__delitem__c C �
t | j�S rk )�lenr@ rs rJ rJ r\ �__len__� rr zApplication.__len__c C rz rk )�iterr@ rs rJ rJ r\ �__iter__� rr zApplication.__iter__�defaultc C rn rk rJ �r[ rm r rJ rJ r\ �get� rq zApplication.getc C rn rk rJ r� rJ rJ r\ r� � rq c C rn rk rJ r� rJ rJ r\ r� � rq c C s | j �||�S rk )r@ r� r� rJ rJ r\ r� � s c C s t jdtdd� ttj| j�S )Nzloop property is deprecatedrR rS )rU rV rW r �asyncio�AbstractEventLoopr; rs rJ rJ r\ rO � 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_loopr; � RuntimeErrorr9 � get_debugrC � _set_loop)r[ rO �subapprJ rJ r\ r� s �
�zApplication._set_loopc C � | j S rk )rB rs rJ rJ r\ �
pre_frozen � zApplication.pre_frozenc C s� | j rd S d| _ | j�� | j�� | j�� | j�� | j�� | j�� | j�� t | �
� �| _ | j r7dnd| _
| jD ]
}|�� | j
pH|j
| _
q=d S )NTF)rB r= �freezer: rD rI rE rF rG �tuple�_prepare_middlewarer> rL r? rC �
pre_freeze�r[ r� rJ rJ r\ r� s
�zApplication.pre_freezec C r� rk )rA rs rJ rJ r\ �frozen1 r� zApplication.frozenc C s0 | j rd S | �� d| _ | jD ]}|�� qd S �NT)rA r� rC r� r� rJ rJ r\ r� 5 s
�zApplication.freezec C s t jdtdd� | jS )Nz debug property is deprecatedrR rS )rU rV rW r9 rs rJ rJ r\ rP > s zApplication.debugr� c s4 dt dd f� �fdd� }|d� |d� |d� d S )N�signamerQ c s2 t �| �� d�� fdd� }t �| �}|�|� d S )N�appr4 rQ c � s ��� � �I d H d S rk )�send)r� )r� �subsigrJ r\ �handlerG s �zEApplication._reg_subapp_signals.<locals>.reg_handler.<locals>.handler)r� r4 rQ N)�getattrrZ )r� r� �appsigr� )r� r\ � reg_handlerD s
z4Application._reg_subapp_signals.<locals>.reg_handler�
on_startup� on_shutdown�
on_cleanup)�str)r[ r� r� rJ r� r\ �_reg_subapp_signalsC 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)rX r� � TypeError�rstrip�
ValueErrorr r2 � _add_subapp)r[ r� r� �factoryrJ rJ r\ �
add_subappQ 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� rK �register_resourcer� rC rZ r� r; r� )r[ r� r� �resourcerJ rJ r\ r� Z s
zApplication._add_subapp�domainc C sD t |t�s td��d|v rt|�}nt|�}tt||�}| �||�S )NzDomain must be str�*)rX r� r� r0 r/ r r1 r� )r[ r� r� �ruler� rJ rJ r\ �
add_domainj s
zApplication.add_domain�routesc C s | j �|�S rk )rK �
add_routes)r[ r� rJ rJ r\ r� t s zApplication.add_routesc C r� rk )rD rs rJ rJ r\ �on_response_preparew r� z Application.on_response_preparec C r� rk )rE rs rJ rJ r\ r� { r� zApplication.on_startupc C r� rk )rF rs rJ rJ r\ r� r� zApplication.on_shutdownc C r� rk )rG rs rJ rJ r\ r� � r� zApplication.on_cleanuprY c C r� rk )rI rs rJ rJ r\ � cleanup_ctx� r� zApplication.cleanup_ctxc C r� rk )r: rs rJ rJ r\ rK � r� zApplication.routerc C r� rk )r= rs rJ rJ r\ rL � r� zApplication.middlewares�rO �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 {}rP r� )�request_factoryrO )
�
issubclassr r� r` r� r� r9 r< �itemsr, �_handle�
_make_requestr; )r[ rO r� r� �k�vrJ rJ r\ �
_make_handler� s(
�
���zApplication._make_handlerc K s& t jdtdd� | jd||d�|��S )NzFApplication.make_handler(...) is deprecated, use AppRunner API insteadrR rS r� rJ )rU rV rW r� )r[ rO r� r� rJ rJ r\ � 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� rs rJ rJ r\ �startup� � �zApplication.startupc � r� )zMCauses on_shutdown signal
Should be called before cleanup()
N)r� r� rs rJ rJ r\ �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� rI rG rs rJ rJ r\ �cleanup� s �zApplication.cleanup�message�payload�protocol�writer�taskzasyncio.Task[None]�_clsc C s ||||||| j | jd�S )N)rN )r; rH )r[ r� r� r� r� r� r� rJ rJ r\ r� � s �zApplication._make_requestc c s` � t | j�D ] }t|dd �dkr|dfV qtjd�|�tdd� |dfV qt| �dfV d S )N�__middleware_version__r Tz1old-style middleware "{!r}" deprecated, see #2252rR rS F)�reversedr= r� rU rV r` rW r' )r[ �mrJ rJ r\ r� � s � � z Application._prepare_middleware�requestc � s �t �� }|�� }| j�|�I d H }|r t|t�s td�|���|� | � |�
� d }||_ |j �
tj�}|rG|�|�I d H }|j�� I d H |d u r|j}| jrx|jd d d� D ] }|jD ]\} }
|
rntt| |d�|�}q^| ||�I d H }q^qY||�I d H }|S )Nz9match_info should be AbstractMatchInfo instance, not {!r}���)r� )r� r� r� r: �resolverX r r� r` �add_appr� � _match_info�headersr� r �EXPECT�expect_handlerr� �drainr� r? �appsr> r r ) r[ r� rO rP �
match_info�resp�expectr� r� r� � new_stylerJ rJ r\ r� � s> �
�
��zApplication._handlec C s | S )zgunicorn compatibilityrJ rs rJ rJ r\ �__call__# rq zApplication.__call__c C s dt | �d�d�S )Nz<Application 0x�x�>)�idrs rJ rJ r\ �__repr__' s zApplication.__repr__c C s dS r� rJ rs rJ rJ r\ �__bool__* s zApplication.__bool__�rQ N).rk )r� r4 rQ N)rQ rY )rQ r4 )Yra �
__module__� __qualname__� frozensetre r" �logging�Loggerr r3 r
r$ r
r� r �intr� r� r] r rb r rg �object�boolrl r r r6 rp r rt rw ry r| r r~ r� r7 �propertyrO r� r� r� r� r� rP r� r- r� r r� r� r+ r r. r� �_RespPrepareSignalr� �
_AppSignalr� r� r� r� rK � _MiddlewaresrL r& r r, r� r� r� r� r� r) r! r# r( r r� r r� r* r� r� r� r� �
__classcell__rJ rJ rh r\ r4 Q s �������� �
�7
" "$$
��
�
����
�!����
�
�������
�
&c @ s" e Zd Zedee fdd��ZdS )r5 rQ c C s t tt | jd �S )Nr )r r �
BaseException�argsrs rJ rJ r\ �
exceptions/ s zCleanupError.exceptionsN)ra r� r� r� r r� r� rJ rJ rJ r\ r5 . s r5 c sB e Zd Zd
� fdd� Zdeddfdd�Zdeddfdd �Z� ZS ) rY rQ Nc s t � �� g | _d S rk )rf r] �_exitsrs rh rJ r\ r] ; s
zCleanupContext.__init__r� c � s6 �| D ]}||�� � }|�� I d H | j�|� qd S rk )� __aiter__� __anext__r� rZ )r[ r� �cb�itrJ rJ r\ rE ? s � �zCleanupContext._on_startupc � s� �g }t | j�D ]5}z |�� I d H W n ty Y q ty2 } z |�|� W Y d }~qd }~ww |�t|�d��� q|rOt|�dkrJ|d �td|��d S )Nz has more than one 'yield'r r z Multiple errors on cleanup stage) r� r� r� �StopAsyncIteration� ExceptionrZ r� r{ r5 )r[ r� �errorsr� �excrJ rJ r\ rG E s" � ��
�zCleanupContext._on_cleanupr� )ra r� r� r] r4 rE rG r� rJ rJ rh r\ rY : s rY )Wr� r� rU � functoolsr 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$ �web_exceptionsr% �web_logr& �web_middlewaresr' � web_protocolr( � web_requestr) � web_responser* � web_routedefr+ �
web_serverr, �web_urldispatcherr- r. r/ r0 r1 r2 r3 �__all__r� r� r� r� �_MiddlewaresHandlers�_Subappsr6 r7 r� r4 r� r5 �_CleanupContextBaserY rJ rJ rJ r\ �<module> s\ T $
$ `