o +ifZ @s ddlZddlZddlZddlZddlmZddlmZddlm Z ddl m Z ddl mZddlmZmZmZmZmZmZmZmZmZmZmZddlZddlZdd lmZmZdd l m!Z!dd l"m#Z#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/ddl0m1Z1ddl2m3Z3ddl4m5Z5ddl6m7Z7ddl8m9Z9m:Z:dZ;erddlee7gee:fZ?e(dde'iidddde@d ZAGdddeBZCGdddeBZDejEdddd Gd!d"d"ZFeee(eFfe/fZGGd#dde!ZHdS)$N)deque)suppress)escape) HTTPStatus)Logger) TYPE_CHECKINGAny AwaitableCallableDequeOptionalSequenceTupleTypeUnioncast)AbstractAccessLoggerAbstractStreamWriter) BaseProtocol) ceil_timeout set_exception)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__r3r3M/var/www/html/corbot_env/lib/python3.10/site-packages/aiohttp/web_protocol.pyr(Nr(c@r-)r)z-Payload was accessed after response was sent.Nr.r3r3r3r4r)Rr5r)) auto_attribsfrozenslotsc@s&eZdZUeed<eed<eed<dS)_ErrInfostatusexcmessageN)r/r0r1int__annotations__ BaseExceptionstrr3r3r3r4r9Vs  r9c!sBeZdZdZdZdZddeeeej ddddd d dd d d dde j de de dedeededede dededede dede de f fddZd efd!d"Zed e fd#d$Zd]d&ee d d'fd(d)Zd*e jd d'ffd+d, Zd-eed d'ffd.d/ Zd0ed d'fd1d2Zd^d3d4Zd5e d d'fd6d7Z!d8e d d'fd9d:Z"d^d;d<Z#d^d=d>Z$d?e%d@e&dAe d d'fdBdCZ'dDedEed d'fdFdGZ(dDedEed d'fdHdIZ)d^dJdKZ*d?e%dLe dMe+e%ge,e&fd e-e&e ffdNdOZ.d^dPdQZ/d?e%dRe&dLe d e fdSdTZ0 U ' 'd_d?e%dVed-eedWeed e&f dXdYZ1dZe2d e+e%ge,e&ffd[d\Z3Z4S)`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 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_parser_reading_pausedloggerdebug access_logr_close _force_close_current_request_timeout_ceil_thresholdgR@TFiig$@i)keepalive_timeoutr!rSaccess_log_classrUaccess_log_formatrT max_line_size max_headersmax_field_sizelingering_time read_bufsizeauto_decompresstimeout_ceil_thresholdmanagerr*loopr[r!rSr\rUr]rTr^r_r`rarbrcrdc st|d|_d|_d|_||_|j|_|j|_ ||_ d|_ d|_ ||_ t| |_t|_d|_d|_d|_d|_d|_t|||| | | t|d|_d|_zt||_Wn ttfy`Ynw||_| |_||_|rs||||_ nd|_ d|_!d|_"dS)NrFg)r^r`r_payload_exceptionrcrZ)#super__init__rArBrXrCrequest_handlerrDrequest_factoryrErFrGrHrIfloatrJrrKrLrMrNrOrPrr(rQrY TypeError ValueErrorrSrTrUrrVrW)selfrerfr[r!rSr\rUr]rTr^r_r`rarbrcrd __class__r3r4rjsX    zRequestHandler.__init__returncCs d|jj|jdur dSdS)Nz<{} {}> connected disconnected)formatrrr/ transportrpr3r3r4__repr__s  zRequestHandler.__repr__cCs|jSN)rIrxr3r3r4r[sz 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)rWrHcancelrMrasyncioCancelledError TimeoutErrorrrX_cancelrNdonerwclose)rpr|r3r3r4shutdowns,     (    zRequestHandler.shutdownrwcsXt|ttj|}|jrt||j| |_ |j dus#J|j ||dSrz) riconnection_maderr~ TransportrFr!_loop create_taskstartrNrC)rprwreal_transportrqr3r4rs  zRequestHandler.connection_mader;cs|jdurdS|j||t||jj}d|_d|_d|_d|_d|_|jdur1|j |j durD|dur>t d}|j ||j durN|j |rZ|jdurZ|j d|_|jdurl|jd|_dSdS)NTzConnection lost)rCconnection_lostrihandler_cancellationrWrErDrQrHr}rXConnectionResetErrorrrMrNrPfeed_eof)rpr;rrqr3r4r%s2            zRequestHandler.connection_lostparsercCs6|jdusJ||_|jr|j|jd|_dSdS)Nrg)rPrL feed_data)rprr3r3r4 set_parserIs  zRequestHandler.set_parsercCsdSrzr3rxr3r3r4 eof_receivedSszRequestHandler.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<Frgr3r)rWrVrPrOrQrrr9r<rrArKappendrMr set_resultrLr) rprmessagesupgradedtailr;msgpayloadwaitereofr3r3r4 data_receivedVs>    zRequestHandler.data_receivedvalcCs$||_|jr|jd|_dSdS)zMSet keep-alive connection mode. :param bool val: new state. N)rBrHr})rprr3r3r4 keep_alive}s   zRequestHandler.keep_alivecCsd|_|jr |jdSdS)zClose connection. Stop accepting new pipelining messages and close connection when handlers done processing messages. TN)rVrMr}rxr3r3r4rszRequestHandler.closecCs8d|_|jr |j|jdur|jd|_dSdS)zForcefully close connection.TN)rWrMr}rwrrxr3r3r4 force_closes    zRequestHandler.force_closerequestresponsetimecCs,|jdur|j|||j|dSdSrz)rlogrr)rprrrr3r3r4 log_accesss zRequestHandler.log_accessargskwcOs |jr|jj|i|dSdSrz)rTrSrprrr3r3r4 log_debugszRequestHandler.log_debugcOs|jj|i|dSrz)rS exceptionrr3r3r4 log_exceptionszRequestHandler.log_exceptioncCsT|js|jsdS|j|j}|jr|j|kr|dS|j|j |j |_ dSrz) rWrBrGrIrMrrr call_laterKEEPALIVE_RESCHEDULE_DELAY_process_keepaliverH)rpnextr3r3r4rs   z!RequestHandler._process_keepalive start_timerkc 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_infoi__http_exception__Fzlreturning HTTPException object is deprecated (#2415) and will be removed, please raise the exception instead)rDrXr"finish_responser~rrr handle_error ExceptiongetattrwarningswarnDeprecationWarning)rprrrkrespr;resetr3r3r4_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(|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)/rrNrCrIrErDrWrK create_futurerMr~rpopleftrrequests_countr isinstancer9_make_error_handlerERRORrrConnectionErrorrrwrBrVrGrHcall_atrboolris_eofrJrrrreadanyrrr) RuntimeErrorrTrrr)rprfhandlerrer[rr<rrwriterrkrtaskrnowraend_tr;r3r3r4rs8          /     )     *                  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. NFrgz+Missing return statement on request handlerz7Web-handler should return a response instance, got {!r}T) rQ set_upgradedrOrLrprepareAttributeErrorrrv write_eofrr)rprrr prepare_methr3r3r4rZs4     zRequestHandler.finish_responserr:r<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 )r:text content_type)rr output_sizerrINTERNAL_SERVER_ERRORrv descriptionrTrr traceback format_excheadersget html_escaper%r) rprr:r;r<ctrrtbrr3r3r4rs8       zRequestHandler.handle_errorerr_infocsdtdtffdd }|S)Nrrscs|jjjSrz)rr:r;r<)rrrpr3r4rsz3RequestHandler._make_error_handler..handler)r$r&)rprrr3rr4rsz"RequestHandler._make_error_handler)r{)rsN)rNN)5r/r0r1r2r __slots__rr#r LOG_FORMATr~AbstractEventLooprmrrrrr@r=rjrypropertyr[r r BaseTransportrr?rrrrbytesrrrrr$r&rrrrr r rrrrrr9r __classcell__r3r3rqr4r'`s'"     J $ '      'y ( 3)Ir~asyncio.streamsrr collectionsr contextlibrhtmlrrhttprloggingrtypingrrr r r r r rrrrattryarlabcrr base_protocolrhelpersrrrrrrrrrrstreamsrr tcp_helpersr!web_exceptionsr"web_logr# web_requestr$ web_responser%r&__all__ web_serverr*_RequestFactory_RequestHandlerURLrrr(r)sr9_MsgTyper'r3r3r3r4sn     4