rPjÁddlZddlZddlZddlZddlZddlmZddlmZddl m Z m Z m Z ddl mZddlmZddlmZddlmZdd lmZmZmZmZddlZddlZdd lmZd d lm Z m!Z!d d l"m#Z#d dl$m%Z%m&Z&d dlm'Z'm(Z(m)Z)m*Z*m+Z+m,Z,d dl-m.Z.d dl/m0Z0m1Z1d dl2m3Z3m4Z4d dl5m6Z6d dl7m8Z8m9Z9d dl:m;Z;d dlm?Z?m@Z@dZAdZBer ddlCZCd dlDmEZEe e*e4de!dge=fZFe e=ge e@fZGe*dde)iiddd d ejd ZIGd!d"eJZKGd#d$eJZLeLZMejddd%Gd&d'ZOePe*eOze4fZQGd(de#ZRy))N) BaseEventLoop)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/TFceZdZdZy)r*zPayload parsing error.N__name__ __module__ __qualname____doc__Y/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/aiohttp/web_protocol.pyr*r*Os r7r*ceZdZdZy)r+z-Payload was accessed after response was sent.Nr1r6r7r8r+r+Ss7r7r+) auto_attribsfrozenslotsc,eZdZUeed<eed<eed<y)_ErrInfostatusexcmessageN)r2r3r4int__annotations__ BaseExceptionstrr6r7r8r>r>Zs K  Lr7r>c!@eZdZdZdZddeeeejddddde dd d d d d e jde de dedeededede dededede dede de f fdZdefdZededfd Zedeeeeeefzeeefzd!zfd"Zedeeeeeefzeeefzd!zfd#Zede fd$ZdJd%e d!zdd!fd&Zd'e j<dd!ffd( Zd)e d!zdd!ffd* Z! dKd+e"d,e#gd!fd!zdd!fd-Z$dLd.Z%d/e&dd!fd0Z'dLd1Z(d2e dd!fd3Z)dLd4Z*dLd5Z+d6e,d7e-d8e d!zdd!fd9Z.d:e/d;e/dd!fd<Z0d:e/d;e/dd!fd=Z1dLd>Z2d6e,d?e d!zd@e#e,ge3e-fdee-e ffdAZ4dLdBZ5d6e,dCe-d?e d!zdee-e ffdDZ6 dMd6e,dEed)e d!zdFed!zde-f dGZ7dHe8de#e,ge3e-ffdIZ9xZ:S)Nr)aOHTTP 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 an idle 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_max_msg_queue_size_msg_queue_resume_size _message_tail _read_bufsize_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"r^access_log_classr`access_log_formatr_rIrHrGlingering_time read_bufsizeauto_decompresstimeout_ceil_thresholdmanagerr-looprjr"r^rkr`rlr_rIrHrGrmrnrorpc >t|_tdz|_||_t |||| | | t |t }t |||d|_d|_ d|_ ||_ |j|_ |j|_| |_| |_| |_||_d|_d|_||_t/| |_t3|_d|_d|_d|_d|_d|_d|_ d|_! t/||_!||_$| |_%||_&|r*||||_'|jNjP|_)nd|_'d|_)d|_*d|_+d|_,i|_-y#tDtFf$rY}wxYw) N)rIrGrHpayload_exceptionromax_msg_queue_sizerTgr7riF).MAX_MSG_QUEUE_SIZErUrVrXrr*super__init__rJrKrcrLrequest_handlerrMrequest_factoryrNrIrHrGrOrPrQrRfloatrSrrTrWr]rZrYr[r\rd TypeError ValueErrorr^r_r`renabledrfrarbrerg)selfrqrrrjr"r^rkr`rlr_rIrHrGrmrnrorpparser __class__s r8ryzRequestHandler.__init__s*$6 '9A&=#)"   ')#1+1   v& 48'. 8?8O8O8?8O8O*&,+*-'8<"3$^4*/' <@48 <@8<$(./$ +01G+HD (  $ >N-?D %)$6$6$>$>D !!%D $)D ! !$)!&( %:&   sF FFreturncrdj|jj|jdSdS)Nz<{} {}> connected disconnected)formatrr2 transportrs r8__repr__zRequestHandler.__repr__ s; NN # #>>5K  ;I  r7zssl.SSLContextcT|jdS|jjdS)zReturn SSLContext if available.N sslcontextrget_extra_infors r8 ssl_contextzRequestHandler.ssl_contexts1 ~~%  ..|< r7NcT|jdS|jjdS)zReturn peername if available.Npeernamerrs r8rzRequestHandler.peername1~~%  ..z: r7cT|jdS|jjdS)zReturn sockname if available.Nsocknamerrs r8rzRequestHandler.sockname$rr7c|jSN)rRrs r8rjz RequestHandler.keepalive_timeout/s&&&r7timeoutcKd|_|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 )rbrQcancelre_loop create_futurerYrasyncioCancelledError TimeoutErrorsys version_info current_task cancellingrc_cancelr[doneshield force_close)rrtasks r8shutdownzRequestHandler.shutdown3s !  ! ! -  " " ) ) +  $ $$(::#;#;#=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=rcdt||ttj|}|j r t ||jJ|jj|||j}|jdkDrE|j|jz}||_ |j||j|_tj dk\rkt#|t$r-tj&|j)d}||_ytj*|j)|d}||_ytj dk\r.tj*|j)|d}||_y|j'|j)}||_y)NrrT eager_startrrrr )rxconnection_maderr TransportrOr"rLrrRtimerPcall_at_process_keepaliverQrr isinstancer create_taskstartTaskr[)rrreal_transportrr close_timerrs r8rzRequestHandler.connection_madeesW  *g//;    . )}}((( %%dN;zz  " "Q &t'>'>>J.8D +%)\\*d>U>U%VD "   w &$ .**4::!$D      + + - r7cyrr6rs r8 eof_receivedzRequestHandler.eof_receiveds r7datac6|js |jry|j|js|jJ |jj |\}}}|D]7\}}|xjdz c_ |jj||f9|j}|r#|!|js|jd|j s2t#|j|j$k\r|j'||_|r |r||_yyy|jd|jrX|rV|xj(|z c_|j s4t#|j(|j*k\r|j'yyy|rN|j,|j-|jj |\} }| r|j/yyy#t $r.}td||jtfg}d}d}Yd}~d}~wwxYw)Nr?r@rAFr7r)rbrar\ _upgradedrrrr>rAr rJrTappendrZr set_resultrlenrU_pause_reading_for_bufferrWrXr]close) rrmessagesupgradedtailr@msgpayloadwaitereofs r8 data_receivedzRequestHandler.data_receiveds        '<<+ ++ +/<<+A+A$+G((D!) 6 W##q(#%%sGn5 6\\FF.v{{}!!$' '''4+C+CC..0%DND%)"!x ! ! )dnn   $ & ''**+t/A/AA..0B( %%1&&(,,66t>"d&>&>> '')r7valcn||_|jr"|jjd|_yy)zMSet keep-alive connection mode. :param bool val: new state. N)rKrQr)rrs r8 keep_alivezRequestHandler.keep_alives3   ! !  " " ) ) +%)D " "r7c`d|_|jr|jjyy)zClose connection. Stop accepting new pipelining messages and close connection when handlers done processing messages. TN)rarZrrs r8rzRequestHandler.closes'  << LL   ! r7cd|_|jr|jj|j"|jj d|_yy)zForcefully close connection.TN)rbrZrrrrs r8rzRequestHandler.force_closesG  << LL   ! >> % NN "!DN &r7requestresponserc|jrP|jCtr|J|jj|||jj |z yyyr)rfrr logrr)rrrrs r8 log_accesszRequestHandler.log_accesssX  T%7%7%C'''    " "7Hdjjoo6G$6N O&D r7argskwcV|jr|jj|i|yyr)r_r^rrrs r8 log_debugzRequestHandler.log_debugs' :: DKK  t *r * r7c<|jj|i|yr)r^ exceptionrs r8 log_exceptionzRequestHandler.log_exception#s t*r*r7cRd|_|js |jsy|j}|j }|j }||kr"|j ||j|_y|jr,|jjs|jyyyr) rQrbrKrrrPrrrZrr)rrrnowrs r8rz!RequestHandler._process_keepalive&s!%   DOO zziik44  %)\\*d>U>U%VD "  << 1 1 3    !4| d} nVt3j@| |d} n=t8j:dk\rt3j@| |d} n|j?| } | d{\}} ~ | r<|jEd  d| _#|jH||jEd ntK|jL|_'|jQs|jR}|j s|r|jEd ||j#}||z} |jQsj||kretU||z 4d{|jWd{dddd{|j#}|jQs||kre|jQs-|j s!|jEd |j_|jatbd| _#|jH||jEd  |jNr`|jlsT|j sH|j#|z}||_7|jp#|js||jt|_8nn|j s3|j s/d|_|jH|jHj_yyy7>#d|_wxYw7l#tB$r<|jEdYd| _#|jH}||jEd wxYw777#1d{7swYxYw#t2jXt2jZf$r>t8j:d k\r't3j4x}r|j]rY wxYw#t2jX$r#|jEd|jetf$r.}|jid||jeYd}~!d}~wtj$r|jewxYw#d| _#|jH||jEd wwwxYww)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. NrrTrrrz&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);rrLrRrNrMrbrTrrZpopleftrmessage_consumedrrrVrrfrrequests_countrrr>_make_error_handlerERRORr[rrrrrrrrConnectionErrorr_taskrboolrrKis_eofrSrreadanyrrrr set_exception_PAYLOAD_ACCESS_ERRORrrrrDrarPrQrr)rrrrqrjrrArrwriterrzrcororrrmrend_ttr@rs r8rzRequestHandler.startbszz--""" 33$$000$$000##>>(#'#5#5#7DL,,&&#'DL#~~557 GW ||' --/##'4+F+FF//1$(#8#8DIIKdE  " "a ' "!$-F'8,"&":":7"C"&"7"7 ++""@g&:&:4&@ GH N++GUOL##w.!$ 6&224TJ&||DtN%%0"<<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*C##H  !%D ~~)$$&*!'#'DLh#-&NN#KLl!% >>)d.>NN#LMu4!<$;!<!<!<!<!( 6 68L8LM& # 0 0G ;*1*>*>*@%@Q%@$%LLN % &)) GH  " #""#83"G  ""    " !% >>)d.>NN#LM/?)sDA Y#$SSS D1Y>B$V"#S(S)S0V"*Y/A+V"'T>TT>T(T"T( T>*T%+)T>AV"'B Y "T(%T>(T;.T1 /T;6T>>AVV"VV""=X&#XX)X&&X))*YYrcK|j|jr%|js|j |j|jj dd|_|j r |jj|j \}}}||_||_|D]7\}} |xjdz c_ |jj|| f9t|j|jk\r|j!n|j"r|j%|j&J |j(} | |d{|j;d{|j?||||dfS#t$r.}td||jtfg}d}d}Yd}~&d}~wwxYw#t*$rx||j-dn|j-d|t/} t1| j2| j4| j6| j8 }|j(} YwxYw77#t<$r|j?||||d fcYSwxYww) 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. NFrrr7rz+Missing return statement on request handlerz3Web-handler should return a response instance, got )r?reasontextheadersT) _finishrrTr\r set_upgradedrWrrr>rAr rJrrrUrrrrZprepareAttributeErrorrr$r'r?rrr write_eofr r) rrrrrrr parse_excrr prepare_methr@s r8rzRequestHandler.finish_responsesV  NNNN$$, ( LL % %e ,"DN!!/3||/E/E**0,Hh("*%)"$,:LC''1,'NN))3.9:t~~&$*B*BB224((335||+++ (<I:G  I: A>I  I: I  I:II I74I:6I77I:r?rAcF|jdk(r9t|tr)|jj d|j |n|j d|j ||jjdkDr tdd}|tjk(rtjjdtjj}tjj}d}|jr,tt 5t#j$}dddd |j&j)d d vr"|rt+|}d |d }d|d|d|d}d }n |r|}|dz|z}t-|||} | j/| S#1swYuxYw)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/plain Nz text/htmlAcceptz

