U /eL@sndZddlmZddlZeeZddlZddlZddl Z ddl Z ddl m Z ddl mZmZmZmZmZddlmZddlmZddlmZd d lmZd d lmZd d lm Z m!Z!m"Z"m#Z#d d l$m%Z%d dl&m'Z'ddlm(Z(m)Z)ddl*m+Z+m,Z,er8d dl-m.Z.d dl/m0Z0d dl1m2Z2d dl3m4Z4ddl5m6Z6dZ7GdddZ8Gddde8Z9Gddde'Z:dS)a Provide basic Bokeh server objects that use a Tornado ``HTTPServer`` and ``BokeTornado`` Tornado Application to service Bokeh Server Applications. There are two public classes in this module: :class:`~bokeh.server.server.BaseServer` This is a lightweight class to explicitly coordinate the components needed to run a Bokeh server (A :class:`~bokeh.server.tornado.BokehTornado` instance, and Tornado ``HTTPServer`` and a Tornado ``IOLoop``) :class:`~bokeh.server.server.Server` This higher-level convenience class only needs to be configured with Bokeh :class:`~bokeh.application.application.Application` instances, and will automatically create and coordinate the lower level Tornado components. ) annotationsN) FrameType) TYPE_CHECKINGAnyDictListMapping)version) HTTPServer)IOLoop) __version__) properties)BoolIntNullableString)DEFAULT_SERVER_PORT)Options)(DEFAULT_WEBSOCKET_MAX_MESSAGE_SIZE_BYTES BokehTornado) bind_socketscreate_hosts_allowlist) Application) ModifyDoc)ID) BrowserTarget) ServerSession) BaseServerServerc@seZdZdZdddddddZedd d d Zdd d d Zd9dddddZdd ddZ dd ddZ ddddddZ d:ddd d!d"Z d;ddd$dd%d&d'Z d(Zdd d)d*Zd+d,dd-d.d/Zed0d d1d2Zedd d3d4Zedd d5d6Zedd d7d8ZdS)` module documentation in the standard lib for more details). new (str, optional) : window or tab (default: "tab") If ``new`` is 'tab', then opens a new tab. If ``new`` is 'window', then opens a new window. Returns: None /zapp_path must start with a / localhostNzhttp://:r)view)rHrI) startswith ValueErroraddressportprefixZbokeh.util.browserrN)r+rArHrIZaddress_stringurlrNr,r,r-shows  zBaseServer.showFcCs0|jr dSd|_td|js,|jdddS)NTzShutdown: cleaning upF)r4) _atexit_ranlogdebugr'r5r0r,r,r-r9!s  zBaseServer._atexitzsignal.Signalsr)signumframer%cCs$td|d|j|jjdS)NzReceived signal z, shutting down)r>r)Zadd_callback_from_signalr5)r+rYrZr,r,r-r<*szBaseServer._sigtermintcCs&tdd|jjD}|dS)zQ The configured port number that the server listens on for HTTP requests css$|]}|jtjtjfkr|VqdSNfamilysocketAF_INETAF_INET6.0sockr,r,r- 3sz"BaseServer.port..rnextr(Z_socketsvalues getsocknamer+rdr,r,r-rR/s zBaseServer.portcCs&tdd|jjD}|dS)zM The configured address that the server listens on for HTTP requests css$|]}|jtjtjfkr|VqdSr\r]rbr,r,r-re=sz%BaseServer.address..rrfrjr,r,r-rQ9s zBaseServer.addresscCs|jjS)z> The configured URL prefix to use for all Bokeh server paths. )r*rSr0r,r,r-rSCszBaseServer.prefixcCs|jjS)z5 A path to a Jinja2 template to use for index at "/" )r*indexr0r,r,r-rkHszBaseServer.index)T)N)NrG)__name__ __module__ __qualname____doc__r.propertyr"r2r5r6r?rCrErUrVr9r<rRrQrSrkr,r,r,r-rXs,%   rcsTeZdZdZdddddddfd d Zed d d dZedd ddZZS)r a A high level convenience class to run a Bokeh server. This class can automatically coordinate the three the base level components required to run a Bokeh server: * A Tornado ``IOLoop`` to run the Bokeh server machinery. * a ``BokehTornado`` Tornado application that defines the Bokeh server machinery. * a Tornado ``HTTPServer`` to direct HTTP requests This high level ``Server`` class has some limitations. In particular, it is not possible to set an explicit ``io_loop`` and ``num_procs`` other than 1 at the same time. To do that, it is necessary to use ``BaseServer`` and coordinate the three components above explicitly. .. autoclasstoc:: Nz?Mapping[str, Application | ModifyDoc] | Application | ModifyDocz IOLoop | NonezDict[str, Any] | Nonerr!) applicationsr"http_server_kwargskwargsr%c  stdttft|}|jdkr4|dk r4td|jdkrPtjdkrPtd|dkr\i}| d|j |j rtdd dl }| |jj}|j|j |j|jd ||d <t|j|j\}|_|j|_t|j|j} ztt|f| |j|j|jd |} |jdkr(td d| j Ds(t!dt"| f|} | #|j| $|Wn,t%k rx|D]} | &qbYnX|dkrt'(}t)*|| | dS)a Create a ``Server`` instance. Args: applications (dict[str, Application] or Application or callable) : A mapping from URL paths to Application instances, or a single Application to put at the root URL. The Application is a factory for Documents, with a new Document initialized for each Session. Each application is identified by a path that corresponds to a URL, like "/" or "/myapp" If a single Application is provided, it is mapped to the URL path "/" automatically. As a convenience, a callable may also be provided, in which an Application will be created for it using ``FunctionHandler``. io_loop (IOLoop, optional) : An explicit Tornado ``IOLoop`` to run Bokeh Server code on. If None, ``IOLoop.current()`` will be used (default: None) http_server_kwargs (dict, optional) : Extra arguments passed to ``tornado.httpserver.HTTPServer``. E.g. ``max_buffer_size`` to specify the maximum upload size. More details can be found at: http://www.tornadoweb.org/en/stable/httpserver.html#http-server If None, no extra arguments are passed (default: None) Additionally, the following options may be passed to configure the operation of ``Server``: .. bokeh-options:: _ServerOpts :module: bokeh.server.server Any remaining keyword arguments will be passed as-is to ``BokehTornado``. z8Starting Bokeh server version %s (running on Tornado %s)rNzSetting both num_procs and io_loop in Server is incompatible. Use BaseServer to coordinate an explicit IOLoop and multi-process HTTPServerwin32z&num_procs > 1 not supported on WindowsZxheaderszConfiguring for SSL terminationr)certfilekeyfilepasswordZ ssl_options)extra_websocket_originsrSrkZ websocket_max_message_size_bytescss|]}|jjVqdSr\)Z applicationZ safe_to_fork)rcZ app_contextr,r,r-resz"Server.__init__..ztUser application code has run before attempting to start multiple processes. This is considered an unsafe operation.)+rWinfor tornado_version _ServerOpts num_procs RuntimeErrorsysplatform setdefault use_xheaders ssl_certfilesslcreate_default_contextPurpose CLIENT_AUTHload_cert_chain ssl_keyfile ssl_passwordrrQrR_port_addressrallow_websocket_originrrSrkwebsocket_max_message_sizeallrqrhr1r r2Z add_sockets Exceptioncloser currentsuperr.) r+rqr"rrrsoptsrcontextZsocketsrxr#r$s __class__r,r-r.gsV,      zServer.__init__r[r/cCs|jS)z[ The configured port number that the server listens on for HTTP requests. )rr0r,r,r-rRsz Server.portrDcCs|jS)zW The configured address that the server listens on for HTTP requests. )rr0r,r,r-rQszServer.address)NN) rlrmrnror.rprRrQ __classcell__r,r,rr-r Qsdr c@seZdZUedddZded<eeddZded <ee d dZ ded <ed d dZ ded<eeddZ ded<ee eddZded<edddZded<eeddZded<eeddZded<eeddZded<eeddZded <d!S)"r{ra The number of worker processes to start for the HTTP server. If an explicit ``io_loop`` is also configured, then ``num_procs=1`` is the only compatible value. Use ``BaseServer`` to coordinate an explicit ``IOLoop`` with a multi-process HTTP server. A value of 0 will auto detect number of cores. Note that due to limitations inherent in Tornado, Windows does not support ``num_procs`` values greater than one! In this case consider running multiple Bokeh server instances behind a load balancer. )defaulthelpr[r|zD The address the server should listen on for HTTP requests. )rrDrQzH The port number the server should listen on for HTTP requests. rRrLz9 A URL prefix to use for all Bokeh server paths. r@rSz> A path to a Jinja2 template to use for the index "/" rkz A list of hosts that can connect to the websocket. This is typically required when embedding a Bokeh server app in an external web site using :func:`~bokeh.embed.server_document` or similar. If None, "localhost" is used. zList[str] | NonerFz Whether to have the Bokeh server override the remote IP and URI scheme and protocol for all requests with ``X-Real-Ip``, ``X-Forwarded-For``, ``X-Scheme``, ``X-Forwarded-Proto`` headers (if they are provided). r3rz= The path to a certificate file for SSL termination. rz= The path to a private key file for SSL termination. rz> A password to decrypt the SSL keyfile, if necessary. rz? Set the Tornado ``websocket_max_message_size`` value. rN)rlrmrnrr|__annotations__rrrQrrRrSrkprrrrrrrrrr,r,r,r-r{s   r{);ro __future__rlogging getLoggerrlrWr7r:r_r~typesrtypingrrrrrZtornador rzZtornado.httpserverr Ztornado.ioloopr rLr corerrZcore.propertiesrrrr resourcesrZ util.optionsrrrutilrrZapplication.applicationrZapplication.handlers.functionrZ core.typesrZ util.browserrsessionr__all__rr r{r,r,r,r-s>                z