nautilus_model/events/order/
submitted.rs1use std::fmt::{Debug, Display};
17
18use derive_builder::Builder;
19use nautilus_core::{UUID4, UnixNanos};
20use rust_decimal::Decimal;
21use serde::{Deserialize, Serialize};
22use ustr::Ustr;
23
24use crate::{
25 enums::{
26 ContingencyType, LiquiditySide, OrderSide, OrderType, TimeInForce, TrailingOffsetType,
27 TriggerType,
28 },
29 events::OrderEvent,
30 identifiers::{
31 AccountId, ClientOrderId, ExecAlgorithmId, InstrumentId, OrderListId, PositionId,
32 StrategyId, TradeId, TraderId, VenueOrderId,
33 },
34 types::{Currency, Money, Price, Quantity},
35};
36
37#[repr(C)]
40#[derive(Clone, Copy, PartialEq, Eq, Default, Serialize, Deserialize, Builder)]
41#[builder(default)]
42#[serde(tag = "type")]
43#[cfg_attr(
44 feature = "python",
45 pyo3::pyclass(module = "nautilus_trader.core.nautilus_pyo3.model")
46)]
47pub struct OrderSubmitted {
48 pub trader_id: TraderId,
50 pub strategy_id: StrategyId,
52 pub instrument_id: InstrumentId,
54 pub client_order_id: ClientOrderId,
56 pub account_id: AccountId,
58 pub event_id: UUID4,
60 pub ts_event: UnixNanos,
62 pub ts_init: UnixNanos,
64}
65
66impl OrderSubmitted {
67 #[allow(clippy::too_many_arguments)]
69 pub fn new(
70 trader_id: TraderId,
71 strategy_id: StrategyId,
72 instrument_id: InstrumentId,
73 client_order_id: ClientOrderId,
74 account_id: AccountId,
75 event_id: UUID4,
76 ts_event: UnixNanos,
77 ts_init: UnixNanos,
78 ) -> Self {
79 Self {
80 trader_id,
81 strategy_id,
82 instrument_id,
83 client_order_id,
84 account_id,
85 event_id,
86 ts_event,
87 ts_init,
88 }
89 }
90}
91
92impl Debug for OrderSubmitted {
93 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
94 write!(
95 f,
96 "{}(trader_id={}, strategy_id={}, instrument_id={}, client_order_id={}, account_id={}, event_id={}, ts_event={}, ts_init={})",
97 stringify!(OrderSubmitted),
98 self.trader_id,
99 self.strategy_id,
100 self.instrument_id,
101 self.client_order_id,
102 self.account_id,
103 self.event_id,
104 self.ts_event,
105 self.ts_init
106 )
107 }
108}
109
110impl Display for OrderSubmitted {
111 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
112 write!(
113 f,
114 "{}(instrument_id={}, client_order_id={}, account_id={}, ts_event={})",
115 stringify!(OrderSubmitted),
116 self.instrument_id,
117 self.client_order_id,
118 self.account_id,
119 self.ts_event
120 )
121 }
122}
123
124impl OrderEvent for OrderSubmitted {
125 fn id(&self) -> UUID4 {
126 self.event_id
127 }
128
129 fn kind(&self) -> &str {
130 stringify!(OrderSubmitted)
131 }
132
133 fn order_type(&self) -> Option<OrderType> {
134 None
135 }
136
137 fn order_side(&self) -> Option<OrderSide> {
138 None
139 }
140
141 fn trader_id(&self) -> TraderId {
142 self.trader_id
143 }
144
145 fn strategy_id(&self) -> StrategyId {
146 self.strategy_id
147 }
148
149 fn instrument_id(&self) -> InstrumentId {
150 self.instrument_id
151 }
152
153 fn trade_id(&self) -> Option<TradeId> {
154 None
155 }
156
157 fn currency(&self) -> Option<Currency> {
158 None
159 }
160
161 fn client_order_id(&self) -> ClientOrderId {
162 self.client_order_id
163 }
164
165 fn reason(&self) -> Option<Ustr> {
166 None
167 }
168
169 fn quantity(&self) -> Option<Quantity> {
170 None
171 }
172
173 fn time_in_force(&self) -> Option<TimeInForce> {
174 None
175 }
176
177 fn liquidity_side(&self) -> Option<LiquiditySide> {
178 None
179 }
180
181 fn post_only(&self) -> Option<bool> {
182 None
183 }
184
185 fn reduce_only(&self) -> Option<bool> {
186 None
187 }
188
189 fn quote_quantity(&self) -> Option<bool> {
190 None
191 }
192
193 fn reconciliation(&self) -> bool {
194 false
195 }
196
197 fn price(&self) -> Option<Price> {
198 None
199 }
200
201 fn last_px(&self) -> Option<Price> {
202 None
203 }
204
205 fn last_qty(&self) -> Option<Quantity> {
206 None
207 }
208
209 fn trigger_price(&self) -> Option<Price> {
210 None
211 }
212
213 fn trigger_type(&self) -> Option<TriggerType> {
214 None
215 }
216
217 fn limit_offset(&self) -> Option<Decimal> {
218 None
219 }
220
221 fn trailing_offset(&self) -> Option<Decimal> {
222 None
223 }
224
225 fn trailing_offset_type(&self) -> Option<TrailingOffsetType> {
226 None
227 }
228
229 fn expire_time(&self) -> Option<UnixNanos> {
230 None
231 }
232
233 fn display_qty(&self) -> Option<Quantity> {
234 None
235 }
236
237 fn emulation_trigger(&self) -> Option<TriggerType> {
238 None
239 }
240
241 fn trigger_instrument_id(&self) -> Option<InstrumentId> {
242 None
243 }
244
245 fn contingency_type(&self) -> Option<ContingencyType> {
246 None
247 }
248
249 fn order_list_id(&self) -> Option<OrderListId> {
250 None
251 }
252
253 fn linked_order_ids(&self) -> Option<Vec<ClientOrderId>> {
254 None
255 }
256
257 fn parent_order_id(&self) -> Option<ClientOrderId> {
258 None
259 }
260
261 fn exec_algorithm_id(&self) -> Option<ExecAlgorithmId> {
262 None
263 }
264
265 fn exec_spawn_id(&self) -> Option<ClientOrderId> {
266 None
267 }
268
269 fn venue_order_id(&self) -> Option<VenueOrderId> {
270 None
271 }
272
273 fn account_id(&self) -> Option<AccountId> {
274 Some(self.account_id)
275 }
276
277 fn position_id(&self) -> Option<PositionId> {
278 None
279 }
280
281 fn commission(&self) -> Option<Money> {
282 None
283 }
284
285 fn ts_event(&self) -> UnixNanos {
286 self.ts_event
287 }
288
289 fn ts_init(&self) -> UnixNanos {
290 self.ts_init
291 }
292}
293
294#[cfg(test)]
299mod tests {
300 use nautilus_core::UnixNanos;
301 use rstest::rstest;
302
303 use super::*;
304 use crate::{
305 events::order::stubs::*,
306 identifiers::{AccountId, ClientOrderId, InstrumentId, StrategyId, TraderId},
307 };
308
309 fn create_test_order_submitted() -> OrderSubmitted {
310 OrderSubmitted::new(
311 TraderId::from("TRADER-001"),
312 StrategyId::from("EMA-CROSS"),
313 InstrumentId::from("EURUSD.SIM"),
314 ClientOrderId::from("O-19700101-000000-001-001-1"),
315 AccountId::from("SIM-001"),
316 Default::default(),
317 UnixNanos::from(1_000_000_000),
318 UnixNanos::from(2_000_000_000),
319 )
320 }
321
322 #[rstest]
323 fn test_order_submitted_new() {
324 let order_submitted = create_test_order_submitted();
325
326 assert_eq!(order_submitted.trader_id, TraderId::from("TRADER-001"));
327 assert_eq!(order_submitted.strategy_id, StrategyId::from("EMA-CROSS"));
328 assert_eq!(
329 order_submitted.instrument_id,
330 InstrumentId::from("EURUSD.SIM")
331 );
332 assert_eq!(
333 order_submitted.client_order_id,
334 ClientOrderId::from("O-19700101-000000-001-001-1")
335 );
336 assert_eq!(order_submitted.account_id, AccountId::from("SIM-001"));
337 assert_eq!(order_submitted.ts_event, UnixNanos::from(1_000_000_000));
338 assert_eq!(order_submitted.ts_init, UnixNanos::from(2_000_000_000));
339 }
340
341 #[rstest]
342 fn test_order_submitted_clone() {
343 let order_submitted1 = create_test_order_submitted();
344 let order_submitted2 = order_submitted1;
345
346 assert_eq!(order_submitted1, order_submitted2);
347 }
348
349 #[rstest]
350 fn test_order_submitted_debug() {
351 let order_submitted = create_test_order_submitted();
352 let debug_str = format!("{order_submitted:?}");
353
354 assert!(debug_str.contains("OrderSubmitted"));
355 assert!(debug_str.contains("TRADER-001"));
356 assert!(debug_str.contains("EMA-CROSS"));
357 assert!(debug_str.contains("EURUSD.SIM"));
358 assert!(debug_str.contains("O-19700101-000000-001-001-1"));
359 }
360
361 #[rstest]
362 fn test_order_rejected_display(order_submitted: OrderSubmitted) {
363 let display = format!("{order_submitted}");
364 assert_eq!(
365 display,
366 "OrderSubmitted(instrument_id=BTCUSDT.COINBASE, client_order_id=O-19700101-000000-001-001-1, account_id=SIM-001, ts_event=0)"
367 );
368 }
369
370 #[rstest]
371 fn test_order_submitted_partial_eq() {
372 let order_submitted1 = create_test_order_submitted();
373 let mut order_submitted2 = create_test_order_submitted();
374 order_submitted2.event_id = order_submitted1.event_id; let mut order_submitted3 = create_test_order_submitted();
376 order_submitted3.client_order_id = ClientOrderId::from("O-19700101-000000-001-001-2");
377
378 assert_eq!(order_submitted1, order_submitted2);
379 assert_ne!(order_submitted1, order_submitted3);
380 }
381
382 #[rstest]
383 fn test_order_submitted_default() {
384 let order_submitted = OrderSubmitted::default();
385
386 assert_eq!(order_submitted.trader_id, TraderId::default());
387 assert_eq!(order_submitted.strategy_id, StrategyId::default());
388 assert_eq!(order_submitted.instrument_id, InstrumentId::default());
389 assert_eq!(order_submitted.client_order_id, ClientOrderId::default());
390 assert_eq!(order_submitted.account_id, AccountId::default());
391 }
392
393 #[rstest]
394 fn test_order_submitted_order_event_trait() {
395 let order_submitted = create_test_order_submitted();
396
397 assert_eq!(order_submitted.id(), order_submitted.event_id);
398 assert_eq!(order_submitted.kind(), "OrderSubmitted");
399 assert_eq!(order_submitted.order_type(), None);
400 assert_eq!(order_submitted.order_side(), None);
401 assert_eq!(order_submitted.trader_id(), TraderId::from("TRADER-001"));
402 assert_eq!(order_submitted.strategy_id(), StrategyId::from("EMA-CROSS"));
403 assert_eq!(
404 order_submitted.instrument_id(),
405 InstrumentId::from("EURUSD.SIM")
406 );
407 assert_eq!(order_submitted.trade_id(), None);
408 assert_eq!(order_submitted.currency(), None);
409 assert_eq!(
410 order_submitted.client_order_id(),
411 ClientOrderId::from("O-19700101-000000-001-001-1")
412 );
413 assert_eq!(order_submitted.reason(), None);
414 assert_eq!(order_submitted.quantity(), None);
415 assert_eq!(order_submitted.time_in_force(), None);
416 assert_eq!(order_submitted.liquidity_side(), None);
417 assert_eq!(order_submitted.post_only(), None);
418 assert_eq!(order_submitted.reduce_only(), None);
419 assert_eq!(order_submitted.quote_quantity(), None);
420 assert!(!order_submitted.reconciliation());
421 assert_eq!(order_submitted.venue_order_id(), None);
422 assert_eq!(
423 order_submitted.account_id(),
424 Some(AccountId::from("SIM-001"))
425 );
426 assert_eq!(order_submitted.position_id(), None);
427 assert_eq!(order_submitted.commission(), None);
428 assert_eq!(order_submitted.ts_event(), UnixNanos::from(1_000_000_000));
429 assert_eq!(order_submitted.ts_init(), UnixNanos::from(2_000_000_000));
430 }
431
432 #[rstest]
433 fn test_order_submitted_timestamps() {
434 let order_submitted = create_test_order_submitted();
435
436 assert_eq!(order_submitted.ts_event, UnixNanos::from(1_000_000_000));
437 assert_eq!(order_submitted.ts_init, UnixNanos::from(2_000_000_000));
438 assert!(order_submitted.ts_event < order_submitted.ts_init);
439 }
440
441 #[rstest]
442 fn test_order_submitted_serialization() {
443 let original = create_test_order_submitted();
444
445 let json = serde_json::to_string(&original).unwrap();
446 let deserialized: OrderSubmitted = serde_json::from_str(&json).unwrap();
447
448 assert_eq!(original, deserialized);
449 }
450
451 #[rstest]
452 fn test_order_submitted_different_strategies() {
453 let mut ema_strategy = create_test_order_submitted();
454 ema_strategy.strategy_id = StrategyId::from("EMA-CROSS");
455
456 let mut rsi_strategy = create_test_order_submitted();
457 rsi_strategy.strategy_id = StrategyId::from("RSI-MEAN-REVERSION");
458
459 assert_ne!(ema_strategy, rsi_strategy);
460 assert_eq!(ema_strategy.strategy_id, StrategyId::from("EMA-CROSS"));
461 assert_eq!(
462 rsi_strategy.strategy_id,
463 StrategyId::from("RSI-MEAN-REVERSION")
464 );
465 }
466
467 #[rstest]
468 fn test_order_submitted_different_traders() {
469 let mut trader1 = create_test_order_submitted();
470 trader1.trader_id = TraderId::from("TRADER-001");
471
472 let mut trader2 = create_test_order_submitted();
473 trader2.trader_id = TraderId::from("TRADER-002");
474
475 assert_ne!(trader1, trader2);
476 assert_eq!(trader1.trader_id, TraderId::from("TRADER-001"));
477 assert_eq!(trader2.trader_id, TraderId::from("TRADER-002"));
478 }
479
480 #[rstest]
481 fn test_order_submitted_different_instruments() {
482 let mut fx_order = create_test_order_submitted();
483 fx_order.instrument_id = InstrumentId::from("EURUSD.SIM");
484
485 let mut crypto_order = create_test_order_submitted();
486 crypto_order.instrument_id = InstrumentId::from("BTCUSD.COINBASE");
487
488 assert_ne!(fx_order, crypto_order);
489 assert_eq!(fx_order.instrument_id, InstrumentId::from("EURUSD.SIM"));
490 assert_eq!(
491 crypto_order.instrument_id,
492 InstrumentId::from("BTCUSD.COINBASE")
493 );
494 }
495}