NgcddlZddlZddlZddlZddlZddlmZddlmZddl m Z ddl m Z ddlmZddlmZmZmZmZmZmZmZmZmZmZmZddlZddlZdd lmZm Z dd l!m"Z"dd l#m$Z$dd l m%Z%m&Z&m'Z'm(Z(m)Z)dd l*m+Z+ddl,m-Z-m.Z.ddl/m0Z0m1Z1ddl2m3Z3ddl4m5Z5m6Z6ddl7m8Z8ddl9m:Z:ddl;merddl?m@Z@ee(e1de dge:fZAee:gee=fZBe(dde'iiddddejCd ZDGddeEZFGdd eEZGeGZHejIddd!Gd"d#ZJeee(eJfe1fZKGd$de"ZLdS)%N)deque)suppress)escape) HTTPStatus)Logger) TYPE_CHECKINGAny AwaitableCallableDequeOptionalSequenceTupleTypeUnioncast)AbstractAccessLoggerAbstractStreamWriter) BaseProtocol) ceil_timeout)HttpProcessingErrorHttpRequestParser HttpVersion10RawRequestMessage StreamWriter) 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__P/var/www/html/ai-engine/env/lib/python3.11/site-packages/aiohttp/web_protocol.pyr*r*Ps    r6r*ceZdZdZdS)r+z-Payload was accessed after response was sent.Nr0r5r6r7r+r+Ts7777r6r+) auto_attribsfrozenslotsc.eZdZUeed<eed<eed<dS)_ErrInfostatusexcmessageN)r1r2r3int__annotations__ BaseExceptionstrr5r6r7r=r=[s. KKK  LLLLLr6r=c!eZdZdZdZddeeeejdddddd dd d d d de j de de de deede dede dededede dede de f fdZdefdZede fd ZdGd"ee dd#fd$Zd%e jdd#ffd& Zd'eedd#ffd( Zd)edd#fd*ZdHd+Zd,edd#fd-Z d.e dd#fd/Z!dHd0Z"dHd1Z#d2e$d3e%d4e dd#fd5Z&d6ed7edd#fd8Z'd6ed7edd#fd9Z(dHd:Z)d2e$d;e dZ.d2e$d?e%d;e de,e%e ffd@Z/ dId2e$dBed'eedCeede%f dDZ0dEe1de*e$ge+e%ffdFZ2xZ3S)Jr)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 )_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_upgrade_payload_parser_request_parser_reading_pausedloggerdebug access_logr_close _force_close_current_request_timeout_ceil_threshold_request_in_progressi.TFiig$@i)keepalive_timeoutr"rYaccess_log_classr[access_log_formatrZ max_line_size max_headersmax_field_sizelingering_time read_bufsizeauto_decompresstimeout_ceil_thresholdmanagerr,looprbr"rYrcr[rdrZrerfrgrhrirjrkc t|d|_d|_d|_||_|j|_|j|_ ||_ d|_ d|_ ||_ t| |_t!|_d|_d|_d|_d|_d|_d|_t1|||| | | t2||_d|_ t||_n#t8t:f$rYnwxYw||_| |_||_ |r||||_!nd|_!d|_"d|_#d|_$dS)NrFgr6)rergrfpayload_exceptionrjra)%super__init__rFrGr^rHrequest_handlerrIrequest_factoryrJrKrLrMrNfloatrOrrPrQrSrRrTrUrVrr*rWr_ TypeError ValueErrorrYrZr[rr\r]r`)selfrlrmrbr"rYrcr[rdrZrerfrgrhrirjrk __class__s r7rqzRequestHandler.__init__s*  7;*1 ;B;R;B;R+*-';?"3$^44*/'' 7; ?C;? $( connected disconnected)formatrxr1 transportrws r7__repr__zRequestHandler.__repr__s0 N #>5KK>   r6c|jSN)rNrs r7rbz RequestHandler.keepalive_timeouts &&r6.@timeoutNclKd|_|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]rMcancelr`_loop create_futurerRrasyncioCancelledError TimeoutErrorsys version_info current_task cancellingr^_cancelrTdoneshield force_close)rwrtasks r7shutdownzRequestHandler.shutdownsg !  ! -  " ) ) + + +  $ $(:#;#;#=#=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=r~ct|ttj|}|jrt ||jJ|j|||j}tj dkr*tj | |d}n'| | }||_dS)Nr Trm eager_start)rpconnection_maderr TransportrKr"rHrrrTaskstart create_taskrT)rwr~real_transportrmrrxs r7rzRequestHandler.connection_made6s  ***g/;;   * . ) ) )}((( %%dN;;;z  w & &< 4TJJJDD##DJJLL11D!r6r?cR|jdS|j|||jj}|t |d|_d|_d|_d|_|j|j |j +|td}|j ||r |j |j d|_ |j"|jd|_dSdS)NzConnection lost)rHconnection_losthandler_cancellationrrprJrIrWrMrr^ConnectionResetErrorrrTrVfeed_eof)rwr?rrxs r7rzRequestHandler.connection_lostGs0 = F %%dC000 $}A  $$$ $ $#  ! -  " ) ) + + +  ,{*+<==  ! ) )# . . .  (D$6$B   % % ' ' '!   +  ) ) + + +#'D  , +r6parserc|jJ||_|jr(|j|jd|_dSdS)Nr6)rVrQ feed_data)rwrs r7 set_parserzRequestHandler.set_parsergsV#+++%   %  * *4+= > > >!$D    % %r6cdSrr5rs r7 eof_receivedzRequestHandler.eof_receivedqs r6datac|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|r5|j|\} }| r|dSdSdS)Ni)r>r?r@Fr6r5r)r]r\rVrUrWrrr=r@r rFrPappendrSr set_resultrQclose) rwrmessagesupgradedtailr?msgpayloadwaitereofs r7 data_receivedzRequestHandler.data_receivedts      F   ' ''333 +/+?+I+I$+O+O((DD&   Sc3;GGGW!  !)B 6 6 W##q(##%%sGn5555\F (F.v{{}}.!!$'''$DM *D *%)""" * * * * ! )dm ) )   $ &     ,66t< % N " " "!DNNN & %r6requestresponsetimec|jD|jjr:|j|||j|z dSdSdSr)renabledlogrr)rwrrrs r7 log_accesszRequestHandler.log_accesssX   )d.@.H )   " "7Hdjoo6G6G$6N O O O O O * ) ) )r6argskwc<|jr|jj|i|dSdSr)rZrYrwrrs r7 log_debugzRequestHandler.log_debugs6 : + DK t *r * * * * * + +r6c*|jj|i|dSr)rY exceptionrs r7 log_exceptionzRequestHandler.log_exceptions" t*r*****r6c8d|_|js|jsdS|j}|}|j}||kr"|||j|_dS|jr/|j s| dSdSdSr) rMr]rGrrrLcall_at_process_keepaliverSrr)rwrmnow close_times r7rz!RequestHandler._process_keepalives!%   DO  Fziikk4 *  %)\\*d>U%V%VD " F <  1 1 3 3             r6 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 ExceptionrRr)rwrrrrrespresetr?s r7_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}tj|}|J|j}|J|j}d}|jJ|jJ|js|js; | |_ |j d{Vd|_ n #d|_ wxYw|j \}}| }|xj dz c_ t||} t|t r||} t$}n|j} ||||| |} || || } t(jdkrtj| |d} n|| } | d{V\}}n#t0$r|dY|j||dnB|js[|jrR|jsK|G| }||z}||_|j |||j |_nnnwxYw~ |r|d |j||dn|js[|jrR|jsK|G| }||z}||_|j |||j |_nAn?n=tC|j"|_|#s|j$}|js-|r*|d || }||z} |#s||krtK||z 4d{V|&d{Vdddd{Vn#1d{VswxYwY| }|#s||kn[#tj'tj(f$r=t(jd kr*tjx}r|)rYnwxYw|#s0|js)|d |*|+tXnf#tj'$r|dtZ$r5}|.d | |/Yd}~nd}~wwxYw|j||dn|jsY|jrQ|jsJ|G| }||z}||_|j |||j |_nnn#|j||dnb|js[|jrQ|jsJ|G| }||z}||_|j |||j |_nYn wxYw|j|js)d|_0|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)1rrrrHrNrJrIr]rPrrSpopleftrrequests_countr isinstancer=_make_error_handlerERRORrrrrrConnectionErrorrr~rGr\rLrMrrboolris_eofrOrreadanyrrrr set_exception_PAYLOAD_ACCESS_ERRORrrrrT)rwrmhandlerrlrbrr@rrwriterrrrcororrrrrhend_ttr?s r7rzRequestHandler.startsz&t,,"""-""" 3$000$000#b > ((#'#5#5#7#7DL,&&&&&&&#'DLL4DL''''#~5577 GWIIKKE  " "a ' " "!$--F'8,, 8"&":":7"C"C"&"7++GWdFGTTGK ++GUOLL#w.."<4TJJJDD++D11D(,******KD%%&NN#KLLLd>)d.>NN#LMMMM*  t{ ,8"&))++C),/@)@J>HD;#5=9=$.0G:":" 6 m NN#MNNNX>)d.>NN#LMMMM*  t{ ,8"&))++C),/@)@J>HD;#5=9=$.0G:":" 6 W#'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#LMMMM*  t{ ,8"&))++C),/@)@J>HD;#5=9=$.0G:":" 6 >)d.>NN#LMMMM*  t{ ,8"&))++C),/@)@J>HD;#5=9=$.0G:":" 6E#b J  '!%D ~)$$&&&&& ' '))s&B B5AR$ FR$H;5R$:H;;R$A/R$ 2O*=N*O** N44O*7N481O*)R$*AQ?R$QA!R$#V $.T+T=V TV BX  X rcK||jN|jdd|_|jr&|j|jd|_ |j}n#t$r||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. NFr6z+Missing return statement on request handlerz7Web-handler should return a response instance, got {!r})r>reasontextheadersT)_finishrW set_upgradedrUrQrprepareAttributeErrorrr}r$r'r>rrr write_eofrr)rwrrr prepare_methr?s r7rzRequestHandler.finish_response~s    +  - -e 4 4 4!DM! )$..t/ABBB%(" (=C>+D..%EErr>r@c|jdkr2t|tr|jd|n|d||jjdkrtdd}|tj krd tj }tj j }d}|jr?tt5tj}dddn #1swxYwYd |jd d vr1|rt'|}d |d }d ||}d }n |r|}|dz|z}t)|||} | | S)zHandle errors. Returns HTTP response with specific status code. Logs additional information. It always closes current connection. rzError handling requestrrzMResponse is sent already, cannot send another response with the error messagez text/plainz{0.value} {0.phrase}Nz text/htmlAcceptz

