ilmari 0.9.3

//! Provider-neutral tmux badge and compact status publication.
//!
//! The daemon writes pane-local attention badges and a global status summary so
//! status-lines and scripts stay agent-agnostic. Waiting and finished attention
//! latch until the pane is focused (or the session leaves that state), so a brief
//! glance at the badge is enough after a popup is closed.

use std::collections::{HashMap, HashSet};

use crate::colors::Palette;
use crate::config::{RendererConfig, StateFormat, StatePresentations};
use crate::model::{SessionRecord, SessionStatus};
use crate::tmux;

/// Resolved badge and compact-status templates after TOML style/symbol merge.
#[derive(Debug, Clone, PartialEq, Eq)]
pub struct RenderSettings {
    pub badges_enabled: bool,
    pub status_enabled: bool,
    /// Whether badges include the same agent identity shown by the popup's app column.
    pub show_agent_names: bool,
    /// Whether ordinary lifecycle states render outside sticky attention.
    pub shared_state_behavior: bool,
    pub badge_running: StateFormat,
    pub badge_waiting: StateFormat,
    pub badge_finished: StateFormat,
    pub badge_terminated: StateFormat,
    pub badge_unknown: StateFormat,
    pub badge_attention: StateFormat,
    pub status_running: StateFormat,
    pub status_waiting: StateFormat,
    pub status_finished: StateFormat,
    pub status_terminated: StateFormat,
    pub status_unknown: StateFormat,
    pub status_attention: StateFormat,
    pub badge_separator: String,
    pub status_separator: String,
}

impl Default for RenderSettings {
    fn default() -> Self {
        let states = StatePresentations::default();
        let palette = Palette::default();
        Self {
            badges_enabled: true,
            status_enabled: true,
            show_agent_names: false,
            shared_state_behavior: true,
            badge_running: states.running.tmux_format(&palette),
            badge_waiting: states.waiting_input.tmux_format(&palette),
            badge_finished: states.finished.tmux_format(&palette),
            badge_terminated: states.terminated.tmux_format(&palette),
            badge_unknown: states.unknown.tmux_format(&palette),
            badge_attention: states.attention.tmux_format(&palette),
            status_running: states.running.tmux_format(&palette),
            status_waiting: states.waiting_input.tmux_format(&palette),
            status_finished: states.finished.tmux_format(&palette),
            status_terminated: states.terminated.tmux_format(&palette),
            status_unknown: states.unknown.tmux_format(&palette),
            status_attention: states.attention.tmux_format(&palette),
            badge_separator: " ".to_string(),
            status_separator: " ".to_string(),
        }
    }
}

impl RenderSettings {
    /// Build pane badge and global status templates from legacy renderer blocks,
    /// unless a shared `[states]` presentation is configured.
    pub fn from_config(
        palette: &Palette,
        badges: &RendererConfig,
        status: &RendererConfig,
        states: Option<&StatePresentations>,
        legacy_badge_state_formats: bool,
        legacy_status_state_formats: bool,
        show_agent_names: bool,
    ) -> Self {
        let default_states = StatePresentations::default();
        let shared_states = states.unwrap_or(&default_states);
        let shared_state_behavior =
            states.is_some() || !(legacy_badge_state_formats || legacy_status_state_formats);
        let use_legacy_badges = states.is_none() && legacy_badge_state_formats;
        let use_legacy_status = states.is_none() && legacy_status_state_formats;
        Self {
            badges_enabled: badges.enabled,
            status_enabled: status.enabled,
            show_agent_names,
            shared_state_behavior,
            badge_running: if use_legacy_badges {
                badges.running.clone()
            } else {
                shared_states.running.tmux_format(palette)
            },
            badge_waiting: if use_legacy_badges {
                badges.waiting_input.clone()
            } else {
                shared_states.waiting_input.tmux_format(palette)
            },
            badge_finished: if use_legacy_badges {
                badges.finished.clone()
            } else {
                shared_states.finished.tmux_format(palette)
            },
            badge_terminated: shared_states.terminated.tmux_format(palette),
            badge_unknown: shared_states.unknown.tmux_format(palette),
            badge_attention: shared_states.attention.tmux_format(palette),
            status_running: if use_legacy_status {
                status.running.clone()
            } else {
                shared_states.running.tmux_format(palette)
            },
            status_waiting: if use_legacy_status {
                status.waiting_input.clone()
            } else {
                shared_states.waiting_input.tmux_format(palette)
            },
            status_finished: if use_legacy_status {
                status.finished.clone()
            } else {
                shared_states.finished.tmux_format(palette)
            },
            status_terminated: shared_states.terminated.tmux_format(palette),
            status_unknown: shared_states.unknown.tmux_format(palette),
            status_attention: shared_states.attention.tmux_format(palette),
            badge_separator: badges.separator.clone(),
            status_separator: status.separator.clone(),
        }
    }
}

/// Aggregated counts used by the global compact status fragment.
#[derive(Debug, Clone, Copy, Default, PartialEq, Eq)]
pub struct StatusCounts {
    /// Unacknowledged waiting/finished panes, rendered with the attention glyph.
    pub attention: usize,
    /// Sticky attention split retained for legacy count-option compatibility.
    pub attention_waiting: usize,
    /// Sticky attention split retained for legacy count-option compatibility.
    pub attention_finished: usize,
    pub running: usize,
    pub waiting: usize,
    pub finished: usize,
    pub terminated: usize,
    pub unknown: usize,
}

/// Per-pane attention latch for waiting/finished until focus acknowledges them.
///
/// `pending_*` holds transitions observed while focus probes are unavailable so a
/// brief scan glitch does not drop the badge when focus state returns.
#[derive(Debug, Clone, Copy, Default)]
struct PaneAttention {
    last_status: Option<SessionStatus>,
    waiting: bool,
    finished: bool,
    pending_waiting: bool,
    pending_finished: bool,
}

/// Incremental publisher of pane badges and the `@ilmari_status_summary` option.
#[derive(Debug, Default)]
pub struct TmuxStatePublisher {
    panes: HashMap<String, PaneAttention>,
    last_sessions: HashMap<String, SessionRecord>,
    current_session_ids: HashSet<String>,
    previously_published: HashSet<String>,
    badges_enabled: Option<bool>,
    status_enabled: Option<bool>,
}

