/usr/local/lib/python3.6/site-packages/werkzeug/__pycache__
Edit: /usr/local/lib/python3.6/site-packages/werkzeug/__pycache__/serving.cpython-36.pyc (30478B)
3
_TBg . @ sZ d Z ddlZddlZddlZddlZddlZddlZddlZddlZ ddl
Z
ddl m Z ddl m
Z
ddl mZ ddlmZ ddlmZ dd lmZ dd
lmZ dd lmZ dd lmZ dd
lmZ ddlmZ y ddlZW n* e k
r G dd dZ e ZY nX dZ ej dkr@y e d W n e k
r> dZ Y nX e!edZ"e"rXej#Z#nG dd dZ#y
ej$Z%W n e&k
r dZ%Y nX dZ'ej( dk oe!edZ)e j*e j+de j,e-e j*e- f d f Z.e j/rddl0Z1dd l2m3Z3 dd l2m4Z4 dd l5m6Z6 dd l7m8Z8 G d!d" d"ej9Z:G d#d$ d$eZ;e-e-e-d%d&d'Z
dd0d1d2Z?d[e-e j*e- e j*e@ dd3d4d5ZAd\e j*eB eCd6d7d8ZDe-e@ejEd9d:d;ZFe-e@ejEe j+e j,e-e@f e-f d<d=d>ZGejEe-d?d@dAZHG dBdC dCeZIG dDdE dEejJeIZKG dFdG dGe#eIZLd]e-e@dHeCe@e j*e jMe; eCe j*e. e j*e@ eIdI
dJdKZNeCd0dLdMZOd^e-e@dHeCeCeCe j*e jPe- e j*e jPe- e@e-eCe@e j*e jMe; e j*e jQe-e j+e-e j,e-e-f f f eCe j*e. ddOdPdQZRe jSe jSddRdSdTZTdd0dUdVZUeVdWkrVeU dS )_a A WSGI and HTTP server for use **during development only**. This
server is convenient to use, but is not designed to be particularly
stable, secure, or efficient. Use a dedicate WSGI server and HTTP
server when deploying to production.
It provides features like interactive debugging and code reloading. Use
``run_simple`` to start the server. Put this in a ``run.py`` script:
.. code-block:: python
from myapp import create_app
from werkzeug import run_simple
N)datetime) timedelta)timezone)BaseHTTPRequestHandler)
HTTPServer )_log)_wsgi_encoding_dance)InternalServerError)
uri_to_iri) url_parse) url_unquotec @ s e Zd ZeejdddZdS ) _SslDummy)namereturnc C s t dd S )NzUSSL is unavailable because this Python runtime was not compiled with SSL/TLS support.) RuntimeError)selfr r 4/tmp/pip-build-0s3hx122/Werkzeug/werkzeug/serving.py __getattr__) s z_SslDummy.__getattr__N)__name__
__module__ __qualname__strtAnyr r r r r r ( s r TntcoloramaFforkc @ s e Zd ZdS ) ForkingMixInN)r r r r r r r r ? s r Windowsfromfdzssl.SSLContextzte.Literal['adhoc'])WSGIApplication)WSGIEnvironment) RSAPrivateKeyWithSerialization) Certificatec @ sR e Zd ZdZeje ddddZedddZ e
dd d
Z e e
d d d
Z
dS )DechunkedInputz8An input stream that handles Transfer-Encoding 'chunked'N)rfiler c C s || _ d| _d| _d S )NFr )_rfile_done_len)r r( r r r __init__\ s zDechunkedInput.__init__)r c C s dS )NTr )r r r r readablea s zDechunkedInput.readablec C sd y"| j j jd}t|j d}W n, tk
rN } ztd|W Y d d }~X nX |dk r`td|S )Nlatin1 zInvalid chunk headerr z!Negative chunk length not allowed)r) readlinedecodeintstrip
ValueErrorOSError)r liner+ er r r read_chunk_lend s z DechunkedInput.read_chunk_len)bufr c C s d}x| j r|t|k r| jdkr.| j | _| jdkr>d| _ | jdkrtt|| j}|| t|kr| jjt|| ||d < | jt|| 8 _t|}n.| jj||||| < | j|8 _||7 }| jdkr| jj }|dkrtdqW |S )Nr T
z!Missing chunk terminating newline)r: r; r< ) r* lenr+ r8 minr) readr0 r5 )r r9 r? n
terminatorr r r readinton s(
zDechunkedInput.readinto)r r r __doc__r ZIObytesr, boolr- r2 r8 bytearrayrB r r r r r' Y s
r' c s: e Zd ZU dZdeedddZddddZd dd
d Z d dd d
Z
d dddZ d*e e
jd d dddZd dddZd+ee
je d dddZed fdd ZedddZedd d Zd,e
jeef e
jeef d d d d!Zee
jd d"d#d$Zee
jd d"d%d&Zeee
jd d'd(d)Z Z S )-WSGIRequestHandlerz3A request handler that implements WSGI dispatching.BaseWSGIServer)r c C s ddl m} d| S )Nr ) __version__z Werkzeug/) rI )r rI r r r server_version s z!WSGIRequestHandler.server_versionr$ c s t j}d d fdd } jjd kr,dnd} js>d _nt jtrV jdf _|j rx|jrxd|j |j }n|j}t |}d | j
t j jj
jjd
| j j jd t|t|jt jt j j j jjd t jjd jd }xl jj D ]^\}}|j jd
d}|jdd }|d kr\d| }||kr\|| d| }|||< qW |j dd j j dkrd|d< t |d |d< |jr|jr|j|d< y* jj dd}|d k rt!j"||d< W n8 t#k
r jj$d d Y n t%k
r Y nX |S )!N)r c s t jddd d j_d S )NzeThe 'environ['werkzeug.server.shutdown']' function is deprecated and will be removed in Werkzeug 2.1. )
stacklevelT)warningswarnservershutdown_signalr )r r r shutdown_server s z8WSGIRequestHandler.make_environ..shutdown_serverhttphttpsr /r FrJ )z wsgi.versionzwsgi.url_schemez
wsgi.inputz wsgi.errorszwsgi.multithreadzwsgi.multiprocessz
wsgi.run_oncezwerkzeug.server.shutdownzwerkzeug.socketZSERVER_SOFTWAREREQUEST_METHODZ SCRIPT_NAMEZ PATH_INFO QUERY_STRINGZ REQUEST_URIZRAW_URI REMOTE_ADDRZ REMOTE_PORTZ SERVER_NAMEZ SERVER_PORTZSERVER_PROTOCOL-_z
CONTENT_TYPECONTENT_LENGTHZHTTP_,ZHTTP_TRANSFER_ENCODINGchunkedTzwsgi.input_terminatedz
wsgi.inputZ HTTP_HOST) binary_formZSSL_CLIENT_CERTerrorz&Cannot fetch SSL peer certificate info)rU r )r r )r\ r] )&r pathrP ssl_contextclient_address
isinstancer schemenetlocr
r( sysstderr multithread multiprocess
connectionrK commandr queryaddress_string port_integerserver_addressrequest_versionheadersitemsupperreplacegetr3 lowerr' getpeercertsslDER_cert_to_PEM_certr4 logAttributeError) r request_urlrR Z
url_schemeZ path_infoenvironkeyvalueZ peer_certr )r r make_environ sn
z WSGIRequestHandler.make_environNc sX j jddj j dkr&jjd j _ d d d d td d fdd dfdd d
d d fd d
}y|j j
W n t t j
fk
r } zj| W Y d d }~X n tk
rR j jr ddlm} |dd}y d krd d |t W n tk
r: Y nX j jdd|j Y nX d S )NZExpectrJ z 100-continues HTTP/1.1 100 Continue
)datar c sP d k st dd k s t dd kr"yjd d\}}W n tk
rd d }}Y nX t|}j|| t }x.D ]&\}}j|| |j }|j| qW d|kp҈ d dkp|dk p|dksd
_ jd d d
|kr jdj
d|krjdj j t
| ts6t djj| jj d S )Nz write() before start_responser rJ zcontent-lengthrW HEAD 0 T
ConnectioncloserP ServerdateDatez applications must write bytes)r r )AssertionErrorsplitr4 r2
send_responsesetZ send_headerrx addclose_connectionversion_stringZdate_time_stringZ end_headersre rD wfilewriteflush)r Zcode_strmsgcodeZ header_keysr r )r headers_sent headers_setr status_sent
status_setr r r s<
z*WSGIRequestHandler.run_wsgi..writec
s@ |r(z r |d j |d W d d }X n r4td| |S )Nr rL zHeaders already set)with_tracebackr )statusrs exc_info)r r r r r r start_response* s z3WSGIRequestHandler.run_wsgi..start_responser# )appr c sJ | }z&x|D ] }| qW s.d W d t |drD|j X d S )N r )hasattrr )r Zapplication_iterr )r r r r r r execute8 s
z,WSGIRequestHandler.run_wsgi..executer )get_current_tracebackT)Zignore_system_exceptionsra zError on request:
%s)N)rs rw rx r3 r r r r rD rP r ConnectionErrorsockettimeoutconnection_dropped Exceptionpassthrough_errorsZ
debug.tbtoolsr r
r| plaintext)r r r7 r tracebackr )r r r r r r r r r run_wsgi s6 $
zWSGIRequestHandler.run_wsgic C s yt j| W nv ttjfk
r@ } z| j| W Y dd}~X nF tk
r } z*| jjdk rrt |rr| j
d| n W Y dd}~X nX | jj r| j dS )z/Handles a request ignoring dropped connections.NzSSL error occurred: %s)
r handler r r r r rP rc is_ssl_error log_errorrQ initiate_shutdown)r r7 r r r r X s zWSGIRequestHandler.handlec C s0 t r$ttdtj}tjtj | d| j_d S )NSIGKILLT) is_running_from_reloadergetattrsignalSIGTERMoskillgetpidrP _BaseServer__shutdown_request)r sigr r r r f s z$WSGIRequestHandler.initiate_shutdown)ra r r c C s dS )z`Called if the connection was closed by the client. By default
nothing happens.
Nr )r ra r r r r r n s z%WSGIRequestHandler.connection_droppedc C s. | j j | _| jsd| _n| j r*| j dS )z Handle a single HTTP request.TN)r( r0 Zraw_requestliner Z
parse_requestr )r r r r handle_one_requestu s
z%WSGIRequestHandler.handle_one_request)r messager c C sf | j | |dkr.|| jkr*| j| d nd}| jdkrb| j d| d| d}| jj|jd dS )z3Send the response header and log the response code.Nr rJ zHTTP/0.9 z
ascii) log_request responsesrr Zprotocol_versionr r encode)r r r hdrr r r r } s
z WSGIRequestHandler.send_responsec s t j j S )N)superr r3 )r ) __class__r r r s z!WSGIRequestHandler.version_stringc C s* t | dd r| jd S | js dS | jd S )Nr rY zr )r r rd )r r r r ro s
z!WSGIRequestHandler.address_stringc C s
| j d S )Nr )rd )r r r r rp s z WSGIRequestHandler.port_integerrZ )r sizer c C s y&t | j}| j d| d| j }W n tk
r@ | j}Y nX t|}tr|d dkrft|d}np|dkrpnf|dkrt|d}nR|d dkrt|d }n:|d
krt|d }n&|d d krt|dd
}n t|dd}| j dd||| d S )Nr r 1boldZ200Z304cyan3greenZ404yellow4redmagentainfoz
"%s" %s %s)
r rb rm rr r} Z requestliner _log_add_style _ansi_styler| )r r r rb r r r r r s*
z WSGIRequestHandler.log_request)formatargsr c G s | j d|f| d S )Nra )r| )r r r r r r r s z WSGIRequestHandler.log_errorc G s | j d|f| d S )Nr )r| )r r r r r r log_message s z WSGIRequestHandler.log_message)typer r r c G s. t || j d| j d| df| d S )Nz - - [z]
)r ro Zlog_date_time_string)r r r r r r r r| s zWSGIRequestHandler.log)N)N)rZ rZ ) r r r rC rP propertyr rK r r r r
BaseExceptionr Optionalr r r2 r r ro rp Unionr r r r r|
__classcell__r r )r r rG s(
Z\ rG )r stylesr c G s> ddddddd}x |D ]}d|| d | } qW | d
S ) Nr ! # $ )r r r r r r z[mz[0mr )r r codesstyler r r r s
r r& r% )cnr c
C s: y@ddl m} ddlm} ddlm} ddlm} ddlm } W n t
k
r^ t dd Y nX | }|j dd |d
}| d krd } |j
|j|jd |j|j| g}| }|j j|j|j|j j|j jtjtjj tjtjt d
d j |j |j gddj |j!|j"| gddj#||j$ |} | |fS )Nr )x509)NameOID)default_backend)hashes)rsaz s
z BaseWSGIServer.serve_forever)requestrd r c s | j r t j||S )N)r r handle_error)r rA rd )r r r rB s zBaseWSGIServer.handle_error)NFNN)r< )r r r rC rj rk LISTEN_QUEUErequest_queue_sizer r2 r r TyperG rE _TSSLContextArgr, r r| floatr> r TuplerB r r r )r r rH s (,
rH c @ s e Zd ZdZdZdZdS )ThreadedWSGIServerz"A WSGI server that does threading.TN)r r r rC rj daemon_threadsr r r r rI s rI c @ sL e Zd ZdZdZd
eedeejej e
e eje eje dd dd Z
dS ) ForkingWSGIServerz A WSGI server that does forking.T( NFr# ) r r r processesr4 r rc r5 r c C s. t s tdtj| ||||||| || _d S )Nz'Your platform does not support forking.)can_forkr4 rH r, max_children) r r r r rM r4 r rc r5 r r r r, s
zForkingWSGIServer.__init__)rL NFNN)r r r rC rk r r2 r r rE rG rE rF r, r r r r rK s *rK r# )
r r r threadedrM request_handlerr rc r5 r c
C sj |r|dkrt dnP|r0t| ||||||dS |dkrPt| |||||||dS t| ||||||dS dS )ztCreate a new server instance that is either threaded, or forks
or just processes one request after another.
r z5cannot have a multithreaded and multi process server.)r5 N)r4 rI rK rH ) r r r rP rM rQ r rc r5 r r r make_server s"
rR c C s t jjddkS )zwChecks if the application is running from within the Werkzeug
reloader subprocess.
.. versionadded:: 0.10
ZWERKZEUG_RUN_MAINtrue)r r rw r r r r r ) s r auto)hostnamer application use_reloader use_debugger
use_evalex extra_filesexclude_patternsreloader_interval
reloader_typerP rM rQ static_filesr rc r c
sx t tstd|r,ddlm} | | |
rFddlm} | |
tjddfdd dd f d
d }|rnt sNd krt rt
d
t }t |}tj|tj
}|jtjtjd |j| |jd t rt|j tjd< |jt | n4|j |tkrNtj t|}t dd| tj | ddl m } |||||| d 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
.. versionchanged:: 2.0
Added ``exclude_patterns`` parameter.
.. 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 exclude_patterns: List of :mod:`fnmatch` patterns to ignore
when running the reloader. For example, ignore cache files that
shouldn't reload when updated.
: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)SharedDataMiddlewareN)sockr c s d}| j tkr tdd nx dkr:td| ttj}n" dkrXtd| ttj}n }d|krpd| d }tdd
d krd nd || j d
d S )Nzp * Running on all addresses.
WARNING: This is a development server. Do not use it in a production deployment.r z' * Running on %s (Press CTRL+C to quit)z0.0.0.0warningz::r []z0 * Running on %s://%s:%d/ (Press CTRL+C to quit)rS rT r )r& r( r r3 r r$ r! r1 )ra Zall_addresses_messageZdisplay_hostname)rU rc r r log_startup s$
z run_simple..log_startup)r c sh yt tjd } W n ttfk
r. d } Y nX t | d }| d kr\|j |j d S )NWERKZEUG_SERVER_FD)r5 )r2 r r LookupErrorr4 rR r r> )r5 Zsrv) rV rU re r r rM rQ rc rP r r inner s"
zrun_simple..innerr zsCannot bind to a random port with enabled reloader if the Python interpreter does not support socket opening by fd.Trf r z Unlinking %s)run_with_reloader)rZ r[ intervalr] )!re r2 r debugr_ Zmiddleware.shared_datar` r r can_open_by_fdr4 r% r. r*
setsockopt
SOL_SOCKET SO_REUSEADDRbindset_inheritabler filenor r listenrC r r( r r r r9 _reloaderri )rU r rV rW rX rY rZ r[ r\ r] rP rM rQ r^ r rc r_ r` rh r7 rq r2 _rwrr ) rV rU re r r rM rQ rc rP r
run_simple2 sL ]
"
rv )r kwargsr c O s* ddl m} tjdtdd || | dS )zRun a process with the reloader. This is not a public API, do
not use this function.
.. deprecated:: 2.0
Will be removed in Werkzeug 2.1.
r )ri zp'run_with_reloader' is a private API, it will no longer be accessible in Werkzeug 2.1. Use 'run_simple' instead.rL )rM N)rt ri rN rO DeprecationWarning)r rw ru r r r ri s ri c C s ddl } ddlm} tdd | jddd }|jd
d d d
d |jddddd |jddddd |jddd |j }d \}}|jr|jjd\}}}t |pdt
|pd ||j |j |j
d dS ) z:A simple command-line interface for :py:func:`run_simple`.r Nr )
import_stringrb z:This CLI is deprecated and will be removed in version 2.1.z;Run the given WSGI application with the development server.F) descriptionZ allow_abbrevz-bz--bindaddressz+The hostname:port the app should listen on.)desthelpz-dz--debug
store_truez7Show the interactive debugger for unhandled exceptions.)actionr} z-rz--reloadz%Reload the process if modules change.rV z8Application to import and serve, in the form module:app.)r} r z 127.0.0.1i )rU r rV rW rX )NN)argparseutilsry r ArgumentParser add_argument
parse_argsr{ partitionrv r2 rV reloadrk )r ry parserr rU r r[ r r r main sB
r __main__)N)r& r% )NN)NN)N)Fr NFNN)
FFTNNr rT Fr NNFN)WrC ior platformr r socketserverrh Ztypingr rN r r r r Z http.serverr r Z _internalr r
exceptionsr
urlsr r r
rz r r r r
__import__r rN r r# r( r} rC systemrl r r rH r rF Z
TYPE_CHECKINGZtyping_extensionsteZ_typeshed.wsgir# r$ Z-cryptography.hazmat.primitives.asymmetric.rsar% Zcryptography.x509r& RawIOBaser' rG r r r r r2 r r rE r
AddressFamilyr% r. r3 rH ThreadingMixInrI rK rE rR r IterableDictrv r ri r r r r r r
s
" > ,
-* "R ,
p :/