harn-vm 0.10.91

Async bytecode virtual machine for the Harn programming language
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

//! Permission-event selection for the portable session-bundle projection.

use serde_json::Value as JsonValue;

use super::BundlePermission;

pub(super) fn collect_permission_events(
    permissions: &mut Vec<BundlePermission>,
    source: &str,
    transcript: &Option<JsonValue>,
) {
    let Some(transcript) = transcript else {
        return;
    };
    for event in transcript
        .get("events")
        .and_then(JsonValue::as_array)
        .into_iter()
        .flatten()
    {
        let kind = event
            .get("type")
            .or_else(|| event.get("kind"))
            .and_then(JsonValue::as_str)
            .unwrap_or_default();
        let normalized_kind = kind.to_ascii_lowercase();
        if normalized_kind.contains("permission")
            || normalized_kind.contains("approval")
            || normalized_kind.starts_with("hitl_")
        {
            permissions.push(permission_from_event(event, source, kind));
        }
    }
}

fn permission_from_event(event: &JsonValue, source: &str, kind: &str) -> BundlePermission {
    let activity = event
        .get("metadata")
        .and_then(|metadata| metadata.get("activity"));
    BundlePermission {
        kind: kind.to_string(),
        source: source.to_string(),
        request_id: activity
            .and_then(|activity| activity.get("request_id"))
            .or_else(|| event.get("request_id"))
            .or_else(|| event.get("id"))
            .and_then(JsonValue::as_str)
            .map(str::to_string),
        agent: activity
            .and_then(|activity| activity.get("requester"))
            .and_then(|requester| requester.get("agent_id"))
            .or_else(|| event.get("agent"))
            .and_then(JsonValue::as_str)
            .map(str::to_string),
        payload: activity.cloned().unwrap_or_else(|| event.clone()),
    }
}