σ mάJ]c@`s±dZddlmZmZmZmZddlZejeƒZ ddl m Z m Z ddl mZddljjZddlmZmZd Zd efd „ƒYZdS( uΦ Provide a base class for all Bokeh Server Protocol message types. Boker messages are comprised of a sequence of JSON fragments. Specified as Python JSON-like data, messages have the general form: .. code-block:: python [ # these are required b'{header}', # serialized header dict b'{metadata}', # serialized metadata dict b'{content}, # serialized content dict # these are optional, and come in pairs; header contains num_buffers b'{buf_header}', # serialized buffer header dict b'array' # raw buffer payload data ... ] The ``header`` fragment will have the form: .. code-block:: python header = { # these are required 'msgid' : # a unique id for the message 'msgtype' : # a message type, e.g. 'ACK', 'PATCH-DOC', etc # these are optional 'num_buffers' : # the number of additional buffers, if any } The ``metadata`` fragment may contain any arbitrary information. It is not processed by Bokeh for any purpose, but may be useful for external monitoring or instrumentation tools. The ``content`` fragment is defined by the specific message type. i(tabsolute_importtdivisiontprint_functiontunicode_literalsN(t json_decodet json_encode(tgeni(t MessageErrort ProtocolErroruMessagetMessagecB`s(eZdZd„Zd„Zed„ƒZd„Zd„Ze j e d„ƒZ edd„ƒZe j d„ƒZed „ƒZed „ƒZejd „ƒZed „ƒZed „ƒZejd„ƒZed„ƒZed„ƒZejd„ƒZed„ƒZed„ƒZRS(už The Message base class encapsulates creating, assembling, and validating the integrity of Bokeh Server messages. Additionally, it provide hooks cC`s(||_||_||_g|_dS(u€ Initialize a new message from header, metadata, and content dictionaries. To assemble a message from existing JSON fragments, use the ``assemble`` method. To create new messages with automatically generated headers, use subclass ``create`` methods. Args: header (JSON-like) : metadata (JSON-like) : content (JSON-like) : N(theadertmetadatatcontentt_buffers(tselfR R R ((s5lib/python2.7/site-packages/bokeh/protocol/message.pyt__init__\s   cC`sd|j|j|jfS(Nu$Message %r (revision %d) content: %r(tmsgtypetrevisionR (R((s5lib/python2.7/site-packages/bokeh/protocol/message.pyt__repr__sscC`sΑyt|ƒ}Wntk r/tdƒ‚nXyt|ƒ}Wntk r_tdƒ‚nXyt|ƒ}Wntk rtdƒ‚nX||||ƒ}||_||_||_|S(u Creates a new message, assembled from JSON fragments. Args: header_json (``JSON``) : metadata_json (``JSON``) : content_json (``JSON``) : Returns: Message subclass Raises: MessageError uheader could not be decodedumetadata could not be decodeducontent could not be decoded(Rt ValueErrorRt _header_jsont_metadata_jsont _content_json(tclst header_jsont metadata_jsont content_jsonR R R tmsg((s5lib/python2.7/site-packages/bokeh/protocol/message.pytassemblevs"      cC`sUd|jkr%|jdcd7-s"