o `gc @s$ddlZddlZddlZddlZddlZddlmZddlmZddl 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+ddl,m-Z-m.Z.ddl/m0Z0m1Z1ddl2m3Z3ddl4m5Z5m6Z6ddl7m8Z8ddl9m:Z:ddl;merddl?m@Z@ee(e1de dge:fZAee:gee=fZBe(dde'iiddddeCd ZDGdddeEZFGdd d eEZGeGZHejIdddd!Gd"d#d#ZJeee(eJfe1fZKGd$dde"ZLdS)%N)deque)suppress)escape) HTTPStatus)Logger) TYPE_CHECKINGAny AwaitableCallableDequeOptionalSequenceTupleTypeUnioncast)AbstractAccessLoggerAbstractStreamWriter) BaseProtocol) ceil_timeout)HttpProcessingErrorHttpRequestParser HttpVersion10RawRequestMessage StreamWriter) BadHttpMethod) access_logger server_logger) EMPTY_PAYLOAD StreamReader) tcp_keepalive) HTTPExceptionHTTPInternalServerError) AccessLogger) BaseRequest)ResponseStreamResponse)RequestHandlerRequestPayloadErrorPayloadAccessError)Serverr(zasyncio.Task[None]UNKNOWN/TFc@eZdZdZdS)r)zPayload parsing error.N__name__ __module__ __qualname____doc__r4r4O/var/www/html/propose/venv/lib/python3.10/site-packages/aiohttp/web_protocol.pyr)Pr)c@r.)r*z-Payload was accessed after response was sent.Nr/r4r4r4r5r*Tr6r*) auto_attribsfrozenslotsc@s&eZdZUeed<eed<eed<dS)_ErrInfostatusexcmessageN)r0r1r2int__annotations__ BaseExceptionstrr4r4r4r5r:[s  r:c!sFeZdZdZdZddeeeejdddddd dd d d d de j de de de deede dede dededede dede de f fddZdefd d!Zede fd"d#Zd\d%ee dd&fd'd(Zd)e jdd&ffd*d+ Zd,eedd&ffd-d. Zd/edd&fd0d1Zd]d2d3Zd4edd&fd5d6Z d7e dd&fd8d9Z!d]d:d;Z"d]de$d?e%d@e dd&fdAdBZ&dCedDedd&fdEdFZ'dCedDedd&fdGdHZ(d]dIdJZ)d>e$dKe dLe*e$ge+e%fde,e%e ffdMdNZ-d]dOdPZ.d>e$dQe%dKe de,e%e ffdRdSZ/ T & &d^d>e$dUed,eedVeede%f dWdXZ0dYe1de*e$ge+e%ffdZd[Z2Z3S)_r(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_progressi.TFiig$@i)keepalive_timeoutr!rUaccess_log_classrWaccess_log_formatrV max_line_size max_headersmax_field_sizelingering_time read_bufsizeauto_decompresstimeout_ceil_thresholdmanagerr+loopr^r!rUr_rWr`rVrarbrcrdrerfrgc st|d|_d|_d|_||_|j|_|j|_ ||_ d|_ d|_ ||_ t| |_t|_d|_d|_d|_d|_d|_d|_t|||| | | t|d|_d|_zt||_Wn ttfycYnw||_| |_||_ |rv||||_!nd|_!d|_"d|_#d|_$dS)NrFg)rarcrbpayload_exceptionrfr])%super__init__rBrCrZrDrequest_handlerrErequest_factoryrFrGrHrIrJfloatrKrrLrMrOrNrPrQrRrr)rSr[ TypeError ValueErrorrUrVrWrrXrYr\)selfrhrir^r!rUr_rWr`rVrarbrcrdrerfrg __class__r4r5rms\    zRequestHandler.__init__returncCs d|jj|jdur dSdS)Nz<{} {}> connected disconnected)formatrur0 transportrsr4r4r5__repr__s  zRequestHandler.__repr__cCs|jSN)rJr{r4r4r5r^sz RequestHandler.keepalive_timeout.@timeoutNc sd|_|jdur|j|jr^|j|_z&t|4IdH|jIdHWdIdHn 1IdHs7wYWn tj tj fy]d|_t j dkr[t }r[|r[Ynwz@t|4IdH+|jduru|jt |jdur|jst|jIdHWdIdHn 1IdHswYWntj tj fyt j dkrt }r|rYnw|jdur|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 )rYrIcancelr\_loop create_futurerNrasyncioCancelledError TimeoutErrorsys version_info current_task cancellingrZ_cancelrPdoneshield force_close)rsrtaskr4r4r5shutdownsT   (    (    zRequestHandler.shutdownrzcst|ttj|}|jrt||jdusJ|j|||j}t j dkr4tj | |dd}n| | }||_dS)Nr Tri eager_start)rlconnection_maderr TransportrGr!rDrrrTaskstart create_taskrP)rsrzreal_transportrirrtr4r5r6s    zRequestHandler.connection_mader<cs|jdurdS|j|||jj}|t|d|_d|_d|_d|_|jdur2|j |j durE|dur?t d}|j ||rQ|j durQ|j d|_ |jdurc|jd|_dSdS)NzConnection lost)rDconnection_losthandler_cancellationrrlrFrErSrIrrZConnectionResetErrorrrPrRfeed_eof)rsr<rrtr4r5rGs.          zRequestHandler.connection_lostparsercCs6|jdusJ||_|jr|j|jd|_dSdS)Nrj)rRrM feed_data)rsrr4r4r5 set_parsergs  zRequestHandler.set_parsercCsdSr}r4r{r4r4r5 eof_receivedqszRequestHandler.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)r;r<r=Frjr4r)rYrXrRrQrSrrr:r=rrBrLappendrOr set_resultrMclose) rsrmessagesupgradedtailr<msgpayloadwaitereofr4r4r5 data_receivedts>    zRequestHandler.data_receivedvalcCs$||_|jr|jd|_dSdS)zMSet keep-alive connection mode. :param bool val: new state. N)rCrIr)rsrr4r4r5 keep_alives   zRequestHandler.keep_alivecCsd|_|jr |jdSdS)zClose connection. Stop accepting new pipelining messages and close connection when handlers done processing messages. TN)rXrOrr{r4r4r5rszRequestHandler.closecCs8d|_|jr |j|jdur|jd|_dSdS)zForcefully close connection.TN)rYrOrrzrr{r4r4r5rs    zRequestHandler.force_closerequestresponsetimecCs8|jdur|jjr|j|||j|dSdSdSr})renabledlogrr)rsrrrr4r4r5 log_accessszRequestHandler.log_accessargskwcOs |jr|jj|i|dSdSr})rVrUrsrrr4r4r5 log_debugszRequestHandler.log_debugcOs|jj|i|dSr})rU exceptionrr4r4r5 log_exceptionszRequestHandler.log_exceptioncCsjd|_|js |js dS|j}|}|j}||kr#|||j|_dS|jr1|j s3| dSdSdSr}) rIrYrCrrrHcall_at_process_keepaliverOrr)rsrinow close_timer4r4r5rs  z!RequestHandler._process_keepalive start_timernc sd|_zzz||_||IdH}Wd|_nd|_wWnwty;}z|}||||IdH\}}WYd}~ntd}~wtjyCtjyn}z|jd|d||d}||||IdH\}}WYd}~nAd}~wt y}z||d|}||||IdH\}}WYd}~nd}~wwt |ddrt dt ||||IdH\}}Wd|_|jdur|jd||fSd|_|jdur|jdww) NTzRequest handler timed out.exc_infoi__http_exception__Fzlreturning HTTPException object is deprecated (#2415) and will be removed, please raise the exception instead)r\rZr"finish_responserrrr handle_error ExceptiongetattrwarningswarnDeprecationWarningrNr)rsrrrnrespr<resetr4r4r5_handle_requestsL$ $$    zRequestHandler._handle_requestc s<|j}t|}|dusJ|j}|dusJ|j}d}|jdus$J|jdus+J|js|jsGz| |_ |j IdHWd|_ nd|_ w|j \}}| }|j d7_ t||} t|trk||} t}n|j} ||||| |} zȐz[|| || } tjdkrtj| |dd} n|| } z | IdH\}}WnJty|dYWW|jdur|dur|dn|js|jr|js|dur| }||}||_|jdur|||j |_nnnw~ |r6|dWW|jdur|dur|dn|js4|jr2|js2|dur0| }||}||_|jdur0|||j |_nTnRnPt!|j"|_|#s|j$}|js|r|d || }||}zB|#s||krt%||4IdH|&IdHWdIdHn 1IdHswY| }|#s||ksdWn!tj'tj(fytjd krt}r|)rYnw|#s|js|d |*|+t,Wn,tj'y|dt-y}z|j.d |d |/WYd}~nd}~wwW|jdur|dur|dno|js@|jr?|js?|dur>| }||}||_|jdur>|||j |_nDnFnB|jdurR|durR|dw|js|jr}|js}|dur|| }||}||_|jdur||||j |_wYnw|jr/|jsd|_0|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. 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)1rrrrDrJrFrErYrLrrOpopleftrrequests_countr isinstancer:_make_error_handlerERRORrrrrrConnectionErrorrrzrCrXrHrIrrboolris_eofrKrreadanyrrrr set_exception_PAYLOAD_ACCESS_ERRORrrrrP)rsrihandlerrhr^rr=rrwriterrnrcororrrrrdend_ttr<r4r4r5rs"           2   ,   *           e zRequestHandler.startrc s||jdur |jdd|_|jr |j|jd|_z|j}Wn-tyR|dur6|dn|d |t }t |j |j |j|jd}|j}Ynwz||IdH|IdHWntyw|||||dfYSw|||||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. NFrjz+Missing return statement on request handlerz7Web-handler should return a response instance, got {!r})r;reasontextheadersT)_finishrS set_upgradedrQrMrprepareAttributeErrorrryr#r&r;rrr write_eofrr)rsrrr prepare_methr<r4r4r5r~s@         zRequestHandler.finish_responserr;r=c Cs|jdkrt|tr|jjd|dn|jd|d|jjdkr$tdd}|t j kr{d t j }t j j }d}|jrRt t t}Wdn1sMwYd |jd d vrq|rgt|}d |d }dj ||d}d }n |ru|}|d|}t|||d} | | S)zHandle errors. Returns HTTP response with specific status code. Logs additional information. It always closes current connection. rzError 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 )r;r content_type)rBrrrUrVrr output_sizerrINTERNAL_SERVER_ERRORry descriptionrr traceback format_excrget html_escaper&r) rsrr;r<r=ctrrtbrr4r4r5rs<        zRequestHandler.handle_errorerr_infocsdtdtffdd }|S)Nrrvcs|jjjSr})rr;r<r=)rrrsr4r5rsz3RequestHandler._make_error_handler..handler)r%r')rsrrr4rr5rsz"RequestHandler._make_error_handler)r~)rvN)rNN)4r0r1r2r3 __slots__rr$r LOG_FORMATrAbstractEventLooprprrrrrAr>rmr|propertyr^r r BaseTransportrr@rrrrbytesrrrrr%r'rrrrr r rrrrrr:r __classcell__r4r4rtr5r(es'%     N2 '      +}  - :)Mrasyncio.streamsrrr collectionsr contextlibrhtmlrrhttprloggingrtypingrrr r r r r rrrrattryarlabcrr base_protocolrhelpersrrrrrrhttp_exceptionsrrrrstreamsrr tcp_helpersr!web_exceptionsr"r#web_logr$ web_requestr% web_responser&r'__all__ web_serverr+_RequestFactory_RequestHandlerURLrrr)r*rsr:_MsgTyper(r4r4r4r5st     4