Struct TmuxManager 

pub struct TmuxManager { /* private fields */ }

Manage tmux sessions for agent tasks.

Implementations

impl TmuxManager

pub fn new() -> Self

pub fn session_name(&self, project: &str, task_id: &str) -> String

Session name for a task: orch-{project}-{task_id}.

The project name is derived from the repo slug (e.g. owner/repo → repo). This prevents collisions between projects with the same issue number.

pub async fn create_session( &self, repo: &str, task_id: &str, working_dir: &str, command: &str, env_vars: &[(&str, &str)], ) -> Result<String>

Create a new tmux session for a task and run a command in it.

Environment variables in env_vars are injected into the session via tmux new-session -e KEY=VALUE — they are not written to disk.

The session is detached — the agent runs in the background. Returns the session name.

Note: GH_TOKEN is passed here via -e like all other env vars. Do NOT use create_session_detached + set_env + create_window to avoid exposing secrets in process args — that creates a 2-window session which breaks all tmux monitoring (completion detection, output capture, silence detection) because they target the default window (the idle shell), not the agent window. See the revert of PR #2903.

pub async fn session_exists(&self, session: &str) -> bool

Check if a session exists.

pub async fn kill_session(&self, session: &str) -> Result<()>

Kill a session.

pub async fn capture_pane(&self, session: &str, lines: i32) -> Result<String>

Capture the current pane content (last N lines).

Returns Ok(String::new()) if the session or pane is not found — this is an expected teardown race when the session was cleaned up between the caller’s is_session_active() check and this capture.

pub async fn is_session_active(&self, session: &str) -> bool

Check if the process in a session’s pane is still running. Returns false if the session doesn’t exist or the pane has no active process.

pub async fn session_blocks_dispatch(&self, session: &str) -> bool

Return whether a session should block a new dispatch.

Dead tmux sessions with the same name are cleaned up eagerly so they do not block reclaim/re-dispatch loops or cause new-session name collisions.

pub async fn session_blocks_dispatch_from_map( &self, session: &str, session_map: &HashMap<String, bool>, ) -> bool

Batch variant of session_blocks_dispatch that uses a pre-fetched session map.

session_map is the result of batch_session_active(). Sessions absent from the map do not exist (→ no block). Sessions present with alive=true block dispatch. Sessions present with alive=false have a dead pane and are cleaned up eagerly.

pub async fn batch_session_active(&self) -> HashMap<String, bool>

Get pane_dead status for all sessions in a single tmux call.

Returns a map from session name → alive (true = alive, false = dead/missing). Uses list-panes -a to avoid one subprocess per session.

pub async fn list_sessions(&self) -> Result<Vec<Session>>

List all orch-prefixed sessions with metadata including creation time.

pub async fn kill_stale_sessions(&self, before_timestamp: u64) -> Result<usize>

Kill all orch-prefixed sessions created before a given timestamp. Returns the number of sessions killed.

pub async fn wait_for_sessions_dead( &self, sessions: &[String], poll_interval: Duration, timeout: Duration, ) -> usize

Wait for multiple sessions to be fully dead (no longer exist). Polls every poll_interval up to timeout. Returns the number of sessions that were still alive after timeout.

pub async fn wait_for_completion( &self, session: &str, poll_interval: Duration, ) -> Result<String>

Wait for a session to finish (pane process exits). Returns the captured output from the last N lines.

pub async fn snapshot(&self) -> Vec<(Session, bool)>

Snapshot all orch-prefixed sessions — for engine tick monitoring.

Returns a vector of (Session, alive) so callers can operate on the actual session name instead of reconstructing one from repo+task_id.

Uses batch_session_active() internally to fetch all pane-dead statuses in a single subprocess call instead of one call per session (N+1 → 2).

pub async fn unset_env(&self, session: &str, key: &str) -> Result<()>

Unset (remove) an environment variable from a tmux session.

pub async fn unset_global_env(&self, key: &str) -> Result<()>

Unset (remove) an environment variable from the tmux global environment.

Uses: tmux set-environment -gu <key>

Trait Implementations

impl Clone for TmuxManager

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.