ockam_api 0.93.0

Ockam's request-response API
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

use ockam::identity::{Identifier, TimestampInSeconds};
use ockam_core::compat::collections::BTreeMap;
use ockam_core::compat::str::FromStr;
use ockam_core::{Error, Result};
use ockam_node::database::Boolean;

/// Project member stored on the Authority node
#[derive(Debug, Clone, PartialEq, Eq)]
pub struct AuthorityMember {
    identifier: Identifier,
    attributes: BTreeMap<Vec<u8>, Vec<u8>>,
    added_by: Identifier,
    added_at: TimestampInSeconds,
    // Was provided by TrustedIdentities argument during the Authority startup
    // pre-trusted identities can't be deleted using [`MembersStorage::delete_member()`]
    is_pre_trusted: bool,
}

impl AuthorityMember {
    pub fn new(
        identifier: Identifier,
        attributes: BTreeMap<Vec<u8>, Vec<u8>>,
        added_by: Identifier,
        added_at: TimestampInSeconds,
        is_pre_trusted: bool,
    ) -> Self {
        Self {
            identifier,
            attributes,
            added_by,
            added_at,
            is_pre_trusted,
        }
    }
    pub fn identifier(&self) -> &Identifier {
        &self.identifier
    }
    pub fn attributes(&self) -> &BTreeMap<Vec<u8>, Vec<u8>> {
        &self.attributes
    }
    pub fn added_by(&self) -> &Identifier {
        &self.added_by
    }
    pub fn added_at(&self) -> TimestampInSeconds {
        self.added_at
    }
    pub fn is_pre_trusted(&self) -> bool {
        self.is_pre_trusted
    }
}

// Low-level representation of a table row
#[derive(sqlx::FromRow)]
pub(crate) struct AuthorityMemberRow {
    identifier: String,
    added_by: String,
    added_at: i64,
    is_pre_trusted: Boolean,
    attributes: Vec<u8>,
}

impl TryFrom<AuthorityMemberRow> for AuthorityMember {
    type Error = Error;

    fn try_from(value: AuthorityMemberRow) -> Result<Self, Self::Error> {
        let member = AuthorityMember::new(
            Identifier::from_str(&value.identifier)?,
            minicbor::decode(&value.attributes)?,
            Identifier::from_str(&value.added_by)?,
            TimestampInSeconds(value.added_at as u64),
            value.is_pre_trusted.to_bool(),
        );

        Ok(member)
    }
}