idC2ddlZddlZddlZddlmZmZddlmZmZm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZddlmZddlmZddlmZddlmZm Z m!Z!m"Z"dd l#m$Z$dd l%m&Z&dd l'm(Z(dd l)m*Z*dd l+m,Z,ddl-m.Z.ddl/m0Z0ddl1m2Z2ddl3m4Z4ddl5m6Z6ddl7m8Z8ddl9m:Z:m;Z;mZ>m?Z?m@Z@dZAerddlBmCZCee dge dfZDee e2e4ge dfZEee e2eCge e4fe deCge eCffZFeeFZGeeeeFeHfZIedZJneZDeZEe ZFeZGeeZIeZJGddeeKefZLGddeMZNeree eLge dfZOneZOGddeOZPdS)N)partialupdate_wrapper) TYPE_CHECKINGAny AsyncIterator AwaitableCallableDictIterableIteratorListMappingMutableMappingOptionalSequenceTupleTypeUnioncast)Signal) FrozenList)hdrs)AbstractAccessLoggerAbstractMatchInfoAbstractRouterAbstractStreamWriter)DEBUG)RawRequestMessage) web_logger) StreamReader) AccessLogger)_fix_request_current_app)RequestHandler)Request)StreamResponse)AbstractRouteDef)Server)AbstractResource AbstractRouteDomain MaskDomainMatchedSubAppResourcePrefixedSubAppResource UrlDispatcher) Application CleanupError)Handlerr0cxeZdZegdZeddddddddejdee d e e d ee e efd ed eejd eddfdZdedddfdZer de deddffd ZdedefdZde defdZdNdZde deddfdZde ddfdZdefdZdee fdZ e!dejfdZ"d eejddfd Z#e!defd!Z$dNd"Z%e!defd#Z&dNd$Z'e!defd%Z(dOd'Z)d(e d&dde*fd)Z+d*e,ge*fd&dde*fd+Z-d,e d&dde*fd-Z.d.e e/de0e1fd/Z2e!de3fd0Z4e!de5fd1Z6e!de5fd2Z7e!de5fd3Z8e!dPd5Z9e!de fd6Z:e!de;fd7Zd:ede?fd;Z@de=d8d eejd9ee>d:ede?fd<ZAdNd=ZBdNd>ZCdNd?ZDeEfd@eFdAeGdBeHdCeIdDdEdFeeEdeEfdGZJdeeKe effdHZLdIeEdeMfdJZNdQdKZOde fdLZPdefdMZQxZRS)Rr0)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_ctxNi.)r4router middlewares handler_argsclient_max_sizeloopdebugr4rGrHrIrJrKrLreturnc@|t}ntjdtdt |t s J||tjdtd|durtjdtd||_||_||_||_ ||_ t||_ d|_ d|_i|_d|_d|_g|_t'||_t'||_t'||_t'||_t1|_|j|jj|j|jj||_dS)Nzrouter argument is deprecated stacklevelzloop argument is deprecated.zdebug argument is deprecatedF)r/warningswarnDeprecationWarning isinstancerr5r6r7r8r4rr9r:r;r<r=r>r?rr@rArBrCCleanupContextrEappendrD)selfr4rGrHrIrJrKrLs D/opt/cloudlinux/venv/lib/python3.11/site-packages/aiohttp/web_app.py__init__zApplication.__init__is >"__FF M/1CPQ    &.11996999   M-/Aa        M.0Bq     &,  ) *4[*A*A<@"04&(   "$ 8>t !'-d||(.t '-d||*,,  1 =>>>  1 =>>> /clscntjd|jtddS)Nz8Inheritance class {} from web.Application is discouragedrOrP)rRrSformat__name__rT)r\s rY__init_subclass__zApplication.__init_subclass__s?  #VCL11        r[namevalc||jvr/tjd|tdt ||dS)Nz:Setting custom web.Application.{} attribute is discouragedrOrP)ATTRSrRrSr^rTsuper __setattr__)rXrarb __class__s rYrfzApplication.__setattr__sa4:%% %%+VD\\&  GG  c * * * * *r[otherc ||uSNrF)rXrhs rY__eq__zApplication.__eq__s u}r[keyc|j|Srj)r<rXrls rY __getitem__zApplication.__getitem__s{3r[cP|jrtjdtddSdS)Nz=Changing state of started or joined application is deprecatedrP)r=rRrSrTrXs rY _check_frozenzApplication._check_frozensB <  MR"        r[valuecB|||j|<dSrjrsr<)rXrlrts rY __setitem__zApplication.__setitem__s&   Cr[c>||j|=dSrjrvrns rY __delitem__zApplication.__delitem__s$  K   r[c*t|jSrj)lenr<rrs rY__len__zApplication.__len__s4;r[c*t|jSrj)iterr<rrs rY__iter__zApplication.__iter__sDK   r[cxtjdtdttj|jS)Nzloop property is deprecatedrOrP)rRrSrTrasyncioAbstractEventLoopr7rrs rYrKzApplication.loops3  35GTUVVVVG-tz:::r[c|tj}|j|j|urtd||_|jdur||_|jD]}||dS)Nz8web.Application instance initialized with different loop.)rget_event_loopr7 RuntimeErrorr5 get_debugr? _set_loop)rXrKsubapps rYrzApplication._set_loops <)++D : !dj&<&<J   ;#  ..**DKm # #F   T " " " " # #r[c|jSrj)r>rrs rY pre_frozenzApplication.pre_frozen r[cR|jrdSd|_|j|j|j|j|j|j|jt| |_ |j rdnd|_ |jD])}||j p|j |_ *dS)NTF)r>r9freezer6r@rErArBrCtuple_prepare_middlewarer:rHr;r? pre_freezerXrs rYrzApplication.pre_freezes%    F   """  !((***   """ !!!   """ !!!%*4+C+C+E+E%F%F")-(8 Cem U UF      $($9$TV=TD ! ! U Ur[c|jSrj)r=rrs rYfrozenzApplication.frozen  |r[c|jrdS|d|_|jD]}|dSNT)r=rr?rrs rYrzApplication.freezesR <  F  m  F MMOOOO  r[cHtjdtd|jS)Nzdebug property is deprecatedrOrP)rRrSrTr5rrs rYrLzApplication.debugs$ 46HUVWWWW{r[rcldtddffd }|d|d|ddS)NsignamerMct|dfd }t|}||dS)Nappr0rMcBKd{VdSrj)send)rrsubsigs rYhandlerzEApplication._reg_subapp_signals..reg_handler..handler s1kk&)))))))))))r[)rr0rMN)getattrrW)rrappsigrrXrs @rY reg_handlerz4Application._reg_subapp_signals..reg_handlers_VW--F * * * * * * *T7++F MM' " " " " "r[ on_startup on_shutdown on_cleanup)str)rXrrs`` rY_reg_subapp_signalszApplication._reg_subapp_signalssm # # # # # # # # #  L!!! M""" L!!!!!r[prefixct|tstd|d}|st dt t ||}|||S)NzPrefix must be str/zPrefix cannot be empty)rUr TypeErrorrstrip ValueErrorrr. _add_subapp)rXrrfactorys rY add_subappzApplication.add_subapp*ss&#&& 2011 1s## 7566 60&&AA000r[resource_factorycn|jrtd|jrtd|}|j||||j|||j| |j|S)Nz0Cannot add sub application to frozen applicationzCannot add frozen application) rrrGregister_resourcerr?rWrr7r)rXrrresources rYrzApplication._add_subapp3s ; SQRR R = @>?? ?##%% %%h///   ((( V$$$ : !   TZ ( ( (r[domainct|tstdd|vrt|}nt |}t t ||}|||S)NzDomain must be str*)rUrrr,r+rr-r)rXrrrulers rY add_domainzApplication.add_domainCsn&#&& "011 1 F]]%f--DD&>>D/v>>000r[routesc6|j|Srj)rG add_routes)rXrs rYrzApplication.add_routesMs{%%f---r[c|jSrj)r@rrs rYon_response_preparezApplication.on_response_preparePs ((r[c|jSrj)rArrs rYrzApplication.on_startupTrr[c|jSrj)rBrrs rYrzApplication.on_shutdownX   r[c|jSrj)rCrrs rYrzApplication.on_cleanup\rr[rVc|jSrj)rErrs rY cleanup_ctxzApplication.cleanup_ctx`rr[c|jSrj)r6rrs rYrGzApplication.routerdrr[c|jSrj)r9rrs rYrHzApplication.middlewareshrr[rKaccess_log_classrkwargsc tt|ts"td|||||j|d<||d<|jr$|jD] \}}|||< t|j f|j |j d|S)NzMaccess_log_class must be subclass of aiohttp.abc.AbstractAccessLogger, got {}rLr)request_factoryrK) issubclassrrr^rrr5r8itemsr(_handle _make_requestr7)rXrKrrkvs rY _make_handlerzApplication._make_handlerls*,@AA ;;A6BR;S;S  t +w%5!"   *0022  1q  L  .      r[c Ztjdtd|jd||d|S)NzFApplication.make_handler(...) is deprecated, use AppRunner API insteadrOrPrrF)rRrSrTr)rXrKrrs rY make_handlerzApplication.make_handlersW  W     "t! (8  >g  JQQRSTT&  h&t,,d222222r[requestcKtj}|}|j|d{V}|r7t |t s"td|| || d}||_ |j tj}|r:||d{V}|jd{V|s|j}|jrT|jdddD]C}|jD]9\} } | r t/t1| ||}'| ||d{V}:D||d{V}|S)Nz9match_info should be AbstractMatchInfo instance, not {!r})r)rrrr6resolverUrrr^add_appr _match_infoheadersgetrEXPECTexpect_handlerrdrainrr;appsr:rr) rXrrKrL match_inforespexpectrrr new_styles rYrzApplication._handles%''  <//88888888  j*;<< ))/ );); 4   ($$T[11  )#227;;;;;;;;D.&&(( ( ( ( ( ( ( ( < (G$ <%?44R40<)idrrs rY__repr__zApplication.__repr__s.D.....r[cdSrrFrrs rY__bool__zApplication.__bool__str[rMN)rr0rMN)rMrV)rMr0)Sr_ __module__ __qualname__ frozensetrdr loggingLoggerrr/r _MiddlewarerrrintrrrZrr`rrfobjectboolrkrorsrwryr|r rpropertyrKrrrrrrLrr)rr rrr'r r*r_RespPrepareSignalr _AppSignalrrrrrG _MiddlewaresrHr"rr(rrrrrr%rr!r$rrrrr&rrrr __classcell__rgs@rYr0r0Qs I     E4",*.-/48&4850505050' 50 k* 50 wsCx01 5050w015050 50505050n tM2 t     + +C +c +d + + + + + +Ft s s    !s!3!4!!!!st     !(3-!!!!;g/;;;X;#hw'@A#d####$ D   X UUUU2XtX " " " "11m1@P1111 (-=)= >HU  11m1@P1111.*:!;.]@S....)%7)))X) J   X !Z!!!X! J   X !!!X! X!\!!!X! 597C    w01 34         B597C    w01 34         $))))**** 6 6 6 6$&  "  !  %  #  7m      & 3XeK4E.F%G 3 3 3 3$W$$$$$L/#////$r[c6eZdZedeefdZdS)r1rMcXttt|jdS)Nr)rr BaseExceptionargsrrs rY exceptionszCleanupError.exceptionssD'1666r[N)r_rrr r rrrFr[rYr1r1s> 7D/777X777r[r1c@eZdZdfd ZdeddfdZdeddfdZxZS)rVrMNcVtg|_dSrj)rerZ_exits)rXrgs rYrZzCleanupContext.__init__s$ 13 r[rcK|D]S}||}|d{V|j|TdSrj) __aiter__ __anext__rrW)rXrcbits rYrAzCleanupContext._on_startupsq # #BC""$$B,,.. K  r " " " " # #r[cKg}t|jD]y} |d{V|t |dC#t $rYOt $r}||Yd}~rd}~wwxYw|r+t|dkr|dtd|dS)Nz has more than one 'yield'rrz Multiple errors on cleanup stage) rrrrWrStopAsyncIteration Exceptionr{r1)rXrerrorsrexcs rYrCzCleanupContext._on_cleanups4;'' Q QB Qllnn$$$$$$$  lb+N+N+NOOPPPP &    # # # c"""""""" #  O6{{aQi"#EvNNN  O OsA B( B1B  Br)r_rrrZr0rArCr rs@rYrVrVs444444#[#T#### O[OTOOOOOOOOr[rV)QrrrR functoolsrrtypingrrrrr r r r r rrrrrrrr aiosignalr frozenlistrrabcrrrrhelpersr http_parserrlogr streamsr!web_logr"web_middlewaresr# web_protocolr$ web_requestr% web_responser& web_routedefr' web_serverr(web_urldispatcherr)r*r+r,r-r.r/__all__typedefsr2r r rr r_MiddlewaresHandlers_Subappsrr0rr1_CleanupContextBaserVrFr[rYr8sR--------(!!!!!! ******!!!!!!!!!!!!555555(((((( ((((((****** *!!!!!!-)D/!ABCJ'>)BIdO)S TU'7#Y~%>>?-)9W+==> @Kk*L#HU;3D-E$FGM"HHJKL#H-Hsssss.c*sssl 77777<777 %$X{m]4=P.P%QR$OOOOO(OOOOOr[