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

//! AI-powered push narrative generation.

use std::collections::HashMap;

use rigg_core::resources::ResourceKind;
use rigg_diff::Change;

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

/// Generate a single AI narrative covering all push changes.
///
/// Returns `Some(narrative)` on success, `None` on failure (caller falls back to non-AI output).
pub(super) async fn generate_push_narrative(
    resources_to_push: &[(ResourceKind, String, serde_json::Value, bool)],
    change_details: &HashMap<(ResourceKind, String), Vec<Change>>,
    remote_values: &HashMap<(ResourceKind, String), serde_json::Value>,
    total_unchanged: usize,
) -> Option<String> {
    eprintln!("Generating AI explanation...");

    let push_labels = Some(("on the server", "locally"));
    let mut contexts = Vec::new();

    for (kind, name, local_def, exists) in resources_to_push {
        let key = (*kind, name.clone());

        if *exists {
            // Updated resource — has changes
            if let Some(changes) = change_details.get(&key) {
                let local_content = Some(format_for_ai(*kind, local_def));
                let remote_content = remote_values.get(&key).map(|v| format_for_ai(*kind, v));
                let descriptions = describe_changes_plain(changes, *kind, name, push_labels);
                contexts.push(ResourceContext {
                    kind: *kind,
                    name: name.clone(),
                    status: ChangeStatus::Modified,
                    local_content,
                    remote_content,
                    descriptions,
                });
            }
        } else {
            // New resource — will be created
            let local_content = Some(format_for_ai(*kind, local_def));
            contexts.push(ResourceContext {
                kind: *kind,
                name: name.clone(),
                status: ChangeStatus::New,
                local_content,
                remote_content: None,
                descriptions: vec![],
            });
        }
    }

    if contexts.is_empty() {
        return None;
    }

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