impl TmuxStatePublisher {
    /// Advance the shared sticky-attention latch from one direct pane scan.
    ///
    /// Popup snapshots and tmux badges both project this exact latch; lifecycle
    /// states alone are never treated as attention. Daemon-originated sticky
    /// attention published as pane-local `@ilmari_attention` is rehydrated first so a
    /// failed daemon snapshot followed by a direct scan does not drop the latch.
    pub fn refresh_attention(
        &mut self,
        sessions: &[SessionRecord],
        live_panes: &[tmux::PaneSnapshot],
    ) {
        let live_pane_ids =
            live_panes.iter().map(|pane| pane.pane_id.clone()).collect::<HashSet<_>>();
        let focused = tmux::focused_pane_ids();
        let live_sessions = sessions
            .iter()
            .filter(|session| live_pane_ids.contains(&session.pane.pane_id))
            .cloned()
            .collect::<Vec<_>>();
        self.panes.retain(|pane_id, _| live_pane_ids.contains(pane_id));
        self.last_sessions.retain(|pane_id, _| live_pane_ids.contains(pane_id));
        for session in &live_sessions {
            self.last_sessions.insert(session.pane.pane_id.clone(), session.clone());
        }
        for pane in live_panes {
            if let Some(session) = self.last_sessions.get_mut(&pane.pane_id) {
                session.pane = pane.clone();
            }
        }
        self.hydrate_attention_from_panes(live_panes, &live_sessions, focused.as_ref().ok());
        self.current_session_ids =
            live_sessions.iter().map(|session| session.pane.pane_id.clone()).collect();
        match focused {
            Ok(focused) => self.update_attention(&live_sessions, &focused, true),
            Err(_) => self.update_attention(&live_sessions, &HashSet::new(), false),
        }
    }

    /// Seed missing latch entries from durable pane options without inventing transitions.
    ///
    /// Only panes that are not yet tracked locally are hydrated, so a live publisher's
    /// acknowledge/clear decisions win over a stale option. Lifecycle status alone never
    /// sets the latch; only an explicit `@ilmari_attention=1` bit does.
    fn hydrate_attention_from_panes(
        &mut self,
        live_panes: &[tmux::PaneSnapshot],
        sessions: &[SessionRecord],
        focused: Option<&HashSet<String>>,
    ) {
        self.hydrate_attention_from_panes_with(live_panes, sessions, focused, |pane_id, value| {
            let _ = tmux::set_pane_option(pane_id, "@ilmari_attention", value);
        });
    }

    /// Reconcile durable daemon attention with a direct scan.
    ///
    /// The callback is kept at this boundary so the state transition is testable without a
    /// tmux server. Production persists the resulting value through the wrapper above.
    fn hydrate_attention_from_panes_with(
        &mut self,
        live_panes: &[tmux::PaneSnapshot],
        sessions: &[SessionRecord],
        focused: Option<&HashSet<String>>,
        mut set_durable_attention: impl FnMut(&str, Option<&str>),
    ) {
        let status_by_pane = sessions
            .iter()
            .map(|session| (session.pane.pane_id.as_str(), session.status))
            .collect::<HashMap<_, _>>();
        for pane in live_panes {
            if !pane.ilmari_attention {
                continue;
            }
            let status = status_by_pane.get(pane.pane_id.as_str()).copied();
            if matches!(
                status,
                Some(SessionStatus::Running | SessionStatus::Terminated | SessionStatus::Unknown)
            ) {
                // A popup does not publish rendered state. Without clearing the durable bit
                // here, a later popup could rehydrate old daemon attention after this pane has
                // returned to an ineligible lifecycle state.
                set_durable_attention(&pane.pane_id, Some("0"));
                continue;
            }
            if self.panes.contains_key(&pane.pane_id) {
                continue;
            }
            if Self::should_acknowledge_durable_attention(pane, focused) {
                // This direct popup scan is authoritative enough to acknowledge a durable
                // daemon latch. Persist the acknowledgement so reopening the popup while the
                // daemon is unavailable cannot revive the stale badge.
                set_durable_attention(&pane.pane_id, Some("0"));
                continue;
            }
            let mut attention = PaneAttention::default();
            match status {
                Some(SessionStatus::WaitingInput) => attention.waiting = true,
                Some(SessionStatus::Finished) => attention.finished = true,
                Some(_) | None => {
                    // A bare option for an unclassified pane is not enough to invent sticky
                    // attention. Keep it until a later direct scan has a concrete lifecycle;
                    // classification glitches must not erase a daemon-published latch.
                }
            }
            if attention.waiting || attention.finished {
                self.panes.insert(pane.pane_id.clone(), attention);
            }
        }
    }

    fn should_acknowledge_durable_attention(
        pane: &tmux::PaneSnapshot,
        focused: Option<&HashSet<String>>,
    ) -> bool {
        pane.ilmari_attention && focused.is_some_and(|focused| focused.contains(&pane.pane_id))
    }

    /// Copy the authoritative latch into runtime records for popup/IPC presentation.
    pub fn project_attention(&self, sessions: &mut [SessionRecord]) {
        for session in sessions {
            let attention = self.panes.get(&session.pane.pane_id).copied().unwrap_or_default();
            session.attention = attention.waiting || attention.finished;
        }
    }

    /// Render and publish tmux options from the latch advanced by [`Self::refresh_attention`].
    pub fn publish_rendered_state(
        &mut self,
        live_panes: &[tmux::PaneSnapshot],
        settings: &RenderSettings,
    ) {
        let live_pane_ids =
            live_panes.iter().map(|pane| pane.pane_id.clone()).collect::<HashSet<_>>();
        let render_sessions = self.sessions_for_render();
        let rendered = self.render(&render_sessions, settings);
        self.publish_rendered(&rendered, &live_pane_ids, settings);
    }

    /// Clear latched waiting/finished attention when a pane is focused between full refreshes.
    ///
    /// Also reapplies live `@ilmari_*_enabled` overrides so status-line toggles take effect
    /// without waiting for the next pane scan.
    pub fn acknowledge_focus(&mut self, settings: &RenderSettings) -> bool {
        let Ok(state) = tmux::focus_and_renderer_overrides() else {
            return false;
        };
        let changed = self.resolve_known_focus(&state.focused_pane_ids);
        let badges_enabled = option_override_value(state.badges_enabled.as_deref())
            .unwrap_or(settings.badges_enabled);
        let status_enabled = option_override_value(state.status_enabled.as_deref())
            .unwrap_or(settings.status_enabled);
        let rendering_changed = self.badges_enabled != Some(badges_enabled)
            || self.status_enabled != Some(status_enabled);
        if !changed && !rendering_changed {
            return false;
        }
        let sessions = self.sessions_for_render();
        let rendered = self.render(&sessions, settings);
        let live_pane_ids = self.previously_published.clone();
        self.publish_rendered(&rendered, &live_pane_ids, settings);
        changed
    }

    fn sessions_for_render(&self) -> Vec<SessionRecord> {
        let mut sessions = self
            .last_sessions
            .iter()
            .filter_map(|(pane_id, session)| {
                let attention = self.panes.get(pane_id).copied().unwrap_or_default();
                (self.current_session_ids.contains(pane_id)
                    || attention.waiting
                    || attention.finished)
                    .then(|| session.clone())
            })
            .collect::<Vec<_>>();
        sessions.sort_by(|left, right| left.pane.pane_id.cmp(&right.pane.pane_id));
        sessions
    }

