Function project_task

src/daemon/git_watch.rs:371–426

One project's event loop: build the notify watcher over git metadata, then debounce raw events into coalesced syncs. On watcher construction/death, fall back to a 5-minute mtime poll for THIS project only.

(inner: Arc<GitWatcherInner>, state: Arc<WatchState>)

/// debounce raw events into coalesced syncs. On watcher construction/death,
/// fall back to a 5-minute mtime poll for THIS project only.
async fn project_task(inner: Arc<GitWatcherInner>, state: Arc<WatchState>) {
    let Some(common_dir) = crate::worktree::git_common_dir(&state.project_root) else {
        // Not a resolvable git repo (yet). Degrade to polling so a later `git
        // init` / clone is still eventually covered.
        state.health.set_degraded(true);
        degraded_poll_loop(&inner, &state, None).await;
        return;
    };

    // Build the raw watcher. Its callback pushes into the dirty set and wakes
    // the debounce loop — it never blocks and never syncs inline.
    let wake_state = Arc::clone(&state);
    let watcher = notify::recommended_watcher(move |res: notify::Result<notify::Event>| {
        if let Ok(event) = res {
            classify_and_mark(&wake_state, &event);
        }
    });

    let mut watcher = match watcher {
        Ok(w) => w,
        Err(e) => {
            log_daemon_event(
                "git_watch_degraded",
                &[
                    ("project", state.project_root.display().to_string()),
                    ("reason", "watcher_build_failed".to_string()),
                    ("error", e.to_string()),
                ],
            );
            state.health.set_degraded(true);
            degraded_poll_loop(&inner, &state, Some(&common_dir)).await;
            return;
        }
    };

    if let Err(e) = install_watches(&mut watcher, &common_dir) {
        log_daemon_event(
            "git_watch_degraded",
            &[
                ("project", state.project_root.display().to_string()),
                ("reason", "watch_install_failed".to_string()),
                ("error", e.to_string()),
            ],
        );
        state.health.set_degraded(true);
        degraded_poll_loop(&inner, &state, Some(&common_dir)).await;
        return;
    }

    state.health.set_degraded(false);
    state.health.beat();

    debounce_loop(&inner, &state, &common_dir).await;
    // Keep the watcher alive for the whole loop.
    drop(watcher);
}

/// Installs the minimal metadata watch set: `HEAD`, `packed-refs`, in-flight