veilid-core 0.5.3

Core library used to create a Veilid node and operate it as part of an application
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

use super::*;

#[derive(Debug)]
pub(in crate::rpc_processor) struct MessageData {
    contents: Bytes, // rpc messages must be a canonicalized single segment
}

impl MessageData {
    pub fn new(contents: Bytes) -> Self {
        Self { contents }
    }

    pub fn get_reader(
        &self,
    ) -> Result<capnp::message::Reader<capnp::serialize::OwnedSegments>, RPCError> {
        capnp::serialize_packed::read_message(
            self.contents.as_ref(),
            capnp::message::ReaderOptions::new(),
        )
        .map_err(RPCError::protocol)
    }
}

/// RPC Message with only header decoded, data is still encoded
#[derive(Debug)]
pub(in crate::rpc_processor) struct MessageEncoded {
    /// Decoded RPC message header
    pub header: MessageHeader,
    /// Encoded RPCSignedOperation
    pub data: MessageData,
}

/// Fully decoded and validated RPC message
#[derive(Debug)]
pub(in crate::rpc_processor) struct Message {
    /// Decoded RPC message header
    pub header: MessageHeader,
    /// Decoded RPC operation, extracted from RPCSignedOperation
    pub operation: RPCOperation,
    /// Decoded and validated signer, extracted from RPCSignedOperation
    pub opt_signer: Option<PublicKey>,
    /// Sender noderef if this came from a node
    pub opt_sender_nr: Option<NodeRef>,
}