nautilus_serialization/capnp/

conversions.rs

// -------------------------------------------------------------------------------------------------
//  Copyright (C) 2015-2026 Nautech Systems Pty Ltd. All rights reserved.
//  https://nautechsystems.io
//
//  Licensed under the GNU Lesser General Public License Version 3.0 (the "License");
//  You may not use this file except in compliance with the License.
//  You may obtain a copy of the License at https://www.gnu.org/licenses/lgpl-3.0.en.html
//
//  Unless required by applicable law or agreed to in writing, software
//  distributed under the License is distributed on an "AS IS" BASIS,
//  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
//  See the License for the specific language governing permissions and
//  limitations under the License.
// -------------------------------------------------------------------------------------------------

//! Conversion implementations between Nautilus types and Cap'n Proto.

use std::error::Error;

use indexmap::IndexMap;
use nautilus_core::DurationNanos;
use nautilus_model::{
    data::{
        FundingRateUpdate, IndexPriceUpdate, InstrumentClose, InstrumentStatus, MarkPriceUpdate,
        OptionGreekValues, OptionGreeks, QuoteTick, TradeTick,
        bar::{Bar, BarSpecification, BarType},
        delta::OrderBookDelta,
        deltas::OrderBookDeltas,
        depth::OrderBookDepth,
        order::BookOrder,
    },
    enums::{
        AccountType, AggregationSource, AggressorSide, AssetClass, BarAggregation, BookAction,
        BookType, ContingencyType, CurrencyType, GreeksConvention, InstrumentClass,
        InstrumentCloseType, LiquiditySide, MarketStatusAction, OmsType, OptionKind, OrderSide,
        OrderStatus, OrderType, PositionAdjustmentType, PositionSide, PriceType, RecordFlag,
        TimeInForce, TrailingOffsetType, TriggerType,
    },
    events::{
        OrderAccepted, OrderCancelRejected, OrderCanceled, OrderDenied, OrderEmulated,
        OrderExpired, OrderFillVoided, OrderFilled, OrderInitialized, OrderModifyRejected,
        OrderPendingCancel, OrderPendingUpdate, OrderRejected, OrderReleased, OrderSubmitted,
        OrderTriggered, OrderUpdated, PositionAdjusted, PositionChanged, PositionClosed,
        PositionOpened,
    },
    identifiers::{
        AccountId, ActorId, ClientId, ClientOrderId, ComponentId, ExecAlgorithmId, InstrumentId,
        OrderListId, PositionId, StrategyId, Symbol, TradeId, TraderId, Venue, VenueOrderId,
    },
    types::{
        AccountBalance, Currency, MarginBalance, Money, Price, Quantity, money::MoneyRaw,
        price::PriceRaw, quantity::QuantityRaw,
    },
};
use rust_decimal::Decimal;
use ustr::Ustr;
use uuid::Uuid;

use super::{FromCapnp, ToCapnp};
use crate::{
    base_capnp, enums_capnp, identifiers_capnp, market_capnp,
    numeric::{raw_to_wire, wire_to_raw},
    order_capnp, position_capnp, types_capnp,
};

const DECIMAL_FLAGS_RESERVED_MASK: u32 = 0x7F00_FFFF;
const DECIMAL_SCALE_MASK: u32 = 0x00FF_0000;
const DECIMAL_SCALE_SHIFT: u32 = 16;

pub(crate) trait CapnpWriteExt<'a, T>
where
    T: ToCapnp<'a>,
{
    fn write_capnp<F>(&self, init: F)
    where
        F: FnOnce() -> T::Builder;
}

impl<'a, T> CapnpWriteExt<'a, T> for T
where
    T: ToCapnp<'a>,
{
    fn write_capnp<F>(&self, init: F)
    where
        F: FnOnce() -> T::Builder,
    {
        self.to_capnp(init());
    }
}

impl<'a, T> CapnpWriteExt<'a, T> for Option<T>
where
    T: ToCapnp<'a>,
{
    fn write_capnp<F>(&self, init: F)
    where
        F: FnOnce() -> T::Builder,
    {
        if let Some(value) = self {
            value.to_capnp(init());
        }
    }
}

pub(crate) fn read_optional_from_capnp<'a, T, FHas, FGet>(
    has: FHas,
    get: FGet,
) -> Result<Option<T>, Box<dyn Error>>
where
    T: FromCapnp<'a>,
    FHas: FnOnce() -> bool,
    FGet: FnOnce() -> capnp::Result<<T as FromCapnp<'a>>::Reader>,
{
    if has() {
        let reader = get()?;
        Ok(Some(T::from_capnp(reader)?))
    } else {
        Ok(None)
    }
}

fn write_string_map(map: &IndexMap<Ustr, Ustr>, mut builder: base_capnp::string_map::Builder<'_>) {
    let mut entries = builder.reborrow().init_entries(map.len() as u32);
    for (index, (key, value)) in map.iter().enumerate() {
        let mut entry = entries.reborrow().get(index as u32);
        entry.set_key(key.as_str());
        entry.set_value(value.as_str());
    }
}

fn read_string_map(
    reader: base_capnp::string_map::Reader<'_>,
) -> Result<IndexMap<Ustr, Ustr>, Box<dyn Error>> {
    let entries = reader.get_entries()?;
    let mut map = IndexMap::with_capacity(entries.len() as usize);
    for entry in entries {
        map.insert(
            Ustr::from(entry.get_key()?.to_str()?),
            Ustr::from(entry.get_value()?.to_str()?),
        );
    }
    Ok(map)
}

impl<'a> ToCapnp<'a> for nautilus_core::UUID4 {
    type Builder = base_capnp::u_u_i_d4::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        builder.set_value(&self.as_bytes());
    }
}

impl<'a> FromCapnp<'a> for nautilus_core::UUID4 {
    type Reader = base_capnp::u_u_i_d4::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let bytes = reader.get_value()?;
        let bytes_array: [u8; 16] = bytes.try_into().map_err(|_| {
            std::io::Error::new(
                std::io::ErrorKind::InvalidData,
                "Invalid UUID4 bytes length",
            )
        })?;
        let uuid = Uuid::from_bytes(bytes_array);
        Ok(Self::from(uuid))
    }
}

// Decimal
// rust_decimal serialization format (16 bytes):
// - Bytes 0-3: flags (u32) - scale and sign
// - Bytes 4-7: lo (u32) - low 32 bits of coefficient
// - Bytes 8-11: mid (u32) - middle 32 bits of coefficient
// - Bytes 12-15: hi (u32) - high 32 bits of coefficient
fn decimal_to_parts(value: &Decimal) -> (u64, u64, u64, u32) {
    let bytes = value.serialize();
    let flags = u32::from_le_bytes(bytes[0..4].try_into().expect("flags slice"));
    let lo = u32::from_le_bytes(bytes[4..8].try_into().expect("lo slice"));
    let mid = u32::from_le_bytes(bytes[8..12].try_into().expect("mid slice"));
    let hi = u32::from_le_bytes(bytes[12..16].try_into().expect("hi slice"));
    (lo as u64, mid as u64, hi as u64, flags)
}

fn decimal_from_parts(lo: u64, mid: u64, hi: u64, flags: u32) -> Result<Decimal, Box<dyn Error>> {
    if flags & DECIMAL_FLAGS_RESERVED_MASK != 0 {
        return Err("Decimal flags contain unsupported bits".into());
    }

    let scale = (flags & DECIMAL_SCALE_MASK) >> DECIMAL_SCALE_SHIFT;
    if scale > Decimal::MAX_SCALE {
        return Err(format!(
            "Decimal scale exceeds maximum {}, was {scale}",
            Decimal::MAX_SCALE
        )
        .into());
    }

    let lo = u32::try_from(lo).map_err(|_| "Decimal lo limb exceeds u32")?;
    let mid = u32::try_from(mid).map_err(|_| "Decimal mid limb exceeds u32")?;
    let hi = u32::try_from(hi).map_err(|_| "Decimal hi limb exceeds u32")?;

    let mut bytes = [0u8; 16];
    bytes[0..4].copy_from_slice(&flags.to_le_bytes());
    bytes[4..8].copy_from_slice(&lo.to_le_bytes());
    bytes[8..12].copy_from_slice(&mid.to_le_bytes());
    bytes[12..16].copy_from_slice(&hi.to_le_bytes());
    Ok(Decimal::deserialize(bytes))
}

impl<'a> ToCapnp<'a> for Decimal {
    type Builder = types_capnp::decimal::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let (lo, mid, hi, flags) = decimal_to_parts(self);
        builder.set_flags(flags);
        builder.set_lo(lo);
        builder.set_mid(mid);
        builder.set_hi(hi);
    }
}

impl<'a> FromCapnp<'a> for Decimal {
    type Reader = types_capnp::decimal::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let flags = reader.get_flags();
        let lo = reader.get_lo();
        let mid = reader.get_mid();
        let hi = reader.get_hi();
        decimal_from_parts(lo, mid, hi, flags)
    }
}

impl<'a> ToCapnp<'a> for TraderId {
    type Builder = identifiers_capnp::trader_id::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        builder.set_value(self.as_str());
    }
}

impl<'a> FromCapnp<'a> for TraderId {
    type Reader = identifiers_capnp::trader_id::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let value = reader.get_value()?.to_str()?;
        Ok(Self::new_checked(value)?)
    }
}

impl<'a> ToCapnp<'a> for StrategyId {
    type Builder = identifiers_capnp::strategy_id::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        builder.set_value(self.as_str());
    }
}

impl<'a> FromCapnp<'a> for StrategyId {
    type Reader = identifiers_capnp::strategy_id::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let value = reader.get_value()?.to_str()?;
        Ok(Self::new_checked(value)?)
    }
}

impl<'a> ToCapnp<'a> for ActorId {
    type Builder = identifiers_capnp::actor_id::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        builder.set_value(self.as_str());
    }
}

impl<'a> FromCapnp<'a> for ActorId {
    type Reader = identifiers_capnp::actor_id::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let value = reader.get_value()?.to_str()?;
        Ok(Self::new_checked(value)?)
    }
}

impl<'a> ToCapnp<'a> for AccountId {
    type Builder = identifiers_capnp::account_id::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        builder.set_value(self.as_str());
    }
}

impl<'a> FromCapnp<'a> for AccountId {
    type Reader = identifiers_capnp::account_id::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let value = reader.get_value()?.to_str()?;
        Ok(Self::new_checked(value)?)
    }
}

impl<'a> ToCapnp<'a> for ClientId {
    type Builder = identifiers_capnp::client_id::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        builder.set_value(self.as_str());
    }
}

impl<'a> FromCapnp<'a> for ClientId {
    type Reader = identifiers_capnp::client_id::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let value = reader.get_value()?.to_str()?;
        Ok(Self::new_checked(value)?)
    }
}

impl<'a> ToCapnp<'a> for ClientOrderId {
    type Builder = identifiers_capnp::client_order_id::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        builder.set_value(self.as_str());
    }
}

impl<'a> FromCapnp<'a> for ClientOrderId {
    type Reader = identifiers_capnp::client_order_id::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let value = reader.get_value()?.to_str()?;
        Ok(Self::new_checked(value)?)
    }
}

impl<'a> ToCapnp<'a> for VenueOrderId {
    type Builder = identifiers_capnp::venue_order_id::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        builder.set_value(self.as_str());
    }
}

impl<'a> FromCapnp<'a> for VenueOrderId {
    type Reader = identifiers_capnp::venue_order_id::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let value = reader.get_value()?.to_str()?;
        Ok(Self::new_checked(value)?)
    }
}

impl<'a> ToCapnp<'a> for TradeId {
    type Builder = identifiers_capnp::trade_id::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        builder.set_value(self.as_cstr().to_str().expect("Valid UTF-8"));
    }
}

impl<'a> FromCapnp<'a> for TradeId {
    type Reader = identifiers_capnp::trade_id::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let value = reader.get_value()?.to_str()?;
        Ok(Self::new_checked(value)?)
    }
}

impl<'a> ToCapnp<'a> for PositionId {
    type Builder = identifiers_capnp::position_id::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        builder.set_value(self.as_str());
    }
}

impl<'a> FromCapnp<'a> for PositionId {
    type Reader = identifiers_capnp::position_id::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let value = reader.get_value()?.to_str()?;
        Ok(Self::new_checked(value)?)
    }
}

impl<'a> ToCapnp<'a> for ExecAlgorithmId {
    type Builder = identifiers_capnp::exec_algorithm_id::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        builder.set_value(self.as_str());
    }
}

impl<'a> FromCapnp<'a> for ExecAlgorithmId {
    type Reader = identifiers_capnp::exec_algorithm_id::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let value = reader.get_value()?.to_str()?;
        Ok(Self::new_checked(value)?)
    }
}

impl<'a> ToCapnp<'a> for ComponentId {
    type Builder = identifiers_capnp::component_id::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        builder.set_value(self.as_str());
    }
}

impl<'a> FromCapnp<'a> for ComponentId {
    type Reader = identifiers_capnp::component_id::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let value = reader.get_value()?.to_str()?;
        Ok(Self::new_checked(value)?)
    }
}

impl<'a> ToCapnp<'a> for OrderListId {
    type Builder = identifiers_capnp::order_list_id::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        builder.set_value(self.as_str());
    }
}

impl<'a> FromCapnp<'a> for OrderListId {
    type Reader = identifiers_capnp::order_list_id::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let value = reader.get_value()?.to_str()?;
        Ok(Self::new_checked(value)?)
    }
}

impl<'a> ToCapnp<'a> for Symbol {
    type Builder = identifiers_capnp::symbol::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        builder.set_value(self.as_str());
    }
}

impl<'a> FromCapnp<'a> for Symbol {
    type Reader = identifiers_capnp::symbol::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let value = reader.get_value()?.to_str()?;
        Ok(Self::new_checked(value)?)
    }
}

impl<'a> ToCapnp<'a> for Venue {
    type Builder = identifiers_capnp::venue::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        builder.set_value(self.as_str());
    }
}

impl<'a> FromCapnp<'a> for Venue {
    type Reader = identifiers_capnp::venue::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let value = reader.get_value()?.to_str()?;
        Ok(Self::new_checked(value)?)
    }
}

impl<'a> ToCapnp<'a> for InstrumentId {
    type Builder = identifiers_capnp::instrument_id::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        self.symbol.to_capnp(builder.reborrow().init_symbol());
        self.venue.to_capnp(builder.init_venue());
    }
}

impl<'a> FromCapnp<'a> for InstrumentId {
    type Reader = identifiers_capnp::instrument_id::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let symbol = Symbol::from_capnp(reader.get_symbol()?)?;
        let venue = Venue::from_capnp(reader.get_venue()?)?;
        Ok(Self::new(symbol, venue))
    }
}

impl<'a> ToCapnp<'a> for Price {
    type Builder = types_capnp::price::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let raw_i128: i128 = raw_to_wire(self.raw());
        let lo = raw_i128 as u64;
        let hi = (raw_i128 >> 64) as u64;

        let mut raw_builder = builder.reborrow().init_raw();
        raw_builder.set_lo(lo);
        raw_builder.set_hi(hi);

        builder.set_precision(self.precision);
    }
}

impl<'a> FromCapnp<'a> for Price {
    type Reader = types_capnp::price::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let raw_reader = reader.get_raw()?;
        let lo = raw_reader.get_lo();
        let hi = raw_reader.get_hi();
        let precision = reader.get_precision();

        // Reconstruct i128 from two u64 halves with proper sign extension.
        // Casting hi through i64 first ensures the sign bit (MSB of hi) propagates
        // to all upper bits when widened to i128, preserving two's complement.
        let raw_i128 = ((hi as i64 as i128) << 64) | (lo as i128);

        let raw: PriceRaw = wire_to_raw(raw_i128).ok_or_else(|| -> Box<dyn Error> {
            "Price value overflows i64 in standard precision mode".into()
        })?;

        Ok(Self::from_raw_checked(raw, precision)?)
    }
}

impl<'a> ToCapnp<'a> for Quantity {
    type Builder = types_capnp::quantity::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let raw_u128: u128 = raw_to_wire(self.raw());
        let lo = raw_u128 as u64;
        let hi = (raw_u128 >> 64) as u64;

        let mut raw_builder = builder.reborrow().init_raw();
        raw_builder.set_lo(lo);
        raw_builder.set_hi(hi);

        builder.set_precision(self.precision);
    }
}

impl<'a> FromCapnp<'a> for Quantity {
    type Reader = types_capnp::quantity::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let raw_reader = reader.get_raw()?;
        let lo = raw_reader.get_lo();
        let hi = raw_reader.get_hi();
        let precision = reader.get_precision();

        // Reconstruct u128 from two u64 halves (unsigned, no sign extension needed)
        let raw_u128 = ((hi as u128) << 64) | (lo as u128);

        let raw: QuantityRaw = wire_to_raw(raw_u128).ok_or_else(|| -> Box<dyn Error> {
            "Quantity value overflows u64 in standard precision mode".into()
        })?;

        Ok(Self::from_raw_checked(raw, precision)?)
    }
}

#[must_use]
pub fn currency_type_to_capnp(value: CurrencyType) -> enums_capnp::CurrencyType {
    match value {
        CurrencyType::Crypto => enums_capnp::CurrencyType::Crypto,
        CurrencyType::Fiat => enums_capnp::CurrencyType::Fiat,
        CurrencyType::CommodityBacked => enums_capnp::CurrencyType::CommodityBacked,
    }
}

#[must_use]
pub fn currency_type_from_capnp(value: enums_capnp::CurrencyType) -> CurrencyType {
    match value {
        enums_capnp::CurrencyType::Crypto => CurrencyType::Crypto,
        enums_capnp::CurrencyType::Fiat => CurrencyType::Fiat,
        enums_capnp::CurrencyType::CommodityBacked => CurrencyType::CommodityBacked,
    }
}

#[must_use]
pub fn account_type_to_capnp(value: AccountType) -> enums_capnp::AccountType {
    match value {
        AccountType::Cash => enums_capnp::AccountType::Cash,
        AccountType::Margin => enums_capnp::AccountType::Margin,
        AccountType::Betting => enums_capnp::AccountType::Betting,
        AccountType::Wallet => enums_capnp::AccountType::Wallet,
    }
}

#[must_use]
pub fn account_type_from_capnp(value: enums_capnp::AccountType) -> AccountType {
    match value {
        enums_capnp::AccountType::Cash => AccountType::Cash,
        enums_capnp::AccountType::Margin => AccountType::Margin,
        enums_capnp::AccountType::Betting => AccountType::Betting,
        enums_capnp::AccountType::Wallet => AccountType::Wallet,
    }
}

#[must_use]
pub fn aggressor_side_to_capnp(value: AggressorSide) -> enums_capnp::AggressorSide {
    match value {
        AggressorSide::NoAggressor => enums_capnp::AggressorSide::NoAggressor,
        AggressorSide::Buy => enums_capnp::AggressorSide::Buy,
        AggressorSide::Sell => enums_capnp::AggressorSide::Sell,
    }
}

#[must_use]
pub fn aggressor_side_from_capnp(value: enums_capnp::AggressorSide) -> AggressorSide {
    match value {
        enums_capnp::AggressorSide::NoAggressor => AggressorSide::NoAggressor,
        enums_capnp::AggressorSide::Buy => AggressorSide::Buy,
        enums_capnp::AggressorSide::Sell => AggressorSide::Sell,
    }
}

#[must_use]
pub fn asset_class_to_capnp(value: AssetClass) -> enums_capnp::AssetClass {
    match value {
        AssetClass::FX => enums_capnp::AssetClass::Fx,
        AssetClass::Equity => enums_capnp::AssetClass::Equity,
        AssetClass::Commodity => enums_capnp::AssetClass::Commodity,
        AssetClass::Debt => enums_capnp::AssetClass::Debt,
        AssetClass::Index => enums_capnp::AssetClass::Index,
        AssetClass::Cryptocurrency => enums_capnp::AssetClass::Cryptocurrency,
        AssetClass::Alternative => enums_capnp::AssetClass::Alternative,
    }
}

#[must_use]
pub fn asset_class_from_capnp(value: enums_capnp::AssetClass) -> AssetClass {
    match value {
        enums_capnp::AssetClass::Fx => AssetClass::FX,
        enums_capnp::AssetClass::Equity => AssetClass::Equity,
        enums_capnp::AssetClass::Commodity => AssetClass::Commodity,
        enums_capnp::AssetClass::Debt => AssetClass::Debt,
        enums_capnp::AssetClass::Index => AssetClass::Index,
        enums_capnp::AssetClass::Cryptocurrency => AssetClass::Cryptocurrency,
        enums_capnp::AssetClass::Alternative => AssetClass::Alternative,
    }
}

#[must_use]
pub fn instrument_class_to_capnp(value: InstrumentClass) -> enums_capnp::InstrumentClass {
    match value {
        InstrumentClass::Spot => enums_capnp::InstrumentClass::Spot,
        InstrumentClass::Swap => enums_capnp::InstrumentClass::Swap,
        InstrumentClass::Future => enums_capnp::InstrumentClass::Future,
        InstrumentClass::FuturesSpread => enums_capnp::InstrumentClass::FuturesSpread,
        InstrumentClass::Forward => enums_capnp::InstrumentClass::Forward,
        InstrumentClass::Cfd => enums_capnp::InstrumentClass::Cfd,
        InstrumentClass::Bond => enums_capnp::InstrumentClass::Bond,
        InstrumentClass::Option => enums_capnp::InstrumentClass::Option,
        InstrumentClass::OptionSpread => enums_capnp::InstrumentClass::OptionSpread,
        InstrumentClass::Warrant => enums_capnp::InstrumentClass::Warrant,
        InstrumentClass::SportsBetting => enums_capnp::InstrumentClass::SportsBetting,
        InstrumentClass::BinaryOption => enums_capnp::InstrumentClass::BinaryOption,
    }
}

