wce?K'ddlZddlZddlZddlZddlZddlZddlmZddlm Z ddl m Z ddl m Z ddlmZddlmZmZmZm ZmZmZmZmZmZmZddlmZd d lmZd d lm Z d d l!m"Z"d d l#m$Z$d dl%m&Z&m'Z'd dl(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmGZGmHZHmIZImJZJmKZKmLZLmMZMmNZNmOZOmPZPmQZQmRZRmSZSmTZTmUZUmVZVmWZWmXZXmYZYmZZZm[Z[m\Z\m]Z]m^Z^m_Z_m`Z`maZambZbmcZcd dldmeZed dlfmgZgd dlhmiZimjZjd dlkmlZlmmZmmnZnd dlompZpmqZqmrZrd dlsmtZtmuZumvZvmwZwd dlxmyZymzZzm{Z{m|Z|m}Z}m~Z~mZmZmZmZmZmZmZmZd dlmZmZmZmZmZmZmZmZmZd dlmZd dlmZmZmZmZmZmZmZmZmZmZmZd dlmZmZmZdZ ddlmZejNdecdeeZddddd d!ded"egegjVe"dddd#d$d%ee&ee&fd&eeeefd'eed(ee$ee$dfd)eeejeejfd*ed+ed,eed-eed.d/ed0eed1ed2eej\d3ed4eed5eed6ed7df$d8Zd9ed:d;ejbd7dfd<Zddddd d!ded"egegjVe"dddd#dd=d%ee&ee&fd&eeeefd'eed(ee$ee$dfd)eeejeejfd*ed+ed,eed-eed.d/ed0eed1ed2eej\d3ed4eed5eed6ed;eejbd7df&d>Zd?eed7dfd@ZedAk(reejld dyy#e$reZYwxYw)BN)ArgumentParser)Iterable)suppress)partial) import_module) Any AwaitableCallablerListOptionalSetTypeUnioncast)WeakSet)AbstractAccessLogger)AppKey) access_logger)PathLike) Application CleanupError); HTTPAcceptedHTTPBadGatewayHTTPBadRequestHTTPClientError HTTPConflict HTTPCreated HTTPError HTTPExceptionHTTPExpectationFailedHTTPFailedDependency HTTPForbidden HTTPFoundHTTPGatewayTimeoutHTTPGoneHTTPInsufficientStorageHTTPInternalServerErrorHTTPLengthRequiredHTTPMethodNotAllowedHTTPMisdirectedRequestHTTPMoveHTTPMovedPermanentlyHTTPMultipleChoices!HTTPNetworkAuthenticationRequired HTTPNoContentHTTPNonAuthoritativeInformationHTTPNotAcceptableHTTPNotExtended HTTPNotFoundHTTPNotImplementedHTTPNotModifiedHTTPOkHTTPPartialContentHTTPPaymentRequiredHTTPPermanentRedirectHTTPPreconditionFailedHTTPPreconditionRequiredHTTPProxyAuthenticationRequiredHTTPRedirectionHTTPRequestEntityTooLargeHTTPRequestHeaderFieldsTooLargeHTTPRequestRangeNotSatisfiableHTTPRequestTimeoutHTTPRequestURITooLongHTTPResetContent HTTPSeeOtherHTTPServerErrorHTTPServiceUnavailableHTTPSuccessfulHTTPTemporaryRedirectHTTPTooManyRequestsHTTPUnauthorizedHTTPUnavailableForLegalReasonsHTTPUnprocessableEntityHTTPUnsupportedMediaTypeHTTPUpgradeRequired HTTPUseProxyHTTPVariantAlsoNegotiatesHTTPVersionNotSupportedNotAppKeyWarning) FileResponse) AccessLogger) middlewarenormalize_path_middleware)PayloadAccessErrorRequestHandlerRequestPayloadError) BaseRequest FileFieldRequest) ContentCodingResponseStreamResponse json_response)AbstractRouteDefRouteDef RouteTableDef StaticDefdeletegetheadoptionspatchpostputroutestaticview) AppRunner BaseRunnerBaseSite GracefulExit NamedPipeSite ServerRunnerSockSiteTCPSiteUnixSite)Server) AbstractResource AbstractRouteDynamicResource PlainResourcePrefixedSubAppResourceResource ResourceRouteStaticResource UrlDispatcherUrlMappingMatchInfoView)WebSocketReadyWebSocketResponse WSMsgType)rrrrrSrrrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9r:r;r<r=r>r?r@rArBrCrDrErFrGrHrIrJrKrLrMrNrOrPrQrRrTrVrWrXrYrZr[r\r]r^r_r`rarbrcrdrerfrgrhrirjrkrlrmrnrorprqrrrsrurvrwrxrtryrzr{r|r}r~rrrrrrrrrrun_app) SSLContextignoreT)categoryappendgN@gR@F)hostportpathsockshutdown_timeoutkeepalive_timeout ssl_contextprintbacklogaccess_log_classaccess_log_format access_loghandle_signals reuse_address reuse_porthandler_cancellationapprrrrrrrr).Nrrrrrrrrreturnc >Kdddtddffd }ddtj|r |d{}tt|}t || | | | |||}|j d{ttj}t||||_ g} |kt|ttttfr"|j!t#||||| ||nO|D]#}|j!t#||||| ||%n&||| |j!t#|||| || |dt|tt$j&fr|j!t)|||| n%|D] }|j!t)|||| "|Tt|t*s|j!t-|||| n%|D] }|j!t-|||| "|D]}|j/d{|rBt1d |j2D}|d j5d j7| tj8dd{7C7 7o7 #|j;d{7wxYww)Nstarting_tasksWeakSet[asyncio.Task[object]]rrc Ktj}|J|j|ttj5tj ||d{dddy7 #1swYyxYww)N)timeout)asyncio current_taskaddr TimeoutErrorwait_for)rrt_waits -/usr/lib/python3/dist-packages/aiohttp/web.pywaitz_run_app..waitCs{  "}}1 g** + T""5#8BRS S S T T S T Ts0AB!A7'A5(A7, B5A77B<Bc4Ktj}|J|j|tjj |x}rDtj |d{tjj |x}rCyy7,wN)rrr all_tasks differencer)excludertaskss rrz_run_app.._waitMs~  "}} A((*55g>>e>,,u% % %((*55g>>e> %sA'B)B*)BB)rrrrrrr)rrrr)rrrrr)rrc3FK|]}t|jywr)strname).0ss r z_run_app..s=13qvv;=s!z6======== Running on {} ======== (Press CTRL+C to quit)z, i)rrrN)floatr iscoroutinerrrpsetuprrrshutdown_callback isinstancerbytes bytearray memoryviewrrwosrrxrrvstartsortedsitesformatjoinsleepcleanup)rrrrrrrrrrrrrrrrrrrunnerrrhprsitenamesrs @r_run_appr/s(T7TKPT T&3i {C C  %)++)1 F ,,. 7>g>O>O>Q6RN&t^=MNFE^  $eY CD $/ '&3#-  ALL" (3$+*7'1  \dld.> LL +#"/)    $bkk 23 $/ ' ALL "(3$+   dH- $/ ' ALL "(3$+  D**,    = ==E ))/ %0@)A  --% % %iv  &nnsk/JI5:J-I8.5J$E'I? I; A#I?/I=0I?5J8J;I?=I??JJJJ to_cancelzasyncio.Task[Any]loopc|sy|D]}|j|jtj|ddi|D]G}|j r|j %|j d|j |dIy)Nreturn_exceptionsTz1unhandled exception during asyncio.run() shutdown)message exceptiontask)cancelrun_until_completergather cancelledrcall_exception_handler)rrrs r _cancel_tasksrs   GNNINNO  >>   >>  '  ' 'R!%!1   )rrrrrrrrrrrrrrrrrc|tj}|jr| r~| jdk(ro| jt j k(r| jt j| js#| jt j|jt|fid|d|d|d|d|d|d |d |d | d | d | d| d| d|d|d|} tj||j|t%|h|t%tj&|||j|j)|j+y#t t"f$rYmwxYw#t%|h|t%tj&|||j|j)|j+wxYw)zRun an app locallyNzaiohttp.accessrrrrrrrrrrrrrrrr)rnew_event_loop get_debugrlevelloggingNOTSETsetLevelDEBUG hasHandlers addHandler StreamHandler create_taskrset_event_looprrsKeyboardInterruptrrshutdown_asyncgensclose)rrrrrrrrrrrrrrrrrr main_tasks rrrs, |%%' ~~J:??>N+N   w~~ -    .%%'  ! !'"7"7"9 :          .  0 $   . 0 " * ( "! ""6# I, t$  * yk4(g''-t4  7 7 9: + ,    yk4(g''-t4  7 7 9: s%1&E33FFFFAG%argvctdd}|jddd|jdd d d |jd ddtd|jddd|j|\}}|jj d\}}}|r|s|j d|jdr|j d t|} t|} |j!ttds|j dtj tj"  |} t%| |j&|j(|j!|j+d"#y#t$r!}|j d|d|Yd}~d}~wwxYw#t$r|j d|d|YwxYw)$Nzaiohttp.web Application serverz aiohttp.web) descriptionprog entry_funczvCallable returning the `aiohttp.web.Application` instance to run. Should be specified in the 'module:function' syntax.z entry-func)helpmetavarz-Hz --hostnamez2TCP/IP hostname to serve on (default: %(default)r) localhost)rdefaultz-Pz--portz.TCP/IP port to serve on (default: %(default)r)8080)rtyperz-Uz--pathzjUnix file system path to serve on. Specifying a path will cause hostname and port arguments to be ignored.)r:z,'entry-func' not in 'module:function' syntax.z#relative module names not supportedzunable to import z: zmodule z has no attribute AF_UNIXz=file system paths not supported by your operating environment)r)rrrzStopped )r)r add_argumentintparse_known_argsr partitionerror startswithr ImportErrorgetattrAttributeErrorrhasattrsocketr basicConfigrrhostnamerexit) r arg_parserargs extra_argvmod_str_func_strmoduleexfuncrs rmainr*s4=J H   A    =   5 "2248D* ??44S9GQ 7GH#>?>w'Nvx(  yyWVY%? N  gmm, z C Cdmm$))$))DOOKO(# >,WIRt<==> N77+-?|LMNs* F F. F+ F&&F+. GG__main__)rrrrsyswarningsargparsercollections.abcr contextlibr functoolsr importlibrtypingrr r TypingIterabler r r rrrweakrefrabcrhelpersrlogrtypedefsrweb_apprrweb_exceptionsrrrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9r:r;r<r=r>r?r@rArBrCrDrErFrGrHrIrJrKrLrMrNrOrPrQrRrSweb_fileresponserTweb_logrUweb_middlewaresrVrW web_protocolrXrYrZ web_requestr[r\r] web_responser^r_r`ra web_routedefrbrcrdrerfrgrhrirjrkrlrmrnro web_runnerrprqrrrsrtrurvrwrx web_serverryweb_urldispatcherrzr{r|r}r~rrrrrrweb_wsrrr__all__sslrrfilterwarningsr HostSequencer LOG_FORMATrrLoggerboolrAbstractEventLooprrr__name__rrrr;s #$#   %%M<<<<<<<<<<<<<<<<z;!      )     @ F +;DIc" 04<@JN"#(,+03?)44+8$(!%!&%^ {Ik22 3^ 5l*+ ,^ 3- ^ .2D8 9 ^ 5v}}(EEF G ^^^*%^ HY' (^^/0^^(^^ D>!^"#^$%^& '^B&'/6/H/H 604<@JN"#(,+03?)44+8$(!%!&04'? {Ik22 3? 5l*+ ,? 3- ? .2D8 9 ? 5v}}(EEF G ???*%? HY' (??/0??(?? D>!?"#?$%?& 7,, -'?( )?D:)tCy:)T:)z z!"C JsL88MM