B iSIZ| @sbdZddlmZddlZddlZddlZddlZddlZeedZ y ddl Z Wne k rfdZ YnXy ddl Z Wn*e k rGddde ZeZ YnXddZyddlZdd lmZmZWn,e k rddlZdd lmZmZYnXejZe rejZnGd d d e ZddlZdd lmZdd lmZmZmZmZddl m!Z!m"Z"ddl#m$Z$dZ%e oreedZ&Gdddej'Z(Gdddee Z)e)Z*d;ddZ+dd d!Z0d"d#Z1d$d%Z2Gd&d'd'ee Z3Gd(d)d)ee3Z4Gd*d+d+ee3Z5d?d.d/Z6d0d1Z7d@d4d5Z8d6d7Z9d8d9Z:e;d:kr^e:dS)Aa} 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: (c) 2014 by the Werkzeug Team, see AUTHORS for more details. :license: BSD, see LICENSE for more details. )with_statementNforkc@seZdZddZdS) _SslDummycCs tddS)NzSSL support unavailable) RuntimeError)selfnamer/lib/python3.7/site-packages/werkzeug/serving.py __getattr__;sz_SslDummy.__getattr__N)__name__ __module__ __qualname__r rrrr r:srcCs6yddlm}Wntk r,tdYnX|SdS)Nr)cryptoz9Using ad-hoc certificates requires the pyOpenSSL library.)OpenSSLr ImportError TypeError)rrrr _get_openssl_crypto_module@s r) HTTPServerBaseHTTPRequestHandlerc@s eZdZdS) ForkingMixInN)r r r rrrr rVsr)_log)PY2WINreraisewsgi_encoding_dance) url_parse url_unquote)InternalServerErrorfromfdc@s0eZdZdZddZddZddZdd Zd S) DechunkedInputz8An input stream that handles Transfer-Encoding 'chunked'cCs||_d|_d|_dS)NFr)_rfile_done_len)rrfilerrr __init__hszDechunkedInput.__init__cCsdS)NTr)rrrr readablemszDechunkedInput.readablecCsTy"|jd}t|d}Wntk r>tdYnX|dkrPtd|S)Nlatin1zInvalid chunk headerrz!Negative chunk length not allowed)r!readlinedecodeintstrip ValueErrorIOError)rliner#rrr read_chunk_lenpszDechunkedInput.read_chunk_lencCsd}x|js|t|kr|jdkr,||_|jdkrjD]0\}}|d d }|d krd|}|||<qW|dddkrd|d<t|d|d<|jr"|jr"|j|d<|S)Ncs dj_dS)NT)servershutdown_signalr)rrr shutdown_serversz8WSGIRequestHandler.make_environ..shutdown_serverhttphttps)rFrrC)z wsgi.versionzwsgi.url_schemez wsgi.inputz wsgi.errorszwsgi.multithreadzwsgi.multiprocessz wsgi.run_oncezwerkzeug.server.shutdownZSERVER_SOFTWAREREQUEST_METHODZ SCRIPT_NAMEZ PATH_INFOZ QUERY_STRING REMOTE_ADDRZ REMOTE_PORTZ SERVER_NAMEZ SERVER_PORTZSERVER_PROTOCOL-_)Z CONTENT_TYPEZCONTENT_LENGTHZHTTP_ZHTTP_TRANSFER_ENCODINGZchunkedTzwsgi.input_terminatedz wsgi.inputZ HTTP_HOST)rpathr> ssl_contextrr$sysstderr multithread multiprocessr=ZcommandrZqueryaddress_string port_integerserver_addressstrrequest_versionheadersitemsupperreplacegetr,lowerr ZschemeZnetloc)rZ request_urlr@Z url_schemeZ path_infoenvironkeyvaluer)rr make_environsB       zWSGIRequestHandler.make_environc s8jdddkr&jd_ggfdddfdd fd d }y|jj Wnt j t j fk r}z |Wdd}~XYn|tk r2jjr҂d d lm}|d d}ysdd=|tWntk rYnXjdd|jYnXdS)NZExpectrDz 100-continuesHTTP/1.1 100 Continue csBs tds\}}dd<y|dd\}}Wntk rX|d}}YnXt|}||t}x.|D]&\}}|||}||qzWd|ksڈddks|dks|dksd _ d d d |krd  d|kr d  t |ts(tdj|jdS)Nzwrite() before start_responserCrDzcontent-lengthrEZHEAD)i0TZ Connectioncloser>ZServerZdateZDatezapplications must write bytes)AssertionErrorsplitr-r+ send_responsesetZ send_headerrYaddclose_connectionversion_stringZdate_time_stringZ end_headers isinstancebyteswfilewriteflush)datastatusresponse_headerscodemsgZ header_keysr[r\)rZ headers_sent headers_setrrr rks6       z*WSGIRequestHandler.run_wsgi..writecs>|rzrt|Wdd}Xn r*td||gdd<S)NzHeaders already set)rra)rnroexc_info)rrrsrkrr start_responses z3WSGIRequestHandler.run_wsgi..start_responsec sN|}z&x|D] }|qWs.dWdt|drD|d}XdS)Nr`)hasattrr`)appZapplication_iterrm)rZrrrurkrr executes     z,WSGIRequestHandler.run_wsgi..executer)get_current_tracebackT)Zignore_system_exceptionserrorzError on request: %s)N)rTrXrYr,rjrkr]rZr>rxsocketr{timeoutconnection_dropped Exceptionpassthrough_errorsZwerkzeug.debug.tbtoolsrzrlogZ plaintext)rryerz tracebackr)rZrrrsrrurkr run_wsgis2       zWSGIRequestHandler.run_wsgic Csd}yt|}WnZtjtjfk rF}z||Wdd}~XYn(tk rl|jjdksft shYnX|jj r~| |S)z/Handles a request ignoring dropped connections.N) rhandler|r{r}r~rr>rJ is_ssl_errorr?initiate_shutdown)rrvrrrr r!szWSGIRequestHandler.handlecCsBttdtj}tjddkr.tt|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. SIGKILLWERKZEUG_RUN_MAINtrueTFN) getattrsignalSIGTERMosrZrXkillgetpidr>Z_BaseServer__shutdown_requestZ_BaseServer__serving)rZsigrrr r/s z$WSGIRequestHandler.initiate_shutdownNcCsdS)z`Called if the connection was closed by the client. By default nothing happens. Nr)rr{rZrrr r~=sz%WSGIRequestHandler.connection_droppedcCs.|j|_|jsd|_n|r*|SdS)zHandle a single HTTP request.rCN)r$r)Zraw_requestlinerfZ parse_requestr)rrrr handle_one_requestBs  z%WSGIRequestHandler.handle_one_requestcCs^|||dkr.||jkr*|j|dp,d}|jdkrZd|j||f}|j|ddS)z3Send the response header and log the response code.NrrDzHTTP/0.9z %s %d %s ascii) log_requestZ responsesrSZprotocol_versionrjrkencode)rrpmessageZhdrrrr rcJs   z WSGIRequestHandler.send_responsecCst|S)N)rrgr,)rrrr rgSsz!WSGIRequestHandler.version_stringcCs$t|ddr|jdS|jdSdS)NrZrFr)rrZclient_address)rrrr rOVs  z!WSGIRequestHandler.address_stringcCs |jdS)NrC)r)rrrr rP\szWSGIRequestHandler.port_integerrGcCs|j}t|}trtj}|ddkr4||dgd}n|ddkrN||dd}nt|dkrd||d d}n^|dd kr~||d d}nD|d kr||d d}n.|ddkr||ddgd}n||ddgd}|dd|||dS)Nr1Zbold)attrs2Zwhite)colorZ304Zcyan3ZgreenZ404Zyellow4Zred)rrZmagentainfoz "%s" %s %s)Z requestlinerR termcolorZcoloredr)rrpsizerqrrrr r_s$    zWSGIRequestHandler.log_requestcGs|jd|dS)Nr{)r{)r)rargsrrr log_errorwszWSGIRequestHandler.log_errorcGs|jd|f|dS)Nr)r)rformatrrrr log_messagezszWSGIRequestHandler.log_messagecGs$t|d||||fdS)Nz%s - - [%s] %s )rrOZlog_date_time_string)rtyperrrrr r}s zWSGIRequestHandler.log)N)N)rGrG)r r r r9propertyr=r]rrrr~rrcrgrOrPrrrrrrrr r:s  -R   r:cCsddlm}t}|dkrd}|}|t|tj|d|d| }||_ d|_ | }d|_ d|_ | }||jd||||d ||fS) Nr)random*i3zDummy CertificatezUntrusted Authorityz Self-SignediZsha256)rrZX509Zset_serial_numberr+rKmaxsizeZgmtime_adj_notBeforeZgmtime_adj_notAfterZ get_subjectZCNOZ get_issuerZPKeyZ generate_keyZTYPE_RSAZ set_pubkeyZsign)cnrrcertZsubjectZissuerpkeyrrr generate_adhoc_ssl_pairs&     rc Csddlm}|dk r d||f}t|d\}}|d}|d}t|d}|||j|WdQRXt|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. r)rNz *.%s/CN=%s)rz.crtz.keywb)rrropenrkdump_certificate FILETYPE_PEMdump_privatekey) base_pathhostrrrr cert_file pkey_filefrrr make_ssl_devcerts    rc Cst}ddl}ddl}t\}}|\}}|\}}|tj||tj|t|| |j |t|| |j |t |t |t ||} | S)z:Generates an adhoc SSL context for the development server.rN)rtempfileatexitrZmkstempregisterrremoverkrrrr`load_ssl_context) rrrrrZ cert_handlerZ pkey_handlerctxrrr generate_adhoc_ssl_contexts      rcCs&|dkrtj}t|}||||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)sslZPROTOCOL_SSLv23 _SSLContextload_cert_chain)rrprotocolrrrr rs  rc@s*eZdZdZddZd ddZddZdS) 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)rrrrr r%sz_SSLContext.__init__NcCs||_|p ||_||_dS)N)rrr)rcertfilekeyfileZpasswordrrr rs z_SSLContext.load_cert_chaincKs tj|f|j|j|jd|S)N)rrZ ssl_version)r wrap_socketrrr)rsockkwargsrrr rs z_SSLContext.wrap_socket)NN)r r r r9r%rrrrrr rs rcCsVtjf}yddlm}||f7}Wntk r6YnX|dkrLtd}t||S)z?Checks if the given error (or the current one) is an SSL error.r)ErrorNrC)rZSSLErrorZ OpenSSL.SSLrrrKrtrh)r{Z exc_typesrrrr rs  rcCsd|krttdrtjStjS)z>Returns AF_INET4 or AF_INET6 depending on where to connect to.:AF_INET6)rwr|rZAF_INET)rportrrr select_ip_versionsrcCsByt|||tjtj}Wntjk r4||fSX|ddS)zSReturns a fully qualified socket address, that can properly used by socket.bindr)r|Z getaddrinfo SOCK_STREAMZSOL_TCPZgaierror)rrfamilyZresrrr get_sockaddr#s   rc@sFeZdZdZdZdZeZdddZddZ dd Z d d Z d d Z dS)BaseWSGIServerz3Simple single-threaded, single-process WSGI server.FNc Cs|dkr t}t|||_|dk r6t||jtj}d}t|t|t ||j|||_ ||_ d|_ ||_ |jd|_|dk r|j||_|j|_|dk r t|trt|}|dkrt}|j} trt| tjst| j| j| j| } |j| dd|_||_nd|_dS)NrFrCZadhocT)Z server_side)r:raddress_familyr|rrrr%rr+rxrr?r getsocknamerr`rQrhtuplerrrrrprotorrJ) rrrrxhandlerrrJfdZ real_sockrrrr r%5s:       zBaseWSGIServer.__init__cGst||f|dS)N)r)rrrrrrr r^szBaseWSGIServer.logcCs>d|_z(yt|Wntk r*YnXWd|XdS)NF)r?r serve_foreverKeyboardInterruptZ server_close)rrrr ras  zBaseWSGIServer.serve_forevercCs|jrt|||S)N)rr handle_error)rZrequestrrrr rjszBaseWSGIServer.handle_errorcCs|j\}}||fS)N)r|Zaccept)rZconrrrr get_requestoszBaseWSGIServer.get_request)NFNN) r r r r9rMrN LISTEN_QUEUEZrequest_queue_sizer%rrrrrrrr r.s ( rc@seZdZdZdZdZdS)ThreadedWSGIServerz"A WSGI server that does threading.TN)r r r r9rMZdaemon_threadsrrrr rtsrc@seZdZdZdZdddZdS) ForkingWSGIServerz A WSGI server that does forking.T(NFc Cs.ts tdt||||||||||_dS)Nz'Your platform does not support forking.)can_forkr-rr%Z max_children) rrrrx processesrrrJrrrr r%s  zForkingWSGIServer.__init__)rNFNN)r r r r9rNr%rrrr r{srFrCc Csj|r|dkrtdnP|r0t|||||||dS|dkrPt||||||||dSt|||||||dSdS)ztCreate a new server instance that is either threaded, or forks or just processes one request after another. rCz5cannot have a multithreaded and multi process server.)rN)r-rrr) rrrxthreadedrrequest_handlerrrJrrrr make_servers       rcCstjddkS)zwChecks if the application is running from within the Werkzeug reloader subprocess. .. versionadded:: 0.10 rr)rrZrXrrrr is_running_from_reloadersrTautoc sFttstd|r,ddlm}||| rFddlm}|| fddf dd}|r.log_startupc shyttjd}Wnttfk r.d}YnXt|d }|dkr\|j|dS)NWERKZEUG_SERVER_FD)r)r+rrZ LookupErrorr-rr|r)rZsrv) applicationrrrrrrrJrrr inners   zrun_simple..innerrrzsCannot bind to a random port with enabled reloader if the Python interpreter does not support socket opening by fd.rCset_inheritableTr)run_with_reloaderN)rhr+rZwerkzeug.debugrZ werkzeug.wsgirrrZrXcan_open_by_fdr-rr|rZ setsockoptZ SOL_SOCKETZ SO_REUSEADDRZbindrrwrrRfilenoZlistenrr`werkzeug._reloaderr)rrr use_reloader use_debuggerZ use_evalexZ extra_filesZreloader_intervalZ reloader_typerrrZ static_filesrrJrrrrsrr) rrrrrrrrJrr run_simples:E              rcOsddlm}|||S)Nr)r)rr)rrrrrr r1s rc Csddl}ddlm}|jdd}|jdddd d |jd d d dddd|jddddddd|\}}d\}}|jr|jd}|d}t|dkr|d}t|dkrt j dt d||d}t |pdt|pd||j|jddS)z:A simple command-line interface for :py:func:`run_simple`.rN) import_stringz,Usage: %prog [options] app_module:app_object)Zusagez-bz--bindaddressz+The hostname:port the app should listen on.)desthelpz-dz--debugr store_trueFzUse Werkzeug's debugger.)ractiondefaultrz-rz--reloadrz(Reload Python process if modules change.)NNrrCz1No application supplied, or too much. See --help z 127.0.0.1i)rrrrr)optparseZwerkzeug.utilsrZ OptionParserZ add_option parse_argsrrbr3rKstdoutrkexitrr+rr) rrparserZoptionsrrrrrxrrr main8s6           r __main__)N)NN)NN)N) NNNFrCNFNN) FFTNrCrFrCNNFN)%s         5k  "   F   %