#jL9dZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlmZddlmZmZmZddlmZmZddlmZmZddlmZd Z ejBd k(Z" ejFd d jId Z% e" xre% Z& e&r ddl'Z'ddl(Z(ddl*Z*nd\Z'Z(Z*e"r)e+e dr e+e dsde _,e+e dsde _-e+e ds erdnde _.dZ/dZ0dZ1dZ2dZ3dZ4dZ5d Z6d!Z7d"Z8e jrdjud#e8fZ;e<Z=gd$Z>e+ed%sie_?Gd&d'Z@Gd(d)e@ZAGd*d+ZBGd,d-ZCGd.d/ZDGd0d1ZEGd2d3ZFGd4d5ZGGd6d7ZHd8d9d:ZId 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$eZdZdZddZdZdZy)rz`Object for reading headers from an HTTP request. Interface and default implementation. Nc|i}d} |j}|s td|tk(r |S|jts td|ddtt hvr|j }n= |jtd\}}|j }|j|}|}|js|tvr&|j|}|rdj||f}|||<#t$r tdwxYw)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. NIllegal end of headers.HTTP requires CRLF terminatorsrzIllegal header line.s, )readline ValueErrorCRLFendswithSPACETABstripsplitCOLON_transform_key _allow_headercomma_separated_headersgetjoin)selfrfilehdicthnamelinevkexistings =/srv/dav/.venv/lib/python3.12/site-packages/cheroot/server.py__call__zHeaderReader.__call__s =E>>#D !:;;t|: 9==& !ABBBQxE3<' JJL=::eQ/DAqGGI''*%%a(++ 99U+ Ha=1AE%LG,"=$%;<<=s 4C66D cy)NTr@key_names rHr<zHeaderReader._allow_headersr'c>|jjSN)r8titlerLs rHr;zHeaderReader._transform_key s~~%%''r'rO)__name__ __module__ __qualname____doc__rIr<r;rKr'rHrrs 7r(r'rc"eZdZdZfdZxZS)rzDCustom HeaderReader to exclude any headers with underscores in them.c:tt| |}|xrd|vS)N_)superrr<)r@rMorig __class__s rHr<z(DropUnderscoreHeaderReader._allow_headers%/DXN+8++r')rQrRrSrTr< __classcell__)rZs@rHrrsN,,r'rcJeZdZdZdZdZd dZd dZd dZdZ d Z d Z e Z y) 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 c.||_||_d|_y)z%Initialize SizeCheckWrapper instance.rN)rAmaxlen bytes_read)r@rAr^s rH__init__zSizeCheckWrapper.__init__s  r'cp|jr*|j|jkDrtjyyrO)r^r_rMaxSizeExceededr@s rH _check_lengthzSizeCheckWrapper._check_length$s+ ;;4??T[[8(( (9;r'Nc|jj|}|xjt|z c_|j |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(s9zzt$ 3t9$  r'c|K|jj|}|xjt|z c_|j |Sg} |jjd}|xjt|z c_|j |j |t|dks |ddt k(rtj|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 N) rAr2r_rhrdappendLFEMPTYr?)r@rjrkress rHr2zSizeCheckWrapper.readline6s  ::&&t,D OOs4y (O    K::&&s+D OOs4y (O    JJt 4y3$rs)r/zz#&r'cd}g}|j|}|rB|j||t|z }d|cxkr|kr |S|j|}|rB|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.readlinesQm}}X& LL  SY E8$u$ %==*D   r'c8|jjyz*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_|j |SzGenerate next file chunk.)nextrAr_rhrdr@rks rH__next__zSizeCheckWrapper.__next__ns3DJJ 3t9$  r'rOr) rQrRrSrTr`rdrgr2r{rrrrrKr'rHrrs6  ) '6* Dr'rcDeZdZdZdZd dZd dZd dZdZdZ d Z e Z y) 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 ||_||_y)z%Initialize KnownLengthRFile instance.N)rA remaining)r@rAcontent_lengths rHr`zKnownLengthRFile.__init__s 'r'Nc|jdk(ry| |j}nt||j}|jj|}|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.readsZ >>Q  <>>DtT^^,Dzzt$ #d)# r'c|jdk(ry| |j}nt||j}|jj|}|xjt |zc_|S)rmrr')rrrAr2rhris rHr2zKnownLengthRFile.readlines\ >>Q  <>>DtT^^,Dzz""4( #d)# r'cd}g}|j|}|rB|j||t|z }d|cxkr|kr |S|j|}|rB|Srurvrws rHr{zKnownLengthRFile.readlinesr|r'c8|jjyr~rrcs rHrzKnownLengthRFile.closerr'c|SrrKrcs rHrzKnownLengthRFile.__iter__rr'clt|j}|xjt|zc_|Sr)rrArrhrs rHrzKnownLengthRFile.__next__s'DJJ #d)# r'rOr) rQrRrSrTr`rgr2r{rrrrrKr'rHrrxs1 ( ((* Dr'rcBeZdZdZd dZdZd dZd dZd dZdZ d Z y) 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 c`||_||_d|_t|_||_d|_y)z!Initialize ChunkedRFile instance.rFN)rAr^r_rrbufferbufsizeclosed)r@rAr^rs rHr`zChunkedRFile.__init__s,     r'cj|jry|jj}|xjt |z c_|j r9|j|j kDr t jd|j |jjtd} |jd}t|d}|dkrd|_y|j r'|j|z|j kDr td|jj|}|xjt |z c_|xj |z c_|jjd}|t"k7rtdt%|zd zy#t$rtdwxYw) 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._fetchsu ;; zz""$ 3t9$ ;;4??T[[8((*   zz|!!)Q/ !JZ,J ?DK  ;;4??Z7$++E45 5  + 3u:% u zzq! 4<d$&)*  ' -j^<  s 0FF2Nc:t}|dk(r|S |rt||k\r|S|js|j|js|S|r5|t|z }||jd|z }|j|d|_n||jz }t|_)rfrN)rrrhrr)r@rjrkrs rHrgzChunkedRFile.reads 19KD T) ;; {{K 3t9,  JY//"kk)*5  ## !r'cZt}|dk(r|S |rt||k\r|S|js|j|js|S|jj t }|ry|dk(r5|t|z }||jd|z }|j|d|_nt |t|z |}||jd|z }|j|d|_nF|dk(r||jz }t|_n&||jd|z }|j|d|_)rmrroN)rrrhrrfindrqr)r@rjrk newline_posrs rHr2zChunkedRFile.readline2s  19KD T) ;; {{K++**2.K"$ $s4y 0IDKK 33D"&++ij"9DK #D3t9$4k BIDKK 33D"&++ij"9DK" ##  L[11"kk+,7 3r'cd}g}|j|}|rB|j||t|z }d|cxkr|kr |S|j|}|rB|Srurvrws rHr{zChunkedRFile.readlines[r|r'c#K|js td |jj}|s td|xjt |z c_|j r$|j|j kDr td|tk(ry|jts td|w)zhRead HTTP headers and yield them. :yields: CRLF separated lines :ytype: bytes z:Cannot read trailers until the request body has been read.r0rr1N) rr3rAr2r_rhr^rr4r5)r@rDs rHread_trailer_lineszChunkedRFile.read_trailer_linesps{{L ::&&(D !:;; OOs4y (O{{t<899t|==& !ABBJ!sB=B?c8|jjyr~rrcs rHrzChunkedRFile.closerr')i rOr) rQrRrSrTr`rrgr2r{rrrKr'rHr r s- )V$@'8R*<r'r ceZdZdZdZ dZ iZ gZ dZ dZ dZ e Z d dZ dZdZdZdZdd Zd Zd Zd Zy)rzrAn HTTP Request (and response). A single HTTP connection may consist of multiple request/response pairs. NFc`||_||_d|_d|_d|_|jj d|_d|_i|_d|_g|_ d|_ |jj|_ d|_ |jj|_||_||_y)aInitialize HTTP request container instance. Args: server (HTTPServer): web server object receiving this request conn (HTTPConnection): HTTP connection object for this request proxy_mode (bool): whether this HTTPServer should behave as a PROXY server for certain requests strict_mode (bool): whether we should return a 400 Bad Request when we encounter a request that a HTTP compliant client should not be making FshttpNshttpszHTTP/1.0r)serverconnreadystarted_requestscheme ssl_adapterresponse_protocol inheadersstatus outheaders sent_headersrZclose_connection chunked_read chunked_write proxy_mode strict_mode)r@rrrrs rHr`zHTTPRequest.__init__s   $ ;; " " ."DK!+ ! $ ? ?!!^^99$&r'ct|jj|jj|_ |j }|sy |j}|syd|_ y#t j$r|jddYywxYw#t j$r|jddYywxYw)z;Parse the next HTTP request start-line and message-headers.Nz414 Request-URI Too LongzHThe Request-URI sent with the request exceeds the maximum allowed bytes.413 Request Entity Too LargezCThe headers sent with the request exceed the maximum allowed bytes.T) rrrArmax_request_header_sizeread_request_linerrbsimple_responseread_request_headersr)r@successs rH parse_requestzHTTPRequest.parse_requests% IIOO KK / /   ,,.G //1G 1%%   *!    %%   .!    s#A*B*%BB%B=<B=c |jj}d|_|sy|tk(r|jj}|sy|j ts|j ddy |j jtd\}}}|jds|j ddy|dd jd d }t|dk7r|j dd yttt|}|d kDr|j ddy ||_|j#|_|j&r$||j$k7rd}|j d|y t(j*j-|\}}} } } |xs|} |j$dk(r|j0r| r|n| } n|j$dk(r|j0s|j dyt(j*j-dj3d|f} | \}}}}}t4}t7j8t5| j:}d d d ||k7xs| xst=||||f}|r|j ddy|x}} t4x}x} } n|j&xr|j0 xr| }|r |j ddy|j&xr|jt> xr| }|r d}|j d|y| r|j ddy| |j ddy t@j| Dcgc]!}t(j*jC|#}}tFj3|} | jt>s t>| z} |t4ur||_$||_%| |_&| |_'t|jPjRdt|jPjRdf}|d|dk7r|j dy||_*dtW||z|_,y#ttf$r|j ddYywxYw#t.$r|j ddYywxYw#1swYExYwcc}w#t$r)}|j d|jDdYd }~yd }~wwxYw) 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.rz HTTP/%s.%s)-rAr2rr4r5rr8r9r6 startswithrhtuplemaprr3 IndexErroruriuppermethodrurllibparseurlsplit UnicodeErrorrr?rr contextlibsuppressportany FORWARD_SLASHQUOTED_SLASH_REGEXunquote_to_bytesargs QUOTED_SLASHr authoritypathqsrprotocolrequest_protocolrr)r@ request_linerr req_protocolrpresprrrrfragmenturi_is_absolute_form uri_split_scheme _authority_path_qs _fragment_port invalid_pathdisallowed_absolutexatomsexsps rHrzHTTPRequest.read_request_lines&zz**,  $ 4   ::..0L$$T*  !0  (4(:(:(<(B(B5!(L %FC**84$$%:ab!''a0B2w!|$$%9s3|$BF{$$4, lln   $++ 5A   !2D 9 4:LL4I4I#4N 1FItR &2 ;;* $ OO(<  [[J &??$$%=> --chhs|.DEI9B 6GZYE$$Z0 '! 'c!999Y78  $$%8 ) )I%* *F *R(  )')( #C$$%H  -}55-,,  >2 $$%6=$$%7|$$%2  055d;LL11!4 $$U+D}- 4'D   DK" %%a( )3t{{/C/CA/F+G G a5BqE>  !A B ,!-B !;OJ'   !24L M &   !24K L 2 ' 'b $$%6 C sg4A Q5Q60Q5%Q6 R<R)&R$9R)!Q32Q36RRR!$R)) S2SSc` |j|j|j|j j} t|jjdd}|r||kDr|j ddy|jd k(r'|jjd d d k(r.d |_ n&|jjd d dk7rd |_ d}|jd k(rh|jjd}|rK|jdDcgc]1}|js|jj3}}d|_|r-|D](}|dk(rd |_|j dd |_ y|jjdd dk(rld j!|j j"j%dt&dt(t(f} |j*j,j/|y y #t$r)}|j d|j dYd}~yd}~wwxYw#t$r|j ddYywxYwcc}w#t0j2$r*}|j dt4j6vrYd}~y d}~wwxYw)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,,chunkedz501 Unimplementedr+s 100-continueasciis 100 Continue) header_readerrArr3rrrmax_request_body_sizerr>rrr9r8lowerrr?rencoder6r4rwfilewritesocketerrorrsocket_errors_to_ignore)r@rmrbsclterencmsgs rHrz HTTPRequest.read_request_headerssv    tzz4>> : {{00 T^^''(91=>B BI  .!    ! !Z /~~!!-5A(,% ^^   s 3} D$(D !  ! !Z /##$89B13$MA1779aggioo'MM!  !*$(,D%(()<=,0D)  !6 >>  i - @((KK((//8# C  %%c*o   !2BGGAJ ?    !2   :N^<< 771:V%C%CCD sL&H%I I+1 I+.%I0 III I('I(0J- J((J-cf|jj}|jr&t|jj ||_npt |jjdd}|r$||kr|js|jddyt|jj ||_|jj|j|jxr|j|j r&|jj"j%dyy)z/Call the gateway and write its iterable output.rrrrNs0 )rrrr rrArrr>rrrgatewayrespondrensure_headers_sentrr r )r@rrs rHrzHTTPRequest.respondEs{{00   %diiootBr ((((61 )$))//2>DJ D!))+ 1t//1    IIOO ! !, / r'ct|}|jjd|d}dt|z}d}|j d|j d|j dg}|dddvr*d |_|j d k(r|jd nd }|jt|r2t|tr|j d}|j| |jjjtj|y#tj $r*}|j"d t$j&vrYd}~yd}~wwxYw)z+Write a simple response back to the client. z zContent-Length: %s zContent-Type: text/plain ISO-8859-1N>413414TrsConnection: close rr)strrrrhr rrrpr4 isinstancerr r rrr?r r rrr)r@rr proto_statusr content_typebufrs rHrzHTTPRequest.simple_response\s'V&*kk&:&:FC 1CH<5    -  ! !, /    -  "1: '$(D !%%3 34+ 4 #s#jj. JJsO  IIOO ! !%**S/ 2|| wwqz!?!??@ s%8DE1 EEcL|jsd|_|jyy)z:Ensure headers are sent to the client if not already sent.TN)r send_headersrcs rHrzHTTPRequest.ensure_headers_sents$  $D     !r'cD|jro|rmtt|ddjd}|t|tg}|j j jtj|y|j j j|y)z$Write unbuffered data to the client.rNr) rhexrhr r4rr r rrr?)r@rchunk_size_hexr"s rHr zHTTPRequest.writesn   % U_QR077@N!45C IIOO ! !%**S/ 2 IIOO ! !% (r'c||jDcgc]\}}|j}}}t|jdd}|dk(rd|_nZd|vrV|dks|dvrnL|j dk(xr|j d k7}|r#d|_|jjd nd|_|js|jj}| |_d |vr^|j dk(r(|jrC|jjd n'|js|jjd d |jvrC|jjdd|jjjdf|jsC|js7t|jdd}|dkDr|jj!|d|vrJ|jjdt"j$j'djdfd|vr@|jjd|jj(jdf|jj*jd}|t,z|jzt.zg} |jD].\} } | j| t0zt,z| zt.z0| jt.|j2j4j7t8j;| ycc}}w)zAssert, process, and send the HTTP response message-headers. You must set ``self.status``, and :py:attr:`self.outheaders ` before calling this. NriTscontent-length>0rsHEAD)r,rs connection)r*r)r*rrztimeout=rrrsdatesDate)usegmtsserversServerr)rrrrrrrrrprcan_add_keepalive_connectiontimeoutr rgetattrrArgemailutils formatdate server_namerr6r4r:rr r rrr?) r@keyvaluehkeysr needs_chunkedcan_keeprprotor"rFrEs rHr$zHTTPRequest.send_headerss 04?e??T[[!_% S=$(D ! e +|v8**j8/ w.!)-D&OO**+MN-1D)$${{??H(0LD !  %%%3((OO**+DE**&&'EF )T__ < OO " "!t{{2234;;LI %%0A0A  K;I1}  * %  OO " "KK**$*7>>|L  E ! OO " "KK++22<@  $$++G4u}t{{*T12OO 5DAq JJq5y5(1,t3 4 5 4 ejjo.m@sL8)FT)r)rQrRrSrTrrrrrrrrrr`rrrrrrr r$rKr'rHrrs F@ DDI$J; E@M<!NM'B DcJbH0.#J )\/r'rceZdZdZdZdZdZejZ ejZ e Z dZ dZdZefdZdZdZdZdZdZd Zed Zed Zed Zd ZedZedZdZy)rz#An HTTP connection (active socket).NFc||_||_||d|j|_||d|j|_d|_|jj|_|jj|_td|j|_ td|j|_ y)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) rr rbufsizerAwbufsizer  requests_seenpeercreds_enabledpeercreds_resolve_enabledrresolve_peer_credsget_peer_creds)r@rsockmakefiles rHr`zHTTPConnection.__init__s  dD$--8 dD$--8 !%!>!>)-)N)N&#7)A"6t7N7N"O2i243F3FGr'cd} |j|j|}|j|jjdr|xjdz c_|j syd}|j |jsy y#tj$r}|jd}d}||vr#|rr{|jro|jdn\|tjvrJ|jjdt!|zt"j$d |jd Yd }~yd }~wt&t(f$rtj*$rYytj,$r|j/Yyt0$rQ}|jjt!|t"j2d |jd Yd }~yd }~wwxYw) 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)RequestHandlerClassrrstatsrBrrrr r rr_conditional_errorrr error_logrloggingWARNINGKeyboardInterrupt SystemExit FatalSSLAlert NoSSLError_handle_no_ssl ExceptionERROR)r@ request_seenreqrerrnum timeout_errss rH communicatezHTTPConnection.communicates  - F**4;;=C    {{  +""a'"99L KKM''(B?|| JWWQZFFL% %##2E2E++C1FGv=== %%%V 4!//"& ''-HI":.  ##     %    $ F KK ! !Rmm "   # #C)D E E Fs8A&B +B GBD88%G#GG AGGc|r |jry |jj}t |d|j |_d}|jd|d|_ y#t$r|jj}YYwxYw)Nr>zUThe client sent a plain HTTP request, but this server only speaks HTTPS on this port.rT) rr _sockAttributeError_socketr rAr rlinger)r@r\ resp_sockrs rHrXzHTTPConnection._handle_no_sslMs~c&&  , ))I")T4==A  :  -s3  , ++I ,sABBc|r |jry |j|y#tj$rYytj$r|j |YywxYw)zvRespond with an error. Don't bother writing if a response has already started being written. N)rrrrVrWrX)r@r\responses rHrPz!HTTPConnection._conditional_error^sY c&&  %    )##     %    $ %s#A#AAc|jj|js+|j|jjyy)z,Close the socket underlying this connection.N)rArrd_close_kernel_socketr rcs rHrzHTTPConnection.closens< {{  % % ' KK    r'cd}ts'|jjtjk7r t d|j s t d |jjtjtjtj|}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_WINDOWSr familyAF_UNIXNotImplementedErrorrC RuntimeError getsockopt SOL_SOCKETrstructcalcsizeunpackr )r@PEERCRED_STRUCT_DEF peer_credspiduidgid socket_errs rHrFzHTTPConnection.get_peer_credss# ++v~~=%G %%B  !//!!"" 34 J"#MM*=zJMCcS= || / J . /sA B>>CCCc.|j\}}}|S)z,Return the id of the connected peer process.rF)r@rxrWs rHpeer_pidzHTTPConnection.peer_pids'') Q r'c.|j\}}}|S)z1Return the user id of the connected peer process.r})r@rWrys rHpeer_uidzHTTPConnection.peer_uids'') 3 r'c.|j\}}}|S)z2Return the group id of the connected peer process.r})r@rWrzs rHpeer_gidzHTTPConnection.peer_gids'') 1c r'cts td|js tdt j |j j}tj|jj}||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_RESOLVABLErorDrppwdgetpwuidrpw_namegrpgetgrgidrgr_name)r@usergroups rHrEz!HTTPConnection.resolve_peer_credssp%%6  --? ||DMM*22 T]]+33U{r'c,|j\}}|S)z2Return the username of the connected peer process.rE)r@rrWs rH peer_userzHTTPConnection.peer_users))+a r'c,|j\}}|S)z/Return the group of the connected peer process.r)r@rWrs rH peer_groupzHTTPConnection.peer_groups**,5 r'c*t|jd|jj} |tjy#tj $rYytj $r'}|jtjvrYd}~yd}~wwxYw)z0Terminate the connection at the transport level. sock_shutdownN) r0r shutdown SHUT_RDWRr#acceptable_sock_shutdown_exceptionsr errno$acceptable_sock_shutdown_error_codes)r@res rHriz#HTTPConnection._close_kernel_socketsx KK  KK     V%% &99  || wwfIIIJ sABB+B  B) rQrRrSrT remote_addr remote_portssl_envioDEFAULT_BUFFER_SIZEr@rArrNrCrD last_usedr r`r_rdrXrPrrFpropertyr~rrrErrrirKr'rHrrs-KKG%%H%%H% %I.6H.4lF"% &*!X   0  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 Zd ZdZdZ e!dZ"e"jFdZ"dZ$dZ%dZ&dZ'dZ(e)jTdZ+e!dZ,dZ-d'dZ.d(dZ/dZ0e1dZ2e3 d)dZ4e1dZ5e1d Z6d!Z7e!d"Z8e!d#Z9e8jFd$Z8d%Z:y)*rzAn HTTP server.z 127.0.0.1Nrr g?zCheroot/FrTc ||_||_tj||xsd||_|s |j }||_||_|xr||_||_ |jtj|_ y)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 ThreadPoolrequestsversionr4rCrD reuse_port clear_statsqueueQueue_unservicable_conns) r@rr minthreads maxthreadsr4rCrDrs rHr`zHTTPServer.__init__Us.# "-- a  ,,K&!2 % ;*; &% #(;;= r'cd_d_idddfddfdd dd fd d fd dfddfddddddddddddddddi_jtjd t z<y)!zReset server stat counters..NrrJFz Bind Addressc.tjSrO)rrsr@s rHz(HTTPServer.clear_stats..sd4>>&:r'zRun timec<|d xrdxsjS)NrJroruntimers rHrz(HTTPServer.clear_stats..s$) $4#<"#||~r'Acceptsz Accepts/secc0|djz S)Nrrrs rHrz(HTTPServer.clear_stats..sQy\DLLN%Br'rc2tjddS)Nqsizer0rrs rHrz(HTTPServer.clear_stats..swt}}gtDr'ThreadscDttjdgS)N_threads)rhr0rrs rHrz(HTTPServer.clear_stats..sWT]]J%K!Lr'z Threads Idlec2tjddS)Nidlerrs rHrz(HTTPServer.clear_stats..sgdmmVT&Jr'z Socket ErrorsRequestscb|d xrdxs$td|djDdS)NrJroc32K|]}|d|yw)rNrK.0ws rH z;HTTPServer.clear_stats....sHa:q!HWorker Threadsrsumvaluesrs rHrz(HTTPServer.clear_stats..s<) $4#<"#H1-=+>+E+E+GHr' Bytes Readcb|d xrdxs$td|djDdS)NrJroc32K|]}|d|yw)rNrKrs rHrz;HTTPServer.clear_stats....sJ<#Jrrrrrs rHrz(HTTPServer.clear_stats..s<!I,&6%>B%JQ/?-@-G-G-IJr' Bytes Writtencb|d xrdxs$td|djDdS)NrJroc32K|]}|d|yw)rNrKrs rHrz;HTTPServer.clear_stats....sM1#?#A&Mrrrrrs rHrz(HTTPServer.clear_stats..s<Qy\)9(Ar(M2B0C0J0J0LMr' Work Timecb|d xrdxs$td|djDdS)NrJroc32K|]}|d|yw)rNrKrs rHrz;HTTPServer.clear_stats....sIq;"Irrrrrs rHrz(HTTPServer.clear_stats..s<9%5$=2$IA.>,?,F,F,HIr'zRead Throughputcb|d xrdxs$td|djDdS)NrJroc3RK|]}|d||d|xsdz !yw)rrư>NrKrs rHrz;HTTPServer.clear_stats....s8$AlOA&.!K.*;*CtD%'rrrrs rHrz(HTTPServer.clear_stats..sCq|+;*C*/0779 r'zWrite Throughputcb|d xrdxs$td|djDdS)NrJroc3RK|]}|d||d|xsdz !yw)rrrNrKrs rHrz;HTTPServer.clear_stats....s9'Ao&q)^Q{^A->-F$Grrrrrs rHrz(HTTPServer.clear_stats..sC) ,<+D"+/0779 r'rzCheroot HTTPServer %d) _start_time _run_timerOrRr-idrcs`rHrzHTTPServer.clear_statss0 u0 :0  0 q 0 B 0  D0  L0  J0  Q0  0 !0 * +0 4 50 >  ?0 N !O0 ^ b_0  bBF2RX=>r'c|j |jS|jtj|jz zS)zReturn server uptime.)rrtimercs rHrzHTTPServer.runtimes8    #>> !~~t/?/?!?@@r'ch|jd|jjd|jdS)z1Render Server instance representing bind address..(r)rRrZrQrrcs rH__str__zHTTPServer.__str__s) OO NN # # NN  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_addrs4r'cVt|tr|ddvr td||_y)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)rrr3r)r@r6s rHrzHTTPServer.bind_addrs6 eU #aJ(>6   r'c |jy#t$r}|j}|s||_||d}~wt$r}|j}|s||_||d}~wwxYw)z4Run the server forever, and stop it cleanly on exit.N)startrT interruptrU)r@ kb_intr_excunderlying_interrupt sys_exit_excs rH safe_startzHTTPServer.safe_startsc 9 JJL  8#'>> '!,#7 7 9#'>> '!-$8 8  9s A4 AAAcd|_|jd|jz|_d|_d}t j ddr9tj dtjtj|_nt|jttfr |j|jnx|j\}} tj||tj tjd tj"}|D]}|\} } } } } |j)| | | n|jstj||jj-d |jj/|j0t3j4||_|j8j;d|_t?j>|_ y#tj$r0}|d|jd|d}tj||d}~wwxYw#tj$$rOtj}|j}d |vrtj&}|d z}|tjd d |fg}YwxYw#tj$rC}|d| d|d}|jr|jj+d|_Yd}~d}~wwxYw)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_PIDrz -- (z: rr:)rrrrT)! _interruptsoftwarerr osgetenvfromfdAF_INET SOCK_STREAMrrrbytesbind_unix_socketr  getaddrinfo AF_UNSPEC AI_PASSIVEgaierrorrbindr settimeoutlistenrequest_queue_sizerConnectionManager _connectionsrrrrr)r@rserrhostrinfo sock_typerrsafsocktyper: _canonnamesas rHpreparezHTTPServer.prepares^  == '$,,6DM * 99\4 ( --6>>6;M;MNDK e 5 2%%dnn5JD$ K))$$&&%% $ '693HeZ'IIb(E2 '{{,,s# # q! 4223(99$?  99;i<< 2*-t~~tDll3'T1 2"?? K"NN  NN $; &I )F 2I"F$6$62yIJ K||'.12t+H))H.1AJJK,)8K''K,c|jrf|jj}|turyt ||} |j dd|_|j!|jreyy#t tjf$rYt$r?}|jjt|tjdYd}~d}~wwxYw)z(Serve connections we can't handle a 503.Nz503 Service UnavailableTrK)rrr>_STOPPING_FOR_INTERRUPTrrOSErrorrrVrYrrQrrRrZrdr)r@rrequestrs rH_serve_unservicablezHTTPServer._serve_unservicableQsjj++//1D..!$-G ''(ABDK JJL+jjV112   %%H!--"&  sA44CC5CCc4tj|jj|jrK|j s? |j j|j|jr |j s?|j rG|jr"t!j"d|jr"|j r |j yy#ttf$rt$r%|jdtjdYwxYw)z1Serve requests, after invoking :func:`prepare()`.targetzError in HTTPServer.serveTrKg?N) threadingThreadrrrrrrunexpiration_intervalrTrUrYrQrRrZ_stopping_for_interruptrsleeprcs rHservezHTTPServer.servejs  8 89??Ajj !!%%d&>&>?jj >>.. 3..~~nn$ &z2  /!--" s%C:DDcD|j|jy)zmRun the server forever. It is shortcut for invoking :func:`prepare()` then :func:`serve()`. N)rrrcs rHrzHTTPServer.starts  r'c#K|jtj|j}d|_|j  ||j y#|j wxYww)z4Context manager for running this server in a thread.rTN)rrrrdaemonrstop)r@threads rH_run_in_threadzHTTPServer._run_in_threadsQ !!4   L IIKDIIKsAA5 A A5 A22A5cJ|jxr|jjS)z>Flag whether it is allowed to add a new keep-alive connection.)rrr.rcs rHr.z'HTTPServer.can_add_keepalive_connectionszzLd//LLLr'ct|jr|jj|y|jy)z7Put an idle connection back into the ConnectionManager.N)rrputrr@rs rHput_connzHTTPServer.put_conns( ::    ! !$ ' JJLr'c,tjj|dtjj|rRt j }tjj|tjjyy)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)sysstderrr flush traceback_ format_exc)r@rrLrMtbliness rHrQzHTTPServer.error_logsd C7"&   ++-G JJ  W % JJ    r'c |j|j||||j|j|j}|j ||jx}|_|j||_|S)z.Create (or recreate) the actual socket object.)prepare_socketrnodelayrr bind_socketr resolve_real_bind_addr)r@rmtyper:rGs rHrzHTTPServer.bindso"" NN    LL    OO "--dDNNCCt{44T: r'c tr tdd} tj|j|j|tjtjd|j|j|j } tj|j!|d } |j#||}|j)|} |s tj*||d }|s!|j1d t2j4||_||_ |S#t $rYt $r}t|}d|vrYd}~d}~wt$r#}t|}d|vr d|vrd|vrYd}~Ad}~wwxYw#t $rd }YwxYw#tj$$r|j'wxYw#t,$rtj.||d YwxYw#t $rYwxYw)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)rrmr7r:r4rrTF)follow_symlinksz(Failed to set socket fs mode permissions)rL)rlr3runlinkrr TypeErrorrr3r rnrr4rrfchmodfilenor5r rr6lchmodrbchmodrQrRrS)r@rfs_permissionstyp_errerr_msgval_errrG FS_PERMS_SETs rHrzHTTPServer.bind_unix_sockets  B   IIdnn %,"">>##LL((#  ! B IIdkkm^ 4L ##D)4D //5   COIIi8 $  NN:oo   #  E   'lG9@GHH 'lG9H(7F 2 ! L ! ||  JJL  &OHHYNO   s}D#'E>0FGF7.G# E;.E;6E  E;E66E;> F  F %F47!GGGG G*)G*c&|dd\}}|dk(}|jtjtjhvr t d|r t dt tdr0|j tjtjdyt tdr0|j tjtjdytr0|j tjtjdytd) NrrzCannot reuse a non-IP socketz"Cannot reuse an ephemeral port (0)SO_REUSEPORT_LBr SO_REUSEPORTz,Current platform does not support port reuse) rmr rrr3hasattr setsockoptrrrFrGrl SO_REUSEADDRro)socket_r_hostrIS_EPHEMERAL_PORTs rH_make_socket_reusablez HTTPServer._make_socket_reusable!sm t AI >>&..&//!B B;< < AB B 6, -   v00&2H2H! L V^ ,   v00&2E2Eq I    v00&2E2Eq I%> r'ctj|||}tj||dd\} } | dk(} |r|j||ts2| s0 |j tj tjd|rEt|ttfs/|j tjtjd||j|}ttdxr|tjk(xr| dv} | rbt!j"t$tj&5|j tj(tj*dddd|S|S#1swY|SxYw)z%Create and prepare the socket object.NrrrKrrr>::::0 ::0.0.0.0)r rprevent_socket_inheritancerNrlrIrrrJrrr IPPROTO_TCP TCP_NODELAYrrHrrrrbr rr) clsrrmr7r:r4rrrGrrrMlistening_ipv6s rHr3zHTTPServer.prepare_socket;sL}}VT51..t4r] d AI   % %di % H/  OOF--v/B/BA F :i#u> OOF..0B0BA F  "##D)D FJ ' 3&//) 322  $$^V\\B ''&&  t   s 60E22E<c(|j||S)z#Bind the socket to given interface.)rrPs rHr5zHTTPServer.bind_socketvs  Yr'c|j}|jtjtjhvr |ddSt |t r t|}|S)z/Retrieve actual bind address from bound socket.Nr) getsocknamermr rrrrr rPs rHr6z!HTTPServer.resolve_real_bind_addr|s] '') >> NN OO   Ra= i 'YIr'c |jj|y#tj$r|jj|YywxYw)z#Process an incoming HTTPConnection.N)rr'rFullrr(s rH process_connzHTTPServer.process_conns@ / MM  d #zz /  $ $ ( ( . /s.AAc|jS)zFlag interrupt of the server.)rrcs rHrzHTTPServer.interruptsr'c&|jtuS)z8Return whether the server is responding to an interrupt.)rrrcs rHrz"HTTPServer._stopping_for_interrupts"999r'ct|_t|tr|j dt|t r|j d|j ||_y)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)rrrrTrQrUr")r@rs rHrzHTTPServer.interruptsJ2 i!2 3 NN> ? i , NN= > #r'cr|jsyd|_|jjt|j4|xj t j |jz z c_d|_|jjt|dd}|rt|jttfs |jdd\}}tj ||tj"tj$D]X}|\}}}}} d} tj|||} | j'd| j)||f| j+Z t5|dr|j+d|_|jj+|j6j|j8y#tj,$r| r| j+YwxYw#tj,$r*} | j.dt0j2vrYd} ~ d} ~ wwxYw)z5Gracefully shutdown a server that is serving forever.NFr rg?rr)rrr'rrrrrr"r0rrrrr[r rrrrconnectrr rrrrHrshutdown_timeout) r@rGrrrsr r r:r _sarrs rHr"zHTTPServer.stopszz     $$%<=    ' NNdiikD,<,<< Process the current request. Must be overridden in a subclass.)rorcs rHrzGateway.responds!!r'N)rQrRrSrTr`rrKr'rHrrsN"r'rz%cheroot.ssl.builtin.BuiltinSSLAdapterz&cheroot.ssl.pyopenssl.pyOpenSSLAdapter)builtin pyopensslct|j}t|trJ|j d}||dzd}|d|} t j |}|t t||}|S|S#t$r"t|ttdg}Y;wxYw#t$rtd|d|dwxYw)z/Return an SSL adapter class for the given name.rrNr'z' object has no attribute ') ssl_adaptersrrrrfindr,modulesKeyError __import__globalslocalsr0rb)nameadapterlast_dot attr_namemod_pathmods rHrr s4::<(G'3==%HqLN+ 9H% B++h'C{ c9-G N7N BXwy&(RDAC B  7?K  sA4$ B"4(BB"B>)rp)KrTr email.utilsr1rrRrplatformrrer r,rrrMr/ urllib.parser functoolsrrrrr_compatrr rHr r workersr __all__systemrlrrIS_GAErrr ImportErrorrsrHrrrrqr4r7r6r:rrrASTERISKrrcompiler?rrYrr=r-rrrrr rrrrrtrrKr'rHrs<AF    ..!, X__ ) + ? $b ) 4 45I J'5v:N 'Cf'&*- 6> *  6= )v}% &2F          RZZ'<)@ AB$+6w %GD(D(N,,^^BWWt~~BY /Y /xCCL| 2| 2~ " "&79 aD  !&Ss'F11 GG