pmat 3.15.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
107
108
109
110
111
112
113

// Incremental analysis methods for IncrementalChurnAnalyzer
// Included from incremental_churn.rs - do NOT add `use` imports or `#!` attributes here.

impl IncrementalChurnAnalyzer {
    /// Get churn metrics for a specific file (lazy evaluation)
    #[provable_contracts_macros::contract("pmat-core.yaml", equation = "path_exists")]
    pub async fn get_file_churn(
        &self,
        file_path: &Path,
    ) -> Result<FileChurnMetrics, TemplateError> {
        // Check cache first
        let relative_path = file_path
            .strip_prefix(&self.project_root)
            .unwrap_or(file_path)
            .to_path_buf();

        if let Some(entry) = self.cache.get(&relative_path) {
            // Check if file has been modified since cache entry
            if self.is_cache_valid(&entry, file_path).await? {
                return Ok(entry.metrics.clone());
            }
        }

        // Compute churn for this specific file
        let metrics = self.compute_file_churn(file_path).await?;

        // Cache the result
        let commit_hash = self.get_current_commit_hash().await?;
        let entry = ChurnCacheEntry {
            metrics: metrics.clone(),
            last_modified: Utc::now(),
            git_commit_hash: commit_hash,
        };
        self.cache.insert(relative_path, entry);

        Ok(metrics)
    }

    /// Get churn analysis for multiple files (incremental)
    #[provable_contracts_macros::contract("pmat-core.yaml", equation = "path_exists")]
    pub async fn analyze_incremental(
        &self,
        files: Vec<PathBuf>,
        period_days: u32,
    ) -> Result<CodeChurnAnalysis, TemplateError> {
        let mut file_metrics = Vec::new();
        let mut uncached_files = Vec::new();

        // Separate cached and uncached files
        for file in files {
            let relative_path = file
                .strip_prefix(&self.project_root)
                .unwrap_or(&file)
                .to_path_buf();

            if let Some(entry) = self.cache.get(&relative_path) {
                if self.is_cache_valid(&entry, &file).await? {
                    file_metrics.push(entry.metrics.clone());
                    continue;
                }
            }
            uncached_files.push(file);
        }

        // Batch analyze uncached files
        if !uncached_files.is_empty() {
            let new_metrics = self
                .batch_compute_churn(&uncached_files, period_days)
                .await?;

            // Cache new results
            let commit_hash = self.get_current_commit_hash().await?;
            for metrics in &new_metrics {
                let relative_path = metrics
                    .path
                    .strip_prefix(&self.project_root)
                    .unwrap_or(&metrics.path)
                    .to_path_buf();

                let entry = ChurnCacheEntry {
                    metrics: metrics.clone(),
                    last_modified: Utc::now(),
                    git_commit_hash: commit_hash.clone(),
                };
                self.cache.insert(relative_path, entry);
            }

            file_metrics.extend(new_metrics);
        }

        // Generate summary
        let summary = self.generate_summary(&file_metrics);

        Ok(CodeChurnAnalysis {
            generated_at: Utc::now(),
            period_days,
            repository_root: self.project_root.clone(),
            files: file_metrics,
            summary,
        })
    }

    /// Check if cache entry is still valid
    async fn is_cache_valid(
        &self,
        entry: &ChurnCacheEntry,
        file_path: &Path,
    ) -> Result<bool, TemplateError> {
        // Check if file has been modified in git since cache entry
        let current_hash = self.get_file_last_commit_hash(file_path).await?;
        Ok(current_hash == entry.git_commit_hash)
    }
}