#[must_use]
pub fn instrument_class_from_capnp(value: enums_capnp::InstrumentClass) -> InstrumentClass {
    match value {
        enums_capnp::InstrumentClass::Spot => InstrumentClass::Spot,
        enums_capnp::InstrumentClass::Swap => InstrumentClass::Swap,
        enums_capnp::InstrumentClass::Future => InstrumentClass::Future,
        enums_capnp::InstrumentClass::FuturesSpread => InstrumentClass::FuturesSpread,
        enums_capnp::InstrumentClass::Forward => InstrumentClass::Forward,
        enums_capnp::InstrumentClass::Cfd => InstrumentClass::Cfd,
        enums_capnp::InstrumentClass::Bond => InstrumentClass::Bond,
        enums_capnp::InstrumentClass::Option => InstrumentClass::Option,
        enums_capnp::InstrumentClass::OptionSpread => InstrumentClass::OptionSpread,
        enums_capnp::InstrumentClass::Warrant => InstrumentClass::Warrant,
        enums_capnp::InstrumentClass::SportsBetting => InstrumentClass::SportsBetting,
        enums_capnp::InstrumentClass::BinaryOption => InstrumentClass::BinaryOption,
    }
}

#[must_use]
pub fn option_kind_to_capnp(value: OptionKind) -> enums_capnp::OptionKind {
    match value {
        OptionKind::Call => enums_capnp::OptionKind::Call,
        OptionKind::Put => enums_capnp::OptionKind::Put,
    }
}

#[must_use]
pub fn option_kind_from_capnp(value: enums_capnp::OptionKind) -> OptionKind {
    match value {
        enums_capnp::OptionKind::Call => OptionKind::Call,
        enums_capnp::OptionKind::Put => OptionKind::Put,
    }
}

#[must_use]
pub fn greeks_convention_to_capnp(value: GreeksConvention) -> enums_capnp::GreeksConvention {
    match value {
        GreeksConvention::BlackScholes => enums_capnp::GreeksConvention::BlackScholes,
        GreeksConvention::PriceAdjusted => enums_capnp::GreeksConvention::PriceAdjusted,
    }
}

#[must_use]
pub fn greeks_convention_from_capnp(value: enums_capnp::GreeksConvention) -> GreeksConvention {
    match value {
        enums_capnp::GreeksConvention::BlackScholes => GreeksConvention::BlackScholes,
        enums_capnp::GreeksConvention::PriceAdjusted => GreeksConvention::PriceAdjusted,
    }
}

#[must_use]
pub fn order_side_to_capnp(value: Option<OrderSide>) -> enums_capnp::OrderSide {
    match value {
        None => enums_capnp::OrderSide::NoOrderSide,
        Some(OrderSide::Buy) => enums_capnp::OrderSide::Buy,
        Some(OrderSide::Sell) => enums_capnp::OrderSide::Sell,
    }
}

#[must_use]
pub fn order_side_from_capnp(value: enums_capnp::OrderSide) -> Option<OrderSide> {
    match value {
        enums_capnp::OrderSide::NoOrderSide => None,
        enums_capnp::OrderSide::Buy => Some(OrderSide::Buy),
        enums_capnp::OrderSide::Sell => Some(OrderSide::Sell),
    }
}

fn order_side_required_from_capnp(
    value: enums_capnp::OrderSide,
) -> Result<OrderSide, Box<dyn Error>> {
    order_side_from_capnp(value)
        .ok_or_else(|| "Cap'n Proto required order side was NO_ORDER_SIDE".into())
}

#[must_use]
pub fn order_type_to_capnp(value: OrderType) -> enums_capnp::OrderType {
    match value {
        OrderType::Market => enums_capnp::OrderType::Market,
        OrderType::Limit => enums_capnp::OrderType::Limit,
        OrderType::StopMarket => enums_capnp::OrderType::StopMarket,
        OrderType::StopLimit => enums_capnp::OrderType::StopLimit,
        OrderType::MarketToLimit => enums_capnp::OrderType::MarketToLimit,
        OrderType::MarketIfTouched => enums_capnp::OrderType::MarketIfTouched,
        OrderType::LimitIfTouched => enums_capnp::OrderType::LimitIfTouched,
        OrderType::TrailingStopMarket => enums_capnp::OrderType::TrailingStopMarket,
        OrderType::TrailingStopLimit => enums_capnp::OrderType::TrailingStopLimit,
    }
}

#[must_use]
pub fn order_type_from_capnp(value: enums_capnp::OrderType) -> OrderType {
    match value {
        enums_capnp::OrderType::Market => OrderType::Market,
        enums_capnp::OrderType::Limit => OrderType::Limit,
        enums_capnp::OrderType::StopMarket => OrderType::StopMarket,
        enums_capnp::OrderType::StopLimit => OrderType::StopLimit,
        enums_capnp::OrderType::MarketToLimit => OrderType::MarketToLimit,
        enums_capnp::OrderType::MarketIfTouched => OrderType::MarketIfTouched,
        enums_capnp::OrderType::LimitIfTouched => OrderType::LimitIfTouched,
        enums_capnp::OrderType::TrailingStopMarket => OrderType::TrailingStopMarket,
        enums_capnp::OrderType::TrailingStopLimit => OrderType::TrailingStopLimit,
    }
}

#[must_use]
pub fn order_status_to_capnp(value: OrderStatus) -> enums_capnp::OrderStatus {
    match value {
        OrderStatus::Initialized => enums_capnp::OrderStatus::Initialized,
        OrderStatus::Denied => enums_capnp::OrderStatus::Denied,
        OrderStatus::Emulated => enums_capnp::OrderStatus::Emulated,
        OrderStatus::Released => enums_capnp::OrderStatus::Released,
        OrderStatus::Submitted => enums_capnp::OrderStatus::Submitted,
        OrderStatus::Accepted => enums_capnp::OrderStatus::Accepted,
        OrderStatus::Rejected => enums_capnp::OrderStatus::Rejected,
        OrderStatus::Canceled => enums_capnp::OrderStatus::Canceled,
        OrderStatus::Expired => enums_capnp::OrderStatus::Expired,
        OrderStatus::Triggered => enums_capnp::OrderStatus::Triggered,
        OrderStatus::PendingUpdate => enums_capnp::OrderStatus::PendingUpdate,
        OrderStatus::PendingCancel => enums_capnp::OrderStatus::PendingCancel,
        OrderStatus::PartiallyFilled => enums_capnp::OrderStatus::PartiallyFilled,
        OrderStatus::Filled => enums_capnp::OrderStatus::Filled,
        OrderStatus::Voided => enums_capnp::OrderStatus::Voided,
    }
}

#[must_use]
pub fn order_status_from_capnp(value: enums_capnp::OrderStatus) -> OrderStatus {
    match value {
        enums_capnp::OrderStatus::Initialized => OrderStatus::Initialized,
        enums_capnp::OrderStatus::Denied => OrderStatus::Denied,
        enums_capnp::OrderStatus::Emulated => OrderStatus::Emulated,
        enums_capnp::OrderStatus::Released => OrderStatus::Released,
        enums_capnp::OrderStatus::Submitted => OrderStatus::Submitted,
        enums_capnp::OrderStatus::Accepted => OrderStatus::Accepted,
        enums_capnp::OrderStatus::Rejected => OrderStatus::Rejected,
        enums_capnp::OrderStatus::Canceled => OrderStatus::Canceled,
        enums_capnp::OrderStatus::Expired => OrderStatus::Expired,
        enums_capnp::OrderStatus::Triggered => OrderStatus::Triggered,
        enums_capnp::OrderStatus::PendingUpdate => OrderStatus::PendingUpdate,
        enums_capnp::OrderStatus::PendingCancel => OrderStatus::PendingCancel,
        enums_capnp::OrderStatus::PartiallyFilled => OrderStatus::PartiallyFilled,
        enums_capnp::OrderStatus::Filled => OrderStatus::Filled,
        enums_capnp::OrderStatus::Voided => OrderStatus::Voided,
    }
}

#[must_use]
pub fn time_in_force_to_capnp(value: TimeInForce) -> enums_capnp::TimeInForce {
    match value {
        TimeInForce::Gtc => enums_capnp::TimeInForce::Gtc,
        TimeInForce::Ioc => enums_capnp::TimeInForce::Ioc,
        TimeInForce::Fok => enums_capnp::TimeInForce::Fok,
        TimeInForce::Gtd => enums_capnp::TimeInForce::Gtd,
        TimeInForce::Day => enums_capnp::TimeInForce::Day,
        TimeInForce::AtTheOpen => enums_capnp::TimeInForce::AtTheOpen,
        TimeInForce::AtTheClose => enums_capnp::TimeInForce::AtTheClose,
    }
}

#[must_use]
pub fn time_in_force_from_capnp(value: enums_capnp::TimeInForce) -> TimeInForce {
    match value {
        enums_capnp::TimeInForce::Gtc => TimeInForce::Gtc,
        enums_capnp::TimeInForce::Ioc => TimeInForce::Ioc,
        enums_capnp::TimeInForce::Fok => TimeInForce::Fok,
        enums_capnp::TimeInForce::Gtd => TimeInForce::Gtd,
        enums_capnp::TimeInForce::Day => TimeInForce::Day,
        enums_capnp::TimeInForce::AtTheOpen => TimeInForce::AtTheOpen,
        enums_capnp::TimeInForce::AtTheClose => TimeInForce::AtTheClose,
    }
}

#[must_use]
pub fn trigger_type_to_capnp(value: Option<TriggerType>) -> enums_capnp::TriggerType {
    match value {
        None => enums_capnp::TriggerType::NoTrigger,
        Some(TriggerType::Default) => enums_capnp::TriggerType::Default,
        Some(TriggerType::LastPrice) => enums_capnp::TriggerType::LastPrice,
        Some(TriggerType::MarkPrice) => enums_capnp::TriggerType::MarkPrice,
        Some(TriggerType::IndexPrice) => enums_capnp::TriggerType::IndexPrice,
        Some(TriggerType::BidAsk) => enums_capnp::TriggerType::BidAsk,
        Some(TriggerType::DoubleLast) => enums_capnp::TriggerType::DoubleLast,
        Some(TriggerType::DoubleBidAsk) => enums_capnp::TriggerType::DoubleBidAsk,
        Some(TriggerType::LastOrBidAsk) => enums_capnp::TriggerType::LastOrBidAsk,
        Some(TriggerType::MidPoint) => enums_capnp::TriggerType::MidPoint,
    }
}

#[must_use]
pub fn trigger_type_from_capnp(value: enums_capnp::TriggerType) -> Option<TriggerType> {
    match value {
        enums_capnp::TriggerType::NoTrigger => None,
        enums_capnp::TriggerType::Default => Some(TriggerType::Default),
        enums_capnp::TriggerType::LastPrice => Some(TriggerType::LastPrice),
        enums_capnp::TriggerType::MarkPrice => Some(TriggerType::MarkPrice),
        enums_capnp::TriggerType::IndexPrice => Some(TriggerType::IndexPrice),
        enums_capnp::TriggerType::BidAsk => Some(TriggerType::BidAsk),
        enums_capnp::TriggerType::DoubleLast => Some(TriggerType::DoubleLast),
        enums_capnp::TriggerType::DoubleBidAsk => Some(TriggerType::DoubleBidAsk),
        enums_capnp::TriggerType::LastOrBidAsk => Some(TriggerType::LastOrBidAsk),
        enums_capnp::TriggerType::MidPoint => Some(TriggerType::MidPoint),
    }
}

#[must_use]
pub fn contingency_type_to_capnp(value: Option<ContingencyType>) -> enums_capnp::ContingencyType {
    match value {
        None => enums_capnp::ContingencyType::NoContingency,
        Some(ContingencyType::Oco) => enums_capnp::ContingencyType::Oco,
        Some(ContingencyType::Oto) => enums_capnp::ContingencyType::Oto,
        Some(ContingencyType::Ouo) => enums_capnp::ContingencyType::Ouo,
    }
}

#[must_use]
pub fn contingency_type_from_capnp(value: enums_capnp::ContingencyType) -> Option<ContingencyType> {
    match value {
        enums_capnp::ContingencyType::NoContingency => None,
        enums_capnp::ContingencyType::Oco => Some(ContingencyType::Oco),
        enums_capnp::ContingencyType::Oto => Some(ContingencyType::Oto),
        enums_capnp::ContingencyType::Ouo => Some(ContingencyType::Ouo),
    }
}

#[must_use]
pub fn position_side_to_capnp(value: Option<PositionSide>) -> enums_capnp::PositionSide {
    match value {
        None => enums_capnp::PositionSide::NoPositionSide,
        Some(PositionSide::Flat) => enums_capnp::PositionSide::Flat,
        Some(PositionSide::Long) => enums_capnp::PositionSide::Long,
        Some(PositionSide::Short) => enums_capnp::PositionSide::Short,
    }
}

#[must_use]
pub fn position_side_from_capnp(value: enums_capnp::PositionSide) -> Option<PositionSide> {
    match value {
        enums_capnp::PositionSide::NoPositionSide => None,
        enums_capnp::PositionSide::Flat => Some(PositionSide::Flat),
        enums_capnp::PositionSide::Long => Some(PositionSide::Long),
        enums_capnp::PositionSide::Short => Some(PositionSide::Short),
    }
}

fn position_side_required_from_capnp(
    value: enums_capnp::PositionSide,
) -> Result<PositionSide, Box<dyn Error>> {
    position_side_from_capnp(value)
        .ok_or_else(|| "Cap'n Proto required position side was NO_POSITION_SIDE".into())
}

#[must_use]
pub fn position_adjustment_type_to_capnp(
    value: PositionAdjustmentType,
) -> enums_capnp::PositionAdjustmentType {
    match value {
        PositionAdjustmentType::Commission => enums_capnp::PositionAdjustmentType::Commission,
        PositionAdjustmentType::Funding => enums_capnp::PositionAdjustmentType::Funding,
    }
}

#[must_use]
pub fn position_adjustment_type_from_capnp(
    value: enums_capnp::PositionAdjustmentType,
) -> PositionAdjustmentType {
    match value {
        enums_capnp::PositionAdjustmentType::Commission => PositionAdjustmentType::Commission,
        enums_capnp::PositionAdjustmentType::Funding => PositionAdjustmentType::Funding,
    }
}

#[must_use]
pub fn liquidity_side_to_capnp(value: LiquiditySide) -> enums_capnp::LiquiditySide {
    match value {
        LiquiditySide::NoLiquiditySide => enums_capnp::LiquiditySide::NoLiquiditySide,
        LiquiditySide::Maker => enums_capnp::LiquiditySide::Maker,
        LiquiditySide::Taker => enums_capnp::LiquiditySide::Taker,
    }
}

#[must_use]
pub fn liquidity_side_from_capnp(value: enums_capnp::LiquiditySide) -> LiquiditySide {
    match value {
        enums_capnp::LiquiditySide::NoLiquiditySide => LiquiditySide::NoLiquiditySide,
        enums_capnp::LiquiditySide::Maker => LiquiditySide::Maker,
        enums_capnp::LiquiditySide::Taker => LiquiditySide::Taker,
    }
}

#[must_use]
pub fn book_action_to_capnp(value: BookAction) -> enums_capnp::BookAction {
    match value {
        BookAction::Add => enums_capnp::BookAction::Add,
        BookAction::Update => enums_capnp::BookAction::Update,
        BookAction::Delete => enums_capnp::BookAction::Delete,
        BookAction::Clear => enums_capnp::BookAction::Clear,
    }
}

#[must_use]
pub fn book_action_from_capnp(value: enums_capnp::BookAction) -> BookAction {
    match value {
        enums_capnp::BookAction::Add => BookAction::Add,
        enums_capnp::BookAction::Update => BookAction::Update,
        enums_capnp::BookAction::Delete => BookAction::Delete,
        enums_capnp::BookAction::Clear => BookAction::Clear,
    }
}

#[must_use]
pub fn book_type_to_capnp(value: BookType) -> enums_capnp::BookType {
    match value {
        BookType::L1_MBP => enums_capnp::BookType::TopOfBookBidOffer,
        BookType::L2_MBP => enums_capnp::BookType::MarketByPrice,
        BookType::L3_MBO => enums_capnp::BookType::MarketByOrder,
    }
}

#[must_use]
pub fn book_type_from_capnp(value: enums_capnp::BookType) -> BookType {
    match value {
        enums_capnp::BookType::TopOfBookBidOffer => BookType::L1_MBP,
        enums_capnp::BookType::MarketByPrice => BookType::L2_MBP,
        enums_capnp::BookType::MarketByOrder => BookType::L3_MBO,
    }
}

#[must_use]
pub fn record_flag_to_capnp(value: RecordFlag) -> enums_capnp::RecordFlag {
    match value {
        RecordFlag::F_LAST => enums_capnp::RecordFlag::FLast,
        RecordFlag::F_TOB => enums_capnp::RecordFlag::FTob,
        RecordFlag::F_SNAPSHOT => enums_capnp::RecordFlag::FSnapshot,
        RecordFlag::F_MBP => enums_capnp::RecordFlag::FMbp,
        RecordFlag::RESERVED_2 => enums_capnp::RecordFlag::Reserved2,
        RecordFlag::RESERVED_1 => enums_capnp::RecordFlag::Reserved1,
    }
}

#[must_use]
pub fn record_flag_from_capnp(value: enums_capnp::RecordFlag) -> RecordFlag {
    match value {
        enums_capnp::RecordFlag::FLast => RecordFlag::F_LAST,
        enums_capnp::RecordFlag::FTob => RecordFlag::F_TOB,
        enums_capnp::RecordFlag::FSnapshot => RecordFlag::F_SNAPSHOT,
        enums_capnp::RecordFlag::FMbp => RecordFlag::F_MBP,
        enums_capnp::RecordFlag::Reserved2 => RecordFlag::RESERVED_2,
        enums_capnp::RecordFlag::Reserved1 => RecordFlag::RESERVED_1,
    }
}

#[must_use]
pub fn aggregation_source_to_capnp(value: AggregationSource) -> enums_capnp::AggregationSource {
    match value {
        AggregationSource::External => enums_capnp::AggregationSource::External,
        AggregationSource::Internal => enums_capnp::AggregationSource::Internal,
    }
}

#[must_use]
pub fn aggregation_source_from_capnp(value: enums_capnp::AggregationSource) -> AggregationSource {
    match value {
        enums_capnp::AggregationSource::External => AggregationSource::External,
        enums_capnp::AggregationSource::Internal => AggregationSource::Internal,
    }
}

#[must_use]
pub fn price_type_to_capnp(value: PriceType) -> enums_capnp::PriceType {
    match value {
        PriceType::Bid => enums_capnp::PriceType::Bid,
        PriceType::Ask => enums_capnp::PriceType::Ask,
        PriceType::Mid => enums_capnp::PriceType::Mid,
        PriceType::Last => enums_capnp::PriceType::Last,
        PriceType::Mark => enums_capnp::PriceType::Mark,
    }
}

#[must_use]
pub fn price_type_from_capnp(value: enums_capnp::PriceType) -> PriceType {
    match value {
        enums_capnp::PriceType::Bid => PriceType::Bid,
        enums_capnp::PriceType::Ask => PriceType::Ask,
        enums_capnp::PriceType::Mid => PriceType::Mid,
        enums_capnp::PriceType::Last => PriceType::Last,
        enums_capnp::PriceType::Mark => PriceType::Mark,
    }
}

#[must_use]
pub fn bar_aggregation_to_capnp(value: BarAggregation) -> enums_capnp::BarAggregation {
    match value {
        BarAggregation::Tick => enums_capnp::BarAggregation::Tick,
        BarAggregation::TickImbalance => enums_capnp::BarAggregation::TickImbalance,
        BarAggregation::TickRuns => enums_capnp::BarAggregation::TickRuns,
        BarAggregation::Volume => enums_capnp::BarAggregation::Volume,
        BarAggregation::VolumeImbalance => enums_capnp::BarAggregation::VolumeImbalance,
        BarAggregation::VolumeRuns => enums_capnp::BarAggregation::VolumeRuns,
        BarAggregation::Value => enums_capnp::BarAggregation::Value,
        BarAggregation::ValueImbalance => enums_capnp::BarAggregation::ValueImbalance,
        BarAggregation::ValueRuns => enums_capnp::BarAggregation::ValueRuns,
        BarAggregation::Millisecond => enums_capnp::BarAggregation::Millisecond,
        BarAggregation::Second => enums_capnp::BarAggregation::Second,
        BarAggregation::Minute => enums_capnp::BarAggregation::Minute,
        BarAggregation::Hour => enums_capnp::BarAggregation::Hour,
        BarAggregation::Day => enums_capnp::BarAggregation::Day,
        BarAggregation::Week => enums_capnp::BarAggregation::Week,
        BarAggregation::Month => enums_capnp::BarAggregation::Month,
        BarAggregation::Year => enums_capnp::BarAggregation::Year,
        BarAggregation::Renko => enums_capnp::BarAggregation::Renko,
    }
}

#[must_use]
pub fn bar_aggregation_from_capnp(value: enums_capnp::BarAggregation) -> BarAggregation {
    match value {
        enums_capnp::BarAggregation::Tick => BarAggregation::Tick,
        enums_capnp::BarAggregation::TickImbalance => BarAggregation::TickImbalance,
        enums_capnp::BarAggregation::TickRuns => BarAggregation::TickRuns,
        enums_capnp::BarAggregation::Volume => BarAggregation::Volume,
        enums_capnp::BarAggregation::VolumeImbalance => BarAggregation::VolumeImbalance,
        enums_capnp::BarAggregation::VolumeRuns => BarAggregation::VolumeRuns,
        enums_capnp::BarAggregation::Value => BarAggregation::Value,
        enums_capnp::BarAggregation::ValueImbalance => BarAggregation::ValueImbalance,
        enums_capnp::BarAggregation::ValueRuns => BarAggregation::ValueRuns,
        enums_capnp::BarAggregation::Millisecond => BarAggregation::Millisecond,
        enums_capnp::BarAggregation::Second => BarAggregation::Second,
        enums_capnp::BarAggregation::Minute => BarAggregation::Minute,
        enums_capnp::BarAggregation::Hour => BarAggregation::Hour,
        enums_capnp::BarAggregation::Day => BarAggregation::Day,
        enums_capnp::BarAggregation::Week => BarAggregation::Week,
        enums_capnp::BarAggregation::Month => BarAggregation::Month,
        enums_capnp::BarAggregation::Year => BarAggregation::Year,
        enums_capnp::BarAggregation::Renko => BarAggregation::Renko,
    }
}

