a -=ic:@sdZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z ddl m Z ddl mZddl mZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZz ddlZWn&eyGdddZeZYn0dZejdkr*z edWney(dZYn0eedZ e rBej!Z!nGdddZ!z ej"Z#Wne$yrdZ#Yn0dZ%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/)rrFrOr)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_terminatedrUZ HTTP_HOST) binary_formZSSL_CLIENT_CERTerrorz&Cannot fetch SSL peer certificate info)&r pathrM ssl_contextclient_address isinstancerschemenetlocrr)sysstderr multithread multiprocess connectionrPcommandr queryaddress_string port_integerserver_addressrequest_versionheadersitemsupperreplacegetr6lowerr( getpeercertsslDER_cert_to_PEM_certr7logAttributeError)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 fy}z|WYd}~nd}~0ty}zj jrdurrd_z dur$dd|tWntyDYn0ddlm}||}j dd|WYd}~n d}~00dS)NZExpectrOz 100-continuesHTTP/1.1 100 Continue F)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_responserrOzcontent-lengthrWHEADd>i0HTTP/1.1TzTransfer-Encodingr\ Connectionclosezapplications must write bytesr>)splitr7r5Z send_responsesetZ send_headeraddruprotocol_versionZ end_headersrbrHwfilewritehexr@encodeflush)rZcode_strmsgcode header_keysr~r)chunk_responser} headers_sent headers_setr status_sent status_setrrrsP              z*WSGIRequestHandler.run_wsgi..writecsD|r,zr|d|dWd}q8d}0n r8td||S)NrrzHeaders already set)with_tracebackAssertionError)statusrpexc_info)rrrrrrstart_response3sz3WSGIRequestHandler.run_wsgi..start_responser$)apprc sh|}zD|D] }|qs*dr:jdWt|drd|nt|drb|0dS)Ns0 r)rrhasattrr)rZapplication_iterr)rr}rrrrrrexecuteAs    z,WSGIRequestHandler.run_wsgi..executeTr)DebugTracebackr^zError on request: )N)rprtrur6rrrr}rHrMrConnectionErrorsockettimeoutconnection_dropped Exceptionpassthrough_errorsZclose_connectionr Z debug.tbtoolsrZrender_traceback_textry)rrr:rrr) rr}rrrrrrrrrun_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) superhandlerrrrrrMr` is_ssl_error log_error)rr: __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}rXrSr)rr}rar/rrrrls   z!WSGIRequestHandler.address_stringcCs |jdS)Nr)rar/rrrrmszWSGIRequestHandler.port_integerrY)rsizercCsz&t|j}|jd|d|j}Wnty>|j}Yn0t|}|ddkr`t|d}np|dkrjnf|dkr~t|d}nR|ddkrt|d }n:|d krt|d }n&|dd krt|dd }n t|dd}|dd|||dS)N r1boldZ200Z304cyan3greenZ404yellow4redmagentainfoz "%s" %s %s) r r_rjrorzZ requestliner _ansi_stylery)rrrr_rrrr log_requests(           zWSGIRequestHandler.log_request)formatargsrcGs|jd|g|RdS)Nr^ryrrrrrrrszWSGIRequestHandler.log_errorcGs|jd|g|RdS)Nrrrrrr log_messageszWSGIRequestHandler.log_messagetypemessagerrcGs0t||d|d|dg|RdS)Nz - - [z]  )r rlZlog_date_time_stringrrrrrrrrys zWSGIRequestHandler.log)N)rYrY)rrrrF__annotations__propertyrrPrrr BaseExceptionrOptionalrrrrlr5rmUnionrrrry __classcell__rrrrrKs. Py     rK)rstylesrcGsBts|Sddddddd}|D]}d||d |}q|d S) Nr !#$)rrrrrrz[mz)_log_add_style)rrcodesstylerrrrs r)r'r&)cnrc Cs8z@ddlm}ddlm}ddlm}ddlm}ddlm }Wnt y\t ddYn0|}|j dd |d }|durd }| ||jd ||j|g}|}|||||ttjttjtd dj||j gddj|!|"|gdd#||$|} | |fS)Nr)x509)NameOID)default_backend)hashes)rsazz::0.0.0.0z * Running on all addresses ()rAr&z[::1]rr[]rr) rr1rappendrr`r+rrrrr join)rZ dev_warningmessagesrcZdisplay_hostname localhostrrr log_startups(       zBaseWSGIServer.log_startup)NFNN)r;)rrrrFrgrh LISTEN_QUEUErequest_queue_sizerr5rrTyperKrI_TSSLContextArgr-rryfloatr=rTupler@rIrrrrrrLs0I rLc@seZdZdZdZdZdS)ThreadedWSGIServerzA WSGI server that handles concurrent requests in separate threads. Use :func:`make_server` to create a server instance. TN)rrrrFrgdaemon_threadsrrrrrPsrPc 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_forkr7rr- max_children) rrrrrTr,rr`r-rrrr-*s zForkingWSGIServer.__init__)rSNFNN)rrrrFrhrr5rrrLrKrIrMr-rrrrrrR!s$rRr$) rrrthreadedrTrequest_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-)r7rPrRrL) rrrrWrTrXrr`r-rrr make_server<s(  rZcCstjddkS)zqCheck if the server is running as a subprocess within the Werkzeug reloader. .. versionadded:: 0.10 ZWERKZEUG_RUN_MAINtrue)r r}rtrrrris_running_from_reloaderisr\)hostnamerrc Cst||}t|||}t|tj}|tjtjd|d|tkrjt t |}t j |rjt |z||Wnty}zht|jtjd|jtjkrtd|dtjdtjdkr|dkrtdtjdtdWYd }~n d }~00|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_r2r3bindr8printstrerrorrerferrno EADDRINUSEplatformexitlistenrJ)r]rr1rnr*r:rrrprepare_socketrs4          rlauto)r]r application use_reloader use_debugger use_evalex extra_filesexclude_patternsreloader_interval reloader_typerWrTrX 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_FDrYrzPress CTRL+C to quitr)run_with_reloader)rrrsintervalruN)rbr5rZmiddleware.shared_datarwdebugrxr\rlfilenodetachrr r}rZrIr rZ _reloaderryr=)r]rrnrorprqrrrsrtrurWrTrXrvrr`rwrxr*r-Zsrvryrrr run_simplesLp        r~)N)NN)NN)N)FrNFNN) FFTNNrrmFrNNFN)PrFrgior r socketserverretypingrrrrrZ http.serverrr _internalr r exceptionsr urlsr r rrwrrrr __import__rrUr"rrrzrJrrrOrrM TYPE_CHECKINGZtyping_extensionsteZ_typeshed.wsgir$r%Z-cryptography.hazmat.primitives.asymmetric.rsar&Zcryptography.x509r' RawIOBaser(rKrrrrr5r rrIr AddressFamilyrr%r+rLThreadingMixInrPrRrLrZr\rlIterableDictr~rrrrs                         >( / ,      - :&