o miJj @s8ddlZddlZddlZddlZddlZddlmZddlmZddl m Z ddl m Z ddlmZddlmZmZmZmZmZmZmZmZmZmZmZddlZddlZddlmZd d l m!Z!m"Z"d d l#m$Z$d d l%m&Z&d d l m'Z'm(Z(m)Z)m*Z*m+Z+d dl,m-Z-d dl.m/Z/m0Z0d dl1m2Z2m3Z3d dl4m5Z5d dl6m7Z7m8Z8d dl9m:Z:d dl;mZ>m?Z?dZ@erddlAZAd dlBmCZCee*e3de"dgeZ&dbd?d@Z'dbdAdBZ(dCe)dDe*dEee dd+fdFdGZ+dHe!dIe!dd+fdJdKZ,dHe!dIe!dd+fdLdMZ-dbdNdOZ.dCe)dPee dQe/e)ge0e*fdee*e ffdRdSZ1dbdTdUZ2dCe)dVe*dPee dee*e ffdWdXZ3 Y + +dcdCe)dZed1eed[eede*f d\d]Z4d^e5de/e)ge0e*ffd_d`Z6Z7S)dr)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 )!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 _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_progress_logging_enabled_cachei.TFig$@i)keepalive_timeoutr"rYaccess_log_classr[access_log_formatrZrErDrClingering_time read_bufsizeauto_decompresstimeout_ceil_thresholdmanagerr,looprer"rYrfr[rgrZrErDrCrhrirjrkc s0t|d|_d|_d|_||_|j|_|j|_ | |_ | |_ | |_ ||_ d|_d|_||_t| |_t|_d|_d|_d|_d|_d|_d|_t|||| | | t|d|_d|_zt||_Wn tt fylYnw||_!| |_"||_#|r||||_$|j$j%|_&nd|_$d|_&d|_'d|_(d|_)i|_*dS)NrFg)rErCrDpayload_exceptionrjrd)+super__init__rFrGr^rHrequest_handlerrIrequest_factoryrJrErDrCrKrLrMrNfloatrOrrPrQrSrRrTrUrVrr*rWr_ TypeError ValueErrorrYrZr[renabledrar\r]r`rb)selfrlrmrer"rYrfr[rgrZrErDrCrhrirjrk __class__r5r6rqsh     zRequestHandler.__init__returncCs d|jj|jdur dSdS)Nz<{} {}> connected disconnected)formatrzr1 transportrxr5r5r6__repr__ s  zRequestHandler.__repr__zssl.SSLContextcC|jdurdS|jdS)zReturn SSLContext if available.N sslcontextrget_extra_inforr5r5r6 ssl_contexts  zRequestHandler.ssl_contextcCr)zReturn peername if available.Npeernamerrr5r5r6rs  zRequestHandler.peernamecCs|jSN)rNrr5r5r6re#sz RequestHandler.keepalive_timeout.@timeoutNc 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]rMcancelr`_loop create_futurerRrasyncioCancelledError TimeoutErrorsys version_info current_task cancellingr^_cancelrTdoneshield force_close)rxrtaskr5r5r6shutdown'sT   (    (    zRequestHandler.shutdownrcst|ttj|}|jrt||jdusJ|j|||j}t j dkr4tj | |dd}n| | }||_dS)Nr Trm eager_start)rpconnection_maderr TransportrKr"rHrrrTaskstart create_taskrT)rxrreal_transportrmrryr5r6rYs    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_cancellationrrprJrIrWrMrr^ConnectionResetErrorrrTrVfeed_eof)rxr=rryr5r6rjs.          zRequestHandler.connection_lostparsercCs6|jdusJ||_|jr|j|jd|_dSdS)Nrn)rVrQ feed_data)rxrr5r5r6 set_parsers  zRequestHandler.set_parsercCsdSrr5rr5r5r6 eof_receivedszRequestHandler.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>Frnr5r)r]r\rVrUrWrrr;r>r rFrPappendrSr set_resultrQclose) rxrmessagesupgradedtailr=msgpayloadwaitereofr5r5r6 data_receiveds>    zRequestHandler.data_receivedvalcCs$||_|jr|jd|_dSdS)zMSet keep-alive connection mode. :param bool val: new state. N)rGrMr)rxrr5r5r6 keep_alives   zRequestHandler.keep_alivecCsd|_|jr |jdSdS)zClose connection. Stop accepting new pipelining messages and close connection when handlers done processing messages. TN)r\rSrrr5r5r6rszRequestHandler.closecCs8d|_|jr |j|jdur|jd|_dSdS)zForcefully close connection.TN)r]rSrrrrr5r5r6rs    zRequestHandler.force_closerequestresponsetimecCsF|jr|jdur!tr|dusJ|j|||j|dSdSdSr)rarrlogrr)rxrrrr5r5r6 log_accesss  zRequestHandler.log_accessargskwcOs |jr|jj|i|dSdSr)rZrYrxrrr5r5r6 log_debugszRequestHandler.log_debugcOs|jj|i|dSr)rY exceptionrr5r5r6 log_exceptionszRequestHandler.log_exceptioncCsjd|_|js |js dS|j}|}|j}||kr#|||j|_dS|jr1|j s3| dSdSdSr) rMr]rGrrrLcall_at_process_keepaliverSrr)rxrmnow close_timer5r5r6rs  z!RequestHandler._process_keepalive start_timerrc 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)r`r^r#finish_responserrrr handle_error ExceptiongetattrwarningswarnDeprecationWarningrRr)rxrrrrrespr=resetr5r5r6_handle_requestsL$ $$    zRequestHandler._handle_requestc sJ|j}|j}|dus J|j}d}|jdusJ|jdus J|js |jsrrwriterrrrcororrrhrend_ttr=rr5r5r6r&s          6  0  *        s zRequestHandler.startrc s||jdur |jdd|_|jr |j|jd|_z|j}Wn-tyR|dur6|dn|d |t }t |j |j |j|jd}|j}Ynwz||IdH|IdHWntyw|||||dfYSw|||||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. NFrnz+Missing return statement on request handlerz7Web-handler should return a response instance, got {!r})r<reasontextheadersT)_finishrW set_upgradedrUrQrprepareAttributeErrorrr~r$r'r<rrr write_eofrr)rxrrr prepare_methr=r5r5r6rs@         zRequestHandler.finish_responserr<r>c Cs|jdkrt|tr|jjd|j|dn |jd|j|d|jjdkr(t dd}|t j krd t j }t j j }d}|jrVtt t}Wdn1sQwYd |jd d vru|rkt|}d |d }dj ||d}d }n |ry|}|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 )r<r content_type)rFrrrYrZremoterr output_sizerrINTERNAL_SERVER_ERRORr~ descriptionrr traceback format_excrget html_escaper'r) rxrr<r=r>ctrrtbrr5r5r6rsD        zRequestHandler.handle_errorerr_infocsdtdtffdd }|S)Nrr{cs|jjjSr)rr<r=r>)rrrxr5r6handlersz3RequestHandler._make_error_handler..handler)r&r()rxrrr5rr6rsz"RequestHandler._make_error_handler)r)r{N)rNN)8r1r2r3r4 __slots__rr%r LOG_FORMATrAbstractEventLooprtrrrrrBr?rqrrr rrrrpropertyrer BaseTransportrrArrrrbytesrrrrr&r(rrrrr r rrrrr;r __classcell__r5r5ryr6r)hs'*     U$  2 '      +   - >)Prasyncio.streamsrrr collectionsr contextlibrhtmlrrhttprloggingrtypingrrr r r r r rrrrattryarl propcacherabcrr base_protocolrhelpersrrrrrrhttp_exceptionsrrrrstreamsr r! tcp_helpersr"web_exceptionsr#r$web_logr% web_requestr& web_responser'r(__all__ssl web_serverr,_RequestFactory_RequestHandlerURLrrr*r+rsr;_MsgTyper)r5r5r5r6sx     4