-eqQdZddlmZddlZejeZddlZddlZddl Z ddl Z ddl m Z ddl mZmZmZddlmZmZddlmZddlmZd d lmZd d lmZd d lmZm Z m!Z!m"Z"d d l#m$Z$m%Z%d dl&m'Z'ddlm(Z(m)Z)ddl*m+Z+m,Z,erd dl-m.Z.d dl/m0Z0d dl1m2Z2d dl3m4Z4ddl5m6Z6dZ7GddZ8Gdde8Z9Gdde'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. See :ref:`ug_server_introduction` for general information on the Bokeh server. ) annotationsN) FrameType) TYPE_CHECKINGAnyMapping)netutilversion) HTTPServer)IOLoop) __version__) properties)BoolIntNullableString)DEFAULT_SERVER_PORT server_url)Options)(DEFAULT_WEBSOCKET_MAX_MESSAGE_SIZE_BYTES BokehTornado) bind_socketscreate_hosts_allowlist) Application) ModifyDoc)ID) BrowserTarget) ServerSession) BaseServerServerceZdZdZd.d Zed/d Zd0d Zd1d2dZd0dZ d0dZ d3dZ d4d5dZ d6d7d!Z d"Zd0d#Zd8d(Zed9d*Zed:d+Zed;d,Zed:d-ZdS)>>r2N str | Nonelist[ServerSession]c||j|Sg}|jjD]}||j|z } |S)ai Gets all currently active sessions for applications. Args: app_path (str, optional) : The configured application path for the application to return sessions for. If None, return active sessions for all applications. (default: None) Returns: list[ServerSession] )r- get_sessions app_paths)r/rJ all_sessionspaths r0rRzBaseServer.get_sessionss[  =--h77 7,. M+ = =D DM66t<< ` 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)rWrX) startswith ValueErroraddressportprefixbokeh.util.browserr^)r/rJrWrXaddress_stringurlr^s r0showzBaseServer.shows2""3'' =;<< <% < # (:(:!\NKKKKDKKKK++++++ S's++++++r2Fc|jrdSd|_td|js|ddSdS)NTzShutdown: cleaning upF)r8) _atexit_ranlogdebugr*r;r4s r0rCzBaseServer._atexits[    F )***} " II5I ! ! ! ! ! " "r2signumintframeFrameType | Nonecttd|d|j|jjdS)NzReceived signal z, shutting down)rHr,add_callback_from_signalr;)r/rlrns r0rFzBaseServer._sigterm$s< 8888999 ++DJO<<<<z"BaseServer.port..-D  {v~v??? ????  r2rnextr+_socketsvalues getsocknamer/r}s r0rbzBaseServer.port)Y  !Z07799     !!!$$r2ctd|jjD}|dS)zM The configured address that the server listens on for HTTP requests c3XK|]%}|jtjtjfv!|V&dSrurvr{s r0r~z%BaseServer.address..7rr2rrrs r0razBaseServer.address3rr2c|jjS)z> The configured URL prefix to use for all Bokeh server paths. )r-rcr4s r0rczBaseServer.prefix=s}##r2c|jjS)z5 A path to a Jinja2 template to use for index at "/" )r-indexr4s r0rzBaseServer.indexBs}""r2)r#r r$rr%r r&r')r&r )r&r')T)r8r9r&r')rJrKrLrr&rru)rJrOr&rP)NrV)rJrKrWrOrXrr&r')rlrmrnror&r'r&rrr&rOr&rK)__name__ __module__ __qualname____doc__r1propertyr#r7r;r?rIrNrRrgrirCrFrbrarcrr2r0r r Ts"****6X "& D D D D,????"(#,#,#,#,#,JK""""==== %%%X%%%%X%$$$X$###X###r2r cpeZdZdZ ddfd ZeddZeddZeddZxZ S)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. N applications?Mapping[str, Application | ModifyDoc] | Application | ModifyDocr# IOLoop | Nonehttp_server_kwargsdict[str, Any] | Nonekwargsrr&r'c tdtdtdt |}|jdkr|t d|jdkrtjdkrt d|j rtjdkrt d |i}| d |j |j ritd d dl }||jj}||j |j|j ||d<|j rUt)j|j g}|j |_d\|_|_|jrt5|jd} nKg} nHt7|j|j\}|_|j|_t5|j|j} t=|j|j|j du|_ tA|f| |j|j!|j"|j#d|} |jdkr:tId| j%&Ds JdtO| fi|} | (|j| )|n(#tT$r|D]} | +wxYw|tYj-}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``. zStarting Bokeh server version z (running on Tornado )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 Windowsz*Unix sockets are not supported on windows.xheaderszConfiguring for SSL terminationr)certfilekeyfilepassword ssl_optionsNN)extra_websocket_origins absolute_urlrcr websocket_max_message_size_bytesc3.K|]}|jjVdSru) application safe_to_fork)r| app_contexts r0r~z"Server.__init__..s(uuK;2?uuuuuur2ztUser application code has run before attempting to start multiple processes. This is considered an unsafe operation.)0rjinfor tornado_version _ServerOpts num_procs RuntimeErrorsysplatform unix_socket setdefault use_xheaders ssl_certfilesslcreate_default_contextPurpose CLIENT_AUTHload_cert_chain ssl_keyfile ssl_passwordrbind_unix_socket _unix_socket_address_portallow_websocket_originrrrarbr _absolute_urlrrcrwebsocket_max_message_sizeallrrr r7 add_sockets Exceptioncloser currentsuperr1)r/rr#rroptsrcontextsocketsrr$r%s __class__s r0r1zServer.__init___saX f+ffTcfffggg6"" >A  '"5]  >A  #,'"9"9GHH H   M  7 7KLL L  %!# %%j$2CDDD   8 HH6 7 7 7 JJJ001HIIG  # #T->HXcgct # u u u07 } -   e/0@AABG $ 0D (2 %DM4:* -*@A\^b*c*c''*,''".t|TY"G"G GTZ LDM& A path to a Jinja2 template to use for the index "/" rz 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). r9rz= 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)rrrrr__annotations__rrrarrbrrcrpListrrrrrrrrrr2r0rrsS *    I     $8F2   G    /7   D     (x6   K    &+   F    !/   E    08xvN0 0 0     e3   L    (x6   L    'hv5   K     (x6   L    '*c2Zb' ' '       r2r);r __future__rlogging getLoggerrrjrArDrxrtypesrtypingrrrtornadorr rtornado.httpserverr tornado.ioloopr r\r corerrcore.propertiesrrrr resourcesrr util.optionsrrrutilrrapplication.applicationrapplication.handlers.functionr core.typesr util.browserrsessionr__all__r r!rrr2r0rs*#"""""g!! ..........87777777))))))!!!!!!"""""" 87777777""""""KKKKKKKK66666666'555555999999,,,,,,&&&&&&  q#q#q#q#q#q#q#q#n\\\\\Z\\\HB B B B B 'B B B B B r2