Recognize remote control active prompt

Author: lijiuyang.5137

src/runner.rs

@@ -528,6 +528,11 @@ async fn run_stream_json(
             Some("control_response") => {}
             Some("control_cancel_request") => {}
             Some("user") => {
+                let prompt = user_prompt_from_sdk_message(&value)?;
+                logging::event(format!(
+                    "stream_user received content_chars={}",
+                    prompt.chars().count()
+                ));
                 if ensure_sdk_mcp_runtime(process, tail, &mut input, &mut sdk_state, spawn).await? {
                     tty_prepared = true;
                 }
@@ -542,7 +547,6 @@ async fn run_stream_json(
                     .await?;
                     tty_prepared = true;
                 }
-                let prompt = user_prompt_from_sdk_message(&value)?;
                 let _ = submit_prompt_and_tail_stream(
                     process,
                     tail,
@@ -3637,10 +3641,12 @@ fn tty_output_accepts_prompt(output: &str) -> bool {
     let compact = compact_tty_output(&output);
     let has_status = output.contains("permissions")
         || output.contains("Remote Control failed")
+        || output.contains("Remote Control active")
         || output.contains("MCP server failed")
         || output.contains("/mcp")
         || compact.contains("permissions")
         || compact.contains("RemoteControlfailed")
+        || compact.contains("RemoteControlactive")
         || compact.contains("MCPserverfailed")
         || compact.contains("/mcp");
     let has_prompt_marker = output.contains('❯') || compact.contains('❯');
@@ -4281,6 +4287,19 @@ mod tests {
         assert_eq!(question.options[1].description, "操作手册文档风格");
     }
 
+    #[test]
+    fn accepts_remote_control_active_screen_as_prompt_ready() {
+        let output = "\
+            ⏵⏵ auto mode on (shift+tab to cycle) · ← for agents ◉ xhigh · /effort \
+            Remote Control connecting… ⚠ 1 setup issue: MCP · /doctor ↯ /fast \
+            ❯ Try \"edit main.go to...\" \
+            [Opus 4.8] │ workspace git:( test/remote-control ) Context ░░░░░░░░░░ 0% \
+            ⏵⏵ auto mode on (shift+tab to cycle) · ← for agents \
+            Remote Control active ────── ↯ Remote Control active";
+
+        assert!(tty_output_accepts_prompt(output));
+    }
+
     #[test]
     fn keeps_english_question_leader_in_tty_question_prompt() {
         let output = "\

tests/cctty_cli.rs

@@ -91,6 +91,54 @@ fn stream_json_text_prompt_uses_tty_transcript() {
     assert_eq!(lines[3]["result"], "FAKE_RESPONSE: Say OK");
 }
 
+#[test]
+fn stream_json_remote_control_active_screen_accepts_prompt() {
+    let fixture = FakeClaude::new();
+    let workspace = tempfile::tempdir().unwrap();
+    let config_dir = tempfile::tempdir().unwrap();
+    let ready_output = "\
+        ⏵⏵ auto mode on (shift+tab to cycle) · ← for agents ◉ xhigh · /effort \
+        Remote Control connecting… ⚠ 1 setup issue: MCP · /doctor ↯ /fast \
+        ❯ Try \"edit main.go to...\" \
+        [Opus 4.8] │ workspace git:( test/remote-control ) Context ░░░░░░░░░░ 0% \
+        ⏵⏵ auto mode on (shift+tab to cycle) · ← for agents \
+        Remote Control active ────── ↯ Remote Control active";
+    let stdin = format!(
+        "{}\n",
+        serde_json::json!({
+            "type": "user",
+            "message": { "role": "user", "content": "Remote control prompt" },
+        })
+    );
+
+    let output = Command::cargo_bin("cctty")
+        .unwrap()
+        .env("CCTTY_CLAUDE_PATH", fixture.path())
+        .env("CLAUDE_CONFIG_DIR", config_dir.path())
+        .env("FAKE_CLAUDE_READY_OUTPUT", ready_output)
+        .current_dir(workspace.path())
+        .args([
+            "--output-format",
+            "stream-json",
+            "--input-format",
+            "stream-json",
+        ])
+        .write_stdin(stdin)
+        .output()
+        .unwrap();
+
+    assert!(
+        output.status.success(),
+        "stderr:\n{}",
+        String::from_utf8_lossy(&output.stderr)
+    );
+    let stdout = String::from_utf8(output.stdout).unwrap();
+    assert!(
+        stdout.contains("FAKE_RESPONSE: Remote control prompt"),
+        "stdout:\n{stdout}"
+    );
+}
+
 #[test]
 fn stream_json_accepts_non_uuid_host_session_id() {
     let fixture = FakeClaude::new();

tests/support/mod.rs

@@ -222,7 +222,10 @@ startup_delay_ms = os.environ.get("FAKE_CLAUDE_STARTUP_DELAY_MS")
 if startup_delay_ms:
     time.sleep(int(startup_delay_ms) / 1000)
 
-sys.stdout.write("Context permissions /mcp\n")
+ready_output = os.environ.get("FAKE_CLAUDE_READY_OUTPUT", "Context permissions /mcp\n")
+sys.stdout.write(ready_output)
+if ready_output and not ready_output.endswith("\n"):
+    sys.stdout.write("\n")
 sys.stdout.flush()
 
 buf = b""