U }gT @sddlZddlZddlZddlZddlZddlmZddlmZddl 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+m,Z,ddl-m.Z.m/Z/ddl0m1Z1ddl2m3Z3m4Z4ddl5m6Z6ddl7m8Z8ddl9m:Z:m;Z;dZZ>ee(e/de dge8fZ?ee8gee;fZ@e(dde'iiddddeAd ZBGdddeCZDGdddeCZEeEZFejGdddd Gd!d"d"ZHeee(eHfe/fZIGd#dde"ZJdS)$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) HTTPExceptionHTTPInternalServerError) AccessLogger) BaseRequest)ResponseStreamResponse)RequestHandlerRequestPayloadErrorPayloadAccessError)Serverr'zasyncio.Task[None]UNKNOWN/TFc@seZdZdZdS)r(zPayload parsing error.N__name__ __module__ __qualname____doc__r2r2T/opt/bot/vods_filmes/script/venv/lib/python3.8/site-packages/aiohttp/web_protocol.pyr(Nsr(c@seZdZdZdS)r)z-Payload was accessed after response was sent.Nr-r2r2r2r3r)Rsr)) auto_attribsfrozenslotsc@s&eZdZUeed<eed<eed<dS)_ErrInfostatusexcmessageN)r.r/r0int__annotations__ BaseExceptionstrr2r2r2r3r7Ys 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'zHTTP protocol implementation.)_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_progressgR@TFiig$@i)keepalive_timeoutr rRaccess_log_classrTaccess_log_formatrS max_line_size max_headersmax_field_sizelingering_time read_bufsizeauto_decompresstimeout_ceil_thresholdr*)managerloopr[r rRr\rTr]rSr^r_r`rarbrcrdc s t|d|_d|_d|_||_|j|_|j|_ ||_ d|_ d|_ ||_ t| |_t|_d|_d|_d|_d|_d|_d|_t|||| | | t|d|_d|_zt||_Wnttfk rYnX||_| |_||_ |r||||_!nd|_!d|_"d|_#d|_$dS)NrFg)r^r`r_payload_exceptionrcrZ)%super__init__r?r@rWrArequest_handlerrBrequest_factoryrCrDrErFrGfloatrHrrIrJrLrKrMrNrOrr(rPrX TypeError ValueErrorrRrSrTrrUrVrY)selfrerfr[r rRr\rTr]rSr^r_r`rarbrcrd __class__r2r3rjs\   zRequestHandler.__init__)returncCsd|jj|jdk rdndS)Nz<{} {}> connected disconnected)formatrrr. transportrpr2r2r3__repr__szRequestHandler.__repr__cCs|jSN)rGrxr2r2r3r[sz RequestHandler.keepalive_timeout.@N)timeoutrsc spd|_|jdk r|j|jr|j|_z2t|4IdH|jIdHW5QIdHRXWnBtj tj fk rd|_t j dkrt }r|rYnXzft|4IdHF|jdk r|jt |jdk r|jst|jIdHW5QIdHRXWnDtj tj fk rLt j dkrHt }rH|rHYnX|jdk rd|j|dS)NT )rVrFcancelrY_loop create_futurerKrasyncioCancelledError TimeoutErrorsys version_info current_task cancellingrW_cancelrMdoneshield force_close)rpr|taskr2r2r3shutdownsD      &   zRequestHandler.shutdown)rwrscst|ttj|}|jr&t||jdk s4t|j|||j }t j dkrhtj | |dd}n|| }||_dS)Nr~ Trf eager_start)riconnection_maderr TransportrDr rAAssertionErrorrrrTaskstart create_taskrM)rprwZreal_transportrfrrqr2r3rs   zRequestHandler.connection_made)r9rscs|jdkrdS|j|||jj}|t|d|_d|_d|_d|_|jdk rd|j |j dk r|dkr~t d}|j ||r|j dk r|j d|_ |jdk r|jd|_dS)NzConnection lost)rAconnection_losthandler_cancellationrrirCrBrPrFrrWConnectionResetErrorrrMrOfeed_eof)rpr9rrqr2r3rs,         zRequestHandler.connection_lost)parserrscCs2|jdkst||_|jr.|j|jd|_dS)Nrg)rOrrJ feed_data)rprr2r2r3 set_parser2s zRequestHandler.set_parsercCsdSrzr2rxr2r2r3 eof_received;szRequestHandler.eof_received)datarsc 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)r8r9r:Frgr2r)rVrUrOrNrPrrrr7r:rr?rIappendrLr set_resultrJclose) rprmessagesupgradedtailr9msgpayloadwaitereofr2r2r3 data_received>s4  zRequestHandler.data_received)valrscCs ||_|jr|jd|_dSrz)r@rFr)rprr2r2r3 keep_alive`s zRequestHandler.keep_alivecCsd|_|jr|jdSNT)rUrLrrxr2r2r3rfszRequestHandler.closecCs4d|_|jr|j|jdk r0|jd|_dSr)rVrLrrwrrxr2r2r3rks    zRequestHandler.force_close)requestresponsetimerscCs(|jdk r$|j|||j|dSrz)rlogrr)rprrrr2r2r3 log_accessss zRequestHandler.log_access)argskwrscOs|jr|jj||dSrz)rSrRrprrr2r2r3 log_debugyszRequestHandler.log_debugcOs|jj||dSrz)rR exceptionrr2r2r3 log_exception}szRequestHandler.log_exceptioncCsbd|_|js|jsdS|j}|}|j}||krF|||j|_dS|jr^|j s^| dSrz) rFrVr@rrrEcall_at_process_keepaliverLrr)rprfnow close_timer2r2r3rs z!RequestHandler._process_keepalive)r start_timerkrsc sd|_zpzHz:||_||IdH}|dkrD|d|j|ddd}W5d|_XWntk r}z |}||||IdH\}}W5d}~XYntj k rYntj k r}z6|j d|d||d }||||IdH\}}W5d}~XYn|t k rB}z*||d|}||||IdH\}}W5d}~XYn4Xt |d dr^td t||||IdH\}}W5d|_|jdk r|jdX||fS) NTFz9Request handler returned None instead of a valid responsezHandler returned None)r:zRequest handler timed out.exc_infoi__http_exception__zlreturning HTTPException object is deprecated (#2415) and will be removed, please raise the exception instead)rYrKrrWr handle_errorr!finish_responserrrr ExceptiongetattrwarningswarnDeprecationWarning)rprrrkrespr9resetr2r2r3_handle_requestsB ( (* zRequestHandler._handle_requestc s|j}t|}|dk st|j}|dk s.t|j}d}|jdk sFt|jdk sTt|js|j sz| |_ |j IdHW5d|_ X|j \}}| }|jd7_t||} t|tr||} t}n|j} ||||| |} dzz|| || }tjdkrtj||dd}n | |}z|IdH\}}Wn0t!k rh|dYWWqYnX~|r|dWW|qt"|j#|_|$s|j%}|jsn|rn|d|| } | |}zX|$s&| |kr&t&|| 4IdH|'IdHW5QIdHRX| } qWnDtj(tj)fk rltjd krht}rh|*rhYnX|$s|js|d |+|,t-Wn\tj(k r|dYn:t.k r}z|j/d |d |0W5d}~XYnXW5|jdkr"|dk r"|dn^|js|jrx|jsx|dk r| } | |} | |_|jdkr|| |j|_nqXqT|jsd|_1|jdk r|j+dS) Nrz'Ignored premature client disconnection.rTrz&Ignored premature client disconnectionz(Ignored premature client disconnection 2z'Start lingering close timer for %s sec.r}zUncompleted request.zUnhandled exceptionr)2rrrrrArGrCrBrVrIrLrpopleftrZrequests_countr isinstancer7_make_error_handlerERRORrwrr@rUrErFrrrrrrrConnectionErrorboolris_eofrHrreadanyrrrr set_exception_PAYLOAD_ACCESS_ERRORrrrrM)rprfhandlerrer[rr:rrwriterrkrrrcororrraZend_ttr9r2r2r3rs                     zRequestHandler.start)rrrrsc s(||jdk r>|jdd|_|jr>|j|jd|_z |j}Wnztk r|dkr|d|t }t |j |j |j |jd}n,|d||t }t |j |j |j |jd}|j}YnXz ||IdH|IdHWn,tk r|||||dfYSX|||||dfS)NFrgz;Missing return statement on request handler for request: %s)r8reasontextheaderszEWeb-handler should return a response instance, got %r for request: %sT)_finishrP set_upgradedrNrJrprepareAttributeErrorrr"r%r8rrr write_eofrr)rprrrZ prepare_methr9r2r2r3r(sV    zRequestHandler.finish_responser)rr8r9r:rsc Cs|jd||d|jjdkr$tdd}|tjkrdtj}tjj}d}|jrlt t t }W5QRXd|j dd kr|rt|}d |d }d j||d }d}n|r|}|d|}t|||d} | | S)NzError handling request: %srrzMResponse is sent already, cannot send another response with the error messagez text/plainz{0.value} {0.phrase}z text/htmlAcceptz

