���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)�AbstractAccessLogger�AbstractMatchInfo�AbstractRouter)�
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_size�routerN� middlewares� handler_args�client_max_sizei � �loop�debug.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 �AssertionError�warnings�warn�DeprecationWarningr 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 �name�val)� __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)�getattr�append)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.middlewares�access_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 �kwargs�k�vr2 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 �messageZpayload�protocol�writerZtask�_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_infoZheaders�getr ZEXPECTZexpect_handlerrv ZdrainrW r Zappsr r r r5 �type) r1 ZrequestZ
match_infoZresp�expectrW 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