_&.@sdZddlZddlZddlZddlZddlZddlmZddlmZddl m Z ddl m Z ddl m Z dd l m Z dd lmZdd lmZdd lmZdd lmZddlmZy0ddlZddlmZddlmZWn>ek rbddlZddlmZddlmZYnXyddlZWn1ek rGdddeZeZYnXyddl Z Wnek rdZ YnXej!Z!e"edZ#e#rej$Z$nGdddeZ$y ej%Z&Wne'k r9dZ&YnXdZ(e oSe"edZ)e rhej*Z+ne,Z+Gdddej-Z.GdddeeZ/e/Z0dddZ1ddddZ2d d!Z3ddd"d#Z4Gd$d%d%eZ5dd&d'Z6d(d)Z7d*d+Z8Gd,d-d-eeZ9Gd.d/d/e!e9Z:Gd0d1d1e$e9Z;dddd2ddd2ddd3d4 Z<d5d6Z=d2d2d7ddd8d2dddd2dd9d: Z>d;d<Z?d=d>Z@eAd?kre@dS)@a7 werkzeug.serving ~~~~~~~~~~~~~~~~ There are many ways to serve a WSGI application. While you're developing it you usually don't want a full blown webserver like Apache but a simple standalone one. From Python 2.5 onwards there is the `wsgiref`_ server in the standard library. If you're using older versions of Python you can download the package from the cheeseshop. However there are some caveats. Sourcecode won't reload itself when changed and each time you kill the server using ``^C`` you get an `KeyboardInterrupt` error. While the latter is easy to solve the first one can be a pain in the ass in some situations. The easiest way is creating a small ``start-myproject.py`` that runs the application:: #!/usr/bin/env python # -*- coding: utf-8 -*- from myproject import make_app from werkzeug.serving import run_simple app = make_app(...) run_simple('localhost', 8080, app, use_reloader=True) You can also pass it a `extra_files` keyword argument with a list of additional files (like configuration files) you want to observe. For bigger applications you should consider using `click` (http://click.pocoo.org) instead of a simple start file. :copyright: 2007 Pallets :license: BSD-3-Clause N)datetime) timedelta)PY2)reraise)WIN)wsgi_encoding_dance)_log)InternalServerError) uri_to_iri) url_parse) url_unquote)BaseHTTPRequestHandler) HTTPServerc@seZdZddZdS) _SslDummycCstddS)NzSSL support unavailable) RuntimeError)selfnamer4/tmp/pip-build-5gj8f0j9/Werkzeug/werkzeug/serving.py __getattr__Fsz_SslDummy.__getattr__N)__name__ __module__ __qualname__rrrrrrEs rforkc@seZdZdS) ForkingMixInN)rrrrrrrrXs rfromfdc@sFeZdZdZddZddZddZdd Zd S) DechunkedInputz8An input stream that handles Transfer-Encoding 'chunked'cCs||_d|_d|_dS)NFr)_rfile_done_len)rrfilerrr__init__qs  zDechunkedInput.__init__cCsdS)NTr)rrrrreadablevszDechunkedInput.readablec Csny1|jjjd}t|jd}Wntk rQtdYnX|dkrjtd|S)Nlatin1zInvalid chunk headerrz!Negative chunk length not allowed)rreadlinedecodeintstrip ValueErrorIOError)rliner!rrrread_chunk_lenys   zDechunkedInput.read_chunk_lencCsd}x|j r|t|kr|jdkrC|j|_|jdkr[d|_|jdkrtt||j}|jj|||||<|j|8_||7}|jdkr |jj}|dkr tdq W|S)NrT   z!Missing chunk terminating newline)r/r0r1) r lenr!r.minrreadr'r,)rbufr4n terminatorrrrreadintos     zDechunkedInput.readintoN)rrr__doc__r#r$r.r8rrrrrns    rc@seZdZdZeddZddZddZdd Zd d Z d d dZ ddZ d ddZ ddZ ddZddZddddZddZddZd d!Zd"d#Zd S)$WSGIRequestHandlerz3A request handler that implements WSGI dispatching.cCsddlm}d|S)Nr) __version__z Werkzeug/)r;)rr;rrrserver_versionsz!WSGIRequestHandler.server_versionc (stj}fdd}jjdkr9dnd}jsQd_tjtrxjdf_n|j r|jrd|j|jf}n |j}t |}dd/d |d j d t j d jj djjddd|djdjdddt|dt|jdtjdtjdjdjdjjddtjjd dji}xjD]x\}}|jjdd }|jd!d}|d0krd$|}||krd%j|||}|||.shutdown_serverhttphttpszrz/%s%sz wsgi.versionrzwsgi.url_schemez wsgi.inputz wsgi.errorszwsgi.multithreadzwsgi.multiprocessz wsgi.run_onceFzwerkzeug.server.shutdownZSERVER_SOFTWAREREQUEST_METHODZ SCRIPT_NAMEr<Z PATH_INFO QUERY_STRINGZ REQUEST_URIZRAW_URI REMOTE_ADDRZ REMOTE_PORTZ SERVER_NAMEZ SERVER_PORTZSERVER_PROTOCOL-_z CONTENT_TYPECONTENT_LENGTHZHTTP_z{},{}ZHTTP_TRANSFER_ENCODINGchunkedTzwsgi.input_terminatedZ HTTP_HOST binary_formZSSL_CLIENT_CERTerrorz&Cannot fetch SSL peer certificate info)rr)rHrI)&r pathr> ssl_contextclient_address isinstancestrschemenetlocr r"sysstderr multithread multiprocessr=commandrqueryaddress_string port_integerserver_addressrequest_versionget_header_itemsupperreplaceformatgetr*lowerr connection getpeercertsslDER_cert_to_PEM_certr+logAttributeError) r request_urlr@Z url_schemeZ path_infoenvironkeyvalueZ peer_certr)rr make_environsj                $     zWSGIRequestHandler.make_environcsjjddjjdkr7jjdj_ggfdddfddfd d }y|jj Wnt t j fk r}zj |WYdd}~Xntk rjjrd d lm}|d d}y$sLdd=|tWntk rnYnXjjdd|jYnXdS)NZExpectr<z 100-continuesHTTP/1.1 100 Continue c sstdsp\}}ddServerdateDatezapplications must write bytes)rqrr)AssertionErrorsplitr+r) send_responsesetZ send_headerrcaddclose_connectionversion_stringZdate_time_stringZ end_headersrPbyteswfilewriteflush)datastatusresponse_headerscodemsgZ header_keysrlrm)rk headers_sent headers_setrrrrs:           z*WSGIRequestHandler.run_wsgi..writec sS|r'zrt|Wdd}Xnr9td||gdd<S)NzHeaders already set)rrx)rrexc_info)rrrrrstart_response+s  z3WSGIRequestHandler.run_wsgi..start_responsec s_|}z/x|D]}|qWs=dWdt|drZ|jXdS)Nrt)hasattrrt)appZapplication_iterr)rkrrrrrexecute7s z,WSGIRequestHandler.run_wsgi..executer)get_current_tracebackZignore_system_exceptionsTrLzError on request: %s)headersrbrcr*rrrnrkr>r_ConnectionErrorsockettimeoutconnection_dropped Exceptionpassthrough_errorsZ debug.tbtoolsrr rh plaintext)rrer tracebackr)rkrrrrrrrun_wsgis0'#  "    zWSGIRequestHandler.run_wsgicCsytj|Wnttjfk rN}z|j|WYdd}~XnGtk r}z'|jjdkst | rWYdd}~XnX|jj r|j dS)z/Handles a request ignoring dropped connections.N) rhandlerrrrrr>rN is_ssl_errorr?initiate_shutdown)rrrrrrVs zWSGIRequestHandler.handlecCsPttdtj}tr4tjtj|d|j_d|j_ dS)zpA horrible, horrible way to kill the server for Python 2.6 and later. It's the best we can do. SIGKILLTFN) getattrsignalSIGTERMis_running_from_reloaderoskillgetpidr>_BaseServer__shutdown_requestZ_BaseServer__serving)rsigrrrrbs   z$WSGIRequestHandler.initiate_shutdownNcCsdS)z`Called if the connection was closed by the client. By default nothing happens. Nr)rrLrkrrrrpsz%WSGIRequestHandler.connection_droppedcCsA|jj|_|js'd|_n|jr=|jSdS)zHandle a single HTTP request.rN)r"r'Zraw_requestliner}Z parse_requestr)rrrrhandle_one_requestus    z%WSGIRequestHandler.handle_one_requestcCs|j||dkr?||jkr9|j|dp<d}|jdkr}d|j||f}|jj|jddS)z3Send the response header and log the response code.Nrr<zHTTP/0.9z %s %d %s ascii) log_request responsesr]Zprotocol_versionrrencode)rrmessagehdrrrrrz}s   &z WSGIRequestHandler.send_responsecCstj|jS)N)rr~r*)rrrrr~sz!WSGIRequestHandler.version_stringcCsRt|ddr|jdS|js*dSt|jtrC|jS|jdSdS)NrkrEzr)rrkrOrPrQ)rrrrrZs  z!WSGIRequestHandler.address_stringcCs |jdS)Nr)rO)rrrrr[szWSGIRequestHandler.port_integerrFcCsvy,t|j}d|j||jf}Wntk rI|j}YnXt|}trYtj}|ddkr||dd}n|ddkr||dd}n|d kr||dd }n|dd kr||dd }nd|d kr||dd}nC|ddkrA||dddd}n||dddd}|j dd|||dS)Nz%s %s %sr1ZboldT2ZfgZwhiteZ304Zcyan3ZgreenZ404Zyellow4ZredZmagentainfoz "%s" %s %s) r rMrXr]riZ requestlinerQclickstylerh)rrsizerMrcolorrrrrs,     zWSGIRequestHandler.log_requestcGs|jd|dS)NrL)rh)rargsrrr log_errorszWSGIRequestHandler.log_errorcGs|jd||dS)Nr)rh)rrarrrr log_messageszWSGIRequestHandler.log_messagecGs.t|d|j|j||fdS)Nz%s - - [%s] %s )r rZZlog_date_time_string)rtyperrrrrrhszWSGIRequestHandler.logc Cstrg}x|jjD]}y&|ddjdd\}}WnJtk r|ddkr|r|j\}}||}nYnX|j||jfqWn|jj}|S) aV Get an iterable list of key/value pairs representing headers. This function provides Python 2/3 compatibility as related to the parsing of request headers. Python 2.7 is not compliant with RFC 3875 Section 4.1.18 which requires multiple values for headers to be provided or RFC 2616 which allows for folding of multi-line headers. This function will return a matching list regardless of Python version. It can be removed once Python 2.7 support is dropped. :return: List of tuples containing header hey/value pairs r:r  )rr)rrryr+popappendlstripitems)rrheaderrlrmrrrr^s&   z#WSGIRequestHandler.get_header_items)rrrr9propertyr=rnrrrrrrzr~rZr[rrrrhr^rrrrr:s"  S V       r:c CsyTddlm}ddlm}ddlm}ddlm}ddlm }Wnt k rtt dYnX|j dd d d d |}|dkrd }|j |j|jd|j|j|g}|jj|j|j|jj|jjtjjtjtddj|j|jgddj|j|j d gddj!||j"|}||fS)Nr)x509)NameOID)default_backend)hashes)rsaz}|j|jd |jjd |j j d |j WdQRX||fS) aCreates an SSL key for development. This should be used instead of the ``'adhoc'`` key which generates a new cert on each server start. It accepts a path for where it should store the key and cert and either a host or CN. If a host is given it will use the CN ``*.host/CN=host``. For more information see :func:`run_simple`. .. versionadded:: 0.9 :param base_path: the path to the certificate and key. The extension ``.crt`` is added for the certificate, ``.key`` is added for the key. :param host: the name of the host. This can be used as an alternative for the `cn`. :param cn: the `CN` to use. Nz *.%s/CN=%srr) serializationz.crtz.keywbencodingraencryption_algorithm) rrropenr public_bytesEncodingPEM private_bytes PrivateFormatTraditionalOpenSSL NoEncryption) base_pathhostrrrr cert_file pkey_filefrrrmake_ssl_devcert!s   #   rc Csddl}ddl}t\}}ddlm}|j\}}|j\}}|jtj||jtj|tj ||j |j j tj ||j d|j j d|jjd|jtj|tj|t||} | S)z:Generates an adhoc SSL context for the development server.rN)rrrar)tempfileatexitrrrmkstempregisterrremoverrrrrrrrrtload_ssl_context) rrrrrZ cert_handlerZ pkey_handlerctxrrrgenerate_adhoc_ssl_contextKs&       rc CsW|dkr7y tj}Wntk r6tj}YnXt|}|j|||S)aLoads SSL context from cert/private key files and optional protocol. Many parameters are directly taken from the API of :py:class:`ssl.SSLContext`. :param cert_file: Path of the certificate to use. :param pkey_file: Path of the private key to use. If not given, the key will be obtained from the certificate file. :param protocol: One of the ``PROTOCOL_*`` constants in the stdlib ``ssl`` module. Defaults to ``PROTOCOL_SSLv23``. N)rfZPROTOCOL_TLS_SERVERriPROTOCOL_SSLv23 _SSLContextload_cert_chain)rrprotocolrrrrris    rc@s@eZdZdZddZddddZddZdS) rzuA dummy class with a small subset of Python3's ``ssl.SSLContext``, only intended to be used with and by Werkzeug.cCs(||_d|_d|_d|_dS)N) _protocol _certfile_keyfile _password)rrrrrr#s   z_SSLContext.__init__NcCs%||_|p||_||_dS)N)rrr)rcertfilekeyfilepasswordrrrrs z_SSLContext.load_cert_chainc Ks+tj|d|jd|jd|j|S)Nrr ssl_version)rf wrap_socketrrr)rsockkwargsrrrrs   z_SSLContext.wrap_socket)rrrr9r#rrrrrrrs  rcCs,|dkrtjd}t|tjS)z?Checks if the given error (or the current one) is an SSL error.Nr)rTrrPrfSSLError)rLrrrrs rcCs?|jdrtjSd|kr8ttdr8tjStjS)zUReturn ``AF_INET4``, ``AF_INET6``, or ``AF_UNIX`` depending on the host and port.zunix://rAF_INET6) startswithrAF_UNIXrr AF_INET)rportrrrselect_address_familys rc Css|tkr |jdddSy%tj|||tjtj}Wntjk rf||fSYnX|ddS)zVReturn a fully qualified socket address that can be passed to :func:`socket.bind`.z://rr)af_unixryr getaddrinfo SOCK_STREAM IPPROTO_TCPgaierror)rr familyresrrr get_sockaddrs rc@speZdZdZdZdZeZddddddZddZ dd Z d d Z d d Z dS)BaseWSGIServerz3Simple single-threaded, single-process WSGI server.FNc Cs|dkrt}t|||_|dk rQtj||jtj}d}t|t||j} |jtkrt j j | rt j | t j|| |||_||_d|_||_|jjd|_|dk r|jj||_|jj|_|dk rt|trBt|}|dkrWt}|j} trt| tj rtj| j| j| j| } |j| dd|_||_ n d|_ dS)NrFrZadhoc server_sideT)!r:raddress_familyrrrrr)rrrMexistsunlinkrr#rrr?r getsocknamer rtr\rPtuplerrrrrprotorrN) rrr rhandlerrrNfdZ real_sockr\rrrrr#s<  !             ! zBaseWSGIServer.__init__cGst|||dS)N)r )rrrrrrrrhszBaseWSGIServer.logcCsEd|_z*ytj|Wntk r1YnXWd|jXdS)NF)r?r serve_foreverKeyboardInterrupt server_close)rrrrr"s    zBaseWSGIServer.serve_forevercCs<|jr ttjdtr)dStj|||S)Nr)rrPrTrrr handle_error)rrequestrOrrrr%s  zBaseWSGIServer.handle_errorcCs|jj\}}||fS)N)raccept)rconrrrr get_requestszBaseWSGIServer.get_request) rrrr9rVrW LISTEN_QUEUErequest_queue_sizer#rhr"r%r)rrrrrs /  rc@s"eZdZdZdZdZdS)ThreadedWSGIServerz"A WSGI server that does threading.TN)rrrr9rVdaemon_threadsrrrrr,s r,c@s7eZdZdZdZdddddddZdS)ForkingWSGIServerz A WSGI server that does forking.T(NFc CsAtstdtj||||||||||_dS)Nz'Your platform does not support forking.)can_forkr+rr# max_children) rrr r processesr rrNr!rrrr#+s  zForkingWSGIServer.__init__)rrrr9rWr#rrrrr.%s r.Fc Cs|r!|dkr!tdnr|rFt||||||d|S|dkrtt|||||||d|St||||||d|SdS)ztCreate a new server instance that is either threaded, or forks or just processes one request after another. rz5cannot have a multithreaded and multi process server.r!N)r+r,r.r) rr rthreadedr2request_handlerrrNr!rrr make_server>s" r5cCstjjddkS)zwChecks if the application is running from within the Werkzeug reloader subprocess. .. versionadded:: 0.10 ZWERKZEUG_RUN_MAINtrue)rrkrbrrrrrcsrTZautoc sttstd|r@ddlm}||| reddlm}|| fddf dd}|rtsd krt rt d t }t |}t j |t j }|jt jt jd|j|t|d rJ|jd trt|jtjd <|jt|n4|j|tkrtdd|tj|ddlm}|||||n|dS)a Start a WSGI application. Optional features include a reloader, multithreading and fork support. This function has a command-line interface too:: python -m werkzeug.serving --help .. versionadded:: 0.5 `static_files` was added to simplify serving of static files as well as `passthrough_errors`. .. versionadded:: 0.6 support for SSL was added. .. versionadded:: 0.8 Added support for automatically loading a SSL context from certificate file and private key. .. versionadded:: 0.9 Added command-line interface. .. versionadded:: 0.10 Improved the reloader and added support for changing the backend through the `reloader_type` parameter. See :ref:`reloader` for more information. .. versionchanged:: 0.15 Bind to a Unix socket by passing a path that starts with ``unix://`` as the ``hostname``. :param hostname: The host to bind to, for example ``'localhost'``. If the value is a path that starts with ``unix://`` it will bind to a Unix socket instead of a TCP socket.. :param port: The port for the server. eg: ``8080`` :param application: the WSGI application to execute :param use_reloader: should the server automatically restart the python process if modules were changed? :param use_debugger: should the werkzeug debugging system be used? :param use_evalex: should the exception evaluation feature be enabled? :param extra_files: a list of files the reloader should watch additionally to the modules. For example configuration files. :param reloader_interval: the interval for the reloader in seconds. :param reloader_type: the type of reloader to use. The default is auto detection. Valid values are ``'stat'`` and ``'watchdog'``. See :ref:`reloader` for more information. :param threaded: should the process handle each request in a separate thread? :param processes: if greater than 1 then handle each request in a new process up to this maximum number of concurrent processes. :param request_handler: optional parameter that can be used to replace the default one. You can use this to replace it with a different :class:`~BaseHTTPServer.BaseHTTPRequestHandler` subclass. :param static_files: a list or dict of paths for static files. This works exactly like :class:`SharedDataMiddleware`, it's actually just wrapping the application in that middleware before serving. :param passthrough_errors: set this to `True` to disable the error catching. This means that the server will die on errors but it can be useful to hook debuggers in (pdb etc.) :param ssl_context: an SSL context for the connection. Either an :class:`ssl.SSLContext`, a tuple in the form ``(cert_file, pkey_file)``, the string ``'adhoc'`` if the server should automatically create one, or ``None`` to disable SSL (which is the default). zport must be an integerr)DebuggedApplication)SharedDataMiddlewarecsd krnd}d}|jtkrCtdd||nQd|krYd|}|jd }tdd dkrd nd |||dS)Nr<r localhostz(Press CTRL+C to quit)rz * Running on %s %srz[%s]rz * Running on %s://%s:%d/ %srArB)r<r)rrr r)rZdisplay_hostnameZquit_msgr )hostnamerNrr log_startups  zrun_simple..log_startupcsyttjd}Wnttfk r7d}YnXtd|}|dkrx|j|jdS)NWERKZEUG_SERVER_FDr!)r)rrk LookupErrorr+r5rr")r!Zsrv) applicationr:r;rr r2r4rNr3rrinners"    zrun_simple..innerrzsCannot bind to a random port with enabled reloader if the Python interpreter does not support socket opening by fd.set_inheritableTr<rz Unlinking %s)run_with_reloaderN) rPr)rdebugr7Zmiddleware.shared_datar8rcan_open_by_fdr+rrrr setsockopt SOL_SOCKET SO_REUSEADDRbindrr@rQfilenorrklistenr*rtrr r _reloaderrA)r:r r> use_reloader use_debuggerZ use_evalexZ extra_filesZreloader_intervalZ reloader_typer3r2r4Z static_filesrrNr7r8r?rr\srAr) r>r:r;rr r2r4rNr3r run_simplelsBV *         rNcOsddlm}|||S)Nr)rA)rJrA)rrrArrrrAsrAc Csyddl}ddlm}|jdd}|jddd d d d |jd dd dddddd d|jddd dddddd d|j\}}d \}}|jr|jjd}|d}t|dkr|d}t|dkr(t j j dt j d||d}t d|pGddt|pVdd|d|jd|jdS)!z:A simple command-line interface for :py:func:`run_simple`.rNr) import_stringusagez,Usage: %prog [options] app_module:app_objectz-bz--binddestaddresshelpz+The hostname:port the app should listen on.z-dz--debugrLaction store_truedefaultFzUse Werkzeug's debugger.z-rz--reloadrKz(Reload Python process if modules change.rz1No application supplied, or too much. See --help r:z 127.0.0.1r ir>)NN)optparseutilsrO OptionParser add_option parse_argsrRryr2rTstdoutrexitrNr)rKrL) rWrOparseroptionsrr:r rRrrrrmain'sN        r`__main__)Br9iorrrrTrrr_compatrrrrZ _internalr exceptionsr urlsr r r socketserverZ http.serverrrr SocketServerBaseHTTPServerrfobjectrrThreadingMixInrr0rr rrir*rCrLrConnectionError RawIOBaserr:BaseRequestHandlerrrrrrrrrrr,r.r5rrNrAr`rrrrr%s                 5S)*   Y   5