o 'h@sUdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl mZddl mZddlmZddlmZdd lmZdd lmZd d lmZd d lmZd dlmZd dlmZzddlZeejej fZ!de"d<Wne#yGdddZ$e$ZeejfZ!YnwdZ%ej&dkrze'dWn e#ydZ%Ynwe(edZ)e)rej*Z*nGdddZ*zej+Z,Wn e-ydZ,YnwdZ.e j/e j0de1e2e j/e2fe j3dfZ4e j5rddl6m7Z7ddl6m8Z8dd l9m:Z:dd!l;mGd$d%d%eZ?drd*d+Z@ dsdtd/d0ZA dudvd4d5ZBdwd6d7ZC dudxd)rrBrIn terminatorrrrreadintous*       $zDechunkedInput.readintoN)r,r-rr.rr3rr7)rBrCrr7)rrr__doc__r2r6rArLrrrrr+`s     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)rR_server_versionr5rrrserver_versionsz!WSGIRequestHandler.server_versionr(cCsNt|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!|}|||<q|d"dd#krd$|d%<t|d |d <|jr|jr|j|d&<z|jj d$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_,HTTP_TRANSFER_ENCODINGchunkedTzwsgi.input_terminated HTTP_HOST) binary_formSSL_CLIENT_CERTerrorz&Cannot fetch SSL peer certificate info)&r pathrR ssl_contextclient_address isinstancerschemenetlocrr,sysstderr multithread multiprocess connectionrUcommandr queryaddress_string port_integerserver_addressrequest_versionheadersitemsupperreplacegetr<lowerr+ 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 bytesrE)splitr=r7 send_responseset send_headeraddrprotocol_version end_headersrvrwfilewritehexrGencodeflush)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,rIrGrhasattr)rapplication_iterrselector total_size total_reads)rrrrrrrrexecuteJsN               z,WSGIRequestHandler.run_wsgi..executeTr )DebugTracebackrrzError on request: )rrrr.rS)rr'rr.)rrrr<rrrrrRrrconnection_dropped Exceptionpassthrough_errorsclose_connectionr debug.tbtoolsrrender_traceback_textr)rrr@rrr) 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) superhandleConnectionErrorsocketrrrrRrt is_ssl_error log_error)rr@ __class__rrrszWSGIRequestHandler.handleNrr BaseExceptionrWSGIEnvironment | NonecCr4)z`Called if the connection was closed by the client. By default nothing happens. Nr)rrrrrrrrsz%WSGIRequestHandler.connection_droppedrrcs|dr|jStt|S)Ndo_) startswithrgetattrrrrrrrs  zWSGIRequestHandler.__getattr__cCs*t|ddr |jdS|jsdS|jdS)NrrbrXr)rrrur5rrrrs   z!WSGIRequestHandler.address_stringr7cCs |jdS)Nr )rur5rrrrs zWSGIRequestHandler.port_integercCsi|] }|d|dqS)z\x02xr).0crrr szWSGIRequestHandler. z\\\rhr 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) rrsr~rr requestline translate_control_char_tabler _ansi_styler)rrrrsrrrr log_requests,            zWSGIRequestHandler.log_requestformatargscG|jd|g|RdS)NrrrrrrrrrrzWSGIRequestHandler.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.rS)rrrrrrr.rrN)rhrh)rrrrrr.)rrrrrr.rrrrrrrr.)rrrrO__annotations__propertyrUrrrrrrrr maketransrangerordrrrr __classcell__rrrrrPs,    Q       rPrrstylesrcGsBts|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 getsockname)ryrKsrrrget_interface_ips  $rcsneZdZdZdZdZeZdZ    d)d*fdd Z d+ddZ d,d-fd d! Z d.fd%d& Z d/d'd(Z ZS)0rQzuA WSGI server that that handles one request at a time. Use :func:`make_server` to create a server instance. FTNrKrrrr7rr'handlertype[WSGIRequestHandler] | Nonerr3rt_TSSLContextArg | Nonefdrjrr.c s|durt}dt|vr|js|jrd|_||_||_||_||_t |||_ }t |t ||} |t krJ|durJtt| } tj| rJt| tj| |dd|durz ||Wnbty} z8|t| jtjd| jtj krtd|dtjdtj!dkr|d krtd tjdt"d WYd} ~ n#d} ~ wt#y|w|t$%||t$j&|_$|j$'|_(|t kr|j(d |_|durt)|t*rt+|}n|d krt,}|j-|j$d d|_$||_.nd|_.ddl/} d| j01d|_2dS)NrrF)bind_and_activate)filezPort zp is in use by another program. Either identify and stop that program, or start the server with a different port.darwinizoOn macOS, try disabling the 'AirPlay Receiver' service from System Preferences -> General -> AirDrop & Handoff.r r&T) server_siderz Werkzeug/werkzeug)3rPvarsr{r|rrKrrrrrxaddress_familyrr7r}rorprrbrsexistsunlinkrr2 server_bindserver_activater> server_closeprintstrerrorryrzerrno EADDRINUSEplatformexitrrfromfdrrrrvtuplerdrh wrap_socketrtimportlib.metadatametadataversionrT) rrKrrrrrrtrrrr@ importlibrrrr2sz             zBaseWSGIServer.__init__rrrrcGst||g|RdSrSr )rrrrrrrr.szBaseWSGIServer.log? poll_intervalfloatcsNz!z tj|dWn tyYnwW|dSW|dS|w)N)r)r serve_foreverKeyboardInterruptr)rrrrrr1s  zBaseWSGIServer.serve_foreverrequestrurzcs|jrt||SrS)rr handle_error)rrrurrrr9szBaseWSGIServer.handle_errorcCsd}t|dd}|g}|jtkr|d|jnW|jdur!dnd}|j}|jdvrX|d |jd |jd krBd }ttj}nd }ttj }|d|d|d|j d|vrbd|d}|d|d|d|j t dd |dS)z::0.0.0.0z * Running on all addresses ()rrz[::1]r{rt[]rr) rrr}appendrKrtrrrwrurrr join)r dev_warningmessagesrwdisplay_hostname localhostrrr log_startupAs(       zBaseWSGIServer.log_startup)NFNN)rKrrrr7rr'rrrr3rtrrrjrr.r )r)rrrr.)rrrurzrr.r )rrrrOr{r| LISTEN_QUEUErequest_queue_sizeallow_reuse_addressr2rrrrrrrrrrQs grQc@seZdZdZdZdZdS)ThreadedWSGIServerzA WSGI server that handles concurrent requests in separate threads. Use :func:`make_server` to create a server instance. TN)rrrrOr{daemon_threadsrrrrrdsrcs2eZdZdZdZ     ddfdd ZZS)ForkingWSGIServerzA WSGI server that handles concurrent requests in separate forked processes. Use :func:`make_server` to create a server instance. T(NFrKrrrr7rr' processesrrrr3rtrrrjrr.c s.tstdt|||||||||_dS)Nz'Your platform does not support forking.)can_forkr=rr2 max_children) rrKrrrrrrrtrrrrr2xs  zForkingWSGIServer.__init__)rNFNN)rKrrrr7rr'rr7rrrr3rtrrrjrr.)rrrrOr|r2rrrrrrosrrr'threadedrrequest_handlerrrrtrrc 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=rrrQ) rKrrrrrrrrtrrrr make_servers(  rcCstjddkS)zqCheck if the server is running as a subprocess within the Werkzeug reloader. .. versionadded:: 0.10 WERKZEUG_RUN_MAINtrue)rbrrrrrris_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)rvr7r.middleware.shared_datardebugr trusted_hostsrrrbrrrset_inheritablerfilenorr r _reloaderrrr)rrrrrrrrrrrrrrrrrtrrrsrvrrrr run_simplesP p        r)rrrrrrrS)rrrr)NN)rJrrKrrrrrL)rr%)r[rr\rrirjrr%)rrrnrr3)rKrrrr7rrs)rKrrrr7ryrsrrz)ryrsrr)Fr NFNN)rKrrrr7rr'rr3rr7rrrr3rtrrrjrrQrM) FFTNNr rFr NNFN)"rrrrr7rr'rr3rr3rr3rrrrrr7rrrr3rr7rrrrrr3rtrrr.)PrO __future__rriorbrr socketserverrytypingrorr;rr http.serverrr urllib.parserr _internalr r exceptionsrurlsrrrr SSLEOFErrorrr r-rrr __import__rrr#rvr}rrOptionalUnionrrLiteral_TSSLContextArg TYPE_CHECKING_typeshed.wsgir'r(-cryptography.hazmat.primitives.asymmetric.rsar)cryptography.x509r* RawIOBaser+rPrrIr^rhrdrrxrrrQThreadingMixInrrrrrrrrrs                   "    > I 2 ,   )  -