#j78*dZddlZddlZddlmZddlmZmZddlm Z GddejZ Gd d ejZ Gd d e Z Gd de Ze jZGddZej'e e ee ey)aThis class holds Cheroot WSGI server implementation. Simplest example on how to use this server:: from cheroot import wsgi def my_crazy_app(environ, start_response): status = '200 OK' response_headers = [('Content-type','text/plain')] start_response(status, response_headers) return [b'Hello world!'] addr = '0.0.0.0', 8070 server = wsgi.Server(addr, my_crazy_app) server.start() The Cheroot WSGI server can serve as many WSGI applications as you want in one instance by using a PathInfoDispatcher:: path_map = { '/': my_crazy_app, '/blog': my_blog_app, } d = wsgi.PathInfoDispatcher(path_map) server = wsgi.Server(addr, d) N)server)btonntob) threadpoolcteZdZdZdZ dfd ZedZejdZxZ S)Serverz8A subclass of HTTPServer which calls a WSGI application.rrctt| |t|j|| | | ||_||_||_||_tj||xsd|| | |_ y)aInitialize WSGI Server instance. Args: bind_addr (tuple): network interface to listen to wsgi_app (callable): WSGI application callable numthreads (int): number of threads for WSGI thread pool server_name (str): web server name to be advertised via Server HTTP header max (int): maximum number of worker threads request_queue_size (int): the 'backlog' arg to socket.listen(); max queued connections timeout (int): the timeout in seconds for accepted connections shutdown_timeout (int): the total time, in seconds, to wait for worker threads to cleanly exit accepted_queue_size (int): maximum number of active requests in queue accepted_queue_timeout (int): timeout for putting request into queue )gateway server_namepeercreds_enabledpeercreds_resolve_enabled reuse_portr)minmaxaccepted_queue_sizeaccepted_queue_timeoutN) superr __init__ wsgi_gateways wsgi_versionwsgi_apprequest_queue_sizetimeoutshutdown_timeoutr ThreadPoolrequests)self bind_addrr numthreadsr rrrrrrrrr __class__s ;/srv/dav/.venv/lib/python3.12/site-packages/cheroot/wsgi.pyrzServer.__init__*s|F fd$ !$"3"34#/&?! % ! "4 0"-- a 3#9   c.|jjS)zSet minimum number of threads.rrrs r#r!zServer.numthreadsas}}   r$c&||j_yNr&)rvalues r#r!zServer.numthreadsfs! r$) Nr+r-r,r+FFF) __name__ __module__ __qualname____doc__rrpropertyr!setter __classcell__r"s@r#r r $seBL)  !"'5 n!!""r$r c\eZdZdZfdZedZdZdZd dZ e dZ dZ xZ S) Gatewayz/A base class to interface HTTPServer with WSGI.crtt| |d|_|j |_d|_y)zzInitialize WSGI Gateway instance with request. Args: req (HTTPRequest): current HTTP request FN)rr7rstarted_response get_environenvremaining_bytes_out)rreqr"s r#rzGateway.__init__ns4 gt%c* %##%#' r$c^|jDcic]}|j|c}Scc}w)zCreate a mapping of gateways and their versions. Returns: dict[tuple[int,int],class]: map of gateway version and corresponding class )__subclasses__version)clsgws r# gateway_mapzGateway.gateway_mapys)*-););)=>2 B>>>s*ct);Return a new environ dict targeting the given wsgi.version.)NotImplementedErrorr's r#r:zGateway.get_environs!!r$c|jjj|j|j} t d|D].}t |ts td|j|0 |jjt|dr|jyy#|jjt|dr|jwwxYw)aProcess the current request. From :pep:`333`: The start_response callable must not actually transmit the response headers. Instead, it must store them for the server or gateway to transmit only after the first iteration of the application return value that yields a NON-EMPTY string, or upon the application's first invocation of the write() callable. Nz"WSGI Applications must yield bytesclose) r=rrr;start_responsefilter isinstancebytes ValueErrorwriteensure_headers_senthasattrrH)rresponsechunks r#respondzGateway.responds88??++DHHd6I6IJ !h/ "!%/$%IJJ 5! " HH ( ( *x) * HH ( ( *x) *s =B229C+c|jr |s tdd|_|jjr|d}||j ||j_|D]\}}t |tstd|zt |tstd|z|jdk(rt||_ t|t|f}|jjj||jS)z)WSGI callable to begin the HTTP response.z:WSGI start_response called a second time with no exc_info.Trz/WSGI response header key %r is not of type str.z1WSGI response header value %r is not of type str.zcontent-length)r9 RuntimeErrorr= sent_headers_encode_statusstatusrKstr TypeErrorlowerintr<r outheadersappendrN)rrXheadersexc_infor*kv out_headers r#rIzGateway.start_responses  L !% 88 QKEK--f5 3DAqa%EIa%G!Kwwy,,+.q6(a$q')J HH   & &z 2 3zzr$cZt|ts td|jdS)a:Cast status to bytes representation of current Python version. According to :pep:`3333`, when using Python 3, the response status and headers must be bytes masquerading as Unicode; that is, they must be of type "str" but are restricted to code points in the "Latin-1" set. z(WSGI response status is not of type str. ISO-8859-1)rKrYrZencode)rXs r#rWzGateway._encode_statuss)&#&FG G}}\**r$cx|js tdt|}|j}|=||kDr8|jj s|jj ddn|d|}|jj|jj||||z}|dkr tdyy)zWSGI callable to write unbuffered data to the client. This method is also used internally by start_response (to write data from the iterable returned by the WSGI application). z(WSGI write called before start_response.Nz500 Internal Server ErrorzLThe requested resource returned more bytes than the declared Content-Length.rz2Response body exceeds the declared Content-Length.) r9rUlenr<r=rVsimple_responserOrNrM)rrRchunklenrbos r#rNz Gateway.writes $$IJ Ju:&& ?x#~88((((//ds  $$& u ? 8OCQw H r$r))r.r/r0r1r classmethodrCr:rSrI staticmethodrWrNr4r5s@r#r7r7ksH9 (??"!0!F + +!r$r7ceZdZdZdZdZy) Gateway_10z8A Gateway class to interface HTTPServer with WSGI 1.0.x.r c|j}|j}id|jjdt |j dt |j d|jxsddt|jxsddt |jdt |jd dd |jjd t |jd |jjd tj d|j"dt%|j&ddddddt |j(|j*d}t-|jj.trd|d< t|j0|d<t|j2|d<t|j4|d<t|j6|d<t|j8|d<|d|d<n%t|jj.d|d<|j=d|j>jAD|jCdd }|||d!<|jCd"d }|||d#<|jjDr%|j=|jjD|S#t:$rYwxYw)$rEACTUAL_SERVER_PROTOCOL PATH_INFO QUERY_STRING REMOTE_ADDR REMOTE_PORTREQUEST_METHOD REQUEST_URI SCRIPT_NAME SERVER_NAMESERVER_PROTOCOLSERVER_SOFTWAREz wsgi.errorsz wsgi.inputzwsgi.input_terminatedzwsgi.multiprocessFzwsgi.multithreadTz wsgi.run_once)zwsgi.url_schemez wsgi.version SERVER_PORT X_REMOTE_PID X_REMOTE_UID X_REMOTE_GID X_REMOTE_USERX_REMOTE_GROUP REMOTE_USERrc3K|]K\}}djt|jjddt|fMyw)zHTTP_{header_name!s}-_) header_nameN)formatrupperreplace).0rarbs r# z)Gateway_10.get_environ...sV 1 '-- $Q  7 7S A.Q   sAAHTTP_CONTENT_TYPEN CONTENT_TYPEHTTP_CONTENT_LENGTHCONTENT_LENGTH)#r=connrprotocolrpathqs remote_addrrY remote_portmethodurir request_protocolsoftwaresysstderrrfilebool chunked_readschemer@rKr peer_pidpeer_uidpeer_gid peer_user peer_grouprUupdate inheadersitemspopssl_env)rr=req_connr;ctcls r#r:zGateway_10.get_environshh88  %cjj&9&9  chh  DL   8//52  3x339r:  d3::.  4=  2  3::11  tC$8$89  szz22 3::! " #))# $ $T#*:*:%;% & ' ( ) * U+ , $CJJ/ LL/ 4 cjj**C 0"$C  &)(*;*;&<N#&)(*;*;&<N#&)(*;*;&<N#'*8+=+='>O$(+H,?,?(@$%%(%9M""%SZZ%9%9!%"$C  WW*D 1 >$&C ! 88   JJsxx'' ( ?   sBK KKN)r.r/r0r1r@r:r$r#rorosBGJr$roc&eZdZdZdZfdZxZS) Gateway_u0zA Gateway class to interface HTTPServer with WSGI u.0. WSGI u.0 is an experimental protocol, which uses Unicode for keys and values in both Python 2 and Python 3. )urc|j}tt|}t |j }|j dd} |jj||d<|jj||d<|j|j |S#t$rd|d<|d|d<|d|d<YAwxYw)rEzwsgi.url_encodingzutf-8rrrsre) r=rrr:dictr setdefaultrdecoderUnicodeDecodeErrorr)rr=env_10r;encr"s r#r:zGateway_u0.get_environOshhz4466<<>"nn0': 9"xxs3C "%&&--"4C  399; " 9'3C# $%k2C "("8C   9s .by_path_lenvss1v; r$T)keyreverse/) contextlibsuppressAttributeErrorlistrsortrstripapps)rrrpas r#rzPathInfoDispatcher.__init__ksw  0 & %D &  k4 0599DAqahhsmQ'9  & &:sA>B >Bc|dxsd}|jD]b\}}|j|ds||k(s |j}|jdd|z|d<|t |d|d<|||cS|dddgdgS) aProcess incoming WSGI request. Ref: :pep:`3333` Args: environ (Mapping): a dict containing WSGI environment variables start_response (callable): function, which sets response status and headers Returns: list[bytes]: iterable containing bytes to be returned in HTTP response body rrrryruNz 404 Not Found)z Content-Typez text/plain)zContent-Length0)r startswithcopygetrh)renvironrIrrrs r#__call__zPathInfoDispatcher.__call__s{#*sii 4FAs!ay)TQY!,,.)0]B)G!)K &'+CFH~ $7N33  4  .'  t r$N)r.r/r0r1rrrr$r#rrhs@:(r$r) WSGIServer WSGIGatewayWSGIGateway_u0WSGIGateway_10WSGIPathInfoDispatcher)r1rrrur_compatrrworkersr HTTPServerr r7rorrCrrglobalsrrr$r#rs6 D"V  D"NFfnnFROOd>##% 66t - r$