rigg 0.17.0

Configuration-as-code CLI for Azure AI Search and Microsoft Foundry
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

//! AI-powered explanation helpers for diff output.

use crate::commands::describe::describe_changes_plain;
use crate::commands::explain::{self, ChangeStatus, ResourceContext};

use super::ResourceDiff;

/// Generate a single AI narrative covering all changed resources.
///
/// Returns `Some(narrative)` on success, `None` on failure (caller falls back to non-AI output).
pub(super) async fn generate_ai_narrative(
    diffs: &[ResourceDiff],
    command_context: &str,
    total_unchanged: usize,
) -> Option<String> {
    let changed: Vec<&ResourceDiff> = diffs.iter().filter(|d| !d.result.is_equal).collect();
    if changed.is_empty() {
        return None;
    }

    eprintln!("Generating AI explanation...");

    let labels = Some(("locally", "on the server"));
    let contexts: Vec<ResourceContext> = changed
        .iter()
        .map(|d| {
            let status = if d.result.changes.len() == 1 && d.result.changes[0].path == "." {
                ChangeStatus::New
            } else {
                ChangeStatus::Modified
            };
            let descriptions =
                describe_changes_plain(&d.result.changes, d.kind, &d.resource_name, labels);
            ResourceContext {
                kind: d.kind,
                name: d.resource_name.clone(),
                status,
                local_content: d.local_content.clone(),
                remote_content: d.remote_content.clone(),
                descriptions,
            }
        })
        .collect();

    match explain::explain_all_changes(&contexts, command_context, total_unchanged).await {
        Ok(narrative) => Some(narrative),
        Err(e) => {
            eprintln!("Warning: AI explanation failed: {}", e);
            None
        }
    }
}

/// Generate AI summaries for all changed resources.
pub(super) async fn generate_ai_summaries(
    diffs: &[ResourceDiff],
) -> std::collections::HashMap<String, String> {
    let mut summaries = std::collections::HashMap::new();

    let changed: Vec<&ResourceDiff> = diffs.iter().filter(|d| !d.result.is_equal).collect();
    if changed.is_empty() {
        return summaries;
    }

    eprintln!("Generating AI explanations...");

    // Run LLM calls concurrently
    let labels = Some(("locally", "on the server"));
    let futures: Vec<_> = changed
        .iter()
        .map(|d| {
            let display_id = d.display_id.clone();
            let resource_type = d.kind.display_name().to_string();
            let resource_name = d.resource_name.clone();
            let changes = d.result.changes.clone();
            let descriptions =
                describe_changes_plain(&d.result.changes, d.kind, &d.resource_name, labels);
            async move {
                let result = crate::commands::explain::explain_resource_changes(
                    &resource_type,
                    &resource_name,
                    &changes,
                    &descriptions,
                    "diff",
                )
                .await;
                (display_id, result)
            }
        })
        .collect();

    let results = futures::future::join_all(futures).await;

    for (display_id, result) in results {
        match result {
            Ok(summary) => {
                summaries.insert(display_id, summary);
            }
            Err(e) => {
                eprintln!("Warning: AI explanation failed for {}: {}", display_id, e);
            }
        }
    }

    summaries
}