o #`^hK] @sddlZddlZddlZddlZddlZddlmZddlmZddl m Z ddl m Z ddlmZddlmZmZmZmZmZmZmZmZmZmZmZddlZddlZdd lmZm Z dd 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/m0Z0ddl1m2Z2ddl3m4Z4ddl5m6Z6ddl7m8Z8ddl9m:Z:m;Z;dZZ>ee)e0de dge8fZ?ee8gee;fZ@e)dde(iiddddeAd ZBGdddeCZDGdddeCZEejFdddd Gd!d"d"ZGeee)eGfe0fZHGd#dde"ZIdS)$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__r3r3R/home/air/shanriGPT/back/venv/lib/python3.10/site-packages/aiohttp/web_protocol.pyr(Or(c@r-)r)z-Payload was accessed after response was sent.Nr.r3r3r3r4r)Sr5r)) auto_attribsfrozenslotsc@s&eZdZUeed<eed<eed<dS)_ErrInfostatusexcmessageN)r/r0r1int__annotations__ BaseExceptionstrr3r3r3r4r9Ws  r9c!s>eZdZdZdZddeeeejdddddd 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 fdRdSZ/ 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_thresholdgR@TFiig$@i)keepalive_timeoutr!rTaccess_log_classrVaccess_log_formatrU max_line_size max_headersmax_field_sizelingering_time read_bufsizeauto_decompresstimeout_ceil_thresholdmanagerr*loopr\r!rTr]rVr^rUr_r`rarbrcrdrec 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|_#dS)NrFg)r_rar`payload_exceptionrdr[)$super__init__rArBrYrCrequest_handlerrDrequest_factoryrErFrGrHrIfloatrJrrKrLrNrMrOrPrQrr(rRrZ TypeError ValueErrorrTrUrVrrWrX)selfrfrgr\r!rTr]rVr^rUr_r`rarbrcrdre __class__r3r4rksZ    zRequestHandler.__init__returncCs d|jj|jdur dSdS)Nz<{} {}> connected disconnected)formatrsr/ transportrqr3r3r4__repr__s  zRequestHandler.__repr__cCs|jSN)rIryr3r3r4r\sz RequestHandler.keepalive_timeout.@timeoutNc sd|_|jdur|j|jr|j|jdurVttjtj,t |4IdH|jIdHWdIdHn 1IdHsBwYWdn1sQwYttjtjCt |4IdH(|j durt|j t|j dur|j s|j IdHWdIdHn 1IdHswYWdn1swY|j dur|j |jdur|jd|_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)rXrHcancelrNrMrasyncioCancelledError TimeoutErrorrrY_cancelrOdonerxclose)rqr}r3r3r4shutdowns:    (  (    zRequestHandler.shutdownrxcst|ttj|}|jrt||jdusJ|j|||j}t j dkr4tj | |dd}n| | }||_dS)N Trg eager_start)rjconnection_maderr TransportrFr!rC_loopsys version_infoTaskstart create_taskrO)rqrxreal_transportrgtaskrrr3r4r s    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_lostrjhandler_cancellationrXrErDrRrHr~rYConnectionResetErrorrrNrOrQfeed_eof)rqr;rrrr3r4r1s2            zRequestHandler.connection_lostparsercCs6|jdusJ||_|jr|j|jd|_dSdS)Nrh)rQrL feed_data)rqrr3r3r4 set_parserUs  zRequestHandler.set_parsercCsdSr{r3ryr3r3r4 eof_received_szRequestHandler.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<Frhr3r)rXrWrQrPrRrrr9r<rrArKappendrNr set_resultrLr) rqrmessagesupgradedtailr;msgpayloadwaitereofr3r3r4 data_receivedbs>    zRequestHandler.data_receivedvalcCs$||_|jr|jd|_dSdS)zMSet keep-alive connection mode. :param bool val: new state. N)rBrHr~)rqrr3r3r4 keep_alives   zRequestHandler.keep_alivecCsd|_|jr |jdSdS)zClose connection. Stop accepting new pipelining messages and close connection when handlers done processing messages. TN)rWrNr~ryr3r3r4rszRequestHandler.closecCs8d|_|jr |j|jdur|jd|_dSdS)zForcefully close connection.TN)rXrNr~rxrryr3r3r4 force_closes    zRequestHandler.force_closerequestresponsetimecCs,|jdur|j|||j|dSdSr{)rlogrr)rqrrrr3r3r4 log_accesss zRequestHandler.log_accessargskwcOs |jr|jj|i|dSdSr{)rUrTrqrrr3r3r4 log_debugszRequestHandler.log_debugcOs|jj|i|dSr{)rT exceptionrr3r3r4 log_exceptionszRequestHandler.log_exceptioncCs\d|_|js |js dS|j}|}|j}||kr#|||j|_dS|jr,| dSdSr{) rHrXrBrrrGcall_at_process_keepaliverNr)rqrgnow close_timer3r3r4rs  z!RequestHandler._process_keepalive start_timerlc s|j|_zzz||_||IdH}Wd|_nd|_wWnqty<}z|}||||IdH}WYd}~nyd}~wtjyDtjym}z|j d|d| |d}||||IdH}WYd}~nSd}~wt y}z| |d|}||||IdH}WYd}~nTraceback: 
z
zV{title}

{title}

{msg} )titlerz )r:text content_type)rr output_sizerrINTERNAL_SERVER_ERRORrw descriptionrUrr traceback format_excheadersget html_escaper%r) rqrr:r;r<ctrrtbrr3r3r4rs8       zRequestHandler.handle_errorerr_infocsdtdtffdd }|S)Nrrtcs|jjjSr{)rr:r;r<)rrrqr3r4rsz3RequestHandler._make_error_handler..handler)r$r&)rqrrr3rr4rsz"RequestHandler._make_error_handler)r|)rtN)rNN)4r/r0r1r2 __slots__rr#r LOG_FORMATrAbstractEventLooprnrrrrr@r=rkrzpropertyr\r r BaseTransportrr?rrrrbytesrrrrr$r&rrrrr r rrrrrr9r __classcell__r3r3rrr4r'as'#     K$$ '      )| ) 3)Jrasyncio.streamsrrr 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'r3r3r3r4sp     4