nautilus_model/events/order/spec/
modify_rejected.rs1use nautilus_core::{UUID4, UnixNanos};
17use ustr::Ustr;
18
19use crate::{
20 events::OrderModifyRejected,
21 identifiers::{AccountId, ClientOrderId, InstrumentId, StrategyId, TraderId, VenueOrderId},
22 stubs::{TestDefault, test_uuid},
23};
24
25#[derive(Debug, Clone, bon::Builder)]
31#[builder(finish_fn = into_spec)]
32pub struct OrderModifyRejectedSpec {
33 #[builder(default = TraderId::test_default())]
34 pub trader_id: TraderId,
35 #[builder(default = StrategyId::test_default())]
36 pub strategy_id: StrategyId,
37 #[builder(default = InstrumentId::test_default())]
38 pub instrument_id: InstrumentId,
39 #[builder(default = ClientOrderId::test_default())]
40 pub client_order_id: ClientOrderId,
41 #[builder(default = Ustr::from("TEST"))]
42 pub reason: Ustr,
43 #[builder(default = test_uuid())]
44 pub event_id: UUID4,
45 #[builder(default = UnixNanos::default())]
46 pub ts_event: UnixNanos,
47 #[builder(default = UnixNanos::default())]
48 pub ts_init: UnixNanos,
49 #[builder(default = false)]
50 pub reconciliation: bool,
51 pub venue_order_id: Option<VenueOrderId>,
52 pub account_id: Option<AccountId>,
53}
54
55impl<S: order_modify_rejected_spec_builder::IsComplete> OrderModifyRejectedSpecBuilder<S> {
56 #[must_use]
58 pub fn build(self) -> OrderModifyRejected {
59 let spec = self.into_spec();
60 OrderModifyRejected::new(
61 spec.trader_id,
62 spec.strategy_id,
63 spec.instrument_id,
64 spec.client_order_id,
65 spec.reason,
66 spec.event_id,
67 spec.ts_event,
68 spec.ts_init,
69 spec.reconciliation,
70 spec.venue_order_id,
71 spec.account_id,
72 )
73 }
74}
75
76#[cfg(test)]
77mod tests {
78 use rstest::rstest;
79
80 use super::*;
81 use crate::stubs::reset_test_uuid_rng;
82
83 #[rstest]
84 fn defaults_are_sensible() {
85 let event = OrderModifyRejectedSpec::builder().build();
88 assert_eq!(event.trader_id, TraderId::test_default());
89 assert_eq!(event.strategy_id, StrategyId::test_default());
90 assert_eq!(event.instrument_id, InstrumentId::test_default());
91 assert_eq!(event.client_order_id, ClientOrderId::test_default());
92 assert_eq!(event.reason, Ustr::from("TEST"));
93 assert_eq!(event.ts_event, UnixNanos::default());
94 assert_eq!(event.ts_init, UnixNanos::default());
95 assert_eq!(event.reconciliation, 0);
96 assert_eq!(event.venue_order_id, None);
97 assert_eq!(event.account_id, None);
98 }
99
100 #[rstest]
101 fn overrides_apply_through_constructor() {
102 let event = OrderModifyRejectedSpec::builder()
103 .reason(Ustr::from("ORDER_DOES_NOT_EXIST"))
104 .venue_order_id(VenueOrderId::from("V-1"))
105 .account_id(AccountId::from("SIM-002"))
106 .reconciliation(true)
107 .build();
108
109 assert_eq!(event.reason, Ustr::from("ORDER_DOES_NOT_EXIST"));
110 assert_eq!(event.venue_order_id, Some(VenueOrderId::from("V-1")));
111 assert_eq!(event.account_id, Some(AccountId::from("SIM-002")));
112 assert_eq!(event.reconciliation, 1);
114 assert_eq!(event.trader_id, TraderId::test_default());
115 }
116
117 #[rstest]
118 fn event_ids_are_unique_within_a_run() {
119 reset_test_uuid_rng();
120 let a = OrderModifyRejectedSpec::builder().build();
121 let b = OrderModifyRejectedSpec::builder().build();
122 let c = OrderModifyRejectedSpec::builder().build();
123 assert_ne!(a.event_id, b.event_id);
124 assert_ne!(b.event_id, c.event_id);
125 assert_ne!(a.event_id, c.event_id);
126 }
127
128 #[rstest]
129 fn event_id_sequence_is_reproducible() {
130 reset_test_uuid_rng();
132 let first_run: Vec<_> = (0..3)
133 .map(|_| OrderModifyRejectedSpec::builder().build().event_id)
134 .collect();
135
136 reset_test_uuid_rng();
137 let second_run: Vec<_> = (0..3)
138 .map(|_| OrderModifyRejectedSpec::builder().build().event_id)
139 .collect();
140
141 assert_eq!(first_run, second_run);
142 }
143}