a 鴫j@sUdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl mZddl mZddlmZddlmZdd lmZdd lmZd d lmZd d lmZd dlmZd dlmZd dlmZz"ddlZe ej!ej"fZ#de$d<Wn2e%y6GdddZ&e&Ze ej!fZ#Yn0dZ'ej(dkrnz e)dWne%yldZ'Yn0e*edZ+e+rej,Z,nGdddZ,z ej-Z.Wne/ydZ.Yn0dZ0e j1e j2de3e4e j1e4fe j5dfZ6e j7rddl8m9Z9dd l8m:Z:dd!l;mZ>Gd#d$d$ej?Z@Gd%d&d&eZAd'd'd'd(d)d*ZBdad+d,d-d.d/ZCdbd'd+d+d0d1d2d3ZDdd4d5d6ZEdcd'd+d7dd8d9d:ZFddd;dd?ZGd'd@dAdBdCdDZHd'd@dAdEdFdGdHZIdAd'dIdJdKZJGdLdMdMeZKGdNdOdOejLeKZMGdPdQdQe,eKZNded'd@dRdrr/)r rFr )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_,chunkedZHTTP_TRANSFER_ENCODINGTzwsgi.input_terminatedrXZ HTTP_HOST) binary_formZSSL_CLIENT_CERTerrorz&Cannot fetch SSL peer certificate info)%r pathrO ssl_contextclient_address isinstancerschemenetlocrr-sysstderr multithread multiprocess connectionrRcommandr queryaddress_string port_integerserver_addressrequest_versionheadersitemsupperreplacergetr+ getpeercertsslDER_cert_to_PEM_certr<logAttributeError)r request_url url_schemeZ path_infoenvironkeyvalueZ peer_certrrr make_environsn             zWSGIRequestHandler.make_environr,c sjdddkr&jd_ddddddddfd d dfd d d ddfdd }z|jj Wnt y}z |WYd}~nd}~0t y}zjj rdur r d_z durdd|tWnt y>Yn0ddlm}||}jdd|WYd}~n d}~00dS)NZExpectrWz 100-continuesHTTP/1.1 100 Continue Fbytesr,)datarcs~dusJddus Jddurzdd\}}Wntybd}}Yn0t|}||t}D]"\}}||||qd|vsddksd|krdksn|d vsjd krd d d dd t |t sJd|rprRj tt|ddj dj |rpj dj dS)Nzwrite() before start_responser rWzcontent-lengthrZHEADd>i0HTTP/1.1TzTransfer-Encodingrb Connectionclosezapplications must write bytesrD)splitr<r6Z send_responsesetZ send_headeraddlowerprotocol_versionZ end_headersrhrwfilewritehexrFencodeflush)rZcode_strmsgcode header_keysrr)chunk_responser headers_sent headers_setr status_sent status_setrrrsP              z*WSGIRequestHandler.run_wsgi..writecsD|r,zr|d|dWd}q8d}0n r8td||S)Nr rzHeaders already set)with_tracebackAssertionError)statusrvexc_info)rrrrrrstart_response=sz3WSGIRequestHandler.run_wsgi..start_responser')apprc sJ|}z|D] }|qs*dr:jdWt}|jtjd}d}|jddrj d}|t |7}|d7}|r|dks|d kr\qq\| t |d r| nt}|jtjd}d}|jddr(j d}|t |7}|d7}|r(|dks(|d krܐq(q| t |d rD| 0dS) Ns0 rg{Gz?)timeoutir ld( ir) rr selectorsDefaultSelectorregisterro EVENT_READselectr-rHrFrhasattr)rZapplication_iterrselector total_sizeZ total_reads)rrrrrrrrexecuteKsD          z,WSGIRequestHandler.run_wsgi..executeTr )DebugTracebackrdzError on request: )N)rvrzrr;rrrrrOrrconnection_dropped Exceptionpassthrough_errorsZclose_connectionrZ debug.tbtoolsrZrender_traceback_textr~)rrr?rrr) rrrrrrrrrrrun_wsgis<  9'    zWSGIRequestHandler.run_wsgic sztWnzttjfyB}z||WYd}~nPd}~0ty}z0|jjdurrt |rr| d|nWYd}~n d}~00dS)z/Handles a request ignoring dropped connections.NzSSL error occurred: %s) superhandleConnectionErrorsocketrrrrOrf is_ssl_error log_error)rr? __class__rrrszWSGIRequestHandler.handleN BaseExceptionzWSGIEnvironment | None)rdrrcCsdS)z`Called if the connection was closed by the client. By default nothing happens. Nr)rrdrrrrrsz%WSGIRequestHandler.connection_droppedrrcs|dr|jStt|S)NZdo_) startswithrgetattrrrrrrrs zWSGIRequestHandler.__getattr__cCs*t|ddr|jdS|js dS|jdS)Nrr\rUr)rrrgr4rrrrrs   z!WSGIRequestHandler.address_stringr6cCs |jdS)Nr )rgr4rrrrsszWSGIRequestHandler.port_integercCsi|]}|d|dqS)z\x02xr).0crrr rzWSGIRequestHandler. z\\\r^z int | str)rsizercCsz&t|j}|jd|d|j}Wnty>|j}Yn0||j}t|}|ddkrlt |d}np|dkrvnf|dkrt |d}nR|ddkrt |d }n:|d krt |d }n&|dd krt |dd }n t |dd}| dd|||dS)N r1boldZ200Z304cyan3greenZ404yellow4redmagentainfoz "%s" %s %s) rrerprurZ requestline translate_control_char_tabler _ansi_styler~)rrrrerrrr log_requests*            zWSGIRequestHandler.log_request)formatargsrcGs|jd|g|RdS)Nrdr~rrrrrrrszWSGIRequestHandler.log_errorcGs|jd|g|RdS)Nrrrrrr log_messageszWSGIRequestHandler.log_messagetypemessagerrcGs<|dd}t||d|d|dg|RdS)N%z%%z - - [z]  )rrryr Zlog_date_time_string)rrrrrrrrrr~szWSGIRequestHandler.log)N)r^r^)rrr rL__annotations__propertyrRrrrrrrrrsr maketransrangerordrrrr~ __classcell__rrrrrMs* Q   rMr)rstylesrcGsBts|Sddddddd}|D]}d||d |}q|d S) Nr r!#$)rrrrrrz[mz)_log_add_style)rrcodesstylerrrrs rz str | Nonez2tuple[Certificate, RSAPrivateKeyWithSerialization])cnrc CsFz@ddlm}ddlm}ddlm}ddlm}ddlm }Wnt y\t ddYn0|}|j dd |d }|durd }| ||jd ||j|g}|}|||||ttjttjtd dj||j gddj|!|"||"d|gdd#||$|} | |fS)Nr)x509)default_backend)hashes)rsa)NameOIDz0.0.0.0z::z * Running on all addresses ()rkrBz[::1]r7r0[]rr) rrQr9appendr rfrGrr3r1r/r join)rZ dev_warningmessagesriZdisplay_hostname localhostrrr log_startupBs(       zBaseWSGIServer.log_startup)NFNN)rd)rrr rLrmrn LISTEN_QUEUErequest_queue_sizeallow_reuse_addressr1r~rgrjrsrrrrrrNs"grNc@seZdZdZdZdZdS)ThreadedWSGIServerzA WSGI server that handles concurrent requests in separate threads. Use :func:`make_server` to create a server instance. TN)rrr rLrmdaemon_threadsrrrrrwesrwc 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(NFrr6r'rHr2rIr'r,) r r/r processesrJrrfrKrc s.ts tdt|||||||||_dS)Nz'Your platform does not support forking.)can_forkr<rr1 max_children) rr r/rr{rJrrfrKrrrr1ys zForkingWSGIServer.__init__)rzNFNN)rrr rLrnr1rrrrrrypsryr'rHrI) r r/rthreadedr{request_handlerrrfrKrc 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.rK)r<rwryrN) r r/rr~r{rrrfrKrrr make_servers(  rcCstjddkS)zqCheck if the server is running as a subprocess within the Werkzeug reloader. .. versionadded:: 0.10 ZWERKZEUG_RUN_MAINtrue)r"rrzrrrris_running_from_reloadersrautozt.Iterable[str] | Nonez'dict[str, str | tuple[str, str]] | Noner,)hostnamer/ application use_reloader use_debugger use_evalex extra_filesexclude_patternsreloader_interval reloader_typer~r{r static_filesrrfrc Cst|tstd| r,ddlm}||| }|rTddlm}|||d}|j|t s`d}ntt j d}t |||| | | |||d }|j d t|t j d<t s|td td d |rdd lm}z ||j|||| dW|n |0n|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_FDrTrzPress CTRL+C to quitr)run_with_reloader)rrintervalr)rhr6rZmiddleware.shared_datardebugr trusted_hostsrorr"rrrset_inheritablerfilenorsr rZ _reloaderrrgrV)rr/rrrrrrrrr~r{rrrrfrrrKZsrvrrrr run_simplesPp        r)N)NN)NN)N)Fr NFNN) FFTNNr rFr NNFN)RrL __future__rrYior"rr socketserverrktypingr,rrrrZ http.serverrr urllib.parserr _internalr r exceptionsrrSrurlsrr|rr SSLEOFErrorrrrrrr __import__rr|r$r2r9rrtOptionalUnionr^rLiteralZ_TSSLContextArg TYPE_CHECKINGZ_typeshed.wsgir'r(Z-cryptography.hazmat.primitives.asymmetric.rsar)Zcryptography.x509r* RawIOBaser+rMrr rr&r$rr4rArGrNThreadingMixInrwryrrrrrrrs                   "    >I2, ) "-