Function test_watcher_multiple_turns

atomic-agent/src/watcher/fallback.rs:768–798

()

    #[tokio::test]
    async fn test_watcher_multiple_turns() {
        let dir = TempDir::new().unwrap();

        let mut watcher = FallbackWatcher::new(make_config(&dir));

        // Turn 1: add a file
        watcher.begin_turn("sess-1").await.unwrap();
        fs::write(dir.path().join("turn1.rs"), "turn 1").unwrap();
        let changes = watcher.end_turn().await.unwrap();
        assert_eq!(changes.added, vec![PathBuf::from("turn1.rs")]);

        // Turn 2: add another file
        watcher.begin_turn("sess-1").await.unwrap();
        fs::write(dir.path().join("turn2.rs"), "turn 2").unwrap();
        let changes = watcher.end_turn().await.unwrap();
        // Should only see turn2.rs, not turn1.rs (which existed before this turn)
        assert_eq!(changes.added, vec![PathBuf::from("turn2.rs")]);
        assert!(changes.modified.is_empty());

        // Turn 3: modify turn1.rs
        watcher.begin_turn("sess-1").await.unwrap();
        std::thread::sleep(std::time::Duration::from_millis(50));
        fs::write(
            dir.path().join("turn1.rs"),
            "turn 1 modified with more content",
        )
        .unwrap();
        let changes = watcher.end_turn().await.unwrap();
        assert_eq!(changes.modified, vec![PathBuf::from("turn1.rs")]);
        assert!(changes.added.is_empty());
    }

    #[tokio::test]
    async fn test_watcher_begin_turn_overwrites_previous() {