#[must_use]
pub fn trailing_offset_type_to_capnp(
    value: Option<TrailingOffsetType>,
) -> enums_capnp::TrailingOffsetType {
    match value {
        None => enums_capnp::TrailingOffsetType::NoTrailingOffset,
        Some(TrailingOffsetType::Price) => enums_capnp::TrailingOffsetType::Price,
        Some(TrailingOffsetType::BasisPoints) => enums_capnp::TrailingOffsetType::BasisPoints,
        Some(TrailingOffsetType::Ticks) => enums_capnp::TrailingOffsetType::Ticks,
        Some(TrailingOffsetType::PriceTier) => enums_capnp::TrailingOffsetType::PriceTier,
    }
}

#[must_use]
pub fn trailing_offset_type_from_capnp(
    value: enums_capnp::TrailingOffsetType,
) -> Option<TrailingOffsetType> {
    match value {
        enums_capnp::TrailingOffsetType::NoTrailingOffset => None,
        enums_capnp::TrailingOffsetType::Price => Some(TrailingOffsetType::Price),
        enums_capnp::TrailingOffsetType::BasisPoints => Some(TrailingOffsetType::BasisPoints),
        enums_capnp::TrailingOffsetType::Ticks => Some(TrailingOffsetType::Ticks),
        enums_capnp::TrailingOffsetType::PriceTier => Some(TrailingOffsetType::PriceTier),
    }
}

#[must_use]
pub fn oms_type_to_capnp(value: OmsType) -> enums_capnp::OmsType {
    match value {
        OmsType::Unspecified => enums_capnp::OmsType::Unspecified,
        OmsType::Netting => enums_capnp::OmsType::Netting,
        OmsType::Hedging => enums_capnp::OmsType::Hedging,
    }
}

#[must_use]
pub fn oms_type_from_capnp(value: enums_capnp::OmsType) -> OmsType {
    match value {
        enums_capnp::OmsType::Unspecified => OmsType::Unspecified,
        enums_capnp::OmsType::Netting => OmsType::Netting,
        enums_capnp::OmsType::Hedging => OmsType::Hedging,
    }
}

#[must_use]
pub fn instrument_close_type_to_capnp(
    value: InstrumentCloseType,
) -> enums_capnp::InstrumentCloseType {
    match value {
        InstrumentCloseType::EndOfSession => enums_capnp::InstrumentCloseType::EndOfSession,
        InstrumentCloseType::ContractExpired => enums_capnp::InstrumentCloseType::ContractExpired,
    }
}

#[must_use]
pub fn instrument_close_type_from_capnp(
    value: enums_capnp::InstrumentCloseType,
) -> InstrumentCloseType {
    match value {
        enums_capnp::InstrumentCloseType::EndOfSession => InstrumentCloseType::EndOfSession,
        enums_capnp::InstrumentCloseType::ContractExpired => InstrumentCloseType::ContractExpired,
    }
}

#[must_use]
#[rustfmt::skip]
pub fn market_status_action_to_capnp(value: MarketStatusAction) -> enums_capnp::MarketStatusAction {
    match value {
        MarketStatusAction::None => enums_capnp::MarketStatusAction::None,
        MarketStatusAction::PreOpen => enums_capnp::MarketStatusAction::PreOpen,
        MarketStatusAction::PreCross => enums_capnp::MarketStatusAction::PreCross,
        MarketStatusAction::Quoting => enums_capnp::MarketStatusAction::Quoting,
        MarketStatusAction::Cross => enums_capnp::MarketStatusAction::Cross,
        MarketStatusAction::Rotation => enums_capnp::MarketStatusAction::Rotation,
        MarketStatusAction::NewPriceIndication => enums_capnp::MarketStatusAction::NewPriceIndication,
        MarketStatusAction::Trading => enums_capnp::MarketStatusAction::Trading,
        MarketStatusAction::Halt => enums_capnp::MarketStatusAction::Halt,
        MarketStatusAction::Pause => enums_capnp::MarketStatusAction::Pause,
        MarketStatusAction::Suspend => enums_capnp::MarketStatusAction::Suspend,
        MarketStatusAction::PreClose => enums_capnp::MarketStatusAction::PreClose,
        MarketStatusAction::Close => enums_capnp::MarketStatusAction::Close,
        MarketStatusAction::PostClose => enums_capnp::MarketStatusAction::PostClose,
        MarketStatusAction::ShortSellRestrictionChange => enums_capnp::MarketStatusAction::ShortSellRestrictionChange,
        MarketStatusAction::NotAvailableForTrading => enums_capnp::MarketStatusAction::NotAvailableForTrading,
    }
}

#[must_use]
#[rustfmt::skip]
pub fn market_status_action_from_capnp(
    value: enums_capnp::MarketStatusAction,
) -> MarketStatusAction {
    match value {
        enums_capnp::MarketStatusAction::None => MarketStatusAction::None,
        enums_capnp::MarketStatusAction::PreOpen => MarketStatusAction::PreOpen,
        enums_capnp::MarketStatusAction::PreCross => MarketStatusAction::PreCross,
        enums_capnp::MarketStatusAction::Quoting => MarketStatusAction::Quoting,
        enums_capnp::MarketStatusAction::Cross => MarketStatusAction::Cross,
        enums_capnp::MarketStatusAction::Rotation => MarketStatusAction::Rotation,
        enums_capnp::MarketStatusAction::NewPriceIndication => MarketStatusAction::NewPriceIndication,
        enums_capnp::MarketStatusAction::Trading => MarketStatusAction::Trading,
        enums_capnp::MarketStatusAction::Halt => MarketStatusAction::Halt,
        enums_capnp::MarketStatusAction::Pause => MarketStatusAction::Pause,
        enums_capnp::MarketStatusAction::Suspend => MarketStatusAction::Suspend,
        enums_capnp::MarketStatusAction::PreClose => MarketStatusAction::PreClose,
        enums_capnp::MarketStatusAction::Close => MarketStatusAction::Close,
        enums_capnp::MarketStatusAction::PostClose => MarketStatusAction::PostClose,
        enums_capnp::MarketStatusAction::ShortSellRestrictionChange => MarketStatusAction::ShortSellRestrictionChange,
        enums_capnp::MarketStatusAction::NotAvailableForTrading => MarketStatusAction::NotAvailableForTrading,
    }
}

#[must_use]
pub fn optional_bool_to_capnp(value: Option<bool>) -> enums_capnp::OptionalBool {
    match value {
        None => enums_capnp::OptionalBool::Unknown,
        Some(true) => enums_capnp::OptionalBool::True,
        Some(false) => enums_capnp::OptionalBool::False,
    }
}

#[must_use]
pub fn optional_bool_from_capnp(value: enums_capnp::OptionalBool) -> Option<bool> {
    match value {
        enums_capnp::OptionalBool::Unknown => None,
        enums_capnp::OptionalBool::True => Some(true),
        enums_capnp::OptionalBool::False => Some(false),
    }
}

impl<'a> ToCapnp<'a> for Currency {
    type Builder = types_capnp::currency::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        builder.set_code(self.code);
        builder.set_precision(self.precision);
        builder.set_iso4217(self.iso4217);
        builder.set_name(self.name);
        builder.set_currency_type(currency_type_to_capnp(self.currency_type));
    }
}

impl<'a> FromCapnp<'a> for Currency {
    type Reader = types_capnp::currency::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let code = reader.get_code()?.to_str()?;
        let precision = reader.get_precision();
        let iso4217 = reader.get_iso4217();
        let name = reader.get_name()?.to_str()?;
        let currency_type = currency_type_from_capnp(reader.get_currency_type()?);

        Ok(Self::new_checked(
            code,
            precision,
            iso4217,
            name,
            currency_type,
        )?)
    }
}

impl<'a> ToCapnp<'a> for Money {
    type Builder = types_capnp::money::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let mut raw_builder = builder.reborrow().init_raw();

        let raw_i128: i128 = raw_to_wire(self.raw());
        raw_builder.set_lo(raw_i128 as u64);
        raw_builder.set_hi((raw_i128 >> 64) as u64);

        let currency_builder = builder.init_currency();
        self.currency.to_capnp(currency_builder);
    }
}

impl<'a> FromCapnp<'a> for Money {
    type Reader = types_capnp::money::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let raw_reader = reader.get_raw()?;
        let lo = raw_reader.get_lo();
        let hi = raw_reader.get_hi();

        // Cast through i64 to sign-extend and preserve two's complement for negative values
        let raw_i128 = ((hi as i64 as i128) << 64) | (lo as i128);

        let currency_reader = reader.get_currency()?;
        let currency = Currency::from_capnp(currency_reader)?;

        let raw: MoneyRaw = wire_to_raw(raw_i128).ok_or_else(|| -> Box<dyn Error> {
            "Money value overflows i64 in standard precision mode".into()
        })?;

        Ok(Self::from_raw(raw, currency))
    }
}

impl<'a> ToCapnp<'a> for AccountBalance {
    type Builder = types_capnp::account_balance::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let total_builder = builder.reborrow().init_total();
        self.total.to_capnp(total_builder);

        let locked_builder = builder.reborrow().init_locked();
        self.locked.to_capnp(locked_builder);

        let free_builder = builder.init_free();
        self.free.to_capnp(free_builder);
    }
}

impl<'a> FromCapnp<'a> for AccountBalance {
    type Reader = types_capnp::account_balance::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let total_reader = reader.get_total()?;
        let total = Money::from_capnp(total_reader)?;

        let locked_reader = reader.get_locked()?;
        let locked = Money::from_capnp(locked_reader)?;

        let free_reader = reader.get_free()?;
        let free = Money::from_capnp(free_reader)?;

        Ok(Self::new_checked(total, locked, free)?)
    }
}

impl<'a> ToCapnp<'a> for MarginBalance {
    type Builder = types_capnp::margin_balance::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let initial_builder = builder.reborrow().init_initial();
        self.initial.to_capnp(initial_builder);

        let maintenance_builder = builder.reborrow().init_maintenance();
        self.maintenance.to_capnp(maintenance_builder);

        // An unset pointer represents an account-wide cross-margin balance
        self.instrument_id.write_capnp(|| builder.init_instrument());
    }
}

impl<'a> FromCapnp<'a> for MarginBalance {
    type Reader = types_capnp::margin_balance::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let initial_reader = reader.get_initial()?;
        let initial = Money::from_capnp(initial_reader)?;

        let maintenance_reader = reader.get_maintenance()?;
        let maintenance = Money::from_capnp(maintenance_reader)?;

        let instrument_id =
            read_optional_from_capnp(|| reader.has_instrument(), || reader.get_instrument())?;

        Ok(Self::new_checked(initial, maintenance, instrument_id)?)
    }
}

/// Serializes an [`InstrumentId`] to Cap'n Proto bytes.
///
/// # Errors
///
/// Returns an error if Cap'n Proto serialization fails.
pub fn serialize_instrument_id(id: &InstrumentId) -> Result<Vec<u8>, Box<dyn Error>> {
    let mut message = capnp::message::Builder::new_default();
    let builder = message.init_root::<identifiers_capnp::instrument_id::Builder>();
    id.to_capnp(builder);

    let mut bytes = Vec::new();
    capnp::serialize::write_message(&mut bytes, &message)?;
    Ok(bytes)
}

/// Deserializes an [`InstrumentId`] from Cap'n Proto bytes.
///
/// # Errors
///
/// Returns an error if Cap'n Proto deserialization fails.
pub fn deserialize_instrument_id(bytes: &[u8]) -> Result<InstrumentId, Box<dyn Error>> {
    let reader =
        capnp::serialize::read_message(&mut &bytes[..], capnp::message::ReaderOptions::new())?;
    let root = reader.get_root::<identifiers_capnp::instrument_id::Reader>()?;
    InstrumentId::from_capnp(root)
}

/// Serializes a [`Price`] to Cap'n Proto bytes.
///
/// # Errors
///
/// Returns an error if Cap'n Proto serialization fails.
pub fn serialize_price(price: &Price) -> Result<Vec<u8>, Box<dyn Error>> {
    let mut message = capnp::message::Builder::new_default();
    let builder = message.init_root::<types_capnp::price::Builder>();
    price.to_capnp(builder);

    let mut bytes = Vec::new();
    capnp::serialize::write_message(&mut bytes, &message)?;
    Ok(bytes)
}

/// Deserializes a [`Price`] from Cap'n Proto bytes.
///
/// # Errors
///
/// Returns an error if Cap'n Proto deserialization fails.
pub fn deserialize_price(bytes: &[u8]) -> Result<Price, Box<dyn Error>> {
    let reader =
        capnp::serialize::read_message(&mut &bytes[..], capnp::message::ReaderOptions::new())?;
    let root = reader.get_root::<types_capnp::price::Reader>()?;
    Price::from_capnp(root)
}

/// Serializes a [`Quantity`] to Cap'n Proto bytes.
///
/// # Errors
///
/// Returns an error if Cap'n Proto serialization fails.
pub fn serialize_quantity(qty: &Quantity) -> Result<Vec<u8>, Box<dyn Error>> {
    let mut message = capnp::message::Builder::new_default();
    let builder = message.init_root::<types_capnp::quantity::Builder>();
    qty.to_capnp(builder);

    let mut bytes = Vec::new();
    capnp::serialize::write_message(&mut bytes, &message)?;
    Ok(bytes)
}

/// Deserializes a [`Quantity`] from Cap'n Proto bytes.
///
/// # Errors
///
/// Returns an error if Cap'n Proto deserialization fails.
pub fn deserialize_quantity(bytes: &[u8]) -> Result<Quantity, Box<dyn Error>> {
    let reader =
        capnp::serialize::read_message(&mut &bytes[..], capnp::message::ReaderOptions::new())?;
    let root = reader.get_root::<types_capnp::quantity::Reader>()?;
    Quantity::from_capnp(root)
}

/// Serializes a [`Currency`] to Cap'n Proto bytes.
///
/// # Errors
///
/// Returns an error if Cap'n Proto serialization fails.
pub fn serialize_currency(currency: &Currency) -> Result<Vec<u8>, Box<dyn Error>> {
    let mut message = capnp::message::Builder::new_default();
    let builder = message.init_root::<types_capnp::currency::Builder>();
    currency.to_capnp(builder);

    let mut bytes = Vec::new();
    capnp::serialize::write_message(&mut bytes, &message)?;
    Ok(bytes)
}

/// Deserializes a [`Currency`] from Cap'n Proto bytes.
///
/// # Errors
///
/// Returns an error if Cap'n Proto deserialization fails.
pub fn deserialize_currency(bytes: &[u8]) -> Result<Currency, Box<dyn Error>> {
    let reader =
        capnp::serialize::read_message(&mut &bytes[..], capnp::message::ReaderOptions::new())?;
    let root = reader.get_root::<types_capnp::currency::Reader>()?;
    Currency::from_capnp(root)
}

/// Serializes a [`Money`] to Cap'n Proto bytes.
///
/// # Errors
///
/// Returns an error if Cap'n Proto serialization fails.
pub fn serialize_money(money: &Money) -> Result<Vec<u8>, Box<dyn Error>> {
    let mut message = capnp::message::Builder::new_default();
    let builder = message.init_root::<types_capnp::money::Builder>();
    money.to_capnp(builder);

    let mut bytes = Vec::new();
    capnp::serialize::write_message(&mut bytes, &message)?;
    Ok(bytes)
}

/// Deserializes a [`Money`] from Cap'n Proto bytes.
///
/// # Errors
///
/// Returns an error if Cap'n Proto deserialization fails.
pub fn deserialize_money(bytes: &[u8]) -> Result<Money, Box<dyn Error>> {
    let reader =
        capnp::serialize::read_message(&mut &bytes[..], capnp::message::ReaderOptions::new())?;
    let root = reader.get_root::<types_capnp::money::Reader>()?;
    Money::from_capnp(root)
}

/// Serializes an [`AccountBalance`] to Cap'n Proto bytes.
///
/// # Errors
///
/// Returns an error if Cap'n Proto serialization fails.
pub fn serialize_account_balance(balance: &AccountBalance) -> Result<Vec<u8>, Box<dyn Error>> {
    let mut message = capnp::message::Builder::new_default();
    let builder = message.init_root::<types_capnp::account_balance::Builder>();
    balance.to_capnp(builder);

    let mut bytes = Vec::new();
    capnp::serialize::write_message(&mut bytes, &message)?;
    Ok(bytes)
}

/// Deserializes an [`AccountBalance`] from Cap'n Proto bytes.
///
/// # Errors
///
/// Returns an error if Cap'n Proto deserialization fails.
pub fn deserialize_account_balance(bytes: &[u8]) -> Result<AccountBalance, Box<dyn Error>> {
    let reader =
        capnp::serialize::read_message(&mut &bytes[..], capnp::message::ReaderOptions::new())?;
    let root = reader.get_root::<types_capnp::account_balance::Reader>()?;
    AccountBalance::from_capnp(root)
}

/// Serializes a [`MarginBalance`] to Cap'n Proto bytes.
///
/// # Errors
///
/// Returns an error if Cap'n Proto serialization fails.
pub fn serialize_margin_balance(balance: &MarginBalance) -> Result<Vec<u8>, Box<dyn Error>> {
    let mut message = capnp::message::Builder::new_default();
    let builder = message.init_root::<types_capnp::margin_balance::Builder>();
    balance.to_capnp(builder);

    let mut bytes = Vec::new();
    capnp::serialize::write_message(&mut bytes, &message)?;
    Ok(bytes)
}

/// Deserializes a [`MarginBalance`] from Cap'n Proto bytes.
///
/// # Errors
///
/// Returns an error if Cap'n Proto deserialization fails.
pub fn deserialize_margin_balance(bytes: &[u8]) -> Result<MarginBalance, Box<dyn Error>> {
    let reader =
        capnp::serialize::read_message(&mut &bytes[..], capnp::message::ReaderOptions::new())?;
    let root = reader.get_root::<types_capnp::margin_balance::Reader>()?;
    MarginBalance::from_capnp(root)
}

impl<'a> ToCapnp<'a> for QuoteTick {
    type Builder = market_capnp::quote_tick::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let bid_price_builder = builder.reborrow().init_bid_price();
        self.bid_price.to_capnp(bid_price_builder);

        let ask_price_builder = builder.reborrow().init_ask_price();
        self.ask_price.to_capnp(ask_price_builder);

        let bid_size_builder = builder.reborrow().init_bid_size();
        self.bid_size.to_capnp(bid_size_builder);

        let ask_size_builder = builder.reborrow().init_ask_size();
        self.ask_size.to_capnp(ask_size_builder);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);
    }
}

impl<'a> FromCapnp<'a> for QuoteTick {
    type Reader = market_capnp::quote_tick::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let bid_price_reader = reader.get_bid_price()?;
        let bid_price = Price::from_capnp(bid_price_reader)?;

        let ask_price_reader = reader.get_ask_price()?;
        let ask_price = Price::from_capnp(ask_price_reader)?;

        let bid_size_reader = reader.get_bid_size()?;
        let bid_size = Quantity::from_capnp(bid_size_reader)?;

        let ask_size_reader = reader.get_ask_size()?;
        let ask_size = Quantity::from_capnp(ask_size_reader)?;

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        Ok(Self {
            instrument_id,
            bid_price,
            ask_price,
            bid_size,
            ask_size,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
        })
    }
}

impl<'a> ToCapnp<'a> for TradeTick {
    type Builder = market_capnp::trade_tick::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let price_builder = builder.reborrow().init_price();
        self.price.to_capnp(price_builder);

        let size_builder = builder.reborrow().init_size();
        self.size.to_capnp(size_builder);

        builder.set_aggressor_side(aggressor_side_to_capnp(self.aggressor_side));

        let trade_id_builder = builder.reborrow().init_trade_id();
        self.trade_id.to_capnp(trade_id_builder);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);
    }
}

impl<'a> FromCapnp<'a> for TradeTick {
    type Reader = market_capnp::trade_tick::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let price_reader = reader.get_price()?;
        let price = Price::from_capnp(price_reader)?;

        let size_reader = reader.get_size()?;
        let size = Quantity::from_capnp(size_reader)?;

        let aggressor_side = aggressor_side_from_capnp(reader.get_aggressor_side()?);

        let trade_id_reader = reader.get_trade_id()?;
        let trade_id = TradeId::from_capnp(trade_id_reader)?;

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        Ok(Self {
            instrument_id,
            price,
            size,
            aggressor_side,
            trade_id,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
        })
    }
}

impl<'a> ToCapnp<'a> for MarkPriceUpdate {
    type Builder = market_capnp::mark_price_update::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let mark_price_builder = builder.reborrow().init_mark_price();
        self.value.to_capnp(mark_price_builder);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);
    }
}

impl<'a> FromCapnp<'a> for MarkPriceUpdate {
    type Reader = market_capnp::mark_price_update::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let mark_price_reader = reader.get_mark_price()?;
        let value = Price::from_capnp(mark_price_reader)?;

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        Ok(Self {
            instrument_id,
            value,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
        })
    }
}

impl<'a> ToCapnp<'a> for IndexPriceUpdate {
    type Builder = market_capnp::index_price_update::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let index_price_builder = builder.reborrow().init_index_price();
        self.value.to_capnp(index_price_builder);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);
    }
}

impl<'a> FromCapnp<'a> for IndexPriceUpdate {
    type Reader = market_capnp::index_price_update::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let index_price_reader = reader.get_index_price()?;
        let value = Price::from_capnp(index_price_reader)?;

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        Ok(Self {
            instrument_id,
            value,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
        })
    }
}

impl<'a> ToCapnp<'a> for FundingRateUpdate {
    type Builder = market_capnp::funding_rate_update::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let rate_builder = builder.reborrow().init_rate();
        self.rate.to_capnp(rate_builder);

        if let Some(interval) = self.interval {
            builder.reborrow().set_interval(interval);
            builder.reborrow().set_has_interval(true);
        }

        if let Some(next_funding_ns) = self.next_funding_ns {
            let mut next_funding_time_builder = builder.reborrow().init_next_funding_time();
            next_funding_time_builder.set_value(*next_funding_ns);
        }

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);
    }
}

impl<'a> FromCapnp<'a> for FundingRateUpdate {
    type Reader = market_capnp::funding_rate_update::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let rate_reader = reader.get_rate()?;
        let rate = Decimal::from_capnp(rate_reader)?;

