o 1)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 dudxdd?d+d,Zd@d/d0Zd@d1d2ZdAd5d6ZZS)BWSGIRequestHandlerz3A request handler that implements WSGI dispatching.BaseWSGIServerserverrrcCs|jjSN)rP_server_versionr3rrrserver_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_METHODZ SCRIPT_NAMEZ PATH_INFOZ QUERY_STRINGZ REQUEST_URIZRAW_URI REMOTE_ADDRZ REMOTE_PORTr )Z SERVER_NAMEZ SERVER_PORTZSERVER_PROTOCOL_-z )Z CONTENT_TYPEZCONTENT_LENGTHZHTTP_,ZHTTP_TRANSFER_ENCODINGchunkedTzwsgi.input_terminatedZ HTTP_HOST) binary_formZSSL_CLIENT_CERTerrorz&Cannot fetch SSL peer certificate info)&r pathrP ssl_contextclient_address isinstancerschemenetlocrr*sysstderr multithread multiprocess connectionrScommandr queryaddress_string port_integerserver_addressrequest_versionheadersitemsupperreplacegetr:lowerr) getpeercertsslDER_cert_to_PEM_certr;logAttributeError)r request_url url_schemeZ path_infoenvironkeyvalueZ 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)NZExpectrZz 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 rZzcontent-lengthrYHEADd>i0HTTP/1.1TzTransfer-Encodingr_ Connectionclosezapplications must write bytesrC)splitr;r5Z send_responsesetZ send_headeraddrxprotocol_versionZ end_headersrerwfilewritehexrEencodeflush)rZcode_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)statusrsexc_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 selectorsDefaultSelectorregisterrl EVENT_READselectr*rGrErhasattr)rZapplication_iterrselector total_sizeZ total_reads)rrrrrrrrexecuteJsN               z,WSGIRequestHandler.run_wsgi..executeTr )DebugTracebackrazError on request: )rrrr,rQ)rr%rr,)rsrwrxr:rrrrrPrrconnection_dropped Exceptionpassthrough_errorsZclose_connectionrZ debug.tbtoolsrZrender_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) superhandleConnectionErrorsocketrrrrPrc is_ssl_error log_error)rr> __class__rrrszWSGIRequestHandler.handleNra BaseExceptionrWSGIEnvironment | NonecCr2)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|jsdS|jdS)Nrr[rVr)rrrdr3rrrros   z!WSGIRequestHandler.address_stringr5cCs |jdS)Nr )rdr3rrrrps zWSGIRequestHandler.port_integercCsi|] }|d|dqS)z\x02xr).0crrr szWSGIRequestHandler. z\\\r]r 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 r1boldZ200Z304cyan3greenZ404yellow4redmagentainfoz "%s" %s %s) rrbrmrrr}Z requestline translate_control_char_tabler _ansi_styler|)rrrrbrrrr log_requests,            zWSGIRequestHandler.log_requestformatargscG|jd|g|RdS)Nrar|rrrrrrrzWSGIRequestHandler.log_errorcGr)Nrrrrrr log_messagerzWSGIRequestHandler.log_messagetypemessagecGs<|dd}t||d|d|dg|RdS)N%z%%z - - [z]  )rorvr Zlog_date_time_string)rrrrrorrrr|s zWSGIRequestHandler.log)rr)rr&rr,rQ)rarrrrr,rrL)r]r])rrrrrr,)rrrrrr,rrrrrrrr,)rrrrM__annotations__propertyrSrrrrrrorpr maketransrangerordrrrr| __classcell__rrrrrNs,    Q       rNrrstylesrcGsBts|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 General -> AirDrop & Handoff.r r$T) server_siderz Werkzeug/Zwerkzeug)3rNvarsrjrkrrr5rrr;address_familyrHr5r@r2r3rr'rbexistsunlinkrr0 server_bindserver_activater< server_closeprintstrerrorrhrierrnoZ EADDRINUSEplatformexitrrfromfdrDrLrqretupler)r+ wrap_socketrcimportlib.metadatametadataversionrR) rrr5rrOrrcrRrXrqr> importlibrrrr0sz             zBaseWSGIServer.__init__rrrrcGst||g|RdSrQr )rrrrrrrr|.szBaseWSGIServer.log? poll_intervalfloatcsNz!z tj|dWn tyYnwW|dSW|dS|w)N)rk)r serve_foreverKeyboardInterruptr])rrkrrrrm1s  zBaseWSGIServer.serve_foreverrequestrdr=cs|jrt||SrQ)rr handle_error)rrordrrrrp9szBaseWSGIServer.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)z0.0.0.0z::z * Running on all addresses ()rqrIz[::1]r>r7[]rr) rrXr@appendrrcrNrr:r8r5r join)rZ dev_warningmessagesrfZdisplay_hostname localhostrrr log_startupAs(       zBaseWSGIServer.log_startup)NFNN)rrr5r5rr%rOrPrr1rcrQrRr-rr,r)rj)rkrlrr,)rorrdr=rr,r)rrrrMrjrk LISTEN_QUEUErequest_queue_sizeallow_reuse_addressr0r|rmrpryrrrrrrOs grOc@seZdZdZdZdZdS)ThreadedWSGIServerzA WSGI server that handles concurrent requests in separate threads. Use :func:`make_server` to create a server instance. TN)rrrrMrjdaemon_threadsrrrrr}dsr}cs2eZdZdZdZ     ddfdd ZZS)ForkingWSGIServerzA WSGI server that handles concurrent requests in separate forked processes. Use :func:`make_server` to create a server instance. T(NFrrr5r5rr% processesrOrPrr1rcrQrRr-rr,c s.tstdt|||||||||_dS)Nz'Your platform does not support forking.)can_forkr;rr0Z max_children) rrr5rrrOrrcrRrrrr0xs  zForkingWSGIServer.__init__)rNFNN)rrr5r5rr%rr5rOrPrr1rcrQrRr-rr,)rrrrMrkr0rrrrrrosrrr%threadedrrequest_handlerrPrrcrQrRc 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.rR)r;r}rrO) rr5rrrrrrcrRrrr make_servers(  rcCstjddkS)zqCheck if the server is running as a subprocess within the Werkzeug reloader. .. versionadded:: 0.10 ZWERKZEUG_RUN_MAINtrue)r'rrwrrrris_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)ZevalexNZWERKZEUG_SERVER_FDrTrzPress CTRL+C to quitr)run_with_reloader)rrintervalr)rer5rZmiddleware.shared_datardebugr trusted_hostsrurr'rrrset_inheritablerfilenoryr rZ _reloaderrrmr])rr5rrrrrrrrrrrrrrcrrrRZsrvrrrr run_simplesP p        r)rrrrrrrQ)rrrr)NN)rrrrrrrr)rr#)r rr!rr,r-rr#)rar1rr1)rrr5r5rr6)rrr5r5r<r6rr=)r<r6rr)Fr NFNN)rrr5r5rr%rr1rr5rrPrr1rcrQrRr-rrOrK) FFTNNr rFr NNFN)"rrr5r5rr%rr1rr1rr1rrrrrr5rrrr1rr5rrPrrrr1rcrQrr,)PrM __future__rr`ior'rr socketserverrhtypingr2rrrrZ http.serverrr urllib.parserr _internalr r exceptionsrurlsrrzrr SSLEOFErrorrrrrrr __import__rrr!r9r@r}rzOptionalUnionrdrLiteralZ_TSSLContextArg TYPE_CHECKINGZ_typeshed.wsgir%r&Z-cryptography.hazmat.primitives.asymmetric.rsar'Zcryptography.x509r( RawIOBaser)rNrrr#r+r)rr;rHrNrOThreadingMixInr}rrrrrrrrs                   "    > I 2 ,   )  -