Z' @ s d d l Z d d l Z d d l m Z d d l m Z d d l m Z d d l m Z m
Z
m Z d d l m
Z
d d l m Z d d l m Z d d
l m Z d d l m Z d d l m Z d d
l m Z d d l m Z d d l m Z m Z d Z Gd d d e Z d S) N)MutableMapping)partial )hdrs)AbstractAccessLoggerAbstractMatchInfoAbstractRouter)
FrozenList) AccessLogger)
web_logger)Signal)_fix_request_current_app)Request)StreamResponse)Server)PrefixedSubAppResource
UrlDispatcher Applicationc sA e Z d Z e d d d d d d d d d d
d d d
d d d g Z d e d d d f d d d d\ d d d d d d Z d d Z f d d Z d! d" Z d# d$ Z
d% d& Z d' d( Z d) d* Z
d+ d, Z d- d. Z e d/ d0 Z d1 d2 Z e d3 d4 Z d5 d6 Z e d7 d8 Z d9 d: Z d; d< Z e d= d> Z e d? d@ Z e dA dB Z e dC dD Z e dE dF Z e dG dH Z d d dI e dJ dK Z dL dM Z dN dO Z! dP dQ Z" e# dR dS Z$ dT dU Z% dV dW Z& dX dY Z' dZ d[ Z( S)]r logger_debug_router_loop
_handler_args _middlewares_middlewares_handlers_run_middlewares_state_frozen_subapps_on_response_prepare _on_startup _on_shutdown _on_cleanup_client_max_sizerouterN middlewares handler_argsclient_max_sizei loopdebug.c C s | d k r t } t | t s0 t | | d k rR t j d t d d | | _ | | _ | | _ | | _
| | _ t | | _
d | _ d | _ i | _ d | _ g | _ t | | _ t | | _ t | | _ t | | _ | | _ d S)Nzloop argument is deprecated
stacklevelr( F)r
isinstancer AssertionErrorwarningswarnDeprecationWarningr r r r r r r r r r r r r r r r! r" r# )selfr r$ r% r& r' r) r* r2 /web_app.py__init__ s, zApplication.__init__c C s& t j d j | j t d d d S)Nz8Inheritance class {} from web.Application is discouragedr+ r( )r. r/ format__name__r0 )clsr2 r2 r3 __init_subclass__A s z Application.__init_subclass__c sE | | j k r. t j d j | t d d t j | | d S)Nz:Setting custom web.Application.{} attribute is discouragedr+ r( )ATTRSr. r/ r5 r0 super __setattr__)r1 nameval) __class__r2 r3 r; G s zApplication.__setattr__c C s
| | k S)Nr2 )r1 otherr2 r2 r3 __eq__Q s zApplication.__eq__c C s | j | S)N)r )r1 keyr2 r2 r3 __getitem__T s zApplication.__getitem__c C s# | j r t j d t d d d S)Nz=Changing state of started or joined application is deprecatedr+ )r r. r/ r0 )r1 r2 r2 r3
_check_frozenW s zApplication._check_frozenc C s | j | | j | <d S)N)rD r )r1 rA valuer2 r2 r3 __setitem__^ s
zApplication.__setitem__c C s | j | j | =d S)N)rD r )r1 rA r2 r2 r3 __delitem__b s
zApplication.__delitem__c C s
t | j S)N)lenr )r1 r2 r2 r3 __len__f s zApplication.__len__c C s
t | j S)N)iterr )r1 r2 r2 r3 __iter__i s zApplication.__iter__c C s | j S)N)r )r1 r2 r2 r3 r) m s zApplication.loopc C s | d k r t j } | j d k rB | j | k rB t d | | _ | j d k ri | j | _ x | j D] } | j | qs Wd S)Nz8web.Application instance initialized with different loop.)asyncioZget_event_loopr RuntimeErrorr Z get_debugr _set_loop)r1 r) subappr2 r2 r3 rN q s zApplication._set_loopc C s | j S)N)r )r1 r2 r2 r3 frozen s zApplication.frozenc C s | j r
d Sd | _ | j j | j j | j j | j j | j j | j j t | j | _
| j r d n d | _ x0 | j
D]% } | j | j p | j | _ q Wd S)NTF)r r freezer r r r! r" tuple_prepare_middlewarer r% r r )r1 rO r2 r2 r3 rQ s
zApplication.freezec C s | j S)N)r )r1 r2 r2 r3 r* s zApplication.debugc s7 f d d } | d | d | d d S)Nc sD t | f d d } t | } | j | d S)Nc s j Id Hd S)N)send)app)rO subsigr2 r3 handler s zEApplication._reg_subapp_signals.<locals>.reg_handler.<locals>.handler)getattrappend)ZsignamerW Zappsig)r1 rO )rV r3 reg_handler s z4Application._reg_subapp_signals.<locals>.reg_handler
on_startup on_shutdown
on_cleanupr2 )r1 rO rZ r2 )r1 rO r3 _reg_subapp_signals s
z Application._reg_subapp_signalsc C s | j r t d | j r* t d | j d rI | d d } | d k ra t d t | | } | j j | | j | | j j | | j
| j d k r | j | j | S) Nz0Cannot add sub application to frozen applicationz Cannot add frozen application/r zPrefix cannot be empty)r` r_ )
rP rM endswith
ValueErrorr r$ Zregister_resourcer^ r rY rQ r rN )r1 prefixrO Zresourcer2 r2 r3
add_subapp s"
zApplication.add_subappc C s | j S)N)r )r1 r2 r2 r3 on_response_prepare s z Application.on_response_preparec C s | j S)N)r )r1 r2 r2 r3 r[ s zApplication.on_startupc C s | j S)N)r! )r1 r2 r2 r3 r\ s zApplication.on_shutdownc C s | j S)N)r" )r1 r2 r2 r3 r] s zApplication.on_cleanupc C s | j S)N)r )r1 r2 r2 r3 r$ s zApplication.routerc C s | j S)N)r )r1 r2 r2 r3 r% s zApplication.middlewaresaccess_log_classc K s t | t s$ t d j | | j | | j | j | d <| j r{ x' | j j D] \ } } | | | <qa Wt | j
d | j d | d | j | S)NzMaccess_log_class must be subclass of aiohttp.abc.AbstractAccessLogger, got {}r* Zrequest_factoryrg r) )
issubclassr TypeErrorr5 rN rQ r* r itemsr _handle
_make_requestr) )r1 r) rg kwargskvr2 r2 r3 make_handler s
zApplication.make_handlerc s | j j | Id Hd S)zmCauses on_startup signal
Should be called in the event loop along with the request handler.
N)r[ rT )r1 r2 r2 r3 startup s zApplication.startupc s | j j | Id Hd S)zMCauses on_shutdown signal
Should be called before cleanup()
N)r\ rT )r1 r2 r2 r3 shutdown s zApplication.shutdownc s | j j | Id Hd S)zLCauses on_cleanup signal
Should be called after shutdown()
N)r] rT )r1 r2 r2 r3 cleanup s zApplication.cleanupc C s% | | | | | | | j d | j S)Nr' )r r# )r1 messageZpayloadprotocolwriterZtask_clsr2 r2 r3 rl s zApplication._make_requestc c s xg t | j D]V } t | d d d k r< | d f Vq t j d j | t d d | d f Vq Wt | d f Vd S)NZ__middleware_version__r Tz1old-style middleware "{!r}" deprecated, see #2252r+ r( F)reversedr rX r. r/ r5 r0 r
)r1 mr2 r2 r3 rS s
z Application._prepare_middlewarec sy | j j | Id H} t | t s2 t | | j | | j d } | | _ | j j t
j } | r | j | Id H} | j
j Id H| d k r2| j } | j r!xg | j d d d D]O } xF | j D]; \ } } | rt | d | } q | | | Id H} q Wq W| | Id H} t | t sut d j | j t | d d | j D | S)Nr rW zIHandler {!r} should return response instance, got {!r} [middlewares {!r}]c S s& g | ] } | j D] } | q q Sr2 )r% ).0rU Z
middlewarer2 r2 r3
<listcomp>< s z'Application._handle.<locals>.<listcomp>ra )r Zresolver, r r- Zadd_apprQ Z _match_infoZheadersgetr ZEXPECTZexpect_handlerrv ZdrainrW r Zappsr r r r5 type) r1 ZrequestZ
match_infoZrespexpectrW rU ry Z new_styler2 r2 r3 rk s2
zApplication._handlec C s | S)zgunicorn compatibilityr2 )r1 r2 r2 r3 __call__A s zApplication.__call__c C s d j t | S)Nz<Application 0x{:x}>)r5 id)r1 r2 r2 r3 __repr__E s zApplication.__repr__i ))r6
__module__ __qualname__ frozensetr9 r r4 r8 r; r@ rB rD rF rG rI rK propertyr) rN rP rQ r* r^ re rf r[ r\ r] r$ r% r
rp rq rr rs r rl rS rk r r r2 r2 )r> r3 r s^
% )r )!rL r. collectionsr functoolsr r` r abcr r r Z
frozenlistr Zhelpersr
logr Zsignalsr Zweb_middlewaresr
Z web_requestr Z web_responser Z
web_serverr Zweb_urldispatcherr r __all__r r2 r2 r2 r3 <module> s