use crate::prelude::*;
use byteserde_derive::{ByteDeserializeSlice, ByteSerializeStack, ByteSerializedLenOf};
use serde::{Deserialize, Serialize};
#[derive(ByteSerializeStack, ByteDeserializeSlice, ByteSerializedLenOf, Serialize, Deserialize, PartialEq, Clone, Debug)]
#[byteserde(endian = "be")]
pub struct CancelPending {
#[serde(default, skip_serializing)]
packet_type: PacketTypeCancelPending,
pub timestamp: Timestamp, pub user_ref_number: UserRefNumber,
}
impl<T: CancelableOrder> From<&T> for CancelPending {
fn from(ord: &T) -> Self {
Self {
packet_type: PacketTypeCancelPending::default(),
timestamp: Timestamp::default(), user_ref_number: ord.user_ref_number(),
}
}
}
#[cfg(test)]
mod test {
use super::*;
use byteserde::prelude::*;
use links_core::unittest::setup;
use log::info;
use serde_json::{from_str, to_string};
use text_diff::{diff, print_diff};
#[test]
fn test_msg_byteserde() {
setup::log::configure_compact(log::LevelFilter::Info);
let enter_order = EnterOrder::default();
let msg_inp = CancelPending::from(&enter_order);
let ser: ByteSerializerStack<128> = to_serializer_stack(&msg_inp).unwrap();
info!("ser: {:#x}", ser);
let msg_out: CancelPending = from_serializer_stack(&ser).unwrap();
info!("msg_inp: {:?}", msg_inp);
info!("msg_out: {:?}", msg_out);
assert_eq!(msg_out, msg_inp);
}
#[test]
fn test_msg_serde() {
setup::log::configure_compact(log::LevelFilter::Info);
let enter_order = EnterOrder::default();
let mut msg_inp = CancelPending::from(&enter_order);
msg_inp.timestamp = 1.into();
let json_out = to_string(&msg_inp).unwrap();
let json_exp = r#"{"timestamp":1,"user_ref_number":1}"#;
info!("json_out: {}", json_out);
if matches!(diff(&json_out, json_exp, ","), (dist, _) if dist != 0) {
print_diff(&json_out, json_exp, ",");
assert_eq!(json_out, json_exp);
}
let msg_out: CancelPending = from_str(&json_out).unwrap();
assert_eq!(msg_out, msg_inp);
}
}