fixer_fix/fix41/
email.rs

1// Code generated by fixer-gen. DO NOT EDIT.
2#![allow(clippy::new_without_default)]
3#![allow(clippy::needless_pass_by_value)]
4#![allow(clippy::too_many_arguments)]
5#![allow(unused_imports)]
6
7use fixer::message::Message;
8use fixer::fix_string::FIXString;
9use fixer::errors::MessageRejectErrorEnum;
10use fixer::session::session_id::SessionID;
11
12
13use jiff::Timestamp;
14
15use crate::field;
16use crate::tag;
17
18/// `Email` is the `fix41` `Email` type, `MsgType` = C.
19pub struct Email {
20    pub message: Message,
21}
22
23impl Email {
24    /// Creates a new `Email` with required fields.
25    pub fn new(email_thread_id: field::EmailThreadIDField, email_type: field::EmailTypeField, subject: field::SubjectField, lines_of_text: field::LinesOfTextField) -> Self {
26        let mut msg = Message::new();
27        msg.header.set_field(tag::MSG_TYPE, FIXString::from("C".to_string()));
28
29        msg.body.set_field(tag::EMAIL_THREAD_ID, email_thread_id.0);
30
31        msg.body.set_field(tag::EMAIL_TYPE, email_type.0);
32
33        msg.body.set_field(tag::SUBJECT, subject.0);
34
35        msg.body.set_field(tag::LINES_OF_TEXT, lines_of_text.0);
36
37        Self { message: msg }
38    }
39
40    /// Creates a `Email` from an existing `Message`.
41    pub fn from_message(msg: Message) -> Self {
42        Self { message: msg }
43    }
44
45    /// Returns the underlying `Message`.
46    pub fn to_message(self) -> Message {
47        self.message
48    }
49
50
51
52
53    /// Sets `ClOrdID`, Tag 11.
54    pub fn set_cl_ord_id(&mut self, v: String) {
55        self.message.body.set_field(tag::CL_ORD_ID, FIXString::from(v));
56    }
57
58    /// Gets `ClOrdID`, Tag 11.
59    pub fn get_cl_ord_id(&self) -> Result<String, MessageRejectErrorEnum> {
60        let mut fld = field::ClOrdIDField::new(String::new());
61        self.message.body.get_field(tag::CL_ORD_ID, &mut fld.0)?;
62        Ok(fld.value().to_string())
63    }
64
65
66    /// Returns true if `ClOrdID` is present, Tag 11.
67    pub fn has_cl_ord_id(&self) -> bool {
68        self.message.body.has(tag::CL_ORD_ID)
69    }
70
71
72
73
74    /// Sets `EmailThreadID`, Tag 164.
75    pub fn set_email_thread_id(&mut self, v: String) {
76        self.message.body.set_field(tag::EMAIL_THREAD_ID, FIXString::from(v));
77    }
78
79    /// Gets `EmailThreadID`, Tag 164.
80    pub fn get_email_thread_id(&self) -> Result<String, MessageRejectErrorEnum> {
81        let mut fld = field::EmailThreadIDField::new(String::new());
82        self.message.body.get_field(tag::EMAIL_THREAD_ID, &mut fld.0)?;
83        Ok(fld.value().to_string())
84    }
85
86
87    /// Returns true if `EmailThreadID` is present, Tag 164.
88    pub fn has_email_thread_id(&self) -> bool {
89        self.message.body.has(tag::EMAIL_THREAD_ID)
90    }
91
92
93
94
95    /// Sets `EmailType`, Tag 94.
96    pub fn set_email_type(&mut self, v: String) {
97        self.message.body.set_field(tag::EMAIL_TYPE, FIXString::from(v));
98    }
99
100    /// Gets `EmailType`, Tag 94.
101    pub fn get_email_type(&self) -> Result<String, MessageRejectErrorEnum> {
102        let mut fld = field::EmailTypeField::new(String::new());
103        self.message.body.get_field(tag::EMAIL_TYPE, &mut fld.0)?;
104        Ok(fld.value().to_string())
105    }
106
107
108    /// Returns true if `EmailType` is present, Tag 94.
109    pub fn has_email_type(&self) -> bool {
110        self.message.body.has(tag::EMAIL_TYPE)
111    }
112
113
114
115
116    /// Sets `LinesOfText`, Tag 33.
117    pub fn set_lines_of_text(&mut self, v: isize) {
118        self.message.body.set_field(tag::LINES_OF_TEXT, fixer::fix_int::FIXInt::from(v));
119    }
120
121    /// Gets `LinesOfText`, Tag 33.
122    pub fn get_lines_of_text(&self) -> Result<isize, MessageRejectErrorEnum> {
123        let mut fld = field::LinesOfTextField::new(0);
124        self.message.body.get_field(tag::LINES_OF_TEXT, &mut fld.0)?;
125        Ok(fld.value())
126    }
127
128
129    /// Returns true if `LinesOfText` is present, Tag 33.
130    pub fn has_lines_of_text(&self) -> bool {
131        self.message.body.has(tag::LINES_OF_TEXT)
132    }
133
134
135
136
137    /// Sets `NoRelatedSym`, Tag 146.
138    pub fn set_no_related_sym(&mut self, v: isize) {
139        self.message.body.set_field(tag::NO_RELATED_SYM, fixer::fix_int::FIXInt::from(v));
140    }
141
142    /// Gets `NoRelatedSym`, Tag 146.
143    pub fn get_no_related_sym(&self) -> Result<isize, MessageRejectErrorEnum> {
144        let mut fld = field::NoRelatedSymField::new(0);
145        self.message.body.get_field(tag::NO_RELATED_SYM, &mut fld.0)?;
146        Ok(fld.value())
147    }
148
149
150    /// Returns true if `NoRelatedSym` is present, Tag 146.
151    pub fn has_no_related_sym(&self) -> bool {
152        self.message.body.has(tag::NO_RELATED_SYM)
153    }
154
155
156
157
158    /// Sets `OrderID`, Tag 37.
159    pub fn set_order_id(&mut self, v: String) {
160        self.message.body.set_field(tag::ORDER_ID, FIXString::from(v));
161    }
162
163    /// Gets `OrderID`, Tag 37.
164    pub fn get_order_id(&self) -> Result<String, MessageRejectErrorEnum> {
165        let mut fld = field::OrderIDField::new(String::new());
166        self.message.body.get_field(tag::ORDER_ID, &mut fld.0)?;
167        Ok(fld.value().to_string())
168    }
169
170
171    /// Returns true if `OrderID` is present, Tag 37.
172    pub fn has_order_id(&self) -> bool {
173        self.message.body.has(tag::ORDER_ID)
174    }
175
176
177
178
179    /// Sets `OrigTime`, Tag 42.
180    pub fn set_orig_time(&mut self, v: Timestamp) {
181        self.message.body.set_field(tag::ORIG_TIME, fixer::fix_utc_timestamp::FIXUTCTimestamp {
182            time: v,
183            precision: fixer::fix_utc_timestamp::TimestampPrecision::Millis,
184        });
185    }
186
187    /// Gets `OrigTime`, Tag 42.
188    pub fn get_orig_time(&self) -> Result<Timestamp, MessageRejectErrorEnum> {
189        let mut fld = field::OrigTimeField::new(Timestamp::UNIX_EPOCH);
190        self.message.body.get_field(tag::ORIG_TIME, &mut fld.0)?;
191        Ok(fld.value())
192    }
193
194
195    /// Returns true if `OrigTime` is present, Tag 42.
196    pub fn has_orig_time(&self) -> bool {
197        self.message.body.has(tag::ORIG_TIME)
198    }
199
200
201
202
203    /// Sets `RawData`, Tag 96.
204    pub fn set_raw_data(&mut self, v: String) {
205        self.message.body.set_field(tag::RAW_DATA, FIXString::from(v));
206    }
207
208    /// Gets `RawData`, Tag 96.
209    pub fn get_raw_data(&self) -> Result<String, MessageRejectErrorEnum> {
210        let mut fld = field::RawDataField::new(String::new());
211        self.message.body.get_field(tag::RAW_DATA, &mut fld.0)?;
212        Ok(fld.value().to_string())
213    }
214
215
216    /// Returns true if `RawData` is present, Tag 96.
217    pub fn has_raw_data(&self) -> bool {
218        self.message.body.has(tag::RAW_DATA)
219    }
220
221
222
223
224    /// Sets `RawDataLength`, Tag 95.
225    pub fn set_raw_data_length(&mut self, v: isize) {
226        self.message.body.set_field(tag::RAW_DATA_LENGTH, fixer::fix_int::FIXInt::from(v));
227    }
228
229    /// Gets `RawDataLength`, Tag 95.
230    pub fn get_raw_data_length(&self) -> Result<isize, MessageRejectErrorEnum> {
231        let mut fld = field::RawDataLengthField::new(0);
232        self.message.body.get_field(tag::RAW_DATA_LENGTH, &mut fld.0)?;
233        Ok(fld.value())
234    }
235
236
237    /// Returns true if `RawDataLength` is present, Tag 95.
238    pub fn has_raw_data_length(&self) -> bool {
239        self.message.body.has(tag::RAW_DATA_LENGTH)
240    }
241
242
243
244
245    /// Sets `Subject`, Tag 147.
246    pub fn set_subject(&mut self, v: String) {
247        self.message.body.set_field(tag::SUBJECT, FIXString::from(v));
248    }
249
250    /// Gets `Subject`, Tag 147.
251    pub fn get_subject(&self) -> Result<String, MessageRejectErrorEnum> {
252        let mut fld = field::SubjectField::new(String::new());
253        self.message.body.get_field(tag::SUBJECT, &mut fld.0)?;
254        Ok(fld.value().to_string())
255    }
256
257
258    /// Returns true if `Subject` is present, Tag 147.
259    pub fn has_subject(&self) -> bool {
260        self.message.body.has(tag::SUBJECT)
261    }
262
263
264}
265
266/// `RouteOut` is the callback type for routing `Email` messages.
267pub type RouteOut = fn(msg: Email, session_id: SessionID) -> Result<(), MessageRejectErrorEnum>;
268
269/// Route type returned by the `route` function.
270pub type Route = (&'static str, &'static str, Box<dyn Fn(&Message, SessionID) -> Result<(), MessageRejectErrorEnum> + Send>);
271
272/// Returns the begin string, message type, and route function for `Email`.
273pub fn route(router: RouteOut) -> Route {
274    let r = move |msg: &Message, session_id: SessionID| -> Result<(), MessageRejectErrorEnum> {
275        router(Email::from_message(msg.clone()), session_id)
276    };
277    ("FIX.4.1", "C", Box::new(r))
278}
fixer_fix/fix41/email.rs

fixer_fix/fix41/
email.rs
