ó ù2¢\c@srdZddlZddlZddlZddlZddlZyddlmZWn!ek ryddlmZnXddl Z ddl m Z m Z m Z ddl mZddlmZmZddlmZddlmZmZdd lmZd d lmZd „Zd „ZdZdefd„ƒYZdeefd„ƒYZ de efd„ƒYZ!dS(s/Tornado handlers for WebSocket <-> ZMQ sockets.iÿÿÿÿN(turlparse(tgentiolooptweb(tStreamClosedError(tWebSocketHandlertWebSocketClosedError(tSession(t date_defaultt extract_dates(t cast_unicodei(tIPythonHandlercCs |jƒ}t|jdƒƒ}tjd krRg|D]}|jƒ^q7}ntj|dtƒj dƒ}|j d|ƒt |ƒ}d|dg}x-|d D]!}|j |dt |ƒƒq¨Wt jd d |d||Œ}|j d|ƒd j|ƒS( s2serialize a message as a binary blob Header: 4 bytes: number of msg parts (nbufs) as 32b int 4 * nbufs bytes: offset for each buffer as integer as 32b int Offsets are from the start of the buffer, including the header. Returns ------- The message serialized to bytes. tbuffersiitdefaulttutf8iiiÿÿÿÿt!tIt(ii(tcopytlisttpoptsyst version_infottobytestjsontdumpsRtencodetinserttlentappendtstructtpacktjoin(tmsgR txtbmsgtnbufstoffsetstbuft offsets_buf((s8lib/python2.7/site-packages/notebook/base/zmqhandlers.pytserialize_binary_messages " !cCsîtjd|d ƒd}ttjdd||dd|d!ƒƒ}|jd ƒg}x9t|d |dƒD] \}}|j|||!ƒqtWtj|djdƒƒ}t |d ƒ|d = 4 calls this method automatically, raising 403 if it returns False. t*tskip_check_origintHosts>Blocking Cross Origin WebSocket Attempt. Origin: %s, Host: %sN(t allow_originthasattrR?tTruetrequesttheadersR7R,t get_origintlowerRtnetloctallow_origin_pattbooltmatchtFalsetlogtwarning(R9toriginthostt origin_hosttallow((s8lib/python2.7/site-packages/notebook/base/zmqhandlers.pyt check_originus*       cOsdS(smeaningless for websocketsN((R9targstkwargs((s8lib/python2.7/site-packages/notebook/base/zmqhandlers.pyt clear_cookieœscOs–|jjd|jjƒ|jdkr}tjjƒ}|jƒ|_ |j |_ tj |j |jƒ|_ |j jƒntt|ƒj||ŽS(NsOpening websocket %si(RMtdebugRDtpathR:RtIOLooptcurrentttimet last_pingt last_pongtPeriodicCallbackt send_pingt ping_callbackR1tsuperR4topen(R9RTRUtloop((s8lib/python2.7/site-packages/notebook/base/zmqhandlers.pyRb s cCsï|jdkr/|jdk r/|jjƒdStjjƒjƒ}d||j}d||j }|d|j kr©||j kr©|j j d|ƒ|jƒdSy|jdƒWn%ttfk rá|jjƒdSX||_ dS(s'send a ping to keep the websocket aliveNg@@is#WebSocket ping timeout after %i ms.R(t ws_connectionR,R`R2RRYRZR[R]R\R:R=RMRNtclosetpingRR(R9tnowtsince_last_pongtsince_last_ping((s8lib/python2.7/site-packages/notebook/base/zmqhandlers.pyR_®s  "  cCstjjƒjƒ|_dS(N(RRYRZR[R](R9tdata((s8lib/python2.7/site-packages/notebook/base/zmqhandlers.pyton_pongÆsN(t__name__t __module__t__doc__R,R`R\R]tstreamtpropertyR:R=RSRVRbR_Rk(((s8lib/python2.7/site-packages/notebook/base/zmqhandlers.pyR4\s '   tZMQStreamHandlercBs8eZejdkr!d„Zndd„Zd„ZRS(iicOs<|jdkr+tt|ƒj||Žn |jjƒdS(N(RoR,RaRt send_errorRe(R9RTRU((s8lib/python2.7/site-packages/notebook/base/zmqhandlers.pyRrÎscCs’t|tƒr|}n*|jj|ƒ\}}|jj|ƒ}|rU||deZd„Zd„Zejd„ƒZd„Zd„ZRS(cCsdS(spUndo the set_default_headers in IPythonHandler which doesn't make sense for websockets N((R9((s8lib/python2.7/site-packages/notebook/base/zmqhandlers.pytset_default_headers scCsx|jƒdkr4|jjdƒtjdƒ‚n|jdtƒrdt|jdƒƒ|j _ n|jjdƒdS(s¡Run before finishing the GET request Extend this method to add logic that should fire before the websocket finishes completing. s*Couldn't authenticate WebSocket connectioni“t session_idsNo session ID specifiedN( tget_current_userR,RMRNRt HTTPErrort get_argumentRLR Rv(R9((s8lib/python2.7/site-packages/notebook/base/zmqhandlers.pytpre_gets cosG|jƒ}tj|ƒVtt|ƒj||Ž}tj|ƒVdS(N(RŽRt maybe_futureRaRˆR7(R9RTRUtres((s8lib/python2.7/site-packages/notebook/base/zmqhandlers.pyR7"s cCs2|jjd|jjƒtd|jƒ|_dS(Ns$Initializing websocket connection %stconfig(RMRWRDRXRR‘Rv(R9((s8lib/python2.7/site-packages/notebook/base/zmqhandlers.pyt initialize+scCs|jjddƒS(Ntwebsocket_compression_options(R6R7R,(R9((s8lib/python2.7/site-packages/notebook/base/zmqhandlers.pytget_compression_options/s( RlRmR‰RŽRt coroutineR7R’R”(((s8lib/python2.7/site-packages/notebook/base/zmqhandlers.pyRˆ s    ("RntosRRtwarningsRt urllib.parseRt ImportErrorR‡RRRttornado.iostreamRttornado.websocketRRtjupyter_client.sessionRtjupyter_client.jsonutilRR tipython_genutils.py3compatR thandlersR R(R3R8tobjectR4RqRˆ(((s8lib/python2.7/site-packages/notebook/base/zmqhandlers.pyts.        n?