DjkddlZddlZddlZddlZddlZddlmZddlmZm Z m Z ddl m Z ddl mZddlmZddlmZddlmZmZmZmZddlZddlZdd lmZd d lmZmZd d l m!Z!d d l"m#Z#m$Z$d dlm%Z%m&Z&m'Z'm(Z(m)Z)m*Z*d dl+m,Z,d dl-m.Z.m/Z/d dl0m1Z1m2Z2d dl3m4Z4d dl5m6Z6m7Z7d dl8m9Z9d dl:m;Z;d dlZ>dZ?er ddl@Z@d dlAmBZBe e(e2dedge;fZCe e;gee>fZDe(dde'iiddddejEd ZFGdd eGZHGd!d"eGZIeIZJejKddd#Gd$d%ZLeMe(eLze2fZNGd&de!ZOdS)'N)deque) AwaitableCallableSequence)suppress)escape) HTTPStatus)Logger) TYPE_CHECKINGAnyOptionalcast)under_cached_property)AbstractAccessLoggerAbstractStreamWriter) BaseProtocol)DEFAULT_CHUNK_SIZE ceil_timeout)HttpProcessingErrorHttpRequestParser HttpVersion10RawRequestMessage StreamWriterWebSocketReader) BadHttpMethod) access_logger server_logger) EMPTY_PAYLOAD StreamReader) tcp_keepalive) HTTPExceptionHTTPInternalServerError) AccessLogger) BaseRequest)ResponseStreamResponse)RequestHandlerRequestPayloadErrorPayloadAccessError)Serverr(zasyncio.Task[None]UNKNOWN/TFceZdZdZdS)r)zPayload parsing error.N__name__ __module__ __qualname____doc__S/home/lighthouse/health/venv/lib64/python3.11/site-packages/aiohttp/web_protocol.pyr)r)Is    r5r)ceZdZdZdS)r*z-Payload was accessed after response was sent.Nr/r4r5r6r*r*Ms7777r5r*) auto_attribsfrozenslotsc.eZdZUeed<eed<eed<dS)_ErrInfostatusexcmessageN)r0r1r2int__annotations__ BaseExceptionstrr4r5r6r<r<Ts. KKK  LLLLLr5r<c!eZdZdZdZddeeeejddddde dd d d d d e j de de dedeededede dededede dede de f fdZdefdZededfd Zedeeeeeefzeeefzd!zfd"Zedeeeeeefzeeefzd!zfd#Zede fd$ZdKd&e d!zdd!fd'Zd(e jdd!ffd) Zd*e d!zdd!ffd+ Z! dLd,e"d-e#gd!fd!zdd!fd.Z$dMd/Z%d0e&dd!fd1Z'd2e dd!fd3Z(dMd4Z)dMd5Z*d6e+d7e,d8e d!zdd!fd9Z-d:e.d;e.dd!fd<Z/d:e.d;e.dd!fd=Z0dMd>Z1d6e+d?e d!zd@e#e+ge2e,fdee,e ffdAZ3dMdBZ4d6e+dCe,d?e d!zdee,e ffdDZ5 dNd6e+dFed*e d!zdGed!zde,f dHZ6dIe7de#e+ge2e,ffdJZ8xZ9S)Or(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 )max_field_size max_headers max_line_size_request_count _keepalive_manager_request_handler_request_factory_tcp_keepalive_next_keepalive_close_time_keepalive_handle_keepalive_timeout_lingering_time _messages _message_tail_handler_waiter_waiter _task_handler_payload_parser_data_received_cbloggerdebug access_logr_close _force_close_current_request_timeout_ceil_threshold_request_in_progress_logging_enabled_cachei.TFig$@)keepalive_timeoutr!rYaccess_log_classr[access_log_formatrZrGrFrElingering_time read_bufsizeauto_decompresstimeout_ceil_thresholdmanagerr+looprer!rYrfr[rgrZrGrFrErhrirjrkc  t|||| | | t|}t||d|_d|_d|_||_|j|_ |j |_ | |_ | |_ | |_||_d|_d|_||_t'| |_t+|_d|_d|_d|_d|_d|_d|_d|_ t'||_n#t<t>f$rYnwxYw||_ | |_!||_"|r#||||_#|j#j$|_%nd|_#d|_%d|_&d|_'d|_(i|_)dS)N)rGrErFpayload_exceptionrjrFgr5rd)*rr)super__init__rHrIr^rJrequest_handlerrKrequest_factoryrLrGrFrErMrNrOrPfloatrQrrRrSrXrUrTrVrWr_ TypeError ValueErrorrYrZr[renabledrar\r]r`rb)selfrlrmrer!rYrfr[rgrZrGrFrErhrirjrkparser __class__s r6rqzRequestHandler.__init__s*#   ')#1+     v&&& 48'. 8?8O8?8O*&,+*-'8<"3$^44*/'' <@48 <@8<$(./$ +01G+H+HD ( (:&    D   $  *>N>N-??D %)$6$>D ! !!%D $)D ! !$)!&( s>DD'&D'returncTd|jj|jdndS)Nz<{} {}> connected disconnected)formatrzr0 transportrxs r6__repr__zRequestHandler.__repr__s0 N #>5KK>   r5zssl.SSLContextcH|jdn|jdS)zReturn SSLContext if available.N sslcontextrget_extra_infors r6 ssl_contextzRequestHandler.ssl_contexts+ ~% D..|<< r5NcH|jdn|jdS)zReturn peername if available.Npeernamerrs r6rzRequestHandler.peername +~% D..z:: r5cH|jdn|jdS)zReturn sockname if available.Nsocknamerrs r6rzRequestHandler.socknamerr5c|jSN)rPrs r6rez RequestHandler.keepalive_timeout!s &&r5.@timeoutclKd|_|j|j|jr|j|_ t|4d{V|jd{Vdddd{Vn#1d{VswxYwYnb#tj tj f$rDd|_tj dkr*tj x}r|rYnwxYw t|4d{V|j+|jtj |j8|jstj|jd{Vdddd{Vn#1d{VswxYwYn[#tj tj f$r=tj dkr*tj x}r|rYnwxYw|j|j|dS)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]rOcancelr`_loop create_futurerTrasyncioCancelledError TimeoutErrorsys version_info current_task cancellingr^_cancelrVdoneshield force_close)rxrtasks r6shutdownzRequestHandler.shutdown%sg !  ! -  " ) ) + + +  $ $(:#;#;#=#=D  '00////////........///////////////////////////*G,@A   '+$$//!(!5!7!770))0  #G,, = = = = = = = =(4)11'2H2J2JKKK%1$:L:Q:Q:S:S1!.);<<<<<<<<<  = = = = = = = = = = = = = = = = = = = = = = = = = = = &(<=    G++$1333T,OO%%,     )   % % ' ' ' soB%B3B BBBBAC65C6:F%A2FF% FF% F!F%%AG=<G=rct|ttj|}|jrt ||jJ|j|||j}tj dkr*tj | |d}n'| | }||_dS)Nr Trm eager_start)rpconnection_maderr TransportrMr!rJrrrTaskstart create_taskrV)rxrreal_transportrmrrzs r6rzRequestHandler.connection_madeWs  ***g/;;   * . ) ) )}((( %%dN;;;z  w & &< 4TJJJDD##DJJLL11D!r5r>cR|jdS|j|||jj}|t |d|_d|_d|_d|_|j|j |j +|td}|j ||r |j |j d|_ |j"|jd|_dSdS)NzConnection lost)rJconnection_losthandler_cancellationrrprLrK_parserrOrr^ConnectionResetErrorrrVrWfeed_eof)rxr>rrzs r6rzRequestHandler.connection_losths/ = F %%dC000 $}A  $$$ $ $  ! -  " ) ) + + +  ,{*+<==  ! ) )# . . .  (D$6$B   % % ' ' '!   +  ) ) + + +#'D  , +r5rydata_received_cbc|jJ||_||_|jr(|j|jd|_dSdS)Nr5)rWrXrS feed_data)rxryrs r6 set_parserzRequestHandler.set_parsers` #+++%!1   %  * *4+= > > >!$D    % %r5cdSrr4rs r6 eof_receivedzRequestHandler.eof_receiveds r5datac|js|jrdS|j|js|jJ |j|\}}}n:#t $r-}td||jtfg}d}d}Yd}~nd}~wwxYw|pdD]1\}}|xj dz c_ |j ||f2|j }|r+|)|s|d||_|r |r ||_dSdSdS|j|jr|r|xj|z c_dS|rP|j||j|\} }| r|dSdSdS)Ni)r=r>r?Fr5r4r)r]r\rW _upgradedrrrr<r?rrHrRappendrUr set_resultrSrXclose) rxrmessagesupgradedtailr>msgpayloadwaitereofs r6 data_receivedzRequestHandler.data_receiveds      F   ' '<+++ +/<+A+A$+G+G((DD&   Sc3;GGGW!  !)B 6 6 W##q(##%%sGn5555\F (F.v{{}}.!!$'''%DN *D *%)""" * * * * ! )dn ) )   $ &     %1&&(((,66t< % N " " "!DNNN & %r5requestresponsetimec|jrJ|jEtr|J|j|||j|z dSdSdSr)rarr logrr)rxrrrs r6 log_accesszRequestHandler.log_accesssp   PT%7%C ('''   " "7Hdjoo6G6G$6N O O O O O P P%C%Cr5argskwc<|jr|jj|i|dSdSr)rZrYrxrrs r6 log_debugzRequestHandler.log_debugs6 : + DK t *r * * * * * + +r5c*|jj|i|dSr)rY exceptionrs r6 log_exceptionzRequestHandler.log_exceptions" t*r*****r5c8d|_|js|jsdS|j}|}|j}||kr"|||j|_dS|jr/|j s| dSdSdSr) rOr]rIrrrNcall_at_process_keepaliverUrr)rxrmnow close_times r6rz!RequestHandler._process_keepalives!%   DO  Fziikk4   %)\\*d>U%V%VD " F <  1 1 3 3             r5 start_timerrcKd|_ ||_||d{V}d|_n #d|_wxYw t|ddrtjdt ||||d{V\}}n#t$r,}|}||||d{V\}}Yd}~nd}~wtj $rtj $rW}| d|| |d}||||d{V\}}Yd}~nQd}~wt$rA}| |d|}||||d{V\}}Yd}~nd}~wwxYwd|_|j|jdn.#d|_|j|jdwwxYw||fS) NT__http_exception__Fzlreturning HTTPException object is deprecated (#2415) and will be removed, please raise the exception insteadzRequest handler timed out.exc_infoi)r`r^getattrwarningswarnDeprecationWarningfinish_responser"rrrr handle_error ExceptionrTr)rxrrrrrespresetr>s r6_handle_requestzRequestHandler._handle_requests %)! 6 -(/%,_W55555555(,%%%,,,,%t1599  9' !% 4 4WdJ O OOOOOOOKD%%- P P PD $ 4 4WdJ O OOOOOOOKD%%%%%%%    # P P P NN7#N F F F$$Wc22D $ 4 4WdJ O OOOOOOOKD%%%%%% P P P$$Wc377D $ 4 4WdJ O OOOOOOOKD%%%%%% P).D %#/$//555).D %#/$//55550U{sa,B 5BA F# E7"B61F#6!E7A D)$F#) E767E2-F#2E77F##+Gc K|j}|j}|J|j}d}|jJ|jJ|js |js; ||_|jd{Vd|_n #d|_wxYw|j \}}|j r| nd}|xj dz c_ t||}t|tr||} t"}n|j} ||||||jpt'j|} || || } t,jdkrt'j| |d} n|| } | d{V\}} nK#t4$r>|dYd| _|j||dn[wxYw~ | r=|d d| _|j||dnt=|j|_ |!s|j"}|js-|r*|d || }||z} |!s||krtG||z 4d{V|$d{Vdddd{Vn#1d{VswxYwY| }|!s||kn[#t&j%t&j&f$r=t,jd kr*t'jx}r|'rYnwxYw|!s0|js)|d |(|)tTn#t&j%$r+|d|+tX$r5}|-d | |+Yd}~n&d}~wt\$r|+wxYwd| _|j||dn,#d| _|j||dwwwxYw|j rT|j/sM|jsF| |z}||_0|j1 |2||j3|_1nn|j |js)d|_|j|j(dSdSdS)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. NrrTrz&Ignored premature client disconnectionz'Ignored premature client disconnection.z(Ignored premature client disconnection 2z'Start lingering close timer for %s sec.rzUncompleted request.zUnhandled exceptionr)4rrJrPrLrKr]rRrrUpopleftrarrequests_countr isinstancer<_make_error_handlerERRORrVrrrrrrrConnectionErrorr_taskrboolrrIis_eofrQrreadanyrrrr set_exception_PAYLOAD_ACCESS_ERRORrrrrBr\rNrOrr)rxrmrlrerr?rrwriterrrrcororrrhrend_ttr>rs r6rzRequestHandler.start*sz-""" 3$000$000#p > ((#'#5#5#7#7DL,&&&&&&&#'DLL4DL''''#~5577 GW$(#8BDIIKKKdE  " "a ' " "!$--F'8,, 8"&":":7"C"C"&"7 ++"@g&:4&@&@ GC N++GUOLL#w.."<4TJJJDD++D11D(,******KD%%&NN#KLLLl!% >)d.>NN#LMMMu NN#MNNN`!% >)d.>NN#LMMM_#'t"7"7~~''%%)%9N,&&E~#iikk #n 4 &&-nn&6&623;;+7 +D+D!<!<!<!<!<!<!<!<*1//*;*;$;$;$;$;$;$;$;!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<'+iikk '.nn&6&623;; !( 68LM&&& # 0G ; ;*1*>*@*@%@Q!<$%LLNN!<!& &#>>++%D4E%'=>>> %%&;<<<<)   GHHH  """ # # #""#83"GGG  """"""""      """ !% >)d.>NN#LMMM!% >)d.>NN#LMMMM*.> t{ 4;L !YY[[+<< 2</)1-1\\"D$;..D*a#p f  '!%D ~)$$&&&&& ' '))s&A.. A7?AO4 F O4 G(?O4'G((O4+A/O42L: K:(L:: LL:L1L:9O4:ANO4NA!O43R24AR 6+Q&!R2&#R  R22)SrcK||jN|jdd|_|jr&|j|jd|_ |j}n|#t$ro||dn|d|t}t|j |j |j |j}|j}YnwxYw ||d{V|d{Vn+#t $r|||||dfcYSwxYw|||||dfS)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 handlerz3Web-handler should return a response instance, got )r=reasontextheadersT)_finishr set_upgradedrrSrprepareAttributeErrorrr#r&r=rrr write_eofrr)rxrrr prepare_methr>s r6rzRequestHandler.finish_responses  < # L % %e , , ,"DN! ) &&t'9:::%(" (Traceback: 
z
zz

