//! # Tests based on CQG's template //! //! See: https://help.cqg.com/apihelp/#!Documents/quotesdirectfixfast.htm //! use fastlib::{Encoder, JsonMessageFactory, TextMessageFactory, TextMessageVisitor}; use fastlib::Decoder; const DEFINITION: &str = include_str!("templates.xml"); fn do_tests_seq(raw: Vec>, data: Vec<&str>) { let mut e = Encoder::new_from_xml(DEFINITION).unwrap(); let mut d = Decoder::new_from_xml(DEFINITION).unwrap(); for (i, (raw, data)) in raw.into_iter().zip(data).enumerate() { let mut msg = TextMessageVisitor::from_text(data).unwrap(); let res = e.encode_vec(&mut msg).unwrap(); assert_eq!(res, raw, "encode failed #{}", i + 1); let mut msg = TextMessageFactory::new(); d.decode_vec(raw, &mut msg).unwrap(); assert_eq!(&msg.text, data, "decode failed #{}", i + 1); } } #[test] fn test_heartbeats() { do_tests_seq( vec![ vec![0xc0, 0x84, 0x81, 0x23, 0x7a, 0x17, 0x15, 0x15, 0x2c, 0x58, 0x80], vec![0x80, 0x82, 0x23, 0x7a, 0x17, 0x15, 0x15, 0x2d, 0x26, 0x90], vec![0x80, 0x83, 0x23, 0x7a, 0x17, 0x15, 0x15, 0x2d, 0x74, 0xa0], ], vec![ "MDHeartbeat=", "MDHeartbeat=", "MDHeartbeat=", ], ) } #[test] fn test_logon() { do_tests_seq( vec![ vec![0xc0, 0x85, 0x81, 0x23, 0x7a, 0x17, 0x15, 0x7a, 0x4d, 0x51, 0x9d, 0x8a], ], vec![ "MDLogon=", ], ) } #[test] fn test_loout() { do_tests_seq( vec![ vec![0xc0, 0x86, 0x83, 0x23, 0x7a, 0x1a, 0x19, 0x36, 0x3b, 0x5f, 0xc8, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x20, 0x74, 0x69, 0x6d, 0x65, 0x6f, 0x75, 0xf4], ], vec![ "MDLogout=", ], ) } #[test] fn test_definitions() { do_tests_seq( vec![ vec![0x7f, 0x57, 0xc0, 0x82, 0x07, 0xc4, 0x23, 0x7a, 0x17, 0x15, 0x7a, 0x4d, 0x59, 0x83, 0x07, 0xc6, 0x82, 0x80, 0x09, 0x53, 0x35, 0xe9, 0x00, 0x68, 0x73, 0x5e, 0x80, 0x4d, 0x42, 0x54, 0x53, 0x31, 0xb3, 0x4d, 0x42, 0x54, 0x53, 0x31, 0x33, 0x43, 0x31, 0x30, 0xb0, 0x4d, 0x69, 0x63, 0x72, 0x6f, 0x20, 0x42, 0x69, 0x74, 0x63, 0x6f, 0x69, 0x6e, 0x20, 0x52, 0x65, 0x76, 0x65, 0x72, 0x73, 0x65, 0x20, 0x43, 0x61, 0x6c, 0x20, 0x53, 0x70, 0x72, 0x65, 0x61, 0xe4, 0x4d, 0x42, 0x54, 0x53, 0x31, 0x33, 0x58, 0x32, 0xb4, 0x1c, 0x79, 0x58, 0xfe, 0x46, 0x58, 0x58, 0x58, 0x58, 0xd8, 0x47, 0x4c, 0x42, 0xd8, 0x46, 0x2e, 0x55, 0x53, 0x2e, 0x4d, 0x42, 0x54, 0x57, 0x31, 0x33, 0x58, 0x32, 0xb4, 0x81, 0x80, 0x55, 0x53, 0xc4, 0x83, 0x80, 0x80, 0xc0, 0x43, 0x51, 0x47, 0xc9, 0x81, 0x82, 0xc0, 0x07, 0xeb, 0x31, 0x30, 0xb0, 0x0c, 0x2d, 0xac, 0x81, 0x81, 0xff, 0x81, 0x81, 0x81, 0xb4, 0x84, 0x81, 0x32, 0x33, 0x39, 0x2e, 0x32, 0x34, 0x36, 0x2e, 0x35, 0x2e, 0xb4, 0x55, 0xfc, 0x82, 0x32, 0x33, 0x39, 0x2e, 0x32, 0x34, 0x36, 0x2e, 0x36, 0x2e, 0xb4, 0x5d, 0xe4, 0x83, 0x31, 0x30, 0x2e, 0x31, 0x2e, 0x30, 0x2e, 0x31, 0x32, 0xb0, 0x4e, 0x90, 0x83, 0x31, 0x30, 0x2e, 0x31, 0x2e, 0x30, 0x2e, 0x31, 0x32, 0xb0, 0x4e, 0x91, 0x86, 0x09, 0x53, 0x31, 0x93, 0x23, 0x7a, 0x14, 0x7a, 0x6e, 0x50, 0x46, 0x80, 0x23, 0x7a, 0x14, 0x7a, 0x6a, 0x49, 0x5f, 0xe0, 0x23, 0x7a, 0x14, 0x7e, 0x46, 0x59, 0x2d, 0x80, 0x23, 0x7a, 0x14, 0x7e, 0x46, 0x59, 0x2d, 0x80, 0x00, 0xc8, 0x02, 0x0c, 0x1c, 0x23, 0x20, 0x80, 0x02, 0x0c, 0x1c, 0x23, 0x20, 0x80, 0x02, 0x0c, 0x1c, 0x23, 0x20, 0x80, 0x02, 0x0c, 0x1c, 0x23, 0x20, 0x80, 0x81, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x81, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x81, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x81, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x80, 0x80, 0x80], vec![0x18, 0xc0, 0x07, 0xc5, 0x23, 0x7a, 0x17, 0x15, 0x7a, 0x4d, 0x59, 0x83, 0x82, 0x80, 0x7f, 0x98, 0x7b, 0x1d, 0x53, 0x80, 0x4d, 0x42, 0x54, 0x53, 0xb1, 0x4d, 0x42, 0x54, 0x53, 0x31, 0x43, 0x31, 0x30, 0xb0, 0x4d, 0x42, 0x54, 0x53, 0x31, 0x56, 0x32, 0xb4, 0x1c, 0x79, 0x58, 0xc1, 0x46, 0x2e, 0x55, 0x53, 0x2e, 0x4d, 0x42, 0x54, 0x57, 0x31, 0x56, 0x32, 0xb4, 0x81, 0x80, 0x83, 0x80, 0x80, 0xc0, 0x43, 0x51, 0x47, 0xc9, 0x81, 0x82, 0x80, 0x80, 0xff, 0x84, 0x81, 0x32, 0x33, 0x39, 0x2e, 0x32, 0x34, 0x36, 0x2e, 0x35, 0x2e, 0xb4, 0x55, 0xfc, 0x82, 0x32, 0x33, 0x39, 0x2e, 0x32, 0x34, 0x36, 0x2e, 0x36, 0x2e, 0xb4, 0x5d, 0xe4, 0x83, 0x31, 0x30, 0x2e, 0x31, 0x2e, 0x30, 0x2e, 0x31, 0x32, 0xb0, 0x4e, 0x90, 0x83, 0x31, 0x30, 0x2e, 0x31, 0x2e, 0x30, 0x2e, 0x31, 0x32, 0xb0, 0x4e, 0x91, 0x86, 0x7f, 0xb4, 0x7d, 0x64, 0x70, 0x30, 0x10, 0x80, 0x7d, 0x64, 0x70, 0x30, 0x10, 0x80, 0x7d, 0x64, 0x70, 0x30, 0x10, 0x80, 0x7d, 0x64, 0x70, 0x30, 0x10, 0x80, 0x00, 0xc8, 0x02, 0x0c, 0x1c, 0x23, 0x20, 0x80, 0x02, 0x0c, 0x1c, 0x23, 0x20, 0x80, 0x02, 0x0c, 0x1c, 0x23, 0x20, 0x80, 0x02, 0x0c, 0x1c, 0x23, 0x20, 0x80, 0x81, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x81, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x81, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x81, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x80, 0x80, 0x80], vec![0x00, 0xc0, 0x07, 0xc6, 0x23, 0x7a, 0x17, 0x15, 0x7a, 0x4d, 0x59, 0x83, 0x82, 0x80, 0x00, 0xe8, 0x04, 0x62, 0x2d, 0x80, 0x4d, 0x42, 0x54, 0x53, 0x31, 0x58, 0x32, 0xb4, 0x1c, 0x79, 0x58, 0xc0, 0x46, 0x2e, 0x55, 0x53, 0x2e, 0x4d, 0x42, 0x54, 0x57, 0x31, 0x58, 0x32, 0xb4, 0x81, 0x80, 0x83, 0x80, 0x80, 0xc0, 0x43, 0x51, 0x47, 0xc9, 0x81, 0x82, 0x80, 0x80, 0x82, 0x84, 0x81, 0x32, 0x33, 0x39, 0x2e, 0x32, 0x34, 0x36, 0x2e, 0x35, 0x2e, 0xb4, 0x55, 0xfc, 0x82, 0x32, 0x33, 0x39, 0x2e, 0x32, 0x34, 0x36, 0x2e, 0x36, 0x2e, 0xb4, 0x5d, 0xe4, 0x83, 0x31, 0x30, 0x2e, 0x31, 0x2e, 0x30, 0x2e, 0x31, 0x32, 0xb0, 0x4e, 0x90, 0x83, 0x31, 0x30, 0x2e, 0x31, 0x2e, 0x30, 0x2e, 0x31, 0x32, 0xb0, 0x4e, 0x91, 0x86, 0x7f, 0xb4, 0x7d, 0x64, 0x70, 0x30, 0x10, 0x80, 0x7d, 0x64, 0x70, 0x30, 0x10, 0x80, 0x7d, 0x64, 0x70, 0x30, 0x10, 0x80, 0x7d, 0x64, 0x70, 0x30, 0x10, 0x80, 0x00, 0xc8, 0x02, 0x0c, 0x1c, 0x23, 0x20, 0x80, 0x02, 0x0c, 0x1c, 0x23, 0x20, 0x80, 0x02, 0x0c, 0x1c, 0x23, 0x20, 0x80, 0x02, 0x0c, 0x1c, 0x23, 0x20, 0x80, 0x81, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x81, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x81, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x81, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x80, 0x80, 0x80], ], vec![ "MDSecurityDefinition=|SecurityGroup=MBTS13|Symbol=MBTS13C100|SecurityName=Micro Bitcoin Reverse Cal Spread|SecurityDesc=MBTS13X24|SecurityID=60714110|SecurityIDSource=100|CFICode=FXXXXX|SecurityExchange=GLBX|CQGSecurityName=F.US.MBTW13X24|StrikePrice=0|Currency=USD|MDFeedTypes=|InstrAttrib=|MaturityMonthYear=202411|MinPriceIncrement=1|MinPriceIncrementAmount=0.1|DisplayFactor=1|ApplID=4|Connections=|TradingSessions=>", "MDSecurityDefinition=|SecurityGroup=MBTS1|Symbol=MBTS1C100|SecurityName=Micro Bitcoin Reverse Cal Spread|SecurityDesc=MBTS1V24|SecurityID=60714049|SecurityIDSource=100|CFICode=FXXXXX|SecurityExchange=GLBX|CQGSecurityName=F.US.MBTW1V24|StrikePrice=0|Currency=USD|MDFeedTypes=|InstrAttrib=|MaturityMonthYear=202410|MinPriceIncrement=1|MinPriceIncrementAmount=0.1|DisplayFactor=1|ApplID=4|Connections=|TradingSessions=>", "MDSecurityDefinition=|SecurityGroup=MBTS1|Symbol=MBTS1C100|SecurityName=Micro Bitcoin Reverse Cal Spread|SecurityDesc=MBTS1X24|SecurityID=60714048|SecurityIDSource=100|CFICode=FXXXXX|SecurityExchange=GLBX|CQGSecurityName=F.US.MBTW1X24|StrikePrice=0|Currency=USD|MDFeedTypes=|InstrAttrib=|MaturityMonthYear=202411|MinPriceIncrement=1|MinPriceIncrementAmount=0.1|DisplayFactor=1|ApplID=4|Connections=|TradingSessions=>", ], ) } fn do_tests_seq_json(raw: Vec>, data: Vec<&str>) { let mut d = Decoder::new_from_xml(DEFINITION).unwrap(); for (i, (raw, data)) in raw.into_iter().zip(data).enumerate() { let mut msg = JsonMessageFactory::new(); d.decode_vec(raw, &mut msg).unwrap(); assert_eq!(&msg.json, data, "decode failed #{}", i + 1); } } #[test] fn test_messages_json() { do_tests_seq_json( vec![ vec![0xc0, 0x84, 0x81, 0x23, 0x7a, 0x17, 0x15, 0x15, 0x2c, 0x58, 0x80], vec![0xc0, 0x85, 0x81, 0x23, 0x7a, 0x17, 0x15, 0x7a, 0x4d, 0x51, 0x9d, 0x8a], vec![0x7f, 0x57, 0xc0, 0x82, 0x07, 0xc4, 0x23, 0x7a, 0x17, 0x15, 0x7a, 0x4d, 0x59, 0x83, 0x07, 0xc6, 0x82, 0x80, 0x09, 0x53, 0x35, 0xe9, 0x00, 0x68, 0x73, 0x5e, 0x80, 0x4d, 0x42, 0x54, 0x53, 0x31, 0xb3, 0x4d, 0x42, 0x54, 0x53, 0x31, 0x33, 0x43, 0x31, 0x30, 0xb0, 0x4d, 0x69, 0x63, 0x72, 0x6f, 0x20, 0x42, 0x69, 0x74, 0x63, 0x6f, 0x69, 0x6e, 0x20, 0x52, 0x65, 0x76, 0x65, 0x72, 0x73, 0x65, 0x20, 0x43, 0x61, 0x6c, 0x20, 0x53, 0x70, 0x72, 0x65, 0x61, 0xe4, 0x4d, 0x42, 0x54, 0x53, 0x31, 0x33, 0x58, 0x32, 0xb4, 0x1c, 0x79, 0x58, 0xfe, 0x46, 0x58, 0x58, 0x58, 0x58, 0xd8, 0x47, 0x4c, 0x42, 0xd8, 0x46, 0x2e, 0x55, 0x53, 0x2e, 0x4d, 0x42, 0x54, 0x57, 0x31, 0x33, 0x58, 0x32, 0xb4, 0x81, 0x80, 0x55, 0x53, 0xc4, 0x83, 0x80, 0x80, 0xc0, 0x43, 0x51, 0x47, 0xc9, 0x81, 0x82, 0xc0, 0x07, 0xeb, 0x31, 0x30, 0xb0, 0x0c, 0x2d, 0xac, 0x81, 0x81, 0xff, 0x81, 0x81, 0x81, 0xb4, 0x84, 0x81, 0x32, 0x33, 0x39, 0x2e, 0x32, 0x34, 0x36, 0x2e, 0x35, 0x2e, 0xb4, 0x55, 0xfc, 0x82, 0x32, 0x33, 0x39, 0x2e, 0x32, 0x34, 0x36, 0x2e, 0x36, 0x2e, 0xb4, 0x5d, 0xe4, 0x83, 0x31, 0x30, 0x2e, 0x31, 0x2e, 0x30, 0x2e, 0x31, 0x32, 0xb0, 0x4e, 0x90, 0x83, 0x31, 0x30, 0x2e, 0x31, 0x2e, 0x30, 0x2e, 0x31, 0x32, 0xb0, 0x4e, 0x91, 0x86, 0x09, 0x53, 0x31, 0x93, 0x23, 0x7a, 0x14, 0x7a, 0x6e, 0x50, 0x46, 0x80, 0x23, 0x7a, 0x14, 0x7a, 0x6a, 0x49, 0x5f, 0xe0, 0x23, 0x7a, 0x14, 0x7e, 0x46, 0x59, 0x2d, 0x80, 0x23, 0x7a, 0x14, 0x7e, 0x46, 0x59, 0x2d, 0x80, 0x00, 0xc8, 0x02, 0x0c, 0x1c, 0x23, 0x20, 0x80, 0x02, 0x0c, 0x1c, 0x23, 0x20, 0x80, 0x02, 0x0c, 0x1c, 0x23, 0x20, 0x80, 0x02, 0x0c, 0x1c, 0x23, 0x20, 0x80, 0x81, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x81, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x81, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x81, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x03, 0x5c, 0x6b, 0x14, 0x80, 0x80, 0x80, 0x80], ], vec![ r#"{"MDHeartbeat":{"MessageType":"0","ApplVerID":"8","SenderCompID":"CQG","MsgSeqNum":1,"SendingTime":20240606000000000}}"#, r#"{"MDLogon":{"MessageType":"A","ApplVerID":"8","SenderCompID":"CQG","MsgSeqNum":1,"SendingTime":20240606212352157,"EncryptMethod":0,"HeartbeatInt":10}}"#, r#"{"MDSecurityDefinition":{"MessageType":"d","ApplVerID":"8","SenderCompID":"CQG","MsgSeqNum":964,"SendingTime":20240606212353155,"TotNumReports":966,"Events":[{"EventType":7,"EventDate":20241129,"EventTime":220000000}],"SecurityGroup":"MBTS13","Symbol":"MBTS13C100","SecurityName":"Micro Bitcoin Reverse Cal Spread","SecurityDesc":"MBTS13X24","SecurityID":60714110,"SecurityIDSource":100,"CFICode":"FXXXXX","SecurityExchange":"GLBX","CQGSecurityName":"F.US.MBTW13X24","StrikePrice":0.0,"Currency":"USD","MDFeedTypes":[{"MDFeedType":"CQGC","MarketDepth":0},{"MDFeedType":"CQGI","MarketDepth":1}],"InstrAttrib":[{"InstrAttribType":1003,"InstrAttribValue":"100"}],"MaturityMonthYear":202411,"MinPriceIncrement":1.0,"MinPriceIncrementAmount":0.1,"DisplayFactor":1.0,"ApplID":"4","Connections":[{"ConnectionType":1,"ConnectionIPAddress":"239.246.5.4","ConnectionPortNumber":11004},{"ConnectionType":2,"ConnectionIPAddress":"239.246.6.4","ConnectionPortNumber":12004},{"ConnectionType":3,"ConnectionIPAddress":"10.1.0.120","ConnectionPortNumber":10000},{"ConnectionType":3,"ConnectionIPAddress":"10.1.0.120","ConnectionPortNumber":10001}],"TradingSessions":[{"TradeDate":20240531,"TradSesStartTime":20240530220000000,"TradSesOpenTime":20240530211500000,"TradSesCloseTime":20240531210000000,"TradSesEndTime":20240531210000000},{"TradeDate":20240603,"TradSesStartTime":20240602220000000,"TradSesOpenTime":20240602211500000,"TradSesCloseTime":20240603210000000,"TradSesEndTime":20240603210000000},{"TradeDate":20240604,"TradSesStartTime":20240603220000000,"TradSesOpenTime":20240603211500000,"TradSesCloseTime":20240604210000000,"TradSesEndTime":20240604210000000},{"TradeDate":20240605,"TradSesStartTime":20240604220000000,"TradSesOpenTime":20240604211500000,"TradSesCloseTime":20240605210000000,"TradSesEndTime":20240605210000000},{"TradeDate":20240606,"TradSesStartTime":20240605220000000,"TradSesOpenTime":20240605211500000,"TradSesCloseTime":20240606210000000,"TradSesEndTime":20240606210000000},{"TradeDate":20240607,"TradSesStartTime":20240606220000000,"TradSesOpenTime":20240606211500000,"TradSesCloseTime":20240607210000000,"TradSesEndTime":20240607210000000}]}}"#, ], ) }