heddle-object-model 0.15.0

Heddle's content-addressed object model and stable codecs.
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
88
89
90
91
92
93
94

// SPDX-License-Identifier: Apache-2.0

use std::collections::BTreeMap;

use crate::object::{Agent, Principal, State};

#[derive(Clone, Eq, Ord, PartialEq, PartialOrd)]
pub(super) struct PrincipalKey(pub(super) Vec<u8>, pub(super) Vec<u8>);

#[derive(Clone, Eq, Ord, PartialEq, PartialOrd)]
pub(super) struct AgentKey {
    pub(super) provider: Vec<u8>,
    pub(super) model: Vec<u8>,
    pub(super) session_id: Option<Vec<u8>>,
    pub(super) segment_id: Option<Vec<u8>>,
    pub(super) policy_id: Option<Vec<u8>>,
}

pub(super) struct StateDictionaries {
    pub(super) principals: Vec<PrincipalKey>,
    pub(super) agents: Vec<AgentKey>,
    principal_indices: BTreeMap<PrincipalKey, u64>,
    agent_indices: BTreeMap<AgentKey, u64>,
}

impl StateDictionaries {
    pub(super) fn from_states(states: &[State]) -> Self {
        let mut value = Self {
            principals: Vec::new(),
            agents: Vec::new(),
            principal_indices: BTreeMap::new(),
            agent_indices: BTreeMap::new(),
        };
        for state in states {
            value.intern_principal(&state.attribution.principal);
            if let Some(committer) = &state.committer {
                value.intern_principal(committer);
            }
            if let Some(agent) = &state.attribution.agent {
                value.intern_agent(agent);
            }
        }
        value
    }

    pub(super) fn principal_index(&self, principal: &Principal) -> u64 {
        self.principal_indices[&principal_key(principal)]
    }

    pub(super) fn agent_index(&self, agent: &Agent) -> u64 {
        self.agent_indices[&agent_key(agent)]
    }

    fn intern_principal(&mut self, principal: &Principal) {
        let key = principal_key(principal);
        if !self.principal_indices.contains_key(&key) {
            let index = self.principals.len() as u64;
            self.principals.push(key.clone());
            self.principal_indices.insert(key, index);
        }
    }

    fn intern_agent(&mut self, agent: &Agent) {
        let key = agent_key(agent);
        if !self.agent_indices.contains_key(&key) {
            let index = self.agents.len() as u64;
            self.agents.push(key.clone());
            self.agent_indices.insert(key, index);
        }
    }
}

fn principal_key(value: &Principal) -> PrincipalKey {
    PrincipalKey(value.name.clone(), value.email.clone())
}

fn agent_key(value: &Agent) -> AgentKey {
    AgentKey {
        provider: value.provider.as_bytes().to_vec(),
        model: value.model.as_bytes().to_vec(),
        session_id: value
            .session_id
            .as_ref()
            .map(|value| value.as_bytes().to_vec()),
        segment_id: value
            .segment_id
            .as_ref()
            .map(|value| value.as_bytes().to_vec()),
        policy_id: value
            .policy_id
            .as_ref()
            .map(|value| value.as_bytes().to_vec()),
    }
}