z

z z )r=r content_type)rHrrrYrZremoterr output_sizerr INTERNAL_SERVER_ERRORvaluephrase descriptionrr traceback format_excrget html_escaper&r) rxrr=r>r?cttitlertbrs r6rzRequestHandler.handle_errors*  ! # # 3 (F(F # K  0'.3        0'.3     > % ) )!)   Z5 5 5!7=ii @`@giiE2>CBz 0i((00"-//B000000000000000go11(B????B$RBArAAAC1#11*/11111 !C&.3.vG"EEE  s%DD  D err_infoc4dtdtffd }|S)Nrr{cVK|jjjSr)rr=r>r?)rrrxs r6handlerz3RequestHandler._make_error_handler..handlers/$$(,8H r5)r%r')rxrr"s`` r6rz"RequestHandler._make_error_handlers< ; >        r5)rr)r{N)rNN):r0r1r2r3 __slots__rr$r LOG_FORMATrrAbstractEventLooprtrr typerrCr@rqrrr rtuplerrpropertyrer BaseTransportrrBrrrrrbytesrrrrr%r'rr rrrrrrrrr<r __classcell__)rzs@r6r(r(^s%%N IP$("&7C*!-!8!" $. $()'R)R)R)R)' R) ! R)R)R)34R)R)R)R)R)R)R) !R)"#R)$%R)&!&'R)R)R)R)R)R)h #     X&67     uS#sC'( (5c? :T A     uS#sC'( (5c? :T A    '5'''X'00edl0d0000d")>"4"""""""(=4#7(D((((((F7; % % %#2t8,t3 %  % % % %    '%'D''''R*d*t****""""""""P"P.<PDIDLP PPPP+s+#+$+++++3+c+d++++"))DL)";->1J"JK ) ~t# $ ))))VG'G'G'G'R'"'*8'FKdl' ~t# $''''X$(" <<<<T ! < t <  <<<<|  ;->!:: ;r5)Prasyncio.streamsrrr collectionsrcollections.abcrrr contextlibrhtmlrrhttpr loggingr typingr r r rattryarl propcacherabcrr base_protocolrhelpersrrrrrrrrhttp_exceptionsrrrrstreamsrr tcp_helpersr!web_exceptionsr"r#web_logr$ web_requestr% web_responser&r'__all__ssl web_serverr+_RequestFactory_RequestHandlerURLrrr)r*rsr<r'_MsgTyper(r4r5r6rIs 9999999999&&&&&&555555555555 ++++++;;;;;;;;''''''55555555+*****--------00000000&&&&&&BBBBBBBB!!!!!!$$$$$$22222222 I#JJJ""""""  K=)N*CCD    DHSMM  !!!!!)!!!88888888+*,,T$d33343 "X-|; <D D D D D \D D D D D r5