    fn publish_rendered(
        &mut self,
        rendered: &RenderedState,
        live_pane_ids: &HashSet<String>,
        settings: &RenderSettings,
    ) {
        for pane_id in self.previously_published.difference(live_pane_ids) {
            clear_pane_daemon_state(pane_id);
        }
        for pane_id in live_pane_ids {
            if let Some(values) = rendered.pane_values.get(pane_id) {
                let _ = tmux::set_pane_option(pane_id, "@ilmari_state", Some(&values.state));
                let _ = tmux::set_pane_option(pane_id, "@ilmari_badge", Some(&values.badge));
                let _ = tmux::set_pane_option(
                    pane_id,
                    "@ilmari_attention",
                    Some(if values.attention { "1" } else { "0" }),
                );
            } else {
                clear_pane_daemon_state(pane_id);
            }
        }

        let badges_enabled =
            option_override("@ilmari_badges_enabled").unwrap_or(settings.badges_enabled);
        let status_enabled =
            option_override("@ilmari_status_enabled").unwrap_or(settings.status_enabled);
        self.badges_enabled = Some(badges_enabled);
        self.status_enabled = Some(status_enabled);
        let _ = tmux::set_global_option(
            "@ilmari_window_badges",
            if badges_enabled { &rendered.window_fragment } else { "" },
        );
        let _ = tmux::set_global_option(
            "@ilmari_status_summary",
            if status_enabled { &rendered.status_summary } else { "" },
        );
        let _ =
            tmux::set_global_option("@ilmari_running_count", &rendered.counts.running.to_string());
        // Keep the original notification-specific options stable. State counts use
        // explicit new names because ordinary waiting/finished are now rendered too.
        let _ = tmux::set_global_option(
            "@ilmari_waiting_count",
            &rendered.counts.attention_waiting.to_string(),
        );
        let _ = tmux::set_global_option(
            "@ilmari_finished_count",
            &rendered.counts.attention_finished.to_string(),
        );
        let _ = tmux::set_global_option(
            "@ilmari_attention_count",
            &rendered.counts.attention.to_string(),
        );
        let _ = tmux::set_global_option(
            "@ilmari_waiting_state_count",
            &rendered.counts.waiting.to_string(),
        );
        let _ = tmux::set_global_option(
            "@ilmari_finished_state_count",
            &rendered.counts.finished.to_string(),
        );
        let _ = tmux::set_global_option(
            "@ilmari_terminated_count",
            &rendered.counts.terminated.to_string(),
        );
        let _ =
            tmux::set_global_option("@ilmari_unknown_count", &rendered.counts.unknown.to_string());
        self.previously_published = live_pane_ids.clone();
    }

    /// Latch waiting/finished on status transitions for unfocused panes.
    ///
    /// When `allow_new_attention` is false (focus probe failed), transitions go to
    /// pending bits instead of live badges so focus recovery can promote them.
    fn update_attention(
        &mut self,
        sessions: &[SessionRecord],
        focused: &HashSet<String>,
        allow_new_attention: bool,
    ) {
        if allow_new_attention {
            self.resolve_known_focus(focused);
        }

        for session in sessions {
            let attention = self.panes.entry(session.pane.pane_id.clone()).or_default();
            if !focused.contains(&session.pane.pane_id) {
                // An unfocused pane no longer needs acknowledgement after it leaves the
                // state that created the latch. Clear pending bits too: a failed focus
                // probe must not later promote stale attention for a running pane.
                if session.status != SessionStatus::WaitingInput {
                    attention.waiting = false;
                    attention.pending_waiting = false;
                }
                if session.status != SessionStatus::Finished {
                    attention.finished = false;
                    attention.pending_finished = false;
                }
            }
            let transitioned = attention.last_status.is_some_and(|last| last != session.status);
            if transitioned && !focused.contains(&session.pane.pane_id) {
                match session.status {
                    SessionStatus::WaitingInput if allow_new_attention => attention.waiting = true,
                    SessionStatus::WaitingInput => attention.pending_waiting = true,
                    SessionStatus::Finished if allow_new_attention => attention.finished = true,
                    SessionStatus::Finished => attention.pending_finished = true,
                    _ => {}
                }
            }
            attention.last_status = Some(session.status);
        }
    }

    /// Clear latched attention for focused panes; promote pending bits for others.
    fn resolve_known_focus(&mut self, focused: &HashSet<String>) -> bool {
        let mut changed = false;
        for (pane_id, attention) in &mut self.panes {
            if focused.contains(pane_id) {
                changed |= attention.waiting
                    || attention.finished
                    || attention.pending_waiting
                    || attention.pending_finished;
                attention.waiting = false;
                attention.finished = false;
                attention.pending_waiting = false;
                attention.pending_finished = false;
            } else {
                changed |= attention.pending_waiting || attention.pending_finished;
                attention.waiting |= attention.pending_waiting;
                attention.finished |= attention.pending_finished;
                attention.pending_waiting = false;
                attention.pending_finished = false;
            }
        }
        changed
    }

