File: //opt/alt/python35/lib64/python3.5/site-packages/aiohttp/__pycache__/web_app.cpython-35.opt-1.pyc
���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 � } | 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 �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* � 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/ �name�val)� __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)�getattr�append)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.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_factoryre r) )
�
issubclassr � TypeErrorr3 rL rO r* r �itemsr �_handle�
_make_requestr) )r/ r) re �kwargs�k�vr0 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/ �messageZpayload�protocol�writerZtask�_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_infoZheaders�getr ZEXPECTZexpect_handlerrt ZdrainrU r Zappsr r ) r/ ZrequestZ
match_infoZresp�expectrU 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