U
    -eC                     @   sh  d dl Z d dlZd dlZd dlmZmZ d dlmZmZm	Z	m
Z
mZmZmZmZmZmZmZmZmZmZ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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/m0Z0 ddl1m2Z2 ddl3m4Z4 ddl5m6Z6 ddl7m8Z8 ddl9m:Z:m;Z;m<Z<m=Z=m>Z>m?Z?m@Z@ dZAerddlBmCZC eedge
d f  ZDeee2e4ge
d f  ZEeee2eCge
e4 f edeCge
eC f f ZFeeF ZGeeeeFeHf   ZIed ZJneZDeZEeZFeZGee ZIeZJG dd deeKef ZLG dd deMZNerPeeeLge	d f  ZOneZOG dd deOZPdS )    N)partialupdate_wrapper)TYPE_CHECKINGAnyAsyncIterator	AwaitableCallableDictIterableIteratorListMappingMutableMappingOptionalSequenceTupleTypeUnioncast)Signal)
FrozenList   )hdrs)AbstractAccessLoggerAbstractMatchInfoAbstractRouterAbstractStreamWriter)DEBUG)RawRequestMessage)
web_logger)StreamReader)AccessLogger)_fix_request_current_app)RequestHandler)Request)StreamResponse)AbstractRouteDef)Server)AbstractResourceAbstractRouteDomain
MaskDomainMatchedSubAppResourcePrefixedSubAppResourceUrlDispatcher)ApplicationCleanupError)Handlerr/   c                       sp  e Zd Zeddddddddd	d
ddddddddgZedddddddejee	 e
e eeeef  eeej eddddZed  ddddZereedd fdd Zeed!d"d#Zeed$d%d&Zdd'd(d)Zeedd*d+d,Zedd$d-d.Zed'd/d0Zee d'd1d2Z e!ejd'd3d4Z"eej dd5d6d7Z#e!ed'd8d9Z$dd'd:d;Z%e!ed'd<d=Z&dd'd>d?Z'e!ed'd@dAZ(d ddBdCdDZ)ed e*dEdFdGZ+e,g e*f d e*dHdIdJZ-ed e*dKdLdMZ.e
e/ e0e1 dNdOdPZ2e!e3d'dQdRZ4e!e5d'dSdTZ6e!e5d'dUdVZ7e!e5d'dWdXZ8e!dYd'dZd[Z9e!e	d'd\d]Z:e!e;d'd^d_Z<de=d`eej ee> ee?dadbdcZ@de=d`eej ee> ee?dadddeZAdd'dfdgZBdd'dhdiZCdd'djdkZDeEfeFeGeHeIdleeE eEdmdndoZJeeKeef  d'dpdqZLeEeMdrdsdtZNd d'dudvZOed'dwdxZPed'dydzZQ  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   .)r2   routermiddlewareshandler_argsclient_max_sizeloopdebug)r2   rE   rF   rG   rH   rI   rJ   returnc                C   s  |d krt  }ntjdtdd t|ts2t||d k	rJtjdtdd |dk	rbtjdtdd || _|| _|| _	|| _
|| _t|| _d | _d | _i | _d| _d| _g | _t| | _t| | _t| | _t| | _t | _| j| jj | j| jj || _d S )Nzrouter argument is deprecated   
stacklevelzloop argument is deprecated.zdebug argument is deprecatedF)r.   warningswarnDeprecationWarning
isinstancer   AssertionErrorr3   r4   r5   r6   r2   r   r7   r8   r9   r:   r;   r<   r=   r   r>   r?   r@   rA   CleanupContextrC   appendrB   )selfr2   rE   rF   rG   rH   rI   rJ   rD   rD   P/var/www/html/Darija-Ai-Train/env/lib/python3.8/site-packages/aiohttp/web_app.py__init__i   sP          