    /// Build pane badge strings and global status counts from latched attention.
    fn render(&self, sessions: &[SessionRecord], settings: &RenderSettings) -> RenderedState {
        let mut counts = StatusCounts::default();
        let mut windows: HashMap<&str, Vec<String>> = HashMap::new();
        let mut pane_values = HashMap::new();

        for session in sessions {
            let attention = self.panes.get(&session.pane.pane_id).copied().unwrap_or_default();
            let (state, format) = if attention.waiting || attention.finished {
                counts.attention += 1;
                if attention.waiting {
                    counts.attention_waiting += 1;
                } else {
                    counts.attention_finished += 1;
                }
                let format = if settings.shared_state_behavior {
                    &settings.badge_attention
                } else if attention.waiting {
                    &settings.badge_waiting
                } else {
                    &settings.badge_finished
                };
                (session.status.as_str(), Some(format))
            } else {
                match session.status {
                    SessionStatus::Running => {
                        counts.running += 1;
                        ("running", Some(&settings.badge_running))
                    }
                    SessionStatus::WaitingInput if settings.shared_state_behavior => {
                        counts.waiting += 1;
                        ("waiting-input", Some(&settings.badge_waiting))
                    }
                    SessionStatus::Finished if settings.shared_state_behavior => {
                        counts.finished += 1;
                        ("finished", Some(&settings.badge_finished))
                    }
                    SessionStatus::Terminated if settings.shared_state_behavior => {
                        counts.terminated += 1;
                        ("terminated", Some(&settings.badge_terminated))
                    }
                    SessionStatus::Unknown if settings.shared_state_behavior => {
                        counts.unknown += 1;
                        ("unknown", Some(&settings.badge_unknown))
                    }
                    _ => (session.status.as_str(), None),
                }
            };
            let has_attention = attention.waiting || attention.finished;
            let badge = format
                .map(|format| render_badge(format, session, settings.show_agent_names))
                .unwrap_or_default();
            if !badge.is_empty() {
                windows.entry(&session.pane.window_id).or_default().push(badge.clone());
            }
            pane_values.insert(
                session.pane.pane_id.clone(),
                PanePublishedValues { state: state.to_string(), badge, attention: has_attention },
            );
        }

        let mut window_ids = windows.keys().copied().collect::<Vec<_>>();
        window_ids.sort_unstable_by(|left, right| compare_tmux_window_ids(left, right));
        // Separators are config-validated plain text; only escape format introducers here.
        // Commas are escaped once when the joined badges are embedded in `#{?}`.
        let separator = tmux_content_literal(&settings.badge_separator);
        let window_fragment = window_ids
            .into_iter()
            .map(|window_id| {
                let badges = windows.get(window_id).cloned().unwrap_or_default().join(&separator);
                window_badge_conditional(window_id, &badges)
            })
            .collect::<String>();

        let mut status_parts = Vec::new();
        if settings.shared_state_behavior {
            if counts.attention > 0 {
                status_parts.push(render_count(&settings.status_attention, counts.attention));
            }
            if counts.waiting > 0 {
                status_parts.push(render_count(&settings.status_waiting, counts.waiting));
            }
            if counts.finished > 0 {
                status_parts.push(render_count(&settings.status_finished, counts.finished));
            }
            if counts.running > 0 {
                status_parts.push(render_count(&settings.status_running, counts.running));
            }
            if counts.terminated > 0 {
                status_parts.push(render_count(&settings.status_terminated, counts.terminated));
            }
            if counts.unknown > 0 {
                status_parts.push(render_count(&settings.status_unknown, counts.unknown));
            }
        } else {
            if counts.attention_waiting > 0 {
                status_parts.push(render_count(&settings.status_waiting, counts.attention_waiting));
            }
            if counts.attention_finished > 0 {
                status_parts
                    .push(render_count(&settings.status_finished, counts.attention_finished));
            }
            if counts.running > 0 {
                status_parts.push(render_count(&settings.status_running, counts.running));
            }
        }

        RenderedState {
            counts,
            pane_values,
            window_fragment,
            status_summary: status_parts.join(&tmux_content_literal(&settings.status_separator)),
        }
    }
}

struct RenderedState {
    counts: StatusCounts,
    pane_values: HashMap<String, PanePublishedValues>,
    window_fragment: String,
    status_summary: String,
}

#[derive(Debug, Clone, PartialEq, Eq)]
struct PanePublishedValues {
    state: String,
    badge: String,
    attention: bool,
}

fn clear_pane_daemon_state(pane_id: &str) {
    let _ = tmux::set_pane_option(pane_id, "@ilmari_state", None);
    let _ = tmux::set_pane_option(pane_id, "@ilmari_badge", None);
    let _ = tmux::set_pane_option(pane_id, "@ilmari_attention", None);
}

fn render_badge(format: &StateFormat, session: &SessionRecord, show_agent_names: bool) -> String {
    let label = if show_agent_names { session.kind.display_name() } else { "" };
    styled(&format.style, &format.symbol, label)
}

fn render_count(format: &StateFormat, count: usize) -> String {
    styled(&format.style, &format.symbol, &count.to_string())
}

fn styled(style: &str, symbol: &str, suffix: &str) -> String {
    let style = style.trim();
    // Symbols and suffixes are dynamic text; escape format introducers so they cannot inject
    // format ops. Commas are left alone here and escaped once when embedded in `#{?}`.
    // Styles remain trusted raw tmux style input (including commas inside `#[...]`).
    let symbol = tmux_content_literal(symbol);
    let content = if suffix.is_empty() {
        symbol
    } else {
        format!("{symbol} {}", tmux_content_literal(suffix))
    };
    if style.is_empty() {
        content
    } else {
        // `default` normally resets to the status line's default style, which can
        // drop an enclosing selected-window background before a later badge.
        // Scope the reset to the style active at this insertion point instead.
        format!("#[push-default]#[{style}]{content}#[default]#[pop-default]")
    }
}

/// Build one window's badge conditional without sentinel string replacement.
fn window_badge_conditional(window_id: &str, badges: &str) -> String {
    // Embed with comma-escaping so trusted style commas and labels cannot split `#{?}`.
    format!(
        "#{{?#{{==:#{{window_id}},{}}},{},}}",
        tmux::quote_tmux_format_literal(window_id),
        tmux::escape_tmux_format_embedded(badges)
    )
}

/// Escape `#` and `}` in free-standing dynamic text. Commas are handled at `#{?}` embed time.
fn tmux_content_literal(value: &str) -> String {
    value.replace('#', "##").replace('}', "#}")
}

/// Sort `@N` window ids by numeric N so `@2` precedes `@10` (string sort would reverse them).
fn compare_tmux_window_ids(left: &str, right: &str) -> std::cmp::Ordering {
    match (tmux_window_id_number(left), tmux_window_id_number(right)) {
        (Some(left_n), Some(right_n)) => left_n.cmp(&right_n).then_with(|| left.cmp(right)),
        (Some(_), None) => std::cmp::Ordering::Less,
        (None, Some(_)) => std::cmp::Ordering::Greater,
        (None, None) => left.cmp(right),
    }
}

fn tmux_window_id_number(window_id: &str) -> Option<u64> {
    window_id.strip_prefix('@')?.parse().ok()
}

fn option_override(name: &str) -> Option<bool> {
    option_override_value(tmux::global_option(name).ok().as_deref())
}

fn option_override_value(value: Option<&str>) -> Option<bool> {
    match value?.trim().to_ascii_lowercase().as_str() {
        "1" | "on" | "true" | "yes" => Some(true),
        "0" | "off" | "false" | "no" => Some(false),
        _ => None,
    }
}

#[cfg(test)]
mod tests {
    use super::{RenderSettings, TmuxStatePublisher};
    use crate::colors::ColorSpec;
    use crate::config::{StateFormat, StatePresentation, StatePresentations};
    use crate::model::{AgentKind, SessionRecord, SessionStatus};
    use crate::tmux::PaneSnapshot;
    use std::collections::HashSet;
    use std::time::Instant;

