U Zj:@sdZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z ddl m Z ddl mZddl mZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZz ddlZWn(ek rGdddZeZYnXdZejdkr.z edWnek r,dZYnXeedZ e rFej!Z!nGdddZ!z ej"Z#Wne$k rxdZ#YnXdZ%ej&ej'dej(e)ej&e)fdfZ*ej+rddl,Z-ddl.m/Z/ddl.m0Z0ddl1m2Z2ddl3m4Z4Gdd d ej5Z6Gd!d"d"eZ7e)e)e)d#d$d%Z8dRej&e)ej(d&d'd(d)Z9dSe)ej&e)ej&e)ej(e)e)fd*d+d,Z:dd-d.d/Z;dTe)ej&e)ej&e<dd0d1d2Z=dUej&e>e?d3d4d5Z@e)eZDGd?d@d@eZEGdAdBdBejFeEZGGdCdDdDe!eEZHdVe)err/)rrFrNr)z wsgi.versionzwsgi.url_scheme wsgi.inputz wsgi.errorszwsgi.multithreadzwsgi.multiprocessz wsgi.run_oncezwerkzeug.socketSERVER_SOFTWAREREQUEST_METHODZ SCRIPT_NAMEZ PATH_INFOZ QUERY_STRINGZ REQUEST_URIZRAW_URI REMOTE_ADDRZ REMOTE_PORTZ SERVER_NAMEZ SERVER_PORTZSERVER_PROTOCOL-_z )Z CONTENT_TYPEZCONTENT_LENGTHZHTTP_,ZHTTP_TRANSFER_ENCODINGchunkedTzwsgi.input_terminatedrTZ HTTP_HOST) binary_formZSSL_CLIENT_CERTerrorz&Cannot fetch SSL peer certificate info)&r pathrL ssl_contextclient_address isinstancerschemenetlocrr(sysstderr multithread multiprocess connectionrOcommandr queryaddress_string port_integerserver_addressrequest_versionheadersitemsupperreplacegetr5lowerr' getpeercertsslDER_cert_to_PEM_certr6logAttributeError)r request_url url_schemeZ path_infoenvironkeyvalueZ peer_certrrr make_environsn            zWSGIRequestHandler.make_environNc sjdddkr&jd_dddddtddfdd dfd d d dd fd d }z|j j Wnt t j fk r}z|W5d}~XYntk r}zj jrdk rrd_z dkr$dd|tWntk rFYnXddlm}||}j dd|W5d}~XYnXdS)NZExpectrNz 100-continuesHTTP/1.1 100 Continue F)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_responserrNzcontent-lengthrVHEADd>0HTTP/1.1TzTransfer-Encodingr[ Connectionclosezapplications must write bytesr=)AssertionErrorsplitr6r4Z send_responsesetZ send_headeraddrtprotocol_versionZ end_headersrarGwfilewritehexr?encodeflush)rZcode_strmsgcode header_keysr}r~)chunk_responser| headers_sent headers_setr status_sent status_setrrrsR             z*WSGIRequestHandler.run_wsgi..writecs@|r(zr|d|dW5d}Xn r4td||S)NrrzHeaders already set)with_tracebackr)statusroexc_info)rrrrrrstart_response3sz3WSGIRequestHandler.run_wsgi..start_responser#)apprc sV|}z2|D] }|qs*dr:jdW5t|drP|XdS)Nrs0 )hasattrrrr)rZapplication_iterr)rr|rrrrrrexecuteAs   z,WSGIRequestHandler.run_wsgi..executeTr)DebugTracebackr]zError on request: )N)rorsrtr5rrrr|rGrLrConnectionErrorsockettimeoutconnection_dropped Exceptionpassthrough_errorsZclose_connectionr Z debug.tbtoolsrZrender_traceback_textrx)rrr9rrr) rr|rrrrrrrrrun_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) superhandlerrrrrrLr_ is_ssl_error log_error)rr9 __class__rrrhszWSGIRequestHandler.handle)r]r|rcCsdS)z`Called if the connection was closed by the client. By default nothing happens. Nr)rr]r|rrrrtsz%WSGIRequestHandler.connection_droppedrcs|dr|jStt|S)NZdo_) startswithrgetattrrrrrrr{s zWSGIRequestHandler.__getattr__cCs*t|ddr|jdS|js dS|jdS)Nr|rWrRr)rr|r`r.rrrrks   z!WSGIRequestHandler.address_stringcCs |jdS)Nr)r`r.rrrrlszWSGIRequestHandler.port_integerrX)rsizercCsz&t|j}|jd|d|j}Wntk r@|j}YnXt|}|ddkrbt|d}np|dkrlnf|dkrt|d}nR|ddkrt|d }n:|d krt|d }n&|dd krt|dd }n t|dd}|dd|||dS)N r1boldZ200Z304cyan3greenZ404yellow4redmagentainfoz "%s" %s %s) r r^rirnryZ requestliner _ansi_stylerx)rrrr^rrrr log_requests(          zWSGIRequestHandler.log_request)formatargsrcGs|jd|f|dS)Nr]rxrrrrrrrszWSGIRequestHandler.log_errorcGs|jd|f|dS)Nrrrrrr log_messageszWSGIRequestHandler.log_messagetypemessagerrcGs.t||d|d|df|dS)Nz - - [z]  )r rkZlog_date_time_stringrrrrrrrrxs zWSGIRequestHandler.log)N)rXrX)rrrrE__annotations__propertyrrOrrr BaseExceptionrOptionalrrrrkr4rlUnionrrrrx __classcell__rrrrrJs4 Py     rJ)r~stylesrcGsBts|Sddddddd}|D]}d||d |}q|d S) Nr !#$)rrrrrrz[mz)_log_add_style)r~rcodesstylerrrrs r)r&r%)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::0.0.0.0z * Running on all addresses ()rBr&z[::1]rr[]rr) rr1rappendrr_r+rrrrr join)rZ dev_warningmessagesrbZdisplay_hostname localhostrrr log_startups(       zBaseWSGIServer.log_startup)NFNN)r;)rrrrErfrg LISTEN_QUEUErequest_queue_sizerr4rrTyperJrH_TSSLContextArgr,rrxfloatr=rTupler@rJrrrrrrKs2I rKc@seZdZdZdZdZdS)ThreadedWSGIServerzA WSGI server that handles concurrent requests in separate threads. Use :func:`make_server` to create a server instance. TN)rrrrErfdaemon_threadsrrrrrQsrQc sTeZdZdZdZd eedeejej e e eje ejedd fdd Z ZS) ForkingWSGIServerzA WSGI server that handles concurrent requests in separate forked processes. Use :func:`make_server` to create a server instance. T(NFr#) rrr processesr,rr_r-rc s.ts tdt|||||||||_dS)Nz'Your platform does not support forking.)can_forkr6rr, max_children) rrrrrUr,rr_r-rrrr,*s zForkingWSGIServer.__init__)rTNFNN)rrrrErgrr4rrrMrJrHrNr,rrrrrrS!s$rSr#) rrrthreadedrUrequest_handlerrr_r-rc 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. rz4Cannot have a multi-thread and multi-process server.r-)r6rQrSrK) rrrrXrUrYrr_r-rrr make_server<s@  r[cCstjddkS)zqCheck if the server is running as a subprocess within the Werkzeug reloader. .. versionadded:: 0.10 ZWERKZEUG_RUN_MAINtrue)r r|rsrrrris_running_from_reloaderisr])hostnamerrc Cst||}t|||}t|tj}|tjtjd|d|tkrjt t |}t j |rjt |z||Wn~tk r}z`t|jtjd|jtjkrtd|dtjdtjdkr|dkrtdtjdtdW5d }~XYnX|t|S) aPrepare a socket for use by the WSGI server and reloader. The socket is marked inheritable so that it can be kept across reloads instead of breaking connections. Catch errors during bind and show simpler error messages. For "address already in use", show instructions for resolving the issue, with special instructions for macOS. This is called from :func:`run_simple`, but can be used separately to control server creation with :func:`make_server`. rT)filezPort zp is in use by another program. Either identify and stop that program, or start the server with a different port.darwinizZOn macOS, try disabling the 'AirPlay Receiver' service from System Preferences -> Sharing.N)rr%rr! setsockopt SOL_SOCKET SO_REUSEADDRset_inheritablerrrrr r^r2r3bindr7printstrerrorrdreerrnoZ EADDRINUSEplatformexitlistenrK)r^rr1rmr*r9rrrprepare_socketrs4         rlauto)r^r application use_reloader use_debugger use_evalex extra_filesexclude_patternsreloader_interval reloader_typerXrUrY static_filesrr_rc Cst|tstd| r,ddlm}||| }|rHddlm}|||d}tsxt||}| }| t |t j d<ntt j d}t|||| | | |||d }ts|tdtd d |rdd lm}||j|||| d n|d S)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 serve 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)ZevalexZWERKZEUG_SERVER_FDrZrzPress CTRL+C to quitr)run_with_reloader)rrrsintervalruN)rar4rZmiddleware.shared_datarwdebugrxr]rlfilenodetachrr r|r[rJr rZ _reloaderryr=)r^rrnrorprqrrrsrtrurXrUrYrvrr_rwrxr*r-Zsrvryrrr run_simplesLp        r~)N)NN)NN)N)FrNFNN) FFTNNrrmFrNNFN)PrErhior r socketserverrdtypingrrrrrZ http.serverrr _internalr r exceptionsr urlsr r rrvrrrr __import__rrVr!rrryrKrrrPrrN TYPE_CHECKINGtyping_extensionsteZ_typeshed.wsgir#r$Z-cryptography.hazmat.primitives.asymmetric.rsar%Zcryptography.x509r& RawIOBaser'rJrrrrr4r rrHr AddressFamilyrr%r+rKThreadingMixInrQrSrMr[r]rlIterableDictr~rrrrs                        >( / ,      - :&