o q>e@sdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl mZddl mZddlmZddlmZdd lmZdd lmZd d lmZd d lmZd dlmZd dlmZzddlZWneyGdddZeZYnwdZ ej!dkrze"dWn eydZ Ynwe#edZ$e$rej%Z%nGdddZ%zej&Z'Wn e(ydZ'YnwdZ)e j*e j+de j,e-e j*e-fe j.dfZ/e j0rddl1m2Z2ddl1m3Z3ddl4m5Z5ddl6m7Z7Gd d!d!ej8Z9Gd"d#d#eZ:dpd(d)Z; dqdrd-d.Z< dsdtd2d3Z=dud4d5Z> dsdvd:d;Z?dqdwd?d@Z@dxdDdEZAdydHdIZBdzdJdKZCGdLdMdMeZDGdNdOdOejEeDZFGdPdQdQe%eDZG     d{d|d\d]ZHd}d^d_ZI      `     d~ddndoZJdS)aA 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 ) annotationsN)datetime) timedelta)timezone)BaseHTTPRequestHandler) HTTPServer)unquote)urlsplit_log)_wsgi_encoding_dance)InternalServerError) uri_to_iric@seZdZdddZdS) _SslDummynamestrreturnt.AnycCstd)NzUSSL is unavailable because this Python runtime was not compiled with SSL/TLS support.) RuntimeErrorselfrrQ/var/www/bmteknikk.ddns.net/venv/lib/python3.10/site-packages/werkzeug/serving.py __getattr__*sz_SslDummy.__getattr__Nrrrr)__name__ __module__ __qualname__rrrrrr)srTntcoloramaFforkc@s eZdZdS) ForkingMixInN)rrrrrrrr"@sr"ssl.SSLContextadhoc)WSGIApplication)WSGIEnvironment)RSAPrivateKeyWithSerialization) Certificatec@s8eZdZdZdddZdd d Zdd d ZdddZdS)DechunkedInputz8An input stream that handles Transfer-Encoding 'chunked'rfile t.IO[bytes]rNonecCs||_d|_d|_dS)NFr)_rfile_done_len)rr+rrr__init__[s zDechunkedInput.__init__boolcCdS)NTrrrrrreadable`szDechunkedInput.readableintc CsZz|jd}t|d}Wnty"}ztd|d}~ww|dkr+td|S)Nlatin1zInvalid chunk headerrz!Negative chunk length not allowed)r.readlinedecoder6strip ValueErrorOSError)rliner0errrread_chunk_lencs zDechunkedInput.read_chunk_lenbuf bytearraycCsd}|js|t|kr|jdkr||_|jdkrd|_|jdkrgtt||j}||t|krP|jt||||d<|jt||8_t|}n|j|||||<|j|8_||7}|jdkry|j}|dvrytd|js|t|ks |S)NrT)   z!Missing chunk terminating newline) r/lenr0r@minr.readr9r=)rrArHn terminatorrrrreadintoms*       $zDechunkedInput.readintoN)r+r,rr-rr2rr6)rArBrr6)rrr__doc__r1r5r@rKrrrrr*Xs     r*cseZdZUdZded<ed7ddZd8d d Zd9d d Zd9fdd Z d:d;ddZ d<fdd Z d7ddZ d=ddZ ed d!ged"ed#d$DZd%eed&<d>d?d+d,Zd@d/d0Zd@d1d2ZdAd5d6ZZS)BWSGIRequestHandlerz3A request handler that implements WSGI dispatching.BaseWSGIServerserverrrcCs|jjSN)rQ_server_versionr4rrrserver_versionsz!WSGIRequestHandler.server_versionr'cCsNt|j}|jjdur dnd}|jsd|_n t|jtr"|jdf|_|js2|jr2d|j|j}n|j}t |}iddd|d |j d t j d |jj d |jjd dd|jd|jd|jdddt|dt|jdt|jdt|jd|d||jjdt|jjd|jd}|jD]1\}}d|vrq|dd}|dd}|dvrd |}||vr||d!|}|||<q|d"dd#krd$|d%<t|d |d <|jr|jr|j|d&<z|jj d$d'}|durt!"||d(<W|SW|St#y|j$d)d*Y|St%y&Y|Sw)+Nhttphttps)rr/z wsgi.version)r rzwsgi.url_schemez wsgi.inputz wsgi.errorszwsgi.multithreadzwsgi.multiprocessz wsgi.run_onceFzwerkzeug.socketSERVER_SOFTWAREREQUEST_METHOD SCRIPT_NAME PATH_INFO QUERY_STRING REQUEST_URIRAW_URI REMOTE_ADDR REMOTE_PORTr ) SERVER_NAME SERVER_PORTSERVER_PROTOCOL_-z ) CONTENT_TYPECONTENT_LENGTHHTTP_,HTTP_TRANSFER_ENCODINGchunkedTzwsgi.input_terminated HTTP_HOST) binary_formSSL_CLIENT_CERTerrorz&Cannot fetch SSL peer certificate info)&r pathrQ ssl_contextclient_address isinstancerschemenetlocrr+sysstderr multithread multiprocess connectionrTcommandr queryaddress_string port_integerserver_addressrequest_versionheadersitemsupperreplacegetr;lowerr* getpeercertsslDER_cert_to_PEM_certr<logAttributeError)r request_url url_scheme path_infoenvironkeyvalue peer_certrrr make_environs                   zWSGIRequestHandler.make_environr-c sxjdddkrjd_ddddddfd d dfd d dfdd }z |jj WdSt t j fyl}z  |WYd}~dSd}~wty}zDjjrxdurrd_zdurdd|tWn tyYnwddlm}||}jdd|WYd}~dSd}~ww)NExpectr\z 100-continuesHTTP/1.1 100 Continue Fdatabytesrr-cstdusJddusJddurz dd\}}Wnty0d}}Ynwt|}||t}D]\}}||||q@d|vsxddksxd|krfdksxn|d vsxjd krxd d d dd t |t sJd|rrj tt|ddj dj |rj dj dS)Nzwrite() before start_responser r\zcontent-lengthrZHEADd>0HTTP/1.1TzTransfer-Encodingrm Connectionclosezapplications must write bytesrD)splitr<r6 send_responseset send_headeraddrprotocol_version end_headersrurwfilewritehexrFencodeflush)rcode_strmsgcode header_keysrr)chunk_responser headers_sent headers_setr status_sent status_setrrrsD            z*WSGIRequestHandler.run_wsgi..writecsB|rzr|d|dWd}n d}wrtd||S)Nr rzHeaders already set)with_tracebackAssertionError)statusrexc_info)rrrrrrstart_response4s z3WSGIRequestHandler.run_wsgi..start_responseappr&c sX|}z`|D]}|qsdrjdWt}|jtjd}d}|jddrUj d}|t |7}|d7}|rN|dksN|d krOn|jdds4| t |d rd| dSdSt}|jtjd}d}|jddrj d}|t |7}|d7}|r|dks|d krn|jdds|| t |d r| ww) Ns0 rg{Gz?)timeoutir ld( ir) rr selectorsDefaultSelectorregisterr| EVENT_READselectr+rHrFrhasattr)rapplication_iterrselector total_size total_reads)rrrrrrrrexecuteBsN               z,WSGIRequestHandler.run_wsgi..executeTr )DebugTracebackrqzError on request: )rrrr-rR)rr&rr-)rrrr;rrrrrQrConnectionErrorsocketrconnection_dropped Exceptionpassthrough_errorsclose_connectionr debug.tbtoolsrrender_traceback_textr)rrr?rrr) rrrrrrrrrrrun_wsgisD 9'    "zWSGIRequestHandler.run_wsgic sztWdSttjfy#}z ||WYd}~dSd}~wtyG}z|jjdur;t |r;| d|nWYd}~dSd}~ww)z/Handles a request ignoring dropped connections.NzSSL error occurred: %s) superhandlerrrrrrQrs is_ssl_error log_error)rr? __class__rrrszWSGIRequestHandler.handleNrq BaseExceptionrWSGIEnvironment | NonecCr3)z`Called if the connection was closed by the client. By default nothing happens. Nr)rrqrrrrrsz%WSGIRequestHandler.connection_droppedrrcs|dr|jStt|S)Ndo_) startswithrgetattrrrrrrrs  zWSGIRequestHandler.__getattr__cCs*t|ddr |jdS|jsdS|jdS)NrrarWr)rrrtr4rrrrs   z!WSGIRequestHandler.address_stringr6cCs |jdS)Nr )rtr4rrrrs zWSGIRequestHandler.port_integercCsi|] }|d|dqS)z\x02xr).0crrr szWSGIRequestHandler. z\\\rgr int | strsizecCszt|j}|jd|d|j}Wn ty|j}Ynw||j}t|}|ddkr6t |d}n8|dkr;n3|dkrEt |d}n)|ddkrQt |d }n|d kr[t |d }n|dd krht |dd }nt |dd}| dd|||dS)N r1bold200304cyan3green404yellow4redmagentainfoz "%s" %s %s) rrrr}rr requestline translate_control_char_tabler _ansi_styler)rrrrrrrrr log_requests,            zWSGIRequestHandler.log_requestformatargscG|jd|g|RdS)NrqrrrrrrrrzWSGIRequestHandler.log_errorcGr)Nrrrrrr log_messagerzWSGIRequestHandler.log_messagetypemessagecGs0t||d|d|dg|RdS)Nz - - [z]  )r rlog_date_time_stringrrrrrrrrs  zWSGIRequestHandler.log)rr)rr'rr-rR)rqrrrrr-rrM)rgrg)rrrrrr-)rrrrrr-rrrrrrrr-)rrrrN__annotations__propertyrTrrrrrrrr maketransrangerordrrrr __classcell__rrrrrOs,    Q       rOrrstylesrcGsBts|Sddddddd}|D] }d||d |}q|d S) Nr r!#$)rrrrrrz[mz)_log_add_style)rrcodesstylerrrrs  rcn str | None2tuple[Certificate, RSAPrivateKeyWithSerialization]c Cs4z ddlm}ddlm}ddlm}ddlm}ddlm }Wn t y,t ddw|}|j dd |d }|dur>d }| ||jd ||j|g}|}|||||ttjttjtd dj||j gddj|!|"|gdd#||$|} | |fS)Nr)x509)NameOID)default_backend)hashes)rsaz General -> AirDrop & Handoff.r r%T) server_siderz Werkzeug/werkzeug)3rOvarsrzr{rrJrqrrrwaddress_familyrr6r|rnrorrarrexistsunlinkrr1 server_bindserver_activater= server_closeprintstrerrorrxryerrno EADDRINUSEplatformexitrrfromfdrrrrutuplercrg wrap_socketrsimportlib.metadatametadataversionrS) rrJrqrrrrsrrrr? importlibrrrr1sz             zBaseWSGIServer.__init__rrrrcGst||g|RdSrRr rrrrr!szBaseWSGIServer.log? poll_intervalfloatcsNz!z tj|dWn tyYnwW|dSW|dS|w)N)r)r serve_foreverKeyboardInterruptr)rrrrrr$s  zBaseWSGIServer.serve_foreverrequestrtrycs|jrt||SrR)rr handle_error)rrrtrrrr,szBaseWSGIServer.handle_errorcCsd}t|dd}|g}|jtkr|d|jnW|jdur!dnd}|j}|jdvrX|d |jd |jd krBd }ttj}nd }ttj }|d|d|d|j d|vrbd|d}|d|d|d|j t dd |dS)z::0.0.0.0z * Running on all addresses ()rrz[::1]rzrs[]rr) rrr|appendrJrsrrrvrtrqr join)r dev_warningmessagesrvdisplay_hostname localhostrrr log_startup4s(       zBaseWSGIServer.log_startup)NFNN)rJrrqr6rr&rrrr2rsrrrirr-r )r)rrrr-)rrrtryrr-r)rrrrNrzr{ LISTEN_QUEUErequest_queue_sizeallow_reuse_addressr1rrrrrrrrrrPs grPc@seZdZdZdZdZdS)ThreadedWSGIServerzA WSGI server that handles concurrent requests in separate threads. Use :func:`make_server` to create a server instance. TN)rrrrNrzdaemon_threadsrrrrrWsrcs2eZdZdZdZ     ddfdd ZZS)ForkingWSGIServerzA WSGI server that handles concurrent requests in separate forked processes. Use :func:`make_server` to create a server instance. T(NFrJrrqr6rr& processesrrrr2rsrrrirr-c s.tstdt|||||||||_dS)Nz'Your platform does not support forking.)can_forkr<rr1 max_children) rrJrqrrrrrsrrrrr1ks  zForkingWSGIServer.__init__)rNFNN)rJrrqr6rr&rr6rrrr2rsrrrirr-)rrrrNr{r1rrrrrrbsrrr&threadedrrequest_handlerrrrsrrc Csd|r |dkr td|rt|||||||dS|dkr't||||||||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. r z4Cannot have a multi-thread and multi-process server.r)r<rrrP) rJrqrrrrrrsrrrr make_server}s(  rcCstjddkS)zqCheck if the server is running as a subprocess within the Werkzeug reloader. .. versionadded:: 0.10 WERKZEUG_RUN_MAINtrue)rarrrrrris_running_from_reloadersrautohostname application use_reloader use_debugger use_evalex extra_filest.Iterable[str] | Noneexclude_patternsreloader_interval reloader_type static_files'dict[str, str | tuple[str, str]] | Noner-c Cst|ts td| rddlm}||| }|r$ddlm}|||d}ts*d}nttj d}t |||| | | |||d }|j d t |tj d<ts\|td td d |r{dd lm}z||j|||| dW|dS|w|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 server 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)evalexNWERKZEUG_SERVER_FDrTrzPress CTRL+C to quitr)run_with_reloader)rrintervalr)rur6r-middleware.shared_datardebugrrrarrrset_inheritablerfilenorr r _reloaderrrr)rrqrrrrrrrrrrrrrrsrrrsrvrrrr run_simplesN p       r)rrrrrrrR)rrrr)NN)rIrrJrrrrrK)rr$)rZrr[rrhrirr$)rqrmrr2)rJrrqr6rrr)rJrrqr6rxrrrry)rxrrrr)Fr NFNN)rJrrqr6rr&rr2rr6rrrr2rsrrrirrPrL) FFTNNr rFr NNFN)"rrrqr6rr&rr2rr2rr2rrrrrr6rrrr2rr6rrrrrr2rsrrr-)KrN __future__rriorarr socketserverrxtypingrnrr:rr http.serverrr urllib.parserr _internalr r exceptionsrurlsrrr,rrr __import__rrr"rur|rrOptionalUnionTuplerLiteral_TSSLContextArg TYPE_CHECKING_typeshed.wsgir&r'-cryptography.hazmat.primitives.asymmetric.rsar(cryptography.x509r) RawIOBaser*rOrrHr]rgrcrrwrrrPThreadingMixInrrrrrrrrrs                     $    > G / ,   )  -