    #[test]
    fn sticky_attention_acknowledges_exact_focused_pane_and_does_not_recreate_unchanged() {
        let mut publisher = TmuxStatePublisher::default();
        let running = session("%1", "@1", AgentKind::Codex, SessionStatus::Running);
        publisher.update_attention(std::slice::from_ref(&running), &HashSet::new(), true);
        let waiting = session("%1", "@1", AgentKind::Codex, SessionStatus::WaitingInput);
        publisher.update_attention(std::slice::from_ref(&waiting), &HashSet::new(), true);
        assert_eq!(
            publisher
                .render(std::slice::from_ref(&waiting), &RenderSettings::default())
                .counts
                .attention,
            1
        );

        publisher.update_attention(
            std::slice::from_ref(&waiting),
            &HashSet::from(["%1".to_string()]),
            true,
        );
        assert_eq!(
            publisher
                .render(std::slice::from_ref(&waiting), &RenderSettings::default())
                .counts
                .attention,
            0
        );
        publisher.update_attention(std::slice::from_ref(&waiting), &HashSet::new(), true);
        assert_eq!(
            publisher
                .render(std::slice::from_ref(&waiting), &RenderSettings::default())
                .counts
                .attention,
            0
        );
    }

    #[test]
    fn shared_projection_never_infers_attention_from_waiting_or_finished_status() {
        let mut publisher = TmuxStatePublisher::default();
        let mut waiting = session("%1", "@1", AgentKind::Codex, SessionStatus::WaitingInput);
        publisher.update_attention(std::slice::from_ref(&waiting), &HashSet::new(), true);
        publisher.project_attention(std::slice::from_mut(&mut waiting));
        assert!(!waiting.attention, "initial waiting state is not an attention transition");

        let running = session("%1", "@1", AgentKind::Codex, SessionStatus::Running);
        publisher.update_attention(std::slice::from_ref(&running), &HashSet::new(), true);
        publisher.update_attention(std::slice::from_ref(&waiting), &HashSet::new(), true);
        publisher.project_attention(std::slice::from_mut(&mut waiting));
        assert!(waiting.attention, "an unfocused transition projects the shared latch");
    }

    #[test]
    fn unfocused_panes_clear_sticky_attention_after_returning_to_running() {
        for status in [SessionStatus::WaitingInput, SessionStatus::Finished] {
            let mut publisher = TmuxStatePublisher::default();
            let running = session("%1", "@1", AgentKind::Codex, SessionStatus::Running);
            publisher.update_attention(std::slice::from_ref(&running), &HashSet::new(), true);

            let attention = session("%1", "@1", AgentKind::Codex, status);
            publisher.update_attention(std::slice::from_ref(&attention), &HashSet::new(), true);
            assert_eq!(attention_count(&publisher, &attention, status), 1);

            publisher.update_attention(std::slice::from_ref(&running), &HashSet::new(), true);
            let rendered =
                publisher.render(std::slice::from_ref(&running), &RenderSettings::default());
            assert_eq!(rendered.counts.attention, 0);
            assert_eq!(rendered.counts.running, 1);
            let values =
                rendered.pane_values.get("%1").expect("running pane should have a rendered badge");
            assert!(values.badge.contains("▶"));
            assert!(!values.badge.contains("?"));
            assert!(!values.attention);
        }
    }

    #[test]
    fn pending_waiting_and_finished_are_acknowledged_when_focus_recovers_on_the_pane() {
        for status in [SessionStatus::WaitingInput, SessionStatus::Finished] {
            let mut publisher = TmuxStatePublisher::default();
            let running = session("%1", "@1", AgentKind::Codex, SessionStatus::Running);
            publisher.update_attention(std::slice::from_ref(&running), &HashSet::new(), true);

            let transitioned = session("%1", "@1", AgentKind::Codex, status);
            publisher.update_attention(std::slice::from_ref(&transitioned), &HashSet::new(), false);
            assert_eq!(attention_count(&publisher, &transitioned, status), 0);
            assert!(has_pending(&publisher, "%1", status));

            let focused = HashSet::from(["%1".to_string()]);
            publisher.update_attention(std::slice::from_ref(&transitioned), &focused, true);
            assert_eq!(attention_count(&publisher, &transitioned, status), 0);
            assert!(!has_pending(&publisher, "%1", status));

            // The acknowledged unchanged state must not recreate attention.
            publisher.update_attention(std::slice::from_ref(&transitioned), &HashSet::new(), true);
            assert_eq!(attention_count(&publisher, &transitioned, status), 0);

            // A later legitimate transition still creates attention.
            publisher.update_attention(std::slice::from_ref(&running), &HashSet::new(), true);
            publisher.update_attention(std::slice::from_ref(&transitioned), &HashSet::new(), true);
            assert_eq!(attention_count(&publisher, &transitioned, status), 1);
        }
    }

    #[test]
    fn pending_waiting_and_finished_become_sticky_when_focus_recovers_elsewhere() {
        for status in [SessionStatus::WaitingInput, SessionStatus::Finished] {
            let mut publisher = TmuxStatePublisher::default();
            let running = session("%1", "@1", AgentKind::Codex, SessionStatus::Running);
            publisher.update_attention(std::slice::from_ref(&running), &HashSet::new(), true);

            let transitioned = session("%1", "@1", AgentKind::Codex, status);
            publisher.update_attention(std::slice::from_ref(&transitioned), &HashSet::new(), false);
            assert_eq!(attention_count(&publisher, &transitioned, status), 0);
            assert!(has_pending(&publisher, "%1", status));

            publisher.update_attention(
                std::slice::from_ref(&transitioned),
                &HashSet::from(["%2".to_string()]),
                true,
            );
            assert_eq!(attention_count(&publisher, &transitioned, status), 1);
            assert!(!has_pending(&publisher, "%1", status));

            // Neither another failed lookup nor an unchanged successful scan acknowledges it.
            publisher.update_attention(std::slice::from_ref(&transitioned), &HashSet::new(), false);
            assert_eq!(attention_count(&publisher, &transitioned, status), 1);
            publisher.update_attention(
                std::slice::from_ref(&transitioned),
                &HashSet::from(["%2".to_string()]),
                true,
            );
            assert_eq!(attention_count(&publisher, &transitioned, status), 1);

            publisher.update_attention(
                std::slice::from_ref(&transitioned),
                &HashSet::from(["%1".to_string()]),
                true,
            );
            assert_eq!(attention_count(&publisher, &transitioned, status), 0);
            publisher.update_attention(std::slice::from_ref(&transitioned), &HashSet::new(), true);
            assert_eq!(attention_count(&publisher, &transitioned, status), 0);
        }
    }

    #[test]
    fn finished_attention_retains_metadata_after_agent_record_disappears_until_focus() {
        let mut publisher = TmuxStatePublisher::default();
        let running = session("%1", "@1", AgentKind::Codex, SessionStatus::Running);
        publisher.last_sessions.insert("%1".to_string(), running.clone());
        publisher.update_attention(std::slice::from_ref(&running), &HashSet::new(), true);
        let finished = session("%1", "@1", AgentKind::Codex, SessionStatus::Finished);
        publisher.last_sessions.insert("%1".to_string(), finished.clone());
        publisher.update_attention(std::slice::from_ref(&finished), &HashSet::new(), true);

        publisher.current_session_ids.clear();
        let retained = publisher.sessions_for_render();
        assert_eq!(retained.len(), 1);
        assert_eq!(publisher.render(&retained, &RenderSettings::default()).counts.attention, 1);

        publisher.update_attention(&[], &HashSet::from(["%1".to_string()]), true);
        assert!(publisher.sessions_for_render().is_empty());
    }

