ockam_core 0.125.0

Core types of the Ockam library.
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

use crate::compat::string::{String, ToString};
use crate::errcode::{Kind, Origin};
use crate::{AddressMetadata, Error, LocalInfoIdentifier, Result, SECURE_CHANNEL_IDENTIFIER};

/// SecureChannel Metadata used for Terminal Address
pub struct SecureChannelMetadata {
    their_identifier: LocalInfoIdentifier,
}

impl SecureChannelMetadata {
    /// Their Identifier
    pub fn their_identifier(&self) -> LocalInfoIdentifier {
        self.their_identifier.clone()
    }
}

impl SecureChannelMetadata {
    #[track_caller]
    fn error_type_id() -> Error {
        Error::new(
            Origin::Identity,
            Kind::Invalid,
            "invalid metadata identifier for secure channel",
        )
    }

    #[track_caller]
    fn error_format() -> Error {
        Error::new(
            Origin::Identity,
            Kind::Invalid,
            "invalid format for metadata identifier for secure channel",
        )
    }

    /// Get the Identifier of the other side of the Secure Channel
    pub fn from_terminal_address_metadata(terminal: &AddressMetadata) -> Result<Self> {
        let identifier = if let Some(identifier) =
            terminal.attributes.iter().find_map(|(key, value)| {
                if key == SECURE_CHANNEL_IDENTIFIER {
                    Some(value.clone())
                } else {
                    None
                }
            }) {
            identifier
        } else {
            return Err(Self::error_type_id());
        };

        if let Ok(identifier) = hex::decode(identifier) {
            match identifier.try_into() {
                Ok(identifier) => Ok(Self {
                    their_identifier: LocalInfoIdentifier(identifier),
                }),
                Err(_) => Err(Self::error_format()),
            }
        } else {
            Err(Self::error_format())
        }
    }

    /// Create an attribute for a Secure Channel given the Identifier of the other side
    pub fn attribute(their_identifier: LocalInfoIdentifier) -> (String, String) {
        (
            SECURE_CHANNEL_IDENTIFIER.to_string(),
            hex::encode(their_identifier.0),
        )
    }
}