nautilus_execution/messages/
submit.rs1use std::fmt::Display;
17
18use nautilus_core::{UnixNanos, UUID4};
19use nautilus_model::{
20 identifiers::{
21 ClientId, ClientOrderId, ExecAlgorithmId, InstrumentId, PositionId, StrategyId, TraderId,
22 VenueOrderId,
23 },
24 orders::OrderAny,
25};
26use serde::{Deserialize, Serialize};
27
28#[derive(Clone, PartialEq, Eq, Debug, Serialize, Deserialize)]
30#[serde(tag = "type")]
32pub struct SubmitOrder {
33 pub trader_id: TraderId,
34 pub client_id: ClientId,
35 pub strategy_id: StrategyId,
36 pub instrument_id: InstrumentId,
37 pub client_order_id: ClientOrderId,
38 pub venue_order_id: VenueOrderId,
39 pub order: OrderAny,
40 pub exec_algorith_id: Option<ExecAlgorithmId>,
41 pub position_id: Option<PositionId>,
42 pub command_id: UUID4,
43 pub ts_init: UnixNanos,
44}
45
46impl SubmitOrder {
47 #[allow(clippy::too_many_arguments)]
49 pub const fn new(
50 trader_id: TraderId,
51 client_id: ClientId,
52 strategy_id: StrategyId,
53 instrument_id: InstrumentId,
54 client_order_id: ClientOrderId,
55 venue_order_id: VenueOrderId,
56 order: OrderAny,
57 exec_algorith_id: Option<ExecAlgorithmId>,
58 position_id: Option<PositionId>,
59 command_id: UUID4,
60 ts_init: UnixNanos,
61 ) -> anyhow::Result<Self> {
62 Ok(Self {
63 trader_id,
64 client_id,
65 strategy_id,
66 instrument_id,
67 client_order_id,
68 venue_order_id,
69 order,
70 exec_algorith_id,
71 position_id,
72 command_id,
73 ts_init,
74 })
75 }
76}
77
78impl Display for SubmitOrder {
79 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
80 write!(
81 f,
82 "SubmitOrder(instrument_id={}, order=TBD, position_id={})",
83 self.instrument_id,
84 self.position_id
85 .map_or("None".to_string(), |position_id| format!("{position_id}")),
86 )
87 }
88}
89
90#[cfg(test)]
94mod tests {}