+ jHjF`Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RIt^RI t ^RI t ^RI t ^RI t ^RI HtHt^RIt] P"P%R4'*t.ROtRtR t^tR tR tR R lt!RR]4tRtRtRRlt RRlt!RRlt"!RR4t#R# ]dRtRtLNi;i)aPTY bridge for `hermes dashboard` chat tab. Wraps a child process behind a pseudo-terminal so its ANSI output can be streamed to xterm.js and keystrokes fed back in; the only caller is the ``/api/pty`` WebSocket endpoint in ``hermes_cli.web_server``. POSIX-only: depends on ``fcntl``, ``termios`` and ``ptyprocess`` (native Windows would need a separate ConPTY/``pywinpty`` implementation). ) annotationsN)OptionalSequencewinF PtyBridgePtyUnavailableErrorHERMES_PTY_HOST dashboardiic$V^8dQhRRRRRR/#)valueintmaximumreturn)formats":/home/ubuntu/.hermes/hermes-agent/hermes_cli/pty_bridge.py __annotate__r/s!00C0#0#0c\V4p\ \\ Y!44# \\\3d \u#i;i)zClamp into ``[_MIN_DIMENSION, maximum]``; non-integer / non-finite values fall back to ``_MIN_DIMENSION`` so a bad probe can never reach ``struct.pack``. )r TypeError ValueError OverflowError_MIN_DIMENSIONmaxmin)r rns&& r_clamp_dimensionr/sA J ~s1 // z= 1s &AAc]tRt^:tRtRtR#)rzPTY cannot be created here (native Windows, or ``ptyprocess`` missing); the dashboard surfaces the message as a chat-tab banner. rN)__name__ __module__ __qualname____firstlineno____doc____static_attributes__rrrrr:srg?g@cV^8dQhRR/#)r rfloatr)rs"rrrHs [ [ [rc^RIHpV!RR4p\P!V4'dV^8:dRp\ \ \ VR,4\4#)) env_float#HERMES_TUI_GATEWAY_SHUTDOWN_GRACE_Sg??)utilsr)mathisfiniterr_HELPER_SHUTDOWN_GRACE_S_MAX_HELPER_SHUTDOWN_GRACE_S)r)gateways r_helper_shutdown_gracer2HsH =sCG == ! !W\ s+Ws];=Y ZZrc V^8dQhRRRR/#)r pgidr rboolr)rs"rrrTsrcZ\P!V^4R# \dR#i;i)r(FT)oskillpgOSError)r4s&r_process_group_existsr:Ts. $  s  **cV^8dQhRR/#r rr5r)rs"rrr\s4rc^RIpVP4;'dVP4VP8g# \dR#i;i)zuBest-effort 'is this psutil Process still alive' for the shutdown cadence; zombies count as dead and it never raises.NF)psutil is_runningstatus STATUS_ZOMBIE Exception)procr>s& r _psutil_aliverD\sB JJT[[]f6J6J%JJ s;; A  A c ]tRt^gtRtRtRRlt]RRl4t]RRRRR ^PR ^/R R ll4t ] R Rl4t RRlt R(RRllt RRltRR/RRlltRRltRRltRRltRR ltR!R"ltR#R$ltR%R&ltR'tR#))raAThin wrapper around ``ptyprocess.PtyProcess`` for byte streaming. Not thread-safe: owned by the WebSocket handler that spawned it; reads run in an executor thread, writes are awaited on the loop. The master fd is non-blocking so input backpressure suspends only the owning WebSocket task, never the dashboard event loop. NcV^8dQhRR/#)r rCzptyprocess.PtyProcessr)rs"rrPtyBridge.__annotate__ps0020rc :WnVPVnRVn\P !VP 4Vn\P!VPR4^RI H pV!VP4Vn R# \d RTnLTi;i)FN)open_fd_waiter) _procfd_fd_closedr7getpgidpid_pgidr9 set_blockingtools.environments.fd_waitrI_waiter)selfrCrIs&& r__init__PtyBridge.__init__pss   (* 488(%dhh/  DJ s%BBBcV^8dQhRR/#r<r)rs"rrrGs$$T$rc \\4#)z.True if a PTY can be spawned on this platform.)r5_PTY_AVAILABLE)clss&r is_availablePtyBridge.is_availablesN##rcwdenvcolsrowsc 0V^8dQhRRRRRRRRR RR R /#) r argvz Sequence[str]r]z Optional[str]r^zOptional[dict]r_r r`rrr)rs"rrrGs< *7ESberu rc \'g<\PPR4'd \ R4h\ R4h^RIHpVf V!RRR7MVP4pVPR4'gRVR&\V\&\PP\V4W'WT3R 7pV!V4# \dTP!R R 7hi;i) z4Spawn ``argv`` behind a new PTY and return a bridge.rz^Pseudo-terminals are unavailable on this platform. Hermes Agent supports Windows only via WSL.zOThe `ptyprocess` package is missing. Run hermes pm repair, then restart Hermes.)build_subprocess_envF) scrub_secretsinherit_profile_homeTERMzxterm-256color)r]r^ dimensionsTforce)rYsysplatform startswithrtools.environments.localrdcopygetPTY_HOST_DASHBOARD PTY_HOST_ENV ptyprocess PtyProcessspawnlistr9close) rZrbr]r^r_r`rd spawn_envrCs &&$$$$ rruPtyBridge.spawns ~||&&u--)+XYY%'ST T B]`]h(uSXYnqnvnvnx }}V$$ 0If  #5 ,$$**4:3[_Zf*g t9   JJTJ "  s C C)cV^8dQhRR/#)r rr r)rs"rrrGs##S#rc @\VPP4#N)r rJrOrTs&rrO PtyBridge.pids4::>>""rcV^8dQhRR/#r<r)rs"rrrGs$rc VP'*;'d$\VPP44# \dR#i;i)F)rMr5rJisaliverBr}s&ris_alivePtyBridge.is_alives@ ||#BBTZZ-?-?-A(B B  s>#> A  A c V^8dQhRRRR/#)r timeoutr&rzOptional[bytes]r)rs"rrrGsEOrc VP'gVPfR#VPPV4pT'gR#\ P !TPR4pT;'gR# \\3dR#i;i \dqpTP\P\P09dRp?R#TP\P\P09dRp?R#hRp?ii;i)zRead up to 64 KiB from the PTY master, blocking at most ``timeout`` seconds. ``b""`` = nothing yet; ``None`` = EOF / closed (also after :meth:`close`). Nr) rMrSwaitr9rr7readrLerrnoEIOEBADFEAGAIN EWOULDBLOCK)rTrreadabledataexcs&& rrPtyBridge.reads <<<4<</ ||((1H 77488U+D||t$    yyUYY 44yyU\\5+<+<==  s5A7 !B7B  B  D /D/DDD c V^8dQhRRRR/#)r rr&rr5r)rs"rrrGsEdrc a"VP'gV^8:dR#\P!4pVP4oRV3RllpVP VP V4\P !SVR7GRjxL VP'*VPVP 4#L1 \\3d#i;i \\\3d9TPTP 4R# \\3dR#i;ii;i TPTP 4i \\3dii;i;i5i)zDWait without blocking the event loop until the master accepts input.FcV^8dQhRR/#r rNoner)rs"rr.PtyBridge._wait_writable..__annotate__s ' 'T 'rcZ<SP4'gSPR4R#R#r|)done set_result)readysr _mark_ready-PtyBridge._wait_writable.._mark_readys!::<<  & r)rN) rMasyncioget_running_loop create_future add_writerrLwait_for remove_writerr9r TimeoutError)rTrlooprrs&& @r_wait_writablePtyBridge._wait_writables <<<7a<'')""$ ' '  OODHHk 2""5': : :||# ""488, ;Z(   gz2  ""488,Z(     ""488,Z(  sA E7CB7CB96E7C9C  E C  ED&D!(DEDEDEDD!!E#D?>E?EEEEErg$@c$V^8dQhRRRRRR/#)r rbytesrr&rr5r)rs"rrrGs!&&&5&D&rc D"VP'dR#V'gR#\P!4pVP4\ RV4,p\ V4pV'dVP'dR#\ P!VPV4pT^8d-YVRpT'd\P !^4GRjxL KqYCP4, pTP#T4GRjxL 'dKR#R# \dpTP\P\P\P09dRp?R#TP\P\P09d^pRp?LhRp?ii;iLL5i)aWrite all raw bytes without ever blocking the dashboard event loop. Returns ``False`` when the bridge closes or the child leaves its input buffer full for ``timeout`` seconds. Callers can then recycle only the affected terminal session while the rest of the dashboard stays live. FTgN)rMrrtimer memoryviewr7writerLr9rrrEPIPErrsleepr) rTrrrdeadlineviewrr remainings &&$ rrPtyBridge.writes( <<<'')99;S'!22$||| HHTXXt,1uBx!--*** 99;.I,,Y7777% 99EKK EE 99u/@/@ AAA  +8swF A F *F <F ?!D ,F  F 0F =F>F  F  F>FF 1FF FFF F c$V^8dQhRRRRRR/#)r r_r r`rrr)rs"rrrGs!3cdrc VP'dR#\P!R\V\4\V\ 4^^4p\ P!VP\PV4R# \dR#i;i)u4Forward a terminal resize to the child via ``TIOCSWINSZ``. Clamped first: WSL2 via xterm.js reports garbage like ``columns=131072, rows=1`` and an unclamped unsigned-short pack raises ``struct.error`` (not ``OSError``), leaving the TUI laid out for a one-row screen — the blank/disappearing-text symptom. NHHHH) rMstructpackr _MAX_ROWS _MAX_COLSfcntlioctlrLtermios TIOCSWINSZr9)rTr_r`winsizes&&& rresizePtyBridge.resizesk <<< ++f&6tY&GIYZ^`iIjlmopq  KK'"4"4g >   s 0A>> B  B c V^8dQhRRRR/#)r rr&rrr)rs"rrrGs  u  rc VPeKVPPV4'd*\P!VPR4'dR#\P!T4R# \ \ 3dL+i;i)Nr) rSrr7rrLr9rrr)rTrs&&r_discard_outputPtyBridge._discard_outputsg ||'DLL,=,=g,F,F277SWS[S[]bKcKc 7$   s.A2&A22BBc$V^8dQhRRRRRR/#)r r4r rr&rrr)rs"rrrG"s!'''u''rc \P!4V,p\V4'd0\P!4V8dVPR4K>R#R#){Gz?N)r monotonicr:r)rTr4rrs&&& r_wait_for_group_exitPtyBridge._wait_for_group_exit"sC>>#g-#D))dnn.>.I   &/J)rcV^8dQhRR/#rr)rs"rrrG'sZZtZrc VP'dR#RVnVPpVPP4p.pVe_WPP8wdEV'd;^RIpVP VPP4PRR7pRp\P\P\P3FpVPP4'gMVe\P!W4MVPPV4\ P"!4R,pVPP4'gK\ P"!4V8gKVP%R4KQ Ve\'4pV'd\P3M\P\P3pV'dVP)W4VFBp\P!W4TP)Y\P8XdTMR4KD EMV'Ed\'4p\P\P3FpVF<p V\P8XdV P-V4K,V P4K> V\P8XgK\\ P"!4V,p\.;QJdRV4F 'gK RM RM !RV44'gK\ P"!4V8gKVP%R4Kk VPP1RR7VP34R# \d.pELi;i \dELi;i \*dKdi;i \dEKWi;i \dLki;i) uTerminate the child's process group (SIGHUP → SIGTERM → SIGKILL, 0.5s grace each while the leader lives, then up to the helper grace for the rest of the group), reap the leader so the dashboard never leaks zombies, and close fds. Idempotent; blocks, so call it off the event loop. NT) recursiver+rc38"TFp\V4xK R#5ir|)rD).0cs& r "PtyBridge.close..zsO8N1mA..8NsFri)rMrPrJrrOr>ProcesschildrenrBsignalSIGHUPSIGTERMSIGKILLr7r8killrrrr2rr9 send_signalanyrw _close_waiter) rTr4leader_was_alivenon_leader_descendantsr>sigrgracesweepchilds & rrwPtyBridge.close's <<<  zz::--/ (*    6 0!-3^^DJJNN-K-T-T_c-T-d*DMM6>>6>>BC::%%'' #IId(JJOOC(~~'#-H**$$&&4>>+;h+F$$T*C*  *,E)9V^^% v~~?^E))$6IId())$ 9MSVW  $ #+,E v~~63E&--/!--c2!JJL 4&--'#~~/%7H#O8NO###O8NOOOTXTbTbTdgoTo,,T27  JJ  4  ( A!0-/*0  *$%   sf+9N;N&N&N8&O /O $O N#"N#& N54N58 OO OO O,+O,cV^8dQhRR/#rr)rs"rrrGs!!t!rc ZVPeVPP4R#R#r|)rSrwr}s&rrPtyBridge._close_waiters! << # LL    $rcV^8dQhRR/#)r rrr)rs"rrrGs9rc V#r|rr}s&r __enter__PtyBridge.__enter__s rcV^8dQhRR/#rr)rs"rrrGsrc &VP4R#r|)rw)rT_excs&*r__exit__PtyBridge.__exit__s  r)rMrLrPrJrS)g?)rr r!r"r#rSrU classmethodr[rupropertyrOrrrrrrrrwrrrr$rrrrrgs G0"$$:>VZhjxz:## 4.&4&P ' Zx!r)rqrrrr)$r# __future__rrrrr-r7rrrkrrtypingrrrsrlrmrY ImportError__all__rrrqrrrr RuntimeErrorrr/r0r2r:rDrrrrrs#  %0077N U!      0, # [dd[JNs$B B-,B-