o j@s UdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl mZddl mZddlmZddlmZdd lmZdd lmZd d lmZd d lmZd dlmZd dlmZd dlmZzddlZe ej!ej"fZ#de$d<Wne%yGdddZ&e&Ze ej!fZ#YnwdZ'ej(dkrze)dWn e%ydZ'Ynwe*edZ+e+rej,Z,nGdddZ,zej-Z.Wn e/ydZ.YnwdZ0e j1e j2de3e4e j1e4fe j5dfZ6e j7r ddl8m9Z9dd l8m:Z:dd!l;mZ>Gd#d$d$ej?Z@Gd%d&d&eZAdsd+d,ZB dtdud0d1ZC dvdwd5d6ZDdxd7d8ZE dvdyd=d>ZFdtdzdBdCZGd{dGdHZHd|dKdLZId}dMdNZJGdOdPdPeZKGdQdRdRejLeKZMGdSdTdTe,eKZN     d~dd_d`ZOddadbZP      c     dddqdrZQdS)aA 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)parse_set_header) uri_to_iriztuple[type[Exception], ...]connection_dropped_errorsc@seZdZdddZdS) _SslDummynamestrreturnt.AnycCstd)NzUSSL is unavailable because this Python runtime was not compiled with SSL/TLS support.) RuntimeErrorselfrr/root/aizidognhua/tmp/workspace/projects/ec89d86c-575f-41c9-af57-ac45cbdbf775/venv/lib/python3.10/site-packages/werkzeug/serving.py __getattr__2sz_SslDummy.__getattr__Nrrrr)__name__ __module__ __qualname__rrrrrr1srTntcoloramaFforkc@s eZdZdS) ForkingMixInN)rrr rrrrr$Isr$ssl.SSLContextadhoc)WSGIApplication)WSGIEnvironment)RSAPrivateKeyWithSerialization) Certificatec@s8eZdZdZdddZdd d Zdd d ZdddZdS)DechunkedInputz8An input stream that handles Transfer-Encoding 'chunked'rfile t.IO[bytes]rNonecCs||_d|_d|_dS)NFr)_rfile_done_len)rr-rrr__init__ds zDechunkedInput.__init__boolcCdS)NTrrrrrreadableiszDechunkedInput.readableintc CsZz|jd}t|d}Wnty"}ztd|d}~ww|dkr+td|S)Nlatin1zInvalid chunk headerrz!Negative chunk length not allowed)r0readlinedecoder8strip ValueErrorOSError)rliner2errrread_chunk_lenls zDechunkedInput.read_chunk_lenbuf bytearraycCsd}|js|t|kr|jdkr||_|jdkrd|_|jdkrgtt||j}||t|krP|jt||||d<|jt||8_t|}n|j|||||<|j|8_||7}|jdkry|j}|dvrytd|js|t|ks |S)NrT)   z!Missing chunk terminating newline) r1lenr2rBminr0readr;r?)rrCrJn terminatorrrrreadintovs*       $zDechunkedInput.readintoN)r-r.rr/rr4rr8)rCrDrr8)rrr __doc__r3r7rBrMrrrrr,as     r,cseZdZUdZded<ed7ddZd8d d Zd9d d Zd9fdd Z d:d;ddZ d<fdd Z d7ddZ d=ddZ ed d!ged"ed#d$DZd%eed&<d>d?d+d,Zd@d/d0Zd@d1d2ZdAd5d6ZZS)BWSGIRequestHandlerz3A request handler that implements WSGI dispatching.BaseWSGIServerserverrrcCs|jjSN)rS_server_versionr6rrrserver_versionsz!WSGIRequestHandler.server_versionr)cCsHt|j}|jjdur dnd}|jsd|_n t|jtr"|jdf|_|js2|jr2d|j|j}n|j}t |}iddd|d |j d t j d |jj d |jjd dd|jd|jd|jdddt|dt|jdt|jdt|jd|d||jjdt|jjd|jd}|jD]1\}}d|vrq|dd}|dd}|dvrd |}||vr||d!|}|||<qd"t|d#vrd$|d%<t|d |d <|jr|jr|j|d&<z|jjd$d'}|durt !||d(<W|SW|St"y|j#d)d*Y|St$y#Y|Sw)+Nhttphttps)rr/z wsgi.version)r rzwsgi.url_schemez wsgi.inputz wsgi.errorszwsgi.multithreadzwsgi.multiprocessz wsgi.run_onceFzwerkzeug.socketSERVER_SOFTWAREREQUEST_METHOD SCRIPT_NAME PATH_INFO QUERY_STRING REQUEST_URIRAW_URI REMOTE_ADDR REMOTE_PORTr ) SERVER_NAME SERVER_PORTSERVER_PROTOCOL_-z ) CONTENT_TYPECONTENT_LENGTHHTTP_,chunkedHTTP_TRANSFER_ENCODINGTzwsgi.input_terminated HTTP_HOST) binary_formSSL_CLIENT_CERTerrorz&Cannot fetch SSL peer certificate info)%r pathrS ssl_contextclient_address isinstancerschemenetlocrr-sysstderr multithread multiprocess connectionrVcommandr queryaddress_string port_integerserver_addressrequest_versionheadersitemsupperreplacergetr, getpeercertsslDER_cert_to_PEM_certr>logAttributeError)r request_url url_scheme path_infoenvironkeyvalue peer_certrrr make_environs                   zWSGIRequestHandler.make_environr/c srjdddkrjd_ddddddfd d dfd d dfdd }z |jj WdSt yi}z  |WYd}~dSd}~wt y}zDjj rudur~r~d_zdurdd|tWn t yYnwddlm}||}jdd|WYd}~dSd}~ww)NExpectr^z 100-continuesHTTP/1.1 100 Continue Fdatabytesrr/cstdusJddusJddurz dd\}}Wnty0d}}Ynwt|}||t}D]\}}||||q@d|vsxddksxd|krfdksxn|d vsxjd krxd d d dd t |t sJd|rrj tt|ddj dj |rj dj dS)Nzwrite() before start_responser r^zcontent-lengthr\HEADd>0HTTP/1.1TzTransfer-Encodingrn Connectionclosezapplications must write bytesrF)splitr>r8 send_responseset send_headeraddlowerprotocol_version end_headersrwrwfilewritehexrHencodeflush)rcode_strmsgcode header_keysrr)chunk_responser headers_sent headers_setr status_sent status_setrrrsD            z*WSGIRequestHandler.run_wsgi..writecsB|rzr|d|dWd}n d}wrtd||S)Nr rzHeaders already set)with_tracebackAssertionError)statusrexc_info)rrrrrrstart_response=s z3WSGIRequestHandler.run_wsgi..start_responseappr(c sX|}z`|D]}|qsdrjdWt}|jtjd}d}|jddrUj d}|t |7}|d7}|rN|dksN|d krOn|jdds4| t |d rd| dSdSt}|jtjd}d}|jddrj d}|t |7}|d7}|r|dks|d krn|jdds|| t |d r| ww) Ns0 rg{Gz?)timeoutir ld( ir) rr selectorsDefaultSelectorregisterr~ EVENT_READselectr-rJrHrhasattr)rapplication_iterrselector total_size total_reads)rrrrrrrrexecuteKsN               z,WSGIRequestHandler.run_wsgi..executeTr )DebugTracebackrszError on request: )rrrr/rT)rr(rr/)rrrr=rrrrrSrrconnection_dropped Exceptionpassthrough_errorsclose_connectionr debug.tbtoolsrrender_traceback_textr)rrrArrr) rrrrrrrrrrrun_wsgisD 9'    "zWSGIRequestHandler.run_wsgic sztWdSttjfy#}z ||WYd}~dSd}~wtyG}z|jjdur;t |r;| d|nWYd}~dSd}~ww)z/Handles a request ignoring dropped connections.NzSSL error occurred: %s) superhandleConnectionErrorsocketrrrrSru is_ssl_error log_error)rrA __class__rrrszWSGIRequestHandler.handleNrs BaseExceptionrWSGIEnvironment | NonecCr5)z`Called if the connection was closed by the client. By default nothing happens. Nr)rrsrrrrrsz%WSGIRequestHandler.connection_droppedrrcs|dr|jStt|S)Ndo_) startswithrgetattrrrrrrrs  zWSGIRequestHandler.__getattr__cCs*t|ddr |jdS|jsdS|jdS)NrrcrYr)rrrvr6rrrrs   z!WSGIRequestHandler.address_stringr8cCs |jdS)Nr )rvr6rrrrs zWSGIRequestHandler.port_integercCsi|] }|d|dqS)z\x02xr).0crrr szWSGIRequestHandler. z\\\rir int | strsizecCszt|j}|jd|d|j}Wn ty|j}Ynw||j}t|}|ddkr6t |d}n8|dkr;n3|dkrEt |d}n)|ddkrQt |d }n|d kr[t |d }n|dd krht |dd }nt |dd}| dd|||dS)N r1bold200304cyan3green404yellow4redmagentainfoz "%s" %s %s) rrtrrr requestline translate_control_char_tabler _ansi_styler)rrrrtrrrr log_requests,            zWSGIRequestHandler.log_requestformatargscG|jd|g|RdS)NrsrrrrrrrrzWSGIRequestHandler.log_errorcGr)Nrrrrrr log_messagerzWSGIRequestHandler.log_messagetypemessagecGs<|dd}t||d|d|dg|RdS)N%z%%z - - [z]  )rrr log_date_time_string)rrrrrrrrrs zWSGIRequestHandler.log)rr)rr)rr/rT)rsrrrrr/rrO)riri)rrrrrr/)rrrrrr/rrrrrrrr/)rrr rP__annotations__propertyrVrrrrrrrr maketransrangerordrrrr __classcell__rrrrrQs,    Q       rQrrstylesrcGsBts|Sddddddd}|D] }d||d |}q|d S) Nr r!#$)rrrrrrz[mz)_log_add_style)rrcodesstylerrrrs  rcn str | None2tuple[Certificate, RSAPrivateKeyWithSerialization]c CsBz ddlm}ddlm}ddlm}ddlm}ddlm }Wn t y,t ddw|}|j dd |d }|dur>d }| ||jd ||j|g}|}|||||ttjttjtd dj||j gddj|!|"||"d|gdd#||$|} | |fS)Nr)x509)default_backend)hashes)rsa)NameOIDz::0.0.0.0z * Running on all addresses ()rrz[::1]r|ru[]rr) rrr~appendrLrurrrxrvrsr join)r dev_warningmessagesrxdisplay_hostname localhostrrr log_startupBs(       zBaseWSGIServer.log_startup)NFNN)rLrrsr8rr(rrrr4rurrrkrr/r )r)rrrr/)rrrvr{rr/r )rrr rPr|r} LISTEN_QUEUErequest_queue_sizeallow_reuse_addressr3rrrrrrrrrrRs grRc@seZdZdZdZdZdS)ThreadedWSGIServerzA WSGI server that handles concurrent requests in separate threads. Use :func:`make_server` to create a server instance. TN)rrr rPr|daemon_threadsrrrrresrcs2eZdZdZdZ     ddfdd ZZS)ForkingWSGIServerzA WSGI server that handles concurrent requests in separate forked processes. Use :func:`make_server` to create a server instance. T(NFrLrrsr8rr( processesrrrr4rurrrkrr/c s.tstdt|||||||||_dS)Nz'Your platform does not support forking.)can_forkr>rr3 max_children) rrLrsrrrrrurrrrr3ys  zForkingWSGIServer.__init__)rNFNN)rLrrsr8rr(rr8rrrr4rurrrkrr/)rrr rPr}r3rrrrrrpsrrr(threadedrrequest_handlerrrrurrc Csd|r |dkr td|rt|||||||dS|dkr't||||||||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.r)r>rrrR) rLrsrrrrrrurrrr make_servers(  rcCstjddkS)zqCheck if the server is running as a subprocess within the Werkzeug reloader. .. versionadded:: 0.10 WERKZEUG_RUN_MAINtrue)rcrrrrrris_running_from_reloadersrautohostname application use_reloader use_debugger use_evalex extra_filest.Iterable[str] | Noneexclude_patternsreloader_interval reloader_type static_files'dict[str, str | tuple[str, str]] | Noner/c Cst|ts td| rddlm}||| }|r*ddlm}|||d}|j|t s0d}ntt j d}t |||| | | |||d }|j d t|t j d<t sb|td td d |rdd lm}z||j|||| dW|dS|w|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)evalexNWERKZEUG_SERVER_FDrTrzPress CTRL+C to quitr)run_with_reloader)rrintervalr)rwr8r/middleware.shared_datardebugr trusted_hostsrrrcrrrset_inheritablerfilenorr r _reloaderrrr)rrsrrrrrrrrrrrrrrurrrsrvrrrr run_simplesP p        r)rrrrrrrT)rrrr)NN)rKrrLrrrrrM)rr&)r\rr]rrjrkrr&)rsrorr4)rLrrsr8rrt)rLrrsr8rzrtrr{)rzrtrr)Fr NFNN)rLrrsr8rr(rr4rr8rrrr4rurrrkrrRrN) FFTNNr rFr NNFN)"rrrsr8rr(rr4rr4rr4rrrrrr8rrrr4rr8rrrrrr4rurrr/)RrP __future__rriorcrr socketserverrztypingrprr<rr http.serverrr urllib.parserr _internalr r exceptionsrrWrurlsrrrr SSLEOFErrorrr r.rrr __import__rrr$rwr~rrOptionalUnionrrLiteral_TSSLContextArg TYPE_CHECKING_typeshed.wsgir(r)-cryptography.hazmat.primitives.asymmetric.rsar*cryptography.x509r+ RawIOBaser,rQrrJr_rirerryrrrRThreadingMixInrrrrrrrrrs                    "    > I 2 ,   )  -