o e&Z @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:erddl;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@eZdZdZdS)r'zPayload parsing error.N__name__ __module__ __qualname____doc__r2r2DD:\Projects\ConvertPro\env\Lib\site-packages\aiohttp/web_protocol.pyr'Nr'c@r,)r(z-Payload was accessed after response was sent.Nr-r2r2r2r3r(Rr4r()Z auto_attribsfrozenslotsc@s&eZdZUeed<eed<eed<dS)_ErrInfostatusexcmessageN)r.r/r0int__annotations__ BaseExceptionstrr2r2r2r3r7Vs  r7cs<eZdZdZdZdZddeeeej ddddd d dd d d de j de de dedeededede dededede dede ffddZdefdd Zede fd!d"Zd[d$ee dd%fd&d'Zd(e jdd%ffd)d* Zd+eedd%ffd,d- Zd.edd%fd/d0Zd\d1d2Zd3e dd%fd4d5Z!d6e dd%fd7d8Z"d\d9d:Z#d\d;d<Z$d=e%d>e&d?e dd%fd@dAZ'dBedCedd%fdDdEZ(dBedCedd%fdFdGZ)d\dHdIZ*d=e%dJe dKe+e%ge,e&fde-e&e ffdLdMZ.d\dNdOZ/d=e%dPe&dJe de fdQdRZ0 S % %d]d=e%dTed+eedUeede&f dVdWZ1dXe2de+e%ge,e&ffdYdZZ3Z4S)^r&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 rPaccess_log_classrRaccess_log_formatrQ max_line_size max_headersmax_field_sizelingering_time read_bufsizeauto_decompressmanagerr)looprVr rPrWrRrXrQrYrZr[r\r]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)rYr[rZZpayload_exceptionr^) super__init__r?r@rUrArequest_handlerrBZrequest_factoryrCrDrErFrGfloatrHrrIrJrKrLrMrNrr'rOrPrQrRrrSrT)selfr_r`rVr rPrWrRrXrQrYrZr[r\r]r^ __class__r2r3rcsL    zRequestHandler.__init__returncCs d|jj|jdur dSdS)Nz<{} {}> connected disconnected)formatrhr. transportrfr2r2r3__repr__s  zRequestHandler.__repr__cCs|jSN)rGrnr2r2r3rVsz RequestHandler.keepalive_timeout.@timeoutNc sd|_|jdur|j|jr|jttjtjCt|4IdH(|j dur4|j t|j durD|j sD|j IdHWdIdHn 1IdHsTwYWdn1scwY|j durr|j |j dur|j d|_ dSdS)zDo worker process exit preparations. We need to clean up everything and stop accepting requests. It is especially important for keep-alive connections. TN)rTrFcancelrKrasyncioCancelledError TimeoutErrorrrU_cancelrLdonermclose)rfrrr2r2r3shutdowns,     (    zRequestHandler.shutdownrmcsXt|ttj|}|jrt||j| |_ |j dus#J|j ||dSrp) rbconnection_maderrt TransportrDr _loop create_taskstartrLrA)rfrmZreal_transportrgr2r3r{s  zRequestHandler.connection_mader9cs|jdurdS|j||t|d|_d|_d|_d|_d|_|jdur-|j|j dur@|dur:t d}|j ||j durJ|j d|_ |jdur\|jd|_dSdS)NTzConnection lost)rAconnection_lostrbrTrCrBrOrFrsrUConnectionResetErrorrwrKrLrNfeed_eof)rfr9rgr2r3rs,           zRequestHandler.connection_lostparsercCs6|jdusJ||_|jr|j|jd|_dSdS)Nra)rNrJ feed_data)rfrr2r2r3 set_parser7s  zRequestHandler.set_parsercCsdSrpr2rnr2r2r3 eof_receivedAszRequestHandler.eof_receiveddatac CsN|js|jrdS|jdur~|js~|jdusJz |j|\}}}Wn!tyC}ztd||jdt fg}d}d}WYd}~nd}~ww|pGdD]\}}|j d7_ |j ||fqH|j }|rn|durn|sn|d||_|rz|r|||_dSdSdS|jdur|jr|r|j|7_dS|r|j|\} }| r|dSdSdS)Ni)r8r9r:Frar2r)rTrSrNrMrOrrr7r:rr?rIappendrKrx set_resultrJry) rfrmessagesZupgradedtailr9msgpayloadwaitereofr2r2r3 data_receivedDs>    zRequestHandler.data_receivedvalcCs$||_|jr|jd|_dSdS)zMSet keep-alive connection mode. :param bool val: new state. N)r@rFrs)rfrr2r2r3 keep_aliveks   zRequestHandler.keep_alivecCsd|_|jr |jdSdS)zClose connection. Stop accepting new pipelining messages and close connection when handlers done processing messages. TN)rSrKrsrnr2r2r3ryuszRequestHandler.closecCs8d|_|jr |j|jdur|jd|_dSdS)zForcefully close connection.TN)rTrKrsrmryrnr2r2r3 force_closes    zRequestHandler.force_closerequestresponsetimecCs,|jdur|j|||j|dSdSrp)rlogr}r)rfrrrr2r2r3 log_accesss zRequestHandler.log_accessargskwcOs |jr|jj|i|dSdSrp)rQrPrfrrr2r2r3 log_debugszRequestHandler.log_debugcOs|jj|i|dSrp)rP exceptionrr2r2r3 log_exceptionszRequestHandler.log_exceptioncCsT|js|jsdS|j|j}|jr|j|kr|dS|j|j |j |_ dSrp) rTr@rErGrKr}rr call_laterKEEPALIVE_RESCHEDULE_DELAY_process_keepaliverF)rfnextr2r2r3rs   z!RequestHandler._process_keepalive start_timerdc sf|jdusJzz||_||IdH}Wd|_nd|_wWnzty?}z|}||||IdH}WYd}~||fSd}~wtjyGtjys}z |jd|d||d}||||IdH}WYd}~||fSd}~wt y}z||d|}||||IdH}WYd}~||fSd}~wwt |ddrt 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)rBrUr!finish_responsertrurvr handle_error ExceptiongetattrwarningswarnDeprecationWarning)rfrrrdrespr9resetr2r2r3_handle_requestsB   zRequestHandler._handle_requestc s|j}|j}|dus J|j}|dusJ|j}d}|jdus"J|jdus)J|js|jsWz"z ||_ |j IdHWnt j yMYWd|_ nwWd|_ nd|_ w|j \}}| }|jd7_t||} t|tr{||} t}n|j} ||||| |} z zB|j|| || } z | IdH\}} WnLt j tfy|dYWW|jdur|dur|dn|js|jr|js|dur|j }||_|jdur||||j|_nnnw~ | r8|dWW|jdur |dur |dn|js6|jr4|js4|dur2|j }||_|jdur2||||j|_nnnt|j |_|!s|j"}|js|r|d|| }||}t#t j$t j H|!s||krt%||4IdH|&IdHWdIdHn 1IdHswY| }|!s||ksmWdn 1swY|!s|js|d|'|(t)Wnt j y|dYW|jdur|dur|dn|js|jr|js|dur|j }||_|jdur||||j|_nnnt*y:}z|j+r,|j,d |d |-WYd}~n"d}~wt.yW}z|j,d |d |-WYd}~nd}~wwW|jdurj|durj|dnm|js|jr|js|dur|j }||_|jdur||||j|_nCnEnA|jdur|dur|dw|js|jr|js|dur|j }||_|jdur||||j|_wYnw|jr-|jsd|_|jdur|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. Nrz&Ignored premature client disconnectionz'Ignored premature client disconnection.z(Ignored premature client disconnection 2z'Start lingering close timer for %s sec.zUncompleted request.z'Ignored premature client disconnection zUnhandled runtime exceptionrzUnhandled exception)/r}rLrArGrCrBrTrI create_futurerKrtrupopleftrZrequests_countr isinstancer7_make_error_handlerERRORr~rConnectionErrorrrmr@rSrErFcall_atrboolrZis_eofrHrrvrZreadanyry set_exceptionr( RuntimeErrorrQrrr)rfr`handlerr_rVrr:rrwriterrdrtaskrnowr\Zend_tr9r2r2r3rs8          /     )     *                  a zRequestHandler.startrcs|jdur|jdd|_|jr|j|jd|_z|j}Wnty7|dur0tdtd|wz||IdH| IdHWnt yY| |||YdSw| |||dS)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. NFraz+Missing return statement on request handlerz7Web-handler should return a response instance, got {!r}T) rOZ set_upgradedrMrJrprepareAttributeErrorrrl write_eofrr)rfrrrZ prepare_methr2r2r3rGs4     zRequestHandler.finish_responserr8r:c Cs|jd|d|jjdkrtdd}|tjkrhdtj}tjj}d}|jr?t t  t }Wdn1s:wYd|j d d vr^|rTt|}d |d }d j||d}d}n |rb|}|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 )r8text content_type)rrZ output_sizerrINTERNAL_SERVER_ERRORrl descriptionrQrr traceback format_excheadersget html_escaper$r) rfrr8r9r:ctrrtbrr2r2r3rls8       zRequestHandler.handle_errorerr_infocsdtdtffdd }|S)Nrrics|jjjSrp)rr8r9r:)rrrfr2r3rsz3RequestHandler._make_error_handler..handler)r#r%)rfrrr2rr3rsz"RequestHandler._make_error_handler)rq)riN)rNN)5r.r/r0r1r __slots__rr"rZ LOG_FORMATrtAbstractEventLooprerrrrr>r;rcropropertyrVr rz BaseTransportr{r=rrrrbytesrrryrr#r%rrrrr r rrrrrr7r __classcell__r2r2rgr3r&`s#!     C  '      'y ( 3)HrtZasyncio.streamsrr collectionsr contextlibrhtmlrrhttprloggingrtypingrrr r r r r rrrrattrZyarlabcrrZ base_protocolrhelpersrrrrrrrrrstreamsrrZ tcp_helpersr Zweb_exceptionsr!Zweb_logr"Z web_requestr#Z web_responser$r%__all__Z web_serverr)Z_RequestFactoryZ_RequestHandlerURLrrr'r(sr7Z_MsgTyper&r2r2r2r3sn     4