o jÁ @sDddlZddlZddlZddlZddlZddlmZddlmZddl m Z m Z m Z ddl mZddlmZddlmZddlmZdd lmZmZmZmZddlZddlZdd lmZd d lm Z m!Z!d d l"m#Z#d dl$m%Z%m&Z&d dlm'Z'm(Z(m)Z)m*Z*m+Z+m,Z,d dl-m.Z.d dl/m0Z0m1Z1d dl2m3Z3m4Z4d dl5m6Z6d dl7m8Z8m9Z9d dl:m;Z;d dlm?Z?m@Z@dZAdZBerddlCZCd dlDmEZEe e*e4de!dge=fZFe e=ge e@fZGe*dde)iiddd d eHd ZIGd!d"d"eJZKGd#d$d$eJZLeLZMejNdddd%Gd&d'd'ZOePe*eOBe4fZQGd(dde#ZRdS))N) BaseEventLoop)deque) AwaitableCallableSequence)suppress)escape) HTTPStatus)Logger) TYPE_CHECKINGAnyOptionalcast)under_cached_property)AbstractAccessLoggerAbstractStreamWriter) BaseProtocol)DEFAULT_CHUNK_SIZE ceil_timeout)HttpProcessingErrorHttpRequestParser HttpVersion10RawRequestMessage StreamWriterWebSocketReader) 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__r5r5G/opt/steambot/venv/lib/python3.10/site-packages/aiohttp/web_protocol.pyr)Or)c@r/)r*z-Payload was accessed after response was sent.Nr0r5r5r5r6r*Sr7r*) auto_attribsfrozenslotsc@s&eZdZUeed<eed<eed<dS)_ErrInfostatusexcmessageN)r1r2r3int__annotations__ BaseExceptionstrr5r5r5r6r;Zs  r;c!seZdZdZdZddeeeejddddde dd d d d d e j de de dedeededede dededede dede de f fddZdefdd Zeded!fd"d#ZedeeeeeefBeeefBd$Bfd%d&ZedeeeeeefBeeefBd$Bfd'd(Zede fd)d*Zded,e d$Bdd$fd-d.Zd/e jdd$ffd0d1 Zd2e d$Bdd$ffd3d4 Z! $dfd5e"d6e#gd$fd$Bdd$fd7d8Z$dgd9d:Z%d;e&dd$fdd?Z(d@e dd$fdAdBZ)dgdCdDZ*dgdEdFZ+dGe,dHe-dIe d$Bdd$fdJdKZ.dLe/dMe/dd$fdNdOZ0dLe/dMe/dd$fdPdQZ1dgdRdSZ2dGe,dTe d$BdUe#e,ge3e-fdee-e ffdVdWZ4dgdXdYZ5dGe,dZe-dTe d$Bdee-e ffd[d\Z6 ] $ $dhdGe,d^ed2e d$Bd_ed$Bde-f d`daZ7dbe8de#e,ge3e-ffdcddZ9Z:S)ir(aOHTTP 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 an idle 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 )"max_field_size max_headers max_line_size_request_count _keepalive_manager_request_handler_request_factory_tcp_keepalive_next_keepalive_close_time_keepalive_handle_keepalive_timeout_lingering_time _messages_max_msg_queue_size_msg_queue_resume_size _message_tail _read_bufsize_handler_waiter_waiter _task_handler_payload_parser_data_received_cbloggerdebug access_logr_close _force_close_current_request_timeout_ceil_threshold_request_in_progress_logging_enabled_cachei.TFig$@)keepalive_timeoutr!rZaccess_log_classr\access_log_formatr[rErDrClingering_time read_bufsizeauto_decompresstimeout_ceil_thresholdmanagerr,looprfr!rZrgr\rhr[rErDrCrirjrkrlc sHt|_td|_||_t|||| | | t|td }t||d|_d|_ d|_ ||_ |j |_ |j|_| |_| |_| |_||_d|_d|_||_t| |_t|_d|_d|_d|_d|_d|_d|_ d|_!zt||_!Wn t"t#fyxYnw||_$| |_%||_&|r||||_'|j'j(|_)nd|_'d|_)d|_*d|_+d|_,i|_-dS) N)rErCrDpayload_exceptionrkmax_msg_queue_sizerTgreF).MAX_MSG_QUEUE_SIZErQrRrTrr)super__init__rFrGr_rHrequest_handlerrIrequest_factoryrJrErDrCrKrLrMrNfloatrOrrPrSrYrVrUrWrXr` TypeError ValueErrorrZr[r\renabledrbr]r^rarc)selfrmrnrfr!rZrgr\rhr[rErDrCrirjrkrlparser __class__r5r6rusp     zRequestHandler.__init__returncCs d|jj|jdur dSdS)Nz<{} {}> connected disconnected)formatrr1 transportr|r5r5r6__repr__ s  zRequestHandler.__repr__zssl.SSLContextcC|jdurdS|jdS)zReturn SSLContext if available.N sslcontextrget_extra_inforr5r5r6 ssl_contexts  zRequestHandler.ssl_contextNcCr)zReturn peername if available.Npeernamerrr5r5r6r  zRequestHandler.peernamecCr)zReturn sockname if available.Nsocknamerrr5r5r6r$rzRequestHandler.socknamecCs|jSN)rNrr5r5r6rf/sz RequestHandler.keepalive_timeout.@timeoutc 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 )r^rMcancelra_loop create_futurerUrasyncioCancelledError TimeoutErrorsys version_info current_task cancellingr__cancelrWdoneshield force_close)r|rtaskr5r5r6shutdown3sT   (    (    zRequestHandler.shutdownrcst|ttj|}|jrt||jdusJ|j|||j}|j dkr;| |j }||_ | ||j |_tjdkrZt|trOtj|dd}n"tj||dd}ntjdkrjtj||dd}n||}||_dS)NrrT eager_startrnrr )rtconnection_maderr TransportrKr!rHrrNtimerLcall_at_process_keepaliverMrr isinstancer create_taskstartTaskrW)r|rreal_transportrn close_timerr~r5r6res&       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)rHconnection_losthandler_cancellationrrtrJrI_parserrMrr_ConnectionResetErrorrrWrXfeed_eof)r|r=rr~r5r6rs.          zRequestHandler.connection_lostr}data_received_cbcCsJ|jdusJ||_||_|jr|j|jd|_|jr#|dSdSNrr)rXrYrS feed_data_buffer_paused_resume_reading_if_drained)r|r}rr5r5r6 set_parsers zRequestHandler.set_parsercCsdSrr5rr5r5r6 eof_receivedszRequestHandler.eof_receiveddatac Cs|js|jrdS|jdur|js|jdusJz |j|\}}}Wn!tyC}ztd||jdt fg}d}d}WYd}~nd}~ww|D]\}}|j d7_ |j ||fqF|j }|rl|durl|sl|d|js{t|j |jkr{|||_|r|r||_dSdSdS|jdur|jr|r|j|7_|jst|j|jkr|dSdSdS|r|jdur||j|\} }| r|dSdSdS)Nr<r=r>Frrr)r^r]rX _upgradedrrrr;r>rrFrPappendrVr set_resultrlenrQ_pause_reading_for_bufferrSrTrYclose) r|rmessagesupgradedtailr=msgpayloadwaitereofr5r5r6 data_receivedsV       zRequestHandler.data_receivedcCsJ|jr t|j|jkr dS|js|dt|j|jkrdS|dSr)rSrrTrrrPrQ_resume_reading_for_bufferrr5r5r6rs  z)RequestHandler._resume_reading_if_drainedvalcCs$||_|jr|jd|_dSdS)zMSet keep-alive connection mode. :param bool val: new state. N)rGrMr)r|rr5r5r6 keep_alives   zRequestHandler.keep_alivecCsd|_|jr |jdSdS)zClose connection. Stop accepting new pipelining messages and close connection when handlers done processing messages. TN)r]rVrrr5r5r6rszRequestHandler.closecCs8d|_|jr |j|jdur|jd|_dSdS)zForcefully close connection.TN)r^rVrrrrr5r5r6rs    zRequestHandler.force_closerequestresponsercCsF|jr|jdur!tr|dusJ|j|||j|dSdSdSr)rbrr logrr)r|rrrr5r5r6 log_accesss  zRequestHandler.log_accessargskwcOs |jr|jj|i|dSdSr)r[rZr|rrr5r5r6 log_debugszRequestHandler.log_debugcOs|jj|i|dSr)rZ exceptionrr5r5r6 log_exception#szRequestHandler.log_exceptioncCsjd|_|js |js dS|j}|}|j}||kr#|||j|_dS|jr1|j s3| dSdSdSr) rMr^rGrrrLrrrVrr)r|rnnowrr5r5r6r&s  z!RequestHandler._process_keepalive start_timervc 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)rar_r"finish_responserrrr handle_error ExceptiongetattrwarningswarnDeprecationWarningrUr)r|rrrvrespr=resetr5r5r6_handle_request7sL$ $$    zRequestHandler._handle_requestc s|j}|j}|dus J|j}d}|jdusJ|jdus J|jsD|jsrrwriterrvrcororrrirend_ttr=rr5r5r6rbs              6  0  *         zRequestHandler.startrc s||jr|js|jdur|jdur|jdd|_|jrz |j|j\}}}Wn!tyN}zt d||j dt fg}d}d}WYd}~nd}~ww||_||_|D]\}} |j d7_ |j || fqWt|j|jkrx|n|jr||jdusJz|j} Wn-ty|dur|dn|d|t} t| j| j| j| jd }|j} Ynwz| |IdH|IdHWnty|||||d fYSw|||||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. NFrrrrrz+Missing return statement on request handlerz3Web-handler should return a response instance, got )r<reasontextheadersT) _finishrrPrXr set_upgradedrSrrr;r>rrFrrrQrrrrVprepareAttributeErrorrr#r&r<rrr write_eofrr) r|rrrrrr parse_excrr prepare_methr=r5r5r6rsz              zRequestHandler.finish_responserr<r>c Cs,|jdkrt|tr|jjd|j|dn |jd|j|d|jjdkr(t dd}|t j krt j j dt j j }t j j}d}|jr[tt t}Wdn1sVwYd |jd d vr|rpt|}d |d }d|d|d|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/plain Nz text/htmlAcceptz