        let interval = if reader.get_has_interval() {
            Some(reader.get_interval())
        } else {
            None
        };

        let next_funding_ns = if reader.has_next_funding_time() {
            let next_funding_time_reader = reader.get_next_funding_time()?;
            Some(next_funding_time_reader.get_value().into())
        } else {
            None
        };

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        Ok(Self {
            instrument_id,
            rate,
            interval,
            next_funding_ns,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
        })
    }
}

impl<'a> ToCapnp<'a> for OptionGreeks {
    type Builder = market_capnp::option_greeks::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        builder.set_convention(greeks_convention_to_capnp(self.convention));
        builder.set_delta(self.greeks.delta);
        builder.set_gamma(self.greeks.gamma);
        builder.set_vega(self.greeks.vega);
        builder.set_theta(self.greeks.theta);
        builder.set_rho(self.greeks.rho);

        if let Some(mark_iv) = self.mark_iv {
            builder.reborrow().set_mark_iv(mark_iv);
            builder.reborrow().set_has_mark_iv(true);
        }

        if let Some(bid_iv) = self.bid_iv {
            builder.reborrow().set_bid_iv(bid_iv);
            builder.reborrow().set_has_bid_iv(true);
        }

        if let Some(ask_iv) = self.ask_iv {
            builder.reborrow().set_ask_iv(ask_iv);
            builder.reborrow().set_has_ask_iv(true);
        }

        if let Some(underlying_price) = self.underlying_price {
            builder.reborrow().set_underlying_price(underlying_price);
            builder.reborrow().set_has_underlying_price(true);
        }

        if let Some(open_interest) = self.open_interest {
            builder.reborrow().set_open_interest(open_interest);
            builder.reborrow().set_has_open_interest(true);
        }

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);
    }
}

impl<'a> FromCapnp<'a> for OptionGreeks {
    type Reader = market_capnp::option_greeks::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;
        let convention = greeks_convention_from_capnp(reader.get_convention()?);
        let greeks = OptionGreekValues {
            delta: reader.get_delta(),
            gamma: reader.get_gamma(),
            vega: reader.get_vega(),
            theta: reader.get_theta(),
            rho: reader.get_rho(),
        };
        let mark_iv = reader.get_has_mark_iv().then_some(reader.get_mark_iv());
        let bid_iv = reader.get_has_bid_iv().then_some(reader.get_bid_iv());
        let ask_iv = reader.get_has_ask_iv().then_some(reader.get_ask_iv());
        let underlying_price = reader
            .get_has_underlying_price()
            .then_some(reader.get_underlying_price());
        let open_interest = reader
            .get_has_open_interest()
            .then_some(reader.get_open_interest());

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        Ok(Self {
            instrument_id,
            convention,
            greeks,
            mark_iv,
            bid_iv,
            ask_iv,
            underlying_price,
            open_interest,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
        })
    }
}

impl<'a> ToCapnp<'a> for InstrumentClose {
    type Builder = market_capnp::instrument_close::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let close_price_builder = builder.reborrow().init_close_price();
        self.close_price.to_capnp(close_price_builder);

        builder.set_close_type(instrument_close_type_to_capnp(self.close_type));

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);
    }
}

impl<'a> FromCapnp<'a> for InstrumentClose {
    type Reader = market_capnp::instrument_close::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let close_price_reader = reader.get_close_price()?;
        let close_price = Price::from_capnp(close_price_reader)?;

        let close_type = instrument_close_type_from_capnp(reader.get_close_type()?);

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        Ok(Self {
            instrument_id,
            close_price,
            close_type,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
        })
    }
}

impl<'a> ToCapnp<'a> for InstrumentStatus {
    type Builder = market_capnp::instrument_status::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        builder.set_action(market_status_action_to_capnp(self.action));

        if let Some(reason) = self.reason {
            builder.reborrow().set_reason(reason.as_str());
        }

        if let Some(trading_event) = self.trading_event {
            builder.reborrow().set_trading_event(trading_event.as_str());
        }

        builder.set_is_trading(optional_bool_to_capnp(self.is_trading));
        builder.set_is_quoting(optional_bool_to_capnp(self.is_quoting));
        builder.set_is_short_sell_restricted(optional_bool_to_capnp(self.is_short_sell_restricted));

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);
    }
}

impl<'a> FromCapnp<'a> for InstrumentStatus {
    type Reader = market_capnp::instrument_status::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let action = market_status_action_from_capnp(reader.get_action()?);

        let reason = if reader.has_reason() {
            Some(Ustr::from(reader.get_reason()?.to_str()?))
        } else {
            None
        };

        let trading_event = if reader.has_trading_event() {
            Some(Ustr::from(reader.get_trading_event()?.to_str()?))
        } else {
            None
        };

        let is_trading = optional_bool_from_capnp(reader.get_is_trading()?);
        let is_quoting = optional_bool_from_capnp(reader.get_is_quoting()?);
        let is_short_sell_restricted =
            optional_bool_from_capnp(reader.get_is_short_sell_restricted()?);

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        Ok(Self {
            instrument_id,
            action,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
            reason,
            trading_event,
            is_trading,
            is_quoting,
            is_short_sell_restricted,
        })
    }
}

impl<'a> ToCapnp<'a> for BarSpecification {
    type Builder = market_capnp::bar_spec::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        builder.set_step(self.step.get() as u64);
        builder.set_aggregation(bar_aggregation_to_capnp(self.aggregation));
        builder.set_price_type(price_type_to_capnp(self.price_type));
    }
}

impl<'a> FromCapnp<'a> for BarSpecification {
    type Reader = market_capnp::bar_spec::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        use std::num::NonZero;

        let step = usize::try_from(reader.get_step())
            .map_err(|_| "BarSpecification step exceeds usize range")?;
        let step = NonZero::new(step).ok_or("BarSpecification step must be non-zero")?;

        let aggregation = bar_aggregation_from_capnp(reader.get_aggregation()?);
        let price_type = price_type_from_capnp(reader.get_price_type()?);

        Ok(Self {
            step,
            aggregation,
            price_type,
        })
    }
}

impl<'a> ToCapnp<'a> for BarType {
    type Builder = market_capnp::bar_type::Builder<'a>;

    /// Encodes the standard form only: the composite chain is a local aggregation
    /// detail and wire representations carry the standard bar type.
    fn to_capnp(&self, mut builder: Self::Builder) {
        let standard = self.standard();
        let instrument_id_builder = builder.reborrow().init_instrument_id();
        standard.instrument_id().to_capnp(instrument_id_builder);

        let spec_builder = builder.reborrow().init_spec();
        standard.spec().to_capnp(spec_builder);

        builder.set_aggregation_source(aggregation_source_to_capnp(standard.aggregation_source()));
    }
}

impl<'a> FromCapnp<'a> for BarType {
    type Reader = market_capnp::bar_type::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let spec_reader = reader.get_spec()?;
        let spec = BarSpecification::from_capnp(spec_reader)?;

        let aggregation_source = aggregation_source_from_capnp(reader.get_aggregation_source()?);

        Ok(Self::new(instrument_id, spec, aggregation_source))
    }
}

impl<'a> ToCapnp<'a> for Bar {
    type Builder = market_capnp::bar::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let bar_type_builder = builder.reborrow().init_bar_type();
        self.bar_type.to_capnp(bar_type_builder);

        let open_builder = builder.reborrow().init_open();
        self.open.to_capnp(open_builder);

        let high_builder = builder.reborrow().init_high();
        self.high.to_capnp(high_builder);

        let low_builder = builder.reborrow().init_low();
        self.low.to_capnp(low_builder);

        let close_builder = builder.reborrow().init_close();
        self.close.to_capnp(close_builder);

        let volume_builder = builder.reborrow().init_volume();
        self.volume.to_capnp(volume_builder);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);
    }
}

impl<'a> FromCapnp<'a> for Bar {
    type Reader = market_capnp::bar::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let bar_type_reader = reader.get_bar_type()?;
        let bar_type = BarType::from_capnp(bar_type_reader)?;

        let open_reader = reader.get_open()?;
        let open = Price::from_capnp(open_reader)?;

        let high_reader = reader.get_high()?;
        let high = Price::from_capnp(high_reader)?;

        let low_reader = reader.get_low()?;
        let low = Price::from_capnp(low_reader)?;

        let close_reader = reader.get_close()?;
        let close = Price::from_capnp(close_reader)?;

        let volume_reader = reader.get_volume()?;
        let volume = Quantity::from_capnp(volume_reader)?;

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        Ok(Self {
            bar_type,
            open,
            high,
            low,
            close,
            volume,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
        })
    }
}

impl<'a> ToCapnp<'a> for BookOrder {
    type Builder = market_capnp::book_order::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let price_builder = builder.reborrow().init_price();
        self.price.to_capnp(price_builder);

        let size_builder = builder.reborrow().init_size();
        self.size.to_capnp(size_builder);

        builder.set_side(order_side_to_capnp(self.side));
        builder.set_order_id(self.order_id);
    }
}

impl<'a> FromCapnp<'a> for BookOrder {
    type Reader = market_capnp::book_order::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let price_reader = reader.get_price()?;
        let price = Price::from_capnp(price_reader)?;

        let size_reader = reader.get_size()?;
        let size = Quantity::from_capnp(size_reader)?;

        let side = order_side_from_capnp(reader.get_side()?);
        let order_id = reader.get_order_id();

        Ok(Self {
            side,
            price,
            size,
            order_id,
        })
    }
}

impl<'a> ToCapnp<'a> for OrderBookDelta {
    type Builder = market_capnp::order_book_delta::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        builder.set_action(book_action_to_capnp(self.action));

        let order_builder = builder.reborrow().init_order();
        self.order.to_capnp(order_builder);

        builder.set_flags(self.flags);
        builder.set_sequence(self.sequence);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);
    }
}

impl<'a> FromCapnp<'a> for OrderBookDelta {
    type Reader = market_capnp::order_book_delta::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let action = book_action_from_capnp(reader.get_action()?);

        let order_reader = reader.get_order()?;
        let order = BookOrder::from_capnp(order_reader)?;

        let flags = reader.get_flags();
        let sequence = reader.get_sequence();

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        Ok(Self {
            instrument_id,
            action,
            order,
            flags,
            sequence,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
        })
    }
}

impl<'a> ToCapnp<'a> for OrderBookDeltas {
    type Builder = market_capnp::order_book_deltas::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let mut deltas_builder = builder.reborrow().init_deltas(self.deltas.len() as u32);
        for (i, delta) in self.deltas.iter().enumerate() {
            let entry_builder = deltas_builder.reborrow().get(i as u32);
            delta.to_capnp(entry_builder);
        }

        builder.set_flags(self.flags);
        builder.set_sequence(self.sequence);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);
    }
}

impl<'a> FromCapnp<'a> for OrderBookDeltas {
    type Reader = market_capnp::order_book_deltas::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let deltas_reader = reader.get_deltas()?;
        let mut deltas = Vec::with_capacity(deltas_reader.len() as usize);
        for delta_reader in deltas_reader {
            let delta = OrderBookDelta::from_capnp(delta_reader)?;
            deltas.push(delta);
        }

        let flags = reader.get_flags();
        let sequence = reader.get_sequence();

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        Ok(Self {
            instrument_id,
            deltas,
            flags,
            sequence,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
        })
    }
}

impl<'a> ToCapnp<'a> for OrderBookDepth {
    type Builder = market_capnp::order_book_depth::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        // Convert bids (BookOrder array to BookLevel list)
        let mut bids_builder = builder.reborrow().init_bids(self.bids.len() as u32);
        for (i, bid) in self.bids.iter().enumerate() {
            let mut level_builder = bids_builder.reborrow().get(i as u32);
            let price_builder = level_builder.reborrow().init_price();
            bid.price.to_capnp(price_builder);
            let size_builder = level_builder.init_size();
            bid.size.to_capnp(size_builder);
        }

        // Convert asks (BookOrder array to BookLevel list)
        let mut asks_builder = builder.reborrow().init_asks(self.asks.len() as u32);
        for (i, ask) in self.asks.iter().enumerate() {
            let mut level_builder = asks_builder.reborrow().get(i as u32);
            let price_builder = level_builder.reborrow().init_price();
            ask.price.to_capnp(price_builder);
            let size_builder = level_builder.init_size();
            ask.size.to_capnp(size_builder);
        }

        // Convert counts
        let mut bid_counts_builder = builder
            .reborrow()
            .init_bid_counts(self.bid_counts.len() as u32);
        for (i, &count) in self.bid_counts.iter().enumerate() {
            bid_counts_builder.set(i as u32, count);
        }

        let mut ask_counts_builder = builder
            .reborrow()
            .init_ask_counts(self.ask_counts.len() as u32);
        for (i, &count) in self.ask_counts.iter().enumerate() {
            ask_counts_builder.set(i as u32, count);
        }

        builder.set_flags(self.flags);
        builder.set_sequence(self.sequence);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);
    }
}

impl<'a> FromCapnp<'a> for OrderBookDepth {
    type Reader = market_capnp::order_book_depth::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        // The Capnp lists retain the snapshot length.
        let bids_reader = reader.get_bids()?;
        let mut bids = Vec::with_capacity(bids_reader.len() as usize);

        for level_reader in bids_reader {
            let price_reader = level_reader.get_price()?;
            let price = Price::from_capnp(price_reader)?;

            let size_reader = level_reader.get_size()?;
            let size = Quantity::from_capnp(size_reader)?;

            bids.push(BookOrder::new(OrderSide::Buy, price, size, 0));
        }

        let asks_reader = reader.get_asks()?;
        let mut asks = Vec::with_capacity(asks_reader.len() as usize);

        for level_reader in asks_reader {
            let price_reader = level_reader.get_price()?;
            let price = Price::from_capnp(price_reader)?;

            let size_reader = level_reader.get_size()?;
            let size = Quantity::from_capnp(size_reader)?;

            asks.push(BookOrder::new(OrderSide::Sell, price, size, 0));
        }

        let bid_counts = reader.get_bid_counts()?.iter().collect::<Vec<_>>();
        let ask_counts = reader.get_ask_counts()?.iter().collect::<Vec<_>>();

        let flags = reader.get_flags();
        let sequence = reader.get_sequence();

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        Ok(Self::new_checked(
            instrument_id,
            bids,
            asks,
            bid_counts,
            ask_counts,
            flags,
            sequence,
            ts_event.into(),
            ts_init.into(),
        )?)
    }
}

impl<'a> ToCapnp<'a> for OrderDenied {
    type Builder = order_capnp::order_denied::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let trader_id_builder = builder.reborrow().init_trader_id();
        self.trader_id.to_capnp(trader_id_builder);

        let strategy_id_builder = builder.reborrow().init_strategy_id();
        self.strategy_id.to_capnp(strategy_id_builder);

        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let client_order_id_builder = builder.reborrow().init_client_order_id();
        self.client_order_id.to_capnp(client_order_id_builder);

        builder.set_reason(self.reason.as_str());

        let event_id_builder = builder.reborrow().init_event_id();
        self.event_id.to_capnp(event_id_builder);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);
    }
}

impl<'a> FromCapnp<'a> for OrderDenied {
    type Reader = order_capnp::order_denied::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let trader_id_reader = reader.get_trader_id()?;
        let trader_id = TraderId::from_capnp(trader_id_reader)?;

        let strategy_id_reader = reader.get_strategy_id()?;
        let strategy_id = StrategyId::from_capnp(strategy_id_reader)?;

        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let client_order_id_reader = reader.get_client_order_id()?;
        let client_order_id = ClientOrderId::from_capnp(client_order_id_reader)?;

        let reason = Ustr::from(reader.get_reason()?.to_str()?);

        let event_id_reader = reader.get_event_id()?;
        let event_id = nautilus_core::UUID4::from_capnp(event_id_reader)?;

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        Ok(Self {
            trader_id,
            strategy_id,
            instrument_id,
            client_order_id,
            reason,
            event_id,
            ts_event: ts_init.into(), // System event - ts_event = ts_init
            ts_init: ts_init.into(),
            causation_id: None,
        })
    }
}

impl<'a> ToCapnp<'a> for OrderEmulated {
    type Builder = order_capnp::order_emulated::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let trader_id_builder = builder.reborrow().init_trader_id();
        self.trader_id.to_capnp(trader_id_builder);

        let strategy_id_builder = builder.reborrow().init_strategy_id();
        self.strategy_id.to_capnp(strategy_id_builder);

        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let client_order_id_builder = builder.reborrow().init_client_order_id();
        self.client_order_id.to_capnp(client_order_id_builder);

        let event_id_builder = builder.reborrow().init_event_id();
        self.event_id.to_capnp(event_id_builder);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);
    }
}

impl<'a> FromCapnp<'a> for OrderEmulated {
    type Reader = order_capnp::order_emulated::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let trader_id_reader = reader.get_trader_id()?;
        let trader_id = TraderId::from_capnp(trader_id_reader)?;

        let strategy_id_reader = reader.get_strategy_id()?;
        let strategy_id = StrategyId::from_capnp(strategy_id_reader)?;

        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let client_order_id_reader = reader.get_client_order_id()?;
        let client_order_id = ClientOrderId::from_capnp(client_order_id_reader)?;

        let event_id_reader = reader.get_event_id()?;
        let event_id = nautilus_core::UUID4::from_capnp(event_id_reader)?;

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        Ok(Self {
            trader_id,
            strategy_id,
            instrument_id,
            client_order_id,
            event_id,
            ts_event: ts_init.into(), // System event - ts_event = ts_init
            ts_init: ts_init.into(),
            causation_id: None,
        })
    }
}

impl<'a> ToCapnp<'a> for OrderReleased {
    type Builder = order_capnp::order_released::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let trader_id_builder = builder.reborrow().init_trader_id();
        self.trader_id.to_capnp(trader_id_builder);

        let strategy_id_builder = builder.reborrow().init_strategy_id();
        self.strategy_id.to_capnp(strategy_id_builder);

        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let client_order_id_builder = builder.reborrow().init_client_order_id();
        self.client_order_id.to_capnp(client_order_id_builder);

        let released_price_builder = builder.reborrow().init_released_price();
        self.released_price.to_capnp(released_price_builder);

        let event_id_builder = builder.reborrow().init_event_id();
        self.event_id.to_capnp(event_id_builder);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);
    }
}

impl<'a> FromCapnp<'a> for OrderReleased {
    type Reader = order_capnp::order_released::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let trader_id_reader = reader.get_trader_id()?;
        let trader_id = TraderId::from_capnp(trader_id_reader)?;

        let strategy_id_reader = reader.get_strategy_id()?;
        let strategy_id = StrategyId::from_capnp(strategy_id_reader)?;

        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let client_order_id_reader = reader.get_client_order_id()?;
        let client_order_id = ClientOrderId::from_capnp(client_order_id_reader)?;

        let released_price_reader = reader.get_released_price()?;
        let released_price = Price::from_capnp(released_price_reader)?;

        let event_id_reader = reader.get_event_id()?;
        let event_id = nautilus_core::UUID4::from_capnp(event_id_reader)?;

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        Ok(Self {
            trader_id,
            strategy_id,
            instrument_id,
            client_order_id,
            released_price,
            event_id,
            ts_event: ts_init.into(), // System event - ts_event = ts_init
            ts_init: ts_init.into(),
            causation_id: None,
        })
    }
}

// OrderSubmitted
impl<'a> ToCapnp<'a> for OrderSubmitted {
    type Builder = order_capnp::order_submitted::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let trader_id_builder = builder.reborrow().init_trader_id();
        self.trader_id.to_capnp(trader_id_builder);

        let strategy_id_builder = builder.reborrow().init_strategy_id();
        self.strategy_id.to_capnp(strategy_id_builder);

        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let client_order_id_builder = builder.reborrow().init_client_order_id();
        self.client_order_id.to_capnp(client_order_id_builder);

        self.account_id
            .write_capnp(|| builder.reborrow().init_account_id());

        let event_id_builder = builder.reborrow().init_event_id();
        self.event_id.to_capnp(event_id_builder);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);
    }
}

impl<'a> FromCapnp<'a> for OrderSubmitted {
    type Reader = order_capnp::order_submitted::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let trader_id_reader = reader.get_trader_id()?;
        let trader_id = TraderId::from_capnp(trader_id_reader)?;

        let strategy_id_reader = reader.get_strategy_id()?;
        let strategy_id = StrategyId::from_capnp(strategy_id_reader)?;

        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let client_order_id_reader = reader.get_client_order_id()?;
        let client_order_id = ClientOrderId::from_capnp(client_order_id_reader)?;

        let account_id_reader = reader.get_account_id()?;
        let account_id = AccountId::from_capnp(account_id_reader)?;

        let event_id_reader = reader.get_event_id()?;
        let event_id = nautilus_core::UUID4::from_capnp(event_id_reader)?;

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        Ok(Self {
            trader_id,
            strategy_id,
            instrument_id,
            client_order_id,
            account_id,
            event_id,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
            causation_id: None,
        })
    }
}

// OrderAccepted
impl<'a> ToCapnp<'a> for OrderAccepted {
    type Builder = order_capnp::order_accepted::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let trader_id_builder = builder.reborrow().init_trader_id();
        self.trader_id.to_capnp(trader_id_builder);

        let strategy_id_builder = builder.reborrow().init_strategy_id();
        self.strategy_id.to_capnp(strategy_id_builder);

        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let client_order_id_builder = builder.reborrow().init_client_order_id();
        self.client_order_id.to_capnp(client_order_id_builder);

        self.venue_order_id
            .write_capnp(|| builder.reborrow().init_venue_order_id());
        self.account_id
            .write_capnp(|| builder.reborrow().init_account_id());

        let event_id_builder = builder.reborrow().init_event_id();
        self.event_id.to_capnp(event_id_builder);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);

        builder.set_reconciliation(self.reconciliation);
    }
}

impl<'a> FromCapnp<'a> for OrderAccepted {
    type Reader = order_capnp::order_accepted::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let trader_id_reader = reader.get_trader_id()?;
        let trader_id = TraderId::from_capnp(trader_id_reader)?;

        let strategy_id_reader = reader.get_strategy_id()?;
        let strategy_id = StrategyId::from_capnp(strategy_id_reader)?;

        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let client_order_id_reader = reader.get_client_order_id()?;
        let client_order_id = ClientOrderId::from_capnp(client_order_id_reader)?;

