;xjÁ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 ejHd ZIGd!d"eJZKGd#d$eJZLeLZMejNddd%Gd&d'ZOePe*eOze4fZQGd(de#ZRdS))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/TFceZdZdZdS)r*zPayload parsing error.N__name__ __module__ __qualname____doc__EC:\Projects\Historical\venv\Lib\site-packages\aiohttp/web_protocol.pyr*r*Os    r7r*ceZdZdZdS)r+z-Payload was accessed after response was sent.Nr1r6r7r8r+r+Ss7777r7r+) auto_attribsfrozenslotsc.eZdZUeed<eed<eed<dS)_ErrInfostatusexcmessageN)r2r3r4int__annotations__ BaseExceptionstrr6r7r8r>r>Zs. KKK  LLLLLr7r>c!eZdZdZdZddeeeejddddde dd d d d d e j de de dedeededede dededede dede de f fdZdefdZededfd Zedeeeeeefzeeefzd!zfd"Zedeeeeeefzeeefzd!zfd#Zede fd$ZdLd&e d!zdd!fd'Zd(e jdd!ffd) Zd*e d!zdd!ffd+ Z! dMd,e"d-e#gd!fd!zdd!fd.Z$dNd/Z%d0e&dd!fd1Z'dNd2Z(d3e dd!fd4Z)dNd5Z*dNd6Z+d7e,d8e-d9e d!zdd!fd:Z.d;e/dZ1dNd?Z2d7e,d@e d!zdAe#e,ge3e-fdee-e ffdBZ4dNdCZ5d7e,dDe-d@e d!zdee-e ffdEZ6 dOd7e,dGed*e d!zdHed!zde-f dIZ7dJe8de#e,ge3e-ffdKZ9xZ:S)Pr)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 pt|_tdz|_||_t |||| | | t |t }t ||d|_d|_ d|_ ||_ |j |_ |j|_| |_| |_| |_||_d|_d|_||_t/| |_t3|_d|_d|_d|_d|_d|_d|_ d|_! t/||_!n#tDtFf$rYnwxYw||_$| |_%||_&|r#||||_'|j'j(|_)nd|_'d|_)d|_*d|_+d|_,i|_-dS) 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?8O8?8O*&,+*-'8<"3$^44*/'' <@48 <@8<$(./$ +01G+H+HD ( (:&    D   $  *>N>N-??D %)$6$>D ! !!%D $)D ! !$)!&( s&D;;EEreturncTd|jj|jdndS)Nz<{} {}> connected disconnected)formatrr2 transportrs r8__repr__zRequestHandler.__repr__ s0 N #>5KK>   r7zssl.SSLContextcH|jdn|jdS)zReturn SSLContext if available.N sslcontextrget_extra_infors r8 ssl_contextzRequestHandler.ssl_contexts+ ~% D..|<< r7NcH|jdn|jdS)zReturn peername if available.Npeernamerrs r8rzRequestHandler.peername+~% D..z:: r7cH|jdn|jdS)zReturn sockname if available.Nsocknamerrs r8rzRequestHandler.sockname$rr7c|jSN)rRrs r8rjz RequestHandler.keepalive_timeout/s &&r7.@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 )rbrQcancelre_loop create_futurerYrasyncioCancelledError TimeoutErrorsys version_info current_task cancellingrc_cancelr[doneshield force_close)rrtasks r8shutdownzRequestHandler.shutdown3sg !  ! -  " ) ) + + +  $ $(:#;#;#=#=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=rc\t|ttj|}|jrt ||jJ|j|||j}|j dkrC| |j z}||_ | ||j |_tjdkrht#|t$r)tj|d}ntj||d}natjdkr*tj||d}n'||}||_dS)NrrT eager_startrrrr )rxconnection_maderr TransportrOr"rLrrRtimerPcall_at_process_keepaliverQrr isinstancer create_taskstartTaskr[)rrreal_transportrr close_timerrs r8rzRequestHandler.connection_madeesp  ***g/;;   * . ) ) )}((( %%dN;;;z  "Q & &t'>>J.8D +%)\\*d>U%V%VD "  w & &$ .. O*4::< > >!$D    .  + + - - - - - . .r7cdSrr6rs r8 eof_receivedzRequestHandler.eof_receiveds r7datac|js|jrdS|j#|js|jJ |j|\}}}n:#t $r-}td||jtfg}d}d}Yd}~nd}~wwxYw|D]1\}}|xj dz c_ |j ||f2|j }|r+|)|s|d|js1t#|j |jkr|||_|r |r ||_dSdSdS|jW|jrP|rN|xj|z c_|js3t#|j|jkr|dSdSdS|rP|j||j|\} }| r|dSdSdS)Nr?r@rAFr7r)rbrar\ _upgradedrrrr>rAr rJrTappendrZr set_resultrlenrU_pause_reading_for_bufferrWrXr]close) rrmessagesupgradedtailr@msgpayloadwaitereofs r8 data_receivedzRequestHandler.data_receiveds      F   ' '<+++ +/<+A+A$+G+G((DD&   Sc3;GGGW!  !) 6 6 W##q(##%%sGn5555\F (F.v{{}}.!!$''' ' 1''4+CCC..000%DN *D *%)""" * * * * ! )dn ) )   $ &  ' 1*++t/AAA..00000  1 1AA  %1&&(((,66t<""d&>>> '')))))r7valcf||_|jr"|jd|_dSdS)zMSet keep-alive connection mode. :param bool val: new state. N)rKrQr)rrs r8 keep_alivezRequestHandler.keep_alivesC   ! *  " ) ) + + +%)D " " " * *r7cXd|_|jr|jdSdS)zClose connection. Stop accepting new pipelining messages and close connection when handlers done processing messages. TN)rarZrrs r8rzRequestHandler.closes9  < " L   ! ! ! ! ! " "r7cd|_|jr|j|j"|jd|_dSdS)zForcefully close connection.TN)rbrZrrrrs r8rzRequestHandler.force_closesW  < " L   ! ! ! > % N " " "!DNNN & %r7requestresponserc|jrJ|jEtr|J|j|||j|z dSdSdSr)rfrr logrr)rrrrs r8 log_accesszRequestHandler.log_accesssp   PT%7%C ('''   " "7Hdjoo6G6G$6N O O O O O P P%C%Cr7argskwc<|jr|jj|i|dSdSr)r_r^rrrs r8 log_debugzRequestHandler.log_debugs6 : + DK t *r * * * * * + +r7c*|jj|i|dSr)r^ exceptionrs r8 log_exceptionzRequestHandler.log_exception#s" t*r*****r7c8d|_|js|jsdS|j}|}|j}||kr"|||j|_dS|jr/|j s| dSdSdSr) rQrbrKrrrPrrrZrr)rrrnowrs r8rz!RequestHandler._process_keepalive&s!%   DO  Fziikk4   %)\\*d>U%V%VD " F <  1 1 3 3             r7 start_timerzcKd|_ ||_||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)rercgetattrwarningswarnDeprecationWarningfinish_responser#rrrr handle_error ExceptionrYr)rrrrzrespresetr@s r8_handle_requestzRequestHandler._handle_request7s %)! 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 D K|j}|j}|J|j}d}|jJ|jJ|js|js; ||_|jd{Vd|_n #d|_wxYw|j \}}|j |j |j r1t|j|jkr||jr|nd}|xjdz c_t'||}t)|t*r||} t.}n|j} ||||||jpt3j|} || || } t8jdkrDt)|t<rt3j| d} nUt3j | |d} n=t8jdkrt3j | |d} n|| } | d{V\}} nK#tB$r>|"dYd| _#|j$||"d n[wxYw~ | r=|"d  d| _#|j$||"d ntK|j&|_'|(s|j)}|js-|r*|"d ||}||z} |(s||krtU||z 4d{V|+d{Vdddd{Vn#1d{VswxYwY|}|(s||kn[#t2j,t2j-f$r=t8jd kr*t3jx}r|.rYnwxYw|(s0|js)|"d |/|0tbn#t2j,$r+|"d|2tf$r5}|4d||2Yd}~n&d}~wtj$r|2wxYwd| _#|j$||"d n,#d| _#|j$||"d wwwxYw|j'rT|j6sM|jsF||z}||_7|j8 |9||j:|_8nn|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. 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.startbsqz-""" 3$000$000#A > ((#'#5#5#7#7DL,&&&&&&&#'DLL4DL''''#~5577 GW |' --///# 2''4+FFF//111$(#8BDIIKKKdE  " "a ' " "!$--F'8,, 8"&":":7"C"C"&"7 ++"@g&:4&@&@ GH N++GUOLL#w..!$ 66O&24TJJJ&|DtNNN%00"<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*C#A H  '!%D ~)$$&&&&& ' '))s&A.. A7B(R I R J+R JR A/R 2O&9N&O&& N00O&3N041O&%R &AP>;R =P>>A!R U AT5"+T U#T55U)VrcK||jr7|js/|j'|j|jdd|_|jr |j|j\}}}n:#t$r-}td||j tfg}d}d}Yd}~nd}~wwxYw||_||_|D]1\}} |xj dz c_ |j || f2t|j|jkr|n|jr||jJ |j} n|#t*$ro||dn|d|t/} t1| j| j| j| j }|j} YnwxYw | |d{V|d{Vn+#t<$r|||||d fcYSwxYw|||||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. 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_responses  N, ,N, ,$, ( L % %e , , ,"DN!$ ,/3|/E/E*00,Hh+ %'*$-(1(9 *  H %HDDDDDD""*%)"$,::LC''1,''N))3.9999t~&&$*BBB224444(633555|+++ (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(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)NrrcVK|jjjSr)rr?r@rA)rr5rs r8handlerz3RequestHandler._make_error_handler..handlers/$$(,8H r7)r&r()rr5r8s`` r8r z"RequestHandler._make_error_handlers< ; >        r7)rr)rN)rNN);r2r3r4r5 __slots__rr%r LOG_FORMATrrAbstractEventLoopr|rr typerrErBryrrrrtuplerrpropertyrjr BaseTransportrrDrrrrrbytesrrrrrr&r(rr rrrrrrrrr>r  __classcell__)rs@r8r)r)ds$$L#IV$("&7C*!-!8!" $. $()'X)X)X)X)' X) ! X)X)X)34X)X)X)X)X)X)X) !X)"#X)$%X)&!&'X)X)X)X)X)X)t #     X&67     uS#sC'( (5c? :T A     uS#sC'( (5c? :T A    '5'''X'00edl0d0000d")>"4"""""":(=4#7(D((((((F7;...#2t8,t3.  ...."    4%4D4444l * * * **d*t****""""""""P"P.<PDIDLP PPPP+s+#+$+++++3+c+d++++"))DL)";->1J"JK ) ~t# $ ))))VX'X'X'X'tT"T*8TFKdlT ~t# $TTTTr$(" <<<<T ! < t <  <<<<|  ;->!:: ;r7)Srasyncio.streamsrr.rasyncio.base_eventsr collectionsrcollections.abcrrr contextlibrhtmlr r1httpr 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`s ------9999999999&&&&&&555555555555 ++++++;;;;;;;;''''''55555555+*****--------00000000&&&&&&BBBBBBBB!!!!!!$$$$$$22222222 I #JJJ""""""  K=)N*CCD    DHSMM  !!!!!)!!!88888888+*,,T$d33343 "X-|; <t t t t t \t t t t t r7