σ mάJ]c@`sdZddlmZmZmZmZddlZejeƒZ ddl Z ddl m Z ddl mZd Zdefd „ƒYZdS( un Assemble WebSocket wire message fragments into complete Bokeh Server message objects that can be processed. i(tabsolute_importtdivisiontprint_functiontunicode_literalsN(tgeni(tValidationErroruReceivertReceivercB`sqeZdZd„Zejd„ƒZd„Zd„Zd„Z d„Z d„Z d„Z d „Z d „ZRS( uΚ Receive wire message fragments and assemble complete Bokeh server message objects. On ``MessageError`` or ``ValidationError``, the receiver will reset its state and attempt to consume a new message. The *fragment* received can be either bytes or unicode, depending on the transport's semantics (WebSocket allows both). .. 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. cC`s+||_|j|_d|_d|_dS(uί Configure a Receiver with a specific Bokeh protocol version. Args: protocol (Protocol) : A Bokeh protocol object to use to assemble collected message fragments. N(t _protocolt_HEADERt_current_consumertNonet_messaget _buf_header(tselftprotocol((s6lib/python2.7/site-packages/bokeh/protocol/receiver.pyt__init__^s   cC`s#|j|ƒtj|jƒ‚dS(u  Consume individual protocol message fragments. Args: fragment (``JSON``) : A message fragment to assemble. When a complete message is assembled, the receiver state will reset to begin consuming a new message. N(R RtReturnR (R tfragment((s6lib/python2.7/site-packages/bokeh/protocol/receiver.pytconsumeks cC`s;|j|ƒd|_d|_|g|_|j|_dS(N(t _assume_textR R t_partialt _fragmentst _METADATAR (R R((s6lib/python2.7/site-packages/bokeh/protocol/receiver.pyRys     cC`s-|j|ƒ|jj|ƒ|j|_dS(N(RRtappendt_CONTENTR (R R((s6lib/python2.7/site-packages/bokeh/protocol/receiver.pyR€s cC`s\|j|ƒ|jj|ƒ|jd \}}}|jj|||ƒ|_|jƒdS(Ni(RRRRtassembleRt_check_complete(R Rt header_jsont metadata_jsont content_json((s6lib/python2.7/site-packages/bokeh/protocol/receiver.pyR…s  cC`s&|j|ƒ||_|j|_dS(N(RR t_BUFFER_PAYLOADR (R R((s6lib/python2.7/site-packages/bokeh/protocol/receiver.pyt_BUFFER_HEADERs  cC`s1|j|ƒ|jj|j|ƒ|jƒdS(N(t_assume_binaryRtassemble_bufferR R(R R((s6lib/python2.7/site-packages/bokeh/protocol/receiver.pyR”s cC`s7|jjr'|j|_|j|_n |j|_dS(N(RtcompleteR RR R(R ((s6lib/python2.7/site-packages/bokeh/protocol/receiver.pyRšs  cC`s/t|tjƒs+td|jjƒ‚ndS(Nu:expected text fragment but received binary fragment for %s(t isinstancetsixt text_typeRR t__name__(R R((s6lib/python2.7/site-packages/bokeh/protocol/receiver.pyR‘scC`s/t|tjƒs+td|jjƒ‚ndS(Nu:expected binary fragment but received text fragment for %s(R#R$t binary_typeRR R&(R R((s6lib/python2.7/site-packages/bokeh/protocol/receiver.pyR ₯s(R&t __module__t__doc__RRt coroutineRRRRRRRRR (((s6lib/python2.7/site-packages/bokeh/protocol/receiver.pyR1s+       (uReceiver(R)t __future__RRRRtloggingt getLoggerR&tlogR$ttornadoRt exceptionsRt__all__tobjectR(((s6lib/python2.7/site-packages/bokeh/protocol/receiver.pyt s"