Struct GitHubMiner 

pub struct GitHubMiner { /* private fields */ }

GitHub organization miner Phase 1: Basic organization and repository fetching

Implementations

impl GitHubMiner

pub fn new(token: Option<String>) -> Self

Create a new GitHub miner

Arguments

• token - Optional GitHub personal access token for authenticated requests

Examples

use organizational_intelligence_plugin::github::GitHubMiner;

// Public repos only (unauthenticated)
let miner = GitHubMiner::new(None);

// With authentication (higher rate limits)
let miner_auth = GitHubMiner::new(Some("ghp_token".to_string()));

Examples found in repository

examples/analyze_org.rs (line 29)

async fn main() -> Result<()> {
    // Initialize logging
    tracing_subscriber::fmt::fmt()
        .with_max_level(tracing::Level::INFO)
        .init();

    println!("🚀 Organizational Intelligence Plugin - Example");
    println!("   Analyzing organization: tokio-rs\n");

    // Initialize GitHub client (unauthenticated for this example)
    let miner = GitHubMiner::new(None);

    // Fetch organization repositories
    println!("📥 Fetching repositories...");
    let repos = miner.fetch_organization_repos("tokio-rs").await?;

    println!("✅ Found {} repositories\n", repos.len());

    // Display top 3 by stars
    let mut sorted_repos = repos.clone();
    sorted_repos.sort_by(|a, b| b.stars.cmp(&a.stars));

    println!("⭐ Top repositories:");
    for (i, repo) in sorted_repos.iter().take(3).enumerate() {
        println!(
            "   {}. {} ({} ⭐) - {}",
            i + 1,
            repo.name,
            repo.stars,
            repo.language.as_deref().unwrap_or("Unknown")
        );
    }

    // Generate report
    println!("\n📊 Generating YAML report...");
    let report_generator = ReportGenerator::new();

    let metadata = AnalysisMetadata {
        organization: "tokio-rs".to_string(),
        analysis_date: Utc::now().to_rfc3339(),
        repositories_analyzed: repos.len(),
        commits_analyzed: 0, // Phase 1: Not analyzing commits yet
        analyzer_version: env!("CARGO_PKG_VERSION").to_string(),
    };

    let report = AnalysisReport {
        version: "1.0".to_string(),
        metadata,
        defect_patterns: vec![], // Phase 1: No classifier yet
    };

    // Write to file
    let output_path = PathBuf::from("tokio-rs-analysis.yaml");
    report_generator
        .write_to_file(&report, &output_path)
        .await?;

    println!("✅ Report saved to: {}", output_path.display());

    // Display a sample of the YAML
    let yaml_content = tokio::fs::read_to_string(&output_path).await?;
    println!("\n📄 Report preview:");
    println!("---");
    for (i, line) in yaml_content.lines().take(15).enumerate() {
        println!("{}", line);
        if i == 14 && yaml_content.lines().count() > 15 {
            println!("   ... (truncated)");
        }
    }
    println!("---");

    println!("\n🎯 Example complete!");
    println!("   Phase 1 MVP features demonstrated:");
    println!("   ✅ GitHub API integration");
    println!("   ✅ Repository fetching");
    println!("   ✅ YAML report generation");

    Ok(())
}

examples/full_analysis.rs (line 31)

