brec 0.6.0

A flexible binary format for storing and streaming structured data as packets with CRC protection and recoverability from corruption. Built for extensibility and robustness.
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

use crate::*;
use brec_node_lib::{
    NapiObject, from_napi_object,
    napi::{Env, Unknown, bindgen_prelude::Buffer},
    to_napi_object,
};

impl<B: BlockDef + NapiObject, P: PayloadDef<Inner>, Inner: PayloadInnerDef + NapiObject>
    PacketDef<B, P, Inner>
{
    /// Reads packet bytes and converts to JS object.
    pub fn decode_napi<'env>(
        env: &'env Env,
        bytes: Buffer,
        ctx: &mut <Inner as ProtocolSchema>::Context<'_>,
    ) -> Result<Unknown<'env>, Error> {
        let mut cursor = std::io::Cursor::new(bytes.as_ref());
        let packet = <Self as ReadPacketFrom>::read(&mut cursor, ctx)?;
        Ok(to_napi_object(
            env,
            &packet.blocks,
            packet.payload.as_ref(),
        )?)
    }

    /// Parses JS object packet and encodes into packet bytes.
    pub fn encode_napi(
        env: &Env,
        value: Unknown<'_>,
        out: &mut Vec<u8>,
        ctx: &mut <Inner as ProtocolSchema>::Context<'_>,
    ) -> Result<(), Error> {
        let (blocks, payload) = from_napi_object::<B, Inner>(env, value)?;
        let mut packet = Self::new(blocks, payload);
        packet.write_all(out, ctx)?;
        Ok(())
    }
}