zApplication.__init__)clsrK   c                 C   s   t jd| jtdd d S )Nz8Inheritance class {} from web.Application is discouragedrL   rM   )rO   rP   format__name__rQ   )rY   rD   rD   rW   __init_subclass__   s    zApplication.__init_subclass__)namevalrK   c                    s2   || j kr tjd|tdd t || d S )Nz:Setting custom web.Application.{} attribute is discouragedrL   rM   )ATTRSrO   rP   rZ   rQ   super__setattr__)rV   r]   r^   	__class__rD   rW   ra      s    
zApplication.__setattr__)otherrK   c                 C   s   | |kS NrD   )rV   rd   rD   rD   rW   __eq__   s    zApplication.__eq__)keyrK   c                 C   s
   | j | S re   )r:   rV   rg   rD   rD   rW   __getitem__   s    zApplication.__getitem__rK   c                 C   s   | j rtjdtdd d S )Nz=Changing state of started or joined application is deprecated   rM   )r;   rO   rP   rQ   rV   rD   rD   rW   _check_frozen   s    zApplication._check_frozen)rg   valuerK   c                 C   s   |    || j|< d S re   rm   r:   )rV   rg   rn   rD   rD   rW   __setitem__   s    zApplication.__setitem__c                 C   s   |    | j|= d S re   ro   rh   rD   rD   rW   __delitem__   s    zApplication.__delitem__c                 C   s
   t | jS re   )lenr:   rl   rD   rD   rW   __len__   s    zApplication.__len__c                 C   s
   t | jS re   )iterr:   rl   rD   rD   rW   __iter__   s    zApplication.__iter__c                 C   s   t jdtdd ttj| jS )Nzloop property is deprecatedrL   rM   )rO   rP   rQ   r   asyncioAbstractEventLoopr5   rl   rD   rD   rW   rI      s    zApplication.loop)rI   rK   c                 C   s`   |d krt  }| jd k	r,| j|k	r,td|| _| jdkrF| | _| jD ]}|| qLd S )Nz8web.Application instance initialized with different loop.)rv   get_event_loopr5   RuntimeErrorr3   	get_debugr=   	_set_loop)rV   rI   subapprD   rD   rW   r{      s    


zApplication._set_loopc                 C   s   | j S re   )r<   rl   rD   rD   rW   
pre_frozen   s    zApplication.pre_frozenc                 C   s   | j r
d S d| _ | j  | j  | j  | j  | j  | j  | j  t	| 
 | _| jrndnd| _| jD ]}|  | jp|j| _qzd S )NTF)r<   r7   freezer4   r>   rC   r?   r@   rA   tuple_prepare_middlewarer8   rF   r9   r=   
pre_freezerV   r|   rD   rD   rW   r      s    







zApplication.pre_freezec                 C   s   | j S re   )r;   rl   rD   rD   rW   frozen
  s    zApplication.frozenc                 C   s0   | j r
d S |   d| _ | jD ]}|  qd S NT)r;   r   r=   r~   r   rD   rD   rW   r~     s    
zApplication.freezec                 C   s   t jdtdd | jS )Nzdebug property is deprecatedrL   rM   )rO   rP   rQ   r3   rl   rD   rD   rW   rJ     s    zApplication.debug)r|   rK   c                    s2   t d d fdd}|d |d |d d S )N)signamerK   c                    s8   t |  dd d fdd}t | }|| d S )Nr/   apprK   c                    s     I d H  d S re   )send)r   )r|   subsigrD   rW   handler   s    zEApplication._reg_subapp_signals.<locals>.reg_handler.<locals>.handler)getattrrU   )r   r   Zappsigr   )r   rW   reg_handler  s    

z4Application._reg_subapp_signals.<locals>.reg_handler
on_startupon_shutdown
on_cleanup)str)rV   r|   r   rD   r   rW   _reg_subapp_signals  s    	zApplication._reg_subapp_signals)prefixr|   rK   c                 C   s@   t |tstd|d}|s(tdtt||}| ||S )NzPrefix must be str/zPrefix cannot be empty)rR   r   	TypeErrorrstrip
ValueErrorr   r-   _add_subapp)rV   r   r|   factoryrD   rD   rW   
add_subapp*  s    

zApplication.add_subapp)resource_factoryr|   rK   c                 C   sf   | j rtd|j rtd| }| j| | | | j| |  | jd k	rb|	| j |S )Nz0Cannot add sub application to frozen applicationzCannot add frozen application)
r   ry   rE   Zregister_resourcer   r=   rU   r   r5   r{   )rV   r   r|   resourcerD   rD   rW   r   3  s    

zApplication._add_subapp)domainr|   rK   c                 C   sF   t |tstdnd|kr&t|}nt|}tt||}| ||S )NzDomain must be str*)rR   r   r   r+   r*   r   r,   r   )rV   r   r|   ruler   rD   rD   rW   
add_domainC  s    


zApplication.add_domain)routesrK   c                 C   s   | j |S re   )rE   
add_routes)rV   r   rD   rD   rW   r   M  s    zApplication.add_routesc                 C   s   | j S re   )r>   rl   rD   rD   rW   on_response_prepareP  s    zApplication.on_response_preparec                 C   s   | j S re   )r?   rl   rD   rD   rW   r   T  s    zApplication.on_startupc                 C   s   | j S re   )r@   rl   rD   rD   rW   r   X  s    zApplication.on_shutdownc                 C   s   | j S re   )rA   rl   rD   rD   rW   r   \  s    zApplication.on_cleanuprT   c                 C   s   | j S re   )rC   rl   rD   rD   rW   cleanup_ctx`  s    zApplication.cleanup_ctxc                 C   s   | j S re   )r4   rl   rD   rD   rW   rE   d  s    zApplication.routerc                 C   s   | j S re   )r7   rl   rD   rD   rW   rF   h  s    zApplication.middlewaresrI   access_log_class)rI   r   kwargsrK   c                K   sz   t |tstd|| | |   | j|d< ||d< | jr^| j D ]\}}|||< qLt	| j
f| j| jd|S )NzMaccess_log_class must be subclass of aiohttp.abc.AbstractAccessLogger, got {}rJ   r   )Zrequest_factoryrI   )
issubclassr   r   rZ   r{   r~   r3   r6   itemsr'   _handle_make_requestr5   )rV   rI   r   r   kvrD   rD   rW   _make_handlerl  s*    



zApplication._make_handlerc                K   s&   t jdtdd | jf ||d|S )NzFApplication.make_handler(...) is deprecated, use AppRunner API insteadrL   rM   r   )rO   rP   rQ   r   )rV   rI   r   r   rD   rD   rW   make_handler  s     zApplication.make_handlerc                    s   | j | I dH  dS )zmCauses on_startup signal

        Should be called in the event loop along with the request handler.
        N)r   r   rl   rD   rD   rW   startup  s    zApplication.startupc                    s   | j | I dH  dS )zMCauses on_shutdown signal

        Should be called before cleanup()
        N)r   r   rl   rD   rD   rW   shutdown  s    zApplication.shutdownc                    s2   | j jr| j | I dH  n| j| I dH  dS )zLCauses on_cleanup signal

        Should be called after shutdown()
        N)r   r   r   rC   rA   rl   rD   rD   rW   cleanup  s    zApplication.cleanupzasyncio.Task[None])messagepayloadprotocolwritertask_clsrK   c              	   C   s   ||||||| j | jdS )N)rH   )r5   rB   )rV   r   r   r   r   r   r   rD   rD   rW   r     s    	zApplication._make_requestc                 c   s^   t | jD ]@}t|dd dkr*|dfV  q
