fixer-fix 0.10.1

Generated FIX protocol types for fixer
Documentation
// Code generated by fixer-gen. DO NOT EDIT.
#![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 jiff::Timestamp;

use crate::field;
use crate::tag;

/// `News` is the `fix40` `News` type, `MsgType` = B.
pub struct News {
    pub message: Message,
}

impl News {
    /// Creates a new `News` with required fields.
    pub fn new(lines_of_text: field::LinesOfTextField, text: field::TextField) -> Self {
        let mut msg = Message::new();
        msg.header.set_field(tag::MSG_TYPE, FIXString::from("B".to_string()));

        msg.body.set_field(tag::LINES_OF_TEXT, lines_of_text.0);

        msg.body.set_field(tag::TEXT, text.0);

        Self { message: msg }
    }

    /// Creates a `News` from an existing `Message`.
    pub fn from_message(msg: Message) -> Self {
        Self { message: msg }
    }

    /// Returns the underlying `Message`.
    pub fn to_message(self) -> Message {
        self.message
    }




    /// Sets `LinesOfText`, Tag 33.
    pub fn set_lines_of_text(&mut self, v: isize) {
        self.message.body.set_field(tag::LINES_OF_TEXT, fixer::fix_int::FIXInt::from(v));
    }

    /// Gets `LinesOfText`, Tag 33.
    pub fn get_lines_of_text(&self) -> Result<isize, MessageRejectErrorEnum> {
        let mut fld = field::LinesOfTextField::new(0);
        self.message.body.get_field(tag::LINES_OF_TEXT, &mut fld.0)?;
        Ok(fld.value())
    }


    /// Returns true if `LinesOfText` is present, Tag 33.
    pub fn has_lines_of_text(&self) -> bool {
        self.message.body.has(tag::LINES_OF_TEXT)
    }




    /// Sets `OrigTime`, Tag 42.
    pub fn set_orig_time(&mut self, v: Timestamp) {
        self.message.body.set_field(tag::ORIG_TIME, fixer::fix_utc_timestamp::FIXUTCTimestamp {
            time: v,
            precision: fixer::fix_utc_timestamp::TimestampPrecision::Millis,
        });
    }

    /// Gets `OrigTime`, Tag 42.
    pub fn get_orig_time(&self) -> Result<Timestamp, MessageRejectErrorEnum> {
        let mut fld = field::OrigTimeField::new(Timestamp::UNIX_EPOCH);
        self.message.body.get_field(tag::ORIG_TIME, &mut fld.0)?;
        Ok(fld.value())
    }


    /// Returns true if `OrigTime` is present, Tag 42.
    pub fn has_orig_time(&self) -> bool {
        self.message.body.has(tag::ORIG_TIME)
    }




    /// Sets `RawData`, Tag 96.
    pub fn set_raw_data(&mut self, v: String) {
        self.message.body.set_field(tag::RAW_DATA, FIXString::from(v));
    }

    /// Gets `RawData`, Tag 96.
    pub fn get_raw_data(&self) -> Result<String, MessageRejectErrorEnum> {
        let mut fld = field::RawDataField::new(String::new());
        self.message.body.get_field(tag::RAW_DATA, &mut fld.0)?;
        Ok(fld.value().to_string())
    }


    /// Returns true if `RawData` is present, Tag 96.
    pub fn has_raw_data(&self) -> bool {
        self.message.body.has(tag::RAW_DATA)
    }




    /// Sets `RawDataLength`, Tag 95.
    pub fn set_raw_data_length(&mut self, v: isize) {
        self.message.body.set_field(tag::RAW_DATA_LENGTH, fixer::fix_int::FIXInt::from(v));
    }

    /// Gets `RawDataLength`, Tag 95.
    pub fn get_raw_data_length(&self) -> Result<isize, MessageRejectErrorEnum> {
        let mut fld = field::RawDataLengthField::new(0);
        self.message.body.get_field(tag::RAW_DATA_LENGTH, &mut fld.0)?;
        Ok(fld.value())
    }


    /// Returns true if `RawDataLength` is present, Tag 95.
    pub fn has_raw_data_length(&self) -> bool {
        self.message.body.has(tag::RAW_DATA_LENGTH)
    }




    /// Sets `RelatdSym`, Tag 46.
    pub fn set_relatd_sym(&mut self, v: String) {
        self.message.body.set_field(tag::RELATD_SYM, FIXString::from(v));
    }

    /// Gets `RelatdSym`, Tag 46.
    pub fn get_relatd_sym(&self) -> Result<String, MessageRejectErrorEnum> {
        let mut fld = field::RelatdSymField::new(String::new());
        self.message.body.get_field(tag::RELATD_SYM, &mut fld.0)?;
        Ok(fld.value().to_string())
    }


    /// Returns true if `RelatdSym` is present, Tag 46.
    pub fn has_relatd_sym(&self) -> bool {
        self.message.body.has(tag::RELATD_SYM)
    }




    /// Sets `Text`, Tag 58.
    pub fn set_text(&mut self, v: String) {
        self.message.body.set_field(tag::TEXT, FIXString::from(v));
    }

    /// Gets `Text`, Tag 58.
    pub fn get_text(&self) -> Result<String, MessageRejectErrorEnum> {
        let mut fld = field::TextField::new(String::new());
        self.message.body.get_field(tag::TEXT, &mut fld.0)?;
        Ok(fld.value().to_string())
    }


    /// Returns true if `Text` is present, Tag 58.
    pub fn has_text(&self) -> bool {
        self.message.body.has(tag::TEXT)
    }




    /// Sets `Urgency`, Tag 61.
    pub fn set_urgency(&mut self, v: String) {
        self.message.body.set_field(tag::URGENCY, FIXString::from(v));
    }

    /// Gets `Urgency`, Tag 61.
    pub fn get_urgency(&self) -> Result<String, MessageRejectErrorEnum> {
        let mut fld = field::UrgencyField::new(String::new());
        self.message.body.get_field(tag::URGENCY, &mut fld.0)?;
        Ok(fld.value().to_string())
    }


    /// Returns true if `Urgency` is present, Tag 61.
    pub fn has_urgency(&self) -> bool {
        self.message.body.has(tag::URGENCY)
    }


}

/// `RouteOut` is the callback type for routing `News` messages.
pub type RouteOut = fn(msg: News, session_id: SessionID) -> Result<(), MessageRejectErrorEnum>;

/// Route type returned by the `route` function.
pub type Route = (&'static str, &'static str, Box<dyn Fn(&Message, SessionID) -> Result<(), MessageRejectErrorEnum> + Send>);

/// Returns the begin string, message type, and route function for `News`.
pub fn route(router: RouteOut) -> Route {
    let r = move |msg: &Message, session_id: SessionID| -> Result<(), MessageRejectErrorEnum> {
        router(News::from_message(msg.clone()), session_id)
    };
    ("FIX.4.0", "B", Box::new(r))
}