a `gd @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;merrddl?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@seZdZdZdS)r)zPayload parsing error.N__name__ __module__ __qualname____doc__r3r3b/var/www/html/cobodadashboardai.evdpl.com/venv/lib/python3.9/site-packages/aiohttp/web_protocol.pyr)Psr)c@seZdZdZdS)r*z-Payload was accessed after response was sent.Nr.r3r3r3r4r*Tsr*)Z auto_attribsfrozenslotsc@s&eZdZUeed<eed<eed<dS)_ErrInfostatusexcmessageN)r/r0r1int__annotations__ BaseExceptionstrr3r3r3r4r7[s r7cseZdZdZdZddeeeejdddddd 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_progressi.TFiig$@i)keepalive_timeoutr!rQaccess_log_classrSaccess_log_formatrR max_line_size max_headersmax_field_sizelingering_time read_bufsizeauto_decompresstimeout_ceil_thresholdr+)managerlooprZr!rQr[rSr\rRr]r^r_r`rarbrcc st|d|_d|_d|_||_|j|_|j|_ ||_ d|_ d|_ ||_ t| |_t|_d|_d|_d|_d|_d|_d|_t|||| | | t|d|_d|_zt||_WnttfyYn0||_| |_||_ |r||||_!nd|_!d|_"d|_#d|_$dS)NrFg)r]r_r^Zpayload_exceptionrbrY)%super__init__r?r@rVrArequest_handlerrBZrequest_factoryrCrDrErFrGfloatrHrrIrJrLrKrMrNrOrr)rPrW TypeError ValueErrorrQrRrSrrTrUrX)selfrdrerZr!rQr[rSr\rRr]r^r_r`rarbrc __class__r3r4rhsZ   zRequestHandler.__init__)returncCsd|jj|jdurdndS)Nz<{} {}> connected disconnected)formatror/ transportrmr3r3r4__repr__szRequestHandler.__repr__cCs|jSN)rGrur3r3r4rZsz RequestHandler.keepalive_timeout.@N)timeoutrpc sd|_|jdur|j|jr|j|_zLt|4IdH"|jIdHWdIdHqv1IdHsl0YWn@tj tj fyd|_t j dkrt }r|rYn0zt|4IdH\|jdur|jt |jdur|jst|jIdHWdIdHq@1IdHs60YWnBtj tj fyt j dkrt }r|rYn0|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 )rUrFcancelrX_loop create_futurerKrasyncioCancelledError TimeoutErrorsys version_info current_task cancellingrV_cancelrMdoneshield force_close)rmrytaskr3r3r4shutdownsD   :  D   zRequestHandler.shutdown)rtrpcst|ttj|}|jr&t||jdus4J|j|||j}t j dkrhtj | |dd}n| | }||_dS)Nr{ TreZ eager_start)rgconnection_maderr TransportrDr!rAr~rrTaskstart create_taskrM)rmrtZreal_transportrerrnr3r4r6s   zRequestHandler.connection_made)r9rpcs|jdurdS|j|||jj}|t|d|_d|_d|_d|_|jdurd|j |j dur|dur~t d}|j ||r|j dur|j d|_ |jdur|jd|_dS)NzConnection lost)rAconnection_losthandler_cancellationrrgrCrBrPrFr}rVConnectionResetErrorrrMrOfeed_eof)rmr9rrnr3r4rGs,         zRequestHandler.connection_lost)parserrpcCs2|jdusJ||_|jr.|j|jd|_dS)Nrf)rOrJ feed_data)rmrr3r3r4 set_parsergs zRequestHandler.set_parsercCsdSrwr3rur3r3r4 eof_receivedqszRequestHandler.eof_received)datarpc CsD|js |jrdS|jdur|js|jdus.Jz|j|\}}}WnBty}z*td||jdt fg}d}d}WYd}~n d}~00|pdD]&\}}|j d7_ |j ||fq|j }|r|dur|s|d||_|r|r||_nN|jdur|jr|r|j|7_n$|r@|j|\} }| r@|dS)Ni)r8r9r:Frfr3r)rUrTrOrNrPrrr7r:rr?rIappendrLr set_resultrJclose) rmrmessagesZupgradedtailr9msgpayloadwaitereofr3r3r4 data_receivedts4  zRequestHandler.data_received)valrpcCs ||_|jr|jd|_dS)zMSet keep-alive connection mode. :param bool val: new state. N)r@rFr})rmrr3r3r4 keep_alives zRequestHandler.keep_alivecCsd|_|jr|jdS)zClose connection. Stop accepting new pipelining messages and close connection when handlers done processing messages. TN)rTrLr}rur3r3r4rszRequestHandler.closecCs4d|_|jr|j|jdur0|jd|_dS)zForcefully close connection.TN)rUrLr}rtrrur3r3r4rs    zRequestHandler.force_close)requestresponsetimerpcCs0|jdur,|jjr,|j|||j|dSrw)renabledlogr~r)rmrrrr3r3r4 log_accessszRequestHandler.log_access)argskwrpcOs|jr|jj|i|dSrw)rRrQrmrrr3r3r4 log_debugszRequestHandler.log_debugcOs|jj|i|dSrw)rQ exceptionrr3r3r4 log_exceptionszRequestHandler.log_exceptioncCsbd|_|js|jsdS|j}|}|j}||krF|||j|_dS|jr^|j s^| dSrw) rFrUr@r~rrEcall_at_process_keepaliverLrr)rmrenow close_timer3r3r4rs z!RequestHandler._process_keepalive)r start_timerirpc sd|_zvz,z||_||IdH}Wd|_nd|_0Wntyv}z(|}||||IdH\}}WYd}~nd}~0tjyYntjy}z>|jd|d||d}||||IdH\}}WYd}~nd}~0t y*}z2||d|}||||IdH\}}WYd}~n, ,.  zRequestHandler._handle_requestc s6|j}t|}|dusJ|j}|dus.J|j}d}|jdusFJ|jdusTJ|js|jsz | |_ |j IdHWd|_ nd|_ 0|j \}}| }|j d7_ t||} t|tr||} t}n|j} ||||| |} zz|| || } tjdkr tj| |dd} n || } z| IdH\}}Wnty|dYWW|jdur~|dur~|dnZ|js|jr|js|dur| }||}||_|jdur|||j |_nqqYn0~ |rx|dWW|jdur|dur|dnZ|js|jr|js|durt| }||}||_|jdurt|||j |_nqqt!|j"|_|#s|j$}|jsx|rx|d || }||}zv|#s2||kr2t%||4IdH&|&IdHWdIdHq&1IdHs0Y| }qWnBtj'tj(fyvtjd krrt}rr|)rrYn0|#s|js|d |*|+t,Wn\tj'y|dYn<t-y}z"|j.d |d |/WYd}~n d}~00W|jdur*|dur*|dnZ|js |jr|js|dur| }||}||_|jdur|||j |_nqqT|jdur|dur|dnb|js |jr|js|dur | }||}||_|jdur |||j |_n Yq0qT|js2d|_0|jdur2|j*dS)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.rzzUncompleted request.zUnhandled exceptionr)1r~rrrArGrCrBrUrIrrLpopleftrZrequests_countr isinstancer7_make_error_handlerERRORrrrrrConnectionErrorrrtr@rTrErFrrboolrZis_eofrHrZreadanyrrrr set_exception_PAYLOAD_ACCESS_ERRORrrrrM)rmrehandlerrdrZrr:rrwriterrircororrrrr`Zend_ttr9r3r3r4rs           2     ,     <           zRequestHandler.start)rrrrpc s||jdur>|jdd|_|jr>|j|jd|_z |j}WnZty|durj|dn|d |t }t |j |j |j|jd}|j}Yn0z ||IdH|IdHWn(ty|||||dfYS0|||||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. NFrfz+Missing return statement on request handlerz7Web-handler should return a response instance, got {!r})r8reasontextheadersT)Z_finishrPZ set_upgradedrNrJrprepareAttributeErrorrrsr#r&r8rrr write_eofrr)rmrrrZ prepare_methr9r3r3r4r~s<        zRequestHandler.finish_responser)rr8r9r:rpc Cs|jdkr*t|tr*|jjd|j|dn|jd|j|d|jjdkrPt dd}|t j krd t j }t j j }d}|jrttt}Wdn1s0Yd |jd d vr|rt|}d |d }dj ||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. rzError handling request from %srrzMResponse 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 )r8r content_type)r?rrrQrRremoterrZ output_sizerrINTERNAL_SERVER_ERRORrs descriptionrr traceback format_excrget html_escaper&r) rmrr8r9r:ctrrtbrr3r3r4rsD     &  zRequestHandler.handle_error)err_inforpcsttdfdd }|S)N)rrpcs|jjjSrw)rr8r9r:)rrrmr3r4rsz3RequestHandler._make_error_handler..handler)r%r')rmrrr3rr4rsz"RequestHandler._make_error_handler)rx)rNN)4r/r0r1r2 __slots__rr$rZ LOG_FORMATrAbstractEventLooprjrrrrr>r;rhrvpropertyrZr r BaseTransportrr=rrrrbytesrrrrr%r'rrrrr r rrrrrr7r __classcell__r3r3rnr4r(es'%N2  '     +~ - ?)MrZasyncio.streamsrrr collectionsr contextlibrhtmlrrhttprloggingrtypingrrr r r r r rrrrattrZyarlabcrrZ base_protocolrhelpersrrrrrrZhttp_exceptionsrrrrstreamsrr Z tcp_helpersr!Zweb_exceptionsr"r#Zweb_logr$Z web_requestr%Z web_responser&r'__all__Z web_serverr+Z_RequestFactoryZ_RequestHandlerURLrrr)r*rsr7Z_MsgTyper(r3r3r3r4sr     4