U d8@sZdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl mZddl mZddlmZddlmZdd lmZdd lmZd d lmZd d lmZd dlmZd dlmZz ddlZWn*ek r GdddZeZYnXdZ ej!dkrDz e"dWnek rBdZ YnXe#edZ$e$r\ej%Z%nGdddZ%z ej&Z'Wne(k rdZ'YnXdZ)e j*e j+de j,e-e j*e-fe j.dfZ/e j0rddl1m2Z2ddl1m3Z3ddl4m5Z5ddl6m7Z7Gd d!d!ej8Z9Gd"d#d#eZ:d$d$d$d%d&d'Z;d^d(d)d*d+d,Zd`d$d(d4dd5d6d7Z?dad8d9d:d;d<Z@d$d=d>d?d@dAZAd$d=d>dBdCdDdEZBd>d$dFdGdHZCGdIdJdJeZDGdKdLdLejEeDZFGdMdNdNe%eDZGdbd$d=dOd9d=dPd9dQd4dJdR dSdTZHd9d1dUdVZIdcd$d=dOd9d9d9dXdXd=d$d9d=dPdYd9dQdZd[d\d]ZJdS)daA WSGI and HTTP server for use **during development only**. This server is convenient to use, but is not designed to be particularly stable, secure, or efficient. Use a dedicate WSGI server and HTTP server when deploying to production. It provides features like interactive debugging and code reloading. Use ``run_simple`` to start the server. Put this in a ``run.py`` script: .. code-block:: python from myapp import create_app from werkzeug import run_simple ) annotationsN)datetime) timedelta)timezone)BaseHTTPRequestHandler) HTTPServer)unquote)urlsplit_log)_wsgi_encoding_dance)InternalServerError) uri_to_iric@seZdZdddddZdS) _SslDummystrt.AnynamereturncCs tddS)NzUSSL is unavailable because this Python runtime was not compiled with SSL/TLS support.) RuntimeErrorselfrr4/tmp/pip-unpacked-wheel-m99gisyz/werkzeug/serving.py __getattr__*sz_SslDummy.__getattr__N)__name__ __module__ __qualname__rrrrrr)srTntcoloramaFforkc@s eZdZdS) ForkingMixInN)rrrrrrrr"@sr"zssl.SSLContextadhoc)WSGIApplication)WSGIEnvironment)RSAPrivateKeyWithSerialization) Certificatec@sLeZdZdZdddddZddd d Zd dd d Zdd dddZdS)DechunkedInputz8An input stream that handles Transfer-Encoding 'chunked'z t.IO[bytes]None)rfilercCs||_d|_d|_dS)NFr)_rfile_done_len)rr+rrr__init__[szDechunkedInput.__init__boolrcCsdS)NTrrrrrreadable`szDechunkedInput.readableintc Csdz"|jd}t|d}Wn,tk rN}ztd|W5d}~XYnX|dkr`td|S)Nlatin1zInvalid chunk headerrz!Negative chunk length not allowed)r,readlinedecoder4strip ValueErrorOSError)rliner.errrread_chunk_lencszDechunkedInput.read_chunk_len bytearray)bufrcCsd}|js|t|kr|jdkr*||_|jdkr:d|_|jdkrtt||j}||t|kr|jt||||d<|jt||8_t|}n.|j|||||<|j|8_||7}|jdkr|j}|dkrtdq|S)NrT)   z!Missing chunk terminating newline) r-lenr.r>minr,readr7r;)rr@rFn terminatorrrrreadintoms(        zDechunkedInput.readintoN)rrr__doc__r/r3r>rIrrrrr)Xs  r)cseZdZUdZded<eddddZddd d Zd dd d Zd dfdd Z d3ddd dddZ dddfdd Z ddddZ ddddZ edd ed!ed"d#DZd$eed%<d4d'd'd d(d)d*Zddd d+d,d-Zddd d+d.d/Zdddd d0d1d2ZZS)5WSGIRequestHandlerz3A request handler that implements WSGI dispatching.BaseWSGIServerserverrr1cCsddlm}d|S)Nr ) __version__z Werkzeug/)rN)rrNrrrserver_versions z!WSGIRequestHandler.server_versionr&cCst|j}|jjdkrdnd}|js,d|_nt|jtrD|jdf|_|jsd|jrdd|j|j}n|j}t |}d||j t j |jj |jjd|j|j|jdt|t|jt|jt|j|||jjdt|jjd |jd }|jD]h\}}d |krq|d d }|d d}|dkrPd|}||krP||d|}|||<q|dddkrd|d<t|d|d<|jr|jr|j|d<z*|jj dd}|dk rt!"||d<Wn8t#k r|j$ddYnt%k rYnX|S)Nhttphttps)rr/)r rFrOr )z wsgi.versionzwsgi.url_scheme 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_terminatedrUZ HTTP_HOST) binary_formZSSL_CLIENT_CERTerrorz&Cannot fetch SSL peer certificate info)&r pathrM ssl_contextclient_address isinstancerschemenetlocrr+sysstderr multithread multiprocess connectionrPcommandr queryaddress_string port_integerserver_addressrequest_versionheadersitemsupperreplacegetr9lowerr) getpeercertsslDER_cert_to_PEM_certr:logAttributeError)r request_urlZ url_schemeZ path_infoenvironkeyvalueZ peer_certrrr make_environsn             zWSGIRequestHandler.make_environr*c sjdddkr&jd_ddddddddfd d dfd d d ddfdd }z|jj Wnt t j fk r}z |W5d}~XYntk r}zjjrdk rrd_z dkr$dd|tWntk rFYnXddlm}||}jdd|W5d}~XYnXdS)NZExpectrOz 100-continuesHTTP/1.1 100 Continue Fbytesr*)datarcsdk stddk s tddkrzdd\}}Wntk rdd}}YnXt|}||t}D]"\}}||||qd|ksddksd|krdksn|d ksj d krd d d dd t |t std|rrrTj tt|ddj dj |rrj dj dS)Nzwrite() before start_responser rOzcontent-lengthrWHEADd>0HTTP/1.1TzTransfer-Encodingr_ Connectionclosezapplications must write bytesrB)AssertionErrorsplitr:r4Z send_responsesetZ send_headeraddrxprotocol_versionZ end_headersrerwfilewritehexrDencodeflush)rZcode_strmsgcodeZ header_keysrr)chunk_responser headers_sent headers_setr status_sent status_setrrrsR             z*WSGIRequestHandler.run_wsgi..writecs@|r(zr|d|dW5d}Xn r4td||S)Nr rzHeaders already set)with_tracebackr)statusrsexc_info)rrrrrrstart_response6sz3WSGIRequestHandler.run_wsgi..start_responser%)apprc s|}z2|D] }|qs*d r:j d W5t}|jtjd}d}|jddrjd}|t|7}|d7}|r|dks|dkr^qq^| t |dr| XdS) Nrg{Gz?)timeoutir ld( irs0 ) selectorsDefaultSelectorregisterrl EVENT_READselectr+rFrDrhasattrrr)rZapplication_iterselectorZ total_sizeZ total_readsr)rrrrrrrrexecuteDs*      z,WSGIRequestHandler.run_wsgi..executeTr )DebugTracebackrazError on request: )N)rsrwrxr9rrrrrMrConnectionErrorsocketrconnection_dropped Exceptionpassthrough_errorsZclose_connectionrZ debug.tbtoolsrZrender_traceback_textr|)rrr=rrr) rrrrrrrrrrrun_wsgis<  9'   zWSGIRequestHandler.run_wsgic sztWnvttjfk r@}z||W5d}~XYnFtk r}z(|jjdk rrt |rr| d|nW5d}~XYnXdS)z/Handles a request ignoring dropped connections.NzSSL error occurred: %s) superhandlerrrrrrMrc is_ssl_error log_error)rr= __class__rrrszWSGIRequestHandler.handleN BaseExceptionzWSGIEnvironment | None)rarrcCsdS)z`Called if the connection was closed by the client. By default nothing happens. Nr)rrarrrrrsz%WSGIRequestHandler.connection_droppedrrcs|dr|jStt|S)NZdo_) startswithrgetattrrrrrrrs zWSGIRequestHandler.__getattr__cCs*t|ddr|jdS|js dS|jdS)NrrYrSr)rrrdr2rrrros   z!WSGIRequestHandler.address_stringr4cCs |jdS)Nr )rdr2rrrrpszWSGIRequestHandler.port_integercCsi|]}|d|dqS)z\xZ02xr).0crrr szWSGIRequestHandler. z\\\r[z int | str)rsizercCsz&t|j}|jd|d|j}Wntk r@|j}YnX||j}t|}|ddkrnt |d}np|dkrxnf|dkrt |d}nR|ddkrt |d }n:|d krt |d }n&|dd krt |dd }n t |dd}| dd|||dS)N r1boldZ200Z304cyan3greenZ404yellow4redmagentainfoz "%s" %s %s) rrbrmrrr}Z requestline translate_control_char_tabler _ansi_styler|)rrrrbrrrr log_requests*           zWSGIRequestHandler.log_request)formatargsrcGs|jd|f|dS)Nrar|rrrrrrrszWSGIRequestHandler.log_errorcGs|jd|f|dS)Nrrrrrr log_messageszWSGIRequestHandler.log_messagetypemessagerrcGs.t||d|d|df|dS)Nz - - [z]  )r roZlog_date_time_stringrrrrrrrr|s zWSGIRequestHandler.log)N)r[r[)rrrrJ__annotations__propertyrPrrrrrrorpr maketransrangerordrrrr| __classcell__rrrrrKs* Q   rKr)rstylesrcGsBts|Sddddddd}|D]}d||d |}q|d S) Nr r!#$)rrrrrrz[mz)_log_add_style)rrcodesstylerrrrs rz str | Nonez2tuple[Certificate, RSAPrivateKeyWithSerialization])cnrc Cs:z@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.r r$T) server_side)/rKvarsrjrkrrr)rrr.address_familyr;r4r3r&r'rrrbexistsunlinkrr/ server_bindserver_activater; server_closeprintstrerrorrhrierrnoZ EADDRINUSEplatformexitrrfromfdr7r?rqretuplerr  wrap_socketrc) rrr)rrDrrcrErKrqr=rrrr/sr                zBaseWSGIServer.__init__rrcGst||f|dSNr rrrrr|szBaseWSGIServer.log?float) poll_intervalrcs<z,ztj|dWntk r(YnXW5|XdS)N)r\)rPr serve_foreverKeyboardInterrupt)rr\rrrr]"s  zBaseWSGIServer.serve_foreverr/)requestrdrcs|jrt||SrY)rr handle_error)rr_rdrrrr`*szBaseWSGIServer.handle_errorr1cCsd}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 ()rbr<z[::1]r1r*[]rr) rrKr3appendrrcrArr-r+r)r join)rZ dev_warningmessagesrfZdisplay_hostname localhostrrr log_startup2s(       zBaseWSGIServer.log_startup)NFNN)rZ)rrrrJrjrk LISTEN_QUEUErequest_queue_sizeallow_reuse_addressr/r|r]r`rjrrrrrrLs"crLc@seZdZdZdZdZdS)ThreadedWSGIServerzA WSGI server that handles concurrent requests in separate threads. Use :func:`make_server` to create a server instance. TN)rrrrJrjdaemon_threadsrrrrrnUsrnc s<eZdZdZdZdddddd d d d d d fdd ZZS)ForkingWSGIServerzA WSGI server that handles concurrent requests in separate forked processes. Use :func:`make_server` to create a server instance. T(NFrr4r%rBr0rCr!r*) rr)r processesrDrrcrErc s.ts tdt|||||||||_dS)Nz'Your platform does not support forking.)can_forkr:rr/ max_children) rrr)rrrrDrrcrErrrr/is zForkingWSGIServer.__init__)rqNFNN)rrrrJrkr/rrrrrrp`srpr%rBrC) rr)rthreadedrrrequest_handlerrrcrErc 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. r z4Cannot have a multi-thread and multi-process server.rE)r:rnrprL) rr)rrurrrvrrcrErrr make_server{s@  rxcCstjddkS)zqCheck if the server is running as a subprocess within the Werkzeug reloader. .. versionadded:: 0.10 ZWERKZEUG_RUN_MAINtrue)rrrwrrrris_running_from_reloadersrzautozt.Iterable[str] | Nonez'dict[str, str | tuple[str, str]] | Noner*)hostnamer) application use_reloader use_debugger use_evalex extra_filesexclude_patternsreloader_interval reloader_typerurrrv static_filesrrcrc Cst|tstd| r,ddlm}||| }|rHddlm}|||d}tsTd}nttj d}t |||| | | |||d }|j d t |tj d<ts|td td d |rdd lm}z||j|||| dW5|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 server 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_FDrwTrzPress CTRL+C to quitr)run_with_reloader)rrintervalr)rer4rZmiddleware.shared_datardebugrrzrrrxrset_inheritablerfilenorjr rZ _reloaderrrPr])r|r)r}r~rrrrrrrurrrvrrrcrrrEZsrvrrrr run_simplesNp         r)N)NN)NN)N)Fr NFNN) FFTNNr r{Fr NNFN)KrJ __future__rrSiorrr socketserverrhtypingr&rrrrZ http.serverrr urllib.parserr _internalr r exceptionsrurlsrrzrrrr __import__rrsr"r,r3r}rkOptionalUnionTuplerLiteralZ_TSSLContextArg TYPE_CHECKINGZ_typeshed.wsgir%r&Z-cryptography.hazmat.primitives.asymmetric.rsar'Zcryptography.x509r( RawIOBaser)rKrrrr rrr.r;rArLThreadingMixInrnrprxrzrrrrrs                    $    >I/, % "-