qi78$SrSSKrSSKrSSKJr SSKJrJr SSKJ r "SS\R5r "S S \R5r "S S \ 5r "S S\ 5r\ R5r"SS5r\"5R'\ \ \\ \S9 g)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) threadpoolc^\rSrSrSrSrSU4Sjjr\S5r\RS5rSr U=r $) Server$z8A subclass of HTTPServer which calls a WSGI application.rrc >[[U] U[URUU U U S9 X lX`lXplXl[R"UU=(d SUU U S9Ul g)a Initialize 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 numthreadsrrrrrrrrrr __class__s A/home/kali/flask_env/lib/python3.13/site-packages/cheroot/wsgi.pyrServer.__init__*stF fd$ !$"3"34#/&?! % ! "4 0"-- a 3#9   c.URR$)zSet minimum number of threads.rrr s r$r"Server.numthreadsas}}   r&c$XRlgNr()r values r$r"r*fs ! r&)rrrrr) Nr.r0r/r.FFF) __name__ __module__ __qualname____firstlineno____doc__rrpropertyr"setter__static_attributes__ __classcell__r#s@r$r r $seBL)  !"'5 n!!""r&r ch^\rSrSrSrU4Sjr\S5rSrSr S Sjr \ S5r S r S rU=r$) Gatewaykz/A base class to interface HTTPServer with WSGI.cr>[[U] U5 SUlUR 5UlSUlg)zbInitialize WSGI Gateway instance with request. Args: req (HTTPRequest): current HTTP request FN)rr<rstarted_response get_environenvremaining_bytes_out)r reqr#s r$rGateway.__init__ns4 gt%c* %##%#' r&cbUR5Vs0sHoRU_M sn$s snf)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_mapGateway.gateway_mapys-*-););)=>)=2 B)=>>>s,c[e);Return a new environ dict targeting the given wsgi.version.)NotImplementedErrorr)s r$r@Gateway.get_environs!!r&cURRRURUR5n[ SU5H4n[ U[5(d [S5eURU5 M6 URR5 [US5(aUR5 gg!URR5 [US5(aUR5 ff=f)azProcess 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) rCrrrAstart_responsefilter isinstancebytes ValueErrorwriteensure_headers_senthasattrrQ)r responsechunks r$respondGateway.responds88??++DHHd6I6IJ !h/!%//$%IJJ 5!0 HH ( ( *x)) * HH ( ( *x)) *s AB==>C;cRUR(aU(d [S5eSUlURR(aUSnUeUR U5URlUHupV[ U[5(d[SU-5e[ U[5(d[SU-5eUR5S:Xa[U5Ul [U5[U54nURRRU5 M UR$)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)r? RuntimeErrorrC sent_headers_encode_statusstatusrTstr TypeErrorlowerintrBr outheadersappendrW)r rbheadersexc_infor-kv out_headers r$rRGateway.start_responses  L !% 88 QKEK--f5DAa%%EIa%%G!Kwwy,,+.q6(a$q')J HH   & &z 2zzr&cd[U[5(d [S5eURS5$)aCast 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)rTrcrdencode)rbs r$raGateway._encode_statuss,&#&&FG G}}\**r&cUR(d [S5e[U5nURnUbBX#:a=URR (dURR SS5 OUSUnURR5 URRU5 UbX2-nUS:a [S5egg)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.) r?r_lenrBrCr`simple_responserXrWrV)r r[chunklenrbos r$rW Gateway.writes $$IJ Ju:&& ?x~88((((//ds  $$& u ? OCQw H r&)rArBr?r,)r1r2r3r4r5r classmethodrJr@r\rR staticmethodrarWr8r9r:s@r$r<r<ksM9 (??"!0!F + +!!r&r<c"\rSrSrSrSrSrSrg) Gateway_10z8A Gateway class to interface HTTPServer with WSGI 1.0.x.r cURnURn0SURR_S[ UR 5_S[ UR 5_SUR=(d S_S[UR=(d S5_S[ UR5_S[ UR5_S S_S URR_S [ UR5_S URR_S [R _SUR"_S[%UR&5_SS_SS_SS_[ UR(5UR*S.En[-URR.[5(aSUS'[UR05US'[UR25US'[UR45US'[UR65US'[UR85US'USUS'O%[URR.S5US'UR=SUR>RA555 URCSS 5nUbXCS!'URCS"S 5nUbXSS#'URRD(a%UR=URRD5 U$![:a Nf=f)$rMACTUAL_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_USERrc3# UHHupSR[U5R5RSS5S9[U54v MJ g7f)zHTTP_{header_name!s}-_) header_nameN)formatrupperreplace).0rkrls r$ )Gateway_10.get_environ...sU . '-- $Q  7 7S A.Q   .sAAHTTP_CONTENT_TYPEN CONTENT_TYPEHTTP_CONTENT_LENGTHCONTENT_LENGTH)#rCconnrprotocolrpathqs remote_addrrc remote_portmethodurirrequest_protocolsoftwaresysstderrrfilebool chunked_readschemerGrTr!peer_pidpeer_uidpeer_gid peer_user peer_groupr_update inheadersitemspopssl_env)r rCreq_connrActcls r$r@Gateway_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 0"$C  &)(*;*;&<N#&)(*;*;&<N#&)(*;*;&<N#'*8+=+='>O$(+H,?,?(@$%%(%9M""%SZZ%9%9!%"$  WW*D 1 >$& ! 88   JJsxx'' ( ?   sBK K+*K+N)r1r2r3r4r5rGr@r8rr&r$r|r|sBGJr&r|c0^\rSrSrSrSrU4SjrSrU=r$) Gateway_u0iFzA 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>URn[[U]5n[ UR 55nUR SS5nURRU5US'URRU5US'URUR 55 U$![a SUS'USUS'USUS'NBf=f)rMzwsgi.url_encodingzutf-8rrrp) rCrrr@dictr setdefaultrdecoderUnicodeDecodeErrorr)r rCenv_10rAencr#s r$r@Gateway_u0.get_environOshhz4466<<>"nn0': 9"xxs3C "%&&--"4C  399; " 9'3C# $%k2C "("8C   9s .by_path_lenvss1v; r&T)keyreverse/) contextlibsuppressAttributeErrorlistrsortrstripapps)r rrpas r$rPathInfoDispatcher.__init__ksr  0 %D1  k4 0599DDAahhsmQ'D9 1 0:sA>B> B c(US=(d SnURHgupEURU<S35(dX4:XdM&UR5nURSS5U-US'U[ U5SUS'U"X5s $ U"SSS/5 S/$) a7Process 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 rrrrNz 404 Not Found)z Content-Typez text/plain)zContent-Length0)r startswithcopygetrt)r environrRrrrs r$__call__PathInfoDispatcher.__call__s{#*siiFA!ay))TY!,,.)0]B)G!)K &'+CFH~ $733    .'  t r&)rN)r1r2r3r4r5rrr8rr&r$rrhs@:(r&r) WSGIServer WSGIGatewayWSGIGateway_u0WSGIGateway_10WSGIPathInfoDispatcher)r5rrrr_compatrrworkersr HTTPServerr r<r|rrJrrglobalsrrr&r$rs6 D"V  D"NFfnnFROOd>##% 66t - r&