        let venue_order_id_reader = reader.get_venue_order_id()?;
        let venue_order_id = VenueOrderId::from_capnp(venue_order_id_reader)?;

        let account_id_reader = reader.get_account_id()?;
        let account_id = AccountId::from_capnp(account_id_reader)?;

        let event_id_reader = reader.get_event_id()?;
        let event_id = nautilus_core::UUID4::from_capnp(event_id_reader)?;

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        let reconciliation = reader.get_reconciliation();

        Ok(Self {
            trader_id,
            strategy_id,
            instrument_id,
            client_order_id,
            venue_order_id,
            account_id,
            event_id,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
            reconciliation,
            causation_id: None,
        })
    }
}

// OrderRejected
impl<'a> ToCapnp<'a> for OrderRejected {
    type Builder = order_capnp::order_rejected::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let trader_id_builder = builder.reborrow().init_trader_id();
        self.trader_id.to_capnp(trader_id_builder);

        let strategy_id_builder = builder.reborrow().init_strategy_id();
        self.strategy_id.to_capnp(strategy_id_builder);

        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let client_order_id_builder = builder.reborrow().init_client_order_id();
        self.client_order_id.to_capnp(client_order_id_builder);

        self.account_id
            .write_capnp(|| builder.reborrow().init_account_id());

        builder.set_reason(self.reason.as_str());

        let event_id_builder = builder.reborrow().init_event_id();
        self.event_id.to_capnp(event_id_builder);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);

        builder.set_reconciliation(self.reconciliation);
        builder.set_due_post_only(self.due_post_only);
    }
}

impl<'a> FromCapnp<'a> for OrderRejected {
    type Reader = order_capnp::order_rejected::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let trader_id_reader = reader.get_trader_id()?;
        let trader_id = TraderId::from_capnp(trader_id_reader)?;

        let strategy_id_reader = reader.get_strategy_id()?;
        let strategy_id = StrategyId::from_capnp(strategy_id_reader)?;

        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let client_order_id_reader = reader.get_client_order_id()?;
        let client_order_id = ClientOrderId::from_capnp(client_order_id_reader)?;

        let account_id_reader = reader.get_account_id()?;
        let account_id = AccountId::from_capnp(account_id_reader)?;

        let reason = Ustr::from(reader.get_reason()?.to_str()?);

        let event_id_reader = reader.get_event_id()?;
        let event_id = nautilus_core::UUID4::from_capnp(event_id_reader)?;

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        let reconciliation = reader.get_reconciliation();
        let due_post_only = reader.get_due_post_only();

        Ok(Self {
            trader_id,
            strategy_id,
            instrument_id,
            client_order_id,
            account_id,
            reason,
            event_id,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
            reconciliation,
            due_post_only,
            causation_id: None,
        })
    }
}

// OrderCanceled
impl<'a> ToCapnp<'a> for OrderCanceled {
    type Builder = order_capnp::order_canceled::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let trader_id_builder = builder.reborrow().init_trader_id();
        self.trader_id.to_capnp(trader_id_builder);

        let strategy_id_builder = builder.reborrow().init_strategy_id();
        self.strategy_id.to_capnp(strategy_id_builder);

        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let client_order_id_builder = builder.reborrow().init_client_order_id();
        self.client_order_id.to_capnp(client_order_id_builder);

        self.venue_order_id
            .write_capnp(|| builder.reborrow().init_venue_order_id());

        self.account_id
            .write_capnp(|| builder.reborrow().init_account_id());

        if let Some(reason) = self.reason {
            builder.reborrow().set_reason(reason.as_str());
        }

        let event_id_builder = builder.reborrow().init_event_id();
        self.event_id.to_capnp(event_id_builder);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);

        builder.set_reconciliation(self.reconciliation);
    }
}

impl<'a> FromCapnp<'a> for OrderCanceled {
    type Reader = order_capnp::order_canceled::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let trader_id_reader = reader.get_trader_id()?;
        let trader_id = TraderId::from_capnp(trader_id_reader)?;

        let strategy_id_reader = reader.get_strategy_id()?;
        let strategy_id = StrategyId::from_capnp(strategy_id_reader)?;

        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let client_order_id_reader = reader.get_client_order_id()?;
        let client_order_id = ClientOrderId::from_capnp(client_order_id_reader)?;

        let venue_order_id = read_optional_from_capnp(
            || reader.has_venue_order_id(),
            || reader.get_venue_order_id(),
        )?;

        let account_id =
            read_optional_from_capnp(|| reader.has_account_id(), || reader.get_account_id())?;

        let reason = if reader.has_reason() {
            Some(Ustr::from(reader.get_reason()?.to_str()?))
        } else {
            None
        };

        let event_id_reader = reader.get_event_id()?;
        let event_id = nautilus_core::UUID4::from_capnp(event_id_reader)?;

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        let reconciliation = reader.get_reconciliation();

        Ok(Self {
            trader_id,
            strategy_id,
            instrument_id,
            client_order_id,
            venue_order_id,
            account_id,
            event_id,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
            reconciliation,
            reason,
            causation_id: None,
        })
    }
}

// OrderExpired
impl<'a> ToCapnp<'a> for OrderExpired {
    type Builder = order_capnp::order_expired::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let trader_id_builder = builder.reborrow().init_trader_id();
        self.trader_id.to_capnp(trader_id_builder);

        let strategy_id_builder = builder.reborrow().init_strategy_id();
        self.strategy_id.to_capnp(strategy_id_builder);

        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let client_order_id_builder = builder.reborrow().init_client_order_id();
        self.client_order_id.to_capnp(client_order_id_builder);

        self.venue_order_id
            .write_capnp(|| builder.reborrow().init_venue_order_id());

        self.account_id
            .write_capnp(|| builder.reborrow().init_account_id());

        let event_id_builder = builder.reborrow().init_event_id();
        self.event_id.to_capnp(event_id_builder);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);

        builder.set_reconciliation(self.reconciliation);
    }
}

impl<'a> FromCapnp<'a> for OrderExpired {
    type Reader = order_capnp::order_expired::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let trader_id_reader = reader.get_trader_id()?;
        let trader_id = TraderId::from_capnp(trader_id_reader)?;

        let strategy_id_reader = reader.get_strategy_id()?;
        let strategy_id = StrategyId::from_capnp(strategy_id_reader)?;

        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let client_order_id_reader = reader.get_client_order_id()?;
        let client_order_id = ClientOrderId::from_capnp(client_order_id_reader)?;

        let venue_order_id = read_optional_from_capnp(
            || reader.has_venue_order_id(),
            || reader.get_venue_order_id(),
        )?;

        let account_id =
            read_optional_from_capnp(|| reader.has_account_id(), || reader.get_account_id())?;

        let event_id_reader = reader.get_event_id()?;
        let event_id = nautilus_core::UUID4::from_capnp(event_id_reader)?;

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        let reconciliation = reader.get_reconciliation();

        Ok(Self {
            trader_id,
            strategy_id,
            instrument_id,
            client_order_id,
            venue_order_id,
            account_id,
            event_id,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
            reconciliation,
            causation_id: None,
        })
    }
}

// OrderTriggered
impl<'a> ToCapnp<'a> for OrderTriggered {
    type Builder = order_capnp::order_triggered::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let trader_id_builder = builder.reborrow().init_trader_id();
        self.trader_id.to_capnp(trader_id_builder);

        let strategy_id_builder = builder.reborrow().init_strategy_id();
        self.strategy_id.to_capnp(strategy_id_builder);

        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let client_order_id_builder = builder.reborrow().init_client_order_id();
        self.client_order_id.to_capnp(client_order_id_builder);

        self.venue_order_id
            .write_capnp(|| builder.reborrow().init_venue_order_id());

        self.account_id
            .write_capnp(|| builder.reborrow().init_account_id());

        let event_id_builder = builder.reborrow().init_event_id();
        self.event_id.to_capnp(event_id_builder);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);

        builder.set_reconciliation(self.reconciliation);
    }
}

impl<'a> FromCapnp<'a> for OrderTriggered {
    type Reader = order_capnp::order_triggered::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let trader_id_reader = reader.get_trader_id()?;
        let trader_id = TraderId::from_capnp(trader_id_reader)?;

        let strategy_id_reader = reader.get_strategy_id()?;
        let strategy_id = StrategyId::from_capnp(strategy_id_reader)?;

        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let client_order_id_reader = reader.get_client_order_id()?;
        let client_order_id = ClientOrderId::from_capnp(client_order_id_reader)?;

        let venue_order_id = read_optional_from_capnp(
            || reader.has_venue_order_id(),
            || reader.get_venue_order_id(),
        )?;

        let account_id =
            read_optional_from_capnp(|| reader.has_account_id(), || reader.get_account_id())?;

        let event_id_reader = reader.get_event_id()?;
        let event_id = nautilus_core::UUID4::from_capnp(event_id_reader)?;

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        let reconciliation = reader.get_reconciliation();

        Ok(Self {
            trader_id,
            strategy_id,
            instrument_id,
            client_order_id,
            venue_order_id,
            account_id,
            event_id,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
            reconciliation,
            causation_id: None,
        })
    }
}

// OrderPendingUpdate
impl<'a> ToCapnp<'a> for OrderPendingUpdate {
    type Builder = order_capnp::order_pending_update::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let trader_id_builder = builder.reborrow().init_trader_id();
        self.trader_id.to_capnp(trader_id_builder);

        let strategy_id_builder = builder.reborrow().init_strategy_id();
        self.strategy_id.to_capnp(strategy_id_builder);

        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let client_order_id_builder = builder.reborrow().init_client_order_id();
        self.client_order_id.to_capnp(client_order_id_builder);

        self.venue_order_id
            .write_capnp(|| builder.reborrow().init_venue_order_id());
        self.account_id
            .write_capnp(|| builder.reborrow().init_account_id());

        let event_id_builder = builder.reborrow().init_event_id();
        self.event_id.to_capnp(event_id_builder);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);

        builder.set_reconciliation(self.reconciliation);
    }
}

impl<'a> FromCapnp<'a> for OrderPendingUpdate {
    type Reader = order_capnp::order_pending_update::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let trader_id_reader = reader.get_trader_id()?;
        let trader_id = TraderId::from_capnp(trader_id_reader)?;

        let strategy_id_reader = reader.get_strategy_id()?;
        let strategy_id = StrategyId::from_capnp(strategy_id_reader)?;

        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let client_order_id_reader = reader.get_client_order_id()?;
        let client_order_id = ClientOrderId::from_capnp(client_order_id_reader)?;

        let venue_order_id = read_optional_from_capnp(
            || reader.has_venue_order_id(),
            || reader.get_venue_order_id(),
        )?;

        let account_id =
            read_optional_from_capnp(|| reader.has_account_id(), || reader.get_account_id())?;

        let event_id_reader = reader.get_event_id()?;
        let event_id = nautilus_core::UUID4::from_capnp(event_id_reader)?;

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        let reconciliation = reader.get_reconciliation();

        Ok(Self {
            trader_id,
            strategy_id,
            instrument_id,
            client_order_id,
            venue_order_id,
            account_id,
            event_id,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
            reconciliation,
            causation_id: None,
        })
    }
}

// OrderPendingCancel
impl<'a> ToCapnp<'a> for OrderPendingCancel {
    type Builder = order_capnp::order_pending_cancel::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let trader_id_builder = builder.reborrow().init_trader_id();
        self.trader_id.to_capnp(trader_id_builder);

        let strategy_id_builder = builder.reborrow().init_strategy_id();
        self.strategy_id.to_capnp(strategy_id_builder);

        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let client_order_id_builder = builder.reborrow().init_client_order_id();
        self.client_order_id.to_capnp(client_order_id_builder);

        self.venue_order_id
            .write_capnp(|| builder.reborrow().init_venue_order_id());
        self.account_id
            .write_capnp(|| builder.reborrow().init_account_id());

        let event_id_builder = builder.reborrow().init_event_id();
        self.event_id.to_capnp(event_id_builder);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);

        builder.set_reconciliation(self.reconciliation);
    }
}

impl<'a> FromCapnp<'a> for OrderPendingCancel {
    type Reader = order_capnp::order_pending_cancel::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let trader_id_reader = reader.get_trader_id()?;
        let trader_id = TraderId::from_capnp(trader_id_reader)?;

        let strategy_id_reader = reader.get_strategy_id()?;
        let strategy_id = StrategyId::from_capnp(strategy_id_reader)?;

        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let client_order_id_reader = reader.get_client_order_id()?;
        let client_order_id = ClientOrderId::from_capnp(client_order_id_reader)?;

        let venue_order_id = read_optional_from_capnp(
            || reader.has_venue_order_id(),
            || reader.get_venue_order_id(),
        )?;

        let account_id =
            read_optional_from_capnp(|| reader.has_account_id(), || reader.get_account_id())?;

        let event_id_reader = reader.get_event_id()?;
        let event_id = nautilus_core::UUID4::from_capnp(event_id_reader)?;

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        let reconciliation = reader.get_reconciliation();

        Ok(Self {
            trader_id,
            strategy_id,
            instrument_id,
            client_order_id,
            venue_order_id,
            account_id,
            event_id,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
            reconciliation,
            causation_id: None,
        })
    }
}

// OrderModifyRejected
impl<'a> ToCapnp<'a> for OrderModifyRejected {
    type Builder = order_capnp::order_modify_rejected::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let trader_id_builder = builder.reborrow().init_trader_id();
        self.trader_id.to_capnp(trader_id_builder);

        let strategy_id_builder = builder.reborrow().init_strategy_id();
        self.strategy_id.to_capnp(strategy_id_builder);

        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let client_order_id_builder = builder.reborrow().init_client_order_id();
        self.client_order_id.to_capnp(client_order_id_builder);

        self.venue_order_id
            .write_capnp(|| builder.reborrow().init_venue_order_id());
        self.account_id
            .write_capnp(|| builder.reborrow().init_account_id());

        builder.set_reason(self.reason.as_str());

        let event_id_builder = builder.reborrow().init_event_id();
        self.event_id.to_capnp(event_id_builder);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);

        builder.set_reconciliation(self.reconciliation);
    }
}

impl<'a> FromCapnp<'a> for OrderModifyRejected {
    type Reader = order_capnp::order_modify_rejected::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let trader_id_reader = reader.get_trader_id()?;
        let trader_id = TraderId::from_capnp(trader_id_reader)?;

        let strategy_id_reader = reader.get_strategy_id()?;
        let strategy_id = StrategyId::from_capnp(strategy_id_reader)?;

        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let client_order_id_reader = reader.get_client_order_id()?;
        let client_order_id = ClientOrderId::from_capnp(client_order_id_reader)?;

        let venue_order_id = read_optional_from_capnp(
            || reader.has_venue_order_id(),
            || reader.get_venue_order_id(),
        )?;

        let account_id =
            read_optional_from_capnp(|| reader.has_account_id(), || reader.get_account_id())?;

        let reason = Ustr::from(reader.get_reason()?.to_str()?);

        let event_id_reader = reader.get_event_id()?;
        let event_id = nautilus_core::UUID4::from_capnp(event_id_reader)?;

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        let reconciliation = reader.get_reconciliation();

        Ok(Self {
            trader_id,
            strategy_id,
            instrument_id,
            client_order_id,
            venue_order_id,
            account_id,
            reason,
            event_id,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
            reconciliation,
            causation_id: None,
        })
    }
}

// OrderCancelRejected
impl<'a> ToCapnp<'a> for OrderCancelRejected {
    type Builder = order_capnp::order_cancel_rejected::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let trader_id_builder = builder.reborrow().init_trader_id();
        self.trader_id.to_capnp(trader_id_builder);

        let strategy_id_builder = builder.reborrow().init_strategy_id();
        self.strategy_id.to_capnp(strategy_id_builder);

        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let client_order_id_builder = builder.reborrow().init_client_order_id();
        self.client_order_id.to_capnp(client_order_id_builder);

        self.venue_order_id
            .write_capnp(|| builder.reborrow().init_venue_order_id());
        self.account_id
            .write_capnp(|| builder.reborrow().init_account_id());

        builder.set_reason(self.reason.as_str());

        let event_id_builder = builder.reborrow().init_event_id();
        self.event_id.to_capnp(event_id_builder);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);

        builder.set_reconciliation(self.reconciliation);
    }
}

impl<'a> FromCapnp<'a> for OrderCancelRejected {
    type Reader = order_capnp::order_cancel_rejected::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let trader_id_reader = reader.get_trader_id()?;
        let trader_id = TraderId::from_capnp(trader_id_reader)?;

        let strategy_id_reader = reader.get_strategy_id()?;
        let strategy_id = StrategyId::from_capnp(strategy_id_reader)?;

        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let client_order_id_reader = reader.get_client_order_id()?;
        let client_order_id = ClientOrderId::from_capnp(client_order_id_reader)?;

        let venue_order_id = read_optional_from_capnp(
            || reader.has_venue_order_id(),
            || reader.get_venue_order_id(),
        )?;

        let account_id =
            read_optional_from_capnp(|| reader.has_account_id(), || reader.get_account_id())?;

        let reason = Ustr::from(reader.get_reason()?.to_str()?);

        let event_id_reader = reader.get_event_id()?;
        let event_id = nautilus_core::UUID4::from_capnp(event_id_reader)?;

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        let reconciliation = reader.get_reconciliation();

        Ok(Self {
            trader_id,
            strategy_id,
            instrument_id,
            client_order_id,
            venue_order_id,
            account_id,
            reason,
            event_id,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
            reconciliation,
            causation_id: None,
        })
    }
}

// OrderUpdated
impl<'a> ToCapnp<'a> for OrderUpdated {
    type Builder = order_capnp::order_updated::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let trader_id_builder = builder.reborrow().init_trader_id();
        self.trader_id.to_capnp(trader_id_builder);

        let strategy_id_builder = builder.reborrow().init_strategy_id();
        self.strategy_id.to_capnp(strategy_id_builder);

        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let client_order_id_builder = builder.reborrow().init_client_order_id();
        self.client_order_id.to_capnp(client_order_id_builder);

        self.venue_order_id
            .write_capnp(|| builder.reborrow().init_venue_order_id());
        self.account_id
            .write_capnp(|| builder.reborrow().init_account_id());

        let quantity_builder = builder.reborrow().init_quantity();
        self.quantity.to_capnp(quantity_builder);

        self.price.write_capnp(|| builder.reborrow().init_price());
        self.trigger_price
            .write_capnp(|| builder.reborrow().init_trigger_price());
        self.protection_price
            .write_capnp(|| builder.reborrow().init_protection_price());

        let event_id_builder = builder.reborrow().init_event_id();
        self.event_id.to_capnp(event_id_builder);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);

        builder.set_reconciliation(self.reconciliation);
        builder.set_is_quote_quantity(self.is_quote_quantity);
    }
}

impl<'a> FromCapnp<'a> for OrderUpdated {
    type Reader = order_capnp::order_updated::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let trader_id_reader = reader.get_trader_id()?;
        let trader_id = TraderId::from_capnp(trader_id_reader)?;

        let strategy_id_reader = reader.get_strategy_id()?;
        let strategy_id = StrategyId::from_capnp(strategy_id_reader)?;

        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let client_order_id_reader = reader.get_client_order_id()?;
        let client_order_id = ClientOrderId::from_capnp(client_order_id_reader)?;

        let venue_order_id = read_optional_from_capnp(
            || reader.has_venue_order_id(),
            || reader.get_venue_order_id(),
        )?;

        let account_id =
            read_optional_from_capnp(|| reader.has_account_id(), || reader.get_account_id())?;

        let quantity_reader = reader.get_quantity()?;
        let quantity = Quantity::from_capnp(quantity_reader)?;

        let price = read_optional_from_capnp(|| reader.has_price(), || reader.get_price())?;

        let trigger_price =
            read_optional_from_capnp(|| reader.has_trigger_price(), || reader.get_trigger_price())?;

        let protection_price = read_optional_from_capnp(
            || reader.has_protection_price(),
            || reader.get_protection_price(),
        )?;

        let event_id_reader = reader.get_event_id()?;
        let event_id = nautilus_core::UUID4::from_capnp(event_id_reader)?;

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        let reconciliation = reader.get_reconciliation();

        Ok(Self {
            trader_id,
            strategy_id,
            instrument_id,
            client_order_id,
            venue_order_id,
            account_id,
            quantity,
            price,
            trigger_price,
            protection_price,
            is_quote_quantity: reader.get_is_quote_quantity(),
            event_id,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
            reconciliation,
            causation_id: None,
        })
    }
}

// OrderFilled
impl<'a> ToCapnp<'a> for OrderFilled {
    type Builder = order_capnp::order_filled::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let trader_id_builder = builder.reborrow().init_trader_id();
        self.trader_id.to_capnp(trader_id_builder);

        let strategy_id_builder = builder.reborrow().init_strategy_id();
        self.strategy_id.to_capnp(strategy_id_builder);

        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let client_order_id_builder = builder.reborrow().init_client_order_id();
        self.client_order_id.to_capnp(client_order_id_builder);

        let venue_order_id_builder = builder.reborrow().init_venue_order_id();
        self.venue_order_id.to_capnp(venue_order_id_builder);

        let account_id_builder = builder.reborrow().init_account_id();
        self.account_id.to_capnp(account_id_builder);

        let trade_id_builder = builder.reborrow().init_trade_id();
        self.trade_id.to_capnp(trade_id_builder);

        builder.set_order_side(order_side_to_capnp(self.order_side.into()));
        builder.set_order_type(order_type_to_capnp(self.order_type));

        let last_qty_builder = builder.reborrow().init_last_qty();
        self.last_qty.to_capnp(last_qty_builder);

        let last_px_builder = builder.reborrow().init_last_px();
        self.last_px.to_capnp(last_px_builder);

        let currency_builder = builder.reborrow().init_currency();
        self.currency.to_capnp(currency_builder);

        builder.set_liquidity_side(liquidity_side_to_capnp(self.liquidity_side));