async fn main() -> Result<()> {
    // Initialize logging
    tracing_subscriber::fmt::fmt()
        .with_max_level(tracing::Level::INFO)
        .init();

    println!("🚀 Organizational Intelligence Plugin - Full Analysis Example\n");
    println!("Demonstrates: GitHub API → Git Mining → Classification → YAML Report\n");

    // Step 1: Fetch repositories from GitHub organization
    println!("📥 Step 1: Fetching repositories from GitHub...");
    let github_miner = GitHubMiner::new(None); // Unauthenticated for demo
    let org_name = "tokio-rs";

    let repos = github_miner.fetch_organization_repos(org_name).await?;
    println!("✅ Found {} repositories in {}\n", repos.len(), org_name);

    // Display top repositories
    let mut sorted_repos = repos.clone();
    sorted_repos.sort_by(|a, b| b.stars.cmp(&a.stars));

    println!("⭐ Top 3 repositories:");
    for (i, repo) in sorted_repos.iter().take(3).enumerate() {
        println!("   {}. {} ({} ⭐)", i + 1, repo.name, repo.stars);
    }
    println!();

    // Step 2: Analyze repositories for defect patterns
    println!("🔍 Step 2: Analyzing commit history for defect patterns...");

    // Create temporary directory for cloning
    let temp_dir = TempDir::new()?;
    let analyzer = OrgAnalyzer::new(temp_dir.path());

    // Analyze top repository (limit to 100 commits for demo speed)
    let top_repo = &sorted_repos[0];
    println!("   Analyzing: {} (up to 100 commits)", top_repo.name);

    let patterns = analyzer
        .analyze_repository(
            &format!("https://github.com/{}/{}", org_name, top_repo.name),
            &top_repo.name,
            100,
        )
        .await?;

    if patterns.is_empty() {
        println!("   ℹ️  No defect patterns detected in last 100 commits");
    } else {
        println!("   ✅ Found {} defect categories\n", patterns.len());

        // Display patterns
        println!("📊 Defect Patterns Found:");
        for pattern in &patterns {
            println!(
                "   • {} (n={}, confidence={:.0}%)",
                pattern.category.as_str(),
                pattern.frequency,
                pattern.confidence * 100.0
            );
            if !pattern.examples.is_empty() {
                let example = &pattern.examples[0];
                println!("     Example: {}: {}", example.commit_hash, example.message);
            }
        }
        println!();
    }

    // Step 3: Generate YAML report
    println!("📝 Step 3: Generating YAML report...");
    let report_generator = ReportGenerator::new();

    let metadata = AnalysisMetadata {
        organization: org_name.to_string(),
        analysis_date: Utc::now().to_rfc3339(),
        repositories_analyzed: 1, // We analyzed 1 repo in this demo
        commits_analyzed: 100,
        analyzer_version: env!("CARGO_PKG_VERSION").to_string(),
    };

    let report = AnalysisReport {
        version: "1.0".to_string(),
        metadata,
        defect_patterns: patterns,
    };

    // Write to file
    let output_path = PathBuf::from("full-analysis-report.yaml");
    report_generator
        .write_to_file(&report, &output_path)
        .await?;

    println!("✅ Report saved to: {}", output_path.display());

    // Display YAML preview
    let yaml_content = tokio::fs::read_to_string(&output_path).await?;
    println!("\n📄 Report Preview (first 20 lines):");
    println!("---");
    for (i, line) in yaml_content.lines().enumerate() {
        if i >= 20 {
            println!(
                "   ... (truncated, see {} for full report)",
                output_path.display()
            );
            break;
        }
        println!("{}", line);
    }
    println!("---");

    // Summary
    println!("\n🎯 Full Analysis Complete!");
    println!("   ✅ GitHub API integration");
    println!("   ✅ Git repository cloning");
    println!("   ✅ Commit history analysis");
    println!("   ✅ Rule-based defect classification");
    println!("   ✅ YAML report generation");
    println!("\n   Phase 1 MVP complete!");
    println!("   Next: User feedback mechanism for Phase 2 ML training");

    Ok(())
}

pub async fn fetch_organization_repos( &self, org_name: &str, ) -> Result<Vec<RepoInfo>>

Fetch all repositories for an organization

Arguments

• org_name - GitHub organization name

Errors

Returns error if:

• Organization name is empty
• API request fails
• Organization doesn’t exist

Examples

use organizational_intelligence_plugin::github::GitHubMiner;

let miner = GitHubMiner::new(None);
let repos = miner.fetch_organization_repos("rust-lang").await?;
println!("Found {} repositories", repos.len());

Examples found in repository

examples/analyze_org.rs (line 33)

async fn main() -> Result<()> {
    // Initialize logging
    tracing_subscriber::fmt::fmt()
        .with_max_level(tracing::Level::INFO)
        .init();

    println!("🚀 Organizational Intelligence Plugin - Example");
    println!("   Analyzing organization: tokio-rs\n");

    // Initialize GitHub client (unauthenticated for this example)
    let miner = GitHubMiner::new(None);

    // Fetch organization repositories
    println!("📥 Fetching repositories...");
    let repos = miner.fetch_organization_repos("tokio-rs").await?;

    println!("✅ Found {} repositories\n", repos.len());

    // Display top 3 by stars
    let mut sorted_repos = repos.clone();
    sorted_repos.sort_by(|a, b| b.stars.cmp(&a.stars));

    println!("⭐ Top repositories:");
    for (i, repo) in sorted_repos.iter().take(3).enumerate() {
        println!(
            "   {}. {} ({} ⭐) - {}",
            i + 1,
            repo.name,
            repo.stars,
            repo.language.as_deref().unwrap_or("Unknown")
        );
    }

    // Generate report
    println!("\n📊 Generating YAML report...");
    let report_generator = ReportGenerator::new();

    let metadata = AnalysisMetadata {
        organization: "tokio-rs".to_string(),
        analysis_date: Utc::now().to_rfc3339(),
        repositories_analyzed: repos.len(),
        commits_analyzed: 0, // Phase 1: Not analyzing commits yet
        analyzer_version: env!("CARGO_PKG_VERSION").to_string(),
    };

    let report = AnalysisReport {
        version: "1.0".to_string(),
        metadata,
        defect_patterns: vec![], // Phase 1: No classifier yet
    };

    // Write to file
    let output_path = PathBuf::from("tokio-rs-analysis.yaml");
    report_generator
        .write_to_file(&report, &output_path)
        .await?;

    println!("✅ Report saved to: {}", output_path.display());

    // Display a sample of the YAML
    let yaml_content = tokio::fs::read_to_string(&output_path).await?;
    println!("\n📄 Report preview:");
    println!("---");
    for (i, line) in yaml_content.lines().take(15).enumerate() {
        println!("{}", line);
        if i == 14 && yaml_content.lines().count() > 15 {
            println!("   ... (truncated)");
        }
    }
    println!("---");

    println!("\n🎯 Example complete!");
    println!("   Phase 1 MVP features demonstrated:");
    println!("   ✅ GitHub API integration");
    println!("   ✅ Repository fetching");
    println!("   ✅ YAML report generation");

    Ok(())
}