    #[test]
    fn aggregates_multiple_providers_in_one_window_with_priority_counts() {
        let mut publisher = TmuxStatePublisher::default();
        let initial = vec![
            session("%1", "@1", AgentKind::Codex, SessionStatus::Running),
            session("%2", "@1", AgentKind::ClaudeCode, SessionStatus::Running),
        ];
        publisher.update_attention(&initial, &HashSet::new(), true);
        let changed = vec![
            session("%1", "@1", AgentKind::Codex, SessionStatus::WaitingInput),
            session("%2", "@1", AgentKind::ClaudeCode, SessionStatus::Running),
        ];
        publisher.update_attention(&changed, &HashSet::new(), true);
        let settings = RenderSettings { show_agent_names: true, ..RenderSettings::default() };
        let rendered = publisher.render(&changed, &settings);
        assert_eq!(rendered.counts.attention, 1);
        assert_eq!(rendered.counts.running, 1);
        assert!(rendered.window_fragment.contains("Codex"));
        assert!(rendered.window_fragment.contains("Claude Code"));
        assert!(
            rendered.status_summary.find("?").unwrap() < rendered.status_summary.find("▶").unwrap()
        );
        assert!(rendered
            .window_fragment
            .contains("#[push-default]#[fg=colour3]? Codex#[default]#[pop-default]"));
        assert!(rendered
            .window_fragment
            .contains("#[push-default]#[fg=colour4]▶ Claude Code#[default]#[pop-default]"));
        assert_eq!(
            rendered.status_summary,
            "#[push-default]#[fg=colour3]? 1#[default]#[pop-default] #[push-default]#[fg=colour4]▶ 1#[default]#[pop-default]"
        );
    }

    #[test]
    fn shared_states_control_tmux_badges_and_summary() {
        let config = crate::config::Config::default();
        let states = StatePresentations {
            running: StatePresentation {
                icon: "R".to_string(),
                color: ColorSpec::parse("#123456").expect("valid shared color"),
            },
            waiting_input: StatePresentation {
                icon: "W".to_string(),
                color: ColorSpec::parse("ansi:10").expect("valid shared color"),
            },
            finished: StatePresentation {
                icon: "D".to_string(),
                color: ColorSpec::parse("ansi:11").expect("valid shared color"),
            },
            terminated: StatePresentation {
                icon: "X".to_string(),
                color: ColorSpec::parse("ansi:9").expect("valid shared color"),
            },
            unknown: StatePresentation {
                icon: "U".to_string(),
                color: ColorSpec::parse("ansi:8").expect("valid shared color"),
            },
            attention: StatePresentation {
                icon: "!".to_string(),
                color: ColorSpec::parse("palette:yellow").expect("valid shared color"),
            },
        };
        let settings = RenderSettings::from_config(
            &crate::colors::Palette::default(),
            &config.badges,
            &config.status,
            Some(&states),
            false,
            false,
            false,
        );

        assert_eq!(
            settings.badge_running,
            StateFormat { symbol: "R".to_string(), style: "fg=#123456".to_string() }
        );
        assert_eq!(
            settings.badge_attention,
            StateFormat { symbol: "!".to_string(), style: "fg=colour3".to_string() }
        );
        assert_eq!(
            settings.badge_finished,
            StateFormat { symbol: "D".to_string(), style: "fg=colour11".to_string() }
        );
        assert_eq!(settings.badge_waiting.symbol, "W");
        assert_eq!(settings.badge_terminated.symbol, "X");
        assert_eq!(settings.badge_unknown.symbol, "U");
        assert_eq!(settings.status_running, settings.badge_running);
        assert_eq!(settings.status_attention, settings.badge_attention);
        assert_eq!(settings.status_finished, settings.badge_finished);

        let mut publisher = TmuxStatePublisher::default();
        let ordinary = vec![
            session("%1", "@1", AgentKind::Codex, SessionStatus::Running),
            session("%2", "@1", AgentKind::Codex, SessionStatus::WaitingInput),
            session("%3", "@1", AgentKind::Codex, SessionStatus::Finished),
            session("%4", "@1", AgentKind::Codex, SessionStatus::Terminated),
            session("%5", "@1", AgentKind::Codex, SessionStatus::Unknown),
        ];
        let rendered = publisher.render(&ordinary, &settings);
        assert_eq!(rendered.counts.attention, 0);
        assert_eq!(rendered.counts.running, 1);
        assert_eq!(rendered.counts.waiting, 1);
        assert_eq!(rendered.counts.finished, 1);
        assert_eq!(rendered.counts.terminated, 1);
        assert_eq!(rendered.counts.unknown, 1);
        assert_eq!(
            rendered.counts.attention
                + rendered.counts.running
                + rendered.counts.waiting
                + rendered.counts.finished
                + rendered.counts.terminated
                + rendered.counts.unknown,
            ordinary.len()
        );
        assert!(rendered.window_fragment.contains("#[fg=colour10]W"));
        assert!(rendered.window_fragment.contains("#[fg=colour11]D"));
        assert!(rendered.window_fragment.contains("#[fg=colour9]X"));
        assert!(rendered.window_fragment.contains("#[fg=colour8]U"));
        assert!(rendered.status_summary.contains("#[fg=colour11]D 1"));

        let running = ordinary[0].clone();
        publisher.update_attention(std::slice::from_ref(&running), &HashSet::new(), true);
        let attention = session("%1", "@1", AgentKind::Codex, SessionStatus::Finished);
        publisher.update_attention(std::slice::from_ref(&attention), &HashSet::new(), true);
        let rendered = publisher.render(&[attention], &settings);
        assert_eq!(rendered.counts.attention, 1);
        assert_eq!(rendered.counts.finished, 0);
        assert!(rendered.window_fragment.contains("#[fg=colour3]!"));
        assert!(rendered.status_summary.contains("#[fg=colour3]! 1"));
    }

