B 5d@sdZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z ddl m Z ddl mZddl mZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZy ddlZWn(ek rGdddZeZYnXdZejdkr.y edWnek r,dZYnXeedZ e rFej!Z!nGdddZ!y ej"Z#Wne$k rxdZ#YnXdZ%ej&ej'dej(e)ej&e)fdfZ*ej+rddl,Z-ddl.m/Z/ddl.m0Z0ddl1m2Z2ddl3m4Z4Gdd d ej5Z6Gd!d"d"eZ7e)e)e)d#d$d%Z8dOej&e)ej(d&d'd(d)Z9dPe)ej&e)ej&e)ej(e)e)fd*d+d,Z:dd-d.d/Z;dQe)ej&e)ej&e<dd0d1d2Z=dRej&e>e?d3d4d5Z@e)eZDGd?d@d@eZEGdAdBdBejFeEZGGdCdDdDe!eEZHdSe)err/)rrFrIr)z wsgi.versionzwsgi.url_schemez wsgi.inputz wsgi.errorszwsgi.multithreadzwsgi.multiprocessz wsgi.run_oncezwerkzeug.socketSERVER_SOFTWAREREQUEST_METHODZ SCRIPT_NAMEZ PATH_INFO QUERY_STRINGZ REQUEST_URIZRAW_URI REMOTE_ADDRZ REMOTE_PORTZ SERVER_NAMEZ SERVER_PORTZSERVER_PROTOCOL-_z ) CONTENT_TYPECONTENT_LENGTHZHTTP_,ZHTTP_TRANSFER_ENCODINGchunkedTzwsgi.input_terminatedz wsgi.inputZ HTTP_HOST) binary_formZSSL_CLIENT_CERTerrorz&Cannot fetch SSL peer certificate info)&r pathrG ssl_contextclient_address isinstancerschemenetlocr r&sysstderr multithread multiprocess connectionrJcommandr queryaddress_string port_integerserver_addressrequest_versionheadersitemsupperreplacegetr1lowerr% getpeercertsslDER_cert_to_PEM_certr2logAttributeError)r request_urlZ url_schemeZ path_infoenvironkeyvalueZ peer_certrrr make_environsh             zWSGIRequestHandler.make_environNc sjdddkr&jd_dddddtddfdd dfd d d dd fd d }y|j j Wnt t j fk r}z|Wdd}~XYntk r}zj jrdk rrd_y dkr$dd|tWntk rFYnXddlm}||}j dd|Wdd}~XYnXdS)NZExpectrIz 100-continuesHTTP/1.1 100 Continue F)datarcsdk stddk s tddkr ydd\}}Wntk rdd}}YnXt|}||t}x*D]"\}}||||qWd|ksddksd|krdksn|d ksj d krd d d dd t |t s td|rvrXj tt|ddj dj |rvj dj dS)Nzwrite() before start_responserrIzcontent-lengthrOHEADd>0zHTTP/1.1TzTransfer-EncodingrW Connectionclosezapplications must write bytess )AssertionErrorsplitr2r0Z send_responsesetZ send_headeraddrpprotocol_versionZ end_headersr]rBwfilewritehexr:encodeflush)r{Zcode_strmsgcodeZ header_keysrxry)chunk_responserw headers_sent headers_setr status_sent status_setrrrsB            z*WSGIRequestHandler.run_wsgi..writecs@|r(zr|d|dWdd}Xn r4td||S)NrrzHeaders already set)with_tracebackr)statusrkexc_info)rrrrrrstart_response1sz3WSGIRequestHandler.run_wsgi..start_responser!)apprc sZ|}z6x|D] }|qWs.dr>jdWdt|drT|XdS)Ns0 r)rrhasattrr)rZapplication_iterr{)rrwrrrrrrexecute?s    z,WSGIRequestHandler.run_wsgi..executeTr)DebugTracebackrYzError on request: )N)rkrorpr1rrrzrwrBrGrConnectionErrorsockettimeoutconnection_dropped Exceptionpassthrough_errorsZclose_connectionr Z debug.tbtoolsrZrender_traceback_textrt)rrr5rrr) rrwrrrrrrrrrun_wsgis<  9    zWSGIRequestHandler.run_wsgic sytWnvttjfk r@}z||Wdd}~XYnFtk r}z(|jjdk rrt |rr| d|nWdd}~XYnXdS)z/Handles a request ignoring dropped connections.NzSSL error occurred: %s) superhandlerrrrrrGr[ is_ssl_error log_error)rr5) __class__rrrfszWSGIRequestHandler.handle)rYrwrcCsdS)z`Called if the connection was closed by the client. By default nothing happens. Nr)rrYrwrrrrrsz%WSGIRequestHandler.connection_dropped)rrcs|dr|jStt|S)NZdo_) startswithrgetattrr)rr)rrrrys zWSGIRequestHandler.__getattr__cCs*t|ddr|jdS|js dS|jdS)NrwrQzr)rrwr\)rrrrrgs   z!WSGIRequestHandler.address_stringcCs |jdS)Nr)r\)rrrrrhszWSGIRequestHandler.port_integerrR)rsizercCsy&t|j}|jd|d|j}Wntk r@|j}YnXt|}|ddkrbt|d}np|dkrlnf|dkrt|d}nR|ddkrt|d }n:|d krt|d }n&|dd krt|dd }n t|dd}|dd|||dS)N r1boldZ200Z304cyan3greenZ404yellow4redmagentainfoz "%s" %s %s) r rZrerjruZ requestliner _ansi_stylert)rrrrZrrrr log_requests(          zWSGIRequestHandler.log_request)formatargsrcGs|jd|f|dS)NrY)rt)rrrrrrrszWSGIRequestHandler.log_errorcGs|jd|f|dS)Nr)rt)rrrrrr log_messageszWSGIRequestHandler.log_message)typemessagerrcGs.t||d|d|df|dS)Nz - - [z]  )rrgZlog_date_time_string)rrrrrrrrtszWSGIRequestHandler.log)N)rRrR)rrrr@__annotations__propertyrrJrzrr BaseExceptionrOptionalrrrrgr0rhUnionrrrrt __classcell__rr)rrrEs" Ny  rE)rystylesrcGsFts|Sddddddd}x |D]}d||d |}q W|d S) Nr !#$)rrrrrrz[mz)_log_add_style)ryrcodesstylerrrrs r)r$r#)cnrc Cs:y@ddlm}ddlm}ddlm}ddlm}ddlm }Wnt k r^t ddYnX|}|j dd |d }|dkrd }| ||jd ||j|g}|}|||||ttjttjtd dj||j gddj|!|"|gdd#||$|} | |fS)Nr)x509)NameOID)default_backend)hashes)rsaz Sharing.rZadhocT) server_side)/rEvarsrbrcrrr rrraddress_familyrr0rrrrrrZexistsunlinkrr* server_bindserver_activater3 server_closeprintstrerrorr`raerrnoZ EADDRINUSEplatformexitrrfromfdrrrir]tuplerr wrap_socketr[) rrr rrrr[rr$rir5)rrrr*sf                   zBaseWSGIServer.__init__)rrrrcGst||f|dS)N)r)rrrrrrrrtszBaseWSGIServer.log?) poll_intervalrcs<z,ytj|dWntk r(YnXWd|XdS)N)r3)r serve_foreverKeyboardInterruptr))rr3)rrrr4s  zBaseWSGIServer.serve_forever)requestr\rcs|jrt||S)N)rr handle_error)rr6r\)rrrr7szBaseWSGIServer.handle_error)rcCsd}t|dd}|g}|jtkr4|d|jn|jdkrBdnd}|j}|jdkr|d |jd |jd krd }ttj}nd }ttj }|d|d|d|j d|krd|d}|d|d|d|j t dd |dS)z::0.0.0.0z * Running on all addresses ()z0.0.0.0z 127.0.0.1z[::1]z://r []rr) rr$rappendrr[rrr r r rjoin)rZ dev_warningmessagesr^Zdisplay_hostname localhostrrr log_startup s&       zBaseWSGIServer.log_startup)NFNN)r2)rrrr@rbrc LISTEN_QUEUErequest_queue_sizeallow_reuse_addressrr0rrTyperErC_TSSLContextArgr*rrtfloatr4rTupler7rArrr)rrrFs(Z rFc@seZdZdZdZdZdS)ThreadedWSGIServerzA WSGI server that handles concurrent requests in separate threads. Use :func:`make_server` to create a server instance. TN)rrrr@rbdaemon_threadsrrrrrI/srIc sTeZdZdZdZd eedeejej e e eje ejedd fdd Z ZS) ForkingWSGIServerzA WSGI server that handles concurrent requests in separate forked processes. Use :func:`make_server` to create a server instance. T(NFr!) rr r processesrrr[rrc s.ts tdt|||||||||_dS)Nz'Your platform does not support forking.)can_forkr2rr* max_children) rrr rrMrrr[r)rrrr*Cs zForkingWSGIServer.__init__)rLNFNN)rrrr@rcrr0rrrErErCrFr*rrr)rrrK:s*rKr!) rr rthreadedrMrequest_handlerrr[rrc Csd|r|dkrtd|r.t|||||||dS|dkrNt||||||||dSt|||||||dS)a6Create an appropriate WSGI server instance based on the value of ``threaded`` and ``processes``. This is called from :func:`run_simple`, but can be used separately to have access to the server object, such as to run it in a separate thread. See :func:`run_simple` for parameter docs. rz4Cannot have a multi-thread and multi-process server.)r)r2rIrKrF) rr rrPrMrQrr[rrrr make_serverUs" rRcCstjddkS)zqCheck if the server is running as a subprocess within the Werkzeug reloader. .. versionadded:: 0.10 ZWERKZEUG_RUN_MAINtrue)rrwrorrrris_running_from_reloadersrTauto)hostnamer  application use_reloader use_debugger use_evalex extra_filesexclude_patternsreloader_interval reloader_typerPrMrQ static_filesrr[rc Cst|tstd| r,ddlm}||| }|rHddlm}|||d}tsTd}nttj d}t |||| | | |||d }|j d t |tj d<ts|td td d |rdd lm}z||j|||| dWd|Xn|dS)aStart a development server for a WSGI application. Various optional features can be enabled. .. warning:: Do not use the development server when deploying to production. It is intended for use only during local development. It is not designed to be particularly efficient, stable, or secure. :param hostname: The host to bind to, for example ``'localhost'``. Can be a domain, IPv4 or IPv6 address, or file path starting with ``unix://`` for a Unix socket. :param port: The port to bind to, for example ``8080``. Using ``0`` tells the OS to pick a random free port. :param application: The WSGI application to run. :param use_reloader: Use a reloader process to restart the server process when files are changed. :param use_debugger: Use Werkzeug's debugger, which will show formatted tracebacks on unhandled exceptions. :param use_evalex: Make the debugger interactive. A Python terminal can be opened for any frame in the traceback. Some protection is provided by requiring a PIN, but this should never be enabled on a publicly visible server. :param extra_files: The reloader will watch these files for changes in addition to Python modules. For example, watch a configuration file. :param exclude_patterns: The reloader will ignore changes to any files matching these :mod:`fnmatch` patterns. For example, ignore cache files. :param reloader_interval: How often the reloader tries to check for changes. :param reloader_type: The reloader to use. The ``'stat'`` reloader is built in, but may require significant CPU to watch files. The ``'watchdog'`` reloader is much more efficient but requires installing the ``watchdog`` package first. :param threaded: Handle concurrent requests using threads. Cannot be used with ``processes``. :param processes: Handle concurrent requests using up to this number of processes. Cannot be used with ``threaded``. :param request_handler: Use a different :class:`~BaseHTTPServer.BaseHTTPRequestHandler` subclass to handle requests. :param static_files: A dict mapping URL prefixes to directories to serve static files from using :class:`~werkzeug.middleware.SharedDataMiddleware`. :param passthrough_errors: Don't catch unhandled exceptions at the server level, let the serve crash instead. If ``use_debugger`` is enabled, the debugger will still catch such errors. :param ssl_context: Configure TLS to serve over HTTPS. Can be an :class:`ssl.SSLContext` object, a ``(cert_file, key_file)`` tuple to create a typical context, or the string ``'adhoc'`` to generate a temporary self-signed certificate. .. versionchanged:: 2.1 Instructions are shown for dealing with an "address already in use" error. .. versionchanged:: 2.1 Running on ``0.0.0.0`` or ``::`` shows the loopback IP in addition to a real IP. .. versionchanged:: 2.1 The command-line interface was removed. .. versionchanged:: 2.0 Running on ``0.0.0.0`` or ``::`` shows a real IP address that was bound as well as a warning not to run the development server in production. .. versionchanged:: 2.0 The ``exclude_patterns`` parameter was added. .. versionchanged:: 0.15 Bind to a Unix socket by passing a ``hostname`` that starts with ``unix://``. .. versionchanged:: 0.10 Improved the reloader and added support for changing the backend through the ``reloader_type`` parameter. .. versionchanged:: 0.9 A command-line interface was added. .. versionchanged:: 0.8 ``ssl_context`` can be a tuple of paths to the certificate and private key files. .. versionchanged:: 0.6 The ``ssl_context`` parameter was added. .. versionchanged:: 0.5 The ``static_files`` and ``passthrough_errors`` parameters were added. zport must be an integerr)SharedDataMiddleware)DebuggedApplication)ZevalexNZWERKZEUG_SERVER_FD)rTrzPress CTRL+C to quitr)run_with_reloader)r[r\intervalr^)r]r0rZmiddleware.shared_datar`debugrarTrrwrRrset_inheritablerfilenorArrZ _reloaderrbr4r))rVr rWrXrYrZr[r\r]r^rPrMrQr_rr[r`rarZsrvrbrrr run_simplesJp         rg)N)NN)NN)N)FrNFNN) FFTNNrrUFrNNFN)Or@r,iorr socketserverr`typingrrrrrZ http.serverrr _internalrr exceptionsr urlsr r r rrrrrr __import__rrNrr rrurBrrrHrrF TYPE_CHECKINGtyping_extensionsteZ_typeshed.wsgir!r"Z-cryptography.hazmat.primitives.asymmetric.rsar#Zcryptography.x509r$ RawIOBaser%rErrrrr0rrrCr AddressFamilyrrrrFThreadingMixInrIrKrErRrTIterableDictrgrrrr s                   "    >& -* "% ,# p