o ^i)@sdZddlmZddlZddlZddlZddlZddlZej r%ddl m Z e dZ ejeejfZejejeejfZejejeZejegdfZejdegdfZGdddZGdd d Zdd gZdS) z?Default classes for Comm and CommManager, for usage in IPython.) annotationsN) ZMQStreamCommBaseCommcseZdZdZ          d5d6fdd Z   d7d8ddZd9dd Z d7d:d!d"Z    #d;dd1d2Z d>d3d4Z ZS)?rzClass for communicating between a Frontend and a Kernel Must be subclassed with a publish_msg method implementation which sends comm messages through the iopub channel. commNT target_namestrdata MaybeDictmetadatabuffers BuffersTypecomm_id str | Noneprimarybool target_moduletopic bytes | None _open_data _close_datakwargst.AnyreturnNonec  stjdi| |r |ntj|_||_||_||_|r |nd|j d|_ | r.| ni|_ | r5| ni|_ d|_ d|_d|_|jrN|j|||ddSd|_dS)Nzcomm-asciiTr r r F)super__init__uuiduuid4hexrrrrencoderrr _msg_callback_close_callback_closedopen) selfrr r r rrrrrrr __class__rI/home/ubuntu/hpml_nyu/venv/lib/python3.10/site-packages/comm/base_comm.pyr!s zBaseComm.__init__msg_typekeyscKs d}t|)Nz*publish_msg Comm method is not implemented)NotImplementedError)r(r,r r r r-msgrrr+ publish_msgEszBaseComm.publish_msgcCs<tt|jddWddS1swYdS)ztrigger close on gcT)deletingN) contextlibsuppress Exceptioncloser(rrr+__del__Ps "zBaseComm.__del__cCsv|dur|j}t}|durd}t|||z|jd||||j|jdd|_WdSt y:| |w)z+Open the frontend-side version of this commNz.Comms cannot be opened without a comm_manager. comm_open)r r r rrF) rrget_comm_manager RuntimeError register_commr0rrr&r4unregister_comm)r(r r r comm_managerr/rrr+r'Ys*    z BaseComm.openFr1cCsJ|jrdSd|_|dur|j}|jd|||d|s#t|dSdS)z,Close the frontend-side version of this commNT comm_closer)r&rr0rr9r<)r(r r r r1rrr+r5tszBaseComm.closecCs|jd|||ddS)z8Send a message to the frontend-side version of this commcomm_msgrN)r0)r(r r r rrr+sends  z BaseComm.sendcallbackCommCallback | NonecC ||_dS)zRegister a callback for comm_close Will be called with the `data` of the close message. Call `on_close(None)` to disable an existing callback. N)r%r(rArrr+on_close zBaseComm.on_closecCrC)zRegister a callback for comm_msg Will be called with the `data` of any comm_msg messages. Call `on_msg(None)` to disable an existing callback. N)r$rDrrr+on_msgrFzBaseComm.on_msgr/ MessageTypecCs(td|j||jr||dSdS)zHandle a comm_close messagezhandle_close[%s](%s)N)loggerdebugrr%)r(r/rrr+ handle_closeszBaseComm.handle_closecCs^td|j||jr+ddlm}|}|r|jd|||r-|jddSdSdS)zHandle a comm_msg messagezhandle_msg[%s](%s)r) get_ipython pre_execute post_executeN)rIrJrr$IPythonrLeventstrigger)r(r/rLshellrrr+ handle_msgs   zBaseComm.handle_msg) rNNNNTNNNN)rrr r r r r r rrrrrrrrrr rr rrrr)NNN) r,rr r r r r r r-rrrrr)r r r r r r rr)NNNF) r r r r r r r1rrr)rArBrr)r/rHrr)__name__ __module__ __qualname____doc__rr0r7r'r5r@rErGrKrS __classcell__rrr)r+rs>'    c@sjeZdZdZd%ddZd&d d Zd'd dZd(ddZd)ddZd*ddZ d+ddZ d+d d!Z d+d"d#Z d$S), CommManagerzDDefault CommManager singleton implementation for Comms in the KernelrrcCsi|_i|_dS)N)commstargetsr6rrr+rs zCommManager.__init__rrfCommTargetCallback | strc Cst|tr@|dd}t|dkr:|\}}t||gd}zt||}Wnty9}z d|}t||d}~wwt|d}t t ||j |<dS)aRegister a callable f for a given target name f will be called with two arguments when a comm_open message is received with `target`: - the Comm instance - the `comm_open` message itself. f can be a Python callable or an import string for one. .)fromlistzNo module named Nr) isinstancerrsplitlen __import__getattrAttributeError ImportErrortcastCommTargetCallbackr\) r(rr]partspackageobjmodulee error_msgrrr+register_targets     zCommManager.register_targetrlcCs |j|S)z5Unregister a callable registered with register_target)r\pop)r(rr]rrr+unregister_targets zCommManager.unregister_targetrrcCs|j}||j|<|S)zRegister a new comm)rr[)r(rrrrr+r;s zCommManager.register_commcCs|j|j}dS)z,Unregister a comm, and close its counterpartN)r[rtr)r(rrrr+r<szCommManager.unregister_commrBaseComm | Nonec CsPz|j|WSty'td|ttjr$tdt|j YdSw)zGet a comm with a particular id Returns the comm if found, otherwise None. This will not raise an error, it will log messages if the comm cannot be found. zNo such comm: %szCurrent comms: %sN) r[KeyErrorrIwarning isEnabledForloggingDEBUGrJlistr-)r(rrrr+get_comms    zCommManager.get_commstreamridentr/rHc Csddlm}|d}|d}|d}|j|d}||d|d} || |dur0td |nz|| |WdStyItjd |d d Ynwz| WdStybtjd d d YdSw)zHandler for comm_open messagesr) create_commcontentrrNF)rrrz"No such comm target registered: %sz&Exception opening comm with target: %sTexc_infozqCould not close comm during `comm_open` failure clean-up. The comm may not have been opened yet.) rrr\getr;rIerrorr4r5) r(r~rr/rrrrr]rrrr+r8s6      zCommManager.comm_opencCs\|d}|d}||}|durdSz||WdSty-tjd|ddYdSw)zHandler for comm_msg messagesrrNzException in comm_msg for %sTr)r}rSr4rIrr(r~rr/rrrrrr+r?(s  zCommManager.comm_msgcCsp|d}|d}||}|durdSd|j|_|j|=z||WdSty7tjd|ddYdSw)zHandler for comm_close messagesrrNTzException in comm_close for %sr)r}r[r&rKr4rIrrrrr+r>5s   zCommManager.comm_closeNrT)rrr]r^rr)rrr]rlrrl)rrrr)rrrr)rrrrv)r~rrrr/rHrr) rUrVrWrXrrsrur;r<r}r8r?r>rrrr+rZs        ! rZ)rX __future__rr2rztypingrjr r TYPE_CHECKINGzmq.eventloop.zmqstreamr getLoggerrIDictrAnyrHOptionalr Listbytesr Callable CommCallbackrlrrZ__all__rrrr+s(   (