perspt-dashboard 0.5.8

Real-time web dashboard for Perspt agent monitoring
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

use super::normalize_state;
use perspt_store::{NodeStateRecord, TaskGraphEdgeRow};

/// View model for the DAG topology page
pub struct DagViewModel {
    pub session_id: String,
    pub nodes: Vec<DagNode>,
    pub edges: Vec<DagEdge>,
}

pub struct DagNode {
    pub node_id: String,
    pub state: String,
    pub v_total: f32,
    pub node_class: String,
    pub goal: String,
    pub attempt_count: i32,
}

pub struct DagEdge {
    pub parent_id: String,
    pub child_id: String,
    pub edge_type: String,
}

impl DagViewModel {
    pub fn from_store(
        session_id: String,
        nodes: Vec<NodeStateRecord>,
        edges: Vec<TaskGraphEdgeRow>,
    ) -> Self {
        let dag_nodes = nodes
            .into_iter()
            .map(|n| DagNode {
                node_id: n.node_id,
                state: normalize_state(&n.state),
                v_total: n.v_total,
                node_class: n.node_class.unwrap_or_default(),
                goal: n.goal.unwrap_or_default(),
                attempt_count: n.attempt_count,
            })
            .collect();

        let dag_edges = edges
            .into_iter()
            .map(|e| DagEdge {
                parent_id: e.parent_node_id,
                child_id: e.child_node_id,
                edge_type: e.edge_type,
            })
            .collect();

        Self {
            session_id,
            nodes: dag_nodes,
            edges: dag_edges,
        }
    }
}