iiddlZddlZddlZddlZddlZddlmZddlmZddl m Z ddl m Z ddlmZddlmZmZmZmZmZmZmZmZmZmZmZddlZddlZddlmZd d l m!Z!m"Z"d d l#m$Z$d d l%m&Z&d d l m'Z'm(Z(m)Z)m*Z*m+Z+d dl,m-Z-d dl.m/Z/m0Z0d dl1m2Z2m3Z3d dl4m5Z5d dl6m7Z7m8Z8d dl9m:Z:d dl;mZ>m?Z?dZ@er ddlAZAd dlBmCZCee*e3de"dger>^s K  Lr7r>c!eZdZdZdZddeeeejdddddd dd d d d de jde de de deede dede dededede dede de f fdZdefdZeded fd!Zedeeeeeeeefeeefffd"Zede fd#ZdHd$ee dd%fd&Zd'e j:dd%ffd( Zd)eedd%ffd* Z d+e!dd%fd,Z"dId-Z#d.e$dd%fd/Z%d0e dd%fd1Z&dId2Z'dId3Z(d4e)d5e*d6ee dd%fd7Z+d8e!d9e!dd%fd:Z,d8e!d9e!dd%fd;Z-dId<Z.d4e)d=ee d>e/e)ge0e*fdee*e ffd?Z1dId@Z2d4e)dAe*d=ee dee*e ffdBZ3 dJd4e)dCed)eedDeede*f dEZ4dFe5de/e)ge0e*ffdGZ6xZ7S)Kr*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_progress_logging_enabled_cachei.TFiig$@i)keepalive_timeoutr#rZaccess_log_classr\access_log_formatr[ max_line_size max_headersmax_field_sizelingering_time read_bufsizeauto_decompresstimeout_ceil_thresholdmanagerr-looprer#rZrfr\rgr[rhrirjrkrlrmrnc t||d|_d|_d|_||_|j |_|j|_ ||_ d|_ d|_ ||_ t| |_t!|_d|_d|_d|_d|_d|_d|_t1|||| | | t2||_d|_ t||_||_| |_||_ |r*||||_!|jBjD|_#nd|_!d|_#d|_$d|_%d|_&i|_'y#t8t:f$rY}wxYw)NrFgr7)rhrjripayload_exceptionrmrd)(super__init__rGrHr_rIrequest_handlerrJrequest_factoryrKrLrMrNrOfloatrPrrQrRrTrSrUrVrWrr+rXr` TypeError ValueErrorrZr[r\renabledrbr]r^rarc)selfrorprer#rZrfr\rgr[rhrirjrkrlrmrn __class__s r8rtzRequestHandler.__init__s*  7;*1 ;B;R;R;B;R;R+*-';?"3$^4*/' 7; ?C;? $($>D !!%D $)D ! !$)!&( %:&   sEE&%E&returncrdj|jj|jdSdS)Nz<{} {}> connected disconnected)formatr|r2 transportr{s 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 ~~%  ..|< r7cT|jdS|jjdS)zReturn peername if available.Npeernamerrs r8rzRequestHandler.peernames1~~%  ..z: r7c|jSN)rOrs r8rez RequestHandler.keepalive_timeouts&&&r7timeoutNcKd|_|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^rNcancelra_loop create_futurerSrasyncioCancelledError TimeoutErrorsys version_info current_task cancellingr__cancelrUdoneshield force_close)r{rtasks r8shutdownzRequestHandler.shutdown s !  ! ! -  " " ) ) +  $ $$(::#;#;#=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=rct||ttj|}|j r t ||jJ|jj|||j}tjdk\r.tj|j|d}||_y|j|j}||_y)Nr Trp eager_start)rsconnection_maderr TransportrLr#rIrrrTaskstart create_taskrU)r{rreal_transportrprr|s r8rzRequestHandler.connection_madeRs  *g//;    . )}}((( %%dN;zz   w &<< 4TJD"##DJJL1D!r7r@ch|jy|jj|||jj}|jt||d|_d|_d|_d|_|j|jj|j(| td}|jj||r&|j|jjd|_ |j"|jjd|_yy)NzConnection lost)rIconnection_losthandler_cancellationrrsrKrJrXrNrr_ConnectionResetErrorrrUrWfeed_eof)r{r@rr|s r8rzRequestHandler.connection_lostcs ==  %%dC0 $}}AA  $ $ $#  ! ! -  " " ) ) +  ,{*+<=  ! ! ) )# . D$6$6$B    % % '!    +  ) ) +#'D  ,r7parserc|jJ||_|jr-|jj|jd|_yy)Nr7)rWrR feed_data)r{rs r8 set_parserzRequestHandler.set_parsersL##+++%     * *4+=+= >!$D  r7cyrr6rs r8 eof_receivedzRequestHandler.eof_receiveds r7datac |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@rAFr7r6r)r^r]rWrVrXrrr>rAr!rGrQappendrTr set_resultrRclose) r{rmessagesupgradedtailr@msgpayloadwaitereofs r8 data_receivedzRequestHandler.data_receivedsv        ' ''3 33 +/+?+?+I+I$+O((D!)B 6 W##q(#%%sGn5 6\\FF.v{{}!!$'$DMD%)"!x ! ! )dmm   $ & ,,66t> % NN "!DN &r7requestresponsetimec|jrP|jCtr|J|jj|||jj |z yyyr)rbrrlogrr)r{rrrs r8 log_accesszRequestHandler.log_accesssX  T%7%7%C'''    " "7Hdjjoo6G$6N O&D r7argskwcV|jr|jj|i|yyr)r[rZr{rrs r8 log_debugzRequestHandler.log_debugs' :: DKK  t *r * r7c<|jj|i|yr)rZ exceptionrs r8 log_exceptionzRequestHandler.log_exceptions t*r*r7cRd|_|js |jsy|j}|j }|j }||kr"|j ||j|_y|jr,|jjs|jyyyr) rNr^rHrrrMcall_at_process_keepaliverTrr)r{rpnow close_times r8rz!RequestHandler._process_keepalives!%   DOO zziik44  %)\\*d>U>U%VD "  << 1 1 3    !4|_ |jCs|jD}|j s|r|j7d ||j}||z} |jCsj||kretG||z 4d{|jId{dddd{|j}|jCs||kre|jCs-|j s!|j7d |jQ|jStTd| _|j:||j7d |j@r`|j^sT|j sH|j|z}||_0|jb#|je||jf|_1nn|j s{|j s/d|_|j:|j:jQyyy7#d|_wxYw7l#t4$r<|j7dYd| _|j:}||j7dwxYw777#1d{7swYxYw#t&jJt&jLf$r>t,j.d k\r't'j(x}r|jOrY wxYw#t&jJ$r#|j7d|jWtX$r.}|j[d | |jWYd}~!d}~wt\$r|jWwxYw#d| _|j:||j7dwwwxYww)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)4rrIrOrKrJr^rQrrTpopleftrbrrequests_countr isinstancer>_make_error_handlerERRORrUrrrrrrrConnectionErrorr_taskrboolrrHis_eofrPrreadanyrrrr set_exception_PAYLOAD_ACCESS_ERRORrrrrDr]rMrNrr)r{rprorerrArrwriterrurcororrrkrend_ttr@rs r8rzRequestHandler.startszz--""" 33$$000$$000##>>(#'#5#5#7DL,,&&#'DL#~~557 GW$(#8#8DIIKdE  " "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*a##f  !%D ~~)$$&*!]'#'DLF#-&NN#KLl!% >>)d.>NN#LMu4!<$;!<!<!<!<!( 6 68L8LM& # 0 0G ;*1*>*>*@%@Q%@$%LLN % &)) GH  " #""#83"G  ""    " !% >>)d.>NN#LM/?)sDA V#$PP P C VAS*+P0P1P8S* *V7A+S*#'R Q' RQ0"Q*#Q0' R2Q-3)RAS*/B VRAS'#S*&S''S**=U.'#U U1U..U11*VVrcK|j|jZ|jjdd|_|jr,|jj |jd|_ |j } ||d{|j!d{|j%||||dfS#t$r||jdn |jdj|t}t|j|j|j|j}|j }YwxYw77#t"$r|j%||||dfcYSwxYww)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. NFr7z+Missing return statement on request handlerz7Web-handler should return a response instance, got {!r})r?reasontextheadersT)_finishrX set_upgradedrVrRrprepareAttributeErrorrrr%r(r?rrr write_eofrr)r{rrr prepare_methr@s r8rzRequestHandler.finish_responses[     +  - -e 4!DM!!$$..t/A/AB%(" (<Traceback: 
z
zV{title}

