aa-gateway 0.0.1-beta.1

Control plane — policy enforcement engine and agent registry for Agent Assembly
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

//! Append-only in-memory edge store for the agent-graph mesh model.
//!
//! Mirrors the logical schema of the `agent_graph_edges` table defined in
//! AAASM-980: append-only rows, `created_at DESC` ordering, and secondary
//! indexes on `(source_agent_id, edge_type)` and `(target_agent_id, edge_type)`.

pub mod cycle;
pub mod events;
pub mod repo;
pub mod store;

pub use cycle::detect_cycle;
pub use events::CrossTeamEdgeEvent;
pub use repo::InMemoryEdgeRepo;
pub use store::InMemoryEdgeStore;

use chrono::{DateTime, Utc};

/// The six valid edge type strings, matching the `EdgeType` enum variants that
/// AAASM-985 will introduce. Validated on every insert.
pub const VALID_EDGE_TYPES: &[&str] = &["delegates_to", "calls", "reads", "writes", "approves", "messages"];

/// Error returned when an insert or lookup is given an unrecognised edge type.
#[derive(Debug, thiserror::Error)]
pub enum EdgeStoreError {
    #[error("invalid edge type: {0:?}")]
    InvalidEdgeType(String),
}

/// Input used when inserting a new edge into the store.
#[derive(Debug, Clone)]
pub struct NewEdge {
    /// Raw UUID bytes of the originating agent.
    pub source_agent_id: [u8; 16],
    /// Raw UUID bytes of the target agent.
    pub target_agent_id: [u8; 16],
    /// Relationship kind — must be one of the six `VALID_EDGE_TYPES` strings.
    pub edge_type: String,
    /// Optional structured metadata (e.g. graph name, reason, key names).
    pub metadata: Option<serde_json::Value>,
}

/// A recorded edge between two agents in the topology graph.
#[derive(Debug, Clone)]
pub struct EdgeRecord {
    /// Auto-assigned monotonically increasing identifier.
    pub id: i64,
    /// Raw UUID bytes of the agent that originated the relationship.
    pub source_agent_id: [u8; 16],
    /// Raw UUID bytes of the agent that was the target of the relationship.
    pub target_agent_id: [u8; 16],
    /// Relationship kind — one of the six valid `VALID_EDGE_TYPES` strings.
    pub edge_type: String,
    /// When this edge was recorded.
    pub created_at: DateTime<Utc>,
    /// Optional structured metadata attached at emission time.
    pub metadata: Option<serde_json::Value>,
}