f[nddlZddlZddlZddlZddlmZddlmZddlm Z ddl m Z ddl mZddlmZmZmZmZmZmZmZmZmZmZmZddlZddlZdd lmZmZdd l m!Z!dd l"m#Z#m$Z$dd l m%Z%m&Z&m'Z'm(Z(m)Z)dd l*m+Z+m,Z,ddl-m.Z.m/Z/ddl0m1Z1ddl2m3Z3ddl4m5Z5ddl6m7Z7ddl8m9Z9m:Z:dZ;erddlee7gee:fZ?e(dde'iiddddejd ZAGddeBZCGddeBZDejddd Gd!d"ZFeee(eFfe/fZGGd#de!ZHy)$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/TFceZdZdZy)r)zPayload parsing error.N__name__ __module__ __qualname____doc__S/opt/lhia/ganansol/python/venv/lib/python3.12/site-packages/aiohttp/web_protocol.pyr)r)Ns r5r)ceZdZdZy)r*z-Payload was accessed after response was sent.Nr/r4r5r6r*r*Rs7r5r*) auto_attribsfrozenslotsc,eZdZUeed<eed<eed<y)_ErrInfostatusexcmessageN)r0r1r2int__annotations__ BaseExceptionstrr4r5r6r<r<Vs K  Lr5r<c!leZdZdZdZdZddeeeejddddd d dd d d dde jde de dedeededede dededede dede de f fdZdefd Zede fd!ZdFd"ee dd#fd$Zd%e j2dd#ffd& Zd'eedd#ffd( Zd)edd#fd*ZdGd+Zd,e dd#fd-Z!d.e dd#fd/Z"dGd0Z#dGd1Z$d2e%d3e&d4e dd#fd5Z'd6ed7edd#fd8Z(d6ed7edd#fd9Z)dGd:Z*d2e%d;e dZ/d2e%d?e&d;e de fd@Z0 dHd2e%dAed'eedBeede&f dCZ1dDe2de+e%ge,e&ffdEZ3xZ4S)Ir(ajHTTP 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_handler_waiter_waiter _task_handler_upgrade_payload_parser_request_parser_reading_pausedloggerdebug access_logr_close _force_close_current_request_timeout_ceil_thresholdgR@TFiig$@i)keepalive_timeoutr"rXaccess_log_classrZaccess_log_formatrY max_line_size max_headersmax_field_sizelingering_time read_bufsizeauto_decompresstimeout_ceil_thresholdmanagerr+loopr`r"rXrarZrbrYrcrdrerfrgrhric rt||d|_d|_d|_||_|j |_|j|_ ||_ d|_ d|_ ||_ t| |_t!|_d|_d|_d|_d|_d|_d|_t1|||| | | t2||_d|_ t||_||_| |_||_ |r||||_!nd|_!d|_"d|_#y#t8t:f$rYMwxYw)NrFgr5)rcrerdpayload_exceptionrhr_)$super__init__rErFr]rGrequest_handlerrHrequest_factoryrIrJrKrLrMfloatrNrrOrPrRrQrSrTrUrr)rVr^ TypeError ValueErrorrXrYrZrr[r\)selfrjrkr`r"rXrarZrbrYrcrdrerfrgrhri __class__s r6rozRequestHandler.__init__sR( 7;*1 ;B;R;R;B;R;R+";?"3$^4*/' 7; ?C;? $( connected disconnected)formatrvr0 transportrus r6__repr__zRequestHandler.__repr__s; NN # #>>5K  ;I  r5c|jSN)rMr}s r6r`z RequestHandler.keepalive_timeouts&&&r5timeoutNc|Kd|_|j|jj|jr|jj|jit t jt j5t|4d{|jd{dddd{dddt t jt j5t|4d{|j-|jjt j|j.|jjs|jd{dddd{ddd|j|jj|j"|jjd|_yy7N7=70#1d{7swYAxYw#1swYFxYw777#1d{7swYxYw#1swYxYww)zDo worker process exit preparations. We need to clean up everything and stop accepting requests. It is especially important for keep-alive connections. TN)r\rLcancelrRrQrasyncioCancelledError TimeoutErrorrr]_cancelrSdoner|close)rurs r6shutdownzRequestHandler.shutdowns !  ! ! -  " " ) ) + << LL   !    +'00'2F2FG /'0//....// /g,,g.B.B C -#G, - -((4))11'2H2H2JK%%1$:L:L:Q:Q:S,,,,  - - -    )    % % ' >> % NN "!DN &/.//// / /  - -  - - - - - -sBH< HG(HG1.G+/G13 H>G.?H0H<3H0HH0A/H6H7H; H0HH0 AH<(H+G1.H1H 7G:8H ?HH H<H0HH0H- !H$"H- )H00H95H<r|c6t||ttj|}|j r t ||jj|j|_ |jJ|jj||yr) rnconnection_maderr TransportrJr"_loop create_taskstartrSrG)rur|real_transportrvs r6rzRequestHandler.connection_made!st  *g//;    . )!ZZ33DJJLA}}((( %%dN;r5r>c|jy|jj||t|||jj}d|_d|_d|_d|_d|_|j|jj|j(| td}|jj||j|jj|r&|j|jjd|_|j"|jj!d|_yy)NTzConnection lost)rGconnection_lostrnhandler_cancellationr\rIrHrVrLrr]ConnectionResetErrorrrRrSrUfeed_eof)rur>rrvs r6rzRequestHandler.connection_lost,s% ==  %%dC0 $ $}}AA   $ $#  ! ! -  " " ) ) +  ,{*+<=  ! ! ) )# . << # LL   ! D$6$6$B    % % '!    +  ) ) +#'D  ,r5parserc|jJ||_|jr-|jj|jd|_yy)Nr5)rUrP feed_data)rurs r6 set_parserzRequestHandler.set_parserPsL##+++%     * *4+=+= >!$D  r5cyrr4r}s r6 eof_receivedzRequestHandler.eof_receivedZs r5datac |js |jry|j|js|jJ |jj |\}}}|xsdD]7\}}|xjdz c_ |jj||f9|j}|r#|!|js|jd||_|r |r||_yyy|j$|jr|r|xj |z c_y|r2|jj |\} }| r|j#yyy#t $r.}td||jtfg}d}d}Yd}~d}~wwxYw)Ni)r=r>r?Fr5r4r)r\r[rUrTrVrrr<r?r rErOappendrRr set_resultrPr) rurmessagesupgradedtailr>msgpayloadwaitereofs r6 data_receivedzRequestHandler.data_received]sv        ' ''3 33 +/+?+?+I+I$+O((D!)B 6 W##q(#%%sGn5 6\\FF.v{{}!!$'$DMD%)"!x ! ! )dmm   $ & ,,66t> % NN "!DN &r5requestresponsetimec|j9|jj|||jj|z yyr)rlogrr)rurrrs r6 log_accesszRequestHandler.log_accesss=    )    " "7Hdjjoo6G$6N O *r5argskwcV|jr|jj|i|yyr)rYrXrurrs r6 log_debugzRequestHandler.log_debugs' :: DKK  t *r * r5c<|jj|i|yr)rX exceptionrs r6 log_exceptionzRequestHandler.log_exceptions t*r*r5cF|js |jsy|j|jz}|jr.|j j |kDr|jy|j j|j|j|_ yr) r\rFrKrMrRrrr call_laterKEEPALIVE_RESCHEDULE_DELAY_process_keepaliverL)runexts r6rz!RequestHandler._process_keepalives   DOO ##d&=&== <<zz 4'  ""&!6!6  + +  # #" r5 start_timerpctK|jj|_ ||_||d{}d|_ t |ddrt j dt|j|||d{}|jj!d||fS7m#d|_wxYw71#t$r(}|}|j|||d{7}Yd}~[d}~wtj$rtj$rK}|jd||j|d}|j|||d{7}Yd}~d}~wt$r:}|j|d|}|j|||d{7}Yd}~ d}~wwxYw#|jj!dwxYww)N__http_exception__Fzlreturning HTTPException object is deprecated (#2415) and will be removed, please raise the exception insteadzRequest handler timed out.exc_infoi)r create_futurerQr]getattrwarningswarnDeprecationWarningfinish_responser#rrrr handle_error Exceptionr)rurrrprespresetr>s r6_handle_requestzRequestHandler._handle_requests $zz779 2 -(/%,W55(,%t159 9' ..wjIIE  + +D 1U{;6(,%.J- JD..wjIIIE%%  ## J NN7#N F$$Wc2D..wjIIIE J$$Wc37D..wjIIIE J  + +D 1s F8B&B$B&B4=FB2FF8$B&& B//B42F4 F=C CC F )F ;EEE F F)FFF FFFF55F8cK|j}|j}|J|j}|J|j}d}|jJ|j J|j s|js2 |j|_ |jd{ d|_ |jj\}}|j}|xjdz c_t||} t!|t"r|j%|} t&}n |j } |j |||| |} |jj)|j+| || } | d{\}} ~ | r|j/d |j0||j/dn|j s|j2rc|j4sW|e|jj}||_|j87|j;||z|j<|_nnt?|j@|_|jCs)|jD}|j s|r|j/d||j}||z}tGtjHtj5|jCsj||kretK||z 4d{|jMd{dddd{|j}|jCs||kreddd|jCs-|j s!|j/d|jOtQ|tS|j0||j/dny|j sm|j2r`|j4sT|S|jj}||_|j8&|j;||z|j<|_nn|j s|j s/d|_|j0|j0jOyyy7#tj$r Yd|_ [wxYw#d|_ wxYw76#tjt,f$r|j/dY|j0||j/d|j r|j2rd|j4sX||jj}||_|j8|j;||z|j<|_68wxYw77z7m#1d{7swY~xYw#1swY]xYw#tj$r|j/dY|j0||j/d|j r|j2re|j4sY||jj}||_|j8|j;||z|j<|_-/tT$r:}|jVr|jYd | |j[Yd}~d}~wt\$r.}|jYd | |j[Yd}~Hd}~wwxYw#|j0||j/dw|j sr|j2rb|j4sV|S|jj}||_|j8%|j;||z|j<|_wwwYHwxYww) 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)/rrSrGrMrIrHr\rOrrRrrpopleftrrequests_countr isinstancer<_make_error_handlerERRORrrConnectionErrorrr|rFr[rKrLcall_atrboolris_eofrNrrrreadanyrrr* RuntimeErrorrYrrr)rurkhandlerrjr`rr?rrwriterrprtaskrnowrfend_tr>s r6rzRequestHandler.startszz$$"""--""" 33$$000$$000##>>(#'#5#5#7DL,,&&$(DL#~~557 GWIIKE  " "a ' "!$-F'8,"&":":7"C"&"7"7++GWdFGTGE zz--((%I(,*KD% NN#MNR>>)d.>NN#LM**t{{,8"&**//"3C36D0#55=9=$'*;$;T=T=T:" 6g#'t"7~~'%)%9%9N,,E~#iik #n 4%g&:&:G>+D4E4E'=> g'9';<>>)d.>NN#LM**t{{,8"&**//"3C36D0#55=9=$'*;$;T=T=T:" 6}##B  !%D ~~)$$&*!y'--#'DL$(DL,#-..@NN#KL^>>)d.>NN#LM**t{{,8"&**//"3C36D0#55=9=$'*;$;T=T=T:" 6}4!<$;!<!<!<!<22)) HI>>)d.>NN#LM**t{{,8"&**//"3C36D0#55=9=$'*;$;T=T=T:" 6+  #::&&'Ds&S  "" #""#83"G  "" #>>)d.>NN#LM**t{{,8"&**//"3C36D0#55=9=$'*;$;T=T=T:" 6 >9+sA0^3$Q8Q5Q8B^<,V!)R'.R$/R'6V! B^*BV!>(V&U5'V*U>>U8?U> VU;)V9AV!B%^9<^5Q88R R ^RR R!!^$R''*U2V!,^?^-^ (^1U22V!5V8U>;V>V VV VVV!!$[["-^5^-^(^([0/Z%["% [1#[["[[""B^>^^^rc>K|j|jZ|jjdd|_|jr,|jj |jd|_ |j } ||d{|jd{|j|||y#t$r(| tdtdj|wxYw7d7N#t$r|j|||YywxYww)aPrepare 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. NFr5z+Missing return statement on request handlerz7Web-handler should return a response instance, got {!r}T) _finishrV set_upgradedrTrPrprepareAttributeErrorrr{ write_eofrr)rurrr prepare_meths r6rzRequestHandler.finish_responsecs     +  - -e 4!DM!!$$..t/A/AB%(" <Traceback: 
z
zV{title}

{title}

{msg} )titlerz )r=text content_type)rr output_sizerrINTERNAL_SERVER_ERRORr{ descriptionrYrr traceback format_excheadersget html_escaper&r) rurr=r>r?ctrrtbrs r6rzRequestHandler.handle_errors< 3cB >> % % )!)   Z55 5*11*2R2RSE22>>CBzzi(0"--/B0goo11(B??$RB6rd&AC0&u#&.  !C&.3.vG"E  -00s #D33D<err_infoc0dtdtffd }|S)NrrwcpKj|jjjSwr)rr=r>r?)rrrus r6rz3RequestHandler._make_error_handler..handlers1$$(,,8H8H s36)r%r')rurrs`` r6rz"RequestHandler._make_error_handlers ; >  r5)g.@)rwN)rNN)5r0r1r2r3r __slots__rr$r LOG_FORMATrAbstractEventLooprrrrrrrCr@ror~propertyr`r r BaseTransportrrBrr rrbytesrrrrr%r'rrrrr r rrrrrr<r __classcell__)rvs@r6r(r(`s %N"#IF$("&7C*!-!8!8! " $! $()%I"I"'' I" ! I"  I"I"34I"I"I"I"I"I"I"I" !I""#I"$!&%I"V # '5''""huo""""H <)>)> <4 <"(8M#:"(t"(H%%% %%%D%N*d*t*""P"P.<PDIP P +s+#+$++3+c+d+ &'''";->1J"JK ' ~t# $ 'Rw'r$"$*8$FK$ $R'+!% 111m $ 1 # 1  1f  ;->!:: ;r5)Irasyncio.streamsrr 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(r4r5r6rsO&     ;'0.0&)!$2 I"  K=)N*CCD    DHHSM !)!88T$d34 ((23\A Bd \d r5