    #[test]
    fn shared_defaults_apply_without_legacy_state_overrides_but_legacy_formats_remain_available() {
        let mut config = crate::config::Config::default();
        let shared = RenderSettings::from_config(
            &crate::colors::Palette::default(),
            &config.badges,
            &config.status,
            None,
            false,
            false,
            false,
        );
        assert_eq!(shared.badge_running.symbol, "▶");
        assert_eq!(shared.badge_finished.symbol, "●");
        assert_eq!(shared.badge_waiting.symbol, "●");
        assert_eq!(shared.badge_attention.symbol, "?");

        config.badges.running =
            StateFormat { symbol: "legacy-badge".to_string(), style: "fg=red".to_string() };
        config.status.running =
            StateFormat { symbol: "legacy-status".to_string(), style: "fg=cyan".to_string() };
        let legacy = RenderSettings::from_config(
            &crate::colors::Palette::default(),
            &config.badges,
            &config.status,
            None,
            true,
            true,
            false,
        );
        assert_eq!(legacy.badge_running.symbol, "legacy-badge");
        assert_eq!(legacy.status_running.symbol, "legacy-status");
        assert!(!legacy.shared_state_behavior);
        let publisher = TmuxStatePublisher::default();
        let ordinary = [
            session("%1", "@1", AgentKind::Codex, SessionStatus::WaitingInput),
            session("%2", "@1", AgentKind::Codex, SessionStatus::Finished),
        ];
        let rendered = publisher.render(&ordinary, &legacy);
        assert!(rendered.window_fragment.is_empty());
        assert!(rendered.status_summary.is_empty());
    }

    #[test]
    fn shared_palette_state_colors_resolve_to_the_same_tmux_rgb_value_as_the_popup() {
        let palette = crate::colors::Palette::from_csv(
            "#010101,#020202,#030303,#040404,#050505,#060606,#070707,#080808,#090909,#0a0a0a,#0b0b0b,#0c0c0c,#0d0d0d,#0e0e0e,#0f0f0f,#101010,#111111,#121212",
        )
        .expect("custom palette");
        let config = crate::config::Config::default();
        let settings = RenderSettings::from_config(
            &palette,
            &config.badges,
            &config.status,
            Some(&StatePresentations::default()),
            false,
            false,
            false,
        );

        assert_eq!(settings.badge_running.style, "fg=#070707");
        assert_eq!(settings.status_attention.style, "fg=#060606");
    }

    #[test]
    fn unstyled_fragments_preserve_the_enclosing_tmux_style() {
        assert_eq!(super::styled("", "?", "Codex"), "? Codex");
        assert_eq!(super::styled("", "?", ""), "?");
    }

    #[test]
    fn dynamic_literals_cannot_alter_tmux_format_grammar() {
        assert_eq!(super::tmux_content_literal("a#b}c"), "a##b#}c");
        assert_eq!(super::window_badge_conditional("@2", "x,y"), "#{?#{==:#{window_id},@2},x#,y,}");
        // Sentinel text that used to collide with WINDOW/BADGES replacement stays literal content.
        let fragment = super::window_badge_conditional("@10", "WINDOW-BADGES");
        assert_eq!(fragment, "#{?#{==:#{window_id},@10},WINDOW-BADGES,}");
        assert!(fragment.contains("WINDOW-BADGES"));
        // Styles stay trusted raw input; embedding escapes commas for `#{?}` branches only.
        assert_eq!(
            super::styled("fg=red,bold", "?", "a,b"),
            "#[push-default]#[fg=red,bold]? a,b#[default]#[pop-default]"
        );
        assert_eq!(
            super::window_badge_conditional("@1", &super::styled("fg=red,bold", "?", "a,b")),
            "#{?#{==:#{window_id},@1},#[push-default]#[fg=red#,bold]? a#,b#[default]#[pop-default],}"
        );
    }

    #[test]
    fn window_ids_sort_numerically_not_lexicographically() {
        let publisher = TmuxStatePublisher::default();
        let sessions = vec![
            session("%10", "@10", AgentKind::Codex, SessionStatus::Running),
            session("%2", "@2", AgentKind::Codex, SessionStatus::Running),
            session("%3", "@3", AgentKind::Codex, SessionStatus::Running),
        ];
        let rendered = publisher.render(&sessions, &RenderSettings::default());
        let at2 = rendered.window_fragment.find("#{?#{==:#{window_id},@2}").expect("@2 present");
        let at3 = rendered.window_fragment.find("#{?#{==:#{window_id},@3}").expect("@3 present");
        let at10 = rendered.window_fragment.find("#{?#{==:#{window_id},@10}").expect("@10 present");
        assert!(
            at2 < at3 && at3 < at10,
            "expected @2 < @3 < @10, got fragment {}",
            rendered.window_fragment
        );

        // Badge text equal to the old WINDOW/BADGES sentinels must not rewrite the template.
        let settings = RenderSettings {
            badge_running: StateFormat { symbol: "WINDOW".to_string(), style: String::new() },
            badge_separator: "BADGES".to_string(),
            ..RenderSettings::default()
        };
        let rendered = publisher.render(&sessions, &settings);
        assert!(rendered.window_fragment.contains("WINDOW"));
        assert!(rendered.window_fragment.contains("#{?#{==:#{window_id},@2},WINDOW"));
        assert!(!rendered.window_fragment.contains("#{?#{==:#{window_id},WINDOW}"));
    }

    #[test]
    fn hydrates_daemon_attention_on_direct_scan_without_inferring_initial_waiting() {
        let waiting = session("%1", "@1", AgentKind::Codex, SessionStatus::WaitingInput);
        let live_panes = [PaneSnapshot { ilmari_attention: true, ..waiting.pane.clone() }];

        // Direct scan after a failed daemon snapshot: durable option restores the latch.
        let mut hydrated = TmuxStatePublisher::default();
        hydrated.hydrate_attention_from_panes(&live_panes, std::slice::from_ref(&waiting), None);
        hydrated.update_attention(std::slice::from_ref(&waiting), &HashSet::new(), true);
        let mut projected = waiting.clone();
        hydrated.project_attention(std::slice::from_mut(&mut projected));
        assert!(projected.attention, "daemon-published attention must survive a direct scan");
        assert!(hydrated
            .render(std::slice::from_ref(&waiting), &RenderSettings::default())
            .pane_values
            .get("%1")
            .is_some_and(|values| values.attention));

        // Lifecycle alone must not invent attention when the durable bit is off.
        let cold = [PaneSnapshot { ilmari_attention: false, ..waiting.pane.clone() }];
        let mut fresh = TmuxStatePublisher::default();
        fresh.hydrate_attention_from_panes(&cold, std::slice::from_ref(&waiting), None);
        fresh.update_attention(std::slice::from_ref(&waiting), &HashSet::new(), true);
        let mut projected = waiting.clone();
        fresh.project_attention(std::slice::from_mut(&mut projected));
        assert!(!projected.attention, "initial waiting must not become attention by inference");

        // A local latch already tracking the pane is not overwritten by a stale option.
        let mut local = TmuxStatePublisher::default();
        let running = session("%1", "@1", AgentKind::Codex, SessionStatus::Running);
        local.update_attention(std::slice::from_ref(&running), &HashSet::new(), true);
        local.update_attention(
            std::slice::from_ref(&waiting),
            &HashSet::from(["%1".to_string()]),
            true,
        );
        assert_eq!(attention_count(&local, &waiting, SessionStatus::WaitingInput), 0);
        local.hydrate_attention_from_panes(&live_panes, std::slice::from_ref(&waiting), None);
        assert_eq!(
            attention_count(&local, &waiting, SessionStatus::WaitingInput),
            0,
            "focus acknowledgement must not be undone by hydrating a stale option"
        );

        // A fresh direct-popup publisher must acknowledge, rather than rehydrate, a daemon
        // option when the matching pane is focused.
        assert!(TmuxStatePublisher::should_acknowledge_durable_attention(
            &live_panes[0],
            Some(&HashSet::from(["%1".to_string()])),
        ));
    }

    #[test]
    fn direct_scan_clears_stale_daemon_attention_before_popup_reopens() {
        let waiting = session("%1", "@1", AgentKind::Codex, SessionStatus::WaitingInput);
        let waiting_with_durable_attention =
            [PaneSnapshot { ilmari_attention: true, ..waiting.pane.clone() }];
        let mut direct_popup = TmuxStatePublisher::default();

        // The daemon is down, so the first popup direct-scans and restores the durable latch.
        direct_popup.hydrate_attention_from_panes(
            &waiting_with_durable_attention,
            std::slice::from_ref(&waiting),
            None,
        );
        direct_popup.update_attention(std::slice::from_ref(&waiting), &HashSet::new(), true);
        let mut projected_waiting = waiting.clone();
        direct_popup.project_attention(std::slice::from_mut(&mut projected_waiting));
        assert!(projected_waiting.attention);

        // The same direct scan later observes that the pane has returned to running. Popup
        // mode does not publish rendered state, so it must persist a cleared durable bit now.
        let running = session("%1", "@1", AgentKind::Codex, SessionStatus::Running);
        let running_with_stale_durable_attention =
            [PaneSnapshot { ilmari_attention: true, ..running.pane.clone() }];
        let mut durable_writes = Vec::new();
        direct_popup.hydrate_attention_from_panes_with(
            &running_with_stale_durable_attention,
            std::slice::from_ref(&running),
            None,
            |pane_id, value| {
                durable_writes.push((pane_id.to_string(), value.map(str::to_string)));
            },
        );
        assert_eq!(durable_writes, vec![("%1".to_string(), Some("0".to_string()))]);
        direct_popup.update_attention(std::slice::from_ref(&running), &HashSet::new(), true);
        let mut projected_running = running.clone();
        direct_popup.project_attention(std::slice::from_mut(&mut projected_running));
        assert!(!projected_running.attention);

        // Simulate reopening after tmux accepted the persisted zero. A later waiting state
        // cannot rehydrate the old latch; a fresh transition is required to create attention.
        let reopened_panes = [PaneSnapshot { ilmari_attention: false, ..waiting.pane.clone() }];
        let mut reopened_popup = TmuxStatePublisher::default();
        reopened_popup.hydrate_attention_from_panes(
            &reopened_panes,
            std::slice::from_ref(&waiting),
            None,
        );
        reopened_popup.update_attention(std::slice::from_ref(&waiting), &HashSet::new(), true);
        let mut reopened_waiting = waiting.clone();
        reopened_popup.project_attention(std::slice::from_mut(&mut reopened_waiting));
        assert!(
            !reopened_waiting.attention,
            "reopening the popup must not revive attention cleared by a direct scan"
        );
    }

    #[test]
    fn rendered_pane_values_publish_attention_zero_or_one() {
        let mut publisher = TmuxStatePublisher::default();
        let running = session("%1", "@1", AgentKind::Codex, SessionStatus::Running);
        publisher.update_attention(std::slice::from_ref(&running), &HashSet::new(), true);
        let waiting = session("%1", "@1", AgentKind::Codex, SessionStatus::WaitingInput);
        publisher.update_attention(std::slice::from_ref(&waiting), &HashSet::new(), true);
        let rendered = publisher.render(std::slice::from_ref(&waiting), &RenderSettings::default());
        assert!(rendered.pane_values["%1"].attention);

        publisher.update_attention(
            std::slice::from_ref(&waiting),
            &HashSet::from(["%1".to_string()]),
            true,
        );
        let rendered = publisher.render(std::slice::from_ref(&waiting), &RenderSettings::default());
        assert!(!rendered.pane_values["%1"].attention);
    }

    #[test]
    fn window_badges_omit_agent_names_when_the_app_column_is_hidden() {
        let mut publisher = TmuxStatePublisher::default();
        let initial = vec![
            session("%1", "@1", AgentKind::Codex, SessionStatus::Running),
            session("%2", "@1", AgentKind::ClaudeCode, SessionStatus::Running),
        ];
        publisher.update_attention(&initial, &HashSet::new(), true);
        let changed = vec![
            session("%1", "@1", AgentKind::Codex, SessionStatus::WaitingInput),
            session("%2", "@1", AgentKind::ClaudeCode, SessionStatus::Running),
        ];
        publisher.update_attention(&changed, &HashSet::new(), true);

        let hidden = publisher.render(&changed, &RenderSettings::default());
        assert!(hidden.window_fragment.contains("?"));
        assert!(hidden.window_fragment.contains("▶"));
        assert!(!hidden.window_fragment.contains("Codex"));
        assert!(!hidden.window_fragment.contains("Claude Code"));

        let visible = publisher.render(
            &changed,
            &RenderSettings { show_agent_names: true, ..RenderSettings::default() },
        );
        assert!(visible.window_fragment.contains("Codex"));
        assert!(visible.window_fragment.contains("Claude Code"));
    }

    fn session(
        pane_id: &str,
        window_id: &str,
        kind: AgentKind,
        status: SessionStatus,
    ) -> SessionRecord {
        let now = Instant::now();
        SessionRecord {
            pane: PaneSnapshot::parse(&format!(
                "{pane_id}\t1\t$1\tdev\t{window_id}\tagents\t0\t/tmp\tcodex\ttitle"
            ))
            .unwrap(),
            kind,
            status,
            attention: false,
            detail: None,
            output_excerpt: None,
            process_usage: None,
            output_fingerprint: None,
            last_changed_at: now,
            last_seen_at: now,
            retained_until: None,
        }
    }

    fn attention_count(
        publisher: &TmuxStatePublisher,
        session: &SessionRecord,
        status: SessionStatus,
    ) -> usize {
        let counts =
            publisher.render(std::slice::from_ref(session), &RenderSettings::default()).counts;
        match status {
            SessionStatus::WaitingInput | SessionStatus::Finished => counts.attention,
            _ => unreachable!("helper only accepts attention statuses"),
        }
    }

    fn has_pending(publisher: &TmuxStatePublisher, pane_id: &str, status: SessionStatus) -> bool {
        let attention = publisher.panes.get(pane_id).expect("pane attention should exist");
        match status {
            SessionStatus::WaitingInput => attention.pending_waiting,
            SessionStatus::Finished => attention.pending_finished,
            _ => unreachable!("helper only accepts attention statuses"),
        }
    }
}