B d@sdZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z ddl m Z ddl mZddl mZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZy ddlZWn(ek rGdddZeZYnXdZejdkr.y edWnek r,dZYnXeedZ e rFej!Z!nGdddZ!y 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%Z8dOej&e)ej(d&d'd(d)Z9dPe)ej&e)ej&e)ej(e)e)fd*d+d,Z:dd-d.d/Z;dQe)ej&e)ej&e<dd0d1d2Z=dRej&e>e?d3d4d5Z@e)eZDGd?d@d@eZEGdAdBdBejFeEZGGdCdDdDe!eEZHdSe)errrrr$Vs  r$cseZdZUdZded<eedddZdddd Zd dd d Z d dfd d Z d%e e j dd dddZee jdfdd ZedddZedddZd&e jeefe jeefd dddZee jd dddZee jd dd d!Zeee jd d"d#d$ZZS)'WSGIRequestHandlerz3A request handler that implements WSGI dispatching.BaseWSGIServerserver)rcCsddlm}d|S)Nr) __version__z Werkzeug/)rG)rrGrrrserver_versions z!WSGIRequestHandler.server_versionr!cCst|j}|jjdkrdnd}|js,d|_nt|jtrD|jdf|_|jsd|jrdd|j|j}n|j}t |}d||j t j |jj |jjd|j|j|jdt|t|jt|jt|j|||jjdt|jjd |jd }xj|jD]\\}}|d d }|d d}|dkrFd|}||krF||d|}|||<qW|dddkrd|d<t|d|d<|jr|jr|j|d<y*|jj dd}|dk rt!"||d<Wn8t#k r|j$ddYnt%k rYnX|S)Nhttphttps)zrr/)rrFrHr)z wsgi.versionzwsgi.url_schemez 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_terminatedz wsgi.inputZ HTTP_HOST) binary_formZSSL_CLIENT_CERTerrorz&Cannot fetch SSL peer certificate info)&r pathrF ssl_contextclient_address isinstancerschemenetlocr r%sysstderr multithread multiprocess connectionrIcommandr queryaddress_string port_integerserver_addressrequest_versionheadersitemsupperreplacegetr0lowerr$ getpeercertsslDER_cert_to_PEM_certr1logAttributeError)r request_url url_schemeZ path_infoenvironkeyvalueZ peer_certrrr make_environsh             zWSGIRequestHandler.make_environNc sjdddkr&jd_dddddtddfdd dfd d d dd fd d }y|j j Wnt t j fk r}z|Wdd}~XYntk r}zj jrdk rrd_y dkr$dd|tWntk rFYnXddlm}||}j dd|Wdd}~XYnXdS)NZExpectrHz 100-continuesHTTP/1.1 100 Continue F)datarcsdk stddk s tddkr ydd\}}Wntk rdd}}YnXt|}||t}x*D]"\}}||||qWd|ksddksd|krdksn|d ksj d krd d d dd t |t s td|rvrXj tt|ddj dj |rvj dj dS)Nzwrite() before start_responserrHzcontent-lengthrNHEADd>0zHTTP/1.1TzTransfer-EncodingrS Connectionclosezapplications must write bytess )AssertionErrorsplitr1r/Z send_responsesetZ send_headeraddrlprotocol_versionZ end_headersrYrAwfilewritehexr9encodeflush)rxZcode_strmsgcode header_keysrurv)chunk_responsert headers_sent headers_setr status_sent status_setrrrsB            z*WSGIRequestHandler.run_wsgi..writecs@|r(zr|d|dWdd}Xn r4td||S)NrrzHeaders already set)with_tracebackr)statusrgexc_info)rrrrrrstart_response1sz3WSGIRequestHandler.run_wsgi..start_responser )apprc sZ|}z6x|D] }|qWs.dr>jdWdt|drT|XdS)Ns0 r)rrhasattrr)rZapplication_iterrx)rrtrrrrrrexecute?s    z,WSGIRequestHandler.run_wsgi..executeTr)DebugTracebackrUzError on request: )N)rgrkrlr0rrrwrtrArFrConnectionErrorsockettimeoutconnection_dropped Exceptionpassthrough_errorsZclose_connectionr Z debug.tbtoolsrZrender_traceback_textrp)rrr4rrr) rrtrrrrrrrrrun_wsgis<  9    zWSGIRequestHandler.run_wsgic sytWnvttjfk r@}z||Wdd}~XYnFtk r}z(|jjdk rrt |rr| d|nWdd}~XYnXdS)z/Handles a request ignoring dropped connections.NzSSL error occurred: %s) superhandlerrrrrrFrW is_ssl_error log_error)rr4) __class__rrrfszWSGIRequestHandler.handle)rUrtrcCsdS)z`Called if the connection was closed by the client. By default nothing happens. Nr)rrUrtrrrrrsz%WSGIRequestHandler.connection_dropped)rrcs|dr|jStt|S)NZdo_) startswithrgetattrr)rr)rrrrys zWSGIRequestHandler.__getattr__cCs*t|ddr|jdS|js dS|jdS)NrtrOzr)rrtrX)rrrrrcs   z!WSGIRequestHandler.address_stringcCs |jdS)Nr)rX)rrrrrdszWSGIRequestHandler.port_integerrP)rsizercCsy&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 rVrarfrqZ requestliner _ansi_stylerp)rrrrVrrrr log_requests(          zWSGIRequestHandler.log_request)formatargsrcGs|jd|f|dS)NrU)rp)rrrrrrrszWSGIRequestHandler.log_errorcGs|jd|f|dS)Nr)rp)rrrrrr log_messageszWSGIRequestHandler.log_message)typemessagerrcGs.t||d|d|df|dS)Nz - - [z]  )rrcZlog_date_time_string)rrrrrrrrpszWSGIRequestHandler.log)N)rPrP)rrrr?__annotations__propertyrrIrwrr BaseExceptionrOptionalrrrrcr/rdUnionrrrrp __classcell__rr)rrrDs" Ny  rD)rvstylesrcGsFts|Sddddddd}x |D]}d||d |}q W|d S) Nr !#$)rrrrrrz[mz)_log_add_style)rvrcodesstylerrrrs r)r#r")cnrc Cs:y@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 Sharing.rZadhocT) server_side)/rDvarsr^r_rrrrrr address_familyrr/rrrrrrVexistsunlinkrr) server_bindserver_activater2 server_closeprintstrerrorr\r]errno EADDRINUSEplatformexitrrfromfdrrrerYtuplerr wrap_socketrW) rrrrrrrWrr"rer4)rrrr)sf                   zBaseWSGIServer.__init__)rrrrcGst||f|dS)N)r)rrrrrrrrpszBaseWSGIServer.log?) poll_intervalrcs<z,ytj|dWntk r(YnXWd|XdS)N)r2)r serve_foreverKeyboardInterruptr')rr2)rrrr3s  zBaseWSGIServer.serve_forever)requestrXrcs|jrt||S)N)rr handle_error)rr5rX)rrrr6szBaseWSGIServer.handle_error)rcCsd}t|dd}|g}|jtkr4|d|jn|jdkrBdnd}|j}|jdkr|d |jd |jd krd }ttj}nd }ttj }|d|d|d|j d|krd|d}|d|d|d|j t dd |dS)z::0.0.0.0z * Running on all addresses ()z0.0.0.0z 127.0.0.1z[::1]z://r[]rr) rr"rappendrrWrrr r rrjoin)rZ dev_warningmessagesrZZdisplay_hostname localhostrrr log_startup s&       zBaseWSGIServer.log_startup)NFNN)r1)rrrr?r^r_ LISTEN_QUEUErequest_queue_sizeallow_reuse_addressrr/rrTyperDrB_TSSLContextArgr)rrpfloatr3rTupler6r@rrr)rrrEs(Z rEc@seZdZdZdZdZdS)ThreadedWSGIServerzA WSGI server that handles concurrent requests in separate threads. Use :func:`make_server` to create a server instance. TN)rrrr?r^daemon_threadsrrrrrH/srHc 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 processesrrrWrrc s.ts tdt|||||||||_dS)Nz'Your platform does not support forking.)can_forkr1rr) max_children) rrrrrLrrrWr)rrrr)Cs zForkingWSGIServer.__init__)rKNFNN)rrrr?r_rr/rrrDrDrBrEr)rrr)rrrJ:s*rJr ) rrrthreadedrLrequest_handlerrrWrrc 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)r1rHrJrE) rrrrOrLrPrrWrrrr make_serverUs" rQcCstjddkS)zqCheck if the server is running as a subprocess within the Werkzeug reloader. .. versionadded:: 0.10 ZWERKZEUG_RUN_MAINtrue)rrtrkrrrris_running_from_reloadersrSauto)hostnamer application use_reloader use_debugger use_evalex extra_filesexclude_patternsreloader_interval reloader_typerOrLrP static_filesrrWrc Cst|tstd| r,ddlm}||| }|rHddlm}|||d}tsTd}nttj d}t |||| | | |||d }|j d t |tj d<ts|td td d |rdd lm}z||j|||| dWd|Xn|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 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)ZevalexNZWERKZEUG_SERVER_FD)rTrzPress CTRL+C to quitr)run_with_reloader)rZr[intervalr])rYr/rZmiddleware.shared_datar_debugr`rSrrtrQrset_inheritablerfilenor@rrZ _reloaderrar3r')rUrrVrWrXrYrZr[r\r]rOrLrPr^rrWr_r`rZsrvrarrr run_simplesJp         rf)N)NN)NN)N)FrNFNN) FFTNNrrTFrNNFN)Or?r*iorr socketserverr\typingrrrrrZ http.serverrr _internalrr exceptionsr urlsr r r rnrrrr __import__rrMrr rrqrArrrGrrE TYPE_CHECKINGtyping_extensionsteZ_typeshed.wsgir r!Z-cryptography.hazmat.primitives.asymmetric.rsar"Zcryptography.x509r# RawIOBaser$rDrrrrr/rrrBr AddressFamilyr rrrEThreadingMixInrHrJrDrQrSIterableDictrfrrrr s                   "    >& -* "% ,# p