Function select_commits

src/gitql/gitql_data_provider.rs:112–207

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

}

fn select_commits(repo: &gix::Repository, selected_columns: &[String]) -> Result<Vec<Row>, String> {
    let head_id = repo.head_id();
    if let Err(error) = head_id {
        return Err(error.to_string());
    }

    let repo_path = repo.path().to_str().unwrap();
    let walker = head_id.unwrap().ancestors().all().unwrap();
    let mut rows: Vec<Row> = vec![];

    for commit_info in walker {
        let commit_info = commit_info.unwrap();
        let commit = repo.find_object(commit_info.id).unwrap().into_commit();
        let commit = commit.decode().unwrap();

        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 == "author_name" {
                if let Ok(commit_author) = commit.author() {
                    values.push(Box::new(TextValue::new(commit_author.name.to_string())));
                    continue;
                }
                values.push(Box::new(TextValue::empty()));
                continue;
            }

            if column_name == "author_email" {
                if let Ok(commit_author) = commit.author() {
                    values.push(Box::new(TextValue::new(commit_author.email.to_string())));
                    continue;
                }
                values.push(Box::new(TextValue::empty()));
                continue;
            }

            if column_name == "committer_name" {
                if let Ok(commit_committer) = commit.committer() {
                    values.push(Box::new(TextValue::new(commit_committer.name.to_string())));
                    continue;
                }
                values.push(Box::new(TextValue::empty()));
                continue;
            }

            if column_name == "committer_email" {
                if let Ok(commit_committer) = commit.committer() {
                    values.push(Box::new(TextValue::new(commit_committer.email.to_string())));
                    continue;
                }
                values.push(Box::new(TextValue::empty()));
                continue;
            }