ankurah-core 0.8.0

Core state management functionality for Ankurah
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

use ankurah_proto::{self as proto, Attested, EntityState};
use async_trait::async_trait;

use crate::{policy::PolicyAgent, storage::StorageEngine, Node};

// TODO redesign this such that:
// - the sender and receiver are disconnected at the same time
// - a connection id or dyn Ord/Eq/Hash is used to identify the connection for deregistration
//   so that we can have multiple connections to the same node without things getting mixed up

#[async_trait]
pub trait PeerSender: Send + Sync {
    fn send_message(&self, message: proto::NodeMessage) -> Result<(), SendError>;
    /// The node ID of the recipient of this message
    fn recipient_node_id(&self) -> proto::EntityId;
    fn cloned(&self) -> Box<dyn PeerSender>;
}

#[derive(Debug, thiserror::Error)]
pub enum SendError {
    #[error("Connection closed")]
    ConnectionClosed,
    #[error("Send timeout")]
    Timeout,
    #[error("Other error: {0}")]
    Other(#[from] anyhow::Error),
    #[error("Unknown error")]
    Unknown,
}

#[async_trait]
pub trait NodeComms: Send + Sync {
    fn id(&self) -> proto::EntityId;
    fn durable(&self) -> bool;
    fn system_root(&self) -> Option<Attested<EntityState>>;
    fn register_peer(&self, presence: proto::Presence, sender: Box<dyn PeerSender>);
    fn deregister_peer(&self, node_id: proto::EntityId);
    async fn handle_message(&self, message: proto::NodeMessage) -> anyhow::Result<()>;
    fn cloned(&self) -> Box<dyn NodeComms>;
}

#[async_trait]
impl<SE: StorageEngine + Send + Sync + 'static, PA: PolicyAgent + Send + Sync + 'static> NodeComms for Node<SE, PA> {
    fn id(&self) -> proto::EntityId { self.id }
    fn durable(&self) -> bool { self.durable }
    fn system_root(&self) -> Option<Attested<EntityState>> { self.system.root() }
    fn register_peer(&self, presence: proto::Presence, sender: Box<dyn PeerSender>) {
        //
        self.register_peer(presence, sender);
    }
    fn deregister_peer(&self, node_id: proto::EntityId) {
        //
        self.deregister_peer(node_id);
    }
    async fn handle_message(&self, message: proto::NodeMessage) -> anyhow::Result<()> {
        //
        self.handle_message(message).await
    }
    fn cloned(&self) -> Box<dyn NodeComms> { Box::new(self.clone()) }
}