        let event_id_builder = builder.reborrow().init_event_id();
        self.event_id.to_capnp(event_id_builder);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);

        builder.set_reconciliation(self.reconciliation);

        self.position_id
            .write_capnp(|| builder.reborrow().init_position_id());
        self.commission
            .write_capnp(|| builder.reborrow().init_commission());

        if let Some(info) = &self.info {
            write_string_map(info, builder.reborrow().init_info());
        }
    }
}

impl<'a> FromCapnp<'a> for OrderFilled {
    type Reader = order_capnp::order_filled::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let trader_id_reader = reader.get_trader_id()?;
        let trader_id = TraderId::from_capnp(trader_id_reader)?;

        let strategy_id_reader = reader.get_strategy_id()?;
        let strategy_id = StrategyId::from_capnp(strategy_id_reader)?;

        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let client_order_id_reader = reader.get_client_order_id()?;
        let client_order_id = ClientOrderId::from_capnp(client_order_id_reader)?;

        let venue_order_id_reader = reader.get_venue_order_id()?;
        let venue_order_id = VenueOrderId::from_capnp(venue_order_id_reader)?;

        let account_id_reader = reader.get_account_id()?;
        let account_id = AccountId::from_capnp(account_id_reader)?;

        let trade_id_reader = reader.get_trade_id()?;
        let trade_id = TradeId::from_capnp(trade_id_reader)?;

        let order_side = order_side_required_from_capnp(reader.get_order_side()?)?;
        let order_type = order_type_from_capnp(reader.get_order_type()?);

        let last_qty_reader = reader.get_last_qty()?;
        let last_qty = Quantity::from_capnp(last_qty_reader)?;

        let last_px_reader = reader.get_last_px()?;
        let last_px = Price::from_capnp(last_px_reader)?;

        let currency_reader = reader.get_currency()?;
        let currency = Currency::from_capnp(currency_reader)?;

        let liquidity_side = liquidity_side_from_capnp(reader.get_liquidity_side()?);

        let event_id_reader = reader.get_event_id()?;
        let event_id = nautilus_core::UUID4::from_capnp(event_id_reader)?;

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        let reconciliation = reader.get_reconciliation();

        let position_id =
            read_optional_from_capnp(|| reader.has_position_id(), || reader.get_position_id())?;

        let commission =
            read_optional_from_capnp(|| reader.has_commission(), || reader.get_commission())?;

        let info = if reader.has_info() {
            Some(read_string_map(reader.get_info()?)?)
        } else {
            None
        };

        Ok(Self {
            trader_id,
            strategy_id,
            instrument_id,
            client_order_id,
            venue_order_id,
            account_id,
            trade_id,
            order_side,
            order_type,
            last_qty,
            last_px,
            currency,
            liquidity_side,
            event_id,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
            reconciliation,
            position_id,
            commission,
            info,
            causation_id: None,
        })
    }
}

impl<'a> ToCapnp<'a> for OrderFillVoided {
    type Builder = order_capnp::order_fill_voided::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        self.trader_id.to_capnp(builder.reborrow().init_trader_id());
        self.strategy_id
            .to_capnp(builder.reborrow().init_strategy_id());
        self.instrument_id
            .to_capnp(builder.reborrow().init_instrument_id());
        self.client_order_id
            .to_capnp(builder.reborrow().init_client_order_id());
        self.venue_order_id
            .to_capnp(builder.reborrow().init_venue_order_id());
        self.account_id
            .to_capnp(builder.reborrow().init_account_id());
        builder.set_correction_id(self.correction_id.as_str());
        self.trade_id.to_capnp(builder.reborrow().init_trade_id());
        self.voided_qty
            .to_capnp(builder.reborrow().init_voided_qty());
        self.commission_voided
            .write_capnp(|| builder.reborrow().init_commission_voided());
        builder.set_order_side(order_side_to_capnp(self.order_side.into()));
        builder.set_order_type(order_type_to_capnp(self.order_type));
        self.last_px.to_capnp(builder.reborrow().init_last_px());
        self.currency.to_capnp(builder.reborrow().init_currency());
        builder.set_liquidity_side(liquidity_side_to_capnp(self.liquidity_side));

        self.position_id
            .write_capnp(|| builder.reborrow().init_position_id());

        if let Some(reason) = self.reason {
            builder.set_reason(reason.as_str());
        }

        if let Some(info) = &self.info {
            write_string_map(info, builder.reborrow().init_info());
        }
        self.event_id.to_capnp(builder.reborrow().init_event_id());
        builder.reborrow().init_ts_event().set_value(*self.ts_event);
        builder.reborrow().init_ts_init().set_value(*self.ts_init);
        builder.set_reconciliation(self.reconciliation);
        builder.set_is_reopened(self.is_reopened);
        self.causation_id
            .write_capnp(|| builder.reborrow().init_causation_id());
    }
}

impl<'a> FromCapnp<'a> for OrderFillVoided {
    type Reader = order_capnp::order_fill_voided::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let trader_id = TraderId::from_capnp(reader.get_trader_id()?)?;
        let strategy_id = StrategyId::from_capnp(reader.get_strategy_id()?)?;
        let instrument_id = InstrumentId::from_capnp(reader.get_instrument_id()?)?;
        let client_order_id = ClientOrderId::from_capnp(reader.get_client_order_id()?)?;
        let venue_order_id = VenueOrderId::from_capnp(reader.get_venue_order_id()?)?;
        let account_id = AccountId::from_capnp(reader.get_account_id()?)?;
        let correction_id = Ustr::from(reader.get_correction_id()?.to_str()?);
        let trade_id = TradeId::from_capnp(reader.get_trade_id()?)?;
        let voided_qty = Quantity::from_capnp(reader.get_voided_qty()?)?;
        let commission_voided = read_optional_from_capnp(
            || reader.has_commission_voided(),
            || reader.get_commission_voided(),
        )?;
        let order_side = order_side_required_from_capnp(reader.get_order_side()?)?;
        let order_type = order_type_from_capnp(reader.get_order_type()?);
        let last_px = Price::from_capnp(reader.get_last_px()?)?;
        let currency = Currency::from_capnp(reader.get_currency()?)?;
        let liquidity_side = liquidity_side_from_capnp(reader.get_liquidity_side()?);
        let position_id =
            read_optional_from_capnp(|| reader.has_position_id(), || reader.get_position_id())?;
        let reason = if reader.has_reason() {
            Some(Ustr::from(reader.get_reason()?.to_str()?))
        } else {
            None
        };
        let info = if reader.has_info() {
            Some(read_string_map(reader.get_info()?)?)
        } else {
            None
        };
        let event_id = nautilus_core::UUID4::from_capnp(reader.get_event_id()?)?;
        let ts_event = reader.get_ts_event()?.get_value().into();
        let ts_init = reader.get_ts_init()?.get_value().into();
        let causation_id =
            read_optional_from_capnp(|| reader.has_causation_id(), || reader.get_causation_id())?;

        Ok(Self {
            trader_id,
            strategy_id,
            instrument_id,
            client_order_id,
            venue_order_id,
            account_id,
            correction_id,
            trade_id,
            voided_qty,
            commission_voided,
            order_side,
            order_type,
            last_px,
            currency,
            liquidity_side,
            position_id,
            reason,
            info,
            event_id,
            ts_event,
            ts_init,
            reconciliation: reader.get_reconciliation(),
            is_reopened: reader.get_is_reopened(),
            causation_id,
        })
    }
}

// OrderInitialized - seed event
impl<'a> ToCapnp<'a> for OrderInitialized {
    type Builder = order_capnp::order_initialized::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let trader_id_builder = builder.reborrow().init_trader_id();
        self.trader_id.to_capnp(trader_id_builder);

        let strategy_id_builder = builder.reborrow().init_strategy_id();
        self.strategy_id.to_capnp(strategy_id_builder);

        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let client_order_id_builder = builder.reborrow().init_client_order_id();
        self.client_order_id.to_capnp(client_order_id_builder);

        builder.set_order_side(order_side_to_capnp(self.order_side.into()));
        builder.set_order_type(order_type_to_capnp(self.order_type));

        let quantity_builder = builder.reborrow().init_quantity();
        self.quantity.to_capnp(quantity_builder);

        builder.set_time_in_force(time_in_force_to_capnp(self.time_in_force));
        builder.set_post_only(self.post_only);
        builder.set_reduce_only(self.reduce_only);
        builder.set_quote_quantity(self.quote_quantity);
        builder.set_reconciliation(self.reconciliation);

        let event_id_builder = builder.reborrow().init_event_id();
        self.event_id.to_capnp(event_id_builder);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);

        self.price.write_capnp(|| builder.reborrow().init_price());
        self.activation_price
            .write_capnp(|| builder.reborrow().init_activation_price());
        self.trigger_price
            .write_capnp(|| builder.reborrow().init_trigger_price());

        builder.set_trigger_type(trigger_type_to_capnp(self.trigger_type));

        self.limit_offset
            .write_capnp(|| builder.reborrow().init_limit_offset());
        self.trailing_offset
            .write_capnp(|| builder.reborrow().init_trailing_offset());

        builder.set_trailing_offset_type(trailing_offset_type_to_capnp(self.trailing_offset_type));

        if let Some(expire_time) = self.expire_time {
            let mut expire_time_builder = builder.reborrow().init_expire_time();
            expire_time_builder.set_value(*expire_time);
        }

        self.display_qty
            .write_capnp(|| builder.reborrow().init_display_qty());

        builder.set_emulation_trigger(trigger_type_to_capnp(self.emulation_trigger));

        self.trigger_instrument_id
            .write_capnp(|| builder.reborrow().init_trigger_instrument_id());

        builder.set_contingency_type(contingency_type_to_capnp(self.contingency_type));

        self.order_list_id
            .write_capnp(|| builder.reborrow().init_order_list_id());

        if let Some(linked_order_ids) = &self.linked_order_ids {
            let mut linked_order_ids_builder = builder
                .reborrow()
                .init_linked_order_ids(linked_order_ids.len() as u32);
            for (i, order_id) in linked_order_ids.iter().enumerate() {
                let order_id_builder = linked_order_ids_builder.reborrow().get(i as u32);
                order_id.to_capnp(order_id_builder);
            }
        }

        self.parent_order_id
            .write_capnp(|| builder.reborrow().init_parent_order_id());

        self.exec_algorithm_id
            .write_capnp(|| builder.reborrow().init_exec_algorithm_id());

        if let Some(exec_algorithm_params) = &self.exec_algorithm_params {
            write_string_map(
                exec_algorithm_params,
                builder.reborrow().init_exec_algorithm_params(),
            );
        }

        self.exec_spawn_id
            .write_capnp(|| builder.reborrow().init_exec_spawn_id());

        if let Some(tags) = &self.tags {
            let mut tags_builder = builder.reborrow().init_tags(tags.len() as u32);
            for (i, tag) in tags.iter().enumerate() {
                tags_builder.set(i as u32, tag.as_str());
            }
        }
    }
}

impl<'a> FromCapnp<'a> for OrderInitialized {
    type Reader = order_capnp::order_initialized::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let trader_id_reader = reader.get_trader_id()?;
        let trader_id = TraderId::from_capnp(trader_id_reader)?;

        let strategy_id_reader = reader.get_strategy_id()?;
        let strategy_id = StrategyId::from_capnp(strategy_id_reader)?;

        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let client_order_id_reader = reader.get_client_order_id()?;
        let client_order_id = ClientOrderId::from_capnp(client_order_id_reader)?;

        let order_side = order_side_required_from_capnp(reader.get_order_side()?)?;
        let order_type = order_type_from_capnp(reader.get_order_type()?);

        let quantity_reader = reader.get_quantity()?;
        let quantity = Quantity::from_capnp(quantity_reader)?;

        let time_in_force = time_in_force_from_capnp(reader.get_time_in_force()?);
        let post_only = reader.get_post_only();
        let reduce_only = reader.get_reduce_only();
        let quote_quantity = reader.get_quote_quantity();
        let reconciliation = reader.get_reconciliation();

        let event_id_reader = reader.get_event_id()?;
        let event_id = nautilus_core::UUID4::from_capnp(event_id_reader)?;

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        let price = read_optional_from_capnp(|| reader.has_price(), || reader.get_price())?;

        let activation_price = read_optional_from_capnp(
            || reader.has_activation_price(),
            || reader.get_activation_price(),
        )?;

        let trigger_price =
            read_optional_from_capnp(|| reader.has_trigger_price(), || reader.get_trigger_price())?;

        let trigger_type = trigger_type_from_capnp(reader.get_trigger_type()?);

        let limit_offset =
            read_optional_from_capnp(|| reader.has_limit_offset(), || reader.get_limit_offset())?;

        let trailing_offset = read_optional_from_capnp(
            || reader.has_trailing_offset(),
            || reader.get_trailing_offset(),
        )?;

        let trailing_offset_type =
            trailing_offset_type_from_capnp(reader.get_trailing_offset_type()?);

        let expire_time = if reader.has_expire_time() {
            let expire_time_reader = reader.get_expire_time()?;
            let value = expire_time_reader.get_value();
            Some(value.into())
        } else {
            None
        };

        let display_qty =
            read_optional_from_capnp(|| reader.has_display_qty(), || reader.get_display_qty())?;

        let emulation_trigger = trigger_type_from_capnp(reader.get_emulation_trigger()?);

        let trigger_instrument_id = read_optional_from_capnp(
            || reader.has_trigger_instrument_id(),
            || reader.get_trigger_instrument_id(),
        )?;

        let contingency_type = contingency_type_from_capnp(reader.get_contingency_type()?);

        let order_list_id =
            read_optional_from_capnp(|| reader.has_order_list_id(), || reader.get_order_list_id())?;

        let linked_order_ids = if reader.has_linked_order_ids() {
            let linked_order_ids_reader = reader.get_linked_order_ids()?;
            let mut linked_order_ids = Vec::with_capacity(linked_order_ids_reader.len() as usize);
            for order_id_reader in linked_order_ids_reader {
                linked_order_ids.push(ClientOrderId::from_capnp(order_id_reader)?);
            }
            Some(linked_order_ids)
        } else {
            None
        };

        let parent_order_id = read_optional_from_capnp(
            || reader.has_parent_order_id(),
            || reader.get_parent_order_id(),
        )?;

        let exec_algorithm_id = read_optional_from_capnp(
            || reader.has_exec_algorithm_id(),
            || reader.get_exec_algorithm_id(),
        )?;

        let exec_algorithm_params = if reader.has_exec_algorithm_params() {
            Some(read_string_map(reader.get_exec_algorithm_params()?)?)
        } else {
            None
        };

        let exec_spawn_id =
            read_optional_from_capnp(|| reader.has_exec_spawn_id(), || reader.get_exec_spawn_id())?;

        let tags = if reader.has_tags() {
            let tags_reader = reader.get_tags()?;
            let mut tags = Vec::with_capacity(tags_reader.len() as usize);
            for tag in tags_reader {
                tags.push(Ustr::from(tag?.to_str()?));
            }
            Some(tags)
        } else {
            None
        };

        Ok(Self {
            trader_id,
            strategy_id,
            instrument_id,
            client_order_id,
            order_side,
            order_type,
            quantity,
            time_in_force,
            post_only,
            reduce_only,
            quote_quantity,
            reconciliation,
            event_id,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
            price,
            activation_price,
            trigger_price,
            trigger_type,
            limit_offset,
            trailing_offset,
            trailing_offset_type,
            expire_time,
            display_qty,
            emulation_trigger,
            trigger_instrument_id,
            contingency_type,
            order_list_id,
            linked_order_ids,
            parent_order_id,
            exec_algorithm_id,
            exec_algorithm_params,
            exec_spawn_id,
            tags,
            causation_id: None,
        })
    }
}

// PositionOpened
impl<'a> ToCapnp<'a> for PositionOpened {
    type Builder = position_capnp::position_opened::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let trader_id_builder = builder.reborrow().init_trader_id();
        self.trader_id.to_capnp(trader_id_builder);

        let strategy_id_builder = builder.reborrow().init_strategy_id();
        self.strategy_id.to_capnp(strategy_id_builder);

        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let position_id_builder = builder.reborrow().init_position_id();
        self.position_id.to_capnp(position_id_builder);

        let account_id_builder = builder.reborrow().init_account_id();
        self.account_id.to_capnp(account_id_builder);

        let opening_order_id_builder = builder.reborrow().init_opening_order_id();
        self.opening_order_id.to_capnp(opening_order_id_builder);

        builder.set_entry(order_side_to_capnp(self.entry.into()));
        builder.set_side(position_side_to_capnp(self.side.into()));
        builder.set_signed_qty(self.signed_qty);

        let quantity_builder = builder.reborrow().init_quantity();
        self.quantity.to_capnp(quantity_builder);

        let last_qty_builder = builder.reborrow().init_last_qty();
        self.last_qty.to_capnp(last_qty_builder);

        let last_px_builder = builder.reborrow().init_last_px();
        self.last_px.to_capnp(last_px_builder);

        let currency_builder = builder.reborrow().init_currency();
        self.currency.to_capnp(currency_builder);

        builder.set_avg_px_open(self.avg_px_open);

        self.realized_pnl
            .write_capnp(|| builder.reborrow().init_realized_pnl());

        let event_id_builder = builder.reborrow().init_event_id();
        self.event_id.to_capnp(event_id_builder);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);
    }
}

impl<'a> FromCapnp<'a> for PositionOpened {
    type Reader = position_capnp::position_opened::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let trader_id_reader = reader.get_trader_id()?;
        let trader_id = TraderId::from_capnp(trader_id_reader)?;

        let strategy_id_reader = reader.get_strategy_id()?;
        let strategy_id = StrategyId::from_capnp(strategy_id_reader)?;

        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let position_id_reader = reader.get_position_id()?;
        let position_id = PositionId::from_capnp(position_id_reader)?;

        let account_id_reader = reader.get_account_id()?;
        let account_id = AccountId::from_capnp(account_id_reader)?;

        let opening_order_id_reader = reader.get_opening_order_id()?;
        let opening_order_id = ClientOrderId::from_capnp(opening_order_id_reader)?;

        let entry = order_side_required_from_capnp(reader.get_entry()?)?;
        let side = position_side_required_from_capnp(reader.get_side()?)?;
        let signed_qty = reader.get_signed_qty();

        let quantity_reader = reader.get_quantity()?;
        let quantity = Quantity::from_capnp(quantity_reader)?;

        let last_qty_reader = reader.get_last_qty()?;
        let last_qty = Quantity::from_capnp(last_qty_reader)?;

        let last_px_reader = reader.get_last_px()?;
        let last_px = Price::from_capnp(last_px_reader)?;

        let currency_reader = reader.get_currency()?;
        let currency = Currency::from_capnp(currency_reader)?;

        let avg_px_open = reader.get_avg_px_open();

        let realized_pnl =
            read_optional_from_capnp(|| reader.has_realized_pnl(), || reader.get_realized_pnl())?;

        let event_id_reader = reader.get_event_id()?;
        let event_id = nautilus_core::UUID4::from_capnp(event_id_reader)?;

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        Ok(Self {
            trader_id,
            strategy_id,
            instrument_id,
            position_id,
            account_id,
            opening_order_id,
            entry,
            side,
            signed_qty,
            quantity,
            last_qty,
            last_px,
            currency,
            avg_px_open,
            realized_pnl,
            event_id,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
        })
    }
}

// PositionChanged
impl<'a> ToCapnp<'a> for PositionChanged {
    type Builder = position_capnp::position_changed::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let trader_id_builder = builder.reborrow().init_trader_id();
        self.trader_id.to_capnp(trader_id_builder);

        let strategy_id_builder = builder.reborrow().init_strategy_id();
        self.strategy_id.to_capnp(strategy_id_builder);

        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let position_id_builder = builder.reborrow().init_position_id();
        self.position_id.to_capnp(position_id_builder);

        let account_id_builder = builder.reborrow().init_account_id();
        self.account_id.to_capnp(account_id_builder);

        let opening_order_id_builder = builder.reborrow().init_opening_order_id();
        self.opening_order_id.to_capnp(opening_order_id_builder);

        builder.set_entry(order_side_to_capnp(self.entry.into()));
        builder.set_side(position_side_to_capnp(self.side.into()));
        builder.set_signed_qty(self.signed_qty);

        let quantity_builder = builder.reborrow().init_quantity();
        self.quantity.to_capnp(quantity_builder);

        let peak_quantity_builder = builder.reborrow().init_peak_quantity();
        self.peak_quantity.to_capnp(peak_quantity_builder);

        let last_qty_builder = builder.reborrow().init_last_qty();
        self.last_qty.to_capnp(last_qty_builder);

        let last_px_builder = builder.reborrow().init_last_px();
        self.last_px.to_capnp(last_px_builder);

        let currency_builder = builder.reborrow().init_currency();
        self.currency.to_capnp(currency_builder);

        builder.set_avg_px_open(self.avg_px_open);
        builder.set_avg_px_close(self.avg_px_close.unwrap_or(f64::NAN));
        builder.set_realized_return(self.realized_return);

        self.realized_pnl
            .write_capnp(|| builder.reborrow().init_realized_pnl());

        let unrealized_pnl_builder = builder.reborrow().init_unrealized_pnl();
        self.unrealized_pnl.to_capnp(unrealized_pnl_builder);

        let event_id_builder = builder.reborrow().init_event_id();
        self.event_id.to_capnp(event_id_builder);

        let mut ts_opened_builder = builder.reborrow().init_ts_opened();
        ts_opened_builder.set_value(*self.ts_opened);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);
    }
}

impl<'a> FromCapnp<'a> for PositionChanged {
    type Reader = position_capnp::position_changed::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let trader_id_reader = reader.get_trader_id()?;
        let trader_id = TraderId::from_capnp(trader_id_reader)?;

        let strategy_id_reader = reader.get_strategy_id()?;
        let strategy_id = StrategyId::from_capnp(strategy_id_reader)?;

        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let position_id_reader = reader.get_position_id()?;
        let position_id = PositionId::from_capnp(position_id_reader)?;

        let account_id_reader = reader.get_account_id()?;
        let account_id = AccountId::from_capnp(account_id_reader)?;

        let opening_order_id_reader = reader.get_opening_order_id()?;
        let opening_order_id = ClientOrderId::from_capnp(opening_order_id_reader)?;

        let entry = order_side_required_from_capnp(reader.get_entry()?)?;
        let side = position_side_required_from_capnp(reader.get_side()?)?;
        let signed_qty = reader.get_signed_qty();

