persona-wire-core 0.9.1

persona-wire core: Domain (Graph + Specification + Compute + Constraint + AutoVersion + CRUD) + Application (NamedProjection registry, Use Case) + Infrastructure (SQLite storage, Rendering adapter). Transport-agnostic.
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
84
85
86
87

//! Test fixtures shared across probe unit tests.

#![cfg(test)]

use crate::application::doctor::probe::{FindingSink, Probe, ProbeCtx};
use crate::domain::error::WireResult;
use crate::domain::graph::{ulid_from_seed, Edge, Node};
use crate::infrastructure::storage::SqliteStorage;
use serde_json::{json, Value};

pub fn setup() -> SqliteStorage {
    let s = SqliteStorage::open_in_memory().unwrap();
    s.migrate().unwrap();
    s.seed_default_types().unwrap();
    s
}

pub fn node(id: &str, ty: &str, metadata: Value) -> Node {
    Node {
        id: ulid_from_seed(id),
        name: id.into(),
        r#type: ty.into(),
        sot_ref: None,
        confidence: None,
        applicability: None,
        last_verified_at: None,
        review_due: None,
        version: 1,
        prev_id: None,
        metadata,
    }
}

pub fn persona_node(id: &str, persona: &str) -> Node {
    node(id, "persona", json!({ "persona": persona }))
}

pub fn bare_persona_node(id: &str) -> Node {
    node(id, "persona", json!({}))
}

pub fn edge(id: &str, src: &str, tgt: &str) -> Edge {
    Edge {
        id: ulid_from_seed(id),
        name: Some(id.into()),
        src_node: ulid_from_seed(src),
        tgt_node: ulid_from_seed(tgt),
        kind: "routes_to".into(),
        severity: None,
        metadata: json!({}),
        version: 1,
        prev_id: None,
    }
}

/// Run a probe on the given storage and return all emitted findings.
pub fn scan<P: Probe>(
    probe: &P,
    storage: &SqliteStorage,
    persona: Option<&str>,
) -> WireResult<Vec<crate::application::doctor::finding::Finding>> {
    let ctx = ProbeCtx {
        storage,
        persona_filter: persona.map(|s| s.to_string()),
    };
    let mut sink = FindingSink::new();
    probe.scan(&ctx, &mut sink)?;
    Ok(sink.into_vec())
}

/// Build a workflow_def Node with given trigger/action JSON literals.
pub fn workflow_node(
    id: &str,
    persona: Option<&str>,
    trigger: Value,
    action: Value,
    enabled: bool,
) -> Node {
    let mut meta = serde_json::Map::new();
    if let Some(p) = persona {
        meta.insert("persona".into(), Value::String(p.into()));
    }
    meta.insert("trigger".into(), trigger);
    meta.insert("action".into(), action);
    meta.insert("enabled".into(), Value::Bool(enabled));
    node(id, "workflow_def", Value::Object(meta))
}