examples/full_analysis.rs (line 34)

async fn main() -> Result<()> {
    // Initialize logging
    tracing_subscriber::fmt::fmt()
        .with_max_level(tracing::Level::INFO)
        .init();

    println!("🚀 Organizational Intelligence Plugin - Full Analysis Example\n");
    println!("Demonstrates: GitHub API → Git Mining → Classification → YAML Report\n");

    // Step 1: Fetch repositories from GitHub organization
    println!("📥 Step 1: Fetching repositories from GitHub...");
    let github_miner = GitHubMiner::new(None); // Unauthenticated for demo
    let org_name = "tokio-rs";

    let repos = github_miner.fetch_organization_repos(org_name).await?;
    println!("✅ Found {} repositories in {}\n", repos.len(), org_name);

    // Display top repositories
    let mut sorted_repos = repos.clone();
    sorted_repos.sort_by(|a, b| b.stars.cmp(&a.stars));

    println!("⭐ Top 3 repositories:");
    for (i, repo) in sorted_repos.iter().take(3).enumerate() {
        println!("   {}. {} ({} ⭐)", i + 1, repo.name, repo.stars);
    }
    println!();

    // Step 2: Analyze repositories for defect patterns
    println!("🔍 Step 2: Analyzing commit history for defect patterns...");

    // Create temporary directory for cloning
    let temp_dir = TempDir::new()?;
    let analyzer = OrgAnalyzer::new(temp_dir.path());

    // Analyze top repository (limit to 100 commits for demo speed)
    let top_repo = &sorted_repos[0];
    println!("   Analyzing: {} (up to 100 commits)", top_repo.name);

    let patterns = analyzer
        .analyze_repository(
            &format!("https://github.com/{}/{}", org_name, top_repo.name),
            &top_repo.name,
            100,
        )
        .await?;

    if patterns.is_empty() {
        println!("   ℹ️  No defect patterns detected in last 100 commits");
    } else {
        println!("   ✅ Found {} defect categories\n", patterns.len());

        // Display patterns
        println!("📊 Defect Patterns Found:");
        for pattern in &patterns {
            println!(
                "   • {} (n={}, confidence={:.0}%)",
                pattern.category.as_str(),
                pattern.frequency,
                pattern.confidence * 100.0
            );
            if !pattern.examples.is_empty() {
                let example = &pattern.examples[0];
                println!("     Example: {}: {}", example.commit_hash, example.message);
            }
        }
        println!();
    }

    // Step 3: Generate YAML report
    println!("📝 Step 3: Generating YAML report...");
    let report_generator = ReportGenerator::new();

    let metadata = AnalysisMetadata {
        organization: org_name.to_string(),
        analysis_date: Utc::now().to_rfc3339(),
        repositories_analyzed: 1, // We analyzed 1 repo in this demo
        commits_analyzed: 100,
        analyzer_version: env!("CARGO_PKG_VERSION").to_string(),
    };

    let report = AnalysisReport {
        version: "1.0".to_string(),
        metadata,
        defect_patterns: patterns,
    };

    // Write to file
    let output_path = PathBuf::from("full-analysis-report.yaml");
    report_generator
        .write_to_file(&report, &output_path)
        .await?;

    println!("✅ Report saved to: {}", output_path.display());

    // Display YAML preview
    let yaml_content = tokio::fs::read_to_string(&output_path).await?;
    println!("\n📄 Report Preview (first 20 lines):");
    println!("---");
    for (i, line) in yaml_content.lines().enumerate() {
        if i >= 20 {
            println!(
                "   ... (truncated, see {} for full report)",
                output_path.display()
            );
            break;
        }
        println!("{}", line);
    }
    println!("---");

    // Summary
    println!("\n🎯 Full Analysis Complete!");
    println!("   ✅ GitHub API integration");
    println!("   ✅ Git repository cloning");
    println!("   ✅ Commit history analysis");
    println!("   ✅ Rule-based defect classification");
    println!("   ✅ YAML report generation");
    println!("\n   Phase 1 MVP complete!");
    println!("   Next: User feedback mechanism for Phase 2 ML training");

    Ok(())
}

pub fn filter_by_date( repos: Vec<RepoInfo>, since: DateTime<Utc>, ) -> Vec<RepoInfo>

Filter repositories by last update date

Arguments

• repos - List of repositories to filter
• since - Only include repos updated since this date

Returns

Filtered list of repositories