Function select_branches

src/gitql/gitql_data_provider.rs:209–297

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

}

fn select_branches(
    repo: &gix::Repository,
    selected_columns: &[String],
) -> Result<Vec<Row>, String> {
    let mut rows: Vec<Row> = vec![];

    let repo_path = repo.path().to_str().unwrap();
    let platform = repo.references().unwrap();
    let local_branches = platform.local_branches().unwrap();
    let remote_branches = platform.remote_branches().unwrap();
    let local_and_remote_branches = local_branches.chain(remote_branches);
    let head_ref_result = repo.head_ref();
    if let Err(error) = head_ref_result {
        return Err(error.to_string());
    }

    let head_ref_option = head_ref_result.unwrap();
    if head_ref_option.is_none() {
        return Ok(rows);
    }

    let head_ref = head_ref_option.unwrap();
    for mut branch in local_and_remote_branches.flatten() {
        let mut values: Vec<Box<dyn Value>> = Vec::with_capacity(selected_columns.len());

        for column_name in selected_columns {
            if column_name == "name" {
                let branch_name = branch.name().as_bstr().to_string();
                values.push(Box::new(TextValue::new(branch_name)));
                continue;
            }

            if column_name == "commit_count" {
                if let Some(id) = branch.try_id()
                    && let Ok(walker) = id.ancestors().all()
                {
                    values.push(Box::new(IntValue::new(walker.count() as i64)));
                    continue;
                }
                values.push(Box::new(IntValue::new_zero()));
                continue;
            }

            if column_name == "updated" {
                if let Ok(top_commit_id) = branch.peel_to_id() {
                    let walker = top_commit_id.ancestors().all().unwrap();
                    if let Some(commit_info) = walker.into_iter().next() {
                        let commit_info = commit_info.unwrap();
                        if let Some(commit_timestamp) = commit_info.commit_time {
                            values.push(Box::new(DateTimeValue::new(commit_timestamp)));
                            continue;
                        }

                        let commit = repo.find_object(commit_info.id).unwrap().into_commit();
                        let commit = commit.decode().unwrap();
                        values.push(Box::new(DateTimeValue::new(commit.time().unwrap().seconds)));
                        continue;
                    }