keri-core 0.17.13

Core library for the Key Event Receipt Infrastructure
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

use rkyv::{util::AlignedVec, with::With};
use said::SelfAddressingIdentifier;
use said_wrapper::{ArchivedSAIDef, SAIDef};

use crate::{
    event::sections::seal::{ArchivedSourceSeal, SourceSeal},
    event_message::signature::{
        ArchivedNontransferable, ArchivedTransferable, Nontransferable, Transferable,
    },
    prefix::{attached_signature::ArchivedIndexedSignature, IndexedSignature},
    state::IdentifierState,
};

pub(crate) mod said_wrapper;
pub(crate) mod serialization_info_wrapper;

pub fn serialize_said(said: &SelfAddressingIdentifier) -> Result<AlignedVec, rkyv::rancor::Error> {
    Ok(rkyv::to_bytes(
        With::<SelfAddressingIdentifier, SAIDef>::cast(said),
    )?)
}

pub fn deserialize_said(bytes: &[u8]) -> Result<SelfAddressingIdentifier, rkyv::rancor::Error> {
    let archived: &ArchivedSAIDef = rkyv::access(&bytes)?;
    let deserialized: SelfAddressingIdentifier =
        rkyv::deserialize(With::<ArchivedSAIDef, SAIDef>::cast(archived))?;
    Ok(deserialized)
}

pub fn deserialize_nontransferable(bytes: &[u8]) -> Result<Nontransferable, rkyv::rancor::Error> {
    let archived = rkyv::access::<ArchivedNontransferable, rkyv::rancor::Failure>(&bytes).unwrap();
    rkyv::deserialize::<Nontransferable, rkyv::rancor::Error>(archived)
}

pub fn deserialize_transferable(bytes: &[u8]) -> Result<Transferable, rkyv::rancor::Error> {
    let archived = rkyv::access::<ArchivedTransferable, rkyv::rancor::Failure>(&bytes).unwrap();
    rkyv::deserialize::<Transferable, rkyv::rancor::Error>(archived)
}

pub fn deserialize_indexed_signatures(
    bytes: &[u8],
) -> Result<IndexedSignature, rkyv::rancor::Error> {
    let archived = rkyv::access::<ArchivedIndexedSignature, rkyv::rancor::Error>(&bytes).unwrap();
    rkyv::deserialize::<IndexedSignature, rkyv::rancor::Error>(archived)
}

pub fn deserialize_source_seal(bytes: &[u8]) -> Result<SourceSeal, rkyv::rancor::Error> {
    let archived = rkyv::access::<ArchivedSourceSeal, rkyv::rancor::Error>(&bytes).unwrap();
    rkyv::deserialize::<SourceSeal, rkyv::rancor::Error>(archived)
}

pub fn deserialize_identifier_state(bytes: &[u8]) -> Result<IdentifierState, rkyv::rancor::Error> {
    let mut aligned_bytes =
        AlignedVec::<{ std::mem::align_of::<IdentifierState>() }>::with_capacity(bytes.len());
    aligned_bytes.extend_from_slice(bytes);

    rkyv::from_bytes::<IdentifierState, rkyv::rancor::Error>(&aligned_bytes)
}