pmat 3.16.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

// Interactive and resume refactor command handlers.
// Handles `pmat refactor interactive` and `pmat refactor resume` workflows.

#[provable_contracts_macros::contract("pmat-core.yaml", equation = "path_exists")]
pub async fn handle_refactor_interactive(
    project_path: PathBuf,
    explain: ExplainLevel,
    checkpoint: PathBuf,
    target_complexity: u16,
    steps: Option<u32>,
    config: Option<PathBuf>,
) -> anyhow::Result<()> {
    println!("🤖 Starting interactive refactor mode...");
    println!("📁 Project path: {}", project_path.display());
    println!("💾 Checkpoint: {}", checkpoint.display());
    println!("🎯 Target complexity: {target_complexity}");
    println!("📝 Explanation level: {explain:?}");

    // Load configuration
    let refactor_config = if let Some(config_path) = config {
        load_refactor_config(&config_path).await?
    } else {
        RefactorConfig {
            target_complexity,
            ..Default::default()
        }
    };

    // Create cache and AST engine
    let cache_config = crate::services::cache::unified::UnifiedCacheConfig::default();
    let cache = Arc::new(UnifiedCacheManager::new(cache_config)?);
    let ast_engine = Arc::new(UnifiedAstEngine::new());

    // Setup interactive mode
    let mode = EngineMode::Interactive {
        checkpoint_file: checkpoint,
        explain_level: explain.into(),
    };

    // Discover targets
    let targets = discover_refactor_targets(&project_path).await?;
    println!("🎯 Found {} refactoring targets", targets.len());

    // Create and run engine
    let mut engine = UnifiedEngine::new(ast_engine, cache, mode, refactor_config, targets);

    if let Some(max_steps) = steps {
        println!("⏱️  Maximum steps: {max_steps}");
    }

    let summary = engine.run().await?;

    println!("✅ Interactive refactor completed:");
    println!("   Files processed: {}", summary.files_processed);
    println!("   Refactors applied: {}", summary.refactors_applied);

    Ok(())
}

#[provable_contracts_macros::contract("pmat-core.yaml", equation = "path_exists")]
pub async fn handle_refactor_resume(
    checkpoint: PathBuf,
    steps: u32,
    explain: Option<ExplainLevel>,
) -> anyhow::Result<()> {
    println!("🔄 Resuming refactor from: {}", checkpoint.display());
    println!("⏱️  Maximum steps: {steps}");

    if !checkpoint.exists() {
        return Err(anyhow::anyhow!(
            "Checkpoint file not found: {}",
            checkpoint.display()
        ));
    }

    // Load the state machine from checkpoint
    let checkpoint_data = tokio::fs::read_to_string(&checkpoint).await?;
    let _state: serde_json::Value = serde_json::from_str(&checkpoint_data)?;

    // This would resume with the loaded state
    println!("📝 State loaded successfully");

    if let Some(explain_level) = explain {
        println!("📖 Explanation level override: {explain_level:?}");
    }

    // Placeholder implementation
    println!("⚠️  Resume functionality not yet fully implemented");
    println!("   This would continue from the saved state for {steps} steps");

    Ok(())
}