MhbdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl m Z mZmZmZmZddlZddlmZmZmZddlmZmZmZmZmZmZmZddlm Z m!Z!d d l"m#Z#d d l$m%Z%e r dd l&m'Z'd d l(m)Z)ee*ee+e*e,ffZ- d:d;d%Z. dd?d1Z0ej1ej2ej3ej2ej2d2Z4d3d4DZ5Gd5d6e Z6Gd7d8e!Z7gd9Z8dS)@zUtilities for connecting to jupyter kernels The :class:`ConnectionFileMixin` class in this module encapsulates the logic related to writing and reading connections files. ) annotationsN)getpass) TYPE_CHECKINGAnyDictUnioncast)jupyter_data_dirjupyter_runtime_dir secure_write)BoolCaselessStrEnumInstanceIntegerTypeUnicodeobserve)LoggingConfigurableSingletonConfigurable) localhost) _filefind)BlockingKernelClientSessiontcp hmac-sha256fname str | None shell_portint iopub_port stdin_porthb_port control_portipstrkeybytes transportsignature_scheme kernel_namekwargsrreturn tuple[str, KernelConnectionInfo]c  l|st}|s+tjd\} }tj| g} g}t |dkt |dkzt |dkzt |dkzt |dkz}|dkrt |D]l}tj}|tj tj d| |df| |m|D]E}| d}|| |Fn{d}t |D]i}tj|d|r)|dz }tj|d|)| ||dz }j|dkr| d}|dkr| d}|dkr| d}|dkr| d}|dkr| d}|||||d}||d<||d <||d <| |d <| |d <|| t'|5}|t+j|d dddn #1swxYwYt/t0drtj|}|rrtj|j}|t0jz}||krD tj||n-#t:$r }|jt<jkr Yd}~nd}~wwxYw||fS)aGenerates a JSON config file, including the selection of random ports. Parameters ---------- fname : unicode The path to the file to write shell_port : int, optional The port to use for ROUTER (shell) channel. iopub_port : int, optional The port to use for the SUB channel. stdin_port : int, optional The port to use for the ROUTER (raw input) channel. control_port : int, optional The port to use for the ROUTER (control) channel. hb_port : int, optional The port to use for the heartbeat REP channel. ip : str, optional The ip address the kernel will bind to. key : str, optional The Session key used for message authentication. signature_scheme : str, optional The scheme used for message authentication. This has the form 'digest-hash', where 'digest' is the scheme used for digests, and 'hash' is the name of the hash function used by the digest scheme. Currently, 'hmac' is the only supported digest scheme, and 'sha256' is the default hash function. kernel_name : str, optional The name of the kernel currently connected to. z.jsonrrr-)r"r$r%r'r&r(r*r,r-r.)indentNS_ISVTX) rtempfilemkstemposcloser#rangesocket setsockopt SOL_SOCKET SO_LINGERbindappend getsocknamepathexistspopdecodeupdater writejsondumpshasattrstatdirnamest_moder7chmodOSErrorerrnoEPERM)r r"r$r%r&r'r(r*r,r-r.r/fdportssockets ports_needed_sockportNcfgf runtime_dir permissionsnew_permissionses V/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/jupyter_client/connect.pywrite_connection_filerc&sl  [[ $W-- E  E#%G J!O jAo    jAo    la  ! gl    E|$$ ! !A=??D OOF-v/? K K K IIr1g    NN4   D##%%a(D JJLLL LL      |$$  A'..B// Q'..B//  LLOOO FAAQYYq\\ QYYq\\ QYYq\\ qyy|| !||))A,,!  $ !!CCICJ C .C$C JJv e  +  3q)))***+++++++++++++++tYgooe,,  '+..6K)DL8O+--H[/::::w%+--  #:s* *K??LL/N N/N**N/ kernel-*.jsonfilenamerDstr | list[str] | Noneprofilec .|tjd|zd|dtg}t|tr|g} t ||S#t $rYnwxYwd|vr|}nd|z}g}|D]G}|tjtj ||Hd|D}|sd |d |}t |t|d kr|d St|d dS)afind a connection file, and return its absolute path. The current working directory and optional search path will be searched for the file if it is not given by absolute path. If the argument does not match an existing file, it will be interpreted as a fileglob, and the matching file in the profile's security dir with the latest access time will be used. Parameters ---------- filename : str The connection file or fileglob to search for. path : str or list of strs[optional] Paths in which to search for connection files. Returns ------- str : The absolute path of the connection file. Nz5Jupyter has no profiles. profile=%s has been ignored.r5) stacklevel.*z*%s*cLg|]!}tj|"S)r:rDabspath).0ms rb z(find_connection_file..s&333arwq!!333rzCould not find z in rrc4tj|jSN)r:rMst_atime)r]s rbz&find_connection_file..sRWQZZ-@r)r*)warningswarnr isinstancer)rrQextendglobr:rDjoinlensorted)rerDrgpatmatchespmsgs rbfind_connection_filersk2 Cg MZ[     |(**+$v 4(((       hxG 88tya!5!5667777337333G F88888cll W  qzg#@#@AAA"EEsA A$#A$connection_infostr | KernelConnectionInfo sshserversshkeytuple[Any, ...]c xddlm}t|trMt |5}t j|}dddn #1swxYwYttttf|}| d}|d|d|d|d|d f}|d }| ||rd } ntd |z} t||D]\} } || | ||||  t!|S) atunnel connections to a kernel via ssh This will open five SSH tunnels from localhost on this machine to the ports associated with the kernel. They can be either direct localhost-localhost tunnels, or if an intermediate server is necessary, the kernel must be listening on a public IP. Parameters ---------- connection_info : dict or str (path) Either a connection dict, or the path to a JSON connection file sshserver : str The ssh sever to use to tunnel to the kernel. Can be a full `user@server:port` string. ssh config aliases are respected. sshkey : str [optional] Path to file containing ssh key to use for authentication. Only necessary if your ssh config does not already associate a keyfile with the host. Returns ------- (shell, iopub, stdin, hb, control) : ints The five ports on localhost that have been forwarded to the kernel. r)tunnelNr"r$r%r&r'r(FzSSH Password for %s: )sshrryr)openrJloadsreadr rrselect_random_portstry_passwordless_sshrzip ssh_tunneltuple) rrrrr]cflportsrports remote_ippasswordlprps rbtunnel_to_kernelrs</3''3 / " " 3a"j22O 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 d38no . .B  ' ' * *F < < < 9  > F4I ""9f55@$2Y>??ff%%JJB"b)YIIII ==s'AA"%A")hbshelliopubstdincontrolcg|]}d|zS)%s_portrm)rochannels rbrqrq:s ^ ^ ^gi'! ^ ^ ^r)rrrrrceZdZUdZeZded<dGdZeddd Ze d Z e d d gd dZ eZ ded<eejZedd ZdGdZeddHdZeddd Zeddd Zeddd Zeddd Zeddd ZdZded<edId!Zed"ZdJd$Z dKdLd(Z!e"e#d)*Z$dMd,Z%dNd-Z&dNd.Z'dNd/Z(dNd0Z)dOd2Z*dPdQd5Z+dRd7Z,dRd8Z-e.dSd;Z/dTd=Z0 dPdUdAZ1dPdVdBZ2dPdVdCZ3dPdVdDZ4dPdVdEZ5dPdVdFZ6dS)WConnectionFileMixinz>Mixin for configurable classes that work with connection filesz str | Unicodedata_dirr0r)ctSrs)r selfs rb_data_dir_defaultz%ConnectionFileMixin._data_dir_defaultBs!!!rrTa:JSON file in which to store connection info [default: kernel-.json] This file will contain the IP, ports, and authentication key needed to connect clients to this kernel. By default, this file will be created in the security dir of the current profile, but can be specified by absolute path. )confighelpFripc) default_valuerr.zSet the kernel's IP address [default localhost]. If the IP address is something other than localhost, then Consoles on other machines will be able to connect to the Kernel, so be careful!c|jdkr6|jr-tj|jddzSdSt S)Nrrz-ipcz kernel-ipc)r,connection_filer:rDsplitextrrs rb _ip_defaultzConnectionFileMixin._ip_default_sL >U " "# $w''(<==a@6II#|;; rr(changerNonec0|ddkr d|_dSdS)Nnewrkz0.0.0.0)r()rrs rb _ip_changedzConnectionFileMixin._ip_changedhs$ %=C  DGGG rrz(set the heartbeat port [default: random]z-set the shell (ROUTER) port [default: random]z*set the iopub (PUB) port [default: random]z-set the stdin (ROUTER) port [default: random]z/set the control (ROUTER) port [default: random]Nzlist[str] | None_random_port_names list[int]c*fdtDS)Nc0g|]}t|Srm)getattr)ronamers rbrqz-ConnectionFileMixin.ports..zs#;;;d##;;;r) port_namesrs`rbrUzConnectionFileMixin.portsxs;;;; ;;;;rzjupyter_client.session.Sessionrc&ddlm}||S)Nrrparent)sessionr)rrs rb_session_defaultz$ConnectionFileMixin._session_defaults'$$$$$$wd####rrboolKernelConnectionInfoc|j|j|j|j|j|j|jd}|r|j|d<n,| |jj |jj d|S)aReturn the connection info as a dict Parameters ---------- session : bool [default: False] If True, return our session object will be included in the connection info. If False (default), the configuration parameters of our session object will be included, rather than the session object itself. Returns ------- connect_info : dict dictionary of connection information. )r,r(r"r$r%r&r'r)r-r*) r,r(r"r$r%r&r'rclonerHr-r*)rrinfos rbget_connection_infoz'ConnectionFileMixin.get_connection_infos '///| -    #l0022DOO KK(, (E<+     rz#jupyter_client.BlockingKernelClient)klassrrc|}||}|||S)z-Make a blocking client connected to my kernelr)rblocking_classload_connection_info)rrbcs rbblocking_clientz#ConnectionFileMixin.blocking_clientsB''))   - - %%% rc|jr;d|_ tj|jdS#tt f$rYdSwxYwdS)z}Cleanup connection file *if we wrote it* Will not raise if the connection file was already removed somehow. FN)_connection_file_writtenr:removerrQAttributeErrorrs rbcleanup_connection_filez+ConnectionFileMixin.cleanup_connection_filesf  ( ,1D )  $./////^,       s+AAc|jdkrdS|jD]3}d|j|fz} tj|$#t $rY0wxYwdS)z#Cleanup ipc files if we wrote them.rNz%s-%i)r,rUr(r:rrQ)rrZipcfiles rbcleanup_ipc_filesz%ConnectionFileMixin.cleanup_ipc_filessw >U " " FJ  D$/G  '""""       s9 AAc|jdkrdS|jdSg|_tD]0}t||dkr|j|1dS)zRecords which of the ports are randomly assigned. Records on first invocation, if the transport is tcp. Does nothing on later invocations.rNr)r,rrrrBrrs rb_record_random_port_namesz-ConnectionFileMixin._record_random_port_namessr >U " " F  " . F"$ 5 5DtT""a'''..t444 5 5rcv|jsdS|jD]}t||d|dS)zForgets randomly assigned port numbers and cleans up the connection file. Does nothing if no port numbers have been randomly assigned. In particular, does nothing unless the transport is tcp. Nr)rsetattrrrs rbcleanup_random_portsz(ConnectionFileMixin.cleanup_random_portssS&  F+ # #D D$ " " " " $$&&&&&rr/c |jr&tj|jrdSt |jf|j|j|jj |j |j |j |j |j|jj|jd |\|_}|t$D]}t'||||d|_dS)z;Write connection info to JSON dict in self.connection_file.N) r,r(r*r%r$r"r&r'r-r.T)rr:rDrErrcr,r(rr*r%r$r"r&r'r-r.rrr)rr/r\rs rbrcz)ConnectionFileMixin.write_connection_files  ( RW^^D>((4!1!1!3!344 &&((( 0 0DtT""a''DDLLdDJ/// D==u+C#s## #jjllc5)) ) ) )"DL   % %,01C,DDL ) ) ) & %rcd}tj|jrt |j5}t j|}dddn #1swxYwY|d|d<|||s!tj |jd|_ nd}|sDtD]}t||d| |||}|||sd}t!|dS)aReconciles the connection information returned from the Provisioner. Because some provisioners (like derivations of LocalProvisioner) may have already written the connection file, this method needs to ensure that, if the connection file exists, its contents match that of what was returned by the provisioner. If the file does exist and its contents do not match, the file will be replaced with the provisioner information (which is considered the truth). If the file does not exist, the connection information in 'info' is loaded into the KernelManager and written to the file. FNr*TrzwKernelManager's connection information already exists and does not match the expected values returned from provisioner!)r:rDrErrrJrr_equal_connectionsrrrrrrcr ValueError)rr file_existsr] file_inforkm_infors rb_reconcile_connection_infoz.ConnectionFileMixin._reconcile_connection_info8s " 7>>$. / / #d*++ )q IaLL  ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) )/6688Ie **4;; # $.///05--"  )# ' 'dA&&&&  % %d + + +  & & ( ( (**,,&&tW55 "A S// !  " "sAA #A conn1conn2cFgd}tfd|DS)z]Compares pertinent keys of connection info data. Returns True if equivalent, False otherwise.) r*r(r%r$r"r'r&r,r-c3pK|]0}||kV1dSrs)r)ror*rrs rb z9ConnectionFileMixin._equal_connections..vs<NN599S>>UYYs^^3NNNNNNr)all)rrpertinent_keyss`` rbrz&ConnectionFileMixin._equal_connectionsfs=    NNNNN~NNNNNNrrcr|j}|j}t|d|z}|dkrd||fzS|d|d|S)z&Make a ZeroMQ URL for a given channel.rrz tcp://%s:%iz://r4)r,r(r)rrr,r(rZs rb _make_urlzConnectionFileMixin._make_url|sZN WtY011    B:- -//B//// /ridentity bytes | Nonezmq.sugar.socket.Socketc||}t|}|jd||j|}d|_|r||_|||S)z1Create a zmq Socket and connect it to the kernel.zConnecting to: %si) rchannel_socket_typesrrcontextr=lingerrconnect)rrrurl socket_typerYs rb_create_connected_socketz,ConnectionFileMixin._create_connected_socketsxnnW%%*73  *C000|"";//  %$DM S rct|d|}|tjd|S)z0return zmq Socket connected to the IOPub channelrrr)rr>zmq SUBSCRIBE)rrrYs rb connect_iopubz!ConnectionFileMixin.connect_iopubs5,,Wx,HH  s+++ rc0|d|S)z0return zmq Socket connected to the Shell channelrrrrrs rb connect_shellz!ConnectionFileMixin.connect_shell,,Wx,HHHrc0|d|S)z0return zmq Socket connected to the StdIn channelrrr r s rb connect_stdinz!ConnectionFileMixin.connect_stdinr rc0|d|S)z4return zmq Socket connected to the Heartbeat channelrrr r s rb connect_hbzConnectionFileMixin.connect_hbs,,TH,EEErc0|d|S)z2return zmq Socket connected to the Control channelrrr r s rbconnect_controlz#ConnectionFileMixin.connect_controls,,Y,JJJr)r0r))rrr0r)r0r)r0r)F)rrr0r)r0r)r0rr/rr0rrs)rr!r0r)rrr0r)rrrrr0r)rr)r0r))rr)rrr0r)rrr0r)7__name__ __module__ __qualname____doc__rr__annotations__rrr rrr,r.rrContextrr(rrrrr&r"r$r%r'rpropertyrUrrrrobjectrrrrrrrcrrr staticmethodrrrrr rrrrmrrbrr=sHH%giiH''''""""g    O $tE{{eDQQQI!(K****hs{##G )   B WT]]   ] ga+UVVVG4.]^^^J4.Z[[[J4.]^^^J71T0abbbL,0//// <<<X<h788G$$$$$$$$$NT6[\\\N        5555 ' ' ' '----4((((( EEEE>,",",","\OOO\O* 0 0 0 06:      IIIIIIIIIIFFFFFKKKKKKKrrc4eZdZdZd fd Zdd Zdd ZxZS)LocalPortCachea Used to keep track of local ports in order to prevent race conditions that can occur between port acquisition and usage by the kernel. All locally- provisioned kernels should use this mechanism to limit the possibility of race conditions. Note that this does not preclude other applications from acquiring a cached but unused port, thereby re-introducing the issue this class is attempting to resolve (minimize). See: https://github.com/jupyter/jupyter_client/issues/487 r/rr0rc `tjdi|t|_dS)Nrm)super__init__setcurrently_used_ports)rr/ __class__s rbr!zLocalPortCache.__init__s2""6""".1ee!!!rr(r)r#cV tj}|tjtjd||df|d}|||jvr|j||S)NTr3rr) r=r>r?r@rArCr;r#add)rr(tmp_sockrZs rbfind_available_portz"LocalPortCache.find_available_ports }H    163CY O O O MM2q' " " "''))!,D NN   4444)--d333  rrZcP||jvr|j|dSdSrs)r#r)rrZs rb return_portzLocalPortCache.return_ports5 4, , ,  % , ,T 2 2 2 2 2 - ,rr)r(r)r0r#)rZr#r0r)rrrrr!r(r* __classcell__)r$s@rbrrso444444    33333333rr)rcrrrr) Nrrrrrrrrrr)r r!r"r#r$r#r%r#r&r#r'r#r(r)r*r+r,r)r-r)r.r)r/rr0r1)rdNN)rer)rDrfrgr!r0r)rs)rrrr)rr!r0r)9r __future__rrRr{rJr:r=rMr8rwrtypingrrrrr rjupyter_core.pathsr r r traitletsr rrrrrrtraitlets.configrrlocalinterfacesrutilsrjupyter_clientrrrr)r#r+rrcrrREQDEALERSUBrrrr__all__rmrrbr8s#""""" 88888888888888 RRRRRRRRRRVVVVVVVVVVVVVVVVVVGGGGGGGG&&&&&&!333333      CsC!778)HHHHHX$#'=F=F=F=F=FF:::::D ' Z W Zz _ ^1] ^ ^ ^ mKmKmKmKmK-mKmKmK` 33333*333D   r