aboutsummaryrefslogtreecommitdiff
path: root/src/detect/agents/claude_code.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/detect/agents/claude_code.rs')
-rw-r--r--src/detect/agents/claude_code.rs434
1 files changed, 0 insertions, 434 deletions
diff --git a/src/detect/agents/claude_code.rs b/src/detect/agents/claude_code.rs
deleted file mode 100644
index b159fede..00000000
--- a/src/detect/agents/claude_code.rs
+++ /dev/null
@@ -1,434 +0,0 @@
-use super::super::{has_confirmation_prompt, has_selection_prompt, AgentState};
-
-/// Claude Code detection. The most complex — it has a structured prompt box UI.
-///
-/// Screen layout:
-/// ```text
-/// (agent output / tool results)
-/// ───────────────────────── (top border)
-/// ❯ _ (prompt line)
-/// ───────────────────────── (bottom border)
-/// ```
-pub(super) fn detect(content: &str) -> AgentState {
- let lower = content.to_lowercase();
-
- if has_live_blocked_form(content) {
- return AgentState::Blocked;
- }
-
- if has_dynamic_workflow_prompt(&lower) {
- return AgentState::Blocked;
- }
-
- if has_working_chrome(content) {
- return AgentState::Working;
- }
-
- if !has_prompt_box(content) && has_claude_blocked_prompt(content, &lower) {
- return AgentState::Blocked;
- }
-
- AgentState::Idle
-}
-
-pub(super) fn has_visible_blocker(content: &str) -> bool {
- if has_live_input_prompt_box(content) {
- return false;
- }
-
- let lower = content.to_lowercase();
- has_live_blocked_form(content)
- || has_dynamic_workflow_prompt(&lower)
- || lower.contains("do you want to proceed?")
- && has_claude_yes_no_choice(content)
- && (lower.contains("bash command")
- || lower.contains("bash(")
- || lower.contains("contains expansion")
- || lower.contains("tab to amend")
- || lower.contains("ctrl+e to explain"))
-}
-
-pub(in crate::detect) fn has_idle_recap_notice(content: &str) -> bool {
- if !has_prompt_box(content) || has_visible_blocker(content) {
- return false;
- }
-
- let above_prompt = content_above_prompt_box(content);
- let bottom_lines = bottom_non_empty_lines(above_prompt, 8);
- let Some(last_line) = bottom_lines.last() else {
- return false;
- };
- if !last_line
- .to_ascii_lowercase()
- .contains("(disable recaps in /config)")
- {
- return false;
- }
- let bottom = normalize_lines(&bottom_lines).to_ascii_lowercase();
-
- bottom.contains("※ recap:")
- && !bottom.contains("esc to interrupt")
- && !bottom.contains("ctrl+c to interrupt")
-}
-
-pub(super) fn has_working_chrome(content: &str) -> bool {
- let above = content_above_prompt_box(content);
- let above_lower = above.to_lowercase();
- above_lower.contains("esc to interrupt")
- || above_lower.contains("ctrl+c to interrupt")
- || has_running_status_line(above)
- || 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 {
- prompt_box_body_lines(content)
- .is_some_and(|lines| lines.iter().any(|line| line.trim_start().starts_with('❯')))
-}
-
-fn has_live_input_prompt_box(content: &str) -> bool {
- prompt_box_body_lines(content).is_some_and(|lines| {
- let non_empty: Vec<&str> = lines
- .iter()
- .map(|line| line.trim())
- .filter(|line| !line.is_empty())
- .collect();
- let Some(first) = non_empty.first() else {
- return false;
- };
- first.trim_start().starts_with('❯')
- && !non_empty
- .iter()
- .any(|line| claude_prompt_box_line_is_selector_chrome(line))
- })
-}
-
-fn claude_prompt_box_line_is_selector_chrome(line: &str) -> bool {
- let trimmed = line.trim().trim_start_matches('❯').trim_start();
- let lower = trimmed.to_ascii_lowercase();
-
- lower.contains("enter to select")
- || lower.contains("enter to confirm")
- || lower.contains("enter to submit")
- || lower.contains("esc to cancel")
- || lower.contains("tab/arrow")
- || lower.contains("arrow keys")
- || lower.contains("↑/↓")
- || lower.contains("↑↓")
- || lower.contains("ctrl+g to edit")
- || lower.contains("ctrl+e to explain")
- || trimmed
- .split_once('.')
- .is_some_and(|(prefix, _)| prefix.trim().parse::<u32>().is_ok())
-}
-
-fn prompt_box_body_lines(content: &str) -> Option<Vec<&str>> {
- let lines: Vec<&str> = content.lines().collect();
- let top_border_index = claude_prompt_box_top_border_index(&lines)?;
-
- Some(
- lines[top_border_index + 1..]
- .iter()
- .take_while(|line| !is_horizontal_rule(line))
- .copied()
- .collect(),
- )
-}
-
-/// Claude uses the same generic Select and Dialog widgets for both
-/// permission flows and ordinary slash/settings menus. Match only the
-/// permission and interview prompts that actually need user input.
-fn has_claude_blocked_prompt(content: &str, lower_content: &str) -> bool {
- has_confirmation_prompt(lower_content)
- || lower_content.contains("do you want to proceed?")
- || lower_content.contains("would you like to proceed?")
- || has_dynamic_workflow_prompt(lower_content)
- || lower_content.contains("waiting for permission")
- || lower_content.contains("do you want to allow this connection?")
- || lower_content.contains("tab to amend")
- || lower_content.contains("ctrl+e to explain")
- || lower_content.contains("review your answers")
- || lower_content.contains("skip interview and plan immediately")
- || (has_selection_prompt(content) && has_claude_yes_no_choice(content))
-}
-
-fn has_dynamic_workflow_prompt(lower_content: &str) -> bool {
- lower_content.contains("run a dynamic workflow?") && lower_content.contains("esc to cancel")
-}
-
-fn has_live_blocked_form(content: &str) -> bool {
- let region = content_after_last_horizontal_rule(content);
- region.lines().any(|line| {
- let lower = line.to_lowercase();
- lower.contains("enter to select")
- && lower.contains("esc to cancel")
- && (lower.contains("tab/arrow keys to navigate")
- || lower.contains("arrow keys to navigate")
- || lower.contains("arrows to navigate")
- || lower.contains("↑/↓ to navigate")
- || lower.contains("↑↓ to navigate"))
- })
-}
-
-fn has_running_status_line(content_above_prompt: &str) -> bool {
- let Some(line) = content_above_prompt
- .lines()
- .rev()
- .find(|line| !line.trim().is_empty())
- else {
- return false;
- };
-
- is_background_agent_wait_line(line) || is_still_running_status_line(line)
-}
-
-fn is_background_agent_wait_line(line: &str) -> bool {
- let mut text = line.trim();
- if !text.starts_with("Waiting for ") && !text.starts_with("waiting for ") {
- let mut chars = text.chars();
- let Some(first) = chars.next() else {
- return false;
- };
- if first.is_alphanumeric() {
- return false;
- }
- text = chars.as_str().trim_start();
- }
-
- let lower = text.to_ascii_lowercase();
- let Some(rest) = lower.strip_prefix("waiting for ") else {
- return false;
- };
- let Some((count, rest)) = rest.split_once(' ') else {
- return false;
- };
- if count.parse::<u32>().ok().is_none_or(|count| count == 0) {
- return false;
- }
-
- rest == "background agent to finish" || rest == "background agents to finish"
-}
-
-fn is_still_running_status_line(line: &str) -> bool {
- let lower = line.to_ascii_lowercase();
- let words: Vec<&str> = lower.split_whitespace().collect();
-
- for (index, word) in words.iter().enumerate() {
- let Ok(count) = word.parse::<u32>() else {
- continue;
- };
- if count == 0 {
- continue;
- }
-
- if matches!(
- words.get(index + 1..index + 4),
- Some(["shell" | "shells", "still", "running"])
- ) {
- return true;
- }
-
- if matches!(
- words.get(index + 1..index + 5),
- Some(["local", "agent" | "agents", "still", "running"])
- ) {
- return true;
- }
- }
-
- false
-}
-
-fn has_claude_yes_no_choice(content: &str) -> bool {
- content.lines().any(|line| {
- let trimmed = line
- .trim()
- .trim_start_matches('❯')
- .trim_start()
- .to_lowercase();
- trimmed == "yes"
- || trimmed == "no"
- || trimmed.starts_with("1. yes")
- || trimmed.starts_with("2. no")
- || trimmed.starts_with("yes, and ")
- || trimmed.starts_with("no, and tell claude")
- })
-}
-
-/// Claude Code spinner characters + activity label.
-/// The verb changes frequently ("Processing…", "Pouncing…", etc.), so rely
-/// on the spinner glyph + trailing ellipsis rather than specific wording.
-/// Include Claude's narrow-pane middle-dot frame too.
-pub(in crate::detect) fn has_spinner_activity(content: &str) -> bool {
- const SPINNER_CHARS: &str = "·✱✲✳✴✵✶✷✸✹✺✻✼✽✾✿❀❁❂❃❇❈❉❊❋✢✣✤✥✦✧✨⊛⊕⊙◉◎◍⁂⁕※⍟☼★☆";
- for line in content.lines() {
- let trimmed = line.trim();
- let mut chars = trimmed.chars();
- if let Some(first) = chars.next() {
- if SPINNER_CHARS.contains(first) {
- let rest: String = chars.collect();
- if rest.starts_with(' ')
- && rest.contains('\u{2026}')
- && rest.chars().any(|c| c.is_alphanumeric())
- {
- return true;
- }
- }
- }
- }
- false
-}
-
-/// Extract content above Claude's prompt box.
-/// The prompt box is two ─── border lines with ❯ between them.
-pub(in crate::detect) fn content_above_prompt_box(content: &str) -> &str {
- let lines: Vec<&str> = content.lines().collect();
-
- if let Some(i) = claude_prompt_box_top_border_index(&lines) {
- let byte_offset: usize = lines[..i].iter().map(|l| l.len() + 1).sum();
- return &content[..byte_offset.min(content.len())];
- }
-
- // No prompt box found, return all content
- content
-}
-
-fn content_after_last_horizontal_rule(content: &str) -> &str {
- let mut last_rule_end = 0usize;
- let mut offset = 0usize;
- for line in content.lines() {
- let next_offset = offset + line.len() + 1;
- if is_horizontal_rule(line) {
- last_rule_end = next_offset.min(content.len());
- }
- offset = next_offset;
- }
-
- &content[last_rule_end..]
-}
-
-fn claude_prompt_box_top_border_index(lines: &[&str]) -> Option<usize> {
- let mut border_count = 0;
-
- for i in (0..lines.len()).rev() {
- if is_horizontal_rule(lines[i]) {
- border_count += 1;
- if border_count == 2 {
- return Some(i);
- }
- }
- }
-
- None
-}
-
-fn is_horizontal_rule(line: &str) -> bool {
- let trimmed = line.trim();
- if trimmed.is_empty() {
- return false;
- }
-
- let rule_chars = trimmed.chars().take_while(|&c| c == '─').count();
- if rule_chars == 0 {
- return false;
- }
-
- let rule_bytes = trimmed
- .char_indices()
- .nth(rule_chars)
- .map(|(index, _)| index)
- .unwrap_or(trimmed.len());
- let suffix = trimmed[rule_bytes..].trim_start();
-
- suffix.is_empty() || rule_chars >= 3
-}
-
-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")
-}
-
-#[cfg(test)]
-mod tests {
- use super::*;
-
- fn prompt_box_below(content_above_prompt: &str) -> String {
- format!(
- "{content_above_prompt}\n────────────────────────────────\n❯ \n────────────────────────────────\n"
- )
- }
-
- #[test]
- fn shell_still_running_status_line_is_working() {
- let content = prompt_box_below(
- "● Started. I'll tell you when it finishes.\n\n✻ Crunched for 7s · 1 shell still running",
- );
-
- assert_eq!(detect(&content), AgentState::Working);
- assert!(has_working_chrome(&content));
- }
-
- #[test]
- fn local_agent_still_running_status_line_is_working() {
- let content = prompt_box_below(
- "● Hey. What do you want to work on?\n\n✻ Worked for 4s · 2 local agents still running",
- );
-
- assert_eq!(detect(&content), AgentState::Working);
- assert!(has_working_chrome(&content));
- }
-
- #[test]
- fn lower_agent_picker_shell_count_is_not_working_chrome() {
- let content = prompt_box_below(" ~/P/herdr ⎇ master ▱▱▱▱▱ 0%\n 1 shell · ← for agents");
-
- assert_eq!(detect(&content), AgentState::Idle);
- assert!(!has_working_chrome(&content));
- }
-
- #[test]
- fn stale_shell_running_line_above_newer_output_is_not_working_chrome() {
- let content = prompt_box_below(
- "● Started. I'll tell you when it finishes.\n\n✻ Crunched for 7s · 1 shell still running\n\n● hi",
- );
-
- assert_eq!(detect(&content), AgentState::Idle);
- assert!(!has_working_chrome(&content));
- }
-}
generated by cgit v1.2.3 (git 2.39.1) at 2026-11-09 12:25:51 +0000