courierust 1.0.0

no_std HTTP and gRPC engine with work-stealing, RFC 9218, and JA3/JA4 fingerprinting.
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

//! Message codec traits for gRPC.
//!
//! Protobuf serialization is deliberately external: implement these
//! traits for your message types (or wrap a codec such as prost) and
//! plug them into [`crate::courierust_grpc::GrpcClient::call_unary`].

use crate::courierust_error::{Error, Result};

/// A message that can be serialized for gRPC transport.
pub trait EncodeMessage {
    /// Serialize to the raw protobuf bytes.
    fn encode_message(&self) -> Result<Vec<u8>>;
}

/// A message that can be deserialized from gRPC transport.
pub trait DecodeMessage: Sized {
    /// Parse from raw protobuf bytes.
    fn decode_message(bytes: &[u8]) -> Result<Self>;
}

/// A pass-through codec for raw bytes (useful for tests and proxies).
pub struct BytesCodec;

impl EncodeMessage for Vec<u8> {
    fn encode_message(&self) -> Result<Vec<u8>> {
        Ok(self.clone())
    }
}

impl DecodeMessage for Vec<u8> {
    fn decode_message(bytes: &[u8]) -> Result<Self> {
        Ok(bytes.to_vec())
    }
}

impl EncodeMessage for String {
    fn encode_message(&self) -> Result<Vec<u8>> {
        Ok(self.as_bytes().to_vec())
    }
}

impl DecodeMessage for String {
    fn decode_message(bytes: &[u8]) -> Result<Self> {
        String::from_utf8(bytes.to_vec()).map_err(|e| Error::protocol(e.to_string()))
    }
}