5iL9dZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlmZddlmZmZmZddlmZmZddlmZmZddlmZd Z ej!d kZ" ej#d d $d Z% e" oe% Z& e&r" ddl'Z'ddl(Z(n#e)$r  dZ&d\Z'Z(YnwxYwddl*Z*nd\Z'Z(Z*e"r2e+e dr&e+e dsde _,e+e dsde _-e+e ds erdnde _.dZ/dZ0dZ1dZ2dZ3dZ4dZ5d Z6d!Z7d"Z8e j9d:d#e8fZ;e<Z=gd$Z>e+ed%sie_?Gd&d'Z@Gd(d)e@ZAGd*d+ZBGd,d-ZCGd.d/ZDGd0d1ZEGd2d3ZFGd4d5ZGGd6d7ZHd8d9d:ZId=d<ZJdS)>a A high-speed, production ready, thread pooled, generic HTTP server. For those of you wanting to understand internals of this module, here's the basic call flow. The server's listening thread runs a very tight loop, sticking incoming connections onto a Queue:: server = HTTPServer(...) server.start() -> serve() while ready: _connections.run() while not stop_requested: child = socket.accept() # blocks until a request comes in conn = HTTPConnection(child, ...) server.process_conn(conn) # adds conn to threadpool Worker threads are kept in a pool and poll the Queue, popping off and then handling each connection in turn. Each connection can consist of an arbitrary number of requests and their responses, so we run a nested loop:: while True: conn = server.requests.get() conn.communicate() -> while True: req = HTTPRequest(...) req.parse_request() -> # Read the Request-Line, e.g. "GET /page HTTP/1.1" req.rfile.readline() read_headers(req.rfile, req.inheaders) req.respond() -> response = app(...) try: for chunk in response: if chunk: req.write(chunk) finally: if hasattr(response, "close"): response.close() if req.close_connection: return For running a server you can invoke :func:`start() ` (it will run the server forever) or use invoking :func:`prepare() ` and :func:`serve() ` like this:: server = HTTPServer(...) server.prepare() try: threading.Thread(target=server.serve).start() # waiting/detecting some appropriate stop condition here ... finally: server.stop() And now for a trivial doctest to exercise the test suite .. testsetup:: from cheroot.server import HTTPServer >>> 'HTTPServer' in globals() True N) lru_cache) __version__ connectionserrors)IS_PPCbton)MakeFile StreamWriter) threadpool) ChunkedRFileDropUnderscoreHeaderReaderGatewayHTTPConnection HTTPRequest HTTPServer HeaderReaderKnownLengthRFileSizeCheckWrapperget_ssl_adapter_classWindowsSERVER_SOFTWAREzGoogle App Engine/F)NN)NNNAF_INET6 IPPROTO_IPV6) IPV6_V6ONLY SO_PEERCRED s   :;*/s%2Fs(?i))sAcceptsAccept-CharsetsAccept-EncodingsAccept-Languages Accept-RangessAllows Cache-Control ConnectionsContent-EncodingsContent-LanguageExpectsIf-Matchs If-None-MatchsPragmasProxy-AuthenticatesTEsTrailerTransfer-EncodingsUpgradesVarysViasWarningsWWW-Authenticate statisticsc&eZdZdZddZdZdZdS)rz`Object for reading headers from an HTTP request. Interface and default implementation. Nc|i}d} |}|std|tkrn|tstd|ddtt hvr|}nh |td\}}n#t$rtdwxYw|}| |}|}| |s|tvr.| |}|rd ||f}|||<E|S)a Read headers from the given stream into the given header dict. If hdict is None, a new header dict is created. Returns the populated header dict. Headers which are repeated are folded together using a comma if their specification so dictates. This function raises ValueError when the read bytes violate the HTTP spec. You should probably return "400 Bad Request" if this happens. NTIllegal end of headers.HTTP requires CRLF terminatorsrzIllegal header line.s, )readline ValueErrorCRLFendswithSPACETABstripsplitCOLON_transform_key _allow_headercomma_separated_headersgetjoin)selfrfilehdicthnamelinevkexistings D/home/kali/Ninja/venv/lib/python3.11/site-packages/cheroot/server.py__call__zHeaderReader.__call__sm =E# >>##D < !:;;;t||==&& C !ABBBBQBxE3<'' JJLL=::eQ//DAqq!===$%;<<<=GGII''**%%a(( +++ 99U++2 Ha=11AE%LG# J s B00C cdS)NTr@key_names rHr<zHeaderReader._allow_headerstr'cN|SN)r8titlerLs rHr;zHeaderReader._transform_key s~~%%'''r'rO)__name__ __module__ __qualname____doc__rIr<r;rKr'rHrrsQ 7777r(((((r'rc"eZdZdZfdZxZS)rzDCustom HeaderReader to exclude any headers with underscores in them.c`tt||}|od|vS)N_)superrr<)r@rMorig __class__s rHr<z(DropUnderscoreHeaderReader._allow_headers1/66DDXNN+8++r')rQrRrSrTr< __classcell__)rZs@rHrrs>NN,,,,,,,,,r'rcLeZdZdZdZdZd dZd dZd dZd Z d Z d Z e Z dS)rzWraps a file-like object, raising MaxSizeExceeded if too large. :param rfile: ``file`` of a limited size :param int maxlen: maximum length of the file being read c0||_||_d|_dS)z%Initialize SizeCheckWrapper instance.rN)rAmaxlen bytes_read)r@rAr^s rH__init__zSizeCheckWrapper.__init__s  r'cP|jr|j|jkrtjdSdSrO)r^r_rMaxSizeExceededr@s rH _check_lengthzSizeCheckWrapper._check_length$s3 ; )4?T[88( ( ) )88r'Nc|j|}|xjt|z c_||S)Read a chunk from ``rfile`` buffer and return it. :param size: amount of data to read :type size: int :returns: chunk from ``rfile``, limited by size if specified :rtype: bytes )rAreadr_lenrdr@sizedatas rHrgzSizeCheckWrapper.read(sDzt$$ 3t99$  r'c|M|j|}|xjt|z c_||Sg} |jd}|xjt|z c_|||t|dks|ddt krt|S)Read a single line from ``rfile`` buffer and return it. :param size: minimum amount of data to read :type size: int :returns: one line from ``rfile`` :rtype: bytes NT) rAr2r_rhrdappendLFEMPTYr?)r@rjrkress rHr2zSizeCheckWrapper.readline6s  :&&t,,D OOs4yy (OO    K ':&&s++D OOs4yy (OO    JJt   4yy3$rss)r//zz#& 'r'rcd}g}||}|rO|||t|z }d|cxkr|krnnn||}|O|SzRead all lines from ``rfile`` buffer and return them. :param sizehint: hint of minimum amount of data to read :type sizehint: int :returns: lines of bytes read from ``rfile`` :rtype: list[bytes] rr2rprhr@sizehinttotallinesrDs rH readlineszSizeCheckWrapper.readlinesQ}}X&& + LL    SYY E8$$$$u$$$$$==**D  +  r'c8|jdSz*Release resources allocated for ``rfile``.NrAclosercs rHrzSizeCheckWrapper.closef r'c|SzReturn file iterator.rKrcs rH__iter__zSizeCheckWrapper.__iter__j r'ct|j}|xjt|z c_||SzGenerate next file chunk.)nextrAr_rhrdr@rks rH__next__zSizeCheckWrapper.__next__ns>DJ 3t99$  r'rOr) rQrRrSrTr`rdrgr2r{rrrrrKr'rHrrs  )))    ''''6* DDDr'rcFeZdZdZdZd dZd dZd dZdZd Z d Z e Z dS) rzWraps a file-like object, returning an empty string when exhausted. :param rfile: ``file`` of a known size :param int content_length: length of the file being read c"||_||_dS)z%Initialize KnownLengthRFile instance.N)rA remaining)r@rAcontent_lengths rHr`zKnownLengthRFile.__init__s 'r'Nc|jdkrdS||j}nt||j}|j|}|xjt |zc_|S)zRead a chunk from ``rfile`` buffer and return it. :param size: amount of data to read :type size: int :rtype: bytes :returns: chunk from ``rfile``, limited by size if specified rr')rminrArgrhris rHrgzKnownLengthRFile.readsc >Q  3 <>DDtT^,,Dzt$$ #d))# r'c|jdkrdS||j}nt||j}|j|}|xjt |zc_|S)rmrr')rrrAr2rhris rHr2zKnownLengthRFile.readlinese >Q  3 <>DDtT^,,Dz""4(( #d))# r'rcd}g}||}|rO|||t|z }d|cxkr|krnnn||}|O|Srurvrws rHr{zKnownLengthRFile.readlinesr|r'c8|jdSr~rrcs rHrzKnownLengthRFile.closerr'c|SrrKrcs rHrzKnownLengthRFile.__iter__rr'cht|j}|xjt|zc_|Sr)rrArrhrs rHrzKnownLengthRFile.__next__s,DJ #d))# r'rOr) rQrRrSrTr`rgr2r{rrrrrKr'rHrrxs ((( ((* DDDr'rcDeZdZdZd dZdZd dZd dZdd Zd Z d Z dS)r aWraps a file-like object, returning an empty string when exhausted. This class is intended to provide a conforming wsgi.input value for request entities that have been encoded with the 'chunked' transfer encoding. :param rfile: file encoded with the 'chunked' transfer encoding :param int maxlen: maximum length of the file being read :param int bufsize: size of the buffer used to read the file cd||_||_d|_t|_||_d|_dS)z!Initialize ChunkedRFile instance.rFN)rAr^r_rrbufferbufsizeclosed)r@rAr^rs rHr`zChunkedRFile.__init__s0     r'cZ|jrdS|j}|xjt |z c_|jr*|j|jkrt jd|j| td} | d}t|d}n #t$rtd|wxYw|dkr d|_dS|jr"|j|z|jkrtd|j|}|xjt |z c_|xj|z c_|jd}|t"kr"tdt%|zd zdS) NRequest Entity Too LargerrzBad chunked transfer size: Tz2Bad chunked transfer coding (expected '\r\n', got ))rrAr2r_rhr^rrbr8r9 SEMICOLONpopintr3IOErrorrgrr4repr)r@rD chunk_sizechunkcrlfs rH_fetchzChunkedRFile._fetchs ;  Fz""$$ 3t99$ ; 4?T[88(*   zz||!!)Q// !JZ,,JJ    o| }|r d}|d|dS| r|dddS| |dddS dt@| D}n9#t$r,}|d|j!dYd }~dSd }~wwxYwtD|} | t>s t>| z} |t4ur||_#||_$| |_%| |_&t|j'j(dt|j'j(df}|d|dkr|ddS||_)d tU||z|_+dS)!zRead and parse first line of the HTTP request. Returns: bool: True if the request line is valid or False if it's malformed. TF400 Bad Requestr1rsHTTP/z$Malformed Request-Line: bad protocolN.rz#Malformed Request-Line: bad version)rrz505 HTTP Version Not SupportedzCannot fulfill requestzMalformed Request-LinezMalformed method name: According to RFC 2616 (section 5.1.1) and its successors RFC 7230 (section 3.1.1) and RFC 7231 (section 4.1) method names are case-sensitive and uppercase.zMalformed Request-URIsOPTIONSsCONNECTz405 Method Not Allowedr's//zFInvalid path in Request-URI: request-target must match authority-form.z2Absolute URI not allowed if server is not a proxy.zInvalid path in Request-URI: request-target must contain origin-form which starts with absolute-path (URI starting with a slash "/").z!Illegal #fragment in Request-URI.zInvalid path in Request-URI.cLg|]!}tj|"SrK)urllibparseunquote_to_bytes.0xs rH z1HTTPRequest.read_request_line..s8L11!44r'rz HTTP/%s.%s),rAr2rr4r5rr8r9r6 startswithrhtuplemaprr3 IndexErroruriuppermethodrrrurlsplit UnicodeErrorrr?rr contextlibsuppressportany FORWARD_SLASHQUOTED_SLASH_REGEXargs QUOTED_SLASHr authoritypathqsrprotocolrequest_protocolrr)r@ request_linerr req_protocolrpresprrrrfragmenturi_is_absolute_form uri_split_scheme _authority_path_qs _fragment_port invalid_pathdisallowed_absoluteatomsexsps rHrzHTTPRequest.read_request_linesz**,,  $ 5 4    :..00L u$$T**   !0   5 (4(:(:(<(<(B(B5!(L(L %FC**844 $$%:uabb!''a00B2ww!||$$%9us3||$$BF{{$$4,u  J'     !24L M M M55 llnn   $+ 5 5A   !2D 9 9 95 4:L4I4I#4N4N 1FItR     !24K L L L55  &2 ;* $ $ O(< D [J & &? $$%=>>>u --chhs|.D.DEEI9B 6GZYE$Z00 ' '! ' ' ' ' ' ' ' ' ' ' ' ' ' ' 'c!999Y788   $$%8 u) )I%* *F *R(( )')( # C$$%Hu -}555-,,   >2 $$%6===u $$%7u|$$%2u /55d;;   $$%6 CCCuuuuu  $$U++D}-- ( 4'D    DK" %a( ) )3t{/CA/F+G+G G a5BqE>>  !A B B B5 ,!-B !;ts\AE(AE('>E(('FF#%H H-,H-K''K+.K+$P P7 !P22P7c ||j|jn9#t$r,}|d|jdYd}~dSd}~wwxYw|jj} t|j dd}n'#t$r|ddYdSwxYw|r||kr|dddS|j d kr'|j d d d krd |_ n&|j d d dkrd |_ d}|j d kr;|j d}|rd| dD}d|_ |r1|D].}|dkrd |_ |dd |_ dS|j dd dkrd |jjdt"dt$t$f} |jj|n6#t,j$r$}|jdt0jvrYd}~nd}~wwxYwd S)zRead ``self.rfile`` into ``self.inheaders``. Ref: :py:attr:`self.inheaders `. :returns: success status :rtype: bool rrNFContent-Lengthz Malformed Content-Length Header.rCThe entity sent with the request exceeds the maximum allowed bytes.HTTP/1.1r*r'closeT Keep-Aliver,cg|]<}||=SrK)r8lowerrs rHrz4HTTPRequest.read_request_headers..s7MMMA17799Maggiioo''MMMr',chunkedz501 Unimplementedr+s 100-continueasciis 100 Continue) header_readerrArr3rrrmax_request_body_sizerr>rrr9rr?rencoder6r4rwfilewritesocketerrorrsocket_errors_to_ignore)r@rmrbsclteencmsgs rHrz HTTPRequest.read_request_headerss    tz4> : : : :     !2BGAJ ? ? ?55555 {0 T^''(91==>>BB     !2   55    BII  .!    5  !Z / /~!!-55AA(,% ^   s 3 3} D D$(D !  !Z / /##$899B NMM$MMM! ! ! !*$$(,D%%(()<===,0D) 55& >  i - - @ @((K(//88# C  %%c****<   71:V%CCCDCCCC ts> # A!AA)(B B65B6H99I,I''I,c&|jj}|jr t|jj||_nnt |jdd}|r%||kr|j s| dddSt|jj||_|j | |jo||jr!|jjddSdS)z/Call the gateway and write its iterable output.rrrrNs0 )rrrr rrArrr>rrrgatewayrespondrensure_headers_sentrrr)r@rrs rHrzHTTPRequest.respondEs{0   ?%diot<>B r (((61 )$)/2>>DJ D!!))+++ 1t//11   0 IO ! !, / / / / / 0 0r'rct|}|jjd|d}dt|z}d}|d|d|dg}|dddvr*d |_|jd kr|d nd }|t|r?t|tr|d}|| |j j t|dS#tj$r%}|jd t$jvrYd}~dSd}~wwxYw)z+Write a simple response back to the client. z zContent-Length: %s zContent-Type: text/plain ISO-8859-1N>413414TrsConnection: close rr)strrrrhrrrrpr4 isinstancerrrrrr?rrrrr)r@rr proto_statusr content_typebufrs rHrzHTTPRequest.simple_response\sV&*k&:&:&:FFFC 1CHH<5    - -  ! !, / /    - -  "1": ' '$(D !%33 34444+ 4  #s## /jj.. JJsOOO  IO ! !%**S// 2 2 2 2 2|   wqz!???@????? s7D??E3E..E3cN|jsd|_|dSdS)z:Ensure headers are sent to the client if not already sent.TN)r send_headersrcs rHrzHTTPRequest.ensure_headers_sents7  $D           r'cV|jr|rtt|ddd}|t|tg}|jjt |dS|jj|dS)z$Write unbuffered data to the client.rNr ) rhexrhrr4rrrrrr?)r@rchunk_size_hexr(s rHrzHTTPRequest.writes   )% ) U__QRR077@@N!45C IO ! !%**S// 2 2 2 2 2 IO ! !% ( ( ( ( (r'cd|jD}t|jdd}|dkrd|_nPd|vrL|dks|dvrnA|jd ko |jd k}|r"d|_|jd nd|_|js|jj }| |_d |vrN|jd kr"|jr|jd n!|js|jdd|jvr<|jdd|jj  df|js=|j s6t|jdd}|dkr|j|d|vrM|jdt jd dfd|vr9|jd|jj df|jj d}|t*z|jzt,zg}|jD]5\}} ||t.zt*z| zt,z6|t,|jjt6|dS)zAssert, process, and send the HTTP response message-headers. You must set ``self.status``, and :py:attr:`self.outheaders ` before calling this. c<g|]\}}|SrK)r )rkeyvalues rHrz,HTTPRequest.send_headers..s$???e???r'Nr!iTscontent-length>0rsHEAD)r,r s connection)r*r)r*rrztimeout=r rrsdatesDate)usegmtsserversServerr )rrrrrrrrprcan_add_keepalive_connectiontimeoutrrgetattrrArgemailutils formatdate server_namerr6r4r:rrrrrr?) r@hkeysr needs_chunkedcan_keeprprotor(rFrEs rHr*zHTTPRequest.send_headerss @?t???T[!_%% S==$(D ! ! e + +||v88*j8/ w.!1)-D&O**+MNNNN-1D)$ 1{?H(0LD !  % %%33(FO**+DEEE* G&&'EFFF )T_ < < O " "!4t{244;;LII   % +0A +  K;;I1}}  *** %   O " "K**$*77>>|LL    E ! ! O " "K+22<@@    $++G44u}t{*T12O 5 5DAq JJq5y5(1,t3 4 4 4 4 4 ejjoo.....r')FT)r)rQrRrSrTrrrrrrrrr r`rrrrrrrr*rKr'rHrrs F@ DDI$J; E@M<!LNNM''''B   DcccJbbbH000.####J   )))\/\/\/\/\/r'rceZdZdZdZdZdZejZ ejZ e Z dZ dZdZefdZdZdZdZdZdZd Zed Zed Zed Zd ZedZedZdZdS)rz#An HTTP connection (active socket).NFc\||_||_||d|j|_||d|j|_d|_|jj|_|jj|_td|j |_ td|j |_ dS)aBInitialize HTTPConnection instance. Args: server (HTTPServer): web server object receiving this request sock (socket._socketobject): the raw socket object (usually TCP) for this connection makefile (file): a fileobject class for reading from the socket rbwbrr)maxsizeN) rrrbufsizerAwbufsizer requests_seenpeercreds_enabledpeercreds_resolve_enabledrresolve_peer_credsget_peer_creds)r@rsockmakefiles rHr`zHTTPConnection.__init__s  XdD$-88 XdD$-88 !%!>)-)N&#7)A"6"6"6t7N"O"O2i22243FGGr'cd} ||j|}||jjdr|xjdz c_|jsdSd}||jsdSnN#tj $r}|j d}d}||vr"|r |r|j r| |dn[|tjvrM|jdt!|zt"jd | |d Yd }~nd }~wt&t(f$rtj$rYntj$r||Yn`t0$rT}|jt!|t"jd | |d Yd }~nd }~wwxYwdS) zrRead each request and respond appropriately. Returns true if the connection should be kept open. FEnabledrTr)z timed outzThe read operation timed outz408 Request Timeoutzsocket.error %slevel tracebackz500 Internal Server ErrorN)RequestHandlerClassrrstatsrIrrrrrrr_conditional_errorrr error_logrloggingWARNINGKeyboardInterrupt SystemExit FatalSSLAlert NoSSLError_handle_no_ssl ExceptionERROR)r@ request_seenreqrerrnum timeout_errss rH communicatezHTTPConnection.communicatesH  - F**4;==C      { + (""a'""9 uL KKMMM' t | J J JWQZFFL%% %H#H#2EH++C1FGGGv=== %%%V 4!/"& ''-HIII!:.    #    D  % % %    $ $ $ $ $ F F F K ! !Rm "     # #C)D E E E E E E E E  Fus8AA?A??G BD###G #G - G 6A GG c|r|jrdS |jj}n#t$r|jj}YnwxYwt |d|j|_d}|d|d|_ dS)NrEzUThe client sent a plain HTTP request, but this server only speaks HTTPS on this port.rT) rr_sockAttributeError_socketr rHrrlinger)r@rc resp_sockrs rHr_zHTTPConnection._handle_no_sslMs c&  F , )II , , , +III ,")T4=AA  :  -s333 s 33c|r|jrdS ||dS#tj$rYdStj$r||YdSwxYw)zvRespond with an error. Don't bother writing if a response has already started being written. N)rrrr]r^r_)r@rcresponses rHrWz!HTTPConnection._conditional_error^s  c&  F %    ) ) ) ) )#    DD  % % %    $ $ $ $ $ $ %s$A#AAc|j|js/||jdSdS)z,Close the socket underlying this connection.N)rArrk_close_kernel_socketrrcs rHrzHTTPConnection.closensU {   % % ' ' ' K        Dr'cd}ts|jjtjkrt d|jst d |jtjtj tj |}tj ||\}}}|||fS#tj $r} t |d}~wwxYw)aReturn the PID/UID/GID tuple of the peer socket for UNIX sockets. This function uses SO_PEERCRED to query the UNIX PID, UID, GID of the peer, which is only available if the bind address is a UNIX domain socket. Raises: NotImplementedError: in case of unsupported socket type RuntimeError: in case of SO_PEERCRED lookup unsupported or disabled 3iz5SO_PEERCRED is only supported in Linux kernel and WSLz0Peer creds lookup is disabled within this serverN) IS_WINDOWSrfamilyAF_UNIXNotImplementedErrorrJ RuntimeError getsockopt SOL_SOCKETrstructcalcsizeunpackr)r@PEERCRED_STRUCT_DEF peer_credspiduidgid socket_errs rHrMzHTTPConnection.get_peer_credss#  +v~==%G % B  !//!" 344 J"#M*=zJJMCcS= | / / / J . /s AB**C9 CCc6|\}}}|S)z,Return the id of the connected peer process.rM)r@rrWs rHpeer_pidzHTTPConnection.peer_pids '')) Q r'c6|\}}}|S)z1Return the user id of the connected peer process.r)r@rWrs rHpeer_uidzHTTPConnection.peer_uids '')) 3 r'c6|\}}}|S)z2Return the group id of the connected peer process.r)r@rWrs rHpeer_gidzHTTPConnection.peer_gids '')) 1c r'ctstd|jstdt j|jj}tj |j j }||fS)aLook up the username and group tuple of the ``PEERCREDS``. :returns: the username and group tuple of the ``PEERCREDS`` :raises NotImplementedError: if the OS is unsupported :raises RuntimeError: if UID/GID lookup is unsupported or disabled zUID/GID lookup is unavailable under current platform. It can only be done under UNIX-like OS but not under the Google App Enginez-UID/GID lookup is disabled within this server) IS_UID_GID_RESOLVABLErvrKrwpwdgetpwuidrpw_namegrpgetgrgidrgr_name)r@usergroups rHrLz!HTTPConnection.resolve_peer_credssy% %6  - ? |DM**2 T]++3U{r'c4|\}}|S)z2Return the username of the connected peer process.rL)r@rrWs rH peer_userzHTTPConnection.peer_users))++a r'c4|\}}|S)z/Return the group of the connected peer process.r)r@rWrs rH peer_groupzHTTPConnection.peer_groups**,,5 r'ct|jd|jj} |tjdS#tj$rYdStj$r}|jtjvrYd}~dSd}~wwxYw)z0Terminate the connection at the transport level. sock_shutdownN) r9rshutdown SHUT_RDWRr#acceptable_sock_shutdown_exceptionsrerrno$acceptable_sock_shutdown_error_codes)r@res rHrpz#HTTPConnection._close_kernel_sockets K  K      HV% & & & & &9    DD|   wfIIIJIIIII s9A8 A8A33A8) rQrRrSrT remote_addr remote_portssl_envioDEFAULT_BUFFER_SIZErGrHrrUrJrK last_usedr r`rfrkr_rWrrMpropertyrrrrLrrrprKr'rHrrsf--KKG%H%H% %I.6HHHH.444lF"%%% &*!*!*!XX X X 0X X r'rceZdZdZdZdZdZ dZ dZ dZ dZ dZ dZ dZ dZ deZ dZ d Z d Z d Z d Z eZ dZ d Z d Z d Z dZ d)d ZdZdZdZ e!dZ"e"j#dZ"dZ$dZ%dZ&dZ'dZ(e)j*dZ+e!dZ,dZ-d*dZ.d+dZ/dZ0e1d Z2e3 d,d!Z4e1d"Z5e1d#Z6d$Z7e!d%Z8e!d&Z9e8j#d'Z8d(Z:dS)-rzAn HTTP server.z 127.0.0.1Nrr g?zCheroot/FrTroc ||_||_tj||pd||_|s|j}||_||_|o||_||_ | tj |_ dS)aInitialize HTTPServer instance. Args: bind_addr (tuple): network interface to listen to gateway (Gateway): gateway for processing HTTP requests minthreads (int): minimum number of threads for HTTP thread pool maxthreads (int): maximum number of threads for HTTP thread pool server_name (str): web server name to be advertised via Server HTTP header reuse_port (bool): if True SO_REUSEPORT option would be set to socket r)rmaxN) bind_addrrr ThreadPoolrequestsversionr=rJrK reuse_port clear_statsqueueQueue_unservicable_conns) r@rr minthreads maxthreadsr=rJrKrs rHr`zHTTPServer.__init__Us.# "- a     ',K&!2 % ;*; &% #(;==   r'c d_d_idddfddfdd dd fd d fd dfddfddddddddddddddddi_jtjd t z<dS)!zReset server stat counters..NrrQFz Bind Addressc,tjSrO)rrsr@s rHz(HTTPServer.clear_stats..sd4>&:&:r'zRun timecB|d rdpS)NrQroruntimers rHrz(HTTPServer.clear_stats..s&) $4#<"#||~~r'Acceptsz Accepts/secc>|dz S)Nrrrs rHrz(HTTPServer.clear_stats..sQy\DLLNN%Br'rc0tjddS)Nqsizer9rrs rHrz(HTTPServer.clear_stats..swt}gtDDr'ThreadscJttjdgS)N_threads)rhr9rrs rHrz(HTTPServer.clear_stats..sWT]J%K%K!L!Lr'z Threads Idlec0tjddS)Nidlerrs rHrz(HTTPServer.clear_stats..sgdmVT&J&Jr'z Socket ErrorsRequestsc||d rdp1td|dDdS)NrQroc38K|]}|d|VdS)rNrKrws rH z;HTTPServer.clear_stats....s0HHa:q!!HHHHHHr'Worker Threadsrsumvaluesrs rHrz(HTTPServer.clear_stats..sM) $4#<"#HH1-=+>+E+E+G+GHHHr' Bytes Readc||d rdp1td|dDdS)NrQroc38K|]}|d|VdS)rNrKrs rHrz;HTTPServer.clear_stats....s0JJ<##JJJJJJr'rrrrs rHrz(HTTPServer.clear_stats..sM!I,&6%>B%JJQ/?-@-G-G-I-IJJJr' Bytes Writtenc||d rdp1td|dDdS)NrQroc38K|]}|d|VdS)rNrKrs rHrz;HTTPServer.clear_stats....s2MM1#?#A&&MMMMMMr'rrrrs rHrz(HTTPServer.clear_stats..sMQy\)9(Ar(MM2B0C0J0J0L0LMMMr' Work Timec||d rdp1td|dDdS)NrQroc38K|]}|d|VdS)rNrKrs rHrz;HTTPServer.clear_stats....s0IIq;""IIIIIIr'rrrrs rHrz(HTTPServer.clear_stats..sM9%5$=2$IIA.>,?,F,F,H,HIIIr'zRead Throughputc||d rdp1td|dDdS)NrQroc3`K|])}|d||d|pdz V*dS)rrư>NrKrs rHrz;HTTPServer.clear_stats....s\$AlOA&&.!K.*;*;*CtDr'rrrrs rHrz(HTTPServer.clear_stats..sZq|+;*C*/07799 r'zWrite Throughputc||d rdp1td|dDdS)NrQroc3`K|])}|d||d|pdz V*dS)rrrNrKrs rHrz;HTTPServer.clear_stats....s]'Ao&q))^Q{^A->->-F$Gr'rrrrs rHrz(HTTPServer.clear_stats..sZ) ,<+D"+/07799 r'rzCheroot HTTPServer %d) _start_time _run_timerVrYr-idrcs`rHrzHTTPServer.clear_statssu0 u0 ::::0  0 q 0 BBBB 0  DDDD0  LLLL0  JJJJ0  Q0  0 !0 * +0 4 50 >   ?0 N !!O0 ^ b_0  bBF2RXX=>>>r'cd|j|jS|jtj|jz zS)zReturn server uptime.)rrtimercs rHrzHTTPServer.runtimes.   #> !~t/?!?@@r'c@|jd|jjd|jdS)z1Render Server instance representing bind address..(r)rRrZrQrrcs rH__str__zHTTPServer.__str__s. OOO N # # # NNN  r'c|jS)aReturn the interface on which to listen for connections. For TCP sockets, a (host, port) tuple. Host values may be any :term:`IPv4` or :term:`IPv6` address, or any valid hostname. The string 'localhost' is a synonym for '127.0.0.1' (or '::1', if your hosts file prefers :term:`IPv6`). The string '0.0.0.0' is a special :term:`IPv4` entry meaning "any active interface" (INADDR_ANY), and '::' is the similar IN6ADDR_ANY for :term:`IPv6`. The empty string or :py:data:`None` are not allowed. For UNIX sockets, supply the file name as a string. Systemd socket activation is automatic and doesn't require tempering with this variable. .. glossary:: :abbr:`IPv4 (Internet Protocol version 4)` Internet Protocol version 4 :abbr:`IPv6 (Internet Protocol version 6)` Internet Protocol version 6 ) _bind_addrrcs rHrzHTTPServer.bind_addrs 4r'cpt|tr|ddvrtd||_dS)z5Set the interface on which to listen for connections.r>NrzzHost values of '' or None are not allowed. Use '0.0.0.0' (IPv4) or '::' (IPv6) instead to listen on all active interfaces.N)r%rr3r)r@r1s rHrzHTTPServer.bind_addrsJ eU # # aJ(>(>6   r'c |dS#t$r}|j}|s||_||d}~wt$r}|j}|s||_||d}~wwxYw)z4Run the server forever, and stop it cleanly on exit.N)startr[ interruptr\)r@ kb_intr_excunderlying_interrupt sys_exit_excs rH safe_startzHTTPServer.safe_starts 9 JJLLLLL  8 8 8#'> ' -!,#7 7 9 9 9#'> ' .!-$8 8  9s A5 AAAc(d|_|jd|jz|_d|_d}t jddr1tjdtjtj|_nt|j ttfrY | |j nB#tj$r*}|d|j d|d}tj||d}~wwxYw|j \}} tj||tjtjd tj}nO#tj$r=tj}|j }d |vrtj}|d z}|tjd d |fg}YnwxYw|D]q}|\} } } } } || | | nN#tj$r<}|d| d|d}|jr|jd|_Yd}~jd}~wwxYw|jstj||jd |j|jt3j||_|jd|_t?j|_ dS)zPrepare server to serving requests. It binds a socket's port, setups the socket to ``listen()`` and does other preparing things. Nz %s ServerzNo socket could be created LISTEN_PIDr!z -- (z: rr:)rrrrT)! _interruptsoftwarerrosgetenvfromfdAF_INET SOCK_STREAMr%rr$bytesbind_unix_socketr getaddrinfo AF_UNSPEC AI_PASSIVEgaierrorrbindr settimeoutlistenrequest_queue_sizerConnectionManager _connectionsrrrrr)r@rserrhostrinfo sock_typerrsafsocktyperA _canonnamesas rHpreparezHTTPServer.prepares  = '$,6DM * 9\4 ( (+ ' -6>6;MNNDKK e 5 5( ' 2%%dn5555< 2 2 2*-##t~~~tttDl3''T1 2JD$ K)$&% ? K K K"N  N $;; &I )F 2I"F$62yIJ K ' '693HeZ'IIb(E222E|'''.1cc222ttt}|j t|tjdYd}~nd}~wwxYwd|_||jdSdS)z(Serve connections we can't handle a 503.Nz503 Service UnavailableTrR)rrr>_STOPPING_FOR_INTERRUPTrrOSErrorrr]r`rrXrrYrarkr)r@rrequestrs rH_serve_unservicablezHTTPServer._serve_unservicableQsj +//11D...!$--G ''(ABBBBV12       %%HH!-"&  DK JJLLL+j     sAB2+ B244B--B2ctj|j|jry|jsr |j|jnC#ttf$rt$r%| dtjdYnwxYw|jr|jr|jr0|jrt!jd|j|jr |jdSdS)z1Serve requests, after invoking :func:`prepare()`.targetzError in HTTPServer.serveTrRg?N) threadingThreadrrrrr runexpiration_intervalr[r\r`rXrYra_stopping_for_interruptrsleeprcs rHservezHTTPServer.servejs-  8999??AAAj   !%%d&>????%z2      /!-"  j   > %.  3. ~ %n$  % % % %sA=BBcV||dS)zmRun the server forever. It is shortcut for invoking :func:`prepare()` then :func:`serve()`. N)rr"rcs rHrzHTTPServer.starts"  r'c#K|tj|j}d|_| |V|dS#|wxYw)z4Context manager for running this server in a thread.rTN)rrrr"daemonrstop)r@threads rH_run_in_threadzHTTPServer._run_in_threadso !444   LLL IIKKKKKDIIKKKKs A''A=c(|jo |jjS)z>Flag whether it is allowed to add a new keep-alive connection.)rr r7rcs rHr7z'HTTPServer.can_add_keepalive_connectionszLd/LLr'ct|jr|j|dS|dS)z7Put an idle connection back into the ConnectionManager.N)rr putrr@rs rHput_connzHTTPServer.put_conns< :    ! !$ ' ' ' ' ' JJLLLLLr'rc.tj|dtj|rRt j}tj|tjdSdS)zWrite error message to log. :param msg: error message :type msg: str :param level: logging level :type level: int :param traceback: add traceback to output or not :type traceback: bool  N)sysstderrrflush traceback_ format_exc)r@rrSrTtbliness rHrXzHTTPServer.error_logs C&&&    +--G J  W % % % J         r'c ||j||||j|j|j}|||jx}|_|||_|S)z.Create (or recreate) the actual socket object.)prepare_socketrnodelayrr bind_socketrresolve_real_bind_addr)r@rttyperArNs rHrzHTTPServer.bindso"" N    L   O  "--dDNCCCt{44T:: r'c tr tdd} tj|jnd#t $rYnXt $r}t|}d|vrYd}~n6d}~wt$r&}t|}d|vr d|vrd|vrYd}~nd}~wwxYw||tj tj d|j |j |j } tj||d }n#t $rd }YnwxYw |||}n(#tj$r|wxYw||} |s@ tj||n'#t,$rtj||d YnwxYwd }n#t $rYnwxYw|s!|d t2j||_||_ |S)z*Create (or recreate) a UNIX socket object.z0AF_UNIX sockets are not supported under Windows.izJremove() argument 1 must be encoded string without null bytes, not unicodeNz'unlink: embedded null character in pathzembedded null bytez0argument must be a string without NUL charactersr)rrtr<rAr9rrTF)follow_symlinksz(Failed to set socket fs mode permissions)rS)rsr3runlinkrr TypeErrorr$r8rrurr9rrfchmodfilenor:rrr;lchmodrichmodrXrYrZ)r@rfs_permissionstyp_errerr_msgval_errrN FS_PERMS_SETs rHrzHTTPServer.bind_unix_sockets   B   Idn % % % %        'llG9@GHHHHHHH   'llG9HH(77F "">#L(#   ! B Idkkmm^ 4 4 4LL ! ! ! LLL ! ##D)44DD|    JJLLL  //55   C $OIi8888%OOOHYNNNNNNO#     D   NN:o     #  s{5 B B A## B0BB*D DDD..%E,F00FF0!F*'F0)F**F00 F=<F=c4|dd\}}|dk}|jtjtjhvrt d|rt dt tdr-|tjtjddSt tdr-|tjtj ddStr-|tjtj ddStd) NrrzCannot reuse a non-IP socketz"Cannot reuse an ephemeral port (0)SO_REUSEPORT_LBr SO_REUSEPORTz,Current platform does not support port reuse) rtrrrr3hasattr setsockoptryrKrLrs SO_REUSEADDRrv)socket_r_hostrIS_EPHEMERAL_PORTs rH_make_socket_reusablez HTTPServer._make_socket_reusable!s m t AI >&.&/!B B B;<< <  CABB B 6, - -    v0&2H! L L L L L V^ , ,    v0&2Eq I I I I I     v0&2Eq I I I I I%> r'ctj|||}tj||dd\} } | dk} |r|||ts.| s, |tjtjd|rGt|ttfs+|tj tj d|| |}ttdo|tjko| dv} | rgt!jt$tj5|tjtjddddn #1swxYwY|S)z%Create and prepare the socket object.NrrrPrrr>::::0 ::0.0.0.0)rrprevent_socket_inheritancerSrsrNryrOr%r$r IPPROTO_TCP TCP_NODELAYrrMrrrrirrr) clsrrtr<rAr9rrrNr rrRlistening_ipv6s rHr8zHTTPServer.prepare_socket;s}VT511.t444rr] d AI  I  % %di % H H H G/ G  OOF-v/BA F F F  G:i#u>> G OOF.0BA F F F  "##D))D FJ ' ' 3&/) 322   $^V\BB  '&                s;,E33E7:E7c0|||S)z#Bind the socket to given interface.)rrUs rHr:zHTTPServer.bind_socketvs  Yr'c|}|jtjtjhvr |ddSt |t rt|}|S)z/Retrieve actual bind address from bound socket.Nr) getsocknamertrrrr%rr rUs rHr;z!HTTPServer.resolve_real_bind_addr|sk '')) > N O    RaR= i ' ' (YIr'c |j|dS#tj$r|j|YdSwxYw)z#Process an incoming HTTPConnection.N)rr+rFullrr,s rH process_connzHTTPServer.process_conns` / M  d # # # # #z / / /  $ ( ( . . . . . . /s)A  A c|jS)zFlag interrupt of the server.)rrcs rHrzHTTPServer.interrupts r'c|jtuS)z8Return whether the server is responding to an interrupt.)rrrcs rHr z"HTTPServer._stopping_for_interrupts"999r'ct|_t|tr|dt|t r|d|||_dS)aPerform the shutdown of this server and save the exception. Typically invoked by a worker thread in :py:mod:`~cheroot.workers.threadpool`, the exception is raised from the thread running :py:meth:`serve` once :py:meth:`stop` has completed. z!Keyboard Interrupt: shutting downz SystemExit raised: shutting downN)rrr%r[rXr\r&)r@rs rHrzHTTPServer.interruptso2 i!2 3 3 @ NN> ? ? ? i , , ? NN= > > > #r'cX|jsdSd|_|jt|j)|xjt j|jz z c_d|_|jt|dd}|r^t|j ttfs |dd\}}tj||tjtjD]}|\}}}}} d} tj|||} | d| ||f| d#tj$r| r| YwxYwn6#tj$r$} | jdt0jvrYd} ~ nd} ~ wwxYwt5|dr|d|_|j|j|jdS)z5Gracefully shutdown a server that is serving forever.NFrrg?rr)rrr+rrrrr r&r9r%rr$rr`rrrrrconnectrrrrrrMrshutdown_timeout) r@rNr rrsrrrAr_sarrs rHr&zHTTPServer.stopsGz  F   $$%<===   ' NNdikkD,<< Process the current request. Must be overridden in a subclass.)rvrcs rHrzGateway.responds!!r'N)rQrRrSrTr`rrKr'rHrrs8NN"""""r'rz%cheroot.ssl.builtin.BuiltinSSLAdapterz&cheroot.ssl.pyopenssl.pyOpenSSLAdapter)builtin pyopensslrtct|}t|tr|d}||dzd}|d|} t j|}|tn;#t$r.t|ttdg}YnwxYw t||}n$#t$rtd|d|dwxYw|S)z/Return an SSL adapter class for the given name.rrNr'z' object has no attribute ') ssl_adaptersr r%r$rfindr1modulesKeyError __import__globalslocalsr9ri)nameadapterlast_dot attr_namemod_pathmods rHrr s4::<<(G'3==%%HqLNN+ 9H9% B+h'C{ B B BXwyy&((RDAACCC B  c9--GG    .7?xxK   Ns"A>>5B65B6:C !C,)rt)KrTr email.utilsr:rrYrplatformrrerr1rrrTr4 urllib.parser functoolsrrrrr_compatrr rOr r workersr __all__systemrsrrIS_GAErrr ImportErrorrzrMrrrrqr4r7r6r:rrrASTERISKrrcompiler?rr`rr=r-rrrrr rrrrrxrrKr'rHrsAAF    ..........!!!!!!!!,,,,,,,, X_  ) + ? $b ) ) 4 45I J J'5v:N(    !&SSSMMMM'Cf ''&*-- 76> * *!  76= ) ) wv}%%. &-2F          RZ'<)@ A ABB$)++6ww %%GD(D(D(D(D(D(D(D(N,,,,,,,,^^^^^^^^BWWWWWWWWt~~~~~~~~BY /Y /Y /Y /Y /Y /Y /Y /xCCCCCCCCL| 2| 2| 2| 2| 2| 2| 2| 2~ " " " " " " " "&79 s&B// B?>B?