mockforge-world-state 0.3.148

World State Engine - Unified visualization of all MockForge state systems
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

//! State Aggregators - Collect state from various MockForge subsystems
//!
//! Each aggregator is responsible for collecting and transforming state
//! from a specific subsystem into the unified world state model.

pub mod behavior_aggregator;
pub mod lifecycle_aggregator;
pub mod persona_aggregator;
pub mod protocol_aggregator;
pub mod reality_aggregator;
pub mod recorded_aggregator;
pub mod schema_aggregator;
pub mod time_aggregator;

use crate::model::{StateEdge, StateNode};
use async_trait::async_trait;
use std::collections::HashMap;

/// Trait for aggregating state from a subsystem
#[async_trait]
pub trait StateAggregator: Send + Sync {
    /// Aggregate state from the subsystem into nodes and edges
    ///
    /// Returns a tuple of (nodes, edges) that represent the current
    /// state of this subsystem.
    async fn aggregate(&self) -> anyhow::Result<(Vec<StateNode>, Vec<StateEdge>)>;

    /// Get the layer this aggregator belongs to
    fn layer(&self) -> crate::model::StateLayer;

    /// Get metadata about this aggregator
    fn metadata(&self) -> HashMap<String, serde_json::Value> {
        HashMap::new()
    }
}