U u?dW @sddlZddlZddlZddlZddlmZddlmZddlm Z ddl m Z ddl mZddlmZmZmZmZmZmZmZmZmZmZmZddlZddlZdd lmZmZdd 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.ddl/m0Z0ddl1m2Z2ddl3m4Z4ddl5m6Z6ddl7m8Z8m9Z9dZ:erZddl;me'dde&iidddde?d Z@GdddeAZBGdddeAZCejDdddd Gd!d"d"ZEeee'eEfe.fZFGd#dde!ZGdS)$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) HTTPException) AccessLogger) BaseRequest)ResponseStreamResponse)RequestHandlerRequestPayloadErrorPayloadAccessError)Serverr&zasyncio.Task[None]UNKNOWN/TFc@seZdZdZdS)r'zPayload parsing error.N__name__ __module__ __qualname____doc__r1r18/tmp/pip-unpacked-wheel-_pk67_um/aiohttp/web_protocol.pyr'Nsr'c@seZdZdZdS)r(z-Payload was accessed after response was sent.Nr,r1r1r1r2r(Rsr()Z auto_attribsfrozenslotsc@s&eZdZUeed<eed<eed<dS)_ErrInfostatusexcmessageN)r-r.r/int__annotations__ BaseExceptionstrr1r1r1r2r5Vs r5cseZdZdZdZdZddeeeej ddddd d dd d e j e e eeeeee eeee ee d fddZedddZee dddZdHee ddddZe jddfdd Zeeddfdd Zedd d!d"Zddd#d$Ze dd%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@Z0dIe%eeeeee&dBdCdDZ1e2e+e%ge,e&fdEdFdGZ3Z4S)Jr&aHTTP 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 r)_request_count _keepalive_manager_request_handler_request_factory_tcp_keepalive_keepalive_time_keepalive_handle_keepalive_timeout_lingering_time _messages _message_tail_waiter _task_handler_upgrade_payload_parser_request_parserZ_reading_pausedloggerdebug access_logr_close _force_close_current_requestgR@TFiig$@i) keepalive_timeoutr rNaccess_log_classrPaccess_log_formatrO max_line_size max_headersmax_field_sizelingering_time read_bufsizeauto_decompressr))managerlooprTr rNrUrPrVrOrWrXrYrZr[r\c st|d|_d|_d|_||_|j|_|j|_ ||_ d|_ d|_ ||_ t| |_t|_d|_d|_d|_d|_d|_t|||| | | t|d|_||_| |_||_|r||||_nd|_d|_d|_dS)NrFg)rWrYrXZpayload_exceptionr\) super__init__r=r>rSr?request_handlerr@Zrequest_factoryrArBrCrDrEfloatrFrrGrHrIrJrKrLrr'rMrNrOrPrrQrR)selfr]r^rTr rNrUrPrVrOrWrXrYrZr[r\ __class__r1r2rasN   zRequestHandler.__init__)returncCsd|jj|jdk rdndS)Nz<{} {}> connectedZ disconnected)formatrfr- transportrdr1r1r2__repr__szRequestHandler.__repr__cCs|jSN)rErkr1r1r2rTsz RequestHandler.keepalive_timeout.@N)timeoutrgc sd|_|jdk r|j|jr*|jttjtjbt|4IdH@|j dk rf|j t|j dk r|j s|j IdHW5QIdHRXW5QRX|j dk r|j |j dk r|j d|_ 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)rRrDcancelrIrasyncioCancelledError TimeoutErrorrrS_cancelrJdonerjclose)rdror1r1r2shutdowns     &    zRequestHandler.shutdown)rjrgcsXt|ttj|}|jr&t||j| |_ |j dk sFt |j ||dSrm) r`connection_maderrq TransportrBr _loop create_taskstartrJr?AssertionError)rdrjZreal_transportrer1r2rxs  zRequestHandler.connection_made)r7rgcs|jdkrdS|j||t|d|_d|_d|_d|_d|_|jdk rZ|j|j dk r|dkrtt d}|j ||j dk r|j d|_ |jdk r|jd|_dS)NTzConnection lost)r?connection_lostr`rRrAr@rMrDrprSConnectionResetErrorrtrIrJrLZfeed_eof)rdr7rer1r2r~s*          zRequestHandler.connection_lost)parserrgcCs2|jdkst||_|jr.|j|jd|_dS)Nr_)rLr}rH feed_data)rdrr1r1r2 set_parser7s zRequestHandler.set_parsercCsdSrmr1rkr1r1r2 eof_receivedAszRequestHandler.eof_received)datargc 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)r6r7r8Fr_r1r)rRrQrLrKrMr}rrr5r8rr=rGappendrIruZ set_resultrHrv) rdrmessagesZupgradedtailr7msgpayloadwaitereofr1r1r2 data_receivedDs4  zRequestHandler.data_received)valrgcCs ||_|jr|jd|_dS)zMSet keep-alive connection mode. :param bool val: new state. N)r>rDrp)rdrr1r1r2 keep_aliveks zRequestHandler.keep_alivecCsd|_|jr|jdS)zClose connection. Stop accepting new pipelining messages and close connection when handlers done processing messages. TN)rQrIrprkr1r1r2rvuszRequestHandler.closecCs4d|_|jr|j|jdk r0|jd|_dS)zForcefully close connection.TN)rRrIrprjrvrkr1r1r2 force_closes    zRequestHandler.force_close)requestresponsetimergcCs(|jdk r$|j|||j|dSrm)rlogrzr)rdrrrr1r1r2 log_accesss zRequestHandler.log_access)argskwrgcOs|jr|jj||dSrm)rOrNrdrrr1r1r2 log_debugszRequestHandler.log_debugcOs|jj||dSrm)rN exceptionrr1r1r2 log_exceptionszRequestHandler.log_exceptioncCsT|js |jsdS|j|j}|jr<|j|kr<|dS|j|j |j |_ dSrm) rRr>rCrErIrzrrZ call_laterKEEPALIVE_RESCHEDULE_DELAY_process_keepaliverD)rdnextr1r1r2rs  z!RequestHandler._process_keepalive)r start_timerbrgc sP|jdk stz&z||_||IdH}W5d|_XWntk rn}z|}||||IdH}W5d}~XYntjk rYntjk r}z2|jd|d| |d}||||IdH}W5d}~XYntt k r}z&| |d|}||||IdH}W5d}~XYn0Xt |ddr4t dt||||IdH}||fS)NzRequest handler timed out.exc_infoiZ__http_exception__Fzlreturning HTTPException object is deprecated (#2415) and will be removed, please raise the exception instead)r@r}rSr!finish_responserqrrrsr handle_error ExceptiongetattrwarningswarnDeprecationWarning)rdrrrbrespr7resetr1r1r2_handle_requests2 $ $&zRequestHandler._handle_requestc s|j}|j}|dk st|j}|dk s*t|j}d}|jdk sBt|jdk sPt|js|jsz@z| |_ |j IdHWn t j k rYWqYnXW5d|_ X|j \}}|}|jd7_t||} t|tr||} t}n|j} ||||| |} dzzh|j|| || } z| IdH\}}Wn6t j tfk rp|dYWWqYnX~ |r|dWWqt |j!|_|"sj|j#}|jsF|rF|d||} | |}t$t j%t j Z|"s<| |krrQrCrDZcall_atrr{rConnectionErrorboolrZis_eofrFrrsrZreadanyrvZ set_exceptionr( RuntimeErrorrOrrr)rdr^handlerr]rTrr8rr|writerrbrnowZtaskrrZZend_tr7r1r1r2r|s                    zRequestHandler.start)rrrrgcs|jdk r6|jdd|_|jr6|j|jd|_z |j}Wn4tk rt|dkrbtdntd|YnXz ||IdH| IdHWn$t k r| |||YdSX| |||dSdS)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. NFr_z+Missing return statement on request handlerz7Web-handler should return a response instance, got {!r}T) rMZ set_upgradedrKrHrprepareAttributeErrorrri write_eofrr)rdrrrZ prepare_methr1r1r2rGs0     zRequestHandler.finish_responser)rr6r7r8rgc 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 )r6text content_type)rrZ output_sizerrINTERNAL_SERVER_ERRORri descriptionrOrr traceback format_excheadersget html_escaper$r) rdrr6r7r8ctrrtbrr1r1r2rls:       zRequestHandler.handle_error)err_inforgcsttdfdd }|S)N)rrgcs|jjjSrm)rr6r7r8)rrrdr1r2rs z3RequestHandler._make_error_handler..handler)r#r%)rdrrr1rr2rsz"RequestHandler._make_error_handler)rn)rNN)5r-r.r/r0r __slots__rr"rZ LOG_FORMATrqZAbstractEventLooprcrrrrr<r9rarlpropertyrTr rwZ BaseTransportrxr;r~rrrbytesrrrvrr#r%rrrrr r rrr|rrr5r __classcell__r1r1rer2r&`s#!C  '     'z ( 4)HrqZasyncio.streamsrr collectionsr contextlibrhtmlrrhttprloggingrtypingrrr r r r r rrrrattrZyarlabcrrZ base_protocolrZhelpersrrrrrrrrrZstreamsrrZ tcp_helpersr Zweb_exceptionsr!Zweb_logr"Z web_requestr#Z web_responser$r%__all__Z web_serverr)Z_RequestFactoryZ_RequestHandlerURLrrr'r(sr5Z_MsgTyper&r1r1r1r2sl     4