e.dZddlmZddlZddlZddlZddlZddlZddlZddl m Z m Z ddl Z ddl mZddlmZddlmZmZd d lmZGd d e jZGd deZdS)z The Terminal Widget makes it easy to create Panel Applications with Terminals. - For example apps which streams the output of processes or logs. - For example apps which provide interactive bash, python or ipython terminals ) annotationsN)ClassVarMapping) JupyterComm)PeriodicCallback) edit_readonly lazy_load)WidgetceZdZdZejeefdZej ddZ ej dZ ej d dd Zejd d Zejd dZejdZejedZejddZejdd dZejd ZejdZfdZedZdZdZejddddZ d Z!d!Z"ed"Z#d-d$Z$d%Z%d&Z&ejd'dd(Z'ejd)dd*Z(d.d,Z)xZ*S)/TerminalSubprocesszn The TerminalSubProcess is a utility class that makes running subprocesses via the Terminal easy. z The arguments used to run the subprocess. This may be a string or a list. The string cannot contain spaces. See subprocess.run docs for more details.)class_doczKills the running processTrconstantze Any other arguments to run the subprocess. See subprocess.run docs for more details.rFz2 Whether or not the subprocess is running.)defaultrrrzChild process idrrzChild file descriptor.iPrz* Watches the subprocess for output2z#Period length of _periodic_callbackz; The Terminal to which the subprocess is connected.)r allow_refsrz%Watches the subprocess for user inputc Jtjd||jd|dS)N) _terminalkill)super__init___kill)selfterminalkwargs __class__s 6lib/python3.11/site-packages/panel/widgets/terminal.pyrzTerminalSubprocess.__init__As/G8$*GGGGGGGc@dd|DS)Nc6g|]}tj|Sr)shlexquote).0cs r$ z-TerminalSubprocess._quote..Fs 8881 A888r%)join)commands r$_quotezTerminalSubprocess._quoteDs#ww88888999r%ct|tr|St|trfd|DS|S)Nc:g|]}|Sr)r0)r+argr s r$r-z2TerminalSubprocess._clean_args..Ls%555DKK$$555r%) isinstancestrr0listr argss` r$ _clean_argszTerminalSubprocess._clean_argsHsX dC  %;;t$$ $ dD ! ! 65555555 5 r%c<ddl}|s|j}|std|jrtd||}|jr i|j|}|\}}|dkrh tj|fi|}tt|dS#t$r*}tt|dzYd}~dSd}~wwxYw||_ ||_ |t|j|j|_|j|jj|jdd |_t+j|5d |_ddddS#1swxYwYdS) z, Runs a subprocess command. rNzError. No args providedz@Error. A child process is already running. Cannot start another.z& CompletedProcess('FileNotFoundError'))callbackperiodvalueF) onlychangedT)ptyr8 ValueErrorrunningr9r"fork subprocessrunprintr5FileNotFoundError _child_pid_fd _set_winsizer&_forward_subprocess_output_to_terminal_period_periodic_callbackstartrparamwatch%_forward_terminal_input_to_subprocess_watcher edit_constant)r r8r"r? child_pidfdresultes r$rDzTerminalSubprocess.runOs+   9D 8677 7 < R %% ; /. .v.F((**B >>  J#7777c&kk"""""$ J J Jc!ffHHIIIIIIIII J(DODH      &6D|'''D #  # ) ) + + + N066:G!7DM$T** $ $#  $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s*:.B** C4CC<FFFz_terminal.ncolsz_terminal.nrowsrOc |j|jjr |jjsdSddl}ddl}ddl}|d|jj|jjdd} ||j|j |dS#t$rYdSwxYw)NrHHHH) rHrnrowsncolsfcntlstructtermiospackioctl TIOCSWINSZOSError)r r\r]r^winsizes r$rIzTerminalSubprocess._set_winsizes 8 4>#7 t~?S  F  ++fdn&:DN > > > >    DD s!A?? B  B c|j}||rQtjtj|t j|jd|ddS|jddS)Nz The process z was killed z No running process to kill ) rG_resetoskillpggetpgidsignalSIGTERMrwrite)r eventsrSs r$rzTerminalSubprocess._killsO   C Ibj++V^ < < < N !J)!J!J!J K K K K K N !A B B B B Br%c.d|_d|_|jr |jd|_|jr$|jj|jt j|5d|_ ddddS#1swxYwYdS)NrF) rHrGrLstoprQrrNunwatchrRrAr s r$rezTerminalSubprocess._resets  " +  # ( ( * * *&*D # = 8 N ( ( 7 7 7   & & ! ! DL ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! !s5B  BBc<|d|dSNCompletedProcess)rfind)r=s r$_remove_last_line_from_stringz0TerminalSubprocess._remove_last_line_from_strings 6u{{#566677r%rctj||}t|dzD]A} |dcS#t$r|tj|dz}Y>wxYwt d)zHUTF-8 characters can be multi-byte so need to decode on correct boundaryr zutf-8z(Could not find decode boundary for UTF-8)rfreadrangedecodeUnicodeDecodeError UnicodeError)r rTmax_read_bytesmax_extra_bytesdata_s r$_decode_utf8_on_boundaryz+TerminalSubprocess._decode_utf8_on_boundaryswr>**q()) - -A -{{7+++++% - - -bgb!nn, -EFFFsA"A'&A'c:|jsdStj|jggg|j\}}}|sdS||j|j}d|vr)|||}|j|dSrr) rHselect _timeout_secr_max_read_bytesrerurrk)r data_readyroutputs r$rJz9TerminalSubprocess._forward_subprocess_output_to_terminalsx  F#]DH:r2t?PQQQ  F..tx9MNN  ' ' KKMMM77??F V$$$$$r%c|jr8tj|j|jjdSdSN)rHrfrkrr=encoder rls r$rPz8TerminalSubprocess._forward_terminal_input_to_subprocesssA 8 > HTXt~3::<< = = = = = > >r%r8c|j}t|tr,d|vr*td|d|ddSdS)N z The args 'zV' provided contains spaces. They must instead be provided as the list )r8r4r5r@splitr7s r$_validate_argsz!TerminalSubprocess._validate_argssky dC  SD[[*t**jjoo**   [[r%rKc:|jr|j|j_dSdSr)rLrKr<rps r$_update_periodic_callbackz,TerminalSubprocess._update_periodic_callbacks*  " :-1\D # * * * : :r%Nc(d|jd|jdS)NzTerminalSubprocess(args=z , running=))r8rAr depths r$__repr__zTerminalSubprocess.__repr__sN$)NNt|NNNNr%)rr)+__name__ __module__ __qualname____doc__rN ClassSelectorr5r6r8ActionrDictr"BooleanrAIntegerrGrHrrrLrK ParameterrrrQr staticmethodr0r9rDdependsrIrrerurrJrPrrr __classcell__r#s@r$rrs 5 sDk8" # # #D 5<7$ G G GD UZ"$$$FemED?5666Gq.@AAAJ %-'? @ @ @C#emI666O,,4DK-...emB,QRRRG%F>???I!5=+++Lu#JKKKHHHHHH::\:7$7$7$rU]$&7tDDD  ED CCC ! ! !88\8GGGG % % %>>>U]6&&&'&U]9D)))::*):OOOOOOOOr%rcHeZdZUdZejddZejiddZej dd Z ej dd Z ej dd Z ej dddZejdd Zej dZej dZdddddddZded<d/fd ZdZd0fd ZdZdZejd d!d"Zd/d#Zed$Zed%Zd&Z d'Z!d(Z"d)Z#d1d*Z$d1d+Z%d,Z&d-Z'd.Z(xZ)S)2Terminala The `Terminal` widget renders a live terminal in the browser using the xterm.js library making it possible to display logs or even provide an interactive terminal in a Panel application. Reference: https://panel.holoviz.org/reference/widgets/Terminal.html :Example: >>> Terminal( ... "Welcome to the Panel Terminal!", options={"cursorBlink": True} ... ) zClears the Terminal.Trz Initial Options for the Terminal Constructor. cf. https://xtermjs.org/docs/api/terminal/interfaces/iterminaloptions/)r precedencerr'z. System output written to the Terminalrz/ The number of columns in the terminal.)readonlyrz, The number of rows in the terminal.InputzO User input received from the Terminal. Sent one character at the time.)labelrrFz7 Whether or not to write to the server console.z$Sends a signal to clear the terminalrrNr)clearnamer_outputr=write_to_consolez"ClassVar[Mapping[str, str | None]]_renamec r|pdx|d<}|j|d<tjdd|i|d|_dS)Nr'rrrr)_clearrr _subprocess)r rparamsr#s r$rzTerminal.__init__ sQ%+\r1yF+w111&111r%c$|}t|tr|}n:t|tr|d}nt|}|j|krd|_||_|xj|z c_t |jS)Nutf8r')r4r5bytesryrrlen)r _Terminal__scleaneds r$rkzTerminal.writes c3   GG U # # jj((GG#hhG <7 " "DL  w 4;r%c|j*tddt|t||_t ||||}|j|_|d||||S)Nzpanel.models.terminalr keystroke)modelrcomm) _widget_typer r4rr _get_modelr_register_events)r rrootparentrrr#s r$rzTerminal._get_model!s|   $ )'Zk5R5RTX!!D ""3fd;;{  kCdKKK r%ct|5|j|_tj|5d|_dddn #1swxYwYddddS#1swxYwYdS)Nr')r keyr=rNdiscard_events)r events r$_process_eventzTerminal._process_event+s 4   DJ%d++                                    s3!AA AA A A AA!$A!c4d|_|xjdz c_dS)z4 Clears all output on the terminal. r'r N)r_clearsrs r$rzTerminal._clear1s   r%rrWc`|jr&tj|jdSdSr)rsys __stdout__rkrrps r$_writezTerminal._write8s5   / N  . . . . . / /r%c(dt|dS)Nz Terminal(id=r)idrs r$rzTerminal.__repr__=s)bhh))))r%cF|jst||_|jS)z The subprocess enables running commands like 'ls', ['ls', '-l'], 'bash', 'python' and 'ipython' in the terminal. )rrrps r$rCzTerminal.subprocess@s(  81$77D r%cdSNFrrps r$closedzTerminal.closedLsur%cdSNrrrps r$filenozTerminal.filenoPsrr%cdSrrrps r$flushzTerminal.flushSs r%c|jSrrrps r$getvaluezTerminal.getvalueVs {r%cdSNTrrps r$readablezTerminal.readableYtr%c:|dkr|jS|jd|Srr)r sizes r$rwz Terminal.read\s$ 2::; {5D5!!r%cg}d}|jdD]<}|dkr||kr|tj|z }n||=|S)Nr r)rrr getsizeofappend)r hintlinesrlines r$ readlineszTerminal.readlinesasoK%%d++  DbyyTD[[ d+++ LL     r%cdSrrrps r$seekablezTerminal.seekableksur%cdSrrrps r$writablezTerminal.writablenrr%c:|D]}||dSr)rk)r rrs r$ writelineszTerminal.writelinesqs0  D JJt      r%r)NNN)r)*rrrrrNrrroptionsStringrrr[rZr=rrrrr__annotations__rrkrrrrrrpropertyrCrrrrrrwrrrrrrs@r$rrs   EL3d C C CEej9NOOOGU\"+1222F EM4.2 3 3 3E EM4./ 0 0 0E ELwrsG #"""""  $$$$$$$$ ######++++++++++++++OOOOO,OOODVVVVVvVVVVVr%