| Server IP : 192.158.238.246 / Your IP : 3.128.31.200 Web Server : LiteSpeed System : Linux uniform.iwebfusion.net 4.18.0-553.27.1.lve.1.el8.x86_64 #1 SMP Wed Nov 20 15:58:00 UTC 2024 x86_64 User : jenniferflocom ( 1321) PHP Version : 8.1.32 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /opt/alt/python38/lib64/python3.8/site-packages/aiohttp/__pycache__/ |
Upload File : |
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� 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 �AssertionErrorr2 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 sP � � �
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 )rX rC rC rV �__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 rY rP �super� __setattr__)rU r\ r] �� __class__rC rV r` � s
��zApplication.__setattr__)�otherrJ c C s | |kS �NrC )rU rc rC rC rV �__eq__� s zApplication.__eq__)�keyrJ c C s
| j | S rd )r9 �rU rf rC rC rV � __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 �rU rC rC rV �
_check_frozen� s �zApplication._check_frozen)rf �valuerJ c C s | � � || j|< d S rd �rl r9 )rU rf rm rC rC rV � __setitem__� s zApplication.__setitem__c C s | � � | j|= d S rd rn rg rC rC rV � __delitem__� s zApplication.__delitem__c C s
t | j�S rd )�lenr9 rk rC rC rV �__len__� s zApplication.__len__c C s
t | j�S rd )�iterr9 rk rC rC rV �__iter__� s zApplication.__iter__c C s t jdtdd� ttj| j�S )Nzloop property is deprecatedrK rL )rN rO rP r �asyncio�AbstractEventLoopr4 rk rC rC rV 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.)ru �get_event_loopr4 � RuntimeErrorr2 � get_debugr< � _set_loop)rU rH �subapprC rC rV rz � s �
zApplication._set_loopc C s | j S rd )r; rk rC rC rV �
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�rU r{ rC rC rV r� � s
zApplication.pre_freezec C s | j S rd )r: rk rC rC rV �frozen s zApplication.frozenc C s0 | j r
d S | �� d| _ | jD ] }|�� q d S �NT)r: r� r< r} r� rC rC rV r}
s
zApplication.freezec C s t jdtdd� | jS )Nz debug property is deprecatedrK rL )rN rO rP r2 rk rC rC rV rI s zApplication.debug)r{ 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 rd )�send)r� )r{ �subsigrC rV �handler s zEApplication._reg_subapp_signals.<locals>.reg_handler.<locals>.handler)�getattrrT )r� r� Zappsigr� )r� rV � reg_handler s
z4Application._reg_subapp_signals.<locals>.reg_handler�
on_startup� on_shutdown�
on_cleanup)�str)rU r{ r� rC r� rV �_reg_subapp_signals s z Application._reg_subapp_signals)�prefixr{ rJ 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� r{ �factoryrC rC rV �
add_subapp) s
zApplication.add_subapp)�resource_factoryr{ 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� rx rD Zregister_resourcer� r< rT r� r4 rz )rU r� r{ �resourcerC rC rV r� 2 s
zApplication._add_subapp)�domainr{ rJ 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� r{ Zruler� rC rC rV �
add_domainB s
zApplication.add_domain)�routesrJ c C s | j �|�S rd )rD �
add_routes)rU r� rC rC rV r� L s zApplication.add_routesc C s | j S rd )r= rk rC rC rV �on_response_prepareO s z Application.on_response_preparec C s | j S rd )r> rk rC rC rV r� S s zApplication.on_startupc C s | j S rd )r? rk rC rC rV r� W s zApplication.on_shutdownc C s | j S rd )r@ rk rC rC rV r� [ s zApplication.on_cleanuprS c C s | j S rd )rB rk rC rC rV � cleanup_ctx_ s zApplication.cleanup_ctxc C s | j S rd )r3 rk rC rC rV rD c s zApplication.routerc C s | j S rd )r6 rk rC rC rV 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� rY rz r} r2 r5 �itemsr' �_handle�
_make_requestr4 )rU rH r� r� �k�vrC rC rV �
_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� )rU rH r� r� rC rC 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� rk rC rC rV �startup� s zApplication.startupc � s | j �| �I dH dS )zMCauses on_shutdown signal
Should be called before cleanup()
N)r� r� rk rC rC rV �shutdown� s zApplication.shutdownc � s | j �| �I dH dS )zLCauses on_cleanup signal
Should be called after shutdown()
N)r� r� rk rC rC rV �cleanup� s zApplication.cleanupzasyncio.Task[None])�message�payload�protocol�writer�task�_clsrJ c C s ||||||| j | jd�S )N)rG )r4 rA )rU r� r� r� r� r� r� rC rC rV 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 rY rP r" )rU �mrC rC rV 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� )ru rw ry r3 �resolverQ r r� rY Zadd_appr} Z _match_info�headers�getr ZEXPECTZexpect_handlerr� Zdrainr� r8 Zappsr7 r r ) rU r� rH rI Z
match_infoZrespZexpectr� r� r� Z new_stylerC rC rV r� � s>
��
�zApplication._handlec C s | S )zgunicorn compatibilityrC rk rC rC rV �__call__� s zApplication.__call__c C s d� t| ��S )Nz<Application 0x{:x}>)rY �idrk rC rC rV �__repr__� s zApplication.__repr__c C s dS r� rC rk rC rC rV �__bool__� s zApplication.__bool__)SrZ �
__module__� __qualname__� frozensetr^ r �logging�Loggerr r. r
� _Middlewarer
r� r �intru rv rW r r[ r r` �object�boolre rh rl ro rp rr r rt �propertyrH rz r| 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 ra rV r/ P s� ���� 7
�
�� !�� �� &c @ s" e Zd Zeee d�dd��ZdS )r0 ri c C s
| j d S )Nr )�argsrk rC rC rV �
exceptions s zCleanupError.exceptionsN)rZ r� r� r� r �
BaseExceptionr� rC rC rC rV r0 s r0 c sB e Zd Zdd�� fdd� Zedd�dd�Zedd�dd �Z� ZS )
rS Nri c s t � �� g | _d S rd )r_ rW �_exitsrk ra rC rV rW s
zCleanupContext.__init__r� c � s4 | D ]*}||�� � }|�� I d H | j�|� qd S rd )� __aiter__� __anext__r� rT )rU r� �cb�itrC rC rV 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� ExceptionrT rx rq r0 )rU r� �errorsr� �excrC rC rV r@ s
zCleanupContext._on_cleanup)rZ r� r� rW r/ r> r@ r� rC rC ra rV rS s rS )Pru 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/ rx r0 Z_CleanupContextBaserS rC rC rC rV �<module> sb L $
��
5