Traceback:

z
zV{title}

{title}

{msg} )titlerz )r>r content_type)rFrrrYrZrr output_sizerrINTERNAL_SERVER_ERRORr} descriptionrr traceback format_excrget html_escaper'r) rwrr>r?r@ctrrtbrs r7rzRequestHandler.handle_errors  ! # # 3 (F(F # K  6  E E E E   7#  F F F > % ) )!)   Z5 5 5*11*2RSSE2>CBz 0i((00"-//B000000000000000go11(B????B$RBArAAAC0&u#&..  !C&.3.vG"EEE  sC33C7:C7err_infoc4dtdtffd }|S)NrrycVK|jjjSr)rr>r?r@)rrrws r7rz3RequestHandler._make_error_handler..handlers/$$(,8H r6)r&r()rwrrs`` r7rz"RequestHandler._make_error_handlers< ; >        r6)r)ryN)rNN)4r1r2r3r4 __slots__rr%r LOG_FORMATrAbstractEventLooprtrrrrrDrArqrpropertyrbr r BaseTransportrrCrr rrbytesrrrrr&r(rrrrr r rrrrrr=r __classcell__)rxs@r7r)r)es%%NIJ$("&7C*!-!8! " $! $()'L*L*L*L*' L* ! L*L*L*34L*L*L*L*L*L*L* !L*"#L*$%L*&!&'L*L*L*L*L*L*\ #    '5'''X'00huo00000d")>"4"""""""(8M#:(t((((((@%%%%%%    %%%D%%%%N*d*t****""""""""P"P.<PDIP PPPP +s+#+$+++++3+c+d++++")))";->1J"JK ) ~t# $ ))))V{'{'{'{'z("(*8(FK( ~t# $((((Z'+!% 8888m $ 8 # 8  8888t  ;->!:: ;r6)Mrasyncio.streamsrrr collectionsr contextlibrhtmlrr httprloggingrtypingrr r r r r rrrrrattryarlabcrr base_protocolrhelpersrrrrrrhttp_exceptionsrrrrstreamsr r! tcp_helpersr"web_exceptionsr#r$web_logr% web_requestr& web_responser'r(__all__ web_serverr,_RequestFactory_RequestHandlerURLrrr*r+rsr=_MsgTyper)r5r6r7r2s &&&&&&                           ;;;;;;;;''''''!!!!!!+*****--------00000000&&&&&&BBBBBBBB!!!!!!$$$$$$22222222 I#""""""  K=)N*CCD    DHSMM  !!!!!)!!!88888888+*,,T$d33343 ((23\A BE E E E E \E E E E E r6