{title}

{msg} )titlerz )r?r content_type)rGrrrZr[remoterr output_sizerrINTERNAL_SERVER_ERRORr descriptionrr traceback format_excrget html_escaper(r) r{rr?r@rActr rtbrs r8rzRequestHandler.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)Nrr}cpKj|jjjSwr)rr?r@rA)rrr{s r8handlerz3RequestHandler._make_error_handler..handlers1$$(,,8H8H s36)r'r))r{rrs`` r8rz"RequestHandler._make_error_handlers ; >  r7)g.@)r}N)rNN)8r2r3r4r5 __slots__r r&r LOG_FORMATrAbstractEventLooprwrrrrrErBrtrrr rrrrpropertyrer BaseTransportrrDrr rrbytesrrrrr'r)rrrrr r rrrrr>r __classcell__)r|s@r8r*r*hs%NIN$("&7C*!-!8!8! " $! $()'O)O)'' O) ! O)O)O)34O)O)O)O)O)O)O) !O)"#O)$%O)&!&'O)b #  X&67   %U3S##56c3hGH I  '5''0huo00d")>)>"4""(8M#:(t(@%%% %%%D%N*d*t*""P"P.<PDLUOP P+s+#+$++3+c+d+"))UO)";->1J"JK ) ~t# $ )VG'R("(*8(FNuo( ~t# $(Z'+!% <<<m $ < # <  <|  ;->!:: ;r7)Prasyncio.streamsrrr collectionsr contextlibrhtmlrrhttprloggingrtypingrr r r r r rrrrrattryarl propcacherabcrr base_protocolrhelpersrrrrrrhttp_exceptionsrrrr streamsr!r" tcp_helpersr#web_exceptionsr$r%web_logr& web_requestr' web_responser(r)__all__ssl web_serverr-_RequestFactory_RequestHandlerURLrrr+r,rsr>_MsgTyper*r6r7r8r?sf &     +;'!+-0&B!$2 I"  K=)N*CCD    DHHSM !)!88+,T$d34 ((23\A Bp \p r7