bgG :ddlZddlZddlZddlmZmZddlmZmZm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZmZddlmZddlmZddlmZddl m!Z!m"Z"m#Z#m$Z$dd l%m&Z&m'Z'dd l(m)Z)dd l*m+Z+dd l,m-Z-dd l.m/Z/ddl0m1Z1ddl2m3Z3ddl4m5Z5ddl6m7Z7ddl8m9Z9ddl:m;Z;ddlm?Z?ddl@mAZAmBZBmCZCmDZDmEZEmFZFmGZGdZHerVee dge dfZIee e9e;ge dfZJee/ZKeeee/eLfZMedZNneZIeZJeZKeeZMeZNedZOedZPGddeeeQe'efefZRGddeSZTeree eRge dfZUneZUGddeUZVdS) N)partialupdate_wrapper) TYPE_CHECKINGAny AsyncIterator AwaitableCallableDictIterableIteratorListMappingMutableMappingOptionalSequenceTupleTypeTypeVarUnioncastoverload)Signal) FrozenList)hdrs)AbstractAccessLoggerAbstractMatchInfoAbstractRouterAbstractStreamWriter)DEBUGAppKey)RawRequestMessage) web_logger) StreamReader) Middleware)NotAppKeyWarning) AccessLogger)_fix_request_current_app)RequestHandler)Request)StreamResponse)AbstractRouteDef)Server)AbstractResource AbstractRouteDomain MaskDomainMatchedSubAppResourcePrefixedSubAppResource UrlDispatcher) Application CleanupErrorr5_T_Uc^eZdZegdZeddddddddejdee d e e d ee e efd ed eejd eddfdZdedddfdZer de deddffd ZdedefdZedeedefdZede defdZdee eefdefdZdWdZedeededdfdZ ede deddfdZ dee eefdeddfdZ dee eefddfd Z!defd!Z"de#ee eeffd"Z$edXdeed#ddeefd$Z%edeed#e&deee&ffd%Z%edXde d#edefd&Z%dYdee eefd#edefd'Z%e'dejfd(Z(d eejddfd)Z)e'defd*Z*dWd+Z+e'defd,Z,dWd-Z-e'defd.Z.dZd0Z/d1e d/dde0fd2Z1d3e2ge0fd/dde0fd4Z3d5e d/dde0fd6Z4d7e e5de6e7fd8Z8e'de9fd9Z:e'de;fd:Ze'd[d>Z?e'de fd?Z@e'deAfd@ZBdeCdAd eejdBeeDdCedeEfdDZFdeCdAd eejdBeeDdCedeEfdEZGdWdFZHdWdGZIdWdHZJeKfdIeLdJeMdKeNdLeOdMdNdOeeKdeKfdPZPde#eQe effdQZRdReKdeSfdSZTd\dTZUde fdUZVdefdVZWxZXS)]r5)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.)r:router middlewares handler_argsclient_max_sizeloopdebugr:rMrNrOrPrQrRreturnc@|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)r4warningswarnDeprecationWarning isinstancerr;r<r=r>r:rr?r@rArBrCrDrErrFrGrHrICleanupContextrKappendrJ)selfr:rMrNrOrPrQrRs F/opt/cloudlinux/venv/lib64/python3.11/site-packages/aiohttp/web_app.py__init__zApplication.__init__is >"__FF M/1CPQ    &.11996991   M-/Aa        M.0Bq     &,  ) *4[*A*A<@"04=?   "$ 8>t !'-d||(.t '-d||*,,  1 =>>>  1 =>>> /clscntjd|jtddS)Nz8Inheritance class {} from web.Application is discouragedrV)rXrYformat__name__rZ)rbs r___init_subclass__zApplication.__init_subclass__s?  #VCL11        ranamevalc||jvr/tjd|tdt ||dS)Nz:Setting custom web.Application.{} attribute is discouragedrUrV)ATTRSrXrYrerZsuper __setattr__)r^rhri __class__s r_rmzApplication.__setattr__sa4:%% %%+VD\\&  GG  c * * * * *raotherc ||uSNrL)r^ros r___eq__zApplication.__eq__s u}rakeycdSrqrLr^rss r_ __getitem__zApplication.__getitem__ racdSrqrLrus r_rvzApplication.__getitem__rwrac|j|Srq)rBrus r_rvzApplication.__getitem__s{3racP|jrtjdtddSdS)Nz=Changing state of started or joined application is deprecatedrdrV)rCrXrYrZr^s r_ _check_frozenzApplication._check_frozensB <  MR"        ravaluecdSrqrLr^rsr}s r_ __setitem__zApplication.__setitem__rwracdSrqrLrs r_rzApplication.__setitem__rwrac|t|tstjdt d||j|<dS)NzIt is recommended to use web.AppKey instances for keys. https://docs.aiohttp.org/en/stable/web_advanced.html#application-s-configrU)categoryrW)r|r[r!rXrYr&rBrs r_rzApplication.__setitem__s` #v&&  M**     ! Crac>||j|=dSrq)r|rBrus r_ __delitem__zApplication.__delitem__s$  K   rac*t|jSrq)lenrBr{s r___len__zApplication.__len__s4;rac*t|jSrq)iterrBr{s r___iter__zApplication.__iter__sDK   radefaultcdSrqrLr^rsrs r_getzApplication.getrwracdSrqrLrs r_rzApplication.getrwracdSrqrLrs r_rzApplication.getrwrac8|j||Srq)rBrrs r_rzApplication.gets{sG,,,racxtjdtdttj|jS)Nzloop property is deprecatedrUrV)rXrYrZrasyncioAbstractEventLoopr=r{s r_rQzApplication.loops3  35GTUVVVVG-tz:::rac|tj}|j|j|urtd||_|jdur||_|jD]}||dS)Nz8web.Application instance initialized with different loop.)rget_event_loopr= RuntimeErrorr; get_debugrE _set_loop)r^rQsubapps r_rzApplication._set_loops <)++D : !dj&<&<J   ;#  ..**DKm # #F   T " " " " # #rac|jSrq)rDr{s r_ pre_frozenzApplication.pre_frozen racR|jrdSd|_|j|j|j|j|j|j|jt| |_ |j rdnd|_ |jD])}||j p|j |_ *dS)NTF)rDr?freezer<rFrKrGrHrItuple_prepare_middlewarer@rNrArE pre_freezer^rs r_rzApplication.pre_freezes%    F   """  !((***   """ !!!   """ !!!%*4+C+C+E+E%F%F")-(8 Cem U UF      $($9$TV=TD ! ! U Urac|jSrq)rCr{s r_frozenzApplication.frozen1 |rac|jrdS|d|_|jD]}|dSNT)rCrrErrs r_rzApplication.freeze5sR <  F  m  F MMOOOO  racHtjdtd|jS)Nzdebug property is deprecatedrUrV)rXrYrZr;r{s r_rRzApplication.debug>s$ 46HUVWWWW{rarcldtddffd }|d|d|ddS)NsignamerSct|dfd }t|}||dS)Nappr5rScBKd{VdSrq)send)rrsubsigs r_handlerzEApplication._reg_subapp_signals..reg_handler..handlerGs1kk&)))))))))))ra)rr5rSN)getattrr])rrappsigrr^rs @r_ reg_handlerz4Application._reg_subapp_signals..reg_handlerDs_VW--F * * * * * * *T7++F MM' " " " " "ra on_startup on_shutdown on_cleanup)str)r^rrs`` r__reg_subapp_signalszApplication._reg_subapp_signalsCsm # # # # # # # # #  L!!! M""" L!!!!!raprefixct|tstd|d}|st dt t ||}|||S)NzPrefix must be str/zPrefix cannot be empty)r[r TypeErrorrstrip ValueErrorrr3 _add_subapp)r^rrfactorys r_ add_subappzApplication.add_subappQss&#&& 2011 1s## 7566 60&&AA000raresource_factorycn|jrtd|jrtd|}|j||||j|||j| |j|S)Nz0Cannot add sub application to frozen applicationzCannot add frozen application) rrrMregister_resourcerrEr]rr=r)r^rrresources r_rzApplication._add_subappZs ; SQRR R = @>?? ?##%% %%h///   ((( V$$$ : !   TZ ( ( (radomainct|tstdd|vrt|}nt |}t t ||}|||S)NzDomain must be str*)r[rrr1r0rr2r)r^rrrulers r_ add_domainzApplication.add_domainjsn&#&& "011 1 F]]%f--DD&>>D/v>>000raroutesc6|j|Srq)rM add_routes)r^rs r_rzApplication.add_routests{%%f---rac|jSrq)rFr{s r_on_response_preparezApplication.on_response_preparews ((rac|jSrq)rGr{s r_rzApplication.on_startup{rrac|jSrq)rHr{s r_rzApplication.on_shutdown   rac|jSrq)rIr{s r_rzApplication.on_cleanuprrar\c|jSrq)rKr{s r_ cleanup_ctxzApplication.cleanup_ctxrrac|jSrq)r<r{s r_rMzApplication.routerrrac|jSrq)r?r{s r_rNzApplication.middlewaresrrarQaccess_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 {}rRr)request_factoryrQ) issubclassrrrerrr;r>itemsr-_handle _make_requestr=)r^rQrrkvs r_ _make_handlerzApplication._make_handlers*,@AA ;;A6BR;S;S  t +w%5!"   *0022  1q  L  .      rac Ztjdtd|jd||d|S)NzFApplication.make_handler(...) is deprecated, use AppRunner API insteadrUrVrrL)rXrYrZr)r^rQrrs r_ make_handlerzApplication.make_handlersW  W     "t! (8  >g  JQQRSTT&  h&t,,d222222rarequestcKtj}|}|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)rrrr<resolver[rrreadd_appr _match_infoheadersrrEXPECTexpect_handlerrdrainrrAappsr@rr) r^rrQrR match_inforespexpectrrr new_styles r_rzApplication._handles%''  <//88888888  j*;<< ))/ );); 4   ($$T[11  )#227;;;;;;;;D.&&(( ( ( ( ( ( ( ( < (G$ <%?44R40<)idr{s r___repr__zApplication.__repr__'s.D.....racdSrrLr{s r___bool__zApplication.__bool__*strarSN).rq)rr5rSN)rSr\)rSr5)Yrf __module__ __qualname__ frozensetrkr#loggingLoggerrr4r r%rrrintrrr`rrgr rmobjectboolrrrr!r7rvrr|rrrr rrr8propertyrQrrrrrrRrr.rr rrr,r r/r_RespPrepareSignalr _AppSignalrrrrrM _MiddlewaresrNr'rr-rrrrrr*r"r$r)rrrrr+rr rr __classcell__rns@r_r5r5Qs I     E4",*.,.48&4850505050' 50 j) 50 wsCx01 5050w015050 50505050n tM2 t     + +C +c +d + + + + + +Ft vbz b   X  s s   X  uS&*_5 #     vbz "    X  s 3 4   X  !uS&*_5 !c !d ! ! ! !uS&*_5$     !(5fSk)9#:;!!!!  vbz D 8B<   X  vbz B 5R=   X   s S 3   X --uS&*_---s----;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      & 3XeJ4D.E%F 3 3 3 3$W$$$$$L/#////$rac6eZdZedeefdZdS)r6rScXttt|jdS)Nr)rr BaseExceptionargsr{s r_ exceptionszCleanupError.exceptions/sD'1666raN)rfrrrr r"r$rLrar_r6r6.s> 7D/777X777rar6c@eZdZdfd ZdeddfdZdeddfdZxZS)r\rSNcVtg|_dSrq)rlr`_exits)r^rns r_r`zCleanupContext.__init__;s$ 13 rarcK|D]S}||}|d{V|j|TdSrq) __aiter__ __anext__r'r])r^rcbits r_rGzCleanupContext._on_startup?sq # #BC""$$B,,.. K  r " " " " # #racKg}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) rr'r*r]rStopAsyncIteration Exceptionrr6)r^rerrorsr,excs r_rIzCleanupContext._on_cleanupEs4;'' Q QB Qllnn$$$$$$$  lb+N+N+NOOPPPP &    # # # c"""""""" #  O6{{aQi"#EvNNN  O OsA B( B1B  Br)rfrrr`r5rGrIrrs@r_r\r\:s444444#[#T#### O[OTOOOOOOOOrar\)WrrrX functoolsrrtypingrrrrr r r r r rrrrrrrrrr aiosignalr frozenlistrrabcrrrrhelpersr r! http_parserr"logr#streamsr$typedefsr%web_exceptionsr&web_logr'web_middlewaresr( web_protocolr) web_requestr* web_responser+ web_routedefr, web_serverr-web_urldispatcherr.r/r0r1r2r3r4__all__rrrr_MiddlewaresHandlers_Subappsr7r8rr5rr6_CleanupContextBaser\rLrar_rJsb--------,!!!!!! #"""""""******!!!!!! ,,,,,,!!!!!!555555(((((( ((((((****** * -)D/!ABCJ'>)BIdO)S TUj)L#HU:t3C-D$EFM"HHJL#H-H WT]] WT]]ZZZZZ.sF3K'7!8#!=>ZZZz77777<777 %$X{m]4=P.P%QR$OOOOO(OOOOOra