        let quantity_reader = reader.get_quantity()?;
        let quantity = Quantity::from_capnp(quantity_reader)?;

        let peak_quantity_reader = reader.get_peak_quantity()?;
        let peak_quantity = Quantity::from_capnp(peak_quantity_reader)?;

        let last_qty_reader = reader.get_last_qty()?;
        let last_qty = Quantity::from_capnp(last_qty_reader)?;

        let last_px_reader = reader.get_last_px()?;
        let last_px = Price::from_capnp(last_px_reader)?;

        let currency_reader = reader.get_currency()?;
        let currency = Currency::from_capnp(currency_reader)?;

        let avg_px_open = reader.get_avg_px_open();
        let avg_px_close = {
            let value = reader.get_avg_px_close();
            if value.is_nan() { None } else { Some(value) }
        };
        let realized_return = reader.get_realized_return();

        let realized_pnl =
            read_optional_from_capnp(|| reader.has_realized_pnl(), || reader.get_realized_pnl())?;

        let unrealized_pnl_reader = reader.get_unrealized_pnl()?;
        let unrealized_pnl = Money::from_capnp(unrealized_pnl_reader)?;

        let event_id_reader = reader.get_event_id()?;
        let event_id = nautilus_core::UUID4::from_capnp(event_id_reader)?;

        let ts_opened_reader = reader.get_ts_opened()?;
        let ts_opened = ts_opened_reader.get_value();

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        Ok(Self {
            trader_id,
            strategy_id,
            instrument_id,
            position_id,
            account_id,
            opening_order_id,
            entry,
            side,
            signed_qty,
            quantity,
            peak_quantity,
            last_qty,
            last_px,
            currency,
            avg_px_open,
            avg_px_close,
            realized_return,
            realized_pnl,
            unrealized_pnl,
            event_id,
            ts_opened: ts_opened.into(),
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
        })
    }
}

// PositionClosed
impl<'a> ToCapnp<'a> for PositionClosed {
    type Builder = position_capnp::position_closed::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let trader_id_builder = builder.reborrow().init_trader_id();
        self.trader_id.to_capnp(trader_id_builder);

        let strategy_id_builder = builder.reborrow().init_strategy_id();
        self.strategy_id.to_capnp(strategy_id_builder);

        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let position_id_builder = builder.reborrow().init_position_id();
        self.position_id.to_capnp(position_id_builder);

        let account_id_builder = builder.reborrow().init_account_id();
        self.account_id.to_capnp(account_id_builder);

        let opening_order_id_builder = builder.reborrow().init_opening_order_id();
        self.opening_order_id.to_capnp(opening_order_id_builder);

        self.closing_order_id
            .write_capnp(|| builder.reborrow().init_closing_order_id());

        builder.set_entry(order_side_to_capnp(self.entry.into()));
        builder.set_side(position_side_to_capnp(self.side.into()));
        builder.set_signed_qty(self.signed_qty);

        let quantity_builder = builder.reborrow().init_quantity();
        self.quantity.to_capnp(quantity_builder);

        let peak_quantity_builder = builder.reborrow().init_peak_quantity();
        self.peak_quantity.to_capnp(peak_quantity_builder);

        let last_qty_builder = builder.reborrow().init_last_qty();
        self.last_qty.to_capnp(last_qty_builder);

        let last_px_builder = builder.reborrow().init_last_px();
        self.last_px.to_capnp(last_px_builder);

        let currency_builder = builder.reborrow().init_currency();
        self.currency.to_capnp(currency_builder);

        builder.set_avg_px_open(self.avg_px_open);
        builder.set_avg_px_close(self.avg_px_close.unwrap_or(f64::NAN));
        builder.set_realized_return(self.realized_return);

        self.realized_pnl
            .write_capnp(|| builder.reborrow().init_realized_pnl());

        let unrealized_pnl_builder = builder.reborrow().init_unrealized_pnl();
        self.unrealized_pnl.to_capnp(unrealized_pnl_builder);

        builder.set_duration(self.duration.as_u64());

        let event_id_builder = builder.reborrow().init_event_id();
        self.event_id.to_capnp(event_id_builder);

        let mut ts_opened_builder = builder.reborrow().init_ts_opened();
        ts_opened_builder.set_value(*self.ts_opened);

        if let Some(ts_closed) = self.ts_closed {
            let mut ts_closed_builder = builder.reborrow().init_ts_closed();
            ts_closed_builder.set_value(*ts_closed);
        }

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);
    }
}

impl<'a> FromCapnp<'a> for PositionClosed {
    type Reader = position_capnp::position_closed::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let trader_id_reader = reader.get_trader_id()?;
        let trader_id = TraderId::from_capnp(trader_id_reader)?;

        let strategy_id_reader = reader.get_strategy_id()?;
        let strategy_id = StrategyId::from_capnp(strategy_id_reader)?;

        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let position_id_reader = reader.get_position_id()?;
        let position_id = PositionId::from_capnp(position_id_reader)?;

        let account_id_reader = reader.get_account_id()?;
        let account_id = AccountId::from_capnp(account_id_reader)?;

        let opening_order_id_reader = reader.get_opening_order_id()?;
        let opening_order_id = ClientOrderId::from_capnp(opening_order_id_reader)?;

        let closing_order_id = read_optional_from_capnp(
            || reader.has_closing_order_id(),
            || reader.get_closing_order_id(),
        )?;

        let entry = order_side_required_from_capnp(reader.get_entry()?)?;
        let side = position_side_required_from_capnp(reader.get_side()?)?;
        let signed_qty = reader.get_signed_qty();

        let quantity_reader = reader.get_quantity()?;
        let quantity = Quantity::from_capnp(quantity_reader)?;

        let peak_quantity_reader = reader.get_peak_quantity()?;
        let peak_quantity = Quantity::from_capnp(peak_quantity_reader)?;

        let last_qty_reader = reader.get_last_qty()?;
        let last_qty = Quantity::from_capnp(last_qty_reader)?;

        let last_px_reader = reader.get_last_px()?;
        let last_px = Price::from_capnp(last_px_reader)?;

        let currency_reader = reader.get_currency()?;
        let currency = Currency::from_capnp(currency_reader)?;

        let avg_px_open = reader.get_avg_px_open();
        let avg_px_close = {
            let value = reader.get_avg_px_close();
            if value.is_nan() { None } else { Some(value) }
        };
        let realized_return = reader.get_realized_return();

        let realized_pnl =
            read_optional_from_capnp(|| reader.has_realized_pnl(), || reader.get_realized_pnl())?;

        let unrealized_pnl_reader = reader.get_unrealized_pnl()?;
        let unrealized_pnl = Money::from_capnp(unrealized_pnl_reader)?;

        let duration = DurationNanos::new(reader.get_duration());

        let event_id_reader = reader.get_event_id()?;
        let event_id = nautilus_core::UUID4::from_capnp(event_id_reader)?;

        let ts_opened_reader = reader.get_ts_opened()?;
        let ts_opened = ts_opened_reader.get_value();

        let ts_closed = if reader.has_ts_closed() {
            let ts_closed_reader = reader.get_ts_closed()?;
            Some(ts_closed_reader.get_value().into())
        } else {
            None
        };

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        Ok(Self {
            trader_id,
            strategy_id,
            instrument_id,
            position_id,
            account_id,
            opening_order_id,
            closing_order_id,
            entry,
            side,
            signed_qty,
            quantity,
            peak_quantity,
            last_qty,
            last_px,
            currency,
            avg_px_open,
            avg_px_close,
            realized_return,
            realized_pnl,
            unrealized_pnl,
            duration,
            event_id,
            ts_opened: ts_opened.into(),
            ts_closed,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
        })
    }
}

// PositionAdjusted
impl<'a> ToCapnp<'a> for PositionAdjusted {
    type Builder = position_capnp::position_adjusted::Builder<'a>;

    fn to_capnp(&self, mut builder: Self::Builder) {
        let trader_id_builder = builder.reborrow().init_trader_id();
        self.trader_id.to_capnp(trader_id_builder);

        let strategy_id_builder = builder.reborrow().init_strategy_id();
        self.strategy_id.to_capnp(strategy_id_builder);

        let instrument_id_builder = builder.reborrow().init_instrument_id();
        self.instrument_id.to_capnp(instrument_id_builder);

        let position_id_builder = builder.reborrow().init_position_id();
        self.position_id.to_capnp(position_id_builder);

        let account_id_builder = builder.reborrow().init_account_id();
        self.account_id.to_capnp(account_id_builder);

        builder.set_adjustment_type(position_adjustment_type_to_capnp(self.adjustment_type));

        self.quantity_change
            .write_capnp(|| builder.reborrow().init_quantity_change());

        self.pnl_change
            .write_capnp(|| builder.reborrow().init_pnl_change());

        if let Some(reason) = self.reason {
            builder.set_reason(reason.as_str());
        }

        let event_id_builder = builder.reborrow().init_event_id();
        self.event_id.to_capnp(event_id_builder);

        let mut ts_event_builder = builder.reborrow().init_ts_event();
        ts_event_builder.set_value(*self.ts_event);

        let mut ts_init_builder = builder.reborrow().init_ts_init();
        ts_init_builder.set_value(*self.ts_init);
    }
}

impl<'a> FromCapnp<'a> for PositionAdjusted {
    type Reader = position_capnp::position_adjusted::Reader<'a>;

    fn from_capnp(reader: Self::Reader) -> Result<Self, Box<dyn Error>> {
        let trader_id_reader = reader.get_trader_id()?;
        let trader_id = TraderId::from_capnp(trader_id_reader)?;

        let strategy_id_reader = reader.get_strategy_id()?;
        let strategy_id = StrategyId::from_capnp(strategy_id_reader)?;

        let instrument_id_reader = reader.get_instrument_id()?;
        let instrument_id = InstrumentId::from_capnp(instrument_id_reader)?;

        let position_id_reader = reader.get_position_id()?;
        let position_id = PositionId::from_capnp(position_id_reader)?;

        let account_id_reader = reader.get_account_id()?;
        let account_id = AccountId::from_capnp(account_id_reader)?;

        let adjustment_type = position_adjustment_type_from_capnp(reader.get_adjustment_type()?);

        let quantity_change = read_optional_from_capnp(
            || reader.has_quantity_change(),
            || reader.get_quantity_change(),
        )?;

        let pnl_change =
            read_optional_from_capnp(|| reader.has_pnl_change(), || reader.get_pnl_change())?;

        let reason = if reader.has_reason() {
            Some(Ustr::from(reader.get_reason()?.to_str()?))
        } else {
            None
        };

        let event_id_reader = reader.get_event_id()?;
        let event_id = nautilus_core::UUID4::from_capnp(event_id_reader)?;

        let ts_event_reader = reader.get_ts_event()?;
        let ts_event = ts_event_reader.get_value();

        let ts_init_reader = reader.get_ts_init()?;
        let ts_init = ts_init_reader.get_value();

        Ok(Self {
            trader_id,
            strategy_id,
            instrument_id,
            position_id,
            account_id,
            adjustment_type,
            quantity_change,
            pnl_change,
            reason,
            event_id,
            ts_event: ts_event.into(),
            ts_init: ts_init.into(),
        })
    }
}

#[cfg(test)]
mod tests {
    use capnp::message::Builder;
    use nautilus_core::{DurationNanos, UUID4, UnixNanos};
    use nautilus_model::{
        data::stubs::*,
        events::order::{
            spec::{OrderCanceledSpec, OrderFillVoidedSpec},
            stubs::*,
        },
    };
    use rstest::rstest;
    use rust_decimal::Decimal;
    use rust_decimal_macros::dec;

    use super::*;

    macro_rules! assert_capnp_roundtrip {
        ($value:expr, $builder:path, $reader:path, $ty:ty) => {{
            let expected: $ty = $value;
            let mut message = Builder::new_default();
            {
                let builder = message.init_root::<$builder>();
                expected.to_capnp(builder);
            }
            let reader = message
                .get_root_as_reader::<$reader>()
                .expect("capnp reader");
            let decoded = <$ty>::from_capnp(reader).expect("capnp decode");
            assert_eq!(expected, decoded);
        }};
    }

    macro_rules! capnp_simple_roundtrip_test {
        ($name:ident, $value:expr, $builder:path, $reader:path, $ty:ty) => {
            #[rstest]
            fn $name() {
                assert_capnp_roundtrip!($value, $builder, $reader, $ty);
            }
        };
    }

    macro_rules! order_fixture_roundtrip_test {
        ($name:ident, $fixture:ident, $ty:ty, $builder:path, $reader:path) => {
            #[rstest]
            fn $name($fixture: $ty) {
                assert_capnp_roundtrip!($fixture, $builder, $reader, $ty);
            }
        };
    }

    #[rstest]
    fn test_instrument_id_roundtrip() {
        let instrument_id = InstrumentId::from("AAPL.NASDAQ");
        let bytes = serialize_instrument_id(&instrument_id).unwrap();
        let decoded = deserialize_instrument_id(&bytes).unwrap();
        assert_eq!(instrument_id, decoded);
    }

    #[rstest]
    fn test_price_roundtrip() {
        let price = Price::from("123.45");
        let bytes = serialize_price(&price).unwrap();
        let decoded = deserialize_price(&bytes).unwrap();
        assert_eq!(price, decoded);
    }

    #[rstest]
    fn test_quantity_roundtrip() {
        let qty = Quantity::from("100.5");
        let bytes = serialize_quantity(&qty).unwrap();
        let decoded = deserialize_quantity(&bytes).unwrap();
        assert_eq!(qty, decoded);
    }

    #[rstest]
    fn test_currency_roundtrip() {
        let currency = Currency::USD();
        let bytes = serialize_currency(&currency).unwrap();
        let decoded = deserialize_currency(&bytes).unwrap();
        assert_currency_fields(currency, decoded);
    }

    #[rstest]
    fn test_currency_crypto_roundtrip() {
        let currency = Currency::BTC();
        let bytes = serialize_currency(&currency).unwrap();
        let decoded = deserialize_currency(&bytes).unwrap();
        assert_currency_fields(currency, decoded);
    }

    fn assert_currency_fields(expected: Currency, actual: Currency) {
        assert_eq!(actual.code, expected.code);
        assert_eq!(actual.precision, expected.precision);
        assert_eq!(actual.iso4217, expected.iso4217);
        assert_eq!(actual.name, expected.name);
        assert_eq!(actual.currency_type, expected.currency_type);
    }

    #[rstest]
    fn test_money_roundtrip() {
        let money = Money::from_raw(100_000_000, Currency::USD());
        let bytes = serialize_money(&money).unwrap();
        let decoded = deserialize_money(&bytes).unwrap();
        assert_eq!(money, decoded);
    }

    #[rstest]
    fn test_money_negative() {
        let money = Money::from_raw(-50_000_000, Currency::USD());
        let bytes = serialize_money(&money).unwrap();
        let decoded = deserialize_money(&bytes).unwrap();
        assert_eq!(money, decoded);
    }

    #[rstest]
    fn test_money_zero() {
        let money = Money::from_raw(0, Currency::USD());
        let bytes = serialize_money(&money).unwrap();
        let decoded = deserialize_money(&bytes).unwrap();
        assert_eq!(money, decoded);
    }

    #[rstest]
    fn test_decimal_serialization_layout() {
        let decimal = Decimal::from_parts(
            0x89ab_cdef,
            0x0123_4567,
            0x0fed_cba9,
            true, // negative to ensure sign bit set
            6,    // add some scale metadata
        );
        let mut message = capnp::message::Builder::new_default();
        {
            let builder = message.init_root::<types_capnp::decimal::Builder>();
            decimal.to_capnp(builder);
        }

        let reader = message
            .get_root_as_reader::<types_capnp::decimal::Reader>()
            .expect("reader");

        let serialized = decimal.serialize();
        let expected_flags = u32::from_le_bytes(serialized[0..4].try_into().expect("flags slice"));

        assert_eq!(reader.get_flags(), expected_flags);
        assert_eq!(reader.get_lo(), 0x89ab_cdef);
        assert_eq!(reader.get_mid(), 0x0123_4567);
        assert_eq!(reader.get_hi(), 0x0fed_cba9);
    }

    #[rstest]
    #[case::positive(false, 9)]
    #[case::negative(true, 9)]
    #[case::maximum_scale_positive(false, Decimal::MAX_SCALE)]
    #[case::maximum_scale_negative(true, Decimal::MAX_SCALE)]
    fn test_decimal_roundtrip_preserves_scale_and_sign(#[case] negative: bool, #[case] scale: u32) {
        let decimal = Decimal::from_parts(0xffff_ffff, 0x7fff_ffff, 0x0000_00ff, negative, scale);

        let mut message = capnp::message::Builder::new_default();
        {
            let builder = message.init_root::<types_capnp::decimal::Builder>();
            decimal.to_capnp(builder);
        }

        let reader = message
            .get_root_as_reader::<types_capnp::decimal::Reader>()
            .expect("reader");
        let decoded = Decimal::from_capnp(reader).expect("decoded decimal");
        assert_eq!(decimal, decoded);
        assert_eq!(decimal.serialize(), decoded.serialize());
    }

    #[rstest]
    fn test_account_balance_roundtrip() {
        let total = Money::new(100.0, Currency::USD());
        let locked = Money::new(10.0, Currency::USD());
        let free = Money::new(90.0, Currency::USD());
        let balance = AccountBalance::new(total, locked, free);
        let bytes = serialize_account_balance(&balance).unwrap();
        let decoded = deserialize_account_balance(&bytes).unwrap();
        assert_eq!(balance, decoded);
    }

    #[rstest]
    fn test_margin_balance_roundtrip() {
        let initial = Money::new(500.0, Currency::USD());
        let maintenance = Money::new(250.0, Currency::USD());
        let instrument_id = InstrumentId::from("BTC-USD-PERP.BINANCE");
        let balance = MarginBalance::new(initial, maintenance, Some(instrument_id));
        let bytes = serialize_margin_balance(&balance).unwrap();
        let decoded = deserialize_margin_balance(&bytes).unwrap();
        assert_eq!(balance, decoded);
    }

    #[rstest]
    fn test_margin_balance_account_scope_roundtrip() {
        let initial = Money::new(500.0, Currency::USD());
        let maintenance = Money::new(250.0, Currency::USD());
        let balance = MarginBalance::new(initial, maintenance, None);
        let bytes = serialize_margin_balance(&balance).unwrap();
        let decoded = deserialize_margin_balance(&bytes).unwrap();
        assert_eq!(balance, decoded);
        assert!(decoded.instrument_id.is_none());
    }

    // Identifier round-trip coverage
    capnp_simple_roundtrip_test!(
        trader_id_capnp_roundtrip,
        TraderId::from("TRADER-CAPNP"),
        identifiers_capnp::trader_id::Builder,
        identifiers_capnp::trader_id::Reader,
        TraderId
    );
    capnp_simple_roundtrip_test!(
        strategy_id_capnp_roundtrip,
        StrategyId::from("STRATEGY-CAPNP"),
        identifiers_capnp::strategy_id::Builder,
        identifiers_capnp::strategy_id::Reader,
        StrategyId
    );
    capnp_simple_roundtrip_test!(
        actor_id_capnp_roundtrip,
        ActorId::from("ACTOR-CAPNP"),
        identifiers_capnp::actor_id::Builder,
        identifiers_capnp::actor_id::Reader,
        ActorId
    );
    capnp_simple_roundtrip_test!(
        account_id_capnp_roundtrip,
        AccountId::from("ACCOUNT-CAPNP"),
        identifiers_capnp::account_id::Builder,
        identifiers_capnp::account_id::Reader,
        AccountId
    );
    capnp_simple_roundtrip_test!(
        client_id_capnp_roundtrip,
        ClientId::from("CLIENT-CAPNP"),
        identifiers_capnp::client_id::Builder,
        identifiers_capnp::client_id::Reader,
        ClientId
    );
    capnp_simple_roundtrip_test!(
        client_order_id_capnp_roundtrip,
        ClientOrderId::from("O-20240101-000000-001-001-1"),
        identifiers_capnp::client_order_id::Builder,
        identifiers_capnp::client_order_id::Reader,
        ClientOrderId
    );
    capnp_simple_roundtrip_test!(
        venue_order_id_capnp_roundtrip,
        VenueOrderId::from("V-ORDER-1"),
        identifiers_capnp::venue_order_id::Builder,
        identifiers_capnp::venue_order_id::Reader,
        VenueOrderId
    );
    capnp_simple_roundtrip_test!(
        trade_id_capnp_roundtrip,
        TradeId::from("TRADE-12345"),
        identifiers_capnp::trade_id::Builder,
        identifiers_capnp::trade_id::Reader,
        TradeId
    );
    capnp_simple_roundtrip_test!(
        position_id_capnp_roundtrip,
        PositionId::from("POSITION-1"),
        identifiers_capnp::position_id::Builder,
        identifiers_capnp::position_id::Reader,
        PositionId
    );
    capnp_simple_roundtrip_test!(
        exec_algorithm_id_capnp_roundtrip,
        ExecAlgorithmId::from("EXEC-1"),
        identifiers_capnp::exec_algorithm_id::Builder,
        identifiers_capnp::exec_algorithm_id::Reader,
        ExecAlgorithmId
    );
    capnp_simple_roundtrip_test!(
        component_id_capnp_roundtrip,
        ComponentId::from("COMPONENT-RISK"),
        identifiers_capnp::component_id::Builder,
        identifiers_capnp::component_id::Reader,
        ComponentId
    );
    capnp_simple_roundtrip_test!(
        order_list_id_capnp_roundtrip,
        OrderListId::from("LIST-1"),
        identifiers_capnp::order_list_id::Builder,
        identifiers_capnp::order_list_id::Reader,
        OrderListId
    );
    capnp_simple_roundtrip_test!(
        symbol_capnp_roundtrip,
        Symbol::from("ETH-PERP"),
        identifiers_capnp::symbol::Builder,
        identifiers_capnp::symbol::Reader,
        Symbol
    );
    capnp_simple_roundtrip_test!(
        venue_capnp_roundtrip,
        Venue::from("BINANCE"),
        identifiers_capnp::venue::Builder,
        identifiers_capnp::venue::Reader,
        Venue
    );
    capnp_simple_roundtrip_test!(
        uuid4_capnp_roundtrip,
        uuid4(),
        base_capnp::u_u_i_d4::Builder,
        base_capnp::u_u_i_d4::Reader,
        nautilus_core::UUID4
    );

