market2nats 0.1.0

WebSocket market data → NATS JetStream relay
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

pub mod json;
pub mod proto;

use crate::domain::MarketDataEnvelope;

/// Serialization format for market data.
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum SerializationFormat {
    /// Protobuf (compact binary).
    Protobuf,
    /// JSON (human-readable).
    Json,
}

/// Serialization errors.
#[derive(Debug, thiserror::Error)]
pub enum SerializeError {
    #[error("protobuf encode: {0}")]
    Protobuf(#[from] proto::EncodeError),
    #[error("json encode: {0}")]
    Json(#[from] json::EncodeError),
}

/// Serializes a market data envelope in the given format.
///
/// # Errors
///
/// Returns `SerializeError` if encoding fails.
pub fn serialize_envelope(
    envelope: &MarketDataEnvelope,
    format: SerializationFormat,
) -> Result<Vec<u8>, SerializeError> {
    match format {
        SerializationFormat::Protobuf => Ok(proto::encode_envelope(envelope)?),
        SerializationFormat::Json => Ok(json::encode_envelope(envelope)?),
    }
}

/// Returns the Content-Type header value for a given format.
#[must_use]
#[inline]
pub fn content_type(format: SerializationFormat) -> &'static str {
    match format {
        SerializationFormat::Protobuf => "application/protobuf",
        SerializationFormat::Json => "application/json",
    }
}