tjd|tdd |dfV  q
t| dfV  d S )NZ__middleware_version__r   Tz1old-style middleware "{!r}" deprecated, see #2252rL   rM   F)reversedr7   r   rO   rP   rZ   rQ   r"   )rV   mrD   rD   rW   r     s    zApplication._prepare_middleware)requestrK   c                    s   t  }| }| j|I d H }|r>t|ts>td||	|  |
  d }||_|jtj}|r||I d H }|j I d H  |d kr|j}| jr|jd d d D ]<}|jD ]0\}	}
|
rtt|	|d|}q|	||I d H }qq||I d H }|S )Nz9match_info should be AbstractMatchInfo instance, not {!r})r   )rv   rx   rz   r4   resolverR   r   r   rZ   Zadd_appr~   Z_match_infoheadersgetr   ZEXPECTZexpect_handlerr   drainr   r9   Zappsr8   r   r   )rV   r   rI   rJ   Z
match_inforespexpectr   r   r   	new_stylerD   rD   rW   r     s>    


 zApplication._handlec                 C   s   | S )zgunicorn compatibilityrD   rl   rD   rD   rW   __call__  s    zApplication.__call__c                 C   s   dt | ddS )Nz<Application 0xx>)idrl   rD   rD   rW   __repr__   s    zApplication.__repr__c                 C   s   dS r   rD   rl   rD   rD   rW   __bool__  s    zApplication.__bool__)Sr[   
__module____qualname__	frozensetr_   r   loggingLoggerr   r.   r
   _Middlewarer   r   r   intrv   rw   rX   r   r\   r   ra   objectboolrf   ri   rm   rp   rq   rs   r   ru   propertyrI   r{   r}   r   r   r~   rJ   r   r(   r   r   r   r   r&   r   r)   r   _RespPrepareSignalr   
_AppSignalr   r   r   r   rE   _MiddlewaresrF   r!   r   r'   r   r   r   r   r   r$   r   r    r#   r   r   r   r   r%   r   r   r   r   __classcell__rD   rD   rb   rW   r/   Q   s   7	

 
!&c                   @   s"   e Zd Zeee dddZdS )r0   rj   c                 C   s   t tt | jd S )Nr   )r   r   BaseExceptionargsrl   rD   rD   rW   
exceptions  s    zCleanupError.exceptionsN)r[   r   r   r   r   r   r   rD   rD   rD   rW   r0     s   r0   c                       sB   e Zd Zdd fddZeddddZedddd	Z  ZS )
rT   Nrj   c                    s   t    g | _d S re   )r`   rX   _exitsrl   rb   rD   rW   rX     s    
zCleanupContext.__init__r   c                    s4   | D ]*}||  }| I d H  | j| qd S re   )	__aiter__	__anext__r   rU   )rV   r   cbitrD   rD   rW   r?     s    zCleanupContext._on_startupc                    s   g }t | jD ]j}z| I d H  W n> tk
r8   Y q tk
rb } z|| W 5 d }~X Y qX |t|d q|rt|dkr|d n
td|d S )Nz has more than one 'yield'r   r   z Multiple errors on cleanup stage)	r   r   r   StopAsyncIteration	ExceptionrU   ry   rr   r0   )rV   r   errorsr   excrD   rD   rW   rA     s    
zCleanupContext._on_cleanup)r[   r   r   rX   r/   r?   rA   r   rD   rD   rb   rW   rT     s   rT   )Qrv   r   rO   	functoolsr   r   typingr   r   r   r   r   r	   r
   r   r   r   r   r   r   r   r   r   r   Z	aiosignalr   Z
frozenlistr    r   abcr   r   r   r   helpersr   Zhttp_parserr   logr   streamsr    Zweb_logr!   Zweb_middlewaresr"   Zweb_protocolr#   Zweb_requestr$   Zweb_responser%   Zweb_routedefr&   Z
web_serverr'   Zweb_urldispatcherr(   r)   r*   r+   r,   r-   r.   __all__Ztypedefsr1   r   r   r   r   r   Z_MiddlewaresHandlersZ_Subappsr   r/   ry   r0   Z_CleanupContextBaserT   rD   rD   rD   rW   <module>   s`   L$

   9