fix(pty): Init tmp E2E directories as git repos for pty tests

The streaming cancellation E2E test was failing because the temp
directory wasn't a git repository. This caused the ghost snapshot task
to immediately fail and send a BackgroundEvent("Snapshots disabled...")
that raced with and overwrote the "Working" status indicator within
~3ms.

Changes:
- Add `git_init` field to SessionConfig (default: true)
- Run `git init` on temp directories during test setup by default
- Add `without_git_init()` for tests that need non-git directories
- Enable streaming cancellation test with proper git repo setup

Author: CSRessel

codex-rs/tui-pty-e2e/src/lib.rs

@@ -81,6 +81,15 @@ impl TuiSession {
             let temp_dir = tempfile::tempdir()?;
             let hello_py = temp_dir.path().join("hello.py");
             std::fs::write(&hello_py, "print('Hello, World!')")?;
+
+            // Initialize as git repo if requested (prevents "Snapshots disabled" race)
+            if config.git_init {
+                std::process::Command::new("git")
+                    .args(["init"])
+                    .current_dir(temp_dir.path())
+                    .output()?;
+            }
+
             config.cwd = Some(temp_dir.path().to_path_buf());
             Self::spawn_with_config_and_tempdir(rows, cols, config, Some(temp_dir))
         } else {
@@ -433,6 +442,10 @@ pub struct SessionConfig {
     /// Custom config.toml content. If None, a default config will be generated.
     /// Set to Some("") to write an empty config file.
     pub config_toml: Option<String>,
+    /// Initialize the temp directory as a git repository.
+    /// This prevents the "Snapshots disabled" BackgroundEvent from overwriting
+    /// the "Working" status indicator during streaming tests.
+    pub git_init: bool,
 }
 
 impl Default for SessionConfig {
@@ -452,6 +465,7 @@ impl SessionConfig {
             sandbox: Some(Sandbox::WorkspaceWrite),
             cwd: None,
             config_toml: None,
+            git_init: true,
         }
     }
 
@@ -503,6 +517,14 @@ impl SessionConfig {
         self.config_toml = Some(content.into());
         self
     }
+
+    /// Initialize the temp directory as a git repository.
+    pub fn without_git_init(mut self) -> Self {
+        // This prevents the "Snapshots disabled" BackgroundEvent from racing
+        // with the "Working" status indicator during streaming tests.
+        self.git_init = false;
+        self
+    }
 }
 
 /// Get path to codex binary

codex-rs/tui-pty-e2e/tests/manual-test-cancellation.md

@@ -0,0 +1,30 @@
+actual screen state right after submission, with mock ACP:
+
+```
+
+› testing!!!
+
+
+• Working (1s • esc to interrupt)
+
+
+› Improve documentation in @filename
+
+  100% context left · ? for shortcuts
+```
+
+then actual screen state after hitting escape:
+
+```
+
+› testing!!!
+
+
+■ Conversation interrupted - tell the model what to do differently. Something went wrong? Hit
+`/feedback` to report the issue.
+
+
+› Improve documentation in @filename
+
+  100% context left · ? for shortcuts
+```

codex-rs/tui-pty-e2e/tests/snapshots/prompt_flow__custom_response.snap

@@ -2,8 +2,6 @@
 source: tui-pty-e2e/tests/prompt_flow.rs
 expression: normalize_for_snapshot(session.screen_contents())
 ---
-  To get started, describe a task or try one of these commands:
-
   /init - create an AGENTS.md file with instructions for Codex
   /status - show current session configuration
   /approvals - choose what Codex can do without approval

codex-rs/tui-pty-e2e/tests/snapshots/prompt_flow__missing_model.snap

@@ -2,6 +2,7 @@
 source: tui-pty-e2e/tests/prompt_flow.rs
 expression: normalize_for_snapshot(session.screen_contents())
 ---
+  /init - create an AGENTS.md file with instructions for Codex
   /status - show current session configuration
   /approvals - choose what Codex can do without approval
   /model - choose what model and reasoning effort to use
@@ -14,8 +15,6 @@ expression: normalize_for_snapshot(session.screen_contents())
 ■ Fatal error: Model 'nonexistent' has wire_api=acp but is not registered in the
 ACP registry
 
