1#![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
12use rust_decimal::Decimal;
13
14
15use crate::field;
16use crate::tag;
17
18pub struct OrderStatusRequest {
20 pub message: Message,
21}
22
23impl OrderStatusRequest {
24 pub fn new(cl_ord_id: field::ClOrdIDField, symbol: field::SymbolField, side: field::SideField) -> Self {
26 let mut msg = Message::new();
27 msg.header.set_field(tag::MSG_TYPE, FIXString::from("H".to_string()));
28
29 msg.body.set_field(tag::CL_ORD_ID, cl_ord_id.0);
30
31 msg.body.set_field(tag::SYMBOL, symbol.0);
32
33 msg.body.set_field(tag::SIDE, side.0);
34
35 Self { message: msg }
36 }
37
38 pub fn from_message(msg: Message) -> Self {
40 Self { message: msg }
41 }
42
43 pub fn to_message(self) -> Message {
45 self.message
46 }
47
48
49
50
51 pub fn set_cl_ord_id(&mut self, v: String) {
53 self.message.body.set_field(tag::CL_ORD_ID, FIXString::from(v));
54 }
55
56 pub fn get_cl_ord_id(&self) -> Result<String, MessageRejectErrorEnum> {
58 let mut fld = field::ClOrdIDField::new(String::new());
59 self.message.body.get_field(tag::CL_ORD_ID, &mut fld.0)?;
60 Ok(fld.value().to_string())
61 }
62
63
64 pub fn has_cl_ord_id(&self) -> bool {
66 self.message.body.has(tag::CL_ORD_ID)
67 }
68
69
70
71
72 pub fn set_client_id(&mut self, v: String) {
74 self.message.body.set_field(tag::CLIENT_ID, FIXString::from(v));
75 }
76
77 pub fn get_client_id(&self) -> Result<String, MessageRejectErrorEnum> {
79 let mut fld = field::ClientIDField::new(String::new());
80 self.message.body.get_field(tag::CLIENT_ID, &mut fld.0)?;
81 Ok(fld.value().to_string())
82 }
83
84
85 pub fn has_client_id(&self) -> bool {
87 self.message.body.has(tag::CLIENT_ID)
88 }
89
90
91
92
93 pub fn set_exec_broker(&mut self, v: String) {
95 self.message.body.set_field(tag::EXEC_BROKER, FIXString::from(v));
96 }
97
98 pub fn get_exec_broker(&self) -> Result<String, MessageRejectErrorEnum> {
100 let mut fld = field::ExecBrokerField::new(String::new());
101 self.message.body.get_field(tag::EXEC_BROKER, &mut fld.0)?;
102 Ok(fld.value().to_string())
103 }
104
105
106 pub fn has_exec_broker(&self) -> bool {
108 self.message.body.has(tag::EXEC_BROKER)
109 }
110
111
112
113
114 pub fn set_id_source(&mut self, v: String) {
116 self.message.body.set_field(tag::ID_SOURCE, FIXString::from(v));
117 }
118
119 pub fn get_id_source(&self) -> Result<String, MessageRejectErrorEnum> {
121 let mut fld = field::IDSourceField::new(String::new());
122 self.message.body.get_field(tag::ID_SOURCE, &mut fld.0)?;
123 Ok(fld.value().to_string())
124 }
125
126
127 pub fn has_id_source(&self) -> bool {
129 self.message.body.has(tag::ID_SOURCE)
130 }
131
132
133
134
135 pub fn set_issuer(&mut self, v: String) {
137 self.message.body.set_field(tag::ISSUER, FIXString::from(v));
138 }
139
140 pub fn get_issuer(&self) -> Result<String, MessageRejectErrorEnum> {
142 let mut fld = field::IssuerField::new(String::new());
143 self.message.body.get_field(tag::ISSUER, &mut fld.0)?;
144 Ok(fld.value().to_string())
145 }
146
147
148 pub fn has_issuer(&self) -> bool {
150 self.message.body.has(tag::ISSUER)
151 }
152
153
154
155
156 pub fn set_maturity_day(&mut self, v: isize) {
158 self.message.body.set_field(tag::MATURITY_DAY, fixer::fix_int::FIXInt::from(v));
159 }
160
161 pub fn get_maturity_day(&self) -> Result<isize, MessageRejectErrorEnum> {
163 let mut fld = field::MaturityDayField::new(0);
164 self.message.body.get_field(tag::MATURITY_DAY, &mut fld.0)?;
165 Ok(fld.value())
166 }
167
168
169 pub fn has_maturity_day(&self) -> bool {
171 self.message.body.has(tag::MATURITY_DAY)
172 }
173
174
175
176
177 pub fn set_maturity_month_year(&mut self, v: String) {
179 self.message.body.set_field(tag::MATURITY_MONTH_YEAR, FIXString::from(v));
180 }
181
182 pub fn get_maturity_month_year(&self) -> Result<String, MessageRejectErrorEnum> {
184 let mut fld = field::MaturityMonthYearField::new(String::new());
185 self.message.body.get_field(tag::MATURITY_MONTH_YEAR, &mut fld.0)?;
186 Ok(fld.value().to_string())
187 }
188
189
190 pub fn has_maturity_month_year(&self) -> bool {
192 self.message.body.has(tag::MATURITY_MONTH_YEAR)
193 }
194
195
196
197
198 pub fn set_opt_attribute(&mut self, v: String) {
200 self.message.body.set_field(tag::OPT_ATTRIBUTE, FIXString::from(v));
201 }
202
203 pub fn get_opt_attribute(&self) -> Result<String, MessageRejectErrorEnum> {
205 let mut fld = field::OptAttributeField::new(String::new());
206 self.message.body.get_field(tag::OPT_ATTRIBUTE, &mut fld.0)?;
207 Ok(fld.value().to_string())
208 }
209
210
211 pub fn has_opt_attribute(&self) -> bool {
213 self.message.body.has(tag::OPT_ATTRIBUTE)
214 }
215
216
217
218
219 pub fn set_order_id(&mut self, v: String) {
221 self.message.body.set_field(tag::ORDER_ID, FIXString::from(v));
222 }
223
224 pub fn get_order_id(&self) -> Result<String, MessageRejectErrorEnum> {
226 let mut fld = field::OrderIDField::new(String::new());
227 self.message.body.get_field(tag::ORDER_ID, &mut fld.0)?;
228 Ok(fld.value().to_string())
229 }
230
231
232 pub fn has_order_id(&self) -> bool {
234 self.message.body.has(tag::ORDER_ID)
235 }
236
237
238
239
240 pub fn set_put_or_call(&mut self, v: isize) {
242 self.message.body.set_field(tag::PUT_OR_CALL, fixer::fix_int::FIXInt::from(v));
243 }
244
245 pub fn get_put_or_call(&self) -> Result<isize, MessageRejectErrorEnum> {
247 let mut fld = field::PutOrCallField::new(0);
248 self.message.body.get_field(tag::PUT_OR_CALL, &mut fld.0)?;
249 Ok(fld.value())
250 }
251
252
253 pub fn has_put_or_call(&self) -> bool {
255 self.message.body.has(tag::PUT_OR_CALL)
256 }
257
258
259
260
261 pub fn set_security_desc(&mut self, v: String) {
263 self.message.body.set_field(tag::SECURITY_DESC, FIXString::from(v));
264 }
265
266 pub fn get_security_desc(&self) -> Result<String, MessageRejectErrorEnum> {
268 let mut fld = field::SecurityDescField::new(String::new());
269 self.message.body.get_field(tag::SECURITY_DESC, &mut fld.0)?;
270 Ok(fld.value().to_string())
271 }
272
273
274 pub fn has_security_desc(&self) -> bool {
276 self.message.body.has(tag::SECURITY_DESC)
277 }
278
279
280
281
282 pub fn set_security_exchange(&mut self, v: String) {
284 self.message.body.set_field(tag::SECURITY_EXCHANGE, FIXString::from(v));
285 }
286
287 pub fn get_security_exchange(&self) -> Result<String, MessageRejectErrorEnum> {
289 let mut fld = field::SecurityExchangeField::new(String::new());
290 self.message.body.get_field(tag::SECURITY_EXCHANGE, &mut fld.0)?;
291 Ok(fld.value().to_string())
292 }
293
294
295 pub fn has_security_exchange(&self) -> bool {
297 self.message.body.has(tag::SECURITY_EXCHANGE)
298 }
299
300
301
302
303 pub fn set_security_id(&mut self, v: String) {
305 self.message.body.set_field(tag::SECURITY_ID, FIXString::from(v));
306 }
307
308 pub fn get_security_id(&self) -> Result<String, MessageRejectErrorEnum> {
310 let mut fld = field::SecurityIDField::new(String::new());
311 self.message.body.get_field(tag::SECURITY_ID, &mut fld.0)?;
312 Ok(fld.value().to_string())
313 }
314
315
316 pub fn has_security_id(&self) -> bool {
318 self.message.body.has(tag::SECURITY_ID)
319 }
320
321
322
323
324 pub fn set_security_type(&mut self, v: String) {
326 self.message.body.set_field(tag::SECURITY_TYPE, FIXString::from(v));
327 }
328
329 pub fn get_security_type(&self) -> Result<String, MessageRejectErrorEnum> {
331 let mut fld = field::SecurityTypeField::new(String::new());
332 self.message.body.get_field(tag::SECURITY_TYPE, &mut fld.0)?;
333 Ok(fld.value().to_string())
334 }
335
336
337 pub fn has_security_type(&self) -> bool {
339 self.message.body.has(tag::SECURITY_TYPE)
340 }
341
342
343
344
345 pub fn set_side(&mut self, v: String) {
347 self.message.body.set_field(tag::SIDE, FIXString::from(v));
348 }
349
350 pub fn get_side(&self) -> Result<String, MessageRejectErrorEnum> {
352 let mut fld = field::SideField::new(String::new());
353 self.message.body.get_field(tag::SIDE, &mut fld.0)?;
354 Ok(fld.value().to_string())
355 }
356
357
358 pub fn has_side(&self) -> bool {
360 self.message.body.has(tag::SIDE)
361 }
362
363
364
365
366 pub fn set_strike_price(&mut self, val: Decimal, scale: i32) {
368 self.message.body.set_field(tag::STRIKE_PRICE, fixer::fix_decimal::FIXDecimal { decimal: val, scale });
369 }
370
371 pub fn get_strike_price(&self) -> Result<Decimal, MessageRejectErrorEnum> {
373 let mut fld = field::StrikePriceField::new(Decimal::ZERO, 0);
374 self.message.body.get_field(tag::STRIKE_PRICE, &mut fld.0)?;
375 Ok(fld.value())
376 }
377
378
379 pub fn has_strike_price(&self) -> bool {
381 self.message.body.has(tag::STRIKE_PRICE)
382 }
383
384
385
386
387 pub fn set_symbol(&mut self, v: String) {
389 self.message.body.set_field(tag::SYMBOL, FIXString::from(v));
390 }
391
392 pub fn get_symbol(&self) -> Result<String, MessageRejectErrorEnum> {
394 let mut fld = field::SymbolField::new(String::new());
395 self.message.body.get_field(tag::SYMBOL, &mut fld.0)?;
396 Ok(fld.value().to_string())
397 }
398
399
400 pub fn has_symbol(&self) -> bool {
402 self.message.body.has(tag::SYMBOL)
403 }
404
405
406
407
408 pub fn set_symbol_sfx(&mut self, v: String) {
410 self.message.body.set_field(tag::SYMBOL_SFX, FIXString::from(v));
411 }
412
413 pub fn get_symbol_sfx(&self) -> Result<String, MessageRejectErrorEnum> {
415 let mut fld = field::SymbolSfxField::new(String::new());
416 self.message.body.get_field(tag::SYMBOL_SFX, &mut fld.0)?;
417 Ok(fld.value().to_string())
418 }
419
420
421 pub fn has_symbol_sfx(&self) -> bool {
423 self.message.body.has(tag::SYMBOL_SFX)
424 }
425
426
427}
428
429pub type RouteOut = fn(msg: OrderStatusRequest, session_id: SessionID) -> Result<(), MessageRejectErrorEnum>;
431
432pub type Route = (&'static str, &'static str, Box<dyn Fn(&Message, SessionID) -> Result<(), MessageRejectErrorEnum> + Send>);
434
435pub fn route(router: RouteOut) -> Route {
437 let r = move |msg: &Message, session_id: SessionID| -> Result<(), MessageRejectErrorEnum> {
438 router(OrderStatusRequest::from_message(msg.clone()), session_id)
439 };
440 ("FIX.4.1", "H", Box::new(r))
441}