use anyhow::Result;
use azure_devops_rust_api::pipelines;
use azure_devops_rust_api::pipelines::models::Pipeline;
use std::env;
mod utils;
#[tokio::main]
async fn main() -> Result<()> {
let credential = utils::get_credential()?;
let organization = env::var("ADO_ORGANIZATION").expect("Must define ADO_ORGANIZATION");
let project = env::var("ADO_PROJECT").expect("Must define ADO_PROJECT");
let pipeline_name = env::args().nth(1).expect("Usage: pipelines <name>");
let pipelines_client = pipelines::ClientBuilder::new(credential).build();
let pipelines = pipelines_client
.pipelines_client()
.list(&organization, &project)
.await?
.value;
println!("Total pipelines: {}", pipelines.len());
println!("\nMatched pipelines:");
let matched_pipelines: Vec<Pipeline> = pipelines
.iter()
.filter(|pipeline| pipeline.name.contains(&pipeline_name))
.cloned()
.collect();
for pipeline in matched_pipelines.iter() {
println!("{:4} {}", pipeline.id, pipeline.name);
}
if let Some(pipeline) = matched_pipelines.first() {
println!("\nExample pipeline struct from list:");
println!("{pipeline:#?}");
let pipeline = pipelines_client
.pipelines_client()
.get(&organization, &project, pipeline.id)
.await?;
println!("\nExample pipeline struct from get:");
println!("{pipeline:#?}");
let runs = pipelines_client
.runs_client()
.list(&organization, &project, pipeline.id)
.await?
.value;
println!("\nPipeline runs: {}", runs.len());
for run in runs.iter() {
let result = match &run.result {
Some(result) => format!("{result:?}"),
None => "-".to_string(),
};
println!(
"{:8} {:16} {:16} {:14}",
run.run_reference.id,
run.run_reference.name,
result,
format!("{:?}", run.state)
);
}
}
Ok(())
}