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 } | d k r7 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 warningswarnDeprecationWarningr r r r r r r r r r r r r r r r! r" r# )selfr r$ r% r& r' r) r* r0 /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__r. )clsr0 r0 r1 __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- r3 r. super __setattr__)r/ nameval) __class__r0 r1 r9 G s zApplication.__setattr__c C s
| | k S)Nr0 )r/ otherr0 r0 r1 __eq__Q s zApplication.__eq__c C s | j | S)N)r )r/ keyr0 r0 r1 __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- r. )r/ r0 r0 r1
_check_frozenW s zApplication._check_frozenc C s | j | | j | <d S)N)rB r )r/ r? valuer0 r0 r1 __setitem__^ s
zApplication.__setitem__c C s | j | j | =d S)N)rB r )r/ r? r0 r0 r1 __delitem__b s
zApplication.__delitem__c C s
t | j S)N)lenr )r/ r0 r0 r1 __len__f s zApplication.__len__c C s
t | j S)N)iterr )r/ r0 r0 r1 __iter__i s zApplication.__iter__c C s | j S)N)r )r/ r0 r0 r1 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)r/ r) subappr0 r0 r1 rL q s zApplication._set_loopc C s | j S)N)r )r/ r0 r0 r1 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 )r/ rM r0 r0 r1 rO s
zApplication.freezec C s | j S)N)r )r/ r0 r0 r1 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)rM subsigr0 r1 handler s zEApplication._reg_subapp_signals.<locals>.reg_handler.<locals>.handler)getattrappend)ZsignamerU Zappsig)r/ rM )rT r1 reg_handler s z4Application._reg_subapp_signals.<locals>.reg_handler
on_startup on_shutdown
on_cleanupr0 )r/ rM rX r0 )r/ rM r1 _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] )
rN rK endswith
ValueErrorr r$ Zregister_resourcer\ r rW rO r rL )r/ prefixrM Zresourcer0 r0 r1
add_subapp s"
zApplication.add_subappc C s | j S)N)r )r/ r0 r0 r1 on_response_prepare s z Application.on_response_preparec C s | j S)N)r )r/ r0 r0 r1 rY s zApplication.on_startupc C s | j S)N)r! )r/ r0 r0 r1 rZ s zApplication.on_shutdownc C s | j S)N)r" )r/ r0 r0 r1 r[ s zApplication.on_cleanupc C s | j S)N)r )r/ r0 r0 r1 r$ s zApplication.routerc C s | j S)N)r )r/ r0 r0 r1 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_factoryre r) )
issubclassr TypeErrorr3 rL rO r* r itemsr _handle
_make_requestr) )r/ r) re kwargskvr0 r0 r1 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)rY rR )r/ r0 r0 r1 startup s zApplication.startupc s | j j | Id Hd S)zMCauses on_shutdown signal
Should be called before cleanup()
N)rZ rR )r/ r0 r0 r1 shutdown s zApplication.shutdownc s | j j | Id Hd S)zLCauses on_cleanup signal
Should be called after shutdown()
N)r[ rR )r/ r0 r0 r1 cleanup s zApplication.cleanupc C s% | | | | | | | j d | j S)Nr' )r r# )r/ messageZpayloadprotocolwriterZtask_clsr0 r0 r1 rj 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 rV r, r- r3 r. r
)r/ mr0 r0 r1 rQ s
z Application._prepare_middlewarec s | j j | Id H} | j | d } | | _ | j j t j } | rt | j | Id H} | j j
Id H| d k r
| j } | j r xg | j
d d d D]O } xF | j D]; \ } } | r t | d | } q | | | Id H} q Wq W| | Id H} | S)Nr rU r_ )r ZresolveZadd_appZ _match_infoZheadersgetr ZEXPECTZexpect_handlerrt ZdrainrU r Zappsr r ) r/ ZrequestZ
match_infoZrespexpectrU rS rw Z new_styler0 r0 r1 ri s$
zApplication._handlec C s | S)zgunicorn compatibilityr0 )r/ r0 r0 r1 __call__A s zApplication.__call__c C s d j t | S)Nz<Application 0x{:x}>)r3 id)r/ r0 r0 r1 __repr__E s zApplication.__repr__i ))r4
__module__ __qualname__ frozensetr7 r r2 r6 r9 r> r@ rB rD rE rG rI propertyr) rL rN rO r* r\ rc rd rY rZ r[ r$ r% r
rn ro rp rq r rj rQ ri rz r| r0 r0 )r< r1 r s^
% )r )!rJ 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 r0 r0 r0 r1 <module> s