U j7g$a @sddlZddlZddlZddlZddlZddlmZddlmZddl 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+m,Z,ddl-m.Z.m/Z/ddl0m1Z1ddl2m3Z3m4Z4ddl5m6Z6ddl7m8Z8ddl9m:Z:m;Z;dZZ>ee(e/de dge8fZ?ee8gee;fZ@e(dde'iiddddeAd ZBGdddeCZDGdddeCZEeEZFejGdddd Gd!d"d"ZHeee(eHfe/fZIGd#dde"ZJdS)$N)deque)suppress)escape) HTTPStatus)Logger) TYPE_CHECKINGAny AwaitableCallableDequeOptionalSequenceTupleTypeUnioncast)AbstractAccessLoggerAbstractStreamWriter) BaseProtocol) ceil_timeout)HttpProcessingErrorHttpRequestParser HttpVersion10RawRequestMessage StreamWriter) access_logger server_logger) EMPTY_PAYLOAD StreamReader) tcp_keepalive) HTTPExceptionHTTPInternalServerError) AccessLogger) BaseRequest)ResponseStreamResponse)RequestHandlerRequestPayloadErrorPayloadAccessError)Serverr'zasyncio.Task[None]UNKNOWN/TFc@seZdZdZdS)r(zPayload parsing error.N__name__ __module__ __qualname____doc__r2r28/tmp/pip-unpacked-wheel-cme3dcq2/aiohttp/web_protocol.pyr(Osr(c@seZdZdZdS)r)z-Payload was accessed after response was sent.Nr-r2r2r2r3r)Ssr))Z auto_attribsfrozenslotsc@s&eZdZUeed<eed<eed<dS)_ErrInfostatusexcmessageN)r.r/r0int__annotations__ BaseExceptionstrr2r2r2r3r6Zs r6cseZdZdZdZddeeeejdddddd dd d d e j e e e eee ee eeee ee e d fddZedddZee dddZdHee ddddZe jddfdd Zeeddfdd Zedd d!d"Zddd#d$Zedd%d&d'Z e dd(d)d*Z!ddd+d,Z"ddd-d.Z#e$e%e dd/d0d1Z&eedd2d3d4Z'eedd2d5d6Z(ddd7d8Z)e$e e*e$ge+e%fe,e%e fd9d:d;Z-dddd?d@Z/dIe$eeeeee%dBdCdDZ0e1e*e$ge+e%fdEdFdGZ2Z3S)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_parserZ_reading_pausedloggerdebug access_logr_close _force_close_current_request_timeout_ceil_threshold_request_in_progressgR@TFiig$@i)keepalive_timeoutr rPaccess_log_classrRaccess_log_formatrQ max_line_size max_headersmax_field_sizelingering_time read_bufsizeauto_decompresstimeout_ceil_thresholdr*)managerlooprYr rPrZrRr[rQr\r]r^r_r`rarbc s t|d|_d|_d|_||_|j|_|j|_ ||_ d|_ d|_ ||_ t| |_t|_d|_d|_d|_d|_d|_d|_t|||| | | t|d|_d|_zt||_Wnttfk rYnX||_| |_||_ |r||||_!nd|_!d|_"d|_#d|_$dS)NrFg)r\r^r]Zpayload_exceptionrarX)%super__init__r>r?rUr@request_handlerrAZrequest_factoryrBrCrDrErFfloatrGrrHrIrKrJrLrMrNrr(rOrV TypeError ValueErrorrPrQrRrrSrTrW)selfrcrdrYr rPrZrRr[rQr\r]r^r_r`rarb __class__r2r3rgs\   zRequestHandler.__init__)returncCsd|jj|jdk rdndS)Nz<{} {}> connectedZ disconnected)formatrnr. transportrlr2r2r3__repr__szRequestHandler.__repr__cCs|jSN)rFrsr2r2r3rYsz RequestHandler.keepalive_timeout.@N)timeoutroc spd|_|jdk r|j|jr|j|_z2t|4IdH|jIdHW5QIdHRXWnBtj tj fk rd|_t j dkrt }r|rYnXzft|4IdHF|jdk r|jt |jdk r|jst|jIdHW5QIdHRXWnDtj tj fk rLt j dkrHt }rH|rHYnX|jdk rd|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 )rTrEcancelrW_loop create_futurerJrasyncioCancelledError TimeoutErrorsys version_info current_task cancellingrU_cancelrLdoneZshield force_close)rlrwtaskr2r2r3shutdownsD      &   zRequestHandler.shutdown)rrrocst|ttj|}|jr&t||jdk s4t|j|||j }t j dkrhtj | |dd}n|| }||_dS)Nry TrdZ eager_start)rfconnection_maderr~ TransportrCr r@AssertionErrorr|rrTaskstart create_taskrL)rlrrZreal_transportrdrrmr2r3r3s   zRequestHandler.connection_made)r8rocs|jdkrdS|j|||jj}|t|d|_d|_d|_d|_|jdk rd|j |j dk r|dkr~t d}|j ||r|j dk r|j d|_ |jdk r|jd|_dS)NzConnection lost)r@connection_losthandler_cancellationrrfrBrArOrEr{rUConnectionResetErrorrrLrNZfeed_eof)rlr8rrmr2r3rDs,         zRequestHandler.connection_lost)parserrocCs2|jdkst||_|jr.|j|jd|_dS)Nre)rNrrI feed_data)rlrr2r2r3 set_parserds zRequestHandler.set_parsercCsdSrur2rsr2r2r3 eof_receivednszRequestHandler.eof_received)dataroc CsB|js |jrdS|jdkr|js|jdk s.tz|j|\}}}Wn@tk r}z"td||j dt fg}d}d}W5d}~XYnX|pdD]&\}}|j d7_ |j ||fq|j}|r|dk r|s|d||_|r|r||_nN|jdkr|jr|r|j|7_n$|r>|j|\} }| r>|dS)Ni)r7r8r9Frer2r)rTrSrNrMrOrrrr6r9rr>rHappendrKr set_resultrIclose) rlrmessagesZupgradedtailr8msgpayloadwaitereofr2r2r3 data_receivedqs4  zRequestHandler.data_received)valrocCs ||_|jr|jd|_dS)zMSet keep-alive connection mode. :param bool val: new state. N)r?rEr{)rlrr2r2r3 keep_alives zRequestHandler.keep_alivecCsd|_|jr|jdS)zClose connection. Stop accepting new pipelining messages and close connection when handlers done processing messages. TN)rSrKr{rsr2r2r3rszRequestHandler.closecCs4d|_|jr|j|jdk r0|jd|_dS)zForcefully close connection.TN)rTrKr{rrrrsr2r2r3rs    zRequestHandler.force_close)requestresponsetimerocCs(|jdk r$|j|||j|dSru)rlogr|r)rlrrrr2r2r3 log_accesss zRequestHandler.log_access)argskwrocOs|jr|jj||dSru)rQrPrlrrr2r2r3 log_debugszRequestHandler.log_debugcOs|jj||dSru)rP exceptionrr2r2r3 log_exceptionszRequestHandler.log_exceptioncCsbd|_|js|jsdS|j}|}|j}||krF|||j|_dS|jr^|j s^| dSru) rErTr?r|rrDcall_at_process_keepaliverKrr)rlrdnow close_timer2r2r3rs z!RequestHandler._process_keepalive)r start_timerhroc sd|_zNz&z||_||IdH}W5d|_XWntk rn}z |}||||IdH\}}W5d}~XYntjk rYntjk r}z6|j d|d| |d}||||IdH\}}W5d}~XYn|t k r }z*| |d|}||||IdH\}}W5d}~XYn4Xt |ddr|jdd|_|jr>|j|jd|_z |j}Wn\tk r|dkrl|dn|d |t }t |j |j |j|jd}|j}YnXz ||IdH|IdHWn*tk r|||||dfYSX|||||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. NFrez+Missing return statement on request handlerz7Web-handler should return a response instance, got {!r})r7reasontextheadersT)Z_finishrOZ set_upgradedrMrIrprepareAttributeErrorrrqr"r%r7rrr write_eofrr)rlrrrZ prepare_methr8r2r2r3r{sB      zRequestHandler.finish_responser)rr7r8r9roc Cs|jd|d|jjdkr"tdd}|tjkrdtj}tjj}d}|jrjt t t }W5QRXd|j d d kr|rt|}d |d }d j||d}d}n|r|}|d|}t|||d} | | S)zHandle errors. Returns HTTP response with specific status code. Logs additional information. It always closes current connection. zError 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 )r7r content_type)rrZ output_sizerrINTERNAL_SERVER_ERRORrq descriptionrQrr traceback format_excrget html_escaper%r) rlrr7r8r9ctrrtbrr2r2r3rs:       zRequestHandler.handle_error)err_inforocsttdfdd }|S)N)rrocs|jjjSru)rr7r8r9)rrrlr2r3rs z3RequestHandler._make_error_handler..handler)r$r&)rlrrr2rr3rsz"RequestHandler._make_error_handler)rv)rNN)4r.r/r0r1 __slots__rr#rZ LOG_FORMATr~ZAbstractEventLooprirrrrr=r:rgrtpropertyrYr rZ BaseTransportrr<rrrrbytesrrrrr$r&rrrrr r rrrrrr6r __classcell__r2r2rmr3r'ds'$L2  '     +~ - 4)Kr~Zasyncio.streamsrrr collectionsr contextlibrhtmlrrhttprloggingrtypingrrr r r r r rrrrattrZyarlabcrrZ base_protocolrZhelpersrrrrrrrrrZstreamsrrZ tcp_helpersr Zweb_exceptionsr!r"Zweb_logr#Z web_requestr$Z web_responser%r&__all__Z web_serverr*Z_RequestFactoryZ_RequestHandlerURLrrr(r)rsr6Z_MsgTyper'r2r2r2r3sp     4