Function ingest_cursor_transcript_for_event

src/hooks/cursor.rs:664–698

Incrementally ingests the Cursor transcript referenced by `event_json` into the resolved project session DB, bounded by `max_new_bytes` (the hot-path cap) and an overall `budget`. Always fails open: a timeout, missing transcript, or any error is swallowed so the calling hook never blocks the agent.

(
    event_json: &str,
    max_new_bytes: Option<u64>,
    budget: Duration,
)

/// and an overall `budget`. Always fails open: a timeout, missing transcript, or
/// any error is swallowed so the calling hook never blocks the agent.
pub(super) async fn ingest_cursor_transcript_for_event(
    event_json: &str,
    max_new_bytes: Option<u64>,
    budget: Duration,
) -> bool {
    let work = async {
        let Ok(parsed) = serde_json::from_str::<Value>(event_json) else {
            return false;
        };
        let Some(project_root) = cursor_project_root_from_parsed_event(&parsed) else {
            return false;
        };
        if let Some(cwd_root) = cursor_event_cwd(&parsed)
            .as_deref()
            .and_then(crate::config::discover_project_root)
        {
            if !paths_same(&cwd_root, &project_root) {
                return false;
            }
        }
        let Some(db) = crate::sessions::cursor::open_project_session_db(&project_root).await else {
            return false;
        };
        let _ = crate::sessions::cursor::ingest_cursor_transcript_event_capped(
            event_json,
            &db,
            max_new_bytes,
        )
        .await;
        true
    };
    // Short-lived CLI hook processes exit immediately, so the ingest must run
    // inline (not on a detached task); the timeout keeps it inside budget.
    tokio::time::timeout(budget, work).await.unwrap_or(false)
}

fn cursor_tool_hint_input(parsed: &Value) -> ToolHintInput {
    let tool_input = parsed