fixer_fix/fix40/
advertisement.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
12use rust_decimal::Decimal;
13
14
15use jiff::Timestamp;
16
17use crate::field;
18use crate::tag;
19
20/// `Advertisement` is the `fix40` `Advertisement` type, `MsgType` = 7.
21pub struct Advertisement {
22    pub message: Message,
23}
24
25impl Advertisement {
26    /// Creates a new `Advertisement` with required fields.
27    pub fn new(adv_id: field::AdvIdField, adv_trans_type: field::AdvTransTypeField, symbol: field::SymbolField, adv_side: field::AdvSideField, shares: field::SharesField) -> Self {
28        let mut msg = Message::new();
29        msg.header.set_field(tag::MSG_TYPE, FIXString::from("7".to_string()));
30
31        msg.body.set_field(tag::ADV_ID, adv_id.0);
32
33        msg.body.set_field(tag::ADV_TRANS_TYPE, adv_trans_type.0);
34
35        msg.body.set_field(tag::SYMBOL, symbol.0);
36
37        msg.body.set_field(tag::ADV_SIDE, adv_side.0);
38
39        msg.body.set_field(tag::SHARES, shares.0);
40
41        Self { message: msg }
42    }
43
44    /// Creates a `Advertisement` from an existing `Message`.
45    pub fn from_message(msg: Message) -> Self {
46        Self { message: msg }
47    }
48
49    /// Returns the underlying `Message`.
50    pub fn to_message(self) -> Message {
51        self.message
52    }
53
54
55
56
57    /// Sets `AdvId`, Tag 2.
58    pub fn set_adv_id(&mut self, v: String) {
59        self.message.body.set_field(tag::ADV_ID, FIXString::from(v));
60    }
61
62    /// Gets `AdvId`, Tag 2.
63    pub fn get_adv_id(&self) -> Result<String, MessageRejectErrorEnum> {
64        let mut fld = field::AdvIdField::new(String::new());
65        self.message.body.get_field(tag::ADV_ID, &mut fld.0)?;
66        Ok(fld.value().to_string())
67    }
68
69
70    /// Returns true if `AdvId` is present, Tag 2.
71    pub fn has_adv_id(&self) -> bool {
72        self.message.body.has(tag::ADV_ID)
73    }
74
75
76
77
78    /// Sets `AdvRefID`, Tag 3.
79    pub fn set_adv_ref_id(&mut self, v: String) {
80        self.message.body.set_field(tag::ADV_REF_ID, FIXString::from(v));
81    }
82
83    /// Gets `AdvRefID`, Tag 3.
84    pub fn get_adv_ref_id(&self) -> Result<String, MessageRejectErrorEnum> {
85        let mut fld = field::AdvRefIDField::new(String::new());
86        self.message.body.get_field(tag::ADV_REF_ID, &mut fld.0)?;
87        Ok(fld.value().to_string())
88    }
89
90
91    /// Returns true if `AdvRefID` is present, Tag 3.
92    pub fn has_adv_ref_id(&self) -> bool {
93        self.message.body.has(tag::ADV_REF_ID)
94    }
95
96
97
98
99    /// Sets `AdvSide`, Tag 4.
100    pub fn set_adv_side(&mut self, v: String) {
101        self.message.body.set_field(tag::ADV_SIDE, FIXString::from(v));
102    }
103
104    /// Gets `AdvSide`, Tag 4.
105    pub fn get_adv_side(&self) -> Result<String, MessageRejectErrorEnum> {
106        let mut fld = field::AdvSideField::new(String::new());
107        self.message.body.get_field(tag::ADV_SIDE, &mut fld.0)?;
108        Ok(fld.value().to_string())
109    }
110
111
112    /// Returns true if `AdvSide` is present, Tag 4.
113    pub fn has_adv_side(&self) -> bool {
114        self.message.body.has(tag::ADV_SIDE)
115    }
116
117
118
119
120    /// Sets `AdvTransType`, Tag 5.
121    pub fn set_adv_trans_type(&mut self, v: String) {
122        self.message.body.set_field(tag::ADV_TRANS_TYPE, FIXString::from(v));
123    }
124
125    /// Gets `AdvTransType`, Tag 5.
126    pub fn get_adv_trans_type(&self) -> Result<String, MessageRejectErrorEnum> {
127        let mut fld = field::AdvTransTypeField::new(String::new());
128        self.message.body.get_field(tag::ADV_TRANS_TYPE, &mut fld.0)?;
129        Ok(fld.value().to_string())
130    }
131
132
133    /// Returns true if `AdvTransType` is present, Tag 5.
134    pub fn has_adv_trans_type(&self) -> bool {
135        self.message.body.has(tag::ADV_TRANS_TYPE)
136    }
137
138
139
140
141    /// Sets `Currency`, Tag 15.
142    pub fn set_currency(&mut self, v: String) {
143        self.message.body.set_field(tag::CURRENCY, FIXString::from(v));
144    }
145
146    /// Gets `Currency`, Tag 15.
147    pub fn get_currency(&self) -> Result<String, MessageRejectErrorEnum> {
148        let mut fld = field::CurrencyField::new(String::new());
149        self.message.body.get_field(tag::CURRENCY, &mut fld.0)?;
150        Ok(fld.value().to_string())
151    }
152
153
154    /// Returns true if `Currency` is present, Tag 15.
155    pub fn has_currency(&self) -> bool {
156        self.message.body.has(tag::CURRENCY)
157    }
158
159
160
161
162    /// Sets `IDSource`, Tag 22.
163    pub fn set_id_source(&mut self, v: String) {
164        self.message.body.set_field(tag::ID_SOURCE, FIXString::from(v));
165    }
166
167    /// Gets `IDSource`, Tag 22.
168    pub fn get_id_source(&self) -> Result<String, MessageRejectErrorEnum> {
169        let mut fld = field::IDSourceField::new(String::new());
170        self.message.body.get_field(tag::ID_SOURCE, &mut fld.0)?;
171        Ok(fld.value().to_string())
172    }
173
174
175    /// Returns true if `IDSource` is present, Tag 22.
176    pub fn has_id_source(&self) -> bool {
177        self.message.body.has(tag::ID_SOURCE)
178    }
179
180
181
182
183    /// Sets `Issuer`, Tag 106.
184    pub fn set_issuer(&mut self, v: String) {
185        self.message.body.set_field(tag::ISSUER, FIXString::from(v));
186    }
187
188    /// Gets `Issuer`, Tag 106.
189    pub fn get_issuer(&self) -> Result<String, MessageRejectErrorEnum> {
190        let mut fld = field::IssuerField::new(String::new());
191        self.message.body.get_field(tag::ISSUER, &mut fld.0)?;
192        Ok(fld.value().to_string())
193    }
194
195
196    /// Returns true if `Issuer` is present, Tag 106.
197    pub fn has_issuer(&self) -> bool {
198        self.message.body.has(tag::ISSUER)
199    }
200
201
202
203
204    /// Sets `Price`, Tag 44.
205    pub fn set_price(&mut self, val: Decimal, scale: i32) {
206        self.message.body.set_field(tag::PRICE, fixer::fix_decimal::FIXDecimal { decimal: val, scale });
207    }
208
209    /// Gets `Price`, Tag 44.
210    pub fn get_price(&self) -> Result<Decimal, MessageRejectErrorEnum> {
211        let mut fld = field::PriceField::new(Decimal::ZERO, 0);
212        self.message.body.get_field(tag::PRICE, &mut fld.0)?;
213        Ok(fld.value())
214    }
215
216
217    /// Returns true if `Price` is present, Tag 44.
218    pub fn has_price(&self) -> bool {
219        self.message.body.has(tag::PRICE)
220    }
221
222
223
224
225    /// Sets `SecurityDesc`, Tag 107.
226    pub fn set_security_desc(&mut self, v: String) {
227        self.message.body.set_field(tag::SECURITY_DESC, FIXString::from(v));
228    }
229
230    /// Gets `SecurityDesc`, Tag 107.
231    pub fn get_security_desc(&self) -> Result<String, MessageRejectErrorEnum> {
232        let mut fld = field::SecurityDescField::new(String::new());
233        self.message.body.get_field(tag::SECURITY_DESC, &mut fld.0)?;
234        Ok(fld.value().to_string())
235    }
236
237
238    /// Returns true if `SecurityDesc` is present, Tag 107.
239    pub fn has_security_desc(&self) -> bool {
240        self.message.body.has(tag::SECURITY_DESC)
241    }
242
243
244
245
246    /// Sets `SecurityID`, Tag 48.
247    pub fn set_security_id(&mut self, v: String) {
248        self.message.body.set_field(tag::SECURITY_ID, FIXString::from(v));
249    }
250
251    /// Gets `SecurityID`, Tag 48.
252    pub fn get_security_id(&self) -> Result<String, MessageRejectErrorEnum> {
253        let mut fld = field::SecurityIDField::new(String::new());
254        self.message.body.get_field(tag::SECURITY_ID, &mut fld.0)?;
255        Ok(fld.value().to_string())
256    }
257
258
259    /// Returns true if `SecurityID` is present, Tag 48.
260    pub fn has_security_id(&self) -> bool {
261        self.message.body.has(tag::SECURITY_ID)
262    }
263
264
265
266
267    /// Sets `Shares`, Tag 53.
268    pub fn set_shares(&mut self, val: Decimal, scale: i32) {
269        self.message.body.set_field(tag::SHARES, fixer::fix_decimal::FIXDecimal { decimal: val, scale });
270    }
271
272    /// Gets `Shares`, Tag 53.
273    pub fn get_shares(&self) -> Result<Decimal, MessageRejectErrorEnum> {
274        let mut fld = field::SharesField::new(Decimal::ZERO, 0);
275        self.message.body.get_field(tag::SHARES, &mut fld.0)?;
276        Ok(fld.value())
277    }
278
279
280    /// Returns true if `Shares` is present, Tag 53.
281    pub fn has_shares(&self) -> bool {
282        self.message.body.has(tag::SHARES)
283    }
284
285
286
287
288    /// Sets `Symbol`, Tag 55.
289    pub fn set_symbol(&mut self, v: String) {
290        self.message.body.set_field(tag::SYMBOL, FIXString::from(v));
291    }
292
293    /// Gets `Symbol`, Tag 55.
294    pub fn get_symbol(&self) -> Result<String, MessageRejectErrorEnum> {
295        let mut fld = field::SymbolField::new(String::new());
296        self.message.body.get_field(tag::SYMBOL, &mut fld.0)?;
297        Ok(fld.value().to_string())
298    }
299
300
301    /// Returns true if `Symbol` is present, Tag 55.
302    pub fn has_symbol(&self) -> bool {
303        self.message.body.has(tag::SYMBOL)
304    }
305
306
307
308
309    /// Sets `SymbolSfx`, Tag 65.
310    pub fn set_symbol_sfx(&mut self, v: String) {
311        self.message.body.set_field(tag::SYMBOL_SFX, FIXString::from(v));
312    }
313
314    /// Gets `SymbolSfx`, Tag 65.
315    pub fn get_symbol_sfx(&self) -> Result<String, MessageRejectErrorEnum> {
316        let mut fld = field::SymbolSfxField::new(String::new());
317        self.message.body.get_field(tag::SYMBOL_SFX, &mut fld.0)?;
318        Ok(fld.value().to_string())
319    }
320
321
322    /// Returns true if `SymbolSfx` is present, Tag 65.
323    pub fn has_symbol_sfx(&self) -> bool {
324        self.message.body.has(tag::SYMBOL_SFX)
325    }
326
327
328
329
330    /// Sets `Text`, Tag 58.
331    pub fn set_text(&mut self, v: String) {
332        self.message.body.set_field(tag::TEXT, FIXString::from(v));
333    }
334
335    /// Gets `Text`, Tag 58.
336    pub fn get_text(&self) -> Result<String, MessageRejectErrorEnum> {
337        let mut fld = field::TextField::new(String::new());
338        self.message.body.get_field(tag::TEXT, &mut fld.0)?;
339        Ok(fld.value().to_string())
340    }
341
342
343    /// Returns true if `Text` is present, Tag 58.
344    pub fn has_text(&self) -> bool {
345        self.message.body.has(tag::TEXT)
346    }
347
348
349
350
351    /// Sets `TransactTime`, Tag 60.
352    pub fn set_transact_time(&mut self, v: Timestamp) {
353        self.message.body.set_field(tag::TRANSACT_TIME, fixer::fix_utc_timestamp::FIXUTCTimestamp {
354            time: v,
355            precision: fixer::fix_utc_timestamp::TimestampPrecision::Millis,
356        });
357    }
358
359    /// Gets `TransactTime`, Tag 60.
360    pub fn get_transact_time(&self) -> Result<Timestamp, MessageRejectErrorEnum> {
361        let mut fld = field::TransactTimeField::new(Timestamp::UNIX_EPOCH);
362        self.message.body.get_field(tag::TRANSACT_TIME, &mut fld.0)?;
363        Ok(fld.value())
364    }
365
366
367    /// Returns true if `TransactTime` is present, Tag 60.
368    pub fn has_transact_time(&self) -> bool {
369        self.message.body.has(tag::TRANSACT_TIME)
370    }
371
372
373}
374
375/// `RouteOut` is the callback type for routing `Advertisement` messages.
376pub type RouteOut = fn(msg: Advertisement, session_id: SessionID) -> Result<(), MessageRejectErrorEnum>;
377
378/// Route type returned by the `route` function.
379pub type Route = (&'static str, &'static str, Box<dyn Fn(&Message, SessionID) -> Result<(), MessageRejectErrorEnum> + Send>);
380
381/// Returns the begin string, message type, and route function for `Advertisement`.
382pub fn route(router: RouteOut) -> Route {
383    let r = move |msg: &Message, session_id: SessionID| -> Result<(), MessageRejectErrorEnum> {
384        router(Advertisement::from_message(msg.clone()), session_id)
385    };
386    ("FIX.4.0", "7", Box::new(r))
387}
fixer_fix/fix40/advertisement.rs

fixer_fix/fix40/
advertisement.rs
