Function select_diffs_changes

src/gitql/gitql_data_provider.rs:425–524

(
    repo: &gix::Repository,
    selected_columns: &[String],
)

}

fn select_diffs_changes(
    repo: &gix::Repository,
    selected_columns: &[String],
) -> Result<Vec<Row>, String> {
    let repo = {
        let mut repo = repo.clone();
        repo.object_cache_size_if_unset(4 * 1024 * 1024);
        repo
    };

    let mut rewrite_cache = repo
        .diff_resource_cache(Mode::ToGit, Default::default())
        .unwrap();

    let mut diff_cache = rewrite_cache.clone();

    let repo_path = repo.path().to_str().unwrap();
    let walker = repo.head_id().unwrap().ancestors().all().unwrap();
    let commits_info = walker.filter_map(Result::ok);

    let mut rows: Vec<Row> = vec![];
    let selected_columns_len = selected_columns.len();
    for commit_info in commits_info.into_iter() {
        let commit = commit_info.id().object().unwrap().into_commit();
        let commit_ref = commit.decode().unwrap();

        if let Some(parent) = commit_info
            .parent_ids()
            .next()
            .map(|id| id.object().unwrap().into_commit().tree().unwrap())
        {
            let current = commit.tree().unwrap();
            rewrite_cache.clear_resource_cache_keep_allocation();
            diff_cache.clear_resource_cache_keep_allocation();

            if let Ok(mut changes) = current.changes() {
                let _ = changes.for_each_to_obtain_tree_with_cache(
                    &parent,
                    &mut rewrite_cache,
                    |change| {
                        let diff_change = DiffChange::new_without_content(&change, &mut diff_cache);

                        let mut values: Vec<Box<dyn Value>> =
                            Vec::with_capacity(selected_columns_len);
                        for column_name in selected_columns {
                            if column_name == "commit_id" {
                                values.push(Box::new(TextValue::new(commit_info.id.to_string())));
                                continue;
                            }

                            if column_name == "insertions" {
                                values.push(Box::new(IntValue::new(diff_change.insertions as i64)));
                                continue;
                            }

                            if column_name == "removals" {
                                values.push(Box::new(IntValue::new(diff_change.removals as i64)));
                                continue;