Traceback:

z
zz

z

z z )r?r content_type)rJrrr^r_remoterr output_sizer r INTERNAL_SERVER_ERRORvaluephrase descriptionrr traceback format_excrget html_escaper'r) rrr?r@rActtitlertbrs r8rzRequestHandler.handle_errorRs   ! # 3 (F KK  0'..3     0'..3   >> % % )!)   Z55 5!77==>a @`@`@g@g?hiE22>>CBzzi(0"--/B0goo11(B??$RB6rd&AC#W%**/1/1 !C&.3.vG"E  -00s FF err_infoc0dtdtffd }|S)NrrcpKj|jjjSwr)rr?r@rA)rr4rs r8handlerz3RequestHandler._make_error_handler..handlers1$$(,,8H8H s36)r&r()rr4r7s`` r8r z"RequestHandler._make_error_handlers ; >  r7)g.@r)rN)rNN);r2r3r4r5 __slots__rr%r LOG_FORMATrrAbstractEventLoopr|rr typerrErBryrrrrtuplerrpropertyrjr BaseTransportrrDrrrrrbytesrrrrrr&r(rr rrrrrrrrr>r  __classcell__)rs@r8r)r)ds$L#IV$("&7C*!-!8!8!" $. $()'X)X)'' X) ! X)X)X)34X)X)X)X)X)X)X) !X)"#X)$%X)&!&'X)t #  X&67   uS#sC'( (5c? :T A   uS#sC'( (5c? :T A  '5''0edl0d0d")>)>"4":(=4#7(D(F7;..#2t8,t3.  ." 4%4D4l **d*t*""P"P.<PDIDLP P+s+#+$++3+c+d+"))DL)";->1J"JK ) ~t# $ )VX'tT"T*8TFKdlT ~t# $Tr$(" <<<T ! < t <  <|  ;->!:: ;r7)Srasyncio.streamsrr-rasyncio.base_eventsr collectionsrcollections.abcrrr contextlibrhtmlr r0httpr loggingr typingr r rrattryarl propcacherabcrr base_protocolrhelpersrrrrrrrrhttp_exceptionsrrrrstreamsr r! tcp_helpersr"web_exceptionsr#r$web_logr% web_requestr& web_responser'r(__all__rwssl web_serverr-_RequestFactory_RequestHandlerURLr rr*r+rsr>r<_MsgTyper)r6r7r8r_sb -99&55 +;'5+-0&B!$2 I "  K=)N*CCD    DHHSM !)!88+,T$d34 "X-|; <t \t r7