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@ dZAere(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 deLZMerZe e eKge d f ZNne ZNG dd deNZOdS ) N)partialupdate_wrapper)
TYPE_CHECKINGAny
AsyncIterator AwaitableCallableDictIterableIteratorListMappingMutableMappingOptionalSequenceTupleTypeUnioncast )hdrs)AbstractAccessLoggerAbstractMatchInfoAbstractRouterAbstractStreamWriter)
FrozenList)DEBUG)RawRequestMessage)
web_logger)Signal) StreamReader) AccessLogger)_fix_request_current_app)RequestHandler)Request)StreamResponse)AbstractRouteDef)Server)AbstractResource
AbstractRouteDomain
MaskDomainMatchedSubAppResourcePrefixedSubAppResource
UrlDispatcher) Application CleanupErrorr/ c sp e Zd Zeddddddddd d
d d d
dddddgZedddddddejee e
e ee e
ef eeej eddddZed ddd d Zere
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/d0Z e e
d'd1d2Z e!ejd'd3d4Z"eej dd5d6d7Z#e!ed'd8d9Z$dd'd:d;Z%e!ed'd<d=Z&dd'd>d?Z'e!ed'd@dAZ(d ddBdCdDZ)e
d e*dEdFdGZ+e,g e*f d e*dHdIdJZ-e
d e*dKdLdMZ.e
e/ e0e1 dNdOdPZ2e!e3d'dQdRZ4e!e5d'dSdTZ6e!e5d'dUdVZ7e!e5d'dWdXZ8e!dYd'dZd[Z9e!e d'd\d]Z:e!e;d'd^d_Z<de=d`eej ee> ee?dadbdcZ@de=d`eej ee> ee?dadddeZAdd'dfdgZBdd'dhdiZCdd'djdkZDeEfeFeGeHeIdleeE eEdmdndoZJe eKe ef d'dpdqZLeEeMdrdsdtZNd d'dudvZOe
d'dwdxZPed'dydzZQ 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_argsclient_max_sizeloopdebug)r1 rD rE rF rG rH rI returnc C s |d krt }ntjdtdd t|ts2t||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. warningswarnDeprecationWarning
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| jtdd 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__)namevalrJ 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 | jS rd )lenr9 rk rC rC rV __len__ s zApplication.__len__c C s
t | jS rd )iterr9 rk rC rC rV __iter__ s zApplication.__iter__c C s t jdtdd ttj| jS )Nzloop property is deprecatedrK rL )rN rO rP r asyncioAbstractEventLoopr4 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_freezerU 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 |tstd|d}|s(tdtt||}| ||S )NzPrefix must be str/zPrefix cannot be empty)rQ r TypeErrorrstrip
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 |tstdnd|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.middlewaresrH access_log_class)rH r kwargsrJ c K sz t |tstd|| | | | 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 kvrC 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])messagepayloadprotocolwritertask_clsrJ c C s ||||||| j | jdS )N)rG )r4 rA )rU r r r r r r rC rC rV r s zApplication._make_requestc c s^ t | jD ]@}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|ts>td|| | |
d }||_ |j
tj}|r||I d H }|j I d H |d kr|j}| jr|jd d d D ]<}|jD ]0\} }
|
rtt| |d|}q| ||I d H }qq||I d H }|S )Nz9match_info should be AbstractMatchInfo instance, not {!r})r )ru rw ry r3 ZresolverQ r r rY Zadd_appr} Z _match_infoZheadersgetr ZEXPECTZexpect_handlerr Zdrainr r8 Zappsr7 r r ) rU r rH rI Z
match_infoZrespexpectr 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 loggingZLoggerr r. r
_Middlewarer
r r intru rv rW r r[ r r` objectboolre 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 dddZdS )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 ZeddddZedddd 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 cbitrC rC rV r> s zCleanupContext._on_startupc s g }t | jD ]j}z| I d H W n> tk
r8 Y q tk
rb } z|| W 5 d }~X Y qX |t|d q|rt|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