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 |d k r8tjdtdd |dk rPtjdtdd || _|| _|| _|| _|| _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. warningswarnDeprecationWarningr2 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 sN
zApplication.__init__)clsrJ c C s t jd| jtdd d S )Nz8Inheritance class {} from web.Application is discouragedrK rL )rN rO format__name__rP )rV rC rC rT __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 rW rP super __setattr__)rS rZ r[ __class__rC rT r^ s
zApplication.__setattr__)otherrJ c C s | |kS NrC )rS ra rC rC rT __eq__ s zApplication.__eq__)keyrJ c C s
| j | S rb )r9 rS rd rC rC rT __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 rS rC rC rT
_check_frozen s zApplication._check_frozen)rd valuerJ c C s | || j|< d S rb rj r9 )rS rd rk rC rC rT __setitem__ s zApplication.__setitem__c C s | | j|= d S rb rl re rC rC rT __delitem__ s zApplication.__delitem__c C s
t | jS rb )lenr9 ri rC rC rT __len__ s zApplication.__len__c C s
t | jS rb )iterr9 ri rC rC rT __iter__ s zApplication.__iter__c C s t jdtdd ttj| jS )Nzloop property is deprecatedrK rL )rN rO rP r asyncioAbstractEventLoopr4 ri rC rC rT 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.)rs get_event_loopr4 RuntimeErrorr2 get_debugr< _set_loop)rS rH subapprC rC rT rx s
zApplication._set_loopc C s | j S rb )r; ri rC rC rT
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_freezerS ry rC rC rT r~ s
zApplication.pre_freezec C s | j S rb )r: ri rC rC rT frozen s zApplication.frozenc C s0 | j r
d S | d| _ | jD ] }| q d S NT)r: r~ r< r{ r rC rC rT r{
s
zApplication.freezec C s t jdtdd | jS )Nz debug property is deprecatedrK rL )rN rO rP r2 ri rC rC rT rI s zApplication.debug)ry 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 rb )send)r )ry subsigrC rT handler s zEApplication._reg_subapp_signals.<locals>.reg_handler.<locals>.handler)getattrrR )r r Zappsigr )r rT reg_handler s
z4Application._reg_subapp_signals.<locals>.reg_handler
on_startup on_shutdown
on_cleanup)str)rS ry r rC r rT _reg_subapp_signals s z Application._reg_subapp_signals)prefixry rJ c C s@ t |tstd|d}|s(tdtt||}| ||S )NzPrefix must be str/zPrefix cannot be empty)
isinstancer TypeErrorrstrip
ValueErrorr r- _add_subapp)rS r ry factoryrC rC rT
add_subapp) s
zApplication.add_subapp)resource_factoryry 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 rv rD Zregister_resourcer r< rR r~ r4 rx )rS r ry resourcerC rC rT r 2 s
zApplication._add_subapp)domainry rJ c C sF t |tstdnd|kr&t|}nt|}tt||}| ||S )NzDomain must be str*)r r r r+ r* r r, r )rS r ry Zruler rC rC rT
add_domainB s
zApplication.add_domain)routesrJ c C s | j |S rb )rD
add_routes)rS r rC rC rT r L s zApplication.add_routesc C s | j S rb )r= ri rC rC rT on_response_prepareO s z Application.on_response_preparec C s | j S rb )r> ri rC rC rT r S s zApplication.on_startupc C s | j S rb )r? ri rC rC rT r W s zApplication.on_shutdownc C s | j S rb )r@ ri rC rC rT r [ s zApplication.on_cleanuprQ c C s | j S rb )rB ri rC rC rT cleanup_ctx_ s zApplication.cleanup_ctxc C s | j S rb )r3 ri rC rC rT rD c s zApplication.routerc C s | j S rb )r6 ri rC rC rT 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 rW rx r{ r2 r5 itemsr' _handle
_make_requestr4 )rS rH r r kvrC rC rT
_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 )rS rH r r rC rC rT 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 ri rC rC rT startup s zApplication.startupc s | j | I dH dS )zMCauses on_shutdown signal
Should be called before cleanup()
N)r r ri rC rC rT shutdown s zApplication.shutdownc s | j | I dH dS )zLCauses on_cleanup signal
Should be called after shutdown()
N)r r ri rC rC rT cleanup s zApplication.cleanupzasyncio.Task[None])messagepayloadprotocolwritertask_clsrJ c C s ||||||| j | jdS )N)rG )r4 rA )rS r r r r r r rC rC rT 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 rW rP r" )rS mrC rC rT 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 )rs ru rw r3 Zresolver r r rW Zadd_appr{ Z _match_infoZheadersgetr ZEXPECTZexpect_handlerr Zdrainr r8 Zappsr7 r r ) rS r rH rI Z
match_infoZrespexpectr r r Z new_stylerC rC rT r s>
zApplication._handlec C s | S )zgunicorn compatibilityrC ri rC rC rT __call__ s zApplication.__call__c C s d t| S )Nz<Application 0x{:x}>)rW idri rC rC rT __repr__ s zApplication.__repr__c C s dS r rC ri rC rC rT __bool__ s zApplication.__bool__)SrX
__module__ __qualname__ frozensetr\ r loggingZLoggerr r. r
_Middlewarer
r r intrs rt rU r rY r r^ objectboolrc rf rj rm rn rp r rr propertyrH rx rz 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 r_ rT r/ P s 7
! &c @ s" e Zd Zeee dddZdS )r0 rg c C s
| j d S )Nr )argsri rC rC rT
exceptions s zCleanupError.exceptionsN)rX r r r r
BaseExceptionr rC rC rC rT r0 s r0 c sB e Zd Zdd fdd ZeddddZedddd Z ZS )
rQ Nrg c s t g | _d S rb )r] rU _exitsri r_ rC rT rU s
zCleanupContext.__init__r c s4 | D ]*}|| }| I d H | j| qd S rb ) __aiter__ __anext__r rR )rS r cbitrC rC rT 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 ExceptionrR rv ro r0 )rS r errorsr excrC rC rT r@ s
zCleanupContext._on_cleanup)rX r r rU r/ r> r@ r rC rC r_ rT rQ s rQ )Prs 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/ rv r0 Z_CleanupContextBaserQ rC rC rC rT <module> sb L $
5