Traceback:

z
zV{title}

{title}

{msg} )titlerz )r8r content_type)rr output_sizerrINTERNAL_SERVER_ERRORrv descriptionrSrr traceback format_excrget html_escaper%r) rprr8r9r:ctrrtbrr2r2r3rSs:      zRequestHandler.handle_error)err_inforscsttdfdd }|S)N)rrscs|jjjSrz)rr8r9r:)rrrpr2r3rs z3RequestHandler._make_error_handler..handler)r$r&)rprrr2rr3rsz"RequestHandler._make_error_handler)r{)rNN)4r.r/r0r1 __slots__rr#r LOG_FORMATrAbstractEventLooprmrrrrr>r;rjrypropertyr[r r BaseTransportrr=rrrrbytesrrrrr$r&rrrrr r rrrrrr7r __classcell__r2r2rqr3r'cs$K( "   .l . .)KrZasyncio.streamsrrr collectionsr contextlibrhtmlrrhttprloggingrtypingrrr r r r r rrrrattryarlabcrr base_protocolrhelpersrrrrrrrrrstreamsrr tcp_helpersr web_exceptionsr!r"web_logr# web_requestr$ web_responser%r&__all__ web_serverr*Z_RequestFactoryZ_RequestHandlerURLrrr(r)rsr7Z_MsgTyper'r2r2r2r3sp     4