Function grep_handler

server/src/server/routes.rs:591–622

(
    State(state): State<AppState>,
    headers: HeaderMap,
    Query(params): Query<GrepQuery>,
)

}

async fn grep_handler(
    State(state): State<AppState>,
    headers: HeaderMap,
    Query(params): Query<GrepQuery>,
) -> Result<Json<Value>, AppError> {
    let project = require_project(&state, &headers)?;
    let max_matches = params.max_matches.unwrap_or(50);
    let context_lines = params.context_lines.unwrap_or(2);
    let scope = params
        .scope
        .as_deref()
        .map(|s| content::GrepScope::from_str(s))
        .flatten()
        .unwrap_or(content::GrepScope::All);

    // Run grep on a blocking thread since it reads many files
    let root = project.root.clone();
    let file_tree = project.file_tree.clone();
    let pattern = params.pattern.clone();
    let file_filter = params.file.clone();

    let result = tokio::task::spawn_blocking(move || {
        content::grep_with_scope(&root, &file_tree, &pattern, max_matches, context_lines, scope, file_filter.as_deref())
    })
    .await
    .map_err(|e| AppError::Internal(e.to_string()))?
    .map_err(AppError::BadRequest)?;

    let preview = format!("{} matches for '{}'", result.total_matches, params.pattern);
    record_history(&state, session_id(&headers).as_deref(), "GET", "/grep", &preview);
    Ok(Json(serde_json::to_value(result).unwrap()))
}

#[derive(Deserialize)]
struct ChunkQuery {