$Gg>eddlZddlZddlZddlZddlZddlmZddlmZddl 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'iiddddejd ZDGddeEZFGdd eEZGeGZHejddd!Gd"d#ZJeee(eJfe1fZKGd$de"ZLy)%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/TFceZdZdZy)r*zPayload parsing error.N__name__ __module__ __qualname____doc__q/home/kushmeetdev/apache_webroot/langgraph_flaskproject/venv/lib/python3.12/site-packages/aiohttp/web_protocol.pyr*r*Ps r6r*ceZdZdZy)r+z-Payload was accessed after response was sent.Nr0r5r6r7r+r+Ts7r6r+) auto_attribsfrozenslotsc,eZdZUeed<eed<eed<y)_ErrInfostatusexcmessageN)r1r2r3int__annotations__ BaseExceptionstrr5r6r7r=r=[s K  Lr6r=c!reZdZdZdZddeeeejdddddd dd d d d de jde de de deede dede dededede dede de f fdZdefdZede fd ZdEd!ee dd"fd#Zd$e j0dd"ffd% Zd&eedd"ffd' Zd(edd"fd)ZdFd*Zd+edd"fd,Z d-e dd"fd.Z!dFd/Z"dFd0Z#d1e$d2e%d3e dd"fd4Z&d5ed6edd"fd7Z'd5ed6edd"fd8Z(dFd9Z)d1e$d:e d;e*e$ge+e%fde,e%e ffd<Z-dFd=Z.d1e$d>e%d:e de,e%e ffd?Z/ dGd1e$d@ed&eedAeede%f dBZ0dCe1de*e$ge+e%ffdDZ2xZ3S)Hr)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||_||_| |_||_ |r||||_!nd|_!d|_"d|_#d|_$y#t8t:f$rYTwxYw)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;R;B;R;R+*-';?"3$^4*/' 7; ?C;? $( connected disconnected)formatrxr1 transportrws r7__repr__zRequestHandler.__repr__s; NN # #>>5K  ;I  r6c|jSN)rNrs r7rbz RequestHandler.keepalive_timeouts&&&r6timeoutNcKd|_|j|jj|jrX|jj |_ t|4d{|j d{dddd{ t|4d{|j-|jj!tj|j"A|j"j%s'tj&|j"d{dddd{|j"|j"j|j)y7 77#1d{7swYxYw#tjtjf$rEd|_tjdk\r'tjx}r|jrYewxYw7Y77#1d{7swYxYw#tjtjf$r>tjdk\r'tjx}r|jrY:wxYww)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.shutdowns !  ! ! -  " " ) ) +  $ $$(::#;#;#=D  '0//....// #G, = =((4))11'2H2H2JK%%1$:L:L:Q:Q:S!..););<<<  = =    )    % % ' =/.////**G,@,@A '+$$$/!(!5!5!777)  = =  = = = = &&(<(<=   G+$1133T3OO%  sAI=F+E6,F/E=?E9E= FE;FH$G=%H(BH*H+H/ H:H;H?7I=6F9E=;F=FF F FA$G:6I=9G::I==HHHH H HHAI:6I=9I::I=r~ct||ttj|}|j r t ||jJ|jj|||j}tjdk\r.tj|j|d}||_y|j|j}||_y)Nr Trm eager_start)rpconnection_maderr TransportrKr"rHrrrTaskstart create_taskrT)rwr~real_transportrmrrxs r7rzRequestHandler.connection_made6s  *g//;    . )}}((( %%dN;zz   w &<< 4TJD"##DJJL1D!r6r?ch|jy|jj|||jj}|jt||d|_d|_d|_d|_|j|jj|j(| td}|jj||r&|j|jjd|_ |j"|jjd|_yy)NzConnection lost)rHconnection_losthandler_cancellationrrprJrIrWrMrr^ConnectionResetErrorrrTrVfeed_eof)rwr?rrxs r7rzRequestHandler.connection_lostGs ==  %%dC0 $}}AA  $ $ $#  ! ! -  " " ) ) +  ,{*+<=  ! ! ) )# . D$6$6$B    % % '!    +  ) ) +#'D  ,r6parserc|jJ||_|jr-|jj|jd|_yy)Nr6)rVrQ feed_data)rwrs r7 set_parserzRequestHandler.set_parsergsL##+++%     * *4+=+= >!$D  r6cyrr5rs r7 eof_receivedzRequestHandler.eof_receivedqs r6datac |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@Fr6r5r)r]r\rVrUrWrrr=r@r rFrPappendrSr set_resultrQclose) rwrmessagesupgradedtailr?msgpayloadwaitereofs r7 data_receivedzRequestHandler.data_receivedtsv        ' ''3 33 +/+?+?+I+I$+O((D!)B 6 W##q(#%%sGn5 6\\FF.v{{}!!$'$DMD%)"!x ! ! )dmm   $ & ,,66t> % NN "!DN &r6requestresponsetimec|jP|jjr9|jj|||jj |z yyyr)renabledlogrr)rwrrrs r7 log_accesszRequestHandler.log_accesssO    )d.@.@.H.H    " "7Hdjjoo6G$6N O/I )r6argskwcV|jr|jj|i|yyr)rZrYrwrrs r7 log_debugzRequestHandler.log_debugs' :: DKK  t *r * r6c<|jj|i|yr)rY exceptionrs r7 log_exceptionzRequestHandler.log_exceptions t*r*r6cRd|_|js |jsy|j}|j }|j }||kr"|j ||j|_y|jr,|jjs|jyyyr) rMr]rGrrrLcall_at_process_keepaliverSrr)rwrmnow close_times r7rz!RequestHandler._process_keepalives!%   DOO zziik44  %)\\*d>U>U%VD "  << 1 1 3    !4r`|j\sT|j sH|j|z}||_/|j`#|jc||jd|_0nn|j sm|j s/d|_|j8|j8jOyyy7x#d|_wxYw7l#t2$r<|j5dYd| _|j8}||j5dwxYw777#1d{7swYxYw#t$jHt$jJf$r>t*j,d k\r't%j&x}r|jMrY wxYw#t$jH$r#|j5d|jUtV$r.}|jYd | |jUYd}~!d}~wtZ$r|jUwxYw#d| _|j8||j5dwwwxYww)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)3rrHrNrJrIr]rPrrSpopleftrrequests_countr isinstancer=_make_error_handlerERRORrTrrrrrrrConnectionErrorr_taskr~boolrrGis_eofrOrreadanyrrrr set_exception_PAYLOAD_ACCESS_ERRORrrrrCr\rLrMrr)rwrmrlrbrr@rrwriterrrrcororrrhrend_ttr?rs r7rzRequestHandler.startszz--""" 33$$000$$000##>>(#'#5#5#7DL,,&&#'DL#~~557 GWIIKE  " "a ' "!$-F'8,"&":":7"C"&"7"7 ++""@g&:&:4&@ GC N++GUOL##w."<<4TJD++D1D(,*KD% NN#MN`!% >>)d.>NN#LM_#'t"7~~'%)%9%9N,,E~#iik #n 4 &&-nn&63;+7 +D!<!<*1//*;$;$;!<!<'+iik '.nn&63;#>>+D4E4E'=> %%&;<!% >>)d.>NN#LMt{{4;L;L!YY[+<< 2</))1-1\\"D$;$;.D*]##b  !%D ~~)$$&*!Y'#'DLB#-&NN#KLl!% >>)d.>NN#LMu4!<$;!<!<!<!<!( 6 68L8LM& # 0 0G ;*1*>*>*@%@Q%@$%LLN % &)) GH  " #""#83"G  ""    " !% >>)d.>NN#LM/?)sDA V#$PO?P B?V ASP"P#P*S?*V)A+S'Q8<Q=Q8Q"QQ" Q8$Q%)Q8AS!B VreasontextheadersT)_finishrW set_upgradedrUrQrprepareAttributeErrorrr}r$r'r>rrr write_eofrr)rwrrr prepare_methr?s r7rzRequestHandler.finish_responses[     +  - -e 4!DM!!$$..t/A/AB%(" (<r@c$|jdk(r9t|tr)|jj d|j |n|j d|j ||jjdkDr tdd}|tjk(rdjtj}tjj}d}|jr,tt5t!j"}dddd |j$j'd d vr)|rt)|}d |d }dj||}d }n |r|}|dz|z}t+|||} | j-| S#1swY|xYw)zHandle errors. Returns HTTP response with specific status code. Logs additional information. It always closes current connection. rzError handling request from %srrzMResponse 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)rFrrrYrZremoterr output_sizerrINTERNAL_SERVER_ERRORr} descriptionrr traceback format_excrget html_escaper'r) rwrr>r?r@ctrrtbrs r7rzRequestHandler.handle_errors   ! # 3 (F KK  0'..3     0'..3   >> % % )!)   Z55 5*11*2R2RSE22>>CBzzi(0"--/B0goo11(B??$RB6rd&AC0&u#&.  !C&.3.vG"E  -00s 6FFerr_infoc0dtdtffd }|S)NrrycpKj|jjjSwr)rr>r?r@)rrrws r7handlerz3RequestHandler._make_error_handler..handlers1$$(,,8H8H s36)r&r()rwrrs`` r7rz"RequestHandler._make_error_handlers ; >  r6)g.@)ryN)rNN)4r1r2r3r4 __slots__rr%r LOG_FORMATrAbstractEventLooprtrrrrrDrArqrpropertyrbr r BaseTransportrrCrr rrbytesrrrrr&r(rrrrr r rrrrrr=r __classcell__)rxs@r7r)r)es%NIJ$("&7C*!-!8!8! " $! $()'L*L*'' L* ! L*L*L*34L*L*L*L*L*L*L* !L*"#L*$%L*&!&'L*\ # '5''0huo00d")>)>"4""(8M#:(t(@%%% %%%D%N*d*t*""P"P.<PDIP P +s+#+$++3+c+d+")))";->1J"JK ) ~t# $ )VE'N("(*8(FK( ~t# $(Z'+!% <<<m $ < # <  <|  ;->!:: ;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)r5r6r7r3s` &     ;'!+-0&B!$2 I"  K=)N*CCD    DHHSM !)!88+,T$d34 ((23\A BS \S r6