bCiZrSSKrSSKrSSKrSSKrSSKJr SSKJr SSKJ r SSK J r SSK Jr SSKJrJrJrJrJrJrJrJrJrJrJr SSKrSSKrSS KJrJr SS K J!r! SS K"J#r#J$r$ SS K J%r%J&r&J'r'J(r(J)r) SS K*J+r+J,r, SSK-J.r.J/r/ SSK0J1r1 SSK2J3r3 SSK4J5r5 SSK6J7r7 SSK8J9r9J:r: Sr;\(aSSK\\7/\\:4r?\("SS\'00SSSS\R"S55 rA"SS\B5rC"SS\B5rD\R"SSSS 9"S!S"55rF\\\(\F4\/4rG"S#S\!5rHg)$N)deque)suppress)escape) HTTPStatus)Logger) TYPE_CHECKINGAny AwaitableCallableDequeOptionalSequenceTupleTypeUnioncast)AbstractAccessLoggerAbstractStreamWriter) BaseProtocol) ceil_timeout set_exception)HttpProcessingErrorHttpRequestParser HttpVersion10RawRequestMessage StreamWriter) access_logger server_logger) EMPTY_PAYLOAD StreamReader) tcp_keepalive) HTTPException) AccessLogger) BaseRequest)ResponseStreamResponse)RequestHandlerRequestPayloadErrorPayloadAccessError)Serverr(zasyncio.Task[None]UNKNOWN/TFc\rSrSrSrSrg)r)NzPayload parsing error.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__r0N/home/james-whalen/.local/lib/python3.13/site-packages/aiohttp/web_protocol.pyr)r)Ns r8r)c\rSrSrSrSrg)r*Rz-Payload was accessed after response was sent.r0Nr1r0r8r9r*r*Rs7r8r*) auto_attribsfrozenslotsc4\rSrSr%\\S'\\S'\\S'Srg)_ErrInfoVstatusexcmessager0N) r2r3r4r5int__annotations__ BaseExceptionstrr7r0r8r9r@r@Vs K  Lr8r@c!^\rSrSrSrSrSrSS\\\ \RSSS SS S SS S .SSS\ RS\ S\S\S\\S\S\S\S\S\S\S\ S\S\S\ 4 U4SjjjrS \4S!jr\S \ 4S"j5rSHS#\\ S S$4S%jjrS&\ R4S S$4U4S'jjrS(\\S S$4U4S)jjrS*\S S$4S+jrSIS,jr S-\!S S$4S.jr"S/\S S$4S0jr#SIS1jr$SIS2jr%S3\&S4\'S5\ S S$4S6jr(S7\S8\S S$4S9jr)S7\S8\S S$4S:jr*SIS;jr+S3\&S<\ S=\,\&/\-\'4S \.\'\44S>jr/SIS?jr0S3\&S@\'S<\ S \4SAjr1SJS3\&SB\S(\\SC\\S \'4 SDjjr2SE\3S \,\&/\-\'44SFjr4SGr5U=r6$)Kr(`aHTTP protocol implementation. RequestHandler handles incoming HTTP request. It reads request line, request headers and request payload and calls handle_request() method. By default it always returns with 404 response. RequestHandler handles errors in incoming request, like bad status line, bad headers or incomplete payload. If any error occurs, connection gets closed. keepalive_timeout -- number of seconds before closing keep-alive connection tcp_keepalive -- TCP keep-alive is on, default is on debug -- enable debug mode logger -- custom logger object access_log_class -- custom class for access_logger access_log -- custom logging object access_log_format -- access log format string loop -- Optional event loop max_line_size -- Optional maximum header line size max_field_size -- Optional maximum header field size max_headers -- Optional maximum header size timeout_ceil_threshold -- Optional value to specify threshold to ceil() timeout values r)_request_count _keepalive_manager_request_handler_request_factory_tcp_keepalive_keepalive_time_keepalive_handle_keepalive_timeout_lingering_time _messages _message_tail_waiter _task_handler_upgrade_payload_parser_request_parser_reading_pausedloggerdebug access_logr_close _force_close_current_request_timeout_ceil_thresholdgR@TFiig$@i)keepalive_timeoutr"r]access_log_classr_access_log_formatr^ max_line_size max_headersmax_field_sizelingering_time read_bufsizeauto_decompresstimeout_ceil_thresholdmanagerr+looprer"r]rfr_rgr^rhrirjrkrlrmrnc \>[TU]U5 SUlSUlSUlXlUR UlURUl X@l SUl SUl X0l [U 5Ul[!5UlSUlSUlSUlSUlSUl[/UUUU U U [0US9UlSUl[U5UlXPlXlXplU(aU"Xx5Ul OSUl SUl!SUl"g![6[84a NOf=f)NrFgr8)rhrjripayload_exceptionrmrd)#super__init__rKrLrbrMrequest_handlerrNrequest_factoryrOrPrQrRrSfloatrTrrUrVrWrXrYrZrr)r[rc TypeError ValueErrorr]r^r_rr`ra)selfrorprer"r]rfr_rgr^rhrirjrkrlrmrn __class__s r9rtRequestHandler.__init__s;( 7;*1 ;B;R;R;B;R;R+";?"3$^4*/' 7; ;? $( connected disconnected)formatr{r2 transportrzs r9__repr__RequestHandler.__repr__s; NN # #>>5K  ;I  r8cUR$N)rSrs r9re RequestHandler.keepalive_timeouts&&&r8timeoutNcl# SUlURbURR5 UR(aURR5 [ [ R [ R5 [U5IShvN URb.URR[ R "55 URb3URR5(dURIShvN SSS5IShvN SSS5 URbURR5 URb"URR5 SUl ggNNuNg!,IShvN (df  N|=f!,(df  N=f7f)zDo worker process exit preparations. We need to clean up everything and stop accepting requests. It is especially important for keep-alive connections. TN)rarRcancelrWrasyncioCancelledError TimeoutErrorrrb_cancelrXdonerclose)rzrs r9shutdownRequestHandler.shutdowns5 !  ! ! -  " " ) ) + << LL   !g,,g.B.B C#G,,((4))11'2H2H2JK%%1$:L:L:Q:Q:S:S,,,, -,D    )    % % ' >> % NN "!DN &- - -,,,D CszBF4F#FF#A7F FF  F#F F#$AF4F#F F# F F F F## F1-F4rc@>[TU]U5 [[RU5nUR (a [ U5 URRUR55Ul URceURRX5 gr) rsconnection_maderr TransportrPr"_loop create_taskstartrXrM)rzrreal_transportr{s r9rRequestHandler.connection_madesr  *g//;    . )!ZZ33DJJLA}}((( %%d;r8rCc>URcgURRX5 [TU]U5 URRnSUlSUlSUlSUlSUlURbURR5 URb)Uc [S5nURRU5 URbURR5 U(a'URbURR5 SUlURb"URR!5 SUlgg)NTzConnection lost)rMconnection_lostrshandler_cancellationrarOrNr[rRrrbConnectionResetErrorrrWrXrZfeed_eof)rzrCrr{s r9rRequestHandler.connection_lost%s# ==  %%d0 $ $}}AA   $ $#  ! ! -  " " ) ) +  ,{*+<=  ! ! ) )# . << # LL   ! D$6$6$B    % % '!    +  ) ) +#'D  ,r8parsercURbeXlUR(a-URRUR5 SUlgg)Nr8)rZrV feed_data)rzrs r9 set_parserRequestHandler.set_parserIsJ##+++%     * *4+=+= >!$D  r8cgrr0rs r9 eof_receivedRequestHandler.eof_receivedSs r8datac|UR(dUR(agURcUR(dURceURR U5up#nU=(d SH6upgU=RS- sl URRXg45 M8 URnU(a)Ub&UR5(dURS5 X0lU(aU(aX@lgggURc.UR(aU(aU=R U- slgU(a6URR U5upU (aUR#5 ggg![ a*n[SXURS9[4/nSnSnSnAGNFSnAff=f)Ni)rBrCrDFr8r0r)rar`rZrYr[rrr@rDr rKrUappendrWr set_resultrVr) rzrmessagesupgradedtailrCmsgpayloadwaitereofs r9 data_receivedRequestHandler.data_receivedVsg        ' ''3 33 +/+?+?+I+I$+O(D!)B ##q(#%%sn5!/\\FF.v{{}}!!$'$MD%)"!x ! ! )dmm   $ & ,,66t> % NN "!DN &r8requestresponsetimecURb8URRXURR5U- 5 ggr)rlogrr)rzrrrs r9 log_accessRequestHandler.log_accesss;    )    " "7djjoo6G$6N O *r8argskwc`UR(aURR"U0UD6 ggr)r^r]rzrrs r9 log_debugRequestHandler.log_debugs% :: KK  t *r * r8c<URR"U0UD6 gr)r] exceptionrs r9 log_exceptionRequestHandler.log_exceptions t*r*r8cfUR(dUR(dgURUR-nUR(a/UR R 5U:aUR5 gUR RURUR5Ul gr) rarLrQrSrWrrr call_laterKEEPALIVE_RESCHEDULE_DELAY_process_keepaliverR)rznexts r9r!RequestHandler._process_keepalives   DOO ##d&=&== <<zz 4'  ""&!6!6  + +  # #" r8 start_timeruc# URceXlU"U5IShvN nSUl[USS5(a[R"S[ 5 UR XU5IShvN nXE4$NV!SUlf=fN![a)nUnUR XU5IShvN nSnAXE4$SnAf[Ra e[RaInURSUS9 URUS5nUR XU5IShvN nSnAXE4$SnAf[a:nURUSU5nUR XU5IShvN nSnAXE4$SnAff=f7f)N__http_exception__Fzlreturning HTTPException object is deprecated (#2415) and will be removed, please raise the exception insteadzRequest handler timed out.exc_infoi)rNrbgetattrwarningswarnDeprecationWarningfinish_responser#rrrr handle_error Exception)rzrrrurespresetrCs r9_handle_requestRequestHandler._handle_requests $$000 J -(/%,W55(,%t1599 9' ..wjIIE{76(,%.J- JD..wjIIIE,{+%%  ## J NN7#N F$$Wc2D..wjIIIE { J$$Wc37D..wjIIIE{ JsE3A>A<A>B AE34B 5E3<A>> BB E3 E0B:-B0.B:3E3:+E0%7D)DD)"E3) E06(E+E!E+$E3+E00E3c~# URnURnUceURnUceURnSnURceUR ceUR (Gd,UR(d2UR5Ul URIShvN SUl URR5upgUR5nU=RS- sl[X5n [!U["5(aUR%U5n [&nO UR n UR XgX U5n URR)UR+XU 55n U IShvN up]A U (aUR/S5 UR0cUbUR/S5 GOUR (GdUR2(ajUR4(dYUbTURR5nXlUR8c%UR;X-UR<5UlGORGOPGONGOL[?UR@5UlURC5(GdIURDnUR (dU(aUR/SU5 UR5nX-n[G[RH[R5 URC5(drUU:al[KUU- 5IShvN URM5IShvN SSS5IShvN UR5nURC5(dUU:aMlSSS5 URC5(d2UR (d!UR/S5 URO5 [QU[S55 UR0cUbUR/S5 OUR (dwUR2(aeUR4(dTUbPURR5nXlUR8c#UR;X-UR<5UlOOUR (dGM,UR (d0SUlUR0bUR0RO5 gggGN8![Ra SUl Mcf=f!SUl f=fGN![R[,4a UR/S5 UR0cUbUR/S5 MUR (aMUR2(amUR4(d\UbVURR5nXlUR8c&UR;X-UR<5UlGMPGMSGMVGMYf=fGNGNGN!,IShvN (df  GN=f!,(df  GN=f![Ra UR/S5 UR0cUbUR/S5 GMUR (aGMUR2(amUR4(d\UbVURR5nXlUR8c&UR;X-UR<5UlGMiGMlGMoGMr[Ta<nURV(aURYS US 9 UR[5 SnAGNqSnAf[\a+nURYS US 9 UR[5 SnAGNSnAff=f!UR0cUbUR/S5 fUR (d}UR2(agUR4(dVUbRURR5nXlUR8c$UR;X-UR<5Ulfff GMf=f7f) a/Process incoming request. It reads request line, request headers and request payload, then calls handle_request() method. Subclass has to override handle_request(). start() handles various exceptions in request or response handling. Connection is being closed always unless keep_alive(True) specified. Nrz&Ignored premature client disconnectionz'Ignored premature client disconnection.z(Ignored premature client disconnection 2z'Start lingering close timer for %s sec.zUncompleted request.z'Ignored premature client disconnection zUnhandled runtime exceptionrzUnhandled exception)/rrXrMrSrOrNrarU create_futurerWrrpopleftrrequests_countr isinstancer@_make_error_handlerERRORrrConnectionErrorrrrLr`rQrRcall_atrboolris_eofrTrrrreadanyrrr* RuntimeErrorr^rrr)rzrphandlerrorerrDrrwriterrurtaskrnowrkend_trCs r9rRequestHandler.startszz$$"""--""" 33$$000$$000###>>(#'#5#5#7DL,,&&$(DL#~~557 GIIKE  " "a ' "!$-F'8,,"&":":7"C"&"7"7++GdGTGE zz--((I(,*KD NN#MNR>>)d.>NN#LM***t{{,8"&**//"3C360#55=9=$'$;T=T=T:" 6 >9g#'t"7~~''%)%9%9N,,E~#iik # 4%g&:&:G>++D4E4E'=> g'9';<>>)d.>NN#LM**t{{,8"&**//"3C360#55=9=$'$;T=T=T:" 6+g###B  !%D ~~)$$&*!y'--#'DL$(DL,#-..@NN#KL^>>)d.>NN#LM***t{{,8"&**//"3C360#55=9=$'$;T=T=T:" 6 >9}4,E$;,E+D+D+DTS)) HI>>)d.>NN#LM***t{{,8"&**//"3C360#55=9=$'$;T=T=T:" 6 >9+  #::&&'Ds&S  "" #""#83"G  "" #>>)d.>NN#LM**t{{,8"&**//"3C360#55=9=$'$;T=T=T:" 6 >9+sA>`=$S %S&S +B`= +X.7T<T=TX.2`=A=`=B"X.1.XW8 X#X7W;8X< XW>/X9A#X.B<`=A`=S S?4T5 `=>S??T T  `=T+W5<X.=2`=3B`=4W55X.8X;X>XX X  X X X+&X..%^^3`= B`= ^1] ^ ^ ^:^^^B-`:5`=9`::`=rc,# URb_URRS5 SUlUR(a,URR UR5 SUlUR nU"U5IShvN UR5IShvN URXU5 g![ a) Uc [S5e[SRU55ef=fNeNO![a URXU5 gf=f7f)zPrepare the response and write_eof, then log access. This has to be called within the context of any exception so the access logger can get exception information. Returns True if the client disconnects prematurely. NFr8z+Missing return statement on request handlerz7Web-handler should return a response instance, got {!r}T) r[ set_upgradedrYrVrprepareAttributeErrorrr write_eofrr)rzrrr prepare_meths r9rRequestHandler.finish_responseZs    +  - -e 4!DM!!$$..t/A/AB%(" <Traceback: 
z
zV{title}

