[jSdZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z m Z ddlmZddlmZddlmZmZmZddlmZddlmZdd lmZejeZeej d Z!e!re"ej#ej$Z%d Z&Gd d Z'dee(gdfdzddfdZ)dee(gdfdzfdZ*de+de(ddfdZ,defdZ-dej.de(ddfdZ/ d)de0e(de(dzdej.fdZ1dede+fdZ2dede+ddfdZ3de(de4e5e6fdzfd Z7Gd!d"eZ8Gd#d$Z9d%e(de(fd&Z:Gd'd(e Z;dS)*aCBase class for all Hermes execution environment backends. Unified spawn-per-call model: every command spawns a fresh ``bash -c`` process. A session snapshot (env vars, functions, aliases) is captured once at init and re-sourced before each command. CWD persists via in-band stdout markers (remote) or a temp file (local). N)ABCabstractmethod)deque)Path)IOCallableProtocol)get_hermes_home)windows_hide_flags)is_interruptedHERMES_DEBUG_INTERRUPTlc|eZdZdZdefdZedefdZedefdZde ddfd Z d d d e de fd Z dS)_BoundedOutputCollectorz9Retain a bounded 40/60 head-tail window of streamed text. max_charsc8tdt||_t|jdz|_|j|jz |_g|_t |_d|_d|_ d|_ tj |_ dS)N皙?r)maxintr _head_limit _tail_limit_headr_tail _head_chars _tail_chars _total_chars threadingLock_lock)selfrs 9/home/ice/.hermes/hermes-agent/tools/environments/base.py__init__z _BoundedOutputCollector.__init__8sQI//t~344>D,<< " !& ^%% returncb|j5|j|jzcdddS#1swxYwYdSN)rrrr s r!buffered_charsz&_BoundedOutputCollector.buffered_charsCs| Z 7 7#d&66 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7s $((cR|j5|jcdddS#1swxYwYdSr&)rrr's r! total_charsz#_BoundedOutputCollector.total_charsHst Z % %$ % % % % % % % % % % % % % % % % % %s   textNc<|sdS|j5t|}|xj|z c_d}|j|jkrSt |j|jz |}|r4|j|d||xj|z c_|}||z }|dks |jdkr ddddS||jkr[|j |j ||j d|j|_ ddddS||d}|j ||xj t|z c_ |j |jkr|j |jz }|j d}t||kr7|j |xj t|zc_ n"||d|j d<|xj |zc_ |j |jkddddS#1swxYwYdS)Nr) rlenrrrminrappendrrclearrpopleft) r r+text_lenstarttake remainingchunkexcessfirsts r!r/z_BoundedOutputCollector.appendMs  F Z / /4yyH    )  E$"2224+d.>>II!J%%d5D5k222$$,$$ E 5(IA~~!1Q!6!6 / / / / / / / /D,,,   """ !!$(8'8':':";<<<#'#3 ' / / / / / / / /*LE J  e $ $ $   E *  "T%555)D,<< 1 u::''J&&((($$E 2$$$$)&''NDJqM$$.$$"T%5551 / / / / / / / / / / / / / / / / / /s BH5AHC)HHHsuffixr;c B|j5t||jkr||j dcdddSd|j}d|j}|jt|z }|j|kr||z|zcdddSd}tdD]n}td|t|z }t|dz}||z } td|j|z | z } d| dd|jdd } | |krn| }otd|t|z }t|dz}||z } | r || dnd} |d||d|z| z|zcdddS#1swxYwYdS) zARender within ``max_chars``, preserving a required status suffix.Nr9rrz ... [OUTPUT TRUNCATED - ,z chars omitted out of z total] ... ) rr-rjoinrrrrangerr) r r;headtail availablenotice_content_budget head_chars tail_charsomittedupdated rendered_tails r!renderz_BoundedOutputCollector.renderrs Z S S6{{dn,,t~o//0 S S S S S S S S774:&&D774:&&DV4I I--d{V+ S S S S S S S SF1XX ! !!$Q CKK(?!@!@ #!566 +j8 a!2Z!?*!LMMC7MCC"/BCCCf$$E  IF $;<Register a callback that _wait_for_process fires periodically.N)_activity_callback_localcallback)rTs r!set_activity_callbackrXs(*%%%r#c.ttddS)NrW)getattrrVrSr#r!_get_activity_callbackr[s +Z > >>r#statelabelctj}|dd}||dz |krdS||d< t}|r+t ||dz }||d|ddSdS#t $rYdSwxYw)a_Fire the activity callback at most once every ``state['interval']`` seconds. *state* must contain ``last_touch`` (monotonic timestamp) and ``start`` (monotonic timestamp of the operation start). An optional ``interval`` key overrides the default 10 s cadence. Swallows all exceptions so callers don't need their own try/except. intervalg$@ last_touchNr3z (z s elapsed))time monotonicgetr[r Exception)r\r]nowr_rTelapseds r!touch_activity_if_duergs .  CyyT**H U<  8++E, # % %  0#g.//G B%..7... / / / / / 0 0      s9A>> B  B ctjd}|rt|}ntdz }|dd|S)zReturn the host-side root for all sandbox storage (Docker workspaces, Singularity overlays/SIF cache, etc.). Configurable via TERMINAL_SANDBOX_DIR. Defaults to {HERMES_HOME}/sandboxes/. TERMINAL_SANDBOX_DIR sandboxesTparentsexist_ok)osgetenvrr mkdir)customps r!get_sandbox_dirrssT Y- . .F , LL    +GGD4G((( Hr#procdatacffd}tj|ddS)uWrite *data* to proc.stdin on a daemon thread to avoid pipe-buffer deadlocks. On Windows, text-mode stdin (``text=True`` / ``encoding="utf-8"``) translates ``\n`` → ``\r\n`` as the data flows through the pipe — which corrupts every write_file / patch call because the bytes that land on disk include injected carriage returns. The file IS created, but every subsequent byte-count / content compare against the caller's ``\n``-only string fails. Workaround: write through ``proc.stdin.buffer`` (the underlying byte buffer), encoding to UTF-8 ourselves. That bypasses Python's newline translation entirely on every platform. No behaviour change on POSIX — the byte sequence is identical to what text-mode would produce there. c ttrdn}tjdj}|||dS#ttf$rYdSwxYw)Nutf-8buffer) isinstancerRencoderZstdinwritecloseBrokenPipeErrorOSError)rawtargetrurts r!_writez_pipe_stdin.._writes  +5T3*?*?I$++g&&&TCTZ4:>>F LL    LLNNNNN)    DD sA0A55B  B TrdaemonN)rThreadr3)rtrurs`` r! _pipe_stdinrsL"      F40006688888r#cmd stdin_datac |dttj|ftjtj| tjn tjdd|}|t|||S)aSpawn a subprocess with standard stdout/stderr/stdin setup. If *stdin_data* is provided, writes it asynchronously via :func:`_pipe_stdin`. Backends with special Popen needs (e.g. local's ``preexec_fn``) can bypass this and call :func:`_pipe_stdin` directly. creationflagsNT)stdoutstderrr|r+) setdefaultr subprocessPopenPIPESTDOUTDEVNULLr)rrkwargsrts r! _popen_bashrs o'9';';<<<     !+!7jooZ=O        DD*%%% Kr#pathc|r9 tj|dS#t$rYnwxYwiS)z:Load a JSON file as a dict, returning ``{}`` on any error.rxencoding)existsjsonloads read_textrd)rs r!_load_json_storersZ {{}} :dnngn>>?? ?    D  Is'> A  A c|jdd|tj|dddS)z.Write *data* as pretty-printed JSON to *path*.Trk)indentrxrN)parentrp write_textrdumps)rrus r!_save_json_storer sHKdT222OODJtA...OAAAAAr# host_pathc t|}|j|jfS#t$rYdSwxYw)zIReturn ``(mtime, size)`` for cache comparison, or ``None`` if unreadable.N)rstatst_mtimest_sizer)rsts r!_file_mtime_keyrsO )__ ! ! # # RZ(( tts .1 ??ceZdZdZdedzfdZd dZd dedzdefdZe de e dzfdZ e dedzfd Z dS) ProcessHandlezDuck type that every backend's _run_bash() must return. subprocess.Popen satisfies this natively. SDK backends (Modal, Daytona) return _ThreadedProcessHandle which adapts their blocking calls. r$NcdSr&rSr's r!pollzProcessHandle.poll(r#cdSr&rSr's r!killzProcessHandle.kill)rr#timeoutcdSr&rSr rs r!waitzProcessHandle.wait*rr#cdSr&rSr's r!rzProcessHandle.stdout,(+r#cdSr&rSr's r! returncodezProcessHandle.returncode/rr#r$Nr&)rMrNrOrPrrrfloatrrQrrRrrrSr#r!rr!s &cDj%%%%< (output_str, exit_code)`` in a background thread and exposes a ProcessHandle-compatible interface. An optional ``cancel_fn`` is invoked on ``kill()`` for backend-specific cancellation (e.g. Modal sandbox.terminate, Daytona sandbox.stop). Nexec_fn cancel_fnc8|_tj_d_d_t j\}}t j|ddd_ |_ fd}tj |d}| dS)Nrrxreplace)rerrorsc \}}|_ tjj|ddn#t $rYnwxYwn%#t $r}|_d_Yd}~nd}~wwxYw tjjn#t $rYnwxYwj dS# tjjn#t $rYnwxYwj wxYw)Nrxrrr) _returncodernr} _write_fdr{rrd_errorr~_doneset)output exit_codeexcrr s r!_workerz0_ThreadedProcessHandle.__init__.._workerKsO !$+GII! #, HT^V]]79]-U-UVVVVD % % %! #$       %HT^,,,,D      HT^,,,,D     sA/AA AAAAC A;#A61C6A;;C?B B&%B&D C D  C-*D ,C--D Tr) _cancel_fnrEventrrrrnpipefdopen_stdoutrrr3)r rrread_fdwrite_fdrts`` r!r"z_ThreadedProcessHandle.__init__<s $_&& '+(, GIIy# RRR ! ! ! ! ! ! !&  GD 9 9 9  r#c|jSr&)rr's r!rz_ThreadedProcessHandle.stdoutas |r#r$c|jSr&)rr's r!rz!_ThreadedProcessHandle.returncodees r#cF|jr|jndSr&)ris_setrr's r!rz_ThreadedProcessHandle.pollis##':#4#4#6#6@tD@r#cd|jr( |dS#t$rYdSwxYwdSr&)rrdr's r!rz_ThreadedProcessHandle.killlsS ?  !!!!!      s  --rcF|j||jS)Nr)rrrrs r!rz_ThreadedProcessHandle.waitss! (((r#r&)rMrNrOrPrtuplerRrr"rQrrrrrrrSr#r!rr3s04##"eCHo-.#BH%,####JX C$J   X AcDjAAAA  EDL C      r#r session_idcd|dS)N __HERMES_CWD___rS)rs r! _cwd_markerr}s ): ) ) ))r#ceZdZUdZdZeed<dZeed<defdZ d-d ed ed e fd Z d ddddede d ededzde f dZedZdZed edefdZdedefdZded edefdZedededefdZ d.d dde d ede de fdZde fd Zd!e fd"Zd!e fd#Zd/d$Z d0ddd&d d'ded ed edzdedzd(e de de fd)Zd*Zd+Zdedeeedzffd,Z dS)1BaseEnvironmentaCommon interface and unified execution flow for all Hermes backends. Subclasses implement ``_run_bash()`` and ``cleanup()``. The base class provides ``execute()`` with session snapshot sourcing, CWD tracking, interrupt handling, and timeout enforcement. r _stdin_mode_snapshot_timeoutr$cdS)a,Return the backend temp directory used for session artifacts. Most sandboxed backends use ``/tmp`` inside the target environment. LocalEnvironment overrides this on platforms like Termux where ``/tmp`` may be missing and ``TMPDIR`` is the portable writable location. z/tmprSr's r! get_temp_dirzBaseEnvironment.get_temp_dirs vr#Ncwdrenvcf||_||_|pi|_tjjdd|_|dpd}|d|jd|_ |d|jd|_ t|j|_ d|_ d|_ dS)N /z /hermes-snap-z.shz /hermes-cwd-z.txtF)rrruuiduuid4hex _session_idrrstrip_snapshot_path _cwd_filer_snapshot_ready_prefer_nonlogin)r rrrtemp_dirs r!r"zBaseEnvironment.__init__s 9":<<+CRC0$$&&--c229c!)MM8HMMM$HH$2BHHH&t'788$!&r#Fxloginrr cmd_stringrrcJtt|jd)zSpawn a bash process to run *cmd_string*. Returns a ProcessHandle (subprocess.Popen or _ThreadedProcessHandle). Must be overridden by every backend. z must implement _run_bash())NotImplementedErrortyperM)r rrrrs r! _run_bashzBaseEnvironment._run_bashs$"T$ZZ%8"U"U"UVVVr#cdS)z z __hermes_fns=$(declare -F | awk '{print $3}' | grep -vE '^_[^_]') || true [ -n "$__hermes_fns" ] && declare -f $__hermes_fns >> z! 2>/dev/null || true alias -p >> z# echo 'shopt -s expand_aliases' >> z echo 'set +e' >> z echo 'set +u' >> z mv -f  z || rm -f z builtin cd -- z 2>/dev/null || true printf '\n%sz\n' "$(pwd -P)" T)rrrrrz)snapshot bootstrap failed with exit code z-Session snapshot created (session=%s, cwd=%s)Ftruerz; non-login probe: Nu_init_session failed (session=%s): %s — login bash unusable; falling back to non-login bash -cuLinit_session failed (session=%s): %s — falling back to bash -l per command)_quote_cwd_for_cdr_quote_shell_pathrrrr_wait_for_processrrc RuntimeErrorr _update_cwdloggerinforrdrRr.striprwarning) r _quoted_cwd _quoted_snap _snap_tmp bootstraprtresultrdetailprefer_nonloginprobe probe_result probe_excs r! init_sessionzBaseEnvironment.init_sessions ,,TX66 --d.ABB $**4+>+HIIJV  U$ U U ! U U"%# U U$2;% U U&!*' U U(!*) U U./ U U."./ U U.:C/ U U0)1 U U2*3 U U2/3.>3 U U U 8- >>)4AW>XXD++D$:P+QQF6::l++0q11Q66"Z <@X@XZZ$(D   V $ $ $ KK?          #(D XXF#O CvUCDLbDcDcdd#55eSTMcEdEd5ee "%l&6&6|&D&D&I"J"Ja"O&V*..x88BFIIKKUvF C C C"BByBB C%4D ! M$ :$ ' sECE JJ5B*H J H;*H61J6H;;AJJc|dkr|S|dkrdS|drdtj|ddStj|S)z7Quote a ``cd`` target while preserving ``~`` expansion.~z~/z$HOMEz$HOME/rN) startswithshlexquote)rs r!r z!BaseEnvironment._quote_cwd_for_cdBsd #::J $;;7 >>$   32EKABB0022 2{3r#rc*tj|S)zQuote *path* for interpolation into a bash script. LocalEnvironment overrides this to rewrite native/mixed Windows paths to ``/c/...`` before quoting. Remote backends leave paths as-is (they already speak POSIX). )r$r%)r rs r!rz!BaseEnvironment._quote_shell_pathMs{4   r#commandc |dd}||j}||jdzdz}g}|jr|d|d||}|d|d|d |d|d |d |jr"|d |d |d|d|d |d|jd|jd|dd|S)zwBuild the full bash script that sources snapshot, cd's, runs command, re-dumps env vars, and emits CWD markers.'z'\''rrzsource z >/dev/null 2>&1 || truezbuiltin cd -- z || exit 126zeval 'z__hermes_ec=$?z umask 077z{ export -p > z && mv -f r z; } 2>/dev/null || rm -f z 2>/dev/null || truez printf '\nr z\n' "$(pwd -P)"zexit $__hermes_ec )rrrrr/r rr?)r r'rescapedrrparts quoted_cwds r! _wrap_commandzBaseEnvironment._wrap_commandVs//#w//--d.ABB **4+>+HIIJV     LL@,@@@    ++C00  >j>>>???  (g((())) %&&&  [!!!    LLH)HHyHH<HH(1HHH     R$* R Rd.> R R R     ()))yyr#cbdtjjdd}|d|d|d|S)z;Append stdin_data as a shell heredoc to the command string. HERMES_STDIN_Nrz << 'z' r*)rrr)r'r delimiters r!_embed_stdin_heredocz$BaseEnvironment._embed_stdin_heredocsGt"d(| | | tj | dz j!j!dS))uPoll-based wait with interrupt checking and stdout draining. Shared across all backends — not overridden. ``bounded_capture=True`` (foreground terminal-tool path only) retains at most ``tool_output.max_bytes`` of output in a head/tail window while draining, so a verbose subprocess cannot OOM the process (#64435). The default (False) preserves full-fidelity capture for internal consumers — file-operation ``cat`` reads feeding the patch engine, code-execution RPC reads, log reads — where truncation would corrupt data. Fires the ``activity_callback`` (if set on this instance) every 10s while the process is running so the gateway's inactivity timeout doesn't kill long-running commands. Also wraps the poll loop in a ``try/finally`` that guarantees we call ``self._kill_process(proc)`` if we exit via ``KeyboardInterrupt`` or ``SystemExit``. Without this, the local backend (which spawns subprocesses with ``os.setsid`` into their own process group) leaves an orphan with ``PPID=1`` when python is shut down mid-tool — the ``sleep 300``-survives-30-min bug Physikal and I both hit. r) get_max_bytesiPrxrrc  |D]e}|t|tr)|Ct |fn#t $rYnwxYw dd}|r|dSdS#t $rYdSwxYw# dd}|r|ww#t $rYwwxYwxYw)Nr#Tfinal)rzbytesr/decoderRrd)streampiecerBdecoderrs r!_drain_iterablez:BaseEnvironment._wait_for_process.._drain_iterablesZ #22E} !%//2 gnnU&;&;<<<< c%jj1111 2    ">>#T>::D, d+++++,, DD ">>#T>::D, d++++, Ds`A(A,+C, A96C8A99C=.B// B=<B=D.C20D2 C?<D>C??DcP j}|dSt|dd} t|r |nd}n#t$rd}YnwxYwt |t r|dkr |dSt jdkr t j|d}|sn) |An#ttf$rYnwxYw dd}|r |nU#t$rYnIwxYw# dd}|r |ww#t$rYwwxYwxYwdSd} tj |gggd\}}}n#ttf$rYnwxYw|r\ t j|d}n#ttf$rYnSwxYw|snL |d}n  |d z }|d krn dd}|r |dSdS#t$rYdSwxYw# dd}|r |ww#t$rYwwxYwxYw) NfilenorntTr#r7g?r)rrZcallablerdrzrrnnamereadr/r: ValueErrorrselectr) r;r@fdr6rBidle_after_exitreadyrEr>r=rrts r!_drainz1BaseEnvironment._wait_for_process.._drains[F~VXt44F !)&!1!1;VVXXXt    b#&& "q&&'''w$= "D 1 1$"! gnnU&;&;<<< =""G,D&~~c~>>0"MM$///$ &~~c~>>0"MM$////0$O "&,mRD"b#&F&F q!!&0""$&GB$5$5EE *G4"""!E"$"! gnnU&;&;<<<*+0(1,*a//!)"2">>#T>::D, d+++++,, DD ">>#T>::D, d++++, Ds; A  A AC D CD CD !.D DD E"".EE" EE"EE"*I#,F I# FI#FI##F98I#9G  I# G  AI# .I I I #J%%.JJ% J"J%!J""J%Tr)r`r3pidNFzg[interrupt-debug] _wait_for_process ENTER tid=%s pid=%s timeout=%ss activity_cb=%s initial_interrupt=%srMISSINGg{Gzt?rut[interrupt-debug] _wait_for_process INTERRUPT DETECTED tid=%s pid=%s iter=%d elapsed=%.1fs — killing process groupr3rrz [Command interrupted]r:)rrzM[interrupt-debug] _wait_for_process TIMEOUT tid=%s pid=%s iter=%d timeout=%ssz [Command timed out after zs]|zterminal command runningg>@zo[interrupt-debug] _wait_for_process HEARTBEAT tid=%s pid=%s iter=%d elapsed=%.0fs interrupt=%s activity_cb=%s%sz (LOST during run)r9g?g?u[interrupt-debug] _wait_for_process EXCEPTION_EXIT tid=%s pid=%s iter=%d elapsed=%.1fs — killing subprocess group before re-raisezd[interrupt-debug] _wait_for_process EXIT (natural) tid=%s pid=%s iter=%d elapsed=%.1fs returncode=%s)"tools.tool_output_limitsr5rd_UNBOUNDED_CAPTURE_CHARSrcodecsgetincrementaldecoderrrr3rarbcurrent_threadidentrZr[_DEBUG_INTERRUPTrrr r _kill_processr?rLr*lstriprgsleepr.KeyboardInterrupt SystemExitrr~r)r rtrr3r5 capture_limitrL drain_threaddeadline_now_activity_state_tid_pid _iter_count_last_heartbeat_last_interrupt_state _cb_was_none _poll_sleep timeout_msg _cb_now_noner>r=rs ` @@@r!rz!BaseEnvironment._wait_for_processs4  5 'BBBBBB -   ' ' ' &  ' 5M(7748&.w77yIII      4F F F F F F F F P!'vdCCC >##g-~  '))/tUD))  %-//47   KKBdG)8y     U K))++%q !## ' \ $ T^5E5EX_H`5` &&t,,, %%a%000"(--7P-"Q"Q&)>##h..' @ $ W &&t,,, %%a%000"K"K"K"KK"-22#)--{-"C"C"J"J"L"L"L#]]+]>>&) &o7QRRR $ 0(8(8?(Jd(R(R#9#;#;t#CLKK8dK((?7+CC&((%1@y0<Y\Y,,WY   '+n&6&6O#/L ;'''$$"%kC&7"="=K}))++%~":.      g$ N$$w'??   ""4(((!!!!,,,,     ) 2 !$$$  K          D    KKDdK  ?7#;;    !--//IIIs^ ((;B,N (B8N !C)N AP+PP PPPP4Q QQcl |dS#tttf$rYdSwxYw)zDTerminate a process. Subclasses may override for process-group kill.N)rProcessLookupErrorPermissionErrorr)r rts r!rXzBaseEnvironment._kill_processsA  IIKKKKK"OW=    DD s 33rc0||dS)zDExtract CWD from command output. Override for local file-based read.N)_extract_cwd_from_output)r rs r!rzBaseEnvironment._update_cwds %%f-----r#cB|dd}|j}||}|dkrdStd|dz }||||}|dks||krdS||t |z|}|r||_|dd|}|dkr|}|d|t |z} | dkr| dznt |} |d||| dz|d<dS) zParse the __HERMES_CWD_{session}__ marker from stdout output. Updates self.cwd and strips the marker from result["output"]. Used by remote backends (Docker, SSH, Modal, Daytona, Singularity). rr9NrrBr*r)rcrrfindrr-rrfind) r rrmarkerlast search_startr8cwd_path line_startline_ends r!roz(BaseEnvironment._extract_cwd_from_outputs: Hb))!||F## 2:: F1dTk**  V\488 B;;%4-- F%#f++-45;;==  DH \\$511   J;;tTCKK%788#+r>>8a<Hook called before each command execution. Remote backends (SSH, Modal, Daytona) override this to trigger their FileSyncManager. Bind-mount backends (Docker, Singularity) and Local don't need file sync — the host filesystem is directly visible inside the container/process. NrSr's r!_before_executezBaseEnvironment._before_executes  r#r9T)rrrewrite_compound_backgroundr3r|c|||\}}|rddlm} | |}|p|j} |p|j} ||||z} n||} n|} | r#|jdkr||| }d} ||| } |j o|j }| | || | }| || |}| ||S)uExecute a command, return {"output": str, "returncode": int}. ``bounded_capture=True`` caps stdout/stderr retention at ``tool_output.max_bytes`` WHILE the stream is drained (head/tail window) instead of holding the full output in memory (#64435). It must only be set by callers whose output is destined for the model/tool payload (the foreground terminal tool). Internal full-fidelity consumers — file operations ``cat`` reads that feed the patch engine, code-execution RPC reads, log reads — MUST leave it False: truncating those corrupts data, not just display. r)_rewrite_compound_backgroundNheredocr)rr3)r{_prepare_commandtools.terminal_toolr~rrrr2r.rrrrr)r r'rrrr|r3 exec_command sudo_stdinr~effective_timeout effective_cwdeffective_stdinwrappedrrtrs r!executezBaseEnvironment.executes]* #'#8#8#A#A j ' F H H H H H H77 EEL#3t|tx   !j&<(:5OO  #(OO(O  #t/9<<44\?SSL"O$$\=AA((F1F-F~~ 5*;  '' +_(       r#c.|dS)z.Alias for cleanup (compat with older callers).N)rr's r!stopzBaseEnvironment.stopWs r#cR |dS#t$rYdSwxYwr&)rrdr's r!__del__zBaseEnvironment.__del__[s:  LLNNNNN    DD s  &&c$ddlm}||S)z6Transform sudo commands if SUDO_PASSWORD is available.r)_transform_sudo_command)rr)r r'rs r!rz BaseEnvironment._prepare_commandas%??????&&w///r#r&)rr)r9)!rMrNrOrPrrR__annotations__rrrdictr"boolrrrrr  staticmethodr rr.r2rrXrror{rrrrrrSr#r!rrs~K sc&&C&#&D&&&&0!% W W W W W  W $J W  W W W W  ^ sssr s s   \ !c!c!!!!@ S@ s@ s@ @ @ @ LHcHsHsHHH\H36jJRWjJjJjJ!jJ,/jJKOjJ jJjJjJjJX -.$.... Ct C C C CL    "< #!%,0 %<<<<< t < $J <&*<< <<<<D 00c3:o0F000000r#rr&)rs   ########)))))))))),,,,,,<<<<<<******  8 $ $ 4  ":;;<<"  OOGL!!!+9?,, %ZSZSZSZSZSZSZSZSz+hud{3d:+t++++ ?# 5 <????        4       (9j&9c9d9999F.2 c #d .4DB4BtBBBBB suUCZ'84'?,,,,,H,,,$B B B B B B B B T*C*C****_ 0_ 0_ 0_ 0_ 0c_ 0_ 0_ 0_ 0_ 0r#