pull_requests.rs

//! Example: Working with Azure DevOps Pull Requests.
//!
//! Set `AZURE_DEVOPS_PAT`, `AZURE_DEVOPS_ORG`, `AZURE_DEVOPS_PROJECT`,
//! and `AZURE_DEVOPS_REPO_ID` before running:
//!
//! ```sh
//! cargo run --example pull_requests
//! ```

use azure_devops::pull_requests::models::GitPullRequestSearchCriteria;
use azure_devops::AzureDevOps;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let pat =
        std::env::var("AZURE_DEVOPS_PAT").expect("AZURE_DEVOPS_PAT environment variable not set");
    let org = std::env::var("AZURE_DEVOPS_ORG").unwrap_or_else(|_| "my-company".to_string());
    let _project =
        std::env::var("AZURE_DEVOPS_PROJECT").unwrap_or_else(|_| "MyProject".to_string());
    let repo_id = std::env::var("AZURE_DEVOPS_REPO_ID")
        .expect("AZURE_DEVOPS_REPO_ID environment variable not set (UUID of the repo)");

    let client = AzureDevOps::builder()
        .organization(&org)
        .pat(&pat)
        .build()?;

    // ── List active pull requests ──────────────────────────────────
    let criteria = GitPullRequestSearchCriteria::default();
    let prs = client.pull_requests().list(&repo_id, &criteria).await?;
    println!(
        "Found {} pull request(s) in repository '{repo_id}':",
        prs.len()
    );
    for pr in &prs {
        println!(
            "  • PR #{} — {} (by {}) — status: {:?}",
            pr.pull_request_id.unwrap_or(0),
            pr.title.as_deref().unwrap_or("?"),
            pr.created_by
                .as_ref()
                .and_then(|c| c.display_name.as_deref())
                .unwrap_or("?"),
            pr.status
        );
    }

    // ── Get a specific PR with details ─────────────────────────────
    if let Some(first) = prs.first() {
        let pr_id = first.pull_request_id.unwrap_or(0);
        if pr_id > 0 {
            let pr = client.pull_requests().get(&repo_id, pr_id).await?;
            println!("\nDetails for PR #{pr_id}:");
            println!("  Title: {}", pr.title.as_deref().unwrap_or("?"));
            println!(
                "  Source: {} → {}",
                pr.source_ref_name.as_deref().unwrap_or("?"),
                pr.target_ref_name.as_deref().unwrap_or("?")
            );

            // List reviewers
            let reviewers = client
                .pull_requests()
                .list_reviewers(&repo_id, pr_id)
                .await?;
            println!(
                "  Reviewers: {}",
                reviewers
                    .iter()
                    .filter_map(|r| r.display_name.as_deref())
                    .collect::<Vec<_>>()
                    .join(", ")
            );
        }
    }

    Ok(())
}