{title}

{msg} )titlerz )rBtext content_type)rr output_sizerrINTERNAL_SERVER_ERRORr descriptionr^rr traceback format_excheadersget html_escaper&r) rzrrBrCrDctrrtbrs r9rRequestHandler.handle_errors1 3cB >> % % )!)   Z55 5*11*2R2RSE22>>CBzzi("--/B)goo11(B??$RB6rd&AC0&u&.  !C&.3.v"E  -)(s 'D<< E err_infoc4^^S[S[4UU4SjjnU$)Nrr}cp># TRUTRTRTR5$7fr)rrBrCrD)rrrzs r9r3RequestHandler._make_error_handler..handlers0$$(,,8H8H s36)r%r')rzrrs`` r9r"RequestHandler._make_error_handlers" ; >   r8)r`rbrarLrRrQrSrTrMrVrUrZrKrOrNr[rXrPrcrYrWr_rr^r]r)g.@)r}N)rNN)7r2r3r4r5r6r __slots__rr$r LOG_FORMATrAbstractEventLooprwrrrrrHrErtrpropertyrer r BaseTransportrrGrr rrbytesrrrrr%r'rrrrr r rrrrrr@rr7 __classcell__)r{s@r9r(r(`s%N"#ID$("&7C*!-!8!8! " $! $()%H"H"'' H" ! H"  H"H"34H"H"H"H"H"H"H"H" !H""#H"$!&%H"H"T # '5''"huo""> <)>)> <4 <"(8M#:"(t"(H%%% %%%D%N*d*t*""P"P.<PDIP P +s+#+$++3+c+d+ &%%%";->1J"JK % ~t# $ %Nw'r#"#*8#FK# #P'+!% 111m $ 1 # 1  1f  ;->!:: ;r8)Irasyncio.streamsr r collectionsr contextlibrhtmlrrhttprloggingrtypingrr r r r r rrrrrattryarlabcrr base_protocolrhelpersrrrrrrrrrrstreamsr r! tcp_helpersr"web_exceptionsr#web_logr$ web_requestr% web_responser&r'__all__ web_serverr+_RequestFactory_RequestHandlerURLrrr)r*sr@_MsgTyper(r0r8r9r8sK&     ;'0.0&)!$2 I"  K=)N*CCD   HHSM !)!88T$d34 ((23\A BZ \Z r8