B @\5@sdZddlmZmZmZmZddlZeeZ ddl m Z m Z m Z ddlmZddlmZddlmZdd lmZdd lmZd ZGd d d eZGdddee ZGdddee ZdS)a Provide the ``Application`` class. Application instances are factories for creating new Bokeh Documents. When a Bokeh server session is initiated, the Bokeh server asks the Application for a new Document to service the session. To do this, the Application first creates a new empty Document, then it passes this new Document to the ``modify_document`` method of each of its handlers. When all handlers have updated the Document, it is used to service the user session. )absolute_importdivisionprint_functionunicode_literalsN)ABCMetaabstractmethodabstractproperty)gen)Document)settings)with_metaclass)yield_for_all_futures) Application ServerContextSessionContextc@seZdZdZdZddZeddZeddZed d Z ed d Z d dZ ddZ ddZ ddZddZejddZejddZdS)rz: An Application is a factory for Document instances. TcOsR|dd}|r$td|dd|_g|_||_x|D]}||qsz+Application.safe_to_fork..)allr)rrrrr"~szApplication.safe_to_forkcCs|jS)zI Path to any (optional) static resources specified by handlers. )r)rrrr static_pathszApplication.static_pathcCsj|j|tdd|jD}|dt|dkrHtdt|nt|dkr`||_ nd|_ dS)z Add a handler to the pipeline used to initialize new documents. Args: handler (Handler) : a handler for this Application to use to process Documents css|]}|VqdS)N)r')r#rrrrr%sz"Application.add..Nz/More than one static path requested for app: %r) rappendsetrdiscardlen RuntimeErrorlistrr)rr$Z static_pathsrrrrs     zApplication.addcCst}|||S)zO Creates and initializes a document using the Application's handlers. )r initialize_document)rdocrrrcreate_documents zApplication.create_documentcCsHx2|jD](}|||jrtd||j|jqWtrD|dS)zD Fills in a new document using the Application's handlers. z,Error running application handler %r: %s %s N) rZmodify_documentZfailedlogerrorZ error_detailr Zperform_document_validationZvalidate)rr0rrrrr/s   zApplication.initialize_documentcCsx|jD]}||qWdS)z Invoked to execute code when a new session is created. This method calls ``on_server_loaded`` on each handler, in order, with the server context passed as the only argument. N)ron_server_loaded)rserver_contextrrrrr4s zApplication.on_server_loadedcCsx|jD]}||qWdS)a{ Invoked to execute code when the server cleanly exits. (Before stopping the server's ``IOLoop``.) This method calls ``on_server_unloaded`` on each handler, in order, with the server context passed as the only argument. .. warning:: In practice this code may not run, since servers are often killed by a signal. N)ron_server_unloaded)rr5rrrrr6s zApplication.on_server_unloadedccs2x"|jD]}||}t|VqWtddS)a7 Invoked to execute code when a new session is created. This method calls ``on_session_created`` on each handler, in order, with the session context passed as the only argument. May return a ``Future`` which will delay session creation until the ``Future`` completes. N)ron_session_createdrr Return)rsession_contextrresultrrrr7s  zApplication.on_session_createdccs2x"|jD]}||}t|VqWtddS)a Invoked to execute code when a session is destroyed. This method calls ``on_session_destroyed`` on each handler, in order, with the session context passed as the only argument. Afterwards, ``session_context.destroyed`` will be ``True``. N)ron_session_destroyedrr r8)rr9rr:rrrr;s  z Application.on_session_destroyedN)__name__ __module__ __qualname____doc__Z_is_a_bokeh_application_classr propertyrrr"r'rr1r/r4r6r coroutiner7r;rrrrr=s(     rc@sdeZdZdZeddZeddZeddZedd Z ed d Z ed d Z eddZ dS)rz A harness for server-specific information and tasks related to collections of Bokeh sessions. *This base class is probably not of interest to general users.* cCsdS)zx ``SessionContext`` instances belonging to this application. *Subclasses must implement this method.* Nr)rrrrsessionsszServerContext.sessionscCsdS)a Add a callback to be run on the next tick of the event loop. *Subclasses must implement this method.* Args: callback (callable) : a callback to add The callback will execute on the next tick of the event loop, and should have the form ``def callback()`` (i.e. it should not accept any arguments) Returns: an ID that can be used with ``remove_next_tick_callback``. Nr)rcallbackrrradd_next_tick_callbacksz$ServerContext.add_next_tick_callbackcCsdS)aX Add a callback to be run periodically until it is removed. *Subclasses must implement this method.* Args: callback (callable) : a callback to add The callback will execute periodically on the event loop as specified, and should have the form ``def callback()`` (i.e. it should not accept any arguments) period_milliseconds (int) : number of milliseconds to wait between executing the callback. Returns: an ID that can be used with ``remove_periodic_callback``. Nr)rrCZperiod_millisecondsrrradd_periodic_callbacksz#ServerContext.add_periodic_callbackcCsdS)a^ Add a callback to be run once after timeout_milliseconds. *Subclasses must implement this method.* Args: callback (callable) : a callback to add The callback will execute once on the event loop after the timeout has passed, and should have the form ``def callback()`` (i.e. it should not accept any arguments) timeout_milliseconds (int) : number of milliseconds to wait before executing the callback. Returns: an ID that can be used with ``remove_timeout_callback``. Nr)rrCZtimeout_millisecondsrrradd_timeout_callback/sz"ServerContext.add_timeout_callbackcCsdS)z Remove a callback added with ``add_next_tick_callback``, before it runs. *Subclasses must implement this method.* Args: callback_id : the ID returned from ``add_next_tick_callback`` Nr)r callback_idrrrremove_next_tick_callbackEs z'ServerContext.remove_next_tick_callbackcCsdS)z Removes a callback added with ``add_periodic_callback``. *Subclasses must implement this method.* Args: callback_id : the ID returned from ``add_periodic_callback`` Nr)rrGrrrremove_periodic_callbackRs z&ServerContext.remove_periodic_callbackcCsdS)z Remove a callback added with ``add_timeout_callback``, before it runs. *Subclasses must implement this method.* Args: callback_id : the ID returned from ``add_timeout_callback`` Nr)rrGrrrremove_timeout_callback^s z%ServerContext.remove_timeout_callbackN) r<r=r>r?rrBrrDrErFrHrIrJrrrrrs    rc@sHeZdZdZddZeddZeddZedd Z e d d Z d S) rz A harness for server-specific information and tasks related to Bokeh sessions. *This base class is probably not of interest to general users.* cCs||_||_dS)z N)_server_context_id)rr5Z session_idrrrr sszSessionContext.__init__cCsdS)z If ``True``, the session has been discarded and cannot be used. A new session with the same ID could be created later but this instance will not come back to life. Nr)rrrr destroyed|szSessionContext.destroyedcCs|jS)zF The unique ID for the session associated with this context. )rL)rrrridszSessionContext.idcCs|jS)z6 The server context for this session context )rK)rrrrr5szSessionContext.server_contextcCsdS)a Runs a function with the document lock held, passing the document to the function. *Subclasses must implement this method.* Args: func (callable): function that takes a single parameter (the Document) and returns ``None`` or a ``Future`` Returns: a ``Future`` containing the result of the function Nr)rfuncrrrwith_locked_documentsz#SessionContext.with_locked_documentN) r<r=r>r?r rrMr@rNr5rrPrrrrrks   r)r?Z __future__rrrrZloggingZ getLoggerr<r2abcrrrZtornador Zdocumentr r Z util.futurer Z util.tornador__all__objectrrrrrrrs       5z