    // Market data structures
    capnp_simple_roundtrip_test!(
        quote_tick_capnp_roundtrip,
        quote_ethusdt_binance(),
        market_capnp::quote_tick::Builder,
        market_capnp::quote_tick::Reader,
        QuoteTick
    );
    capnp_simple_roundtrip_test!(
        trade_tick_capnp_roundtrip,
        stub_trade_ethusdt_buy(),
        market_capnp::trade_tick::Builder,
        market_capnp::trade_tick::Reader,
        TradeTick
    );
    capnp_simple_roundtrip_test!(
        bar_specification_capnp_roundtrip,
        sample_bar_specification(),
        market_capnp::bar_spec::Builder,
        market_capnp::bar_spec::Reader,
        BarSpecification
    );
    capnp_simple_roundtrip_test!(
        bar_type_standard_capnp_roundtrip,
        sample_bar_type_standard(),
        market_capnp::bar_type::Builder,
        market_capnp::bar_type::Reader,
        BarType
    );
    capnp_simple_roundtrip_test!(
        bar_capnp_roundtrip,
        stub_bar(),
        market_capnp::bar::Builder,
        market_capnp::bar::Reader,
        Bar
    );
    capnp_simple_roundtrip_test!(
        book_order_capnp_roundtrip,
        stub_book_order(),
        market_capnp::book_order::Builder,
        market_capnp::book_order::Reader,
        BookOrder
    );
    capnp_simple_roundtrip_test!(
        order_book_delta_capnp_roundtrip,
        stub_delta(),
        market_capnp::order_book_delta::Builder,
        market_capnp::order_book_delta::Reader,
        OrderBookDelta
    );
    capnp_simple_roundtrip_test!(
        order_book_deltas_capnp_roundtrip,
        stub_deltas(),
        market_capnp::order_book_deltas::Builder,
        market_capnp::order_book_deltas::Reader,
        OrderBookDeltas
    );
    capnp_simple_roundtrip_test!(
        order_book_depth_capnp_roundtrip,
        sample_order_book_depth(),
        market_capnp::order_book_depth::Builder,
        market_capnp::order_book_depth::Reader,
        OrderBookDepth
    );
    capnp_simple_roundtrip_test!(
        mark_price_update_capnp_roundtrip,
        sample_mark_price_update(),
        market_capnp::mark_price_update::Builder,
        market_capnp::mark_price_update::Reader,
        MarkPriceUpdate
    );
    capnp_simple_roundtrip_test!(
        index_price_update_capnp_roundtrip,
        sample_index_price_update(),
        market_capnp::index_price_update::Builder,
        market_capnp::index_price_update::Reader,
        IndexPriceUpdate
    );
    capnp_simple_roundtrip_test!(
        funding_rate_update_capnp_roundtrip,
        sample_funding_rate_update(),
        market_capnp::funding_rate_update::Builder,
        market_capnp::funding_rate_update::Reader,
        FundingRateUpdate
    );
    capnp_simple_roundtrip_test!(
        option_greeks_capnp_roundtrip,
        sample_option_greeks(),
        market_capnp::option_greeks::Builder,
        market_capnp::option_greeks::Reader,
        OptionGreeks
    );
    capnp_simple_roundtrip_test!(
        option_greeks_black_scholes_zero_optional_capnp_roundtrip,
        sample_option_greeks_black_scholes_zero_optional(),
        market_capnp::option_greeks::Builder,
        market_capnp::option_greeks::Reader,
        OptionGreeks
    );
    capnp_simple_roundtrip_test!(
        instrument_close_capnp_roundtrip,
        stub_instrument_close(),
        market_capnp::instrument_close::Builder,
        market_capnp::instrument_close::Reader,
        InstrumentClose
    );
    capnp_simple_roundtrip_test!(
        instrument_status_capnp_roundtrip,
        sample_instrument_status_event(),
        market_capnp::instrument_status::Builder,
        market_capnp::instrument_status::Reader,
        InstrumentStatus
    );

    // Order-event coverage through fixtures
    order_fixture_roundtrip_test!(
        order_filled_capnp_roundtrip,
        order_filled,
        OrderFilled,
        order_capnp::order_filled::Builder,
        order_capnp::order_filled::Reader
    );
    capnp_simple_roundtrip_test!(
        order_fill_voided_capnp_roundtrip,
        OrderFillVoidedSpec::builder().is_reopened(true).build(),
        order_capnp::order_fill_voided::Builder,
        order_capnp::order_fill_voided::Reader,
        OrderFillVoided
    );
    capnp_simple_roundtrip_test!(
        order_fill_voided_populated_optionals_capnp_roundtrip,
        {
            let mut event = OrderFillVoidedSpec::builder()
                .voided_qty(Quantity::from("0.561000"))
                .commission_voided(Money::from("12.20000000 USDT"))
                .position_id(PositionId::from("P-001"))
                .reason(Ustr::from("VENUE_VOID"))
                .info(IndexMap::from([(Ustr::from("source"), Ustr::from("test"))]))
                .is_reopened(true)
                .build();
            event.causation_id = Some(UUID4::new());
            event
        },
        order_capnp::order_fill_voided::Builder,
        order_capnp::order_fill_voided::Reader,
        OrderFillVoided
    );
    order_fixture_roundtrip_test!(
        order_denied_capnp_roundtrip,
        order_denied_max_submitted_rate,
        OrderDenied,
        order_capnp::order_denied::Builder,
        order_capnp::order_denied::Reader
    );
    order_fixture_roundtrip_test!(
        order_rejected_capnp_roundtrip,
        order_rejected_insufficient_margin,
        OrderRejected,
        order_capnp::order_rejected::Builder,
        order_capnp::order_rejected::Reader
    );
    order_fixture_roundtrip_test!(
        order_initialized_capnp_roundtrip,
        order_initialized_buy_limit,
        OrderInitialized,
        order_capnp::order_initialized::Builder,
        order_capnp::order_initialized::Reader
    );
    #[rstest]
    fn order_initialized_activation_price_capnp_roundtrip(
        order_initialized_buy_limit: OrderInitialized,
    ) {
        let initialized = OrderInitialized {
            activation_price: Some(Price::from("21000")),
            ..order_initialized_buy_limit
        };
        assert_capnp_roundtrip!(
            initialized,
            order_capnp::order_initialized::Builder,
            order_capnp::order_initialized::Reader,
            OrderInitialized
        );
    }

    #[rstest]
    #[case::empty(false)]
    #[case::populated(true)]
    fn order_initialized_optional_collections_capnp_roundtrip(
        order_initialized_buy_limit: OrderInitialized,
        #[case] populated: bool,
    ) {
        let initialized = OrderInitialized {
            expire_time: Some(UnixNanos::from(123_456)),
            linked_order_ids: Some(if populated {
                vec![ClientOrderId::from("O-101"), ClientOrderId::from("O-202")]
            } else {
                vec![]
            }),
            exec_algorithm_params: Some(if populated {
                IndexMap::from([
                    (Ustr::from("interval"), Ustr::from("17")),
                    (Ustr::from("duration"), Ustr::from("53")),
                ])
            } else {
                IndexMap::new()
            }),
            tags: Some(if populated {
                vec![Ustr::from("first"), Ustr::from("second")]
            } else {
                vec![]
            }),
            ..order_initialized_buy_limit
        };

        let mut message = Builder::new_default();
        initialized.to_capnp(message.init_root::<order_capnp::order_initialized::Builder>());
        let reader = message
            .get_root_as_reader::<order_capnp::order_initialized::Reader>()
            .unwrap();
        let decoded = OrderInitialized::from_capnp(reader).unwrap();

        assert_eq!(
            serde_json::to_value(&decoded).unwrap(),
            serde_json::to_value(&initialized).unwrap()
        );
        assert_eq!(
            decoded
                .exec_algorithm_params
                .unwrap()
                .into_iter()
                .collect::<Vec<_>>(),
            initialized
                .exec_algorithm_params
                .unwrap()
                .into_iter()
                .collect::<Vec<_>>()
        );
    }

    #[rstest]
    fn order_filled_info_capnp_roundtrip(order_filled: OrderFilled) {
        let mut info = IndexMap::new();
        info.insert(Ustr::from("liquidation"), Ustr::from("true"));
        info.insert(Ustr::from("maker_order_id"), Ustr::from("ABC-123"));
        let filled = OrderFilled {
            info: Some(info),
            ..order_filled
        };
        assert_capnp_roundtrip!(
            filled,
            order_capnp::order_filled::Builder,
            order_capnp::order_filled::Reader,
            OrderFilled
        );
    }
    order_fixture_roundtrip_test!(
        order_submitted_capnp_roundtrip,
        order_submitted,
        OrderSubmitted,
        order_capnp::order_submitted::Builder,
        order_capnp::order_submitted::Reader
    );
    order_fixture_roundtrip_test!(
        order_triggered_capnp_roundtrip,
        order_triggered,
        OrderTriggered,
        order_capnp::order_triggered::Builder,
        order_capnp::order_triggered::Reader
    );
    order_fixture_roundtrip_test!(
        order_emulated_capnp_roundtrip,
        order_emulated,
        OrderEmulated,
        order_capnp::order_emulated::Builder,
        order_capnp::order_emulated::Reader
    );
    order_fixture_roundtrip_test!(
        order_released_capnp_roundtrip,
        order_released,
        OrderReleased,
        order_capnp::order_released::Builder,
        order_capnp::order_released::Reader
    );
    order_fixture_roundtrip_test!(
        order_updated_capnp_roundtrip,
        order_updated,
        OrderUpdated,
        order_capnp::order_updated::Builder,
        order_capnp::order_updated::Reader
    );
    order_fixture_roundtrip_test!(
        order_pending_update_capnp_roundtrip,
        order_pending_update,
        OrderPendingUpdate,
        order_capnp::order_pending_update::Builder,
        order_capnp::order_pending_update::Reader
    );
    order_fixture_roundtrip_test!(
        order_pending_cancel_capnp_roundtrip,
        order_pending_cancel,
        OrderPendingCancel,
        order_capnp::order_pending_cancel::Builder,
        order_capnp::order_pending_cancel::Reader
    );
    #[rstest]
    fn order_pending_update_none_account_capnp_roundtrip(order_pending_update: OrderPendingUpdate) {
        let event = OrderPendingUpdate {
            account_id: None,
            ..order_pending_update
        };
        assert_capnp_roundtrip!(
            event,
            order_capnp::order_pending_update::Builder,
            order_capnp::order_pending_update::Reader,
            OrderPendingUpdate
        );
    }
    #[rstest]
    fn order_pending_cancel_none_account_capnp_roundtrip(order_pending_cancel: OrderPendingCancel) {
        let event = OrderPendingCancel {
            account_id: None,
            ..order_pending_cancel
        };
        assert_capnp_roundtrip!(
            event,
            order_capnp::order_pending_cancel::Builder,
            order_capnp::order_pending_cancel::Reader,
            OrderPendingCancel
        );
    }
    order_fixture_roundtrip_test!(
        order_modify_rejected_capnp_roundtrip,
        order_modify_rejected,
        OrderModifyRejected,
        order_capnp::order_modify_rejected::Builder,
        order_capnp::order_modify_rejected::Reader
    );
    order_fixture_roundtrip_test!(
        order_accepted_capnp_roundtrip,
        order_accepted,
        OrderAccepted,
        order_capnp::order_accepted::Builder,
        order_capnp::order_accepted::Reader
    );
    order_fixture_roundtrip_test!(
        order_cancel_rejected_capnp_roundtrip,
        order_cancel_rejected,
        OrderCancelRejected,
        order_capnp::order_cancel_rejected::Builder,
        order_capnp::order_cancel_rejected::Reader
    );
    order_fixture_roundtrip_test!(
        order_expired_capnp_roundtrip,
        order_expired,
        OrderExpired,
        order_capnp::order_expired::Builder,
        order_capnp::order_expired::Reader
    );
    #[rstest]
    fn order_canceled_capnp_roundtrip() {
        assert_capnp_roundtrip!(
            sample_order_canceled(),
            order_capnp::order_canceled::Builder,
            order_capnp::order_canceled::Reader,
            OrderCanceled
        );
    }

    #[rstest]
    fn order_canceled_none_reason_capnp_roundtrip() {
        let event = OrderCanceled {
            reason: None,
            ..sample_order_canceled()
        };
        assert_capnp_roundtrip!(
            event,
            order_capnp::order_canceled::Builder,
            order_capnp::order_canceled::Reader,
            OrderCanceled
        );
    }

    // Position event coverage
    #[rstest]
    fn position_opened_capnp_roundtrip() {
        assert_capnp_roundtrip!(
            sample_position_opened(),
            position_capnp::position_opened::Builder,
            position_capnp::position_opened::Reader,
            PositionOpened
        );
    }

    #[rstest]
    fn position_opened_none_realized_pnl_capnp_roundtrip() {
        let event = PositionOpened {
            realized_pnl: None,
            ..sample_position_opened()
        };
        assert_capnp_roundtrip!(
            event,
            position_capnp::position_opened::Builder,
            position_capnp::position_opened::Reader,
            PositionOpened
        );
    }

    #[rstest]
    fn position_changed_capnp_roundtrip() {
        assert_capnp_roundtrip!(
            sample_position_changed(),
            position_capnp::position_changed::Builder,
            position_capnp::position_changed::Reader,
            PositionChanged
        );
    }

    #[rstest]
    fn position_closed_capnp_roundtrip() {
        assert_capnp_roundtrip!(
            sample_position_closed(),
            position_capnp::position_closed::Builder,
            position_capnp::position_closed::Reader,
            PositionClosed
        );
    }

    #[rstest]
    fn position_adjusted_capnp_roundtrip() {
        assert_capnp_roundtrip!(
            sample_position_adjusted(),
            position_capnp::position_adjusted::Builder,
            position_capnp::position_adjusted::Reader,
            PositionAdjusted
        );
    }

    fn sample_bar_specification() -> BarSpecification {
        BarSpecification::new(5, BarAggregation::Minute, PriceType::Last)
    }

    fn sample_bar_type_standard() -> BarType {
        BarType::new(
            InstrumentId::from("AUDUSD.SIM"),
            sample_bar_specification(),
            AggregationSource::External,
        )
    }

    fn sample_mark_price_update() -> MarkPriceUpdate {
        MarkPriceUpdate::new(
            InstrumentId::from("BTCUSD-PERP.BINANCE"),
            Price::from("42000.123"),
            UnixNanos::from(1),
            UnixNanos::from(2),
        )
    }

    fn sample_index_price_update() -> IndexPriceUpdate {
        IndexPriceUpdate::new(
            InstrumentId::from("BTCUSD-PERP.BINANCE"),
            Price::from("41950.500"),
            UnixNanos::from(3),
            UnixNanos::from(4),
        )
    }

    fn sample_funding_rate_update() -> FundingRateUpdate {
        FundingRateUpdate::new(
            InstrumentId::from("BTCUSD-PERP.BINANCE"),
            dec!(0.0001),
            Some(60),
            Some(UnixNanos::from(1_000_000)),
            UnixNanos::from(5),
            UnixNanos::from(6),
        )
    }

    fn sample_option_greeks() -> OptionGreeks {
        OptionGreeks {
            instrument_id: InstrumentId::from("BTC-30JUN23-40000-C.DERIBIT"),
            convention: GreeksConvention::PriceAdjusted,
            greeks: OptionGreekValues {
                delta: 0.525,
                gamma: 0.00032,
                vega: 12.25,
                theta: -0.72,
                rho: 0.18,
            },
            mark_iv: Some(0.52),
            bid_iv: None,
            ask_iv: Some(0.54),
            underlying_price: Some(41_500.25),
            open_interest: None,
            ts_event: UnixNanos::from(7),
            ts_init: UnixNanos::from(8),
        }
    }

    fn sample_option_greeks_black_scholes_zero_optional() -> OptionGreeks {
        OptionGreeks {
            instrument_id: InstrumentId::from("ETH-30JUN23-2000-C.DERIBIT"),
            convention: GreeksConvention::BlackScholes,
            greeks: OptionGreekValues {
                delta: 0.12,
                gamma: 0.002,
                vega: 8.0,
                theta: -0.45,
                rho: 0.06,
            },
            mark_iv: Some(0.0),
            bid_iv: Some(0.0),
            ask_iv: Some(0.0),
            underlying_price: Some(0.0),
            open_interest: Some(0.0),
            ts_event: UnixNanos::from(9),
            ts_init: UnixNanos::from(10),
        }
    }

    fn sample_instrument_status_event() -> InstrumentStatus {
        InstrumentStatus::new(
            InstrumentId::from("MSFT.XNAS"),
            MarketStatusAction::Trading,
            UnixNanos::from(1),
            UnixNanos::from(2),
            Some(Ustr::from("Normal trading")),
            Some(Ustr::from("MARKET_OPEN")),
            Some(true),
            Some(true),
            Some(false),
        )
    }

    fn sample_order_canceled() -> OrderCanceled {
        OrderCanceledSpec::builder()
            .strategy_id(strategy_id_ema_cross())
            .instrument_id(instrument_id_btc_usdt())
            .ts_event(UnixNanos::from(7))
            .ts_init(UnixNanos::from(8))
            .reconciliation(true)
            .venue_order_id(venue_order_id())
            .account_id(account_id())
            .reason(Ustr::from("not-enough-liquidity"))
            .build()
    }

    fn sample_order_book_depth() -> OrderBookDepth {
        const LEVELS: usize = 10;
        let instrument_id = InstrumentId::from("AAPL.XNAS");
        let mut bids = [BookOrder::default(); LEVELS];
        let mut asks = [BookOrder::default(); LEVELS];
        for i in 0..LEVELS {
            bids[i] = BookOrder::new(
                OrderSide::Buy,
                Price::new(100.0 - i as f64, 2),
                Quantity::new(1.0 + i as f64, 2),
                0,
            );
            asks[i] = BookOrder::new(
                OrderSide::Sell,
                Price::new(101.0 + i as f64, 2),
                Quantity::new(1.0 + i as f64, 2),
                0,
            );
        }
        let bid_counts = [1_u32; LEVELS];
        let ask_counts = [1_u32; LEVELS];
        OrderBookDepth::new(
            instrument_id,
            bids,
            asks,
            bid_counts,
            ask_counts,
            0,
            1,
            UnixNanos::from(9),
            UnixNanos::from(10),
        )
    }

    fn sample_position_opened() -> PositionOpened {
        PositionOpened {
            trader_id: trader_id(),
            strategy_id: strategy_id_ema_cross(),
            instrument_id: instrument_id_btc_usdt(),
            position_id: PositionId::from("P-OPEN"),
            account_id: account_id(),
            opening_order_id: client_order_id(),
            entry: OrderSide::Buy,
            side: PositionSide::Long,
            signed_qty: 100.0,
            quantity: Quantity::from("100"),
            last_qty: Quantity::from("100"),
            last_px: Price::from("20000"),
            currency: Currency::USD(),
            avg_px_open: 20000.0,
            realized_pnl: Some(Money::new(-0.5, Currency::USD())),
            event_id: uuid4(),
            ts_event: UnixNanos::from(9),
            ts_init: UnixNanos::from(10),
        }
    }

    fn sample_position_changed() -> PositionChanged {
        PositionChanged {
            trader_id: trader_id(),
            strategy_id: strategy_id_ema_cross(),
            instrument_id: instrument_id_btc_usdt(),
            position_id: PositionId::from("P-CHANGED"),
            account_id: account_id(),
            opening_order_id: client_order_id(),
            entry: OrderSide::Buy,
            side: PositionSide::Long,
            signed_qty: 150.0,
            quantity: Quantity::from("150"),
            peak_quantity: Quantity::from("175"),
            last_qty: Quantity::from("50"),
            last_px: Price::from("20100"),
            currency: Currency::USD(),
            avg_px_open: 19950.0,
            avg_px_close: Some(20100.0),
            realized_return: 0.01,
            realized_pnl: Some(Money::new(150.0, Currency::USD())),
            unrealized_pnl: Money::new(75.0, Currency::USD()),
            event_id: uuid4(),
            ts_opened: UnixNanos::from(11),
            ts_event: UnixNanos::from(12),
            ts_init: UnixNanos::from(13),
        }
    }

    fn sample_position_closed() -> PositionClosed {
        PositionClosed {
            trader_id: trader_id(),
            strategy_id: strategy_id_ema_cross(),
            instrument_id: instrument_id_btc_usdt(),
            position_id: PositionId::from("P-CLOSED"),
            account_id: account_id(),
            opening_order_id: client_order_id(),
            closing_order_id: Some(ClientOrderId::from("O-19700101-000000-001-001-9")),
            entry: OrderSide::Buy,
            side: PositionSide::Flat,
            signed_qty: 0.0,
            quantity: Quantity::from("0"),
            peak_quantity: Quantity::from("200"),
            last_qty: Quantity::from("200"),
            last_px: Price::from("20500"),
            currency: Currency::USD(),
            avg_px_open: 20000.0,
            avg_px_close: Some(20500.0),
            realized_return: 0.025,
            realized_pnl: Some(Money::new(1000.0, Currency::USD())),
            unrealized_pnl: Money::new(0.0, Currency::USD()),
            duration: DurationNanos::from_millis(1),
            event_id: uuid4(),
            ts_opened: UnixNanos::from(14),
            ts_closed: Some(UnixNanos::from(15)),
            ts_event: UnixNanos::from(15),
            ts_init: UnixNanos::from(16),
        }
    }

    fn sample_position_adjusted() -> PositionAdjusted {
        PositionAdjusted::new(
            trader_id(),
            strategy_id_ema_cross(),
            instrument_id_btc_usdt(),
            PositionId::from("P-ADJUST"),
            account_id(),
            PositionAdjustmentType::Funding,
            Some(dec!(-0.001)),
            Some(Money::new(-5.5, Currency::USD())),
            Some(Ustr::from("funding_2024-01-15")),
            uuid4(),
            UnixNanos::from(17),
            UnixNanos::from(18),
        )
    }
}