vasari-core 0.2.3

Content-addressed intent-graph library behind Vasari — intent attribution for autonomous coding agents.
Documentation 
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

use chrono::{DateTime, Utc};
use serde::{Deserialize, Serialize};
use serde_json::json;

use super::NodeId;
use crate::hash::node_id;

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Action {
    pub id: NodeId,
    pub tool: String,
    /// Hashed if the args contain sensitive values (e.g., credentials, PII).
    pub args: serde_json::Value,
    /// Human-readable summary of the result — EXCLUDED from content hash.
    pub result_summary: String,
    pub timestamp: DateTime<Utc>,
    pub plan_ref: PlanRef,
    pub parent_ids: Vec<NodeId>,
    #[serde(default = "default_schema_version")]
    pub schema_version: String,
}

fn default_schema_version() -> String {
    "1".to_string()
}

/// Reference to a specific step within a Plan.
/// Steps are sub-records of Plan nodes, not standalone nodes.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct PlanRef {
    pub plan_id: NodeId,
    pub step_index: usize,
}

impl Action {
    pub fn new(
        tool: String,
        args: serde_json::Value,
        result_summary: String,
        timestamp: DateTime<Utc>,
        plan_ref: PlanRef,
        parent_ids: Vec<NodeId>,
    ) -> Self {
        let id = NodeId(node_id(&Self::hash_input(
            &tool,
            &args,
            &timestamp,
            &plan_ref,
            &parent_ids,
        )));
        Self {
            id,
            tool,
            args,
            result_summary,
            timestamp,
            plan_ref,
            parent_ids,
            schema_version: default_schema_version(),
        }
    }

    /// result_summary is intentionally excluded — it's an annotation, not identity.
    fn hash_input(
        tool: &str,
        args: &serde_json::Value,
        timestamp: &DateTime<Utc>,
        plan_ref: &PlanRef,
        parent_ids: &[NodeId],
    ) -> serde_json::Value {
        json!({
            "type": "action",
            "tool": tool,
            "args": args,
            "timestamp": timestamp.to_rfc3339(),
            "plan_ref": {
                "plan_id": plan_ref.plan_id.as_str(),
                "step_index": plan_ref.step_index,
            },
            "parent_ids": parent_ids.iter().map(|id| id.as_str()).collect::<Vec<_>>(),
        })
    }
}