#![allow(clippy::new_without_default)]
#![allow(clippy::needless_pass_by_value)]
#![allow(clippy::too_many_arguments)]
#![allow(unused_imports)]
use fixer::message::Message;
use fixer::fix_string::FIXString;
use fixer::errors::MessageRejectErrorEnum;
use fixer::session::session_id::SessionID;
use crate::field;
use crate::tag;
pub struct NewOrderList {
pub message: Message,
}
impl NewOrderList {
pub fn new(list_id: field::ListIDField, bid_type: field::BidTypeField, tot_no_orders: field::TotNoOrdersField, no_orders: field::NoOrdersField) -> Self {
let mut msg = Message::new();
msg.header.set_field(tag::MSG_TYPE, FIXString::from("E".to_string()));
msg.body.set_field(tag::LIST_ID, list_id.0);
msg.body.set_field(tag::BID_TYPE, bid_type.0);
msg.body.set_field(tag::TOT_NO_ORDERS, tot_no_orders.0);
msg.body.set_field(tag::NO_ORDERS, no_orders.0);
Self { message: msg }
}
pub fn from_message(msg: Message) -> Self {
Self { message: msg }
}
pub fn to_message(self) -> Message {
self.message
}
pub fn set_bid_id(&mut self, v: String) {
self.message.body.set_field(tag::BID_ID, FIXString::from(v));
}
pub fn get_bid_id(&self) -> Result<String, MessageRejectErrorEnum> {
let mut fld = field::BidIDField::new(String::new());
self.message.body.get_field(tag::BID_ID, &mut fld.0)?;
Ok(fld.value().to_string())
}
pub fn has_bid_id(&self) -> bool {
self.message.body.has(tag::BID_ID)
}
pub fn set_bid_type(&mut self, v: isize) {
self.message.body.set_field(tag::BID_TYPE, fixer::fix_int::FIXInt::from(v));
}
pub fn get_bid_type(&self) -> Result<isize, MessageRejectErrorEnum> {
let mut fld = field::BidTypeField::new(0);
self.message.body.get_field(tag::BID_TYPE, &mut fld.0)?;
Ok(fld.value())
}
pub fn has_bid_type(&self) -> bool {
self.message.body.has(tag::BID_TYPE)
}
pub fn set_cancellation_rights(&mut self, v: String) {
self.message.body.set_field(tag::CANCELLATION_RIGHTS, FIXString::from(v));
}
pub fn get_cancellation_rights(&self) -> Result<String, MessageRejectErrorEnum> {
let mut fld = field::CancellationRightsField::new(String::new());
self.message.body.get_field(tag::CANCELLATION_RIGHTS, &mut fld.0)?;
Ok(fld.value().to_string())
}
pub fn has_cancellation_rights(&self) -> bool {
self.message.body.has(tag::CANCELLATION_RIGHTS)
}
pub fn set_client_bid_id(&mut self, v: String) {
self.message.body.set_field(tag::CLIENT_BID_ID, FIXString::from(v));
}
pub fn get_client_bid_id(&self) -> Result<String, MessageRejectErrorEnum> {
let mut fld = field::ClientBidIDField::new(String::new());
self.message.body.get_field(tag::CLIENT_BID_ID, &mut fld.0)?;
Ok(fld.value().to_string())
}
pub fn has_client_bid_id(&self) -> bool {
self.message.body.has(tag::CLIENT_BID_ID)
}
pub fn set_encoded_list_exec_inst(&mut self, v: String) {
self.message.body.set_field(tag::ENCODED_LIST_EXEC_INST, FIXString::from(v));
}
pub fn get_encoded_list_exec_inst(&self) -> Result<String, MessageRejectErrorEnum> {
let mut fld = field::EncodedListExecInstField::new(String::new());
self.message.body.get_field(tag::ENCODED_LIST_EXEC_INST, &mut fld.0)?;
Ok(fld.value().to_string())
}
pub fn has_encoded_list_exec_inst(&self) -> bool {
self.message.body.has(tag::ENCODED_LIST_EXEC_INST)
}
pub fn set_encoded_list_exec_inst_len(&mut self, v: isize) {
self.message.body.set_field(tag::ENCODED_LIST_EXEC_INST_LEN, fixer::fix_int::FIXInt::from(v));
}
pub fn get_encoded_list_exec_inst_len(&self) -> Result<isize, MessageRejectErrorEnum> {
let mut fld = field::EncodedListExecInstLenField::new(0);
self.message.body.get_field(tag::ENCODED_LIST_EXEC_INST_LEN, &mut fld.0)?;
Ok(fld.value())
}
pub fn has_encoded_list_exec_inst_len(&self) -> bool {
self.message.body.has(tag::ENCODED_LIST_EXEC_INST_LEN)
}
pub fn set_list_exec_inst(&mut self, v: String) {
self.message.body.set_field(tag::LIST_EXEC_INST, FIXString::from(v));
}
pub fn get_list_exec_inst(&self) -> Result<String, MessageRejectErrorEnum> {
let mut fld = field::ListExecInstField::new(String::new());
self.message.body.get_field(tag::LIST_EXEC_INST, &mut fld.0)?;
Ok(fld.value().to_string())
}
pub fn has_list_exec_inst(&self) -> bool {
self.message.body.has(tag::LIST_EXEC_INST)
}
pub fn set_list_exec_inst_type(&mut self, v: String) {
self.message.body.set_field(tag::LIST_EXEC_INST_TYPE, FIXString::from(v));
}
pub fn get_list_exec_inst_type(&self) -> Result<String, MessageRejectErrorEnum> {
let mut fld = field::ListExecInstTypeField::new(String::new());
self.message.body.get_field(tag::LIST_EXEC_INST_TYPE, &mut fld.0)?;
Ok(fld.value().to_string())
}
pub fn has_list_exec_inst_type(&self) -> bool {
self.message.body.has(tag::LIST_EXEC_INST_TYPE)
}
pub fn set_list_id(&mut self, v: String) {
self.message.body.set_field(tag::LIST_ID, FIXString::from(v));
}
pub fn get_list_id(&self) -> Result<String, MessageRejectErrorEnum> {
let mut fld = field::ListIDField::new(String::new());
self.message.body.get_field(tag::LIST_ID, &mut fld.0)?;
Ok(fld.value().to_string())
}
pub fn has_list_id(&self) -> bool {
self.message.body.has(tag::LIST_ID)
}
pub fn set_money_laundering_status(&mut self, v: String) {
self.message.body.set_field(tag::MONEY_LAUNDERING_STATUS, FIXString::from(v));
}
pub fn get_money_laundering_status(&self) -> Result<String, MessageRejectErrorEnum> {
let mut fld = field::MoneyLaunderingStatusField::new(String::new());
self.message.body.get_field(tag::MONEY_LAUNDERING_STATUS, &mut fld.0)?;
Ok(fld.value().to_string())
}
pub fn has_money_laundering_status(&self) -> bool {
self.message.body.has(tag::MONEY_LAUNDERING_STATUS)
}
pub fn set_no_orders(&mut self, v: isize) {
self.message.body.set_field(tag::NO_ORDERS, fixer::fix_int::FIXInt::from(v));
}
pub fn get_no_orders(&self) -> Result<isize, MessageRejectErrorEnum> {
let mut fld = field::NoOrdersField::new(0);
self.message.body.get_field(tag::NO_ORDERS, &mut fld.0)?;
Ok(fld.value())
}
pub fn has_no_orders(&self) -> bool {
self.message.body.has(tag::NO_ORDERS)
}
pub fn set_prog_period_interval(&mut self, v: isize) {
self.message.body.set_field(tag::PROG_PERIOD_INTERVAL, fixer::fix_int::FIXInt::from(v));
}
pub fn get_prog_period_interval(&self) -> Result<isize, MessageRejectErrorEnum> {
let mut fld = field::ProgPeriodIntervalField::new(0);
self.message.body.get_field(tag::PROG_PERIOD_INTERVAL, &mut fld.0)?;
Ok(fld.value())
}
pub fn has_prog_period_interval(&self) -> bool {
self.message.body.has(tag::PROG_PERIOD_INTERVAL)
}
pub fn set_prog_rpt_reqs(&mut self, v: isize) {
self.message.body.set_field(tag::PROG_RPT_REQS, fixer::fix_int::FIXInt::from(v));
}
pub fn get_prog_rpt_reqs(&self) -> Result<isize, MessageRejectErrorEnum> {
let mut fld = field::ProgRptReqsField::new(0);
self.message.body.get_field(tag::PROG_RPT_REQS, &mut fld.0)?;
Ok(fld.value())
}
pub fn has_prog_rpt_reqs(&self) -> bool {
self.message.body.has(tag::PROG_RPT_REQS)
}
pub fn set_regist_id(&mut self, v: String) {
self.message.body.set_field(tag::REGIST_ID, FIXString::from(v));
}
pub fn get_regist_id(&self) -> Result<String, MessageRejectErrorEnum> {
let mut fld = field::RegistIDField::new(String::new());
self.message.body.get_field(tag::REGIST_ID, &mut fld.0)?;
Ok(fld.value().to_string())
}
pub fn has_regist_id(&self) -> bool {
self.message.body.has(tag::REGIST_ID)
}
pub fn set_tot_no_orders(&mut self, v: isize) {
self.message.body.set_field(tag::TOT_NO_ORDERS, fixer::fix_int::FIXInt::from(v));
}
pub fn get_tot_no_orders(&self) -> Result<isize, MessageRejectErrorEnum> {
let mut fld = field::TotNoOrdersField::new(0);
self.message.body.get_field(tag::TOT_NO_ORDERS, &mut fld.0)?;
Ok(fld.value())
}
pub fn has_tot_no_orders(&self) -> bool {
self.message.body.has(tag::TOT_NO_ORDERS)
}
}
pub type RouteOut = fn(msg: NewOrderList, session_id: SessionID) -> Result<(), MessageRejectErrorEnum>;
pub type Route = (&'static str, &'static str, Box<dyn Fn(&Message, SessionID) -> Result<(), MessageRejectErrorEnum> + Send>);
pub fn route(router: RouteOut) -> Route {
let r = move |msg: &Message, session_id: SessionID| -> Result<(), MessageRejectErrorEnum> {
router(NewOrderList::from_message(msg.clone()), session_id)
};
("FIX.4.3", "E", Box::new(r))
}