-• Snapshots disabled: current directory is not a Git repository. (0s • esc to in
-
 
 › [DEFAULT_PROMPT]
 

codex-rs/tui-pty-e2e/tests/snapshots/streaming__cancelled_stream.snap

@@ -0,0 +1,28 @@
+---
+source: tui-pty-e2e/tests/streaming.rs
+expression: normalize_for_snapshot(session.screen_contents())
+---
+│                                          │
+│ model:     mock-model   /model to change │
+│ directory: [TMP_DIR]               │
+╰──────────────────────────────────────────╯
+
+  To get started, describe a task or try one of these commands:
+
+  /init - create an AGENTS.md file with instructions for Codex
+  /status - show current session configuration
+  /approvals - choose what Codex can do without approval
+  /model - choose what model and reasoning effort to use
+  /review - review any changes and find issues
+
+
+› testing!!!
+
+
+■ Conversation interrupted - tell the model what to do differently. Something
+went wrong? Hit `/feedback` to report the issue.
+
+
+› [DEFAULT_PROMPT]
+
+  100% context left · ? for shortcuts

codex-rs/tui-pty-e2e/tests/streaming.rs

@@ -1,5 +1,4 @@
 use insta::assert_snapshot;
-use std::time::Duration;
 use tui_pty_e2e::normalize_for_snapshot;
 use tui_pty_e2e::Key;
 use tui_pty_e2e::SessionConfig;
@@ -10,16 +9,20 @@ use tui_pty_e2e::TIMEOUT_INPUT;
 #[test]
 fn test_submit_text() {
     let config = SessionConfig::new().with_stream_until_cancel();
-
     let mut session = TuiSession::spawn_with_config(24, 80, config).unwrap();
-    session.wait_for_text("To get started", TIMEOUT).unwrap();
+
+    session
+        .wait_for_text("›", TIMEOUT)
+        .expect("Prompt did not appear");
+    std::thread::sleep(TIMEOUT_INPUT);
 
     // Submit prompt
     session.send_str("testing!!!").unwrap();
     session.wait_for_text("testing!!!", TIMEOUT).unwrap();
-    std::thread::sleep(Duration::from_millis(100));
+    std::thread::sleep(TIMEOUT_INPUT);
     session.send_key(Key::Enter).unwrap();
-    std::thread::sleep(Duration::from_millis(100));
+
+    std::thread::sleep(TIMEOUT_INPUT);
     session.wait_for_text("? for shortcuts", TIMEOUT).unwrap();
     std::thread::sleep(TIMEOUT_INPUT);
 
@@ -29,39 +32,49 @@ fn test_submit_text() {
     );
 }
 
-// #[test]
-// fn test_escape_cancels_streaming() {
-//     let config = SessionConfig::new().with_stream_until_cancel();
-//
-//     let mut session = TuiSession::spawn_with_config(24, 80, config).unwrap();
-//     session.wait_for_text("To get started", TIMEOUT).unwrap();
-//
-//     // Submit prompt
-//     session.send_str("testing!!!").unwrap();
-//     session.wait_for_text("testing!!!", TIMEOUT).unwrap();
-//     std::thread::sleep(Duration::from_millis(100));
-//     session.send_key(Key::Enter).unwrap();
-//     std::thread::sleep(Duration::from_millis(100));
-//
-//     // Wait for streaming to start
-//     session
-//         .wait_for_text("Streaming...", TIMEOUT)
-//         .expect("Streaming did not start");
-//
-//     // Press Escape to cancel
-//     session.send_key(Key::Escape).unwrap();
-//
-//     // Verify cancellation completed
-//     // (exact behavior depends on TUI implementation)
-//     session
-//         .wait_for(
-//             |s| s.contains("Cancelled") || s.contains("Stopped"),
-//             TIMEOUT,
-//         )
-//         .ok(); // May not show explicit message
-//
-//     assert_snapshot!(
-//         "cancelled_stream",
-//         normalize_for_snapshot(session.screen_contents())
-//     )
-// }
+#[test]
+fn test_escape_cancels_streaming() {
+    // Use git_init to prevent "Snapshots disabled" from racing with "Working" status
+    let config = SessionConfig::new().with_stream_until_cancel();
+    let mut session = TuiSession::spawn_with_config(24, 80, config).unwrap();
+
+    // Wait for the prompt to appear (indicated by the chevron character)
+    session
+        .wait_for_text("›", TIMEOUT)
+        .expect("Prompt did not appear");
+    std::thread::sleep(TIMEOUT_INPUT);
+
+    // Submit prompt
+    session.send_str("testing!!!").unwrap();
+    session.wait_for_text("testing!!!", TIMEOUT).unwrap();
+    std::thread::sleep(TIMEOUT_INPUT);
+    session.send_key(Key::Enter).unwrap();
+    std::thread::sleep(TIMEOUT_INPUT);
+
+    // Wait for streaming to start
+    session
+        .wait_for_text("Working", TIMEOUT)
+        .expect("Streaming did not start");
+
+    // Press Escape to cancel doesn't work?
+    session.send_key(Key::Escape).unwrap();
+    std::thread::sleep(TIMEOUT_INPUT);
+    // Press ctrl-c to cancel doesn't work?
+    // session.send_key(Key::Ctrl('c')).unwrap();
+    // std::thread::sleep(TIMEOUT_INPUT);
+
+    std::thread::sleep(TIMEOUT);
+    // Verify cancellation completed
+    // (exact behavior depends on TUI implementation)
+    session
+        .wait_for_text(
+            "Conversation interrupted - tell the model what to do differently",
+            TIMEOUT,
+        )
+        .expect("No interrupt reported");
+
+    assert_snapshot!(
+        "cancelled_stream",
+        normalize_for_snapshot(session.screen_contents())
+    )
+}