pmat 3.11.0

PMAT - Zero-config AI context generation and code quality toolkit (CLI, MCP, HTTP)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106

// TDG watch mode - feature-gated file watcher for continuous analysis

#[cfg(feature = "watch")]
/// Helper function to perform TDG analysis without watch mode
#[allow(clippy::too_many_arguments)]
async fn perform_tdg_analysis(
    calculator: &crate::services::tdg_calculator::TDGCalculator,
    path: &Path,
    threshold: f64,
    top: usize,
    format: &TdgOutputFormat,
    include_components: bool,
    output: &Option<PathBuf>,
    critical_only: bool,
    verbose: bool,
) -> Result<()> {
    // Reuse the main analysis logic
    let output_content = analyze_multiple_files(
        calculator,
        path,
        vec![], // Empty files list for project mode
        threshold,
        top,
        format.clone(),
        include_components,
        critical_only,
        verbose,
    )
    .await?;

    if let Some(output_path) = output {
        std::fs::write(output_path, output_content)?;
        eprintln!("✅ TDG analysis saved to {}", output_path.display());
    } else {
        print!("{output_content}");
    }

    Ok(())
}

#[cfg(feature = "watch")]
/// Run TDG analysis in watch mode
#[allow(clippy::too_many_arguments)]
async fn run_tdg_watch_mode(
    path: PathBuf,
    threshold: f64,
    top: usize,
    format: TdgOutputFormat,
    include_components: bool,
    output: Option<PathBuf>,
    critical_only: bool,
    verbose: bool,
) -> Result<()> {
    use notify::{RecommendedWatcher, RecursiveMode, Watcher};
    use std::sync::mpsc;
    use tokio::time::Duration;

    eprintln!("👁️  Watching for changes in TDG analysis...");
    let (tx, rx) = mpsc::channel();

    let mut watcher = RecommendedWatcher::new(
        tx,
        notify::Config::default().with_poll_interval(Duration::from_secs(2)),
    )?;
    watcher.watch(&path, RecursiveMode::Recursive)?;

    // Initial analysis
    let calculator = crate::services::tdg_calculator::TDGCalculator::new();
    perform_tdg_analysis(
        &calculator,
        &path,
        threshold,
        top,
        &format,
        include_components,
        &output,
        critical_only,
        verbose,
    )
    .await?;

    loop {
        match rx.recv() {
            Ok(_event) => {
                eprintln!("🔄 Change detected, re-analyzing...");
                perform_tdg_analysis(
                    &calculator,
                    &path,
                    threshold,
                    top,
                    &format,
                    include_components,
                    &output,
                    critical_only,
                    verbose,
                )
                .await?;
            }
            Err(e) => {
                eprintln!("❌ Watch error: {e}");
                break;
            }
        }
    }
    Ok(())
}