Skip to main content

winx_code_agent/state/
pty.rs

1//! Real PTY implementation using portable-pty
2//!
3//! This module provides a true pseudo-terminal interface for interactive
4//! shell sessions, enabling proper handling of:
5//! - ANSI escape sequences and colors
6//! - Interactive programs (sudo, vim, less, etc.)
7//! - Terminal resize events
8//! - Job control signals (Ctrl+C, Ctrl+Z, etc.)
9
10use anyhow::{anyhow, Context, Result};
11use portable_pty::{native_pty_system, Child, CommandBuilder, MasterPty, PtySize};
12use std::collections::hash_map::DefaultHasher;
13use std::hash::{Hash, Hasher};
14use std::io::{Read, Write};
15use std::path::{Path, PathBuf};
16use std::process::Command;
17use std::sync::mpsc::{self, TryRecvError};
18use std::sync::{Arc, Mutex as StdMutex};
19use std::thread;
20use std::time::{Duration, Instant};
21use tokio::sync::Mutex;
22use tracing::{debug, info, warn};
23
24use crate::state::line_ring::LineRing;
25use crate::state::live_terminal::{LiveTerminal, ScreenUpdate};
26
27/// Default terminal dimensions (columns x rows)
28pub const DEFAULT_COLS: u16 = 200;
29pub const DEFAULT_ROWS: u16 = 50;
30
31/// Maximum output buffer size to prevent memory issues
32const MAX_OUTPUT_SIZE: usize = 1_000_000;
33
34/// Cap on bytes streamed to one command's output-offload scratch file, so a
35/// command emitting gigabytes cannot fill the disk. The head beyond this is
36/// dropped (the agent still gets the first 50 MB plus the live tail).
37const SCRATCH_MAX_BYTES: u64 = 50 * 1024 * 1024;
38
39/// How many fully-formed lines to keep in the per-shell ringbuffer. Callers can
40/// ask for at most this many lines of historical context via
41/// `StatusCheck.scrollback_lines`.
42pub const RING_BUFFER_LINES: usize = 2_000;
43
44/// Cap on the unterminated tail held in `line_ring_partial`. Bounds memory when
45/// a program emits megabytes without ever printing a newline (a `\r`-redrawn
46/// progress bar, a binary blob). Generous enough to hold any real terminal line.
47const MAX_PARTIAL_LINE_BYTES: usize = 64 * 1024;
48
49/// WCGW-style prompt pattern for command completion detection
50const WCGW_PROMPT_PATTERN: &str = "◉";
51const WCGW_PROMPT_END: &str = "──➤";
52
53fn attachable_command(restricted_mode: bool) -> (CommandBuilder, Option<String>, bool) {
54    let requested = std::env::var("WINX_ATTACH_TERMINAL")
55        .or_else(|_| std::env::var("WINX_USE_SCREEN"))
56        .unwrap_or_default();
57    if !requested.is_empty() && requested != "0" && requested != "false" {
58        let session = format!("winx-{}-{}", std::process::id(), timestamp_millis());
59        if requested == "tmux" && command_available("tmux") {
60            let mut cmd = CommandBuilder::new("tmux");
61            cmd.args(["new-session", "-A", "-s", &session, "bash"]);
62            if restricted_mode {
63                cmd.arg("-r");
64            }
65            return (cmd, Some(format!("tmux attach -t {session}")), false);
66        }
67        if command_available("screen") {
68            // Parity with wcgw: ensure a sane ~/.screenrc and reap sessions whose
69            // creating winx process has died before spawning a fresh one.
70            ensure_screenrc();
71            cleanup_orphaned_screens();
72            let mut cmd = CommandBuilder::new("screen");
73            cmd.args(["-q", "-S", &session, "bash"]);
74            if restricted_mode {
75                cmd.arg("-r");
76            }
77            return (cmd, Some(format!("screen -x {session}")), false);
78        }
79    }
80
81    let shell = preferred_shell(restricted_mode);
82    let is_zsh = shell == "zsh";
83    let mut cmd = CommandBuilder::new(&shell);
84    // zsh's restricted mode isn't the `-r` flag, so restricted always uses bash -r.
85    if restricted_mode && !is_zsh {
86        cmd.arg("-r");
87    }
88    (cmd, None, is_zsh)
89}
90
91/// Shell to spawn directly. Defaults to bash; honors `WINX_SHELL=zsh` when zsh is
92/// on PATH and we're not in restricted mode (zsh's restricted mode differs from
93/// `bash -r`, so restricted falls back to bash).
94fn preferred_shell(restricted_mode: bool) -> String {
95    if !restricted_mode {
96        if let Ok(requested) = std::env::var("WINX_SHELL") {
97            if requested == "zsh" && command_available("zsh") {
98                return "zsh".to_string();
99            }
100        }
101    }
102    "bash".to_string()
103}
104
105fn command_available(command: &str) -> bool {
106    Command::new("sh")
107        .args(["-c", &format!("command -v {command}")])
108        .output()
109        .is_ok_and(|output| output.status.success())
110}
111
112/// Create `~/.screenrc` with a large scrollback if the user has none, matching
113/// wcgw's `check_if_screen_command_available`. Never overwrites an existing file.
114fn ensure_screenrc() {
115    let Some(home) = home::home_dir() else {
116        return;
117    };
118    let screenrc = home.join(".screenrc");
119    if screenrc.exists() {
120        return;
121    }
122    let _ = std::fs::write(
123        &screenrc,
124        "defscrollback 10000\ntermcapinfo xterm* ti@:te@\nstartup_message off\n",
125    );
126}
127
128/// Reap detached `winx-*` screen sessions whose creating process is gone.
129///
130/// The session name embeds the creator PID (`winx-<pid>-<ts>`), so an orphan is
131/// simply a session whose `<pid>` no longer exists — the wcgw equivalent of
132/// detecting `parent_pid == 1`. Best-effort: any failure is silently ignored.
133fn cleanup_orphaned_screens() {
134    let Ok(output) = Command::new("screen").arg("-ls").output() else {
135        return;
136    };
137    // `screen -ls` exits non-zero when sessions exist, so we parse stdout regardless.
138    let listing = String::from_utf8_lossy(&output.stdout);
139    for line in listing.lines() {
140        let Some(session) = line.split_whitespace().next() else {
141            continue;
142        };
143        // session token looks like "<screen_pid>.winx-<creator_pid>-<ts>"
144        let Some((_, name)) = session.split_once('.') else {
145            continue;
146        };
147        if let Some(creator_pid) = winx_creator_pid(name) {
148            if !process_exists(creator_pid) {
149                let _ = Command::new("screen").args(["-S", session, "-X", "quit"]).output();
150            }
151        }
152    }
153}
154
155/// Extract the creator PID from a `winx-<pid>-<ts>` screen session name.
156fn winx_creator_pid(name: &str) -> Option<u32> {
157    name.strip_prefix("winx-")?.split('-').next()?.parse::<u32>().ok()
158}
159
160/// Whether a process with `pid` is currently alive (Linux `/proc` check).
161fn process_exists(pid: u32) -> bool {
162    std::path::Path::new("/proc").join(pid.to_string()).exists()
163}
164
165fn timestamp_millis() -> u128 {
166    std::time::SystemTime::now()
167        .duration_since(std::time::UNIX_EPOCH)
168        .map_or(0, |duration| duration.as_millis())
169}
170
171/// Real PTY-based interactive shell
172///
173/// Uses portable-pty for true pseudo-terminal functionality,
174/// enabling proper handling of interactive programs like sudo, vim, etc.
175pub struct PtyShell {
176    /// The PTY master handle for resize operations
177    master: Box<dyn MasterPty + Send>,
178    /// Child process running the shell
179    child: Box<dyn Child + Send + Sync>,
180    /// Writer for PTY input (taken from master)
181    writer: Box<dyn Write + Send>,
182    /// Channel receiver for output from reader thread
183    output_rx: mpsc::Receiver<String>,
184    /// Current terminal size
185    size: PtySize,
186    /// Last command executed
187    pub last_command: String,
188    /// Accumulated output buffer
189    pub output_buffer: String,
190    /// Whether a command is currently running
191    pub command_running: bool,
192    /// Last cwd observed in this shell's nonce-bearing prompt.
193    current_cwd: PathBuf,
194    /// Monotonic start time of the current or most recently completed command.
195    /// Status polling uses this instead of restarting the clock per tool call.
196    command_started_at: Option<Instant>,
197    /// Monotonic command generation used by daemon journals to distinguish two
198    /// consecutive commands whose terminal bytes happen to be identical.
199    command_generation: u64,
200    /// Exit code of the last completed foreground command, parsed from the prompt
201    /// marker (`──➤<nonce>:<code>`). `None` until a command finishes, and reset
202    /// to `None` while one is running.
203    pub last_exit_code: Option<i32>,
204    /// Maximum output size before truncation
205    max_output_size: usize,
206    /// Flag for output truncation
207    pub output_truncated: bool,
208    /// Bounded scrollback ring of raw PTY lines (newest at the back) plus the
209    /// in-flight partial line, with drop accounting so a truncated scrollback is
210    /// reported to the caller instead of silently shrinking. See `LineRing`.
211    ring: LineRing,
212    /// Hash of the last rendered output we shipped to the caller. Used by the
213    /// delta path in `status_check` to elide repeats when the screen is idle.
214    pub last_returned_hash: Option<u64>,
215    /// Cumulative PTY snapshot already delivered to the caller. Incremental
216    /// status polling diffs against this value, then advances it after rendering.
217    delivered_output: String,
218    /// Optional command a human can run to attach to the same terminal session.
219    pub attach_hint: Option<String>,
220    /// The exact suffix that ends this shell's prompt: `──➤<nonce>`. The nonce is
221    /// a per-shell random value embedded in `PROMPT_COMMAND`, so command output
222    /// can't impersonate the prompt (printing `◉ x──➤` no longer ends a command
223    /// early). Anchoring completion on this instead of the bare glyphs removes
224    /// the false-positive that truncated output when a program echoed them.
225    prompt_end_marker: String,
226    /// Live terminal emulator (fixed-viewport, `vt100`-backed) fed continuously
227    /// by the reader thread. Unlike the scrollback ring (raw lines), it keeps a
228    /// consolidated screen grid — cursor moves, redraws, alternate-screen
229    /// applied — so a TUI yields a stable, non-stacked snapshot. The fixed
230    /// viewport is what lets inline-rendering TUIs (the `agy`/Antigravity CLI,
231    /// which redraws with cursor-up + erase-line in the main screen) consolidate
232    /// instead of ghosting. See `live_snapshot`.
233    live: Arc<StdMutex<LiveTerminal>>,
234    /// Workspace root under which output-offload scratch files are written.
235    /// `None` until a caller sets it (the workspace is only known after
236    /// Initialize, and `execute_command` sets it per command). See
237    /// `crate::utils::scratch_file`.
238    scratch_workspace_root: Option<PathBuf>,
239    /// Scratch file holding the CURRENT command's dropped output head, created
240    /// lazily on the first truncation and reset per command.
241    scratch_path: Option<PathBuf>,
242    /// Bytes already streamed to `scratch_path`, used to enforce `SCRATCH_MAX_BYTES`.
243    scratch_bytes: u64,
244}
245
246impl std::fmt::Debug for PtyShell {
247    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
248        f.debug_struct("PtyShell")
249            .field("size", &format!("{}x{}", self.size.cols, self.size.rows))
250            .field("last_command", &self.last_command)
251            .field("command_running", &self.command_running)
252            .field("current_cwd", &self.current_cwd)
253            .field("output_truncated", &self.output_truncated)
254            .field("output_buffer_len", &self.output_buffer.len())
255            .field("attach_hint", &self.attach_hint)
256            .finish_non_exhaustive()
257    }
258}
259
260/// Resolve the process group to signal for a PTY child, but ONLY when it is
261/// safe: the pid must be a real child (`> 1`) that leads its own group
262/// (`getpgid(pid) == pid`). portable-pty `setsid`s the shell, so a live PTY
263/// child is always its own group leader; if that ever stopped holding,
264/// `kill(-pgid, ...)` would hit some unrelated group, so we refuse instead of
265/// guessing.
266///
267/// The `pid > 1` check is load-bearing: `kill(-1, ...)` means "every process I
268/// may signal" and `kill(0, ...)` means "my own group" - either would be
269/// catastrophic from a teardown path.
270#[cfg(unix)]
271fn killable_group(pid: u32) -> Option<i32> {
272    let pid = i32::try_from(pid).ok()?;
273    if pid <= 1 {
274        return None;
275    }
276    // SAFETY: getpgid(2) reads the group of an existing pid; integer-only, no
277    // memory touched. Returns -1 for a dead/invalid pid, which fails the check.
278    let group = unsafe { libc::getpgid(pid) };
279    (group == pid).then_some(group)
280}
281
282/// Send `signal` to the whole process group `pgid` (group-kill via negative
283/// pid). `pgid` must be one vetted by [`killable_group`].
284#[cfg(unix)]
285fn signal_group(pgid: i32, signal: i32) {
286    // SAFETY: kill(2) with a negative pid signals a process group; integer-only,
287    // no memory touched. `pgid` came from `killable_group`, so it is `> 1`.
288    unsafe {
289        libc::kill(-pgid, signal);
290    }
291}
292
293impl Drop for PtyShell {
294    /// Kill and reap the shell child **and its whole process group** so neither
295    /// the shell nor anything it spawned leaks.
296    ///
297    /// `std::process::Child::drop` neither kills nor waits, and even
298    /// `Child::kill` signals only the shell itself: a background job it started
299    /// (`npm run dev &`, a `nohup`'d server) would be reparented to init and live
300    /// on. Because portable-pty runs the shell as a session/group leader, we can
301    /// signal the whole group with a negative pid - SIGTERM first so well-behaved
302    /// children can clean up, then `Child::kill` (SIGKILL on the leader, which
303    /// closes the PTY slave so the reader thread's `read()` returns EOF and the
304    /// thread exits), then SIGKILL the group to sweep anything still alive, then
305    /// reap. The pgid is captured while the leader is alive and reused: it stays
306    /// valid until we `wait()`, even after the leader dies. All best-effort.
307    fn drop(&mut self) {
308        // Only group-kill the direct bash/zsh path. Under screen/tmux (`attach_hint`
309        // is `Some`) the `Child` is a multiplexer *client*; the real shell runs in
310        // a detached daemon in another process group, so a group-kill here would
311        // miss the shell entirely and could disturb unrelated sessions of the same
312        // multiplexer. Let the multiplexer own its lifecycle in that case.
313        #[cfg(unix)]
314        let pgid = if self.attach_hint.is_some() {
315            None
316        } else {
317            self.child.process_id().and_then(killable_group)
318        };
319
320        #[cfg(unix)]
321        if let Some(pgid) = pgid {
322            signal_group(pgid, libc::SIGTERM);
323        }
324
325        // SIGKILL the leader and close the PTY slave (unblocks the reader thread).
326        let _ = self.child.kill();
327
328        #[cfg(unix)]
329        if let Some(pgid) = pgid {
330            signal_group(pgid, libc::SIGKILL);
331        }
332
333        let _ = self.child.wait();
334    }
335}
336
337impl PtyShell {
338    /// Create a new PTY shell session
339    ///
340    /// # Arguments
341    /// * `initial_dir` - Starting directory for the shell
342    /// * `restricted_mode` - Whether to use bash restricted mode (-r)
343    ///
344    /// # Returns
345    /// A new `PtyShell` instance with an active bash session
346    pub fn new(initial_dir: &Path, restricted_mode: bool) -> Result<Self> {
347        info!(
348            "Creating new PTY shell (restricted: {}) in {}",
349            restricted_mode,
350            initial_dir.display()
351        );
352
353        // Initialize the native PTY system
354        let pty_system = native_pty_system();
355
356        // Configure terminal size
357        let size =
358            PtySize { rows: DEFAULT_ROWS, cols: DEFAULT_COLS, pixel_width: 0, pixel_height: 0 };
359
360        // Open the PTY pair (master + slave)
361        let pair = pty_system.openpty(size).context("Failed to open PTY pair")?;
362
363        // Build the command
364        let (mut cmd, attach_hint, is_zsh) = attachable_command(restricted_mode);
365
366        // Set up environment for proper terminal behavior
367        cmd.env("TERM", "xterm-256color");
368        cmd.env("COLORTERM", "truecolor");
369        cmd.env("PAGER", "cat");
370        cmd.env("GIT_PAGER", "cat");
371        cmd.env("COLUMNS", DEFAULT_COLS.to_string());
372        cmd.env("ROWS", DEFAULT_ROWS.to_string());
373        // Per-shell random nonce embedded in the prompt so command output can't
374        // forge the completion marker. 64 bits of entropy in hex.
375        let nonce = format!("{:016x}", rand::random::<u64>());
376        // WCGW-style prompt for command completion detection
377        // Note: removed \r\e[2K which was erasing the prompt before it could be detected
378        // `__winx_ec=$?` captures the user command's exit status as the very
379        // first thing PROMPT_COMMAND does, then we print it after the marker.
380        cmd.env(
381            "PROMPT_COMMAND",
382            format!(r#"__winx_ec=$?; printf "◉ %s──➤{nonce}:%s " "$PWD" "$__winx_ec""#),
383        );
384        cmd.cwd(initial_dir);
385
386        // Spawn bash in the PTY slave
387        let child = pair.slave.spawn_command(cmd).context("Failed to spawn bash in PTY")?;
388
389        // Get reader and writer from master
390        let mut reader = pair.master.try_clone_reader().context("Failed to clone PTY reader")?;
391        let writer = pair.master.take_writer().context("Failed to take PTY writer")?;
392
393        // Bounded channel: if the consumer stalls, the reader thread blocks on
394        // send (natural backpressure via the PTY OS buffer) instead of growing
395        // memory without bound on a runaway producer like `yes`.
396        let (output_tx, output_rx) = mpsc::sync_channel::<String>(1024);
397
398        // Live terminal emulator, shared with the reader thread so the screen
399        // grid stays current without any consumer needing to poll.
400        let live = Arc::new(StdMutex::new(LiveTerminal::new(DEFAULT_ROWS, DEFAULT_COLS)));
401        let live_reader = Arc::clone(&live);
402
403        // Spawn a background thread to read from the PTY
404        // This prevents blocking the main thread
405        thread::spawn(move || {
406            let mut buf = [0u8; 4096];
407            // Bytes of an incomplete trailing UTF-8 char held back for the next
408            // read. Without this, a multibyte glyph split across a 4096-byte read
409            // boundary would decode to two U+FFFDs — corrupting the output buffer
410            // and the prompt/CWD detection that runs over it.
411            let mut carry: Vec<u8> = Vec::new();
412            loop {
413                match reader.read(&mut buf) {
414                    Ok(0) => {
415                        // EOF - PTY closed. Flush any held bytes lossily.
416                        if !carry.is_empty() {
417                            let _ = output_tx.send(String::from_utf8_lossy(&carry).into_owned());
418                        }
419                        break;
420                    }
421                    Ok(n) => {
422                        // Tap the raw bytes into the live emulator first (brief
423                        // lock; feed is O(chunk len)). Feeding bytes — not the
424                        // lossy String — keeps the persistent VTE parser exact
425                        // across chunk boundaries. Recover from a poisoned lock
426                        // instead of dropping the feed silently.
427                        {
428                            let mut emu = live_reader
429                                .lock()
430                                .unwrap_or_else(std::sync::PoisonError::into_inner);
431                            emu.feed(&buf[..n]);
432                        }
433                        // Decode the longest valid prefix; carry an incomplete
434                        // trailing char into the next read.
435                        carry.extend_from_slice(&buf[..n]);
436                        let (chunk, rest) = decode_keep_incomplete(&carry);
437                        carry = rest;
438                        if !chunk.is_empty() && output_tx.send(chunk).is_err() {
439                            // Receiver dropped, exit thread
440                            break;
441                        }
442                    }
443                    Err(e) => {
444                        debug!("PTY reader thread error: {}", e);
445                        break;
446                    }
447                }
448            }
449            debug!("PTY reader thread exiting");
450        });
451
452        // Create the shell instance
453        let mut shell = Self {
454            master: pair.master,
455            child,
456            writer,
457            output_rx,
458            size,
459            last_command: String::new(),
460            output_buffer: String::new(),
461            command_running: false,
462            current_cwd: initial_dir.to_path_buf(),
463            command_started_at: None,
464            command_generation: 0,
465            last_exit_code: None,
466            max_output_size: MAX_OUTPUT_SIZE,
467            output_truncated: false,
468            ring: LineRing::new(RING_BUFFER_LINES, MAX_PARTIAL_LINE_BYTES),
469            last_returned_hash: None,
470            delivered_output: String::new(),
471            attach_hint,
472            prompt_end_marker: format!("{WCGW_PROMPT_END}{nonce}"),
473            live,
474            scratch_workspace_root: None,
475            scratch_path: None,
476            scratch_bytes: 0,
477        };
478
479        // Initialize the shell with WCGW-style prompt
480        shell.initialize_prompt(is_zsh, &nonce)?;
481
482        debug!("PTY shell created successfully");
483        Ok(shell)
484    }
485
486    /// Initialize the shell prompt for WCGW compatibility
487    fn initialize_prompt(&mut self, is_zsh: bool, nonce: &str) -> Result<()> {
488        // Set up the dynamic prompt - matches WCGW Python PROMPT_STATEMENT.
489        // zsh ignores PROMPT_COMMAND, so it gets a precmd hook with a blanked
490        // default prompt instead.
491        // Blank the shell's own PS1/PROMPT so the line ends exactly at our `──➤`
492        // marker. Otherwise a user's ~/.bashrc/~/.zshrc PS1 (e.g. `[user@host]$`)
493        // is appended after the marker, and prompt detection — which anchors on a
494        // trailing `──➤` — only fires when the chunk happens to fragment right
495        // before the PS1, making command-completion detection flaky.
496        let prompt_statement = if is_zsh {
497            // Clear precmd_functions too: frameworks (oh-my-zsh/p10k) register the
498            // prompt via that array, so redefining `precmd` alone leaves their
499            // prompt in place and our `──➤` marker never ends the line.
500            format!(
501                r#"export GIT_PAGER=cat PAGER=cat; precmd_functions=(); preexec_functions=(); PROMPT=''; RPROMPT=''; precmd() {{ local __winx_ec=$?; printf "◉ %s──➤{nonce}:%s " "$PWD" "$__winx_ec" }}"#
502            )
503        } else {
504            format!(
505                r#"export GIT_PAGER=cat PAGER=cat PROMPT_COMMAND='__winx_ec=$?; printf "◉ %s──➤{nonce}:%s " "$PWD" "$__winx_ec"'; PS1=''"#
506            )
507        };
508
509        self.write_command(&prompt_statement)?;
510
511        // Wait for prompt to be ready
512        std::thread::sleep(Duration::from_millis(100));
513        let _ = self.drain_output();
514
515        Ok(())
516    }
517
518    /// Write a command to the PTY, submitting it with a carriage return.
519    fn write_command(&mut self, command: &str) -> Result<()> {
520        // Submit with `\r`, matching the foreground path (`send_special_key("Enter")`
521        // also sends `\r`) and a real terminal's Enter key. The two paths used to
522        // disagree — background sent `\n` here, foreground sent `\r` — which is a
523        // real difference for readline-based TUIs. bash's canonical line discipline
524        // maps CR to NL (ICRNL), so plain commands behave identically.
525        let cmd_with_newline = format!("{command}\r");
526        self.writer.write_all(cmd_with_newline.as_bytes()).context("Failed to write to PTY")?;
527        self.writer.flush().context("Failed to flush PTY")?;
528        Ok(())
529    }
530
531    /// Drain any pending output from the PTY channel
532    fn drain_output(&mut self) -> String {
533        let mut output = String::new();
534        let deadline = Instant::now() + Duration::from_millis(200);
535
536        // Drain all available output from the channel
537        while Instant::now() < deadline {
538            match self.output_rx.try_recv() {
539                Ok(chunk) => {
540                    output.push_str(&chunk);
541
542                    // Prevent runaway reads
543                    if output.len() > self.max_output_size {
544                        self.output_truncated = true;
545                        break;
546                    }
547                }
548                Err(TryRecvError::Empty) => {
549                    // No more data, wait briefly for more
550                    thread::sleep(Duration::from_millis(10));
551                }
552                Err(TryRecvError::Disconnected) => {
553                    // Reader thread died
554                    break;
555                }
556            }
557        }
558
559        output
560    }
561
562    /// Send a command to the shell and start reading output
563    pub fn send_command(&mut self, command: &str) -> Result<()> {
564        debug!(bytes = command.len(), "PTY sending command");
565
566        // Clear previous state
567        self.output_buffer.clear();
568        self.output_truncated = false;
569        self.reset_scratch();
570        self.last_command = command.to_string();
571        self.command_running = true;
572        self.mark_command_started();
573        self.last_exit_code = None;
574        // A new command means the next status_check should return whatever
575        // shows up — drop the dedup hash so we don't elide the first response.
576        self.last_returned_hash = None;
577        self.delivered_output.clear();
578
579        // Write the command
580        self.write_command(command)?;
581
582        Ok(())
583    }
584
585    /// Start the monotonic runtime clock for a newly submitted command.
586    pub fn mark_command_started(&mut self) {
587        self.command_generation = self.command_generation.saturating_add(1);
588        self.command_started_at = Some(Instant::now());
589    }
590
591    pub fn command_generation(&self) -> u64 {
592        self.command_generation
593    }
594
595    /// Elapsed runtime since the current command was submitted.
596    pub fn command_elapsed(&self) -> Option<Duration> {
597        self.command_started_at.map(|started_at| started_at.elapsed())
598    }
599
600    /// Current working directory last reported by this shell's prompt.
601    pub fn current_cwd(&self) -> &Path {
602        &self.current_cwd
603    }
604
605    /// Snapshot used as the left-hand side of incremental output rendering.
606    pub fn delivered_output(&self) -> String {
607        self.delivered_output.clone()
608    }
609
610    /// Mark the cumulative output snapshot as delivered after rendering it.
611    pub fn mark_output_delivered(&mut self, output: &str) {
612        self.delivered_output.clear();
613        self.delivered_output.push_str(output);
614    }
615
616    /// Return up to `lines` recent lines from the scrollback ring, oldest
617    /// first. When older lines were evicted or a long unterminated line was
618    /// clipped, a `[winx: …]` notice is prepended so the caller knows the
619    /// scrollback is incomplete rather than silently receiving less than asked.
620    pub fn collect_scrollback(&self, lines: usize) -> String {
621        // The ring holds raw PTY lines. Replay them through the terminal
622        // emulator so cursor movements (readline echo, in-place redraws) are
623        // *applied* — not merely stripped — yielding what the screen actually
624        // showed. A plain strip can't undo a `\x1b[D`, so it would leave
625        // `>>> p>>> pr>>> pri...` echo noise behind; the emulator collapses it.
626        let rendered =
627            crate::state::terminal::render_terminal_output(&self.ring.raw(lines)).join("\n");
628        match self.ring.scrollback_notice(lines) {
629            Some(notice) => format!("{notice}\n{rendered}"),
630            None => rendered,
631        }
632    }
633
634    /// Hash arbitrary rendered output into a u64 dedup key.
635    pub fn fingerprint(text: &str) -> u64 {
636        let mut hasher = DefaultHasher::new();
637        text.hash(&mut hasher);
638        hasher.finish()
639    }
640
641    /// Read output from the PTY with timeout
642    ///
643    /// Returns (output, `is_complete`) tuple where `is_complete` indicates
644    /// whether the command has finished (prompt detected)
645    pub fn read_output(&mut self, timeout_secs: f32) -> Result<(String, bool)> {
646        let timeout = Duration::from_secs_f32(timeout_secs.clamp(0.1, 60.0));
647        let start = Instant::now();
648        let mut complete = false;
649        let mut no_data_count = 0;
650        let mut prompt_detected_at: Option<Instant> = None;
651
652        while start.elapsed() < timeout {
653            match self.output_rx.try_recv() {
654                Ok(chunk) => {
655                    self.output_buffer.push_str(&chunk);
656                    self.ring.push_chunk(&chunk);
657                    no_data_count = 0;
658
659                    // Check for WCGW prompt indicating command completion
660                    if prompt_detected_at.is_none()
661                        && (Self::check_prompt_complete(&chunk, &self.prompt_end_marker)
662                            || Self::check_prompt_complete(
663                                &self.output_buffer,
664                                &self.prompt_end_marker,
665                            ))
666                    {
667                        prompt_detected_at = Some(Instant::now());
668                        debug!("Prompt detected, draining remaining output...");
669                    }
670
671                    // Truncate if too large (offloads the dropped head to scratch).
672                    self.truncate_output_buffer_with_offload();
673                }
674                Err(TryRecvError::Empty) => {
675                    // No data available, wait briefly
676                    thread::sleep(Duration::from_millis(10));
677                    no_data_count += 1;
678
679                    // If prompt was detected, check if we've drained long enough
680                    if let Some(detected_time) = prompt_detected_at {
681                        // Wait 100ms after prompt detection to capture any trailing output
682                        if detected_time.elapsed() > Duration::from_millis(100) {
683                            complete = true;
684                            debug!("Command completed - prompt detected and drained");
685                            break;
686                        }
687                    } else if no_data_count > 10
688                        && Self::check_prompt_complete(&self.output_buffer, &self.prompt_end_marker)
689                    {
690                        // Prompt detected during empty reads
691                        prompt_detected_at = Some(Instant::now());
692                        debug!("Prompt detected after wait, draining...");
693                    }
694                }
695                Err(TryRecvError::Disconnected) => {
696                    // Reader thread died - PTY closed
697                    warn!("PTY reader disconnected");
698                    complete = true;
699                    break;
700                }
701            }
702        }
703
704        if complete || prompt_detected_at.is_some() {
705            self.command_running = false;
706            self.last_exit_code =
707                Self::parse_prompt_exit_code(&self.output_buffer, &self.prompt_end_marker);
708            self.update_current_cwd_from_prompt();
709            complete = true;
710        }
711
712        Ok((self.output_buffer.clone(), complete))
713    }
714
715    /// Non-blocking drain of whatever the reader thread has already queued.
716    ///
717    /// Unlike [`read_output`](Self::read_output), this never sleeps: it consumes
718    /// every chunk currently available, updates prompt/completion state, and
719    /// returns immediately. `prune_finished_shells` uses it so the global
720    /// background-shell lock is never held across a blocking 100ms `read_output`.
721    /// Returns `true` if the command has completed (prompt seen or PTY closed).
722    pub fn poll_output_nonblocking(&mut self) -> bool {
723        let mut prompt_seen = false;
724        loop {
725            match self.output_rx.try_recv() {
726                Ok(chunk) => {
727                    let chunk_has_prompt =
728                        Self::check_prompt_complete(&chunk, &self.prompt_end_marker);
729                    self.output_buffer.push_str(&chunk);
730                    self.ring.push_chunk(&chunk);
731                    if chunk_has_prompt
732                        || Self::check_prompt_complete(&self.output_buffer, &self.prompt_end_marker)
733                    {
734                        prompt_seen = true;
735                    }
736                    self.truncate_output_buffer_with_offload();
737                }
738                Err(TryRecvError::Empty) => break,
739                Err(TryRecvError::Disconnected) => {
740                    self.command_running = false;
741                    return true;
742                }
743            }
744        }
745        if prompt_seen {
746            self.command_running = false;
747            self.last_exit_code =
748                Self::parse_prompt_exit_code(&self.output_buffer, &self.prompt_end_marker);
749            self.update_current_cwd_from_prompt();
750        }
751        // Completion is state, not an edge. Another consumer (notably the
752        // background reaper) may have drained the prompt first; a later poll
753        // must still report the already-idle shell as complete even when this
754        // particular drain saw no new prompt bytes.
755        !self.command_running
756    }
757
758    fn update_current_cwd_from_prompt(&mut self) {
759        let Some(last) =
760            self.output_buffer.lines().rev().find(|line| line.contains(&self.prompt_end_marker))
761        else {
762            return;
763        };
764        let clean = crate::state::terminal::strip_ansi_codes(last);
765        let Some((before_marker, _)) = clean.rsplit_once(&self.prompt_end_marker) else {
766            return;
767        };
768        let Some((_, cwd)) = before_marker.rsplit_once("◉ ") else {
769            return;
770        };
771        let cwd = cwd.trim();
772        if !cwd.is_empty() {
773            self.current_cwd = PathBuf::from(cwd);
774        }
775    }
776
777    /// Snapshot of the accumulated output buffer — the same text `read_output`
778    /// returns. Lets callers poll non-blocking (`poll_output_nonblocking`) and
779    /// grab the buffer once at the end instead of cloning it on every slice.
780    pub fn output_snapshot(&self) -> String {
781        self.output_buffer.clone()
782    }
783
784    /// Check if the output ends with this shell's prompt.
785    ///
786    /// `prompt_end` is the per-shell `──➤<nonce>` suffix. Anchoring on the LAST
787    /// non-empty line (not a global `contains`) plus the random nonce means
788    /// command output that happens to print the prompt glyphs mid-stream — or
789    /// even a forged `◉ x──➤ ` at end of line — can't be mistaken for the prompt
790    /// and truncate output or end the command early.
791    fn check_prompt_complete(text: &str, prompt_end: &str) -> bool {
792        Self::parse_prompt_exit_code(text, prompt_end).is_some()
793    }
794
795    /// If the last non-empty line is this shell's completion prompt
796    /// (`◉ <pwd>──➤<nonce>:<code>`), return the exit code that follows the
797    /// marker. Returns `None` when the prompt isn't present — which is exactly
798    /// "the command is still running". The per-shell nonce plus the structured
799    /// `:<digits>` suffix keep command output from forging completion.
800    fn parse_prompt_exit_code(text: &str, prompt_end: &str) -> Option<i32> {
801        let last = text.lines().rev().find(|line| !line.trim().is_empty())?;
802        // Strip ANSI so a trailing erase/cursor sequence after the code
803        // (e.g. ":0 \x1b[K") doesn't defeat the suffix check.
804        let clean = crate::state::terminal::strip_ansi_codes(last);
805        let clean = clean.trim_end();
806        if !clean.contains(WCGW_PROMPT_PATTERN) {
807            return None;
808        }
809        // Everything after the last "──➤<nonce>" must be ":<digits>" and nothing
810        // else — this confirms the prompt ends the line AND yields the code.
811        let after = clean.rsplit_once(prompt_end)?.1;
812        after.strip_prefix(':')?.trim().parse::<i32>().ok()
813    }
814
815    /// Point output-offload scratch files at `root` (the workspace). Idempotent;
816    /// callers set it per command so it always tracks the current workspace.
817    pub fn set_scratch_root(&mut self, root: &Path) {
818        self.scratch_workspace_root = Some(root.to_path_buf());
819    }
820
821    /// The scratch file holding the current command's dropped output head, if any
822    /// was offloaded this command.
823    pub fn scratch_path(&self) -> Option<&Path> {
824        self.scratch_path.as_deref()
825    }
826
827    /// Forget the current command's scratch file so the next command starts a
828    /// fresh one. Does not delete the file (pruned later by age).
829    pub fn reset_scratch(&mut self) {
830        self.scratch_path = None;
831        self.scratch_bytes = 0;
832    }
833
834    /// Append a just-dropped output `head` to the per-command scratch file so the
835    /// agent can recover it via `ReadFiles`. Best-effort: needs a known workspace
836    /// root, stops at `SCRATCH_MAX_BYTES`, and swallows IO errors.
837    fn offload_dropped_head(&mut self, head: &str) {
838        let Some(root) = self.scratch_workspace_root.clone() else {
839            return;
840        };
841        // Clamp to the remaining byte budget so the file honors SCRATCH_MAX_BYTES
842        // exactly (a single head can be up to keep_size, ~500 KB). Snap to a char
843        // boundary so we never slice mid-UTF-8.
844        let remaining = SCRATCH_MAX_BYTES.saturating_sub(self.scratch_bytes);
845        if remaining == 0 {
846            return;
847        }
848        let head = match usize::try_from(remaining) {
849            Ok(rem) if rem < head.len() => &head[..crate::utils::floor_char_boundary(head, rem)],
850            _ => head,
851        };
852        if self.scratch_path.is_none() {
853            self.scratch_path = crate::utils::scratch_file::new_scratch_path(&root);
854        }
855        let Some(path) = self.scratch_path.clone() else {
856            return;
857        };
858        match crate::utils::scratch_file::append_scratch(&path, head.as_bytes()) {
859            Ok(0) if self.scratch_bytes == 0 => self.scratch_path = None,
860            Ok(written) => {
861                self.scratch_bytes = self.scratch_bytes.saturating_add(written as u64);
862            }
863            Err(e) => debug!("scratch: append to {} failed: {e}", path.display()),
864        }
865    }
866
867    /// Once `output_buffer` exceeds the cap, offload the head about to be dropped
868    /// to the scratch file, then keep only the tail with a truncation marker.
869    /// Shared by the blocking and non-blocking drain paths so the offload and the
870    /// char-boundary handling live in one place.
871    fn truncate_output_buffer_with_offload(&mut self) {
872        if self.output_buffer.len() <= self.max_output_size {
873            return;
874        }
875        self.output_truncated = true;
876        let keep_size = self.max_output_size / 2;
877        // Snap to a char boundary: a raw byte offset can land mid-UTF-8
878        // (CJK/emoji/box-drawing/the prompt glyphs) and slicing there would panic.
879        let cut = crate::utils::floor_char_boundary(
880            &self.output_buffer,
881            self.output_buffer.len() - keep_size,
882        );
883        let head = self.output_buffer[..cut].to_owned();
884        self.offload_dropped_head(&head);
885        // Replace the dropped head in place instead of `format!`-ing a brand-new
886        // String: `replace_range` shifts the kept tail down once and reuses the
887        // buffer's allocation. `cut` is already a char boundary (above), and 0 is
888        // always one, so the range is valid.
889        self.output_buffer.replace_range(..cut, "\n(...output truncated...)\n");
890    }
891
892    /// Send Ctrl+C (interrupt) to the PTY
893    pub fn send_interrupt(&mut self) -> Result<()> {
894        debug!("PTY sending Ctrl+C");
895        self.writer
896            .write_all(&[0x03]) // ASCII ETX (Ctrl+C)
897            .context("Failed to send Ctrl+C")?;
898        self.writer.flush()?;
899        Ok(())
900    }
901
902    /// Send Ctrl+D (EOF) to the PTY
903    pub fn send_eof(&mut self) -> Result<()> {
904        debug!("PTY sending Ctrl+D");
905        self.writer
906            .write_all(&[0x04]) // ASCII EOT (Ctrl+D)
907            .context("Failed to send Ctrl+D")?;
908        self.writer.flush()?;
909        Ok(())
910    }
911
912    /// Send Ctrl+Z (suspend) to the PTY
913    pub fn send_suspend(&mut self) -> Result<()> {
914        debug!("PTY sending Ctrl+Z");
915        self.writer
916            .write_all(&[0x1A]) // ASCII SUB (Ctrl+Z)
917            .context("Failed to send Ctrl+Z")?;
918        self.writer.flush()?;
919        Ok(())
920    }
921
922    /// Send text directly to the PTY (for interactive input)
923    pub fn send_text(&mut self, text: &str) -> Result<()> {
924        debug!(bytes = text.len(), "PTY sending text");
925        self.send_bytes(text.as_bytes()).context("Failed to send text")?;
926        Ok(())
927    }
928
929    /// Send raw bytes directly to the PTY.
930    pub fn send_bytes(&mut self, bytes: &[u8]) -> Result<()> {
931        self.writer.write_all(bytes).context("Failed to send bytes")?;
932        self.writer.flush()?;
933        Ok(())
934    }
935
936    /// Send a special key sequence
937    pub fn send_special_key(&mut self, key: &str) -> Result<()> {
938        let bytes: &[u8] = match key {
939            "Enter" => b"\r",
940            "Tab" => b"\t",
941            "Backspace" => b"\x7F",
942            "Escape" => b"\x1B",
943            "Up" | "KeyUp" => b"\x1B[A",
944            "Down" | "KeyDown" => b"\x1B[B",
945            "Right" | "KeyRight" => b"\x1B[C",
946            "Left" | "KeyLeft" => b"\x1B[D",
947            "Home" => b"\x1B[H",
948            "End" => b"\x1B[F",
949            "PageUp" => b"\x1B[5~",
950            "PageDown" => b"\x1B[6~",
951            "Delete" => b"\x1B[3~",
952            "Insert" => b"\x1B[2~",
953            "CtrlC" | "Ctrl-C" => b"\x03",
954            "CtrlD" | "Ctrl-D" => b"\x04",
955            "CtrlZ" | "Ctrl-Z" => b"\x1A",
956            "CtrlL" | "Ctrl-L" => b"\x0C",
957            _ => return Err(anyhow!("Unknown special key: {key}")),
958        };
959
960        debug!("PTY sending special key: {} ({:?})", key, bytes);
961        self.send_bytes(bytes)?;
962        Ok(())
963    }
964
965    /// Snapshot the live terminal screen — a stable, consolidated view of what a
966    /// human would currently see, with cursor moves/redraws applied and ANSI
967    /// stripped. `max_lines` of 0 returns the full screen buffer. This is the
968    /// foundation for piloting interactive TUIs (the `claude` CLI, vim, ...).
969    pub fn live_snapshot(&self, max_lines: usize) -> Vec<String> {
970        // Recover from a poisoned lock instead of returning a blank screen
971        // forever — a single panic while holding `live` would otherwise wedge
972        // every future snapshot (and `wait_for_turn`/`screen` with it).
973        self.live.lock().unwrap_or_else(std::sync::PoisonError::into_inner).snapshot(max_lines)
974    }
975
976    /// Whether the live terminal is currently on the alternate screen buffer
977    /// (a full-screen app like vim/htop/less is running).
978    pub fn live_in_alt_screen(&self) -> bool {
979        self.live.lock().unwrap_or_else(std::sync::PoisonError::into_inner).in_alt_screen()
980    }
981
982    /// Cursor position `(row, col)` on the live screen (0-based), so a piloting
983    /// agent knows where focus is in a menu/form. `(0, 0)` if the lock is poisoned.
984    pub fn live_cursor_position(&self) -> (u16, u16) {
985        self.live.lock().unwrap_or_else(std::sync::PoisonError::into_inner).cursor_position()
986    }
987
988    /// Diff the live screen against what the client last saw, returning only the
989    /// changed lines when the change is small (huge token savings over many
990    /// polls). Updates the baseline as a side effect. See [`ScreenUpdate`].
991    pub fn live_snapshot_diff(&self, max_lines: usize, threshold: usize) -> ScreenUpdate {
992        self.live
993            .lock()
994            .unwrap_or_else(std::sync::PoisonError::into_inner)
995            .snapshot_diff(max_lines, threshold)
996    }
997
998    /// Resize the terminal
999    pub fn resize(&mut self, cols: u16, rows: u16) -> Result<()> {
1000        debug!("PTY resizing to {}x{}", cols, rows);
1001
1002        let new_size = PtySize { rows, cols, pixel_width: 0, pixel_height: 0 };
1003
1004        self.master.resize(new_size).context("Failed to resize PTY")?;
1005
1006        // Keep the live emulator's viewport in lockstep with the PTY size.
1007        self.live.lock().unwrap_or_else(std::sync::PoisonError::into_inner).resize(rows, cols);
1008
1009        self.size = new_size;
1010        Ok(())
1011    }
1012
1013    /// Get current terminal size
1014    pub fn get_size(&self) -> (u16, u16) {
1015        (self.size.cols, self.size.rows)
1016    }
1017
1018    /// OS process id of the shell that owns this PTY.
1019    pub fn process_id(&self) -> Option<u32> {
1020        self.child.process_id()
1021    }
1022
1023    /// Check if the shell is still alive
1024    pub fn is_alive(&mut self) -> bool {
1025        self.child.try_wait().is_ok_and(|status| status.is_none())
1026    }
1027}
1028
1029/// Thread-safe wrapper for `PtyShell`
1030pub type SharedPtyShell = Arc<Mutex<Option<PtyShell>>>;
1031
1032/// Create a new shared PTY shell
1033pub fn create_shared_pty(initial_dir: &Path, restricted_mode: bool) -> Result<SharedPtyShell> {
1034    let shell = PtyShell::new(initial_dir, restricted_mode)?;
1035    Ok(Arc::new(Mutex::new(Some(shell))))
1036}
1037
1038/// Split a byte slice into the longest valid-UTF-8 prefix (decoded) and the
1039/// trailing bytes of an incomplete final char (to carry into the next read).
1040/// Genuinely invalid sequences become a single U+FFFD and are consumed, so the
1041/// carry only ever holds a recoverable incomplete tail and never grows unbounded.
1042///
1043/// Iterative on purpose: a recursive version blows the reader thread's stack on
1044/// a burst of invalid bytes (e.g. `cat`-ing a binary), which aborts under
1045/// `panic = "abort"`. This stays O(1) in stack depth regardless of input.
1046fn decode_keep_incomplete(bytes: &[u8]) -> (String, Vec<u8>) {
1047    let mut decoded = String::new();
1048    let mut rest = bytes;
1049    loop {
1050        match std::str::from_utf8(rest) {
1051            Ok(text) => {
1052                decoded.push_str(text);
1053                return (decoded, Vec::new());
1054            }
1055            Err(error) => {
1056                let valid = error.valid_up_to();
1057                // `rest[..valid]` is valid UTF-8 by construction (no allocation
1058                // for the borrowed case).
1059                decoded.push_str(&String::from_utf8_lossy(&rest[..valid]));
1060                match error.error_len() {
1061                    // Incomplete final char: keep the tail for the next read.
1062                    None => return (decoded, rest[valid..].to_vec()),
1063                    // Genuinely invalid run: emit one replacement and skip past it.
1064                    Some(bad) => {
1065                        decoded.push('\u{FFFD}');
1066                        rest = &rest[valid + bad..];
1067                    }
1068                }
1069            }
1070        }
1071    }
1072}
1073
1074#[cfg(test)]
1075mod tests {
1076    use super::*;
1077    use tempfile::TempDir;
1078
1079    #[test]
1080    fn decode_passes_clean_utf8_through() {
1081        let (text, carry) = decode_keep_incomplete("hello ✓ café".as_bytes());
1082        assert_eq!(text, "hello ✓ café");
1083        assert!(carry.is_empty());
1084    }
1085
1086    #[test]
1087    fn decode_carries_incomplete_trailing_char_across_reads() {
1088        // "é" is 0xC3 0xA9; a read boundary splits it. The first half must NOT
1089        // turn into U+FFFD — it's held and completed on the next read.
1090        let (text1, carry1) = decode_keep_incomplete(&[b'a', 0xC3]);
1091        assert_eq!(text1, "a");
1092        assert_eq!(carry1, vec![0xC3]);
1093
1094        let mut next = carry1;
1095        next.push(0xA9); // continuation byte arrives in the next read
1096        let (text2, carry2) = decode_keep_incomplete(&next);
1097        assert_eq!(text2, "é");
1098        assert!(carry2.is_empty());
1099    }
1100
1101    #[test]
1102    fn decode_replaces_genuinely_invalid_bytes() {
1103        // 0xFF is never valid UTF-8 and is not an incomplete prefix.
1104        let (text, carry) = decode_keep_incomplete(&[b'x', 0xFF, b'y']);
1105        assert_eq!(text, "x\u{FFFD}y");
1106        assert!(carry.is_empty());
1107    }
1108
1109    #[test]
1110    fn decode_handles_large_invalid_burst_without_overflow() {
1111        // Regression: the first (recursive) version blew the stack — one frame
1112        // per invalid byte — and aborted under panic="abort" on a binary dump.
1113        // The iterative version must handle far more than the 4KB reader buffer.
1114        let big = vec![0xFFu8; 200_000];
1115        let (text, carry) = decode_keep_incomplete(&big);
1116        assert!(carry.is_empty());
1117        assert_eq!(text.chars().filter(|&c| c == '\u{FFFD}').count(), 200_000);
1118    }
1119
1120    #[test]
1121    fn prompt_detection_is_suffix_anchored() {
1122        // Per-shell nonce + exit code after the arrow: `──➤<nonce>:<code>`.
1123        let end = "──➤deadbeefcafe0001";
1124        // real prompt on the last line -> complete
1125        assert!(PtyShell::check_prompt_complete("out\nmore\n◉ /home/x──➤deadbeefcafe0001:0 ", end));
1126        // prompt with trailing ANSI erase -> still complete
1127        assert!(PtyShell::check_prompt_complete("◉ /home/x──➤deadbeefcafe0001:0 \u{1b}[K", end));
1128        // the bug: ◉ and ──➤ appear MID-output, last line is normal -> NOT complete
1129        assert!(!PtyShell::check_prompt_complete(
1130            "menu: ◉ start ──➤deadbeefcafe0001 stop\nstill running",
1131            end
1132        ));
1133        // command echoed after the prompt (not the waiting prompt) -> not complete
1134        assert!(!PtyShell::check_prompt_complete("◉ /home/x──➤deadbeefcafe0001:0 ls -la", end));
1135        // no prompt at all
1136        assert!(!PtyShell::check_prompt_complete("just some output\n", end));
1137        // the nonce's payoff: output that forges the bare glyphs but NOT the
1138        // nonce (or omits the exit code) must not be mistaken for the prompt.
1139        assert!(!PtyShell::check_prompt_complete("◉ /fake──➤ ", end));
1140        assert!(!PtyShell::check_prompt_complete("◉ /fake──➤wrongnonce:0 ", end));
1141        assert!(!PtyShell::check_prompt_complete("◉ /home/x──➤deadbeefcafe0001 ", end));
1142    }
1143
1144    #[test]
1145    fn parses_exit_code_from_prompt_marker() {
1146        let end = "──➤cafe1234";
1147        assert_eq!(PtyShell::parse_prompt_exit_code("ok\n◉ /x──➤cafe1234:0 ", end), Some(0));
1148        assert_eq!(PtyShell::parse_prompt_exit_code("oops\n◉ /x──➤cafe1234:1 ", end), Some(1));
1149        assert_eq!(PtyShell::parse_prompt_exit_code("◉ /x──➤cafe1234:42 ", end), Some(42));
1150        // still running (no completion prompt yet) -> None
1151        assert_eq!(PtyShell::parse_prompt_exit_code("building...", end), None);
1152        // forged with the wrong nonce -> None
1153        assert_eq!(PtyShell::parse_prompt_exit_code("◉ /x──➤wrong:0 ", end), None);
1154    }
1155
1156    use proptest::prelude::*;
1157
1158    proptest! {
1159        // Exit-code parsing runs on untrusted program output — arbitrary text
1160        // (and a forgeable marker) must never panic, only ever return None or a
1161        // parsed i32.
1162        #[test]
1163        fn parse_prompt_exit_code_never_panics(
1164            text in prop::collection::vec(any::<char>(), 0..256),
1165            nonce in "[0-9a-f]{0,16}",
1166        ) {
1167            let s: String = text.into_iter().collect();
1168            let end = format!("{WCGW_PROMPT_END}{nonce}");
1169            // Must not panic; any Option<i32> is acceptable.
1170            let _ = PtyShell::parse_prompt_exit_code(&s, &end);
1171        }
1172
1173        // A well-formed marker round-trips the embedded code for any i32.
1174        #[test]
1175        fn parse_prompt_exit_code_round_trips(code in any::<i32>(), nonce in "[0-9a-f]{1,16}") {
1176            let end = format!("{WCGW_PROMPT_END}{nonce}");
1177            let line = format!("output line\n{WCGW_PROMPT_PATTERN} /home/x{end}:{code} ");
1178            prop_assert_eq!(PtyShell::parse_prompt_exit_code(&line, &end), Some(code));
1179        }
1180    }
1181
1182    #[test]
1183    fn test_pty_shell_creation() -> Result<()> {
1184        let temp_dir = TempDir::new()?;
1185        let result = PtyShell::new(temp_dir.path(), false);
1186        assert!(result.is_ok(), "Failed to create PTY shell: {:?}", result.err());
1187        Ok(())
1188    }
1189
1190    #[test]
1191    fn test_pty_shell_echo() -> Result<()> {
1192        let temp_dir = TempDir::new()?;
1193        let mut shell = PtyShell::new(temp_dir.path(), false)?;
1194
1195        shell.send_command("echo 'hello pty'")?;
1196        let (output, _complete) = shell.read_output(2.0)?;
1197
1198        assert!(output.contains("hello pty"), "Output should contain 'hello pty': {output}");
1199        Ok(())
1200    }
1201
1202    #[test]
1203    fn completed_nonblocking_poll_is_level_triggered() -> Result<()> {
1204        let temp_dir = TempDir::new()?;
1205        let mut shell = PtyShell::new(temp_dir.path(), false)?;
1206
1207        shell.send_command("true")?;
1208        let deadline = Instant::now() + Duration::from_secs(2);
1209        while Instant::now() < deadline && !shell.poll_output_nonblocking() {
1210            std::thread::sleep(Duration::from_millis(10));
1211        }
1212
1213        assert!(!shell.command_running, "shell did not complete before the deadline");
1214        assert!(
1215            shell.poll_output_nonblocking(),
1216            "a later consumer must still observe the completed state"
1217        );
1218        Ok(())
1219    }
1220
1221    #[test]
1222    fn test_pty_shell_pwd() -> Result<()> {
1223        let temp_dir = TempDir::new()?;
1224        let mut shell = PtyShell::new(temp_dir.path(), false)?;
1225
1226        // Simply verify shell responds to pwd command
1227        // Use single quotes like echo test for consistency
1228        shell.send_command("pwd && echo 'pwd_done'")?;
1229        let (output, _complete) = shell.read_output(2.0)?;
1230
1231        // Verify the echo marker appears (proves command executed)
1232        assert!(output.contains("pwd_done"), "Output should contain 'pwd_done': {output}");
1233        Ok(())
1234    }
1235
1236    #[test]
1237    fn test_pty_resize() -> Result<()> {
1238        let temp_dir = TempDir::new()?;
1239        let mut shell = PtyShell::new(temp_dir.path(), false)?;
1240
1241        let result = shell.resize(120, 40);
1242        assert!(result.is_ok());
1243
1244        let (cols, rows) = shell.get_size();
1245        assert_eq!(cols, 120);
1246        assert_eq!(rows, 40);
1247        Ok(())
1248    }
1249
1250    /// `kill(pid, 0)` probes existence without sending a signal: 0 = the pid
1251    /// exists, -1 (ESRCH) = it's gone. A freshly-killed orphan lingers briefly
1252    /// as a zombie under init until reaped, so callers poll.
1253    #[cfg(unix)]
1254    fn pid_alive(pid: i32) -> bool {
1255        // SAFETY: kill(2) with signal 0 only checks permission/existence for an
1256        // integer pid; it sends nothing and touches no memory.
1257        unsafe { libc::kill(pid, 0) == 0 }
1258    }
1259
1260    #[cfg(unix)]
1261    #[test]
1262    fn dropping_shell_kills_orphaned_background_child() -> Result<()> {
1263        // A background job the shell starts must not outlive the shell. Spawn a
1264        // long `sleep` in the background, record its pid, drop the shell, and
1265        // confirm the sleep is gone - proving the group-kill reached past the
1266        // shell to a child `Child::kill` alone would have orphaned.
1267        let dir = TempDir::new()?;
1268        let pidfile = dir.path().join("child.pid");
1269        let mut shell = PtyShell::new(dir.path(), false)?;
1270
1271        shell
1272            .send_command(&format!("sleep 300 & echo $! > {} ; echo spawned", pidfile.display()))?;
1273
1274        // The PTY echoes the input line, so `out` containing "spawned" only proves
1275        // the line was sent - not that bash ran it. Under CI load bash can lag, so
1276        // poll the pidfile (it only appears once `echo $! > pidfile` executes) while
1277        // draining the PTY, instead of trusting the echo and racing the redirect.
1278        let mut child_pid = None;
1279        for _ in 0..150 {
1280            let _ = shell.read_output(0.1);
1281            if let Some(pid) =
1282                std::fs::read_to_string(&pidfile).ok().and_then(|c| c.trim().parse::<i32>().ok())
1283            {
1284                child_pid = Some(pid);
1285                break;
1286            }
1287            thread::sleep(Duration::from_millis(20));
1288        }
1289        let child_pid =
1290            child_pid.ok_or_else(|| anyhow!("background child pid never materialized"))?;
1291        assert!(pid_alive(child_pid), "background child should be running before drop");
1292
1293        drop(shell);
1294
1295        // The group-kill plus init reaping the orphan are async w.r.t. us; poll.
1296        let mut gone = false;
1297        for _ in 0..150 {
1298            if !pid_alive(child_pid) {
1299                gone = true;
1300                break;
1301            }
1302            thread::sleep(Duration::from_millis(20));
1303        }
1304        assert!(gone, "background child {child_pid} survived shell teardown (orphan leak)");
1305        Ok(())
1306    }
1307}