Traceback:

z
zz

z

z z )r<r content_type)rFrrrZr[remoterr output_sizerr INTERNAL_SERVER_ERRORvaluephrase descriptionrr traceback format_excrget html_escaper&r) r|rr<r=r>cttitlertbrr5r5r6rRsN       zRequestHandler.handle_errorerr_infocsdtdtffdd }|S)Nrrcs|jjjSr)rr<r=r>)rrr|r5r6handlersz3RequestHandler._make_error_handler..handler)r%r')r|rrr5rr6rsz"RequestHandler._make_error_handler)rr)rN)rNN);r1r2r3r4 __slots__rr$r LOG_FORMATrrAbstractEventLooprxrr typerrBr?rurrr rtuplerrpropertyrfr BaseTransportrrArrrrrbytesrrrrrr%r'rr rrrrrrrrr;r __classcell__r5r5r~r6r(ds&+     Z"  "  2#  6      +  Y >)Srasyncio.streamsrrrasyncio.base_eventsr collectionsrcollections.abcrrr contextlibrhtmlrrhttpr loggingr typingr r r rattryarl propcacherabcrr base_protocolrhelpersrrrrrrrrhttp_exceptionsrrrrstreamsrr tcp_helpersr!web_exceptionsr"r#web_logr$ web_requestr% web_responser&r'__all__rsssl web_serverr,_RequestFactory_RequestHandlerURLrrr)r*rsr;r#_MsgTyper(r5r5r5r6s~