aboutsummaryrefslogtreecommitdiff
path: root/src/detect
diff options
context:
space:
mode:
Diffstat (limited to 'src/detect')
-rw-r--r--src/detect/agents/claude_code.rs42
-rw-r--r--src/detect/agents/codex.rs47
-rw-r--r--src/detect/agents/mod.rs20
-rw-r--r--src/detect/mod.rs90
4 files changed, 199 insertions, 0 deletions
diff --git a/src/detect/agents/claude_code.rs b/src/detect/agents/claude_code.rs
index ace946da..77db856c 100644
--- a/src/detect/agents/claude_code.rs
+++ b/src/detect/agents/claude_code.rs
@@ -63,6 +63,20 @@ pub(super) fn has_working_chrome(content: &str) -> bool {
|| has_spinner_activity(above)
}
+pub(super) fn is_transcript_viewer(content: &str) -> bool {
+ let bottom_lines = bottom_non_empty_lines(content, 3);
+ let Some(last_line) = bottom_lines.last() else {
+ return false;
+ };
+ let bottom_text = normalize_lines(&bottom_lines);
+
+ bottom_text.contains("showing detailed transcript")
+ && bottom_text.contains("ctrl+o to toggle")
+ && (bottom_text.contains("ctrl+e to show all")
+ || bottom_text.contains("ctrl+e to collapse"))
+ && transcript_control_tail(last_line)
+}
+
pub(super) fn has_prompt_box(content: &str) -> bool {
let lines: Vec<&str> = content.lines().collect();
let Some(top_border_index) = claude_prompt_box_top_border_index(&lines) else {
@@ -232,3 +246,31 @@ fn is_horizontal_rule(line: &str) -> bool {
let trimmed = line.trim();
!trimmed.is_empty() && trimmed.chars().all(|c| c == '─')
}
+
+fn bottom_non_empty_lines(content: &str, max_lines: usize) -> Vec<&str> {
+ let mut lines: Vec<&str> = content
+ .lines()
+ .rev()
+ .filter(|line| !line.trim().is_empty())
+ .take(max_lines)
+ .collect();
+ lines.reverse();
+ lines
+}
+
+fn normalize_lines(lines: &[&str]) -> String {
+ lines
+ .iter()
+ .flat_map(|line| line.split_whitespace())
+ .collect::<Vec<_>>()
+ .join(" ")
+ .to_lowercase()
+}
+
+fn transcript_control_tail(line: &str) -> bool {
+ let lower = line.to_lowercase();
+ lower.contains("ctrl+e")
+ || lower.contains("show all")
+ || lower.contains("collapse")
+ || lower.contains("verbose")
+}
diff --git a/src/detect/agents/codex.rs b/src/detect/agents/codex.rs
index 50430aa4..e00d0a28 100644
--- a/src/detect/agents/codex.rs
+++ b/src/detect/agents/codex.rs
@@ -48,6 +48,25 @@ pub(super) fn has_visible_working(content: &str) -> bool {
|| (!has_codex_current_prompt(content) && has_codex_visible_working_without_prompt(content))
}
+pub(super) fn is_transcript_viewer(content: &str) -> bool {
+ let bottom_lines = bottom_non_empty_lines(content, 3);
+ let Some(last_line) = bottom_lines.last() else {
+ return false;
+ };
+ let bottom_text = normalize_lines(&bottom_lines);
+
+ bottom_text.contains("↑/↓ to scroll")
+ && bottom_text.contains("pgup/pgdn to page")
+ && bottom_text.contains("home/end to jump")
+ && bottom_text.contains("q to quit")
+ && has_codex_edit_prev_controls(&bottom_text)
+ && transcript_control_tail(last_line)
+}
+
+fn has_codex_edit_prev_controls(bottom_text: &str) -> bool {
+ bottom_text.contains("esc to edit prev") || bottom_text.contains("esc/← to edit prev")
+}
+
fn has_codex_visible_working_without_prompt(content: &str) -> bool {
let mut recent_lines = content.lines().rev().filter(|line| !line.trim().is_empty());
let Some(last_line) = recent_lines.next() else {
@@ -171,3 +190,31 @@ fn codex_queued_input_header_line(line: &str) -> bool {
lower.starts_with("• queued follow-up inputs")
|| lower.starts_with("• messages to be submitted after next tool call")
}
+
+fn bottom_non_empty_lines(content: &str, max_lines: usize) -> Vec<&str> {
+ let mut lines: Vec<&str> = content
+ .lines()
+ .rev()
+ .filter(|line| !line.trim().is_empty())
+ .take(max_lines)
+ .collect();
+ lines.reverse();
+ lines
+}
+
+fn normalize_lines(lines: &[&str]) -> String {
+ lines
+ .iter()
+ .flat_map(|line| line.split_whitespace())
+ .collect::<Vec<_>>()
+ .join(" ")
+ .to_lowercase()
+}
+
+fn transcript_control_tail(line: &str) -> bool {
+ let lower = line.to_lowercase();
+ lower.contains("q to quit")
+ || lower.contains("esc to edit")
+ || lower.contains("esc/← to edit")
+ || lower.contains("edit message")
+}
diff --git a/src/detect/agents/mod.rs b/src/detect/agents/mod.rs
index 4597c122..a89b2f37 100644
--- a/src/detect/agents/mod.rs
+++ b/src/detect/agents/mod.rs
@@ -39,14 +39,34 @@ pub(super) fn detect(agent: Agent, screen_content: &str) -> AgentDetection {
Agent::Qodercli => qodercli::detect(screen_content),
};
+ let skip_state_update = should_skip_state_update(agent, screen_content);
+ if skip_state_update {
+ return AgentDetection {
+ state,
+ skip_state_update: true,
+ visible_blocker: false,
+ visible_idle: false,
+ visible_working: false,
+ };
+ }
+
AgentDetection {
state,
+ skip_state_update: false,
visible_blocker: has_visible_blocker(agent, screen_content, state),
visible_idle: has_visible_idle(agent, screen_content, state),
visible_working: has_visible_working(agent, screen_content, state),
}
}
+pub(super) fn should_skip_state_update(agent: Agent, content: &str) -> bool {
+ match agent {
+ Agent::Claude => claude_code::is_transcript_viewer(content),
+ Agent::Codex => codex::is_transcript_viewer(content),
+ _ => false,
+ }
+}
+
fn has_visible_blocker(agent: Agent, content: &str, state: AgentState) -> bool {
if state != AgentState::Blocked {
return false;
diff --git a/src/detect/mod.rs b/src/detect/mod.rs
index 58a73d7d..e5e9b93b 100644
--- a/src/detect/mod.rs
+++ b/src/detect/mod.rs
@@ -22,6 +22,9 @@ pub enum AgentState {
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub struct AgentDetection {
pub state: AgentState,
+ /// True when the current screen is an agent-owned viewer that shows
+ /// transcript/history instead of the live prompt state.
+ pub skip_state_update: bool,
/// True when the current screen visibly shows live UI chrome that needs
/// human input. This is stronger than arbitrary prompt-like text in the
/// scrollback and may override a non-blocked integration state.
@@ -173,6 +176,7 @@ pub fn detect_agent(agent: Option<Agent>, screen_content: &str) -> AgentDetectio
let Some(agent) = agent else {
return AgentDetection {
state: AgentState::Unknown,
+ skip_state_update: false,
visible_blocker: false,
visible_idle: false,
visible_working: false,
@@ -181,6 +185,10 @@ pub fn detect_agent(agent: Option<Agent>, screen_content: &str) -> AgentDetectio
agents::detect(agent, screen_content)
}
+pub fn should_skip_state_update(agent: Option<Agent>, screen_content: &str) -> bool {
+ agent.is_some_and(|agent| agents::should_skip_state_update(agent, screen_content))
+}
+
// ---------------------------------------------------------------------------
// Per-agent detectors
// ---------------------------------------------------------------------------
@@ -940,6 +948,42 @@ mod tests {
}
#[test]
+ fn claude_detailed_transcript_skips_state_update() {
+ let screen = "● I read the root and README.md.\n\n✻ Cogitated for 14s\n\n───────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────\n Showing detailed transcript · ctrl+o to toggle · ctrl+e to show all verbose";
+ let detection = detect_agent(Some(Agent::Claude), screen);
+
+ assert!(detection.skip_state_update);
+ assert!(!detection.visible_idle);
+ assert!(!detection.visible_working);
+ assert!(!detection.visible_blocker);
+ }
+
+ #[test]
+ fn claude_detailed_transcript_collapse_skips_state_update() {
+ let screen = "● Running tool\n\n───────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────\n Showing detailed transcript · ctrl+o to toggle · ctrl+e to collapse";
+ let detection = detect_agent(Some(Agent::Claude), screen);
+
+ assert!(detection.skip_state_update);
+ }
+
+ #[test]
+ fn claude_wrapped_detailed_transcript_controls_skip_state_update() {
+ let screen = "● Running tool\n\n────────────────────────\n Showing detailed transcript · ctrl+o\n to toggle · ctrl+e to\n collapse";
+ let detection = detect_agent(Some(Agent::Claude), screen);
+
+ assert!(detection.skip_state_update);
+ }
+
+ #[test]
+ fn claude_transcript_text_above_prompt_does_not_skip_state_update() {
+ let screen = "Docs mention: Showing detailed transcript · ctrl+o to toggle · ctrl+e to show all\n\n───────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────\n❯ \n───────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────";
+ let detection = detect_agent(Some(Agent::Claude), screen);
+
+ assert!(!detection.skip_state_update);
+ assert!(detection.visible_idle);
+ }
+
+ #[test]
fn claude_waiting_do_you_want() {
let screen = "Do you want to run this command?\n\nYes No";
assert_eq!(detect_claude(screen), AgentState::Blocked);
@@ -1474,6 +1518,52 @@ mod tests {
assert_eq!(detect_codex("❯ "), AgentState::Idle);
}
+ #[test]
+ fn codex_transcript_viewer_skips_state_update() {
+ let screen = "/ T R A N S C R I P T / / / / / / / / / / / / / / / /\n\n› i did thats why our latest commit is also a claude fix D\n\n• Yes, then I would release.\n──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────── 100% ─\n ↑/↓ to scroll pgup/pgdn to page home/end to jump\n q to quit esc to edit prev";
+ let detection = detect_agent(Some(Agent::Codex), screen);
+
+ assert!(detection.skip_state_update);
+ assert!(!detection.visible_idle);
+ assert!(!detection.visible_working);
+ assert!(!detection.visible_blocker);
+ }
+
+ #[test]
+ fn codex_wrapped_transcript_controls_skip_state_update() {
+ let screen = "/ T R A N S C R I P T /\n\n› yeah go ahead\n──────────────────────────────── 100% ─\n ↑/↓ to scroll pgup/pgdn to\n page home/end to jump\n q to quit esc to edit prev";
+ let detection = detect_agent(Some(Agent::Codex), screen);
+
+ assert!(detection.skip_state_update);
+ assert!(!detection.visible_idle);
+ }
+
+ #[test]
+ fn codex_esc_transcript_controls_skip_state_update() {
+ let screen = "/ T R A N S C R I P T /\n\n› yeah go ahead\n──────────────────────────────── 100% ─\n ↑/↓ to scroll pgup/pgdn to page home/end to jump\n q to quit esc/← to edit prev → to edit next enter to edit message";
+ let detection = detect_agent(Some(Agent::Codex), screen);
+
+ assert!(detection.skip_state_update);
+ assert!(!detection.visible_idle);
+ }
+
+ #[test]
+ fn codex_transcript_controls_above_prompt_do_not_skip_state_update() {
+ let screen = "Old output:\n ↑/↓ to scroll pgup/pgdn to page home/end to jump\n q to quit esc to edit prev\n\n› ";
+ let detection = detect_agent(Some(Agent::Codex), screen);
+
+ assert!(!detection.skip_state_update);
+ assert!(detection.visible_idle);
+ }
+
+ #[test]
+ fn codex_exit_control_without_scroll_control_does_not_skip_state_update() {
+ let screen = "Some output\n\n q to quit esc to edit prev";
+ let detection = detect_agent(Some(Agent::Codex), screen);
+
+ assert!(!detection.skip_state_update);
+ }
+
// ---- Gemini ----
#[test]
generated by cgit v1.2.3 (git 2.39